Home
last modified time | relevance | path

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 Dpeer_control.cpp177 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 Dpeer_control.hpp213 Uint8 m_SrvId; member in CNCPeerControl
284 return m_SrvId; in GetSrvId()
H A Dperiodic_sync.cpp773 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 Dactive_handler.hpp264 return m_SrvId; in GetSrvId()
346 Uint8 m_SrvId; member in CNCActiveHandler
H A Dmessage_handler.cpp2162 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 Dperiodic_sync.hpp308 Uint8 m_SrvId; member in CNCActiveSyncControl
H A Dmessage_handler.hpp355 Uint8 m_SrvId; member in CNCMessageHandler
H A Dactive_handler.cpp153 : 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()