diff --git a/include/spore/types/Config.h b/include/spore/types/Config.h index c9ca59e..fc3bf35 100644 --- a/include/spore/types/Config.h +++ b/include/spore/types/Config.h @@ -15,6 +15,7 @@ public: // Cluster Configuration unsigned long discovery_interval_ms; unsigned long heartbeat_interval_ms; + unsigned long cluster_listen_interval_ms; unsigned long status_update_interval_ms; unsigned long member_info_update_interval_ms; unsigned long print_interval_ms; diff --git a/src/spore/core/ClusterManager.cpp b/src/spore/core/ClusterManager.cpp index f413086..4746488 100644 --- a/src/spore/core/ClusterManager.cpp +++ b/src/spore/core/ClusterManager.cpp @@ -15,7 +15,7 @@ ClusterManager::ClusterManager(NodeContext& ctx, TaskManager& taskMgr) : ctx(ctx void ClusterManager::registerTasks() { taskManager.registerTask("cluster_discovery", ctx.config.discovery_interval_ms, [this]() { sendDiscovery(); }); - taskManager.registerTask("cluster_listen", ctx.config.discovery_interval_ms / 10, [this]() { listen(); }); + taskManager.registerTask("cluster_listen", ctx.config.cluster_listen_interval_ms, [this]() { listen(); }); taskManager.registerTask("status_update", ctx.config.status_update_interval_ms, [this]() { updateAllNodeStatuses(); removeDeadNodes(); }); taskManager.registerTask("print_members", ctx.config.print_interval_ms, [this]() { printMemberList(); }); taskManager.registerTask("heartbeat", ctx.config.heartbeat_interval_ms, [this]() { heartbeatTaskCallback(); }); diff --git a/src/spore/types/Config.cpp b/src/spore/types/Config.cpp index e36ac3f..f4d9ace 100644 --- a/src/spore/types/Config.cpp +++ b/src/spore/types/Config.cpp @@ -10,10 +10,11 @@ Config::Config() { api_server_port = 80; // Cluster Configuration - discovery_interval_ms = 1000; + discovery_interval_ms = 1000; // TODO retire this in favor of heartbeat_interval_ms + cluster_listen_interval_ms = 10; heartbeat_interval_ms = 5000; status_update_interval_ms = 1000; - member_info_update_interval_ms = 10000; + member_info_update_interval_ms = 10000; // TODO retire this in favor of heartbeat_interval_ms print_interval_ms = 5000; // Node Status Thresholds