Home
last modified time | relevance | path

Searched refs:sessionId (Results 1 - 25 of 45) sorted by relevance

12

/developtools/hdc/src/daemon/
H A Ddaemon_usb.cpp217 void HdcDaemonUSB::ResetOldSession(uint32_t sessionId, bool isSoftReset) in ResetOldSession() argument
220 if (sessionId == 0) { in ResetOldSession()
221 sessionId = currentSessionId; in ResetOldSession()
223 HSession hSession = daemon->AdminSession(OP_QUERY, sessionId, nullptr); in ResetOldSession()
225 WRITE_LOG(LOG_FATAL, "ResetOldSession hSession nullptr sessionId:%u", sessionId); in ResetOldSession()
230 WRITE_LOG(LOG_WARN, "Hostside softreset to restart daemon, old sessionId:%u isSoftReset:%d", in ResetOldSession()
231 sessionId, isSoftReset); in ResetOldSession()
232 daemon->FreeSession(sessionId); in ResetOldSession()
236 int HdcDaemonUSB::AvailablePacket(uint8_t *ioBuf, int ioBytes, uint32_t *sessionId) in AvailablePacket() argument
337 uint32_t sessionId = hSession->sessionId; SendUSBRaw() local
354 OnNewHandshakeOK(const uint32_t sessionId) OnNewHandshakeOK() argument
374 PrepareNewSession(uint32_t sessionId, uint8_t *pRecvBuf, int recvBytesIO) PrepareNewSession() argument
534 DispatchToWorkThread(uint32_t sessionId, uint8_t *readBuf, int readBytes) DispatchToWorkThread() argument
591 uint32_t sessionId = 0; OnUSBRead() local
[all...]
H A Ddaemon.cpp434 WRITE_LOG(LOG_INFO, "client support RSA_3072_SHA512 auth for %u session", hSession->sessionId); in InitMod()
437 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in InitMod()
441 InitSessionAuthInfo(hSession->sessionId, hSession->tokenRSA); in InitMod()
452 WRITE_LOG(LOG_FATAL, "get pubkey failed for %u", hSession->sessionId); in InitMod()
464 std::thread notifymsg([this, &handshake, channelId, sessionId = hSession->sessionId, &confirmmsg]() { in InitMod()
465 this->EchoHandshakeMsg(handshake, channelId, sessionId, confirmmsg); in InitMod()
471 WRITE_LOG(LOG_FATAL, "user allow onece for %u", hSession->sessionId); in InitMod()
474 WRITE_LOG(LOG_FATAL, "user allow forever for %u", hSession->sessionId); in InitMod()
478 WRITE_LOG(LOG_FATAL, "user refuse for %u", hSession->sessionId); in InitMod()
952 ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, uint8_t *bufPtr, const int size) InitMod() argument
[all...]
H A Ddaemon_uart.cpp162 void HdcDaemonUART::ResetOldSession(uint32_t sessionId) in ResetOldSession() argument
164 if (sessionId == 0) { in ResetOldSession()
165 sessionId = currentSessionId; in ResetOldSession()
167 HSession hSession = daemon.AdminSession(OP_QUERY, sessionId, nullptr); in ResetOldSession()
175 WRITE_LOG(LOG_WARN, "Hostside softreset to restart daemon, old sessionId:%u", sessionId); in ResetOldSession()
179 HSession HdcDaemonUART::GetSession(const uint32_t sessionId, bool create = false) in GetSession() argument
181 HSession hSession = daemon.AdminSession(OP_QUERY, sessionId, nullptr); in GetSession()
183 hSession = PrepareNewSession(sessionId); in GetSession()
193 daemon.FreeSession(session->sessionId); in OnTransferError()
198 OnNewHandshakeOK(const uint32_t sessionId) OnNewHandshakeOK() argument
203 PrepareNewSession(uint32_t sessionId) PrepareNewSession() argument
[all...]
H A Ddaemon_usb.h27 void OnNewHandshakeOK(const uint32_t sessionId);
44 int DispatchToWorkThread(uint32_t sessionId, uint8_t *readBuf, int readBytes);
45 int AvailablePacket(uint8_t *ioBuf, int ioBytes, uint32_t *sessionId);
50 HSession PrepareNewSession(uint32_t sessionId, uint8_t *pRecvBuf, int recvBytesIO);
54 void ResetOldSession(uint32_t sessionId, bool isSoftReset = false);
H A Ddaemon_uart.h29 void OnNewHandshakeOK(const uint32_t sessionId);
32 virtual HSession GetSession(const uint32_t sessionId, bool create) override;
54 virtual HSession PrepareNewSession(uint32_t sessionId);
58 virtual void ResetOldSession(uint32_t sessionId) override;
/developtools/hdc/test/unittest/common/
H A Duart_test.cpp36 bool MakeRndData(std::vector<uint8_t> &data, uint32_t sessionId);
37 bool MakeDemoData(std::vector<uint8_t> &data, uint32_t sessionId);
119 server->sessionId = SERVER_ID; in SetUp()
125 daemon->sessionId = DAEMON_SESSION_ID; in SetUp()
133 bool HdcUARTBaseTest::MakeRndData(std::vector<uint8_t> &data, uint32_t sessionId) in MakeRndData() argument
137 head.sessionId = sessionId; in MakeRndData()
149 bool HdcUARTBaseTest::MakeDemoData(std::vector<uint8_t> &data, uint32_t sessionId) in MakeDemoData() argument
153 head.sessionId = sessionId; in MakeDemoData()
204 const uint32_t sessionId = 12345; HWTEST_F() local
221 uint32_t sessionId = 1234567980; HWTEST_F() local
522 uint32_t sessionId = 0; HWTEST_F() local
674 const uint32_t sessionId = 12345; HWTEST_F() local
692 const uint32_t sessionId = 12345; HWTEST_F() local
755 const uint32_t sessionId = 12345; HWTEST_F() local
795 const uint32_t sessionId = 12345; HWTEST_F() local
815 const uint32_t sessionId = 12345; HWTEST_F() local
835 const uint32_t sessionId = 12345; HWTEST_F() local
[all...]
H A Dhost_uart_test.cpp513 constexpr uint32_t sessionId = 1234; in HWTEST_F() local
516 resetPackage.sessionId = sessionId; in HWTEST_F()
521 mockHostUART.SendUartSoftReset(&mySession, sessionId); in HWTEST_F()
541 EXPECT_CALL(mockServer, FreeSession(mySession.sessionId)).Times(1); in HWTEST_F()
740 constexpr uint32_t sessionId = 1234; in HWTEST_F() local
744 EXPECT_CALL(mockServer, AdminSession(OP_QUERY, sessionId, nullptr)) in HWTEST_F()
747 mockHostUART.GetSession(sessionId, false); in HWTEST_F()
791 const uint32_t sessionId = 12345; in HWTEST_F() local
792 mySession.sessionId in HWTEST_F()
824 const uint32_t sessionId = mySession.sessionId; HWTEST_F() local
[all...]
H A Ddaemon_uart_test.cpp410 ON_CALL(mockDaemonUART, PrepareNewSession).WillByDefault([&](uint32_t sessionId) { in HWTEST_F()
411 return mockDaemonUART.HdcDaemonUART::PrepareNewSession(sessionId); in HWTEST_F()
654 constexpr uint32_t sessionId = 1234; in HWTEST_F() local
659 EXPECT_CALL(mockDaemon, AdminSession(OP_QUERY, sessionId, nullptr)) in HWTEST_F()
663 mockDaemonUART.ResetOldSession(sessionId); in HWTEST_F()
667 EXPECT_CALL(mockDaemon, AdminSession(OP_QUERY, sessionId, nullptr)) in HWTEST_F()
670 mockDaemonUART.ResetOldSession(sessionId); in HWTEST_F()
695 constexpr uint32_t sessionId = 1234; in HWTEST_F() local
699 EXPECT_CALL(mockDaemon, AdminSession(OP_QUERY, sessionId, nullptr)) in HWTEST_F()
702 mockDaemonUART.GetSession(sessionId, fals in HWTEST_F()
712 uint32_t sessionId = 1234; HWTEST_F() local
[all...]
/developtools/profiler/device/services/profiler_service/test/unittest/
H A Dprofiler_service_test.cpp115 grpc::Status StartSession(uint32_t sessionId) in StartSession() argument
120 request.set_session_id(sessionId); in StartSession()
125 grpc::Status StopSession(uint32_t sessionId) in StopSession() argument
130 request.set_session_id(sessionId); in StopSession()
135 grpc::Status DestroySession(uint32_t sessionId) in DestroySession() argument
140 request.set_session_id(sessionId); in DestroySession()
517 uint32_t sessionId = CreateOfflineSession(); in HWTEST_F() local
518 EXPECT_NE(sessionId, 0); in HWTEST_F()
520 EXPECT_EQ(DestroySession(sessionId).error_code(), grpc::StatusCode::OK); in HWTEST_F()
532 uint32_t sessionId in HWTEST_F() local
551 uint32_t sessionId = 0; HWTEST_F() local
599 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
626 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
658 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
672 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
689 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
719 uint32_t sessionId = 0; HWTEST_F() local
767 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
794 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
826 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
840 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
864 uint32_t sessionId = 0; HWTEST_F() local
920 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
948 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
1015 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
1043 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
1086 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
1151 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
1188 uint32_t sessionId = CreateOnlineSession(); HWTEST_F() local
1232 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
1254 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
1284 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
1318 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
1344 uint32_t sessionId = CreateOfflineSession(); HWTEST_F() local
[all...]
/developtools/hdc/src/common/
H A Dusb.cpp35 WRITE_LOG(LOG_FATAL, "ReadUSB FetchIOBuf error sessionId:%u", hSession->sessionId); in ReadUSB()
36 hSessionBase->FreeSession(hSession->sessionId); in ReadUSB()
65 vector<uint8_t> HdcUSBBase::BuildPacketHeader(uint32_t sessionId, uint8_t option, uint32_t dataSize) in BuildPacketHeader() argument
69 head.sessionId = htonl(sessionId); in BuildPacketHeader()
87 auto header = BuildPacketHeader(hSession->sessionId, USB_OPTION_HEADER, length); in SendUSBBlock()
100 auto dummy = BuildPacketHeader(hSession->sessionId, 0, 0); in SendUSBBlock()
143 WRITE_LOG(LOG_WARN, "SendToHdcStream check, sessionId not matched"); in PreSendUsbSoftReset()
158 header->sessionId in CheckPacketOption()
[all...]
H A Dsession.cpp119 hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
123 hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
129 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove retry count %d/%d, taskType:%d channelId:%u, sessionId:%u", in BeginRemoveTask()
130 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
171 WRITE_LOG(LOG_WARN, "ClearOwnTasks OP_CLEAR finish, sessionId:%u channelIDInput:%u", in ClearOwnTasks()
172 hSession->sessionId, channelIDInput); in ClearOwnTasks()
190 FreeSession(hSession->sessionId); in ClearSessions()
330 void HdcSessionBase::PushAsyncMessage(const uint32_t sessionId, const uint8_t method, const void *data, in PushAsyncMessage() argument
337 param->sid = sessionId; in PushAsyncMessage()
418 uint32_t sessionId) in MallocSession()
417 MallocSession(bool serverOrDaemon, const ConnType connType, void *classModule, uint32_t sessionId) MallocSession() argument
644 FreeSession(const uint32_t sessionId) FreeSession() argument
669 AdminSession(const uint8_t op, const uint32_t sessionId, HSession hInput) AdminSession() argument
831 Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, const uint8_t *data, const int dataSize) Send() argument
1298 LogMsg(const uint32_t sessionId, const uint32_t channelId, MessageLevel level, const char *msg, ...) LogMsg() argument
[all...]
H A Duart.cpp457 uint32_t sessionId = 0; in PackageProcess() local
460 if (ValidateUartPacket(data, sessionId, packageIndex, packetSize) != RET_SUCCESS) { in PackageProcess()
475 hSession = GetSession(sessionId); in PackageProcess()
478 hSession = GetSession(sessionId, true); in PackageProcess()
482 WRITE_LOG(LOG_WARN, "%s have not found session (%u). skip it", __FUNCTION__, sessionId); in PackageProcess()
502 ResponseUartTrans(hSession->sessionId, ++hSession->hUART->packageIndex, in PackageProcess()
542 hSession = GetSession(uartHeader->sessionId); in SendUARTRaw()
545 WRITE_LOG(LOG_WARN, "%s hSession not found:%zu", __FUNCTION__, uartHeader->sessionId); in SendUARTRaw()
585 if (head->sessionId != hSession->sessionId) { in UartSendToHdcStream()
793 ClearUARTOutMap(uint32_t sessionId) ClearUARTOutMap() argument
825 ValidateUartPacket(vector<uint8_t> &data, uint32_t &sessionId, uint32_t &packageIndex, size_t &packetSize) ValidateUartPacket() argument
887 ResponseUartTrans(uint32_t sessionId, uint32_t packageIndex, UartProtocolOption option) ResponseUartTrans() argument
[all...]
H A Dtask.cpp68 if (Base::IsSessionDeleted(taskInfo->sessionId)) { in SendToAnother()
73 return sessionBase->Send(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size) > 0; in SendToAnother()
101 sessionBase->LogMsg(taskInfo->sessionId, taskInfo->channelId, level, log.c_str()); in LogMsg()
108 return hSession->ServerCommand(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size); in ServerCommand()
115 HSession hSession = sessionBase->AdminSession(OP_QUERY, taskInfo->sessionId, nullptr); in ThreadCtrlCommunicate()
117 WRITE_LOG(LOG_FATAL, "ThreadCtrlCommunicate hSession nullptr sessionId:%u", taskInfo->sessionId); in ThreadCtrlCommunicate()
H A Duart.h51 uint32_t sessionId; // the package owner (COM dev owner) member
62 oss << "Id:" << sessionId; in ToPkgIdentityString() local
72 oss << " sessionId:" << sessionId; in ToDebugString() local
87 sessionId(sessionIdIn),
182 virtual void SendUartSoftReset(HSession hUART, uint32_t sessionId) {}; in SendUartSoftReset() argument
183 virtual RetErrCode ValidateUartPacket(vector<uint8_t> &data, uint32_t &sessionId,
186 virtual void ResetOldSession(uint32_t sessionId) in ResetOldSession() argument
204 virtual void ResponseUartTrans(uint32_t sessionId, uint32_t packageIndex,
211 virtual HSession GetSession(const uint32_t sessionId, boo
278 uint32_t sessionId = 0; // like group , sometimes we will delete by this filter global() member
325 Wait(uint32_t sessionId) Wait() argument
332 Free(uint32_t sessionId) Free() argument
[all...]
H A Dsession.h31 uint32_t sessionId; member
40 oss << " sessionId:" << sessionId; in ToDebugString() local
82 void LogMsg(const uint32_t sessionId, const uint32_t channelId, MessageLevel level, const char *msg, ...);
91 uint32_t sessionId = 0);
92 virtual void FreeSession(const uint32_t sessionId);
95 int Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, const uint8_t *data,
98 virtual HSession AdminSession(const uint8_t op, const uint32_t sessionId, HSession hInput);
100 virtual void PushAsyncMessage(const uint32_t sessionId, const uint8_t method, const void *data, const int dataSize);
115 virtual bool ServerCommand(const uint32_t sessionId, cons in FetchCommand() argument
[all...]
H A Ddefine_plus.h69 uint32_t sessionId; member
75 uint32_t sid; // sessionId/channelId
84 uint32_t sessionId; member
208 uint32_t sessionId; member
256 oss << " sessionId:" << sessionId; in ToDebugString() local
268 sessionId = 0; in HdcSession()
371 uint32_t sessionId; member
378 uint32_t sessionId = 0; member
/developtools/profiler/device/services/profiler_service/src/
H A Dprofiler_service.cpp331 uint32_t sessionId = ++sessionIdCounter_; in CreateSession() local
332 ctx->id = sessionId; in CreateSession()
333 ctx->name = "session-" + std::to_string(sessionId); in CreateSession()
335 // add {sessionId, ctx} to map in CreateSession()
336 CHECK_EXPRESSION_TRUE(AddSessionContext(sessionId, ctx), "sessionId conflict!"); in CreateSession()
349 response->set_session_id(sessionId); in CreateSession()
351 PROFILER_LOG_INFO(LOG_CORE, "CreateSession %d %u done!", request->request_id(), sessionId); in CreateSession()
355 bool ProfilerService::AddSessionContext(uint32_t sessionId, const SessionContextPtr& sessionCtx) in AddSessionContext() argument
358 CHECK_TRUE(sessionContext_.count(sessionId) in AddSessionContext()
374 RemoveSessionContext(uint32_t sessionId) RemoveSessionContext() argument
480 uint32_t sessionId = request->session_id(); StartSession() local
537 uint32_t sessionId = request->session_id(); FetchData() local
595 uint32_t sessionId = request->session_id(); StopSession() local
621 uint32_t sessionId = request->session_id(); DestroySession() local
655 uint32_t sessionId = request->session_id(); KeepSession() local
[all...]
/developtools/hdc/hdc_rust/src/cffi/
H A Dserial_struct.h30 uint32_t sessionId; member
39 oss << " sessionId:" << sessionId; in ToDebugString() local
94 uint32_t sessionId; member
149 uint32_t sessionId; member
156 uint32_t sessionId; member
224 Field<fieldThree, &BaseStruct::SessionHandShake::sessionId>("sessionId"), in type()
/developtools/profiler/device/cmds/src/
H A Dmain.cpp219 bool CheckStartSession(std::unique_ptr<IProfilerService::Stub>& profilerStub, uint32_t& sessionId) in CheckStartSession() argument
224 startRequest.set_session_id(sessionId); in CheckStartSession()
235 bool CheckStopSession(std::unique_ptr<IProfilerService::Stub>& profilerStub, uint32_t& sessionId) in CheckStopSession() argument
240 stopRequest.set_session_id(sessionId); in CheckStopSession()
250 bool CheckDestroySession(std::unique_ptr<IProfilerService::Stub>& profilerStub, uint32_t& sessionId) in CheckDestroySession() argument
255 destroyRequest.set_session_id(sessionId); in CheckDestroySession()
305 uint32_t sessionId = CreateSession(profilerStub, config, keepSecond, outputFile); in DoCapture() local
306 if (sessionId == 0) { in DoCapture()
312 return CheckDestroySession(profilerStub, sessionId); in DoCapture()
315 // start keepSessionThread, in order to ensure the sessionId i in DoCapture()
[all...]
/developtools/hdc/src/host/
H A Dhost_usb.cpp171 hdcServer->FreeSession(hSession->sessionId); in DetectMyNeed()
195 ptrConnect->FreeSession(hSession->sessionId); in KickoutZombie()
440 WRITE_LOG(LOG_INFO, "HostUSB CancelUsbIo, sid:%u ref:%u", hSession->sessionId, uint32_t(hSession->ref)); in CancelUsbIo()
564 hSession->sessionId, childRet); in SubmitUsbBio()
570 hSession->sessionId, ep->transfer->status); in SubmitUsbBio()
595 WRITE_LOG(LOG_FATAL, "Read usb failed, sid:%u ret:%d", hSession->sessionId, childRet); in BeginUsbRead()
606 WRITE_LOG(LOG_WARN, "Read usb return 0, continue read, sid:%u", hSession->sessionId); in BeginUsbRead()
613 WRITE_LOG(LOG_FATAL, "SendToHdcStream failed, sid:%u ret:%d", hSession->sessionId, childRet); in BeginUsbRead()
620 server->FreeSession(hSession->sessionId); in BeginUsbRead()
622 WRITE_LOG(LOG_INFO, "Usb loop read finish sid:%u", hSession->sessionId); in BeginUsbRead()
[all...]
H A Dserver.cpp408 CleanForwardMap(hSession->sessionId); in NotifyInstanceSessionFree()
438 WRITE_LOG(LOG_INFO, "the deamon maybe old version for %u session, so use rsa encrypt", hSession->sessionId); in GetDaemonAuthType()
443 WRITE_LOG(LOG_FATAL, "the buf is invalid for %u session, so use rsa encrypt", hSession->sessionId); in GetDaemonAuthType()
447 WRITE_LOG(LOG_INFO, "daemon auth type is rsa_3072_sha512 for %u session", hSession->sessionId); in GetDaemonAuthType()
463 Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, in HandServerAuth()
477 Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, in HandServerAuth()
584 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &flag, 1); in FetchCommand()
612 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
621 pdiNew->sessionId = hSession->sessionId; in FetchCommand()
726 CleanForwardMap(uint32_t sessionId) CleanForwardMap() argument
959 ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, uint8_t *bufPtr, const int size) ServerCommand() argument
[all...]
H A Dserver_for_client.h58 bool ChannelSendSessionCtrlMsg(vector<uint8_t> &ctrlMsg, uint32_t sessionId) override;
59 HSession FindAliveSession(uint32_t sessionId);
H A Dhost_uart.cpp458 server.FreeSession(hSession->sessionId); in EnumSerialPort()
597 server.FreeSession(hSession->sessionId); in EnumSerialPort()
606 server.FreeSession(hSession->sessionId); in EnumSerialPort()
629 server.FreeSession(hSession->sessionId); in EnumSerialPort()
632 HSession HdcHostUART::GetSession(const uint32_t sessionId, bool) in EnumSerialPort() argument
634 return server.AdminSession(OP_QUERY, sessionId, nullptr); in EnumSerialPort()
661 server.EchoToClientsForSession(session->sessionId, echoStr); in EnumSerialPort()
672 server.FreeSession(session->sessionId); in EnumSerialPort()
673 ClearUARTOutMap(session->sessionId); in EnumSerialPort()
686 server.EchoToClientsForSession(session->sessionId, in EnumSerialPort()
770 SendUartSoftReset(HSession hSession, uint32_t sessionId) EnumSerialPort() argument
[all...]
/developtools/profiler/device/services/profiler_service/include/
H A Dprofiler_service.h120 SessionContextPtr GetSessionContext(uint32_t sessionId) const;
122 bool AddSessionContext(uint32_t sessionId, const SessionContextPtr& sessionCtx);
124 bool RemoveSessionContext(uint32_t sessionId);
/developtools/profiler/host/smartperf/client/client_command/
H A Dsp_task.cpp58 std::string sessionId; in ParseToTask() local
65 sessionId = args[++i]; in ParseToTask()
88 if (sessionId.empty()) { in ParseToTask()
95 taskInfo = { sessionId, pkg, configs, interval, snf }; in ParseToTask()
278 std::string outSdkDataDir = baseOutPath + "/" + curTaskInfo.sessionId; in StopSdkRecv()
314 std::string fileDir = baseOutPath + "/" + curTaskInfo.sessionId; in InitDataFile()
398 std::string writePath = CMD_COMMAND_MAP.at(CmdCommand::WRITE_PATH) + curTaskInfo.sessionId; in WritePath()
406 std::string thisBasePath = baseOutPath + "/" + curTaskInfo.sessionId; in StopGetInfo()
416 { "sessionId", curTaskInfo.sessionId }, in StopGetInfo()
[all...]

Completed in 21 milliseconds

12