Lines Matching refs:rqst
329 void ToOutputRqst(OutputRqst& rqst) in ToOutputRqst()
331 rqst.headLines = headLines; in ToOutputRqst()
332 rqst.types = types; in ToOutputRqst()
333 rqst.levels = levels; in ToOutputRqst()
334 rqst.blackDomain = blackDomain; in ToOutputRqst()
335 rqst.domainCount = static_cast<uint8_t>(domainCount); in ToOutputRqst()
338 rqst.domains[i] = domains[i]; in ToOutputRqst()
340 rqst.blackTag = blackTag; in ToOutputRqst()
341 rqst.tagCount = tagCount; in ToOutputRqst()
343 (void)strncpy_s(rqst.tags[i], MAX_TAG_LEN, tags[i].c_str(), tags[i].length()); in ToOutputRqst()
345 rqst.blackPid = blackPid; in ToOutputRqst()
346 rqst.pidCount = pidCount; in ToOutputRqst()
348 rqst.pids[i] = pids[i]; in ToOutputRqst()
350 (void)strncpy_s(rqst.regex, MAX_REGEX_STR_LEN, regex.c_str(), regex.length()); in ToOutputRqst()
351 rqst.noBlock = noBlock; in ToOutputRqst()
352 rqst.tailLines = tailLines; in ToOutputRqst()
355 void ToPersistStartRqst(PersistStartRqst& rqst) in ToPersistStartRqst()
357 ToOutputRqst(rqst.outputFilter); in ToPersistStartRqst()
358 rqst.jobId = jobId; in ToPersistStartRqst()
359 rqst.fileNum = fileNum; in ToPersistStartRqst()
360 rqst.fileSize = fileSize; in ToPersistStartRqst()
361 (void)strncpy_s(rqst.fileName, MAX_FILE_NAME_LEN, fileName.c_str(), fileName.length()); in ToPersistStartRqst()
362 (void)strncpy_s(rqst.stream, MAX_STREAM_NAME_LEN, stream.c_str(), stream.length()); in ToPersistStartRqst()
365 void ToPersistStopRqst(PersistStopRqst& rqst) in ToPersistStopRqst()
367 rqst.jobId = jobId; in ToPersistStopRqst()
370 void ToBufferSizeSetRqst(BufferSizeSetRqst& rqst) in ToBufferSizeSetRqst()
372 rqst.types = types; in ToBufferSizeSetRqst()
373 rqst.size = buffSize; in ToBufferSizeSetRqst()
376 void ToBufferSizeGetRqst(BufferSizeGetRqst& rqst) in ToBufferSizeGetRqst()
378 rqst.types = types; in ToBufferSizeGetRqst()
381 void ToStatsQueryRqst(StatsQueryRqst& rqst) in ToStatsQueryRqst()
383 rqst.types = types; in ToStatsQueryRqst()
384 rqst.domainCount = static_cast<uint8_t>(domainCount); in ToStatsQueryRqst()
387 rqst.domains[i] = domains[i]; in ToStatsQueryRqst()
391 void ToLogRemoveRqst(LogRemoveRqst& rqst) in ToLogRemoveRqst()
393 rqst.types = types; in ToLogRemoveRqst()
401 OutputRqst rqst = { 0 }; in QueryLogHandler() local
402 context.ToOutputRqst(rqst); in QueryLogHandler()
404 int ret = ioctl.RequestOutput(rqst, [&context](const OutputRsp& rsp) { in QueryLogHandler()
520 BufferSizeGetRqst rqst = { 0 }; in BufferSizeGetHandler() local
521 context.ToBufferSizeGetRqst(rqst); in BufferSizeGetHandler()
523 …int ret = ioctl.Request<BufferSizeGetRqst, BufferSizeGetRsp>(rqst, [&rqst](const BufferSizeGetRsp&… in BufferSizeGetHandler()
532 cout << "Get " << ComboLogType2Str(rqst.types) << " buffer size failed" << endl; in BufferSizeGetHandler()
544 BufferSizeSetRqst rqst; in BufferSizeSetHandler() local
545 context.ToBufferSizeSetRqst(rqst); in BufferSizeSetHandler()
547 …int ret = ioctl.Request<BufferSizeSetRqst, BufferSizeSetRsp>(rqst, [&rqst](const BufferSizeSetRsp&… in BufferSizeSetHandler()
554 << Size2Str(rqst.size) << " failed" << endl; in BufferSizeSetHandler()
596 KmsgEnableRqst rqst = { kmsgOn }; in KmsgFeatureSetHandler() local
598 int ret = ioctl.Request<KmsgEnableRqst, KmsgEnableRsp>(rqst, [&rqst](const KmsgEnableRsp& rsp) { in KmsgFeatureSetHandler()
684 DomainFlowCtrlRqst rqst = { 0 }; in SetDomainFlowCtrl() local
685 rqst.on = on; in SetDomainFlowCtrl()
687 …int ret = ioctl.Request<DomainFlowCtrlRqst, DomainFlowCtrlRsp>(rqst, [&rqst](const DomainFlowCtrlR… in SetDomainFlowCtrl()
718 LogRemoveRqst rqst = { 0 }; in RemoveHandler() local
719 context.ToLogRemoveRqst(rqst); in RemoveHandler()
721 int ret = ioctl.Request<LogRemoveRqst, LogRemoveRsp>(rqst, [&rqst](const LogRemoveRsp& rsp) { in RemoveHandler()
733 StatsQueryRqst rqst = { 0 }; in StatsInfoQueryHandler() local
734 context.ToStatsQueryRqst(rqst); in StatsInfoQueryHandler()
736 int ret = ioctl.RequestStatsQuery(rqst, [&rqst](const StatsQueryRsp& rsp) { in StatsInfoQueryHandler()
748 StatsClearRqst rqst = { 0 }; in StatsInfoClearHandler() local
750 int ret = ioctl.Request<StatsClearRqst, StatsClearRsp>(rqst, [&rqst](const StatsClearRsp& rsp) { in StatsInfoClearHandler()
829 PersistStartRqst rqst = { { 0 }, 0 }; in PersistTaskStart() local
830 context.ToPersistStartRqst(rqst); in PersistTaskStart()
832 …int ret = ioctl.Request<PersistStartRqst, PersistStartRsp>(rqst, [&rqst](const PersistStartRsp& rs… in PersistTaskStart()
844 PersistStopRqst rqst = { 0 }; in PersistTaskStop() local
845 context.ToPersistStopRqst(rqst); in PersistTaskStop()
847 …int ret = ioctl.Request<PersistStopRqst, PersistStopRsp>(rqst, [&rqst](const PersistStopRsp& rsp)… in PersistTaskStop()
867 PersistQueryRqst rqst = { 0 }; in PersistTaskQuery() local
869 …int ret = ioctl.Request<PersistQueryRqst, PersistQueryRsp>(rqst, [&rqst](const PersistQueryRsp& r… in PersistTaskQuery()