Lines Matching refs:m_Server
614 m_Server(server), in CNetScheduleHandler()
638 STimeout to = {m_Server->GetInactivityTimeout(), 0}; in OnOpen()
647 if (m_Server->IsLog()) { in OnOpen()
662 m_Server->DecrementCurrentSubmitsCounter(); in OnClose()
766 if (m_Server->ShutdownRequested()) { in OnMessage()
772 m_Server->CloseConnection(&GetSocket()); in OnMessage()
796 m_Server->CloseConnection(&GetSocket()); in OnMessage()
874 SErrorEmulatorParameter err_emul = m_Server->GetDebugWriteDelay(); in x_PrepareWriteBuffer()
884 err_emul = m_Server->GetDebugConnDropBeforeWrite(); in x_PrepareWriteBuffer()
887 m_Server->CloseConnection(&GetSocket()); in x_PrepareWriteBuffer()
892 err_emul = m_Server->GetDebugReplyWithGarbage(); in x_PrepareWriteBuffer()
895 string value = m_Server->GetDebugGarbage(); in x_PrepareWriteBuffer()
950 m_Server->GetDebugConnDropAfterWrite(); in x_WriteMessage()
953 m_Server->CloseConnection(&GetSocket()); in x_WriteMessage()
1005 m_Server->CloseConnection(&GetSocket()); in x_HandleSocketErrorOnResponse()
1017 if (peer_addr == m_Server->GetHostNetAddr()) in x_GetPeerAddress()
1036 m_Server->CloseConnection(&GetSocket()); in x_ProcessMsgAuth()
1073 m_Server->CloseConnection(&GetSocket()); in x_ProcessMsgQueue()
1082 if (m_Server->AdminHostValid(m_ClientId.GetAddress()) && in x_ProcessMsgQueue()
1083 m_Server->IsAdminClientName(m_ClientId.GetClientName())) in x_ProcessMsgQueue()
1107 queue = m_Server->OpenQueue(m_QueueName); in x_ProcessMsgQueue()
1122 m_Server->CloseConnection(&GetSocket()); in x_ProcessMsgQueue()
1160 m_Server->GetCompoundIDPool()); in x_ProcessMsgRequest()
1204 m_Server->OpenQueue( in x_ProcessMsgRequest()
1235 m_ClientId.CheckAccess(extra.checks, m_Server, cmd.command->cmd); in x_ProcessMsgRequest()
1328 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchHeader()
1334 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchHeader()
1346 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchHeader()
1358 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchHeader()
1383 m_Server->GetCompoundIDPool()); in x_ProcessMsgBatchJob()
1387 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchJob()
1393 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchJob()
1406 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchJob()
1420 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchJob()
1472 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchSubmit()
1478 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchSubmit()
1493 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchSubmit()
1546 m_Server->GetHost().c_str() + " " + in x_ProcessMsgBatchSubmit()
1547 to_string(unsigned(m_Server->GetPort())) + in x_ProcessMsgBatchSubmit()
1553 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchSubmit()
1566 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessMsgBatchSubmit()
1797 if (q->GetRefuseSubmits() || m_Server->GetRefuseSubmits()) { in x_ProcessSubmit()
1804 if (m_Server->IncrementCurrentSubmitsCounter() < in x_ProcessSubmit()
1807 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessSubmit()
1833 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessSubmit()
1835 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessSubmit()
1847 if (q->GetRefuseSubmits() || m_Server->GetRefuseSubmits()) { in x_ProcessSubmitBatch()
1854 if (m_Server->IncrementCurrentSubmitsCounter() < in x_ProcessSubmitBatch()
1857 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessSubmitBatch()
1886 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessSubmitBatch()
1911 m_Server->DecrementCurrentSubmitsCounter(); in x_ProcessBatchSequenceEnd()
2884 string info = m_Server->GetQueueClassesInfo(); in x_ProcessStatistics()
2894 string info = m_Server->GetQueueInfo(); in x_ProcessStatistics()
2906 m_Server->GetServices(services); in x_ProcessStatistics()
2918 string output = m_Server->SerializeAlerts(); in x_ProcessStatistics()
2929 info = m_Server->PrintJobsStat(m_ClientId) + kEndOfResponse; in x_ProcessStatistics()
2932 info = "OK:Started: " + m_Server->GetStartTime().AsString() + in x_ProcessStatistics()
2936 if (m_Server->GetRefuseSubmits()) info += "1"; in x_ProcessStatistics()
2941 if (m_Server->IsDrainShutdown()) info += "1"; in x_ProcessStatistics()
2945 info += m_Server->PrintTransitionCounters() + kEndOfResponse; in x_ProcessStatistics()
2963 m_Server->GetStartTime().AsString() + kEndOfResponse; in x_ProcessStatistics()
2966 if (m_Server->GetRefuseSubmits() || q->GetRefuseSubmits()) info += "1"; in x_ProcessStatistics()
3006 if (!m_Server->IsAdminClientName(m_ClientId.GetClientName()) && in x_ProcessReloadConfig()
3007 !m_Server->AnybodyCanReconfigure()) { in x_ProcessReloadConfig()
3008 m_Server->RegisterAlert(eAccess, "admin privileges required " in x_ProcessReloadConfig()
3022 if (reloaded || m_Server->AnybodyCanReconfigure()) { in x_ProcessReloadConfig()
3041 m_Server->RegisterAlert(eReconfigure, alert_msg); in x_ProcessReloadConfig()
3061 m_Server->SetRAMConfigFileChecksum(config_checksum); in x_ProcessReloadConfig()
3062 m_Server->SetDiskConfigFileChecksum(config_checksum); in x_ProcessReloadConfig()
3074 CJsonNode what_changed = m_Server->SetNSParameters(params, true); in x_ProcessReloadConfig()
3075 CJsonNode services_changed = m_Server->ReadServicesConfig(reg); in x_ProcessReloadConfig()
3078 m_Server->Configure(reg, diff); in x_ProcessReloadConfig()
3079 m_Server->SetAnybodyCanReconfigure(false); in x_ProcessReloadConfig()
3084 m_Server->AcknowledgeAlert(eReconfigure, "NSAcknowledge"); in x_ProcessReloadConfig()
3085 m_Server->AcknowledgeAlert(eConfigOutOfSync, "NSAcknowledge"); in x_ProcessReloadConfig()
3105 m_Server->AcknowledgeAlert(eReconfigure, "NSAcknowledge"); in x_ProcessReloadConfig()
3106 m_Server->AcknowledgeAlert(eConfigOutOfSync, "NSAcknowledge"); in x_ProcessReloadConfig()
3120 string active_jobs = to_string(m_Server->CountActiveJobs()); in x_ProcessActiveCount()
3212 if (m_Server->ShutdownRequested()) { in x_ProcessShutdown()
3219 if (m_Server->IsDrainShutdown()) { in x_ProcessShutdown()
3227 m_Server->SetRefuseSubmits(true); in x_ProcessShutdown()
3228 m_Server->SetDrainShutdown(); in x_ProcessShutdown()
3236 m_Server->SetRefuseSubmits(true); in x_ProcessShutdown()
3237 m_Server->SetShutdownFlag(); in x_ProcessShutdown()
3251 m_Server->GetQueueClassesConfig() + in x_ProcessGetConf()
3252 m_Server->GetQueueConfig() + in x_ProcessGetConf()
3253 m_Server->GetLinkedSectionConfig() + in x_ProcessGetConf()
3254 m_Server->GetServiceToQueueSectionConfig() + in x_ProcessGetConf()
3279 "&ns_node=" + m_Server->GetNodeID() + in x_ProcessVersion()
3280 "&ns_session=" + m_Server->GetSessionID() + in x_ProcessVersion()
3311 SErrorEmulatorParameter err_emul = m_Server->GetDebugFDCount(); in x_ProcessHealth()
3317 err_emul = m_Server->GetDebugMemCount(); in x_ProcessHealth()
3328 m_Server->GetNodeID() + in x_ProcessHealth()
3330 m_Server->GetSessionID() + in x_ProcessHealth()
3332 NStr::URLEncode(m_Server->GetStartTime().AsString()) + in x_ProcessHealth()
3390 string alerts = m_Server->GetAlerts(); in x_ProcessHealth()
3418 m_Server->AcknowledgeAlert(m_CommandArguments.alert, in x_ProcessAckAlert()
3438 x_WriteMessage("OK:" + m_Server->GetQueueNames(";") + kEndOfResponse); in x_ProcessQList()
3445 m_Server->CloseConnection(&GetSocket()); in x_ProcessQuitSession()
3452 m_Server->CreateDynamicQueue( in x_ProcessCreateDynamicQueue()
3466 m_Server->DeleteDynamicQueue(m_ClientId, m_CommandArguments.qname); in x_ProcessDeleteDynamicQueue()
3482 qname = m_Server->ResolveService(m_CommandArguments.service); in x_ProcessQueueInfo()
3493 SQueueParameters params = m_Server->QueueInfo(qname); in x_ProcessQueueInfo()
3504 queue_ref.Reset(m_Server->OpenQueue(qname)); in x_ProcessQueueInfo()
3544 SQueueParameters params = m_Server->QueueInfo( in x_ProcessQueueInfo()
3578 queue_ref.Reset(m_Server->OpenQueue(m_CommandArguments.qname)); in x_ProcessSetQueue()
3640 unsigned int max_slots = m_Server->GetScopeRegistrySettings().max_records; in x_ProcessSetScope()
3947 unsigned int limit = m_Server->GetMaxClientData(); in x_ProcessSetClientData()
4016 (m_Server->IsDrainShutdown() || m_Server->ShutdownRequested())) { in x_ProcessRefuseSubmits()
4027 m_Server->SetRefuseSubmits(m_CommandArguments.mode); in x_ProcessRefuseSubmits()
4029 SerializeRefuseSubmitState(m_Server); in x_ProcessRefuseSubmits()
4039 m_Server->GetRefuseSubmits() == true) in x_ProcessRefuseSubmits()
4044 SerializeRefuseSubmitState(m_Server); in x_ProcessRefuseSubmits()
4552 m_Server->CloseConnection(&GetSocket()); in x_OnCmdParserError()
4606 m_Server->GetParameters(&server_params); in x_GetServerSection()
4616 to_string(m_Server->GetPort()) + "\"\n" in x_GetServerSection()
4618 NStr::BoolToString(m_Server->GetUseHostname()) + "\"\n" in x_GetServerSection()
4620 to_string(m_Server->GetInactivityTimeout()) + "\"\n" in x_GetServerSection()
4622 NStr::BoolToString(m_Server->IsLog()) + "\"\n" in x_GetServerSection()
4624 NStr::BoolToString(m_Server->IsLogBatchEachJob()) + "\"\n" in x_GetServerSection()
4626 NStr::BoolToString(m_Server->IsLogNotificationThread()) + "\"\n" in x_GetServerSection()
4628 NStr::BoolToString(m_Server->IsLogCleaningThread()) + "\"\n" in x_GetServerSection()
4631 m_Server->IsLogExecutionWatcherThread()) + "\"\n" in x_GetServerSection()
4633 NStr::BoolToString(m_Server->IsLogStatisticsThread()) + "\"\n" in x_GetServerSection()
4635 to_string(m_Server->GetDeleteBatchSize()) + "\"\n" in x_GetServerSection()
4637 to_string(m_Server->GetMarkdelBatchSize()) + "\"\n" in x_GetServerSection()
4639 to_string(m_Server->GetScanBatchSize()) + "\"\n" in x_GetServerSection()
4641 to_string(m_Server->GetPurgeTimeout()) + "\"\n" in x_GetServerSection()
4643 to_string(m_Server->GetStatInterval()) + "\"\n" in x_GetServerSection()
4645 to_string(m_Server->GetJobCountersInterval()) + in x_GetServerSection()
4648 to_string(m_Server->GetMaxClientData()) + "\"\n" in x_GetServerSection()
4650 m_Server->GetAdminHosts().GetAsFromConfig() + "\"\n" in x_GetServerSection()
4652 m_Server->GetAdminClientNames() + "\"\n" + in x_GetServerSection()
4654 m_Server->GetStateTransitionPerfLogQueues() + "\"\n" + in x_GetServerSection()
4656 m_Server->GetStateTransitionPerfLogClasses() + "\"\n" + in x_GetServerSection()
4657 m_Server->GetAffRegistrySettings().Serialize("affinity", "", "\n") + in x_GetServerSection()
4658 m_Server->GetGroupRegistrySettings().Serialize("group", "", "\n") + in x_GetServerSection()
4659 m_Server->GetScopeRegistrySettings().Serialize("scope", "", "\n") + in x_GetServerSection()
4661 to_string(m_Server->GetReserveDumpSpace()) + "\"\n"; in x_GetServerSection()