Lines Matching refs:m_ClientId
1000 ref->RegisterSocketWriteError(m_ClientId); in x_HandleSocketErrorOnResponse()
1078 m_ClientId.Update(this->x_GetPeerAddress(), params); in x_ProcessMsgQueue()
1082 if (m_Server->AdminHostValid(m_ClientId.GetAddress()) && in x_ProcessMsgQueue()
1083 m_Server->IsAdminClientName(m_ClientId.GetClientName())) in x_ProcessMsgQueue()
1084 m_ClientId.SetPassedChecks(eNS_Admin); in x_ProcessMsgQueue()
1210 orig_client_passed_checks = m_ClientId.GetPassedChecks(); in x_ProcessMsgRequest()
1211 orig_client_id = m_ClientId.GetID(); in x_ProcessMsgRequest()
1235 m_ClientId.CheckAccess(extra.checks, m_Server, cmd.command->cmd); in x_ProcessMsgRequest()
1246 queue_ptr->TouchClientsRegistry(m_ClientId, client_was_found, in x_ProcessMsgRequest()
1259 .Print("client_node", m_ClientId.GetNode()) in x_ProcessMsgRequest()
1260 .Print("client_session", m_ClientId.GetSession()) in x_ProcessMsgRequest()
1274 m_ClientId.SetPassedChecks(orig_client_passed_checks); in x_ProcessMsgRequest()
1275 m_ClientId.SetID(orig_client_id); in x_ProcessMsgRequest()
1284 m_ClientId.ResetPassedCheck(); in x_UpdateClientPassedChecks()
1290 m_ClientId.SetPassedChecks(eNS_Queue); in x_UpdateClientPassedChecks()
1291 if (!m_ClientId.IsAdmin()) { in x_UpdateClientPassedChecks()
1294 if (q->IsWorkerAllowed(m_ClientId.GetAddress())) in x_UpdateClientPassedChecks()
1295 m_ClientId.SetPassedChecks(eNS_Worker); in x_UpdateClientPassedChecks()
1296 if (q->IsSubmitAllowed(m_ClientId.GetAddress())) in x_UpdateClientPassedChecks()
1297 m_ClientId.SetPassedChecks(eNS_Submitter); in x_UpdateClientPassedChecks()
1298 if (q->IsReaderAllowed(m_ClientId.GetAddress())) in x_UpdateClientPassedChecks()
1299 m_ClientId.SetPassedChecks(eNS_Reader); in x_UpdateClientPassedChecks()
1300 if (q->IsProgramAllowed(m_ClientId.GetProgramName())) in x_UpdateClientPassedChecks()
1301 m_ClientId.SetPassedChecks(eNS_Program); in x_UpdateClientPassedChecks()
1305 q->SetClientScope(m_ClientId); in x_UpdateClientPassedChecks()
1528 unsigned job_id = GetQueue()->SubmitBatch(m_ClientId, in x_ProcessMsgBatchSubmit()
1744 .Print("client_node", m_ClientId.GetNode()) in x_ProcessChangeAffinity()
1745 .Print("client_session", m_ClientId.GetSession()); in x_ProcessChangeAffinity()
1751 list<string> msgs = q->ChangeAffinity(m_ClientId, aff_to_add_list, in x_ProcessChangeAffinity()
1774 .Print("client_node", m_ClientId.GetNode()) in x_ProcessSetAffinity()
1775 .Print("client_session", m_ClientId.GetSession()); in x_ProcessSetAffinity()
1788 q->SetAffinity(m_ClientId, aff_to_set, cmd_group); in x_ProcessSetAffinity()
1824 unsigned int job_id = q->Submit(m_ClientId, job, in x_ProcessSubmit()
2009 m_ClientId, in x_ProcessCancel()
2031 switch (q->Cancel(m_ClientId, in x_ProcessCancel()
2166 q->RegisterQueueResumeNotification(m_ClientId.GetAddress(), in x_ProcessGetJob()
2202 if (q->GetJobOrWait(m_ClientId, in x_ProcessGetJob()
2230 .Print("client_node", m_ClientId.GetNode()) in x_ProcessGetJob()
2231 .Print("client_session", m_ClientId.GetSession()) in x_ProcessGetJob()
2247 q->CancelWaitGet(m_ClientId); in x_ProcessCancelWaitGet()
2257 q->CancelWaitRead(m_ClientId); in x_ProcessCancelWaitRead()
2273 TJobStatus old_status = q->PutResult(m_ClientId, CNSPreciseTime::Current(), in x_ProcessPut()
2344 TJobStatus old_status = q->PutResult(m_ClientId, curr, in x_ProcessJobExchange()
2376 q->RegisterQueueResumeNotification(m_ClientId.GetAddress(), in x_ProcessJobExchange()
2403 if (q->GetJobOrWait(m_ClientId, in x_ProcessJobExchange()
2428 .Print("client_node", m_ClientId.GetNode()) in x_ProcessJobExchange()
2429 .Print("client_session", m_ClientId.GetSession()) in x_ProcessJobExchange()
2492 m_ClientId, in x_ProcessPutFailure()
2555 q->CancelAllJobs(m_ClientId, x_NeedCmdLogging()); in x_ProcessDropQueue()
2578 TJobStatus old_status = q->ReturnJob(m_ClientId, in x_ProcessReturn()
2636 m_ClientId, in x_ProcessReschedule()
2689 TJobStatus old_status = q->RedoJob(m_ClientId, in x_ProcessRedo()
2826 m_ClientId.GetAddress(), in x_ProcessListenJob()
2881 q->MarkClientAsAdmin(m_ClientId); in x_ProcessStatistics()
2929 info = m_Server->PrintJobsStat(m_ClientId) + kEndOfResponse; in x_ProcessStatistics()
3006 if (!m_Server->IsAdminClientName(m_ClientId.GetClientName()) && in x_ProcessReloadConfig()
3179 q->PrintAllJobDbStat(m_ClientId, in x_ProcessDump()
3195 string job_info = q->PrintJobDbStat(m_ClientId, in x_ProcessDump()
3453 m_ClientId, in x_ProcessCreateDynamicQueue()
3466 m_Server->DeleteDynamicQueue(m_ClientId, m_CommandArguments.qname); in x_ProcessDeleteDynamicQueue()
3506 queue_ptr->GetJobsPerState(m_ClientId, "", "", in x_ProcessQueueInfo()
3564 m_ClientId.ResetPassedCheck(); in x_ProcessSetQueue()
3604 queue_ptr->TouchClientsRegistry(m_ClientId, client_was_found, in x_ProcessSetQueue()
3618 .Print("client_node", m_ClientId.GetNode()) in x_ProcessSetQueue()
3619 .Print("client_session", m_ClientId.GetSession()) in x_ProcessSetQueue()
3652 m_ClientId.SetScope(m_CommandArguments.scope); in x_ProcessSetScope()
3653 q->SetClientScope(m_ClientId); in x_ProcessSetScope()
3737 if (q->GetJobForReadingOrWait(m_ClientId, in x_ProcessReading()
3783 .Print("client_node", m_ClientId.GetNode()) in x_ProcessReading()
3784 .Print("client_session", m_ClientId.GetSession()) in x_ProcessReading()
3814 m_ClientId, in x_ProcessConfirm()
3830 m_ClientId, in x_ProcessReadFailed()
3848 m_ClientId, in x_ProcessReadRollback()
3866 TJobStatus old_status = q->RereadJob(m_ClientId, in x_ProcessReread()
3962 int current_data_version = q->SetClientData(m_ClientId, in x_ProcessSetClientData()
3979 q->ClearWorkerNode(m_ClientId, client_found, in x_ProcessClearWorkerNode()
3992 .Print("client_node", m_ClientId.GetNode()) in x_ProcessClearWorkerNode()
3993 .Print("client_session", m_ClientId.GetSession()) in x_ProcessClearWorkerNode()
4007 unsigned int count = q->CancelAllJobs(m_ClientId, x_NeedCmdLogging()); in x_ProcessCancelQueue()
4035 q->MarkClientAsAdmin(m_ClientId); in x_ProcessRefuseSubmits()
4059 q->SetPauseStatus(m_ClientId, new_value); in x_ProcessPause()
4080 q->SetPauseStatus(m_ClientId, CQueue::eNoPause); in x_ProcessResume()
4110 if (!m_ClientId.IsComplete()) in x_CheckNonAnonymousClient()
4572 info = q->PrintAffinitiesList(m_ClientId, verbose); in x_StatisticsNew()
4575 info = q->PrintGroupsList(m_ClientId, verbose); in x_StatisticsNew()
4581 info = q->PrintJobsStat(m_ClientId, in x_StatisticsNew()