MCPcopy Create free account
hub / github.com/Dstack-TEE/dstack / sync_connections

Method sync_connections

gateway/src/main_service.rs:1346–1350  ·  view source on GitHub ↗

Sync connection count for an instance to KvStore

(&self, instance_id: &str, count: u64)

Source from the content-addressed store, hash-verified

1344
1345 /// Sync connection count for an instance to KvStore
1346 pub(crate) fn sync_connections(&self, instance_id: &str, count: u64) {
1347 if let Err(err) = self.kv_store.sync_connections(instance_id, count) {
1348 debug!("Failed to sync connections: {err:?}");
1349 }
1350 }
1351
1352 /// Get latest handshake for an instance from KvStore (max across all nodes)
1353 pub(crate) fn get_instance_latest_handshake(&self, instance_id: &str) -> Option<u64> {

Callers 1

start_wavekv_watch_taskFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected