Log Message:
-----------
A reference to last_sync_group_size was missed; added it back

And some reindentation...

Modified Files:
--------------
    slony1-engine/src/slon:
        remote_worker.c (r1.70 -> r1.71)

-------------- next part --------------
Index: remote_worker.c
===================================================================
RCS file: /usr/local/cvsroot/slony1/slony1-engine/src/slon/remote_worker.c,v
retrieving revision 1.70
retrieving revision 1.71
diff -Lsrc/slon/remote_worker.c -Lsrc/slon/remote_worker.c -u -w -r1.70 -r1.71
--- src/slon/remote_worker.c
+++ src/slon/remote_worker.c
@@ -220,7 +220,6 @@
 int			last_sync_length;
 int			max_sync;
 int			min_sync;
-
 /*
  * ---------- Local functions ----------
  */
@@ -472,6 +471,7 @@
 				}
 
 				gettimeofday(&sync_start, NULL);
+
 				pthread_mutex_lock(&(node->message_lock));
 				while (sync_group_size < next_sync_group_size && node->message_head != NULL)
 				{
@@ -485,6 +485,7 @@
 					event = (SlonWorkMsg_event *) (node->message_head);
 					sync_group[sync_group_size++] = event;
 					DLLIST_REMOVE(node->message_head, node->message_tail, msg);
+					last_sync_group_size ++;
 				}
 				pthread_mutex_unlock(&(node->message_lock));
 			}