Lines Matching refs:rsp
128 OutputRsp rsp; in WriteQueryResponse() local
130 rsp.end = true; // tell client it's the last messsage in WriteQueryResponse()
131 return m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in WriteQueryResponse()
134 rsp.len = data.len; /* data len, equals tag_len plus content length, include '\0' */ in WriteQueryResponse()
135 rsp.level = data.level; in WriteQueryResponse()
136 rsp.type = data.type; in WriteQueryResponse()
137 rsp.tagLen = data.tag_len; /* include '\0' */ in WriteQueryResponse()
138 rsp.pid = data.pid; in WriteQueryResponse()
139 rsp.tid = data.tid; in WriteQueryResponse()
140 rsp.domain = data.domain; in WriteQueryResponse()
141 rsp.tv_sec = data.tv_sec; in WriteQueryResponse()
142 rsp.tv_nsec = data.tv_nsec; in WriteQueryResponse()
143 rsp.mono_sec = data.mono_sec; in WriteQueryResponse()
144 rsp.end = false; in WriteQueryResponse()
147 vec[0].iov_base = &rsp; in WriteQueryResponse()
154 static void StatsEntry2StatsRsp(const StatsEntry &entry, StatsRsp &rsp) in StatsEntry2StatsRsp() argument
159 rsp.lines[i] = entry.lines[i]; in StatsEntry2StatsRsp()
160 rsp.len[i] = entry.len[i]; in StatsEntry2StatsRsp()
162 rsp.dropped = entry.dropped; in StatsEntry2StatsRsp()
163 rsp.freqMax = entry.GetFreqMax(); in StatsEntry2StatsRsp()
164 rsp.freqMaxSec = entry.realTimeFreqMax.tv_sec; in StatsEntry2StatsRsp()
165 rsp.freqMaxNsec = entry.realTimeFreqMax.tv_nsec; in StatsEntry2StatsRsp()
166 rsp.throughputMax = entry.GetThroughputMax(); in StatsEntry2StatsRsp()
167 rsp.tpMaxSec = entry.realTimeThroughputMax.tv_sec; in StatsEntry2StatsRsp()
168 rsp.tpMaxNsec = entry.realTimeThroughputMax.tv_nsec; in StatsEntry2StatsRsp()
173 StatsQueryRsp rsp; in SendOverallStats() local
177 rsp.tsBeginSec = tsBegin.tv_sec; in SendOverallStats()
178 rsp.tsBeginNsec = tsBegin.tv_nsec; in SendOverallStats()
182 rsp.durationSec = monoNow.tv_sec; in SendOverallStats()
183 rsp.durationNsec = monoNow.tv_nsec; in SendOverallStats()
184 stats.GetTotalLines(rsp.totalLines); in SendOverallStats()
185 stats.GetTotalLens(rsp.totalLens); in SendOverallStats()
186 rsp.typeNum = 0; in SendOverallStats()
191 rsp.typeNum++; in SendOverallStats()
193 rsp.ldStats = nullptr; in SendOverallStats()
194 rsp.procNum = pTable.size(); in SendOverallStats()
195 rsp.pStats = nullptr; in SendOverallStats()
196 m_communicationSocket->Write(reinterpret_cast<char *>(&rsp), sizeof(StatsQueryRsp)); in SendOverallStats()
612 PersistStartRsp rsp = { msg.jobId }; in HandlePersistStartRqst() local
613 WriteRspHeader(IoctlCmd::PERSIST_START_RSP, sizeof(rsp)); in HandlePersistStartRqst()
614 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandlePersistStartRqst()
619 PersistStopRsp rsp = { 0 }; in HandlePersistStopRqst() local
626 for (auto it = resultList.begin(); it != resultList.end() && rsp.jobNum < MAX_JOBS; ++it) { in HandlePersistStopRqst()
630 rsp.jobId[rsp.jobNum] = jobId; in HandlePersistStopRqst()
631 rsp.jobNum++; in HandlePersistStopRqst()
634 if (rsp.jobNum == 0) { in HandlePersistStopRqst()
638 WriteRspHeader(IoctlCmd::PERSIST_STOP_RSP, sizeof(rsp)); in HandlePersistStopRqst()
639 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandlePersistStopRqst()
650 PersistQueryRsp rsp = { 0 }; in HandlePersistQueryRqst() local
651 for (auto it = resultList.begin(); it != resultList.end() && rsp.jobNum < MAX_JOBS; ++it) { in HandlePersistQueryRqst()
652 PersistTaskInfo &task = rsp.taskInfo[rsp.jobNum]; in HandlePersistQueryRqst()
660 rsp.jobNum++; in HandlePersistQueryRqst()
662 WriteRspHeader(IoctlCmd::PERSIST_QUERY_RSP, sizeof(rsp)); in HandlePersistQueryRqst()
663 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandlePersistQueryRqst()
674 BufferSizeGetRsp rsp = { 0 }; in HandleBufferSizeGetRqst() local
677 rsp.size[t] = static_cast<uint32_t>(m_hilogBuffer.GetBuffLen(t)); in HandleBufferSizeGetRqst()
685 WriteRspHeader(IoctlCmd::BUFFERSIZE_GET_RSP, sizeof(rsp)); in HandleBufferSizeGetRqst()
686 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleBufferSizeGetRqst()
697 BufferSizeSetRsp rsp = { 0 }; in HandleBufferSizeSetRqst() local
702 rsp.size[t] = ret; in HandleBufferSizeSetRqst()
705 rsp.size[t] = rqst.size; in HandleBufferSizeSetRqst()
714 WriteRspHeader(IoctlCmd::BUFFERSIZE_SET_RSP, sizeof(rsp)); in HandleBufferSizeSetRqst()
715 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleBufferSizeSetRqst()
744 StatsClearRsp rsp = { 0 }; in HandleStatsClearRqst() local
745 WriteRspHeader(IoctlCmd::STATS_CLEAR_RSP, sizeof(rsp)); in HandleStatsClearRqst()
746 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleStatsClearRqst()
754 DomainFlowCtrlRsp rsp = { 0 }; in HandleDomainFlowCtrlRqst() local
755 WriteRspHeader(IoctlCmd::DOMAIN_FLOWCTRL_RSP, sizeof(rsp)); in HandleDomainFlowCtrlRqst()
756 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleDomainFlowCtrlRqst()
767 LogRemoveRsp rsp = { types }; in HandleLogRemoveRqst() local
778 WriteRspHeader(IoctlCmd::LOG_REMOVE_RSP, sizeof(rsp)); in HandleLogRemoveRqst()
779 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleLogRemoveRqst()
793 KmsgEnableRsp rsp = { 0 }; in HandleLogKmsgEnableRqst() local
794 WriteRspHeader(IoctlCmd::KMSG_ENABLE_RSP, sizeof(rsp)); in HandleLogKmsgEnableRqst()
795 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp)); in HandleLogKmsgEnableRqst()