Searched refs:m_SrvId (Results 1 – 8 of 8) sorted by relevance
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netcache/ |
H A D | peer_control.cpp | 177 res += NStr::NumericToString(Uint2(ctrl->m_SrvId)); in GetPeerNameOrEmpty() 184 : m_SrvId(srv_id), in CNCPeerControl() 185 m_HostIP( Uint4(m_SrvId >> 32)), in CNCPeerControl() 207 string hostport( CNCDistributionConf::GetPeerNameOrEmpty(m_SrvId)); in CNCPeerControl() 216 m_HostAlias = CNCDistributionConf::CreateHostAlias(m_HostIP, Uint4(m_SrvId)); in CNCPeerControl() 269 << CNCDistributionConf::GetFullPeerName(m_SrvId) << " is throttled"); in CreateNewSocket() 281 << CNCDistributionConf::GetFullPeerName(m_SrvId)); in CreateNewSocket() 296 if (!proxy->Connect(m_HostIP, Uint2(m_SrvId))) { in CreateNewSocket() 432 CNCActiveHandler* conn = new CNCActiveHandler(m_SrvId, this); in x_CreateNewConn() 956 << CNCDistributionConf::GetFullPeerName(m_SrvId) << " completed"); in x_SrvInitiallySynced() [all …]
|
H A D | peer_control.hpp | 213 Uint8 m_SrvId; member in CNCPeerControl 284 return m_SrvId; in GetSrvId()
|
H A D | periodic_sync.cpp | 773 m_SrvId = m_SlotSrv->peer->GetSrvId(); in x_DoPeriodicSync() 795 .PrintParam("srv_id", m_SrvId) in x_DoPeriodicSync() 799 CNCSyncLog::GetLastSyncedRecNo(m_SrvId, m_Slot, in x_DoPeriodicSync() 969 CNCDistributionConf::GetSelfID(), m_SrvId, m_Slot, in x_FinishSync() 1001 if (CNCSyncLog::GetSyncOperations(m_SrvId, m_Slot, in x_PrepareSyncByEvents() 1031 CNCSyncLog::GetSyncOperations(m_SrvId, m_Slot, in x_PrepareSyncByEvents() 1349 CNCSyncLog::SetLastSyncRecNo(m_SrvId, m_Slot, in x_DoFinalize() 1512 … ).WriteText(iss).WriteText(CNCDistributionConf::GetPeerName( (*c)->m_SrvId)).WriteText("\""); in PrintState()
|
H A D | active_handler.hpp | 264 return m_SrvId; in GetSrvId() 346 Uint8 m_SrvId; member in CNCActiveHandler
|
H A D | message_handler.cpp | 2162 m_SrvId = NStr::StringToUInt8(val); in x_AssignCmdParams() 2400 m_SrvId, m_Slot, in x_StartCommand() 2987 CNCPeriodicSync::SyncCommandFinished(m_SrvId, m_Slot, m_SyncId); in x_CleanCmdResources() 2989 CNCPeriodicSync::Cancel(m_SrvId, m_Slot, m_SyncId); in x_CleanCmdResources() 3327 << m_SrvId << ": " << m_ChunkLen); in x_ReadBlobChunkLength() 4521 ESyncInitiateResult sync_res = CNCPeriodicSync::Initiate(m_SrvId, m_Slot, in x_DoCmd_SyncStart() 4537 if (CNCStat::AddUnknownServer(m_SrvId)) { in x_DoCmd_SyncStart() 4538 SRV_LOG(Warning, "SYNC_START request from unknown server " << m_SrvId); in x_DoCmd_SyncStart() 4565 if (!CNCPeerControl::Peer(m_SrvId)->AcceptsBlobKey(evt->key)) { in x_DoCmd_SyncStart() 4608 CNCPeriodicSync::MarkCurSyncByBlobs(m_SrvId, m_Slot, m_SyncId); in x_DoCmd_SyncBlobsList() [all …]
|
H A D | periodic_sync.hpp | 308 Uint8 m_SrvId; member in CNCActiveSyncControl
|
H A D | message_handler.hpp | 355 Uint8 m_SrvId; member in CNCMessageHandler
|
H A D | active_handler.cpp | 153 : m_SrvId(srv_id), in CNCActiveHandler() 1301 << CNCDistributionConf::GetFullPeerName(m_SrvId) << ": " in x_ProcessProtocolError() 1578 << CNCDistributionConf::GetFullPeerName(m_SrvId) << ": " in x_ReadSizeToRead() 1591 << CNCDistributionConf::GetFullPeerName(m_SrvId) << ": " in x_ReadSizeToRead()
|