Lines Matching defs:rqst

339     void ToOutputRqst(OutputRqst& rqst)
341 rqst.headLines = headLines;
342 rqst.types = types;
343 rqst.levels = levels;
344 rqst.blackDomain = blackDomain;
345 rqst.domainCount = static_cast<uint8_t>(domainCount);
348 rqst.domains[i] = domains[i];
350 rqst.blackTag = blackTag;
351 rqst.tagCount = tagCount;
353 (void)strncpy_s(rqst.tags[i], MAX_TAG_LEN, tags[i].c_str(), tags[i].length());
355 rqst.blackPid = blackPid;
356 rqst.pidCount = pidCount;
358 rqst.pids[i] = pids[i];
360 (void)strncpy_s(rqst.regex, MAX_REGEX_STR_LEN, regex.c_str(), regex.length());
361 rqst.noBlock = noBlock;
362 rqst.tailLines = tailLines;
365 void ToPersistStartRqst(PersistStartRqst& rqst)
367 ToOutputRqst(rqst.outputFilter);
368 rqst.jobId = jobId;
369 rqst.fileNum = fileNum;
370 rqst.fileSize = fileSize;
371 (void)strncpy_s(rqst.fileName, MAX_FILE_NAME_LEN, fileName.c_str(), fileName.length());
372 (void)strncpy_s(rqst.stream, MAX_STREAM_NAME_LEN, stream.c_str(), stream.length());
375 void ToPersistStopRqst(PersistStopRqst& rqst)
377 rqst.jobId = jobId;
380 void ToBufferSizeSetRqst(BufferSizeSetRqst& rqst)
382 rqst.types = types;
383 rqst.size = buffSize;
386 void ToBufferSizeGetRqst(BufferSizeGetRqst& rqst)
388 rqst.types = types;
391 void ToStatsQueryRqst(StatsQueryRqst& rqst)
393 rqst.types = types;
394 rqst.domainCount = static_cast<uint8_t>(domainCount);
397 rqst.domains[i] = domains[i];
401 void ToLogRemoveRqst(LogRemoveRqst& rqst)
403 rqst.types = types;
411 OutputRqst rqst = { 0 };
412 context.ToOutputRqst(rqst);
414 int ret = ioctl.RequestOutput(rqst, [&context](const OutputRsp& rsp) {
531 BufferSizeGetRqst rqst = { 0 };
532 context.ToBufferSizeGetRqst(rqst);
534 int ret = ioctl.Request<BufferSizeGetRqst, BufferSizeGetRsp>(rqst, [&rqst](const BufferSizeGetRsp& rsp) {
543 cout << "Get " << ComboLogType2Str(rqst.types) << " buffer size failed" << endl;
555 BufferSizeSetRqst rqst;
556 context.ToBufferSizeSetRqst(rqst);
558 int ret = ioctl.Request<BufferSizeSetRqst, BufferSizeSetRsp>(rqst, [&rqst](const BufferSizeSetRsp& rsp) {
565 << Size2Str(rqst.size) << " failed" << endl;
607 KmsgEnableRqst rqst = { kmsgOn };
609 int ret = ioctl.Request<KmsgEnableRqst, KmsgEnableRsp>(rqst, [&rqst](const KmsgEnableRsp& rsp) {
695 DomainFlowCtrlRqst rqst = { 0 };
696 rqst.on = on;
698 int ret = ioctl.Request<DomainFlowCtrlRqst, DomainFlowCtrlRsp>(rqst, [&rqst](const DomainFlowCtrlRsp& rsp) {
729 LogRemoveRqst rqst = { 0 };
730 context.ToLogRemoveRqst(rqst);
732 int ret = ioctl.Request<LogRemoveRqst, LogRemoveRsp>(rqst, [&rqst](const LogRemoveRsp& rsp) {
744 StatsQueryRqst rqst = { 0 };
745 context.ToStatsQueryRqst(rqst);
747 int ret = ioctl.RequestStatsQuery(rqst, [&rqst](const StatsQueryRsp& rsp) {
759 StatsClearRqst rqst = { 0 };
761 int ret = ioctl.Request<StatsClearRqst, StatsClearRsp>(rqst, [&rqst](const StatsClearRsp& rsp) {
871 PersistStartRqst rqst = { { 0 }, 0 };
872 context.ToPersistStartRqst(rqst);
874 int ret = ioctl.Request<PersistStartRqst, PersistStartRsp>(rqst, [&rqst](const PersistStartRsp& rsp) {
886 PersistStopRqst rqst = { 0 };
887 context.ToPersistStopRqst(rqst);
889 int ret = ioctl.Request<PersistStopRqst, PersistStopRsp>(rqst, [&rqst](const PersistStopRsp& rsp) {
909 PersistQueryRqst rqst = { 0 };
911 int ret = ioctl.Request<PersistQueryRqst, PersistQueryRsp>(rqst, [&rqst](const PersistQueryRsp& rsp) {
925 PersistRefreshRqst rqst = { 0 };
927 int ret = ioctl.Request<PersistRefreshRqst, PersistRefreshRsp>(rqst, [&rqst](const PersistRefreshRsp& rsp) {
941 PersistClearRqst rqst = { 0 };
943 int ret = ioctl.Request<PersistClearRqst, PersistClearRsp>(rqst, [&rqst](const PersistClearRsp& rsp) {