Searched refs:qID (Results 1 – 5 of 5) sorted by relevance
24 Status CachePerfMsg::Send(int32_t qID) { in Send() argument25 …auto err = msgsnd(qID, reinterpret_cast<void *>(&small_msg_), sizeof(small_msg_.body.msg), IPC_NOW… in Send()33 Status CachePerfMsg::Receive(int32_t qID) { in Receive() argument36 …auto err = msgrcv(qID, reinterpret_cast<void *>(&small_msg_), sizeof(small_msg_.body.msg), 0, MSG_… in Receive()
63 Status Send(int32_t qID);71 Status Receive(int32_t qID);
357 int32_t qID = msg_recv_lists_[workerId]; in ListenToPipeline() local361 RETURN_IF_NOT_OK(msg.Receive(qID)); in ListenToPipeline()
468 explicit ServerStopRequest(int32_t qID) : BaseRequest(RequestType::kStopService) { in ServerStopRequest() argument469 rq_.add_buf_data(std::to_string(qID)); in ServerStopRequest()
131 for (int32_t qID : shutdown_qIDs_) { in DoServiceStop() local132 SharedMessage msg(qID); in DoServiceStop()1175 int32_t qID = std::stoi(rq->buf_data(0)); in AcknowledgeShutdown() local1176 shutdown_qIDs_.push_back(qID); in AcknowledgeShutdown()