|
@@ -570,6 +570,7 @@ void sync_v2_start (
|
|
|
size_t member_list_entries,
|
|
size_t member_list_entries,
|
|
|
const struct memb_ring_id *ring_id)
|
|
const struct memb_ring_id *ring_id)
|
|
|
{
|
|
{
|
|
|
|
|
+ ENTER();
|
|
|
memcpy (&my_ring_id, ring_id, sizeof (struct memb_ring_id));
|
|
memcpy (&my_ring_id, ring_id, sizeof (struct memb_ring_id));
|
|
|
|
|
|
|
|
if (my_memb_determine) {
|
|
if (my_memb_determine) {
|
|
@@ -587,7 +588,7 @@ void sync_v2_save_transitional (
|
|
|
size_t member_list_entries,
|
|
size_t member_list_entries,
|
|
|
const struct memb_ring_id *ring_id)
|
|
const struct memb_ring_id *ring_id)
|
|
|
{
|
|
{
|
|
|
- log_printf (LOGSYS_LEVEL_DEBUG, "saving transitional configuration\n");
|
|
|
|
|
|
|
+ ENTER();
|
|
|
memcpy (my_trans_list, member_list, member_list_entries *
|
|
memcpy (my_trans_list, member_list, member_list_entries *
|
|
|
sizeof (unsigned int));
|
|
sizeof (unsigned int));
|
|
|
my_trans_list_entries = member_list_entries;
|
|
my_trans_list_entries = member_list_entries;
|
|
@@ -595,6 +596,7 @@ void sync_v2_save_transitional (
|
|
|
|
|
|
|
|
void sync_v2_abort (void)
|
|
void sync_v2_abort (void)
|
|
|
{
|
|
{
|
|
|
|
|
+ ENTER();
|
|
|
if (my_state == SYNC_PROCESS) {
|
|
if (my_state == SYNC_PROCESS) {
|
|
|
schedwrk_destroy (my_schedwrk_handle);
|
|
schedwrk_destroy (my_schedwrk_handle);
|
|
|
my_service_list[my_processing_idx].sync_abort ();
|
|
my_service_list[my_processing_idx].sync_abort ();
|
|
@@ -608,6 +610,7 @@ void sync_v2_abort (void)
|
|
|
|
|
|
|
|
void sync_v2_memb_list_determine (const struct memb_ring_id *ring_id)
|
|
void sync_v2_memb_list_determine (const struct memb_ring_id *ring_id)
|
|
|
{
|
|
{
|
|
|
|
|
+ ENTER();
|
|
|
memcpy (&my_memb_determine_ring_id, ring_id,
|
|
memcpy (&my_memb_determine_ring_id, ring_id,
|
|
|
sizeof (struct memb_ring_id));
|
|
sizeof (struct memb_ring_id));
|
|
|
|
|
|
|
@@ -616,6 +619,7 @@ void sync_v2_memb_list_determine (const struct memb_ring_id *ring_id)
|
|
|
|
|
|
|
|
void sync_v2_memb_list_abort (void)
|
|
void sync_v2_memb_list_abort (void)
|
|
|
{
|
|
{
|
|
|
|
|
+ ENTER();
|
|
|
my_memb_determine_list_entries = 0;
|
|
my_memb_determine_list_entries = 0;
|
|
|
memset (&my_memb_determine_ring_id, 0, sizeof (struct memb_ring_id));
|
|
memset (&my_memb_determine_ring_id, 0, sizeof (struct memb_ring_id));
|
|
|
}
|
|
}
|