Lines Matching refs:rsp
140 OutputRsp rsp;
142 rsp.end = true; // tell client it's the last messsage
143 return m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
146 rsp.len = data.len; /* data len, equals tagLen plus content length, include '\0' */
147 rsp.level = data.level;
148 rsp.type = data.type;
149 rsp.tagLen = data.tagLen; /* include '\0' */
150 rsp.pid = data.pid;
151 rsp.tid = data.tid;
152 rsp.domain = data.domain;
153 rsp.tv_sec = data.tv_sec;
154 rsp.tv_nsec = data.tv_nsec;
155 rsp.mono_sec = data.mono_sec;
156 rsp.end = false;
159 vec[0].iov_base = &rsp;
166 static void StatsEntry2StatsRsp(const StatsEntry &entry, StatsRsp &rsp)
171 rsp.lines[i] = entry.lines[i];
172 rsp.len[i] = entry.len[i];
174 rsp.dropped = entry.dropped;
175 rsp.freqMax = entry.GetFreqMax();
176 rsp.freqMaxSec = entry.realTimeFreqMax.tv_sec;
177 rsp.freqMaxNsec = entry.realTimeFreqMax.tv_nsec;
178 rsp.throughputMax = entry.GetThroughputMax();
179 rsp.tpMaxSec = entry.realTimeThroughputMax.tv_sec;
180 rsp.tpMaxNsec = entry.realTimeThroughputMax.tv_nsec;
185 StatsQueryRsp rsp;
189 rsp.tsBeginSec = tsBegin.tv_sec;
190 rsp.tsBeginNsec = tsBegin.tv_nsec;
194 rsp.durationSec = monoNow.tv_sec;
195 rsp.durationNsec = monoNow.tv_nsec;
196 stats.GetTotalLines(rsp.totalLines);
197 stats.GetTotalLens(rsp.totalLens);
198 rsp.typeNum = 0;
203 rsp.typeNum++;
205 rsp.ldStats = nullptr;
206 rsp.procNum = pTable.size();
207 rsp.pStats = nullptr;
208 m_communicationSocket->Write(reinterpret_cast<char *>(&rsp), sizeof(StatsQueryRsp));
629 PersistStartRsp rsp = { msg.jobId };
630 WriteRspHeader(IoctlCmd::PERSIST_START_RSP, sizeof(rsp));
631 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
636 PersistStopRsp rsp = { 0 };
643 for (auto it = resultList.begin(); it != resultList.end() && rsp.jobNum < MAX_JOBS; ++it) {
647 rsp.jobId[rsp.jobNum] = jobId;
648 rsp.jobNum++;
651 if (rsp.jobNum == 0) {
655 WriteRspHeader(IoctlCmd::PERSIST_STOP_RSP, sizeof(rsp));
656 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
667 PersistQueryRsp rsp = { 0 };
668 for (auto it = resultList.begin(); it != resultList.end() && rsp.jobNum < MAX_JOBS; ++it) {
669 PersistTaskInfo &task = rsp.taskInfo[rsp.jobNum];
677 rsp.jobNum++;
679 WriteRspHeader(IoctlCmd::PERSIST_QUERY_RSP, sizeof(rsp));
680 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
685 PersistRefreshRsp rsp = { 0 };
692 for (auto it = resultList.begin(); it != resultList.end() && rsp.jobNum < MAX_JOBS; ++it) {
696 rsp.jobId[rsp.jobNum] = jobId;
697 rsp.jobNum++;
700 if (rsp.jobNum == 0) {
704 WriteRspHeader(IoctlCmd::PERSIST_REFRESH_RSP, sizeof(rsp));
705 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
711 PersistClearRsp rsp = { 0 };
712 WriteRspHeader(IoctlCmd::PERSIST_CLEAR_RSP, sizeof(rsp));
713 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
724 BufferSizeGetRsp rsp = { 0 };
728 rsp.size[t] = static_cast<uint32_t>(hilogBuffer.GetBuffLen(t));
736 WriteRspHeader(IoctlCmd::BUFFERSIZE_GET_RSP, sizeof(rsp));
737 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
748 BufferSizeSetRsp rsp = { 0 };
754 rsp.size[t] = ret;
757 rsp.size[t] = rqst.size;
766 WriteRspHeader(IoctlCmd::BUFFERSIZE_SET_RSP, sizeof(rsp));
767 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
796 StatsClearRsp rsp = { 0 };
797 WriteRspHeader(IoctlCmd::STATS_CLEAR_RSP, sizeof(rsp));
798 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
806 DomainFlowCtrlRsp rsp = { 0 };
807 WriteRspHeader(IoctlCmd::DOMAIN_FLOWCTRL_RSP, sizeof(rsp));
808 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
819 LogRemoveRsp rsp = { types };
831 WriteRspHeader(IoctlCmd::LOG_REMOVE_RSP, sizeof(rsp));
832 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));
846 KmsgEnableRsp rsp = { 0 };
847 WriteRspHeader(IoctlCmd::KMSG_ENABLE_RSP, sizeof(rsp));
848 (void)m_communicationSocket->Write(reinterpret_cast<char*>(&rsp), sizeof(rsp));