test: ci skip: try shorter protocol time

flowerinthenight · Sep 23, 2024 · 49cf62c · 49cf62c
1 parent d83bf6b
commit 49cf62c
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 7 deletions.
diff --git a/src/main.zig b/src/main.zig
@@ -73,6 +73,8 @@ pub fn main() !void {
     var config = Fleet.Config{
         .name = name,
         .ip = member[0..sep],
+        .protocol_time = std.time.ns_per_s * 1,
+        .suspected_time = std.time.ns_per_s * 1,
         .callbacks = callbacks,
     };
 

diff --git a/src/zgroup.zig b/src/zgroup.zig
@@ -561,13 +561,6 @@ pub fn Fleet(UserData: type) type {
                     defer self.members_mtx.unlock();
                     var it = self.members.iterator();
                     while (it.next()) |v| {
-                        log.debug("[{d}] members: key={s}, state={any}, inc={d}", .{
-                            i,
-                            v.key_ptr.*,
-                            v.value_ptr.state,
-                            v.value_ptr.incarnation,
-                        });
-
                         if (self.keyIsMe(v.key_ptr.*)) {
                             if (v.value_ptr.state != .alive) {
                                 v.value_ptr.state = .alive;
@@ -589,6 +582,15 @@ pub fn Fleet(UserData: type) type {
                     });
                 }
 
+                const counts = self.getCounts();
+                log.debug("[{d}] members: alive={d}, suspected={d}, faulty={d}, total={d}", .{
+                    i,
+                    counts[0],
+                    counts[1],
+                    counts[2],
+                    counts[3],
+                });
+
                 try self.removeFaultyMembers();
 
                 var key_ptr: ?[]const u8 = null;