Lines Matching defs:rqst
110 int ServiceController::GetRqst(const MsgHeader& hdr, char* rqst, int expectedLen)
116 int ret = m_communicationSocket->Read(rqst, hdr.len);
430 int ServiceController::CheckOutputRqst(const OutputRqst& rqst)
432 if (((rqst.types & (0b01 << LOG_KMSG)) != 0) && (GetBitsCount(rqst.types) > 1)) {
435 if (rqst.domainCount > MAX_DOMAINS) {
438 if (rqst.tagCount > MAX_TAGS) {
441 if (rqst.pidCount > MAX_PIDS) {
446 if (uid != ROOT_UID && uid != SHELL_UID && rqst.pidCount > 0 && uid != HIVIEW_UID && uid != PROFILER_UID) {
452 void ServiceController::LogFilterFromOutputRqst(const OutputRqst& rqst, LogFilter& filter)
454 if (rqst.types == 0) {
457 filter.types = rqst.types;
459 if (rqst.levels == 0) {
460 filter.levels = ~rqst.levels; // 0 means all
462 filter.levels = rqst.levels;
465 filter.blackDomain = rqst.blackDomain;
466 filter.domainCount = rqst.domainCount;
467 for (i = 0; i < rqst.domainCount; i++) {
468 filter.domains[i] = rqst.domains[i];
470 filter.blackTag = rqst.blackTag;
471 filter.tagCount = rqst.tagCount;
472 for (i = 0; i < rqst.tagCount; i++) {
473 (void)strncpy_s(filter.tags[i], MAX_TAG_LEN, rqst.tags[i], MAX_TAG_LEN - 1);
475 filter.blackPid = rqst.blackPid;
476 filter.pidCount = rqst.pidCount;
477 for (i = 0; i < rqst.pidCount; i++) {
478 filter.pids[i] = rqst.pids[i];
480 (void)strncpy_s(filter.regex, MAX_REGEX_STR_LEN, rqst.regex, MAX_REGEX_STR_LEN - 1);
497 void ServiceController::HandleOutputRqst(const OutputRqst &rqst)
500 int ret = CheckOutputRqst(rqst);
506 LogFilterFromOutputRqst(rqst, filter);
507 int lines = rqst.headLines ? rqst.headLines : rqst.tailLines;
508 int tailCount = rqst.tailLines;
519 if (rqst.noBlock) {
541 int ServiceController::CheckPersistStartRqst(const PersistStartRqst &rqst)
544 int ret = CheckOutputRqst(rqst.outputFilter);
548 if (rqst.jobId && (rqst.jobId < JOB_ID_MIN || rqst.jobId == JOB_ID_MAX)) {
551 if (rqst.fileSize && (rqst.fileSize < MIN_LOG_FILE_SIZE || rqst.fileSize > MAX_LOG_FILE_SIZE)) {
554 if (rqst.fileName[0] && IsValidFileName(rqst.fileName) == false) {
557 if (rqst.fileNum && (rqst.fileNum > MAX_LOG_FILE_NUM || rqst.fileNum < MIN_LOG_FILE_NUM)) {
563 void ServiceController::PersistStartRqst2Msg(const PersistStartRqst &rqst, LogPersistStartMsg &msg)
565 LogFilterFromOutputRqst(rqst.outputFilter, msg.filter);
566 bool isKmsgType = rqst.outputFilter.types == (0b01 << LOG_KMSG);
567 msg.compressAlg = LogCompress::Str2CompressType(rqst.stream);
568 msg.fileSize = rqst.fileSize == 0 ? DEFAULT_PERSIST_FILE_SIZE : rqst.fileSize;
569 msg.fileNum = rqst.fileNum == 0 ? DEFAULT_PERSIST_FILE_NUM : rqst.fileNum;
570 msg.jobId = rqst.jobId;
574 string fileName = rqst.fileName;
596 void ServiceController::HandlePersistStartRqst(const PersistStartRqst &rqst)
609 ret = CheckPersistStartRqst(rqst);
621 PersistStartRqst2Msg(rqst, msg);
623 HilogBuffer& logBuffer = IsKmsg(rqst.outputFilter.types) ? m_kmsgBuffer : m_hilogBuffer;
634 void ServiceController::HandlePersistStopRqst(const PersistStopRqst &rqst)
639 if (rqst.jobId == 0 && resultList.empty()) {
645 if (rqst.jobId == 0 || rqst.jobId == jobId) {
659 void ServiceController::HandlePersistQueryRqst(const PersistQueryRqst& rqst)
683 void ServiceController::HandlePersistRefreshRqst(const PersistRefreshRqst& rqst)
688 if (rqst.jobId == 0 && resultList.empty()) {
694 if (rqst.jobId == 0 || rqst.jobId == jobId) {
716 void ServiceController::HandleBufferSizeGetRqst(const BufferSizeGetRqst& rqst)
719 uint16_t types = rqst.types;
740 void ServiceController::HandleBufferSizeSetRqst(const BufferSizeSetRqst& rqst)
743 uint16_t types = rqst.types;
752 int ret = hilogBuffer.SetBuffLen(t, rqst.size);
756 SetBufferSize(t, true, rqst.size);
757 rsp.size[t] = rqst.size;
770 void ServiceController::HandleStatsQueryRqst(const StatsQueryRqst& rqst)
793 void ServiceController::HandleStatsClearRqst(const StatsClearRqst& rqst)
801 void ServiceController::HandleDomainFlowCtrlRqst(const DomainFlowCtrlRqst& rqst)
803 SetDomainSwitchOn(rqst.on);
804 m_logCollector.SetLogFlowControl(rqst.on);
811 void ServiceController::HandleLogRemoveRqst(const LogRemoveRqst& rqst)
814 uint16_t types = rqst.types;
835 void ServiceController::HandleLogKmsgEnableRqst(const KmsgEnableRqst& rqst)
837 SetKmsgSwitchOn(rqst.on);
840 if (rqst.on) {
874 RequestHandler<OutputRqst>(hdr, [this](const OutputRqst& rqst) {
875 HandleOutputRqst(rqst);
880 RequestHandler<PersistStartRqst>(hdr, [this](const PersistStartRqst& rqst) {
881 HandlePersistStartRqst(rqst);
886 RequestHandler<PersistStopRqst>(hdr, [this](const PersistStopRqst& rqst) {
887 HandlePersistStopRqst(rqst);
892 RequestHandler<PersistQueryRqst>(hdr, [this](const PersistQueryRqst& rqst) {
893 HandlePersistQueryRqst(rqst);
898 RequestHandler<BufferSizeGetRqst>(hdr, [this](const BufferSizeGetRqst& rqst) {
899 HandleBufferSizeGetRqst(rqst);
904 RequestHandler<BufferSizeSetRqst>(hdr, [this](const BufferSizeSetRqst& rqst) {
905 HandleBufferSizeSetRqst(rqst);
910 RequestHandler<StatsQueryRqst>(hdr, [this](const StatsQueryRqst& rqst) {
911 HandleStatsQueryRqst(rqst);
916 RequestHandler<PersistRefreshRqst>(hdr, [this](const PersistRefreshRqst& rqst) {
917 HandlePersistRefreshRqst(rqst);
922 RequestHandler<PersistClearRqst>(hdr, [this](const PersistClearRqst& rqst) {
928 RequestHandler<StatsClearRqst>(hdr, [this](const StatsClearRqst& rqst) {
929 HandleStatsClearRqst(rqst);
934 RequestHandler<DomainFlowCtrlRqst>(hdr, [this](const DomainFlowCtrlRqst& rqst) {
935 HandleDomainFlowCtrlRqst(rqst);
940 RequestHandler<LogRemoveRqst>(hdr, [this](const LogRemoveRqst& rqst) {
941 HandleLogRemoveRqst(rqst);
946 RequestHandler<KmsgEnableRqst>(hdr, [this](const KmsgEnableRqst& rqst) {
947 HandleLogKmsgEnableRqst(rqst);