Home
last modified time | relevance | path

Searched refs:channelId (Results 1 – 25 of 26) sorted by relevance

12

/developtools/hdc/src/common/
Dchannel.cpp98 FreeChannel(hChannel->channelId); in ClearChannels()
167 thisClass->FreeChannel(hChannel->channelId); in ReadStream()
180 thisClass->FreeChannel(hChannel->channelId); in WriteCallback()
229 void HdcChannelBase::PushAsyncMessage(const uint32_t channelId, const uint8_t method, const void *d… in PushAsyncMessage() argument
239 param->sid = channelId; // Borrow SID storage in PushAsyncMessage()
284 void HdcChannelBase::SendWithCmd(const uint32_t channelId, const uint16_t commandFlag, uint8_t *buf… in SendWithCmd() argument
286 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); in SendWithCmd()
326 void HdcChannelBase::Send(const uint32_t channelId, uint8_t *bufPtr, const int size) in Send() argument
328 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); in Send()
366 uint32_t channelId = GetChannelPseudoUid(); in MallocChannel() local
[all …]
Dchannel.h24 HChannel AdminChannel(const uint8_t op, const uint32_t channelId, HChannel hInput);
27 …void PushAsyncMessage(const uint32_t channelId, const uint8_t method, const void *data, const int …
29 void FreeChannel(const uint32_t channelId);
32 …void SendWithCmd(const uint32_t channelId, const uint16_t commandFlag, uint8_t *bufPtr, const int …
38 uint32_t channelId; member
49 void Send(const uint32_t channelId, uint8_t *bufPtr, const int size);
Dsession.h49 uint32_t channelId; member
54 uint32_t channelId; member
62 virtual void AttachChannel(HSession hSession, const uint32_t channelId) in AttachChannel() argument
65 virtual void DeatchChannel(HSession hSession, const uint32_t channelId) in DeatchChannel() argument
71 virtual bool RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, in RedirectToTask() argument
80 …void LogMsg(const uint32_t sessionId, const uint32_t channelId, MessageLevel level, const char *ms…
92 …int Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, const uin…
98 …HTaskInfo AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, HTaskInfo hInpu…
99 …bool DispatchTaskData(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t…
107 …virtual bool FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uin… in FetchCommand() argument
[all …]
Dtask.cpp32 WRITE_LOG(LOG_DEBUG, "HdcTaskBase channelId:%u", taskInfo->channelId); in HdcTaskBase()
37 WRITE_LOG(LOG_DEBUG, "~HdcTaskBase channelId:%u", taskInfo->channelId); in ~HdcTaskBase()
60 channelBase->SendWithCmd(taskInfo->channelId, command, bufPtr, size); in SendToAnother()
64 … return sessionBase->Send(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size) > 0; in SendToAnother()
92 sessionBase->LogMsg(taskInfo->sessionId, taskInfo->channelId, level, log.c_str()); in LogMsg()
99 return hSession->ServerCommand(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size); in ServerCommand()
Dsession.cpp102 …RITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
105 …(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
113 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
120 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
144 uint32_t channelId = iter->first; in ClearOwnTasks() local
147 if (channelIDInput != channelId) { in ClearOwnTasks()
694 idx++, ti->channelId, ti->taskType, ti->closeRetryCount); in DumpTasksInfo()
699 HTaskInfo HdcSessionBase::AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, … in AdminTask() argument
716 hRet = mapTask[channelId]; in AdminTask()
720 mapTask[channelId] = hInput; in AdminTask()
[all …]
Ddefine_plus.h248 uint32_t channelId; member
458 uint32_t channelId; member
504 uint32_t channelId; member
Dserial_struct.h92 … return Message(Field<fieldOne, &Hdc::HdcSessionBase::PayloadProtect::channelId>("channelId"),
/developtools/profiler/host/smartperf/ide/src/hdc/message/
DPayloadProtect.ts24 constructor(channelId: number, commandFlag: number, checkSum: number, vCode: number) {
26 this._channelId = channelId;
36 get channelId(): number { method in PayloadProtect
40 set channelId(value: number) { method in PayloadProtect
DDataMessage.ts49 this._channelId = payloadProtect.channelId;
83 get channelId(): number {
87 set channelId(value: number) {
/developtools/hdc/src/daemon/
Ddaemon.h33 …bool FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *pa…
35 …bool ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, uin…
46 …bool RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, const uint16…
49 bool HandDaemonAuth(HSession hSession, const uint32_t channelId, SessionHandShake &handshake);
51 …bool DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payload, int pay…
Ddaemon.cpp146 bool HdcDaemon::RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, in RedirectToTask() argument
200 bool HdcDaemon::HandDaemonAuth(HSession hSession, const uint32_t channelId, SessionHandShake &hands… in HandDaemonAuth() argument
209 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in HandDaemonAuth()
229 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in HandDaemonAuth()
247 bool HdcDaemon::DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payloa… in DaemonSessionHandshake() argument
285 if (enableSecure && !HandDaemonAuth(hSession, channelId, handshake)) { in DaemonSessionHandshake()
299 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)failedString.c_str(), in DaemonSessionHandshake()
318 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in DaemonSessionHandshake()
324 bool HdcDaemon::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u… in FetchCommand() argument
339 WRITE_LOG(LOG_DEBUG, "FetchCommand channelId:%u command:%u", channelId, command); in FetchCommand()
[all …]
Djdwp.cpp436 sessionBase->LogMsg(t->sessionId, t->channelId, MSG_OK, data.c_str()); in SendProcessList()
499 …WRITE_LOG(LOG_DEBUG, "RemoveJdwpTracker channelId:%d, taskType:%d.", taskInfo->channelId, taskInfo… in RemoveJdwpTracker()
/developtools/profiler/host/smartperf/ide/src/hdc/hdcclient/
DHdcStream.ts28 private readonly channelId: number property in HdcStream
35 this.channelId = Utils.getLocalId();
37 this.hdcClient.bindStopStream(this.channelId, this);
39 this.hdcClient.bindStream(this.channelId, this);
137 …t this.hdcClient.readDataProcessing.send(this.hdcClient.sessionId, this.channelId, command.cmdFlag…
149 this.hdcClient.unbindStream(this.channelId);
153 this.hdcClient.unbindStopStream(this.channelId);
/developtools/hdc/src/host/
Dserver.h24 …bool FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *pa…
31 void AttachChannel(HSession hSession, const uint32_t channelId) override;
32 void DeatchChannel(HSession hSession, const uint32_t channelId) override;
52 …bool ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, uin…
54 …bool RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, const uint16…
Dserver.cpp523 bool HdcServer::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u… in FetchCommand() argument
535 HChannel hChannel = sfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in FetchCommand()
540 WRITE_LOG(LOG_DEBUG, "Die channelId :%lu recv CMD_KERNEL_CHANNEL_CLOSE", channelId); in FetchCommand()
543 WRITE_LOG(LOG_DEBUG, "channelId :%lu die", channelId); in FetchCommand()
546 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &flag, 1); in FetchCommand()
566 WRITE_LOG(LOG_DEBUG, "CMD_KERNEL_CHANNEL_CLOSE channelid:%u", channelId); in FetchCommand()
568 ClearOwnTasks(hSession, channelId); in FetchCommand()
570 sfc->PushAsyncMessage(channelId, ASYNC_FREE_CHANNEL, nullptr, 0); in FetchCommand()
573 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
581 pdiNew->channelId = channelId; in FetchCommand()
[all …]
Dclient.cpp272 thisClass->Send(thisClass->channel->channelId, in CommandWorker()
296 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(cmd), strlen(cmd)); in ReadStd()
359 thisClass->FreeChannel(hChannel->channelId); in Connect()
376 uint32_t unOld = hChannel->channelId; in PreHandshake()
377 hChannel->channelId = ntohl(hShake->channelId); in PreHandshake()
402 Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), sizeof(ChannelHandShake)); in PreHandshake()
405 …Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), offsetof(struct ChannelHandShake, v… in PreHandshake()
410 Send(hChannel->channelId, in PreHandshake()
486 … Send(this->channel->channelId, (uint8_t *)this->command.c_str(), this->command.size() + 1); in WaitFor()
554 hTaskInfo->channelId = hChannel->channelId; in GetRemoteTaskInfo()
Dserver_for_client.cpp76 handShake.channelId = htonl(hChannel->channelId); in AcceptClient()
84 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
87 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
170 …if (ptrServer->Send(hdi->hSession->sessionId, hChannel->channelId, commandFlag, bufPtr, bufSize) <… in SendToDaemon()
251 thisClass->FreeChannel(hChannel->channelId); in OrderConnecTargetResult()
306 ptrServer->ClearOwnTasks(hSession, hfi->channelId); in CommandRemoveForward()
307 FreeChannel(hfi->channelId); in CommandRemoveForward()
523 … WRITE_LOG(LOG_DEBUG, "command send back to remote client channelId:%u", hChannel->channelId); in TaskCommand()
529 ptrServer->DispatchTaskData(hSession, hChannel->channelId, formatCommand->cmdFlag, in TaskCommand()
549 WRITE_LOG(LOG_DEBUG, "remote client mode channelId:%u", hChannel->channelId); in HandleRemote()
[all …]
Dhost_unity.cpp49 … WRITE_LOG(LOG_DEBUG, "taskInfo->channelId:%u fileLog:%d", taskInfo->channelId, opContext.fileLog); in StopTask()
Dhost_updater.cpp324 sessionBase->ServerCommand(taskInfo->sessionId, taskInfo->channelId, CMD_KERNEL_ECHO_RAW, in SendRawData()
/developtools/profiler/host/smartperf/ide/test/hdc/message/
DPayloadProtect.test.ts26 expect(payloadProtect.channelId).toBeUndefined()
30 payloadProtect.channelId = true
31 expect(payloadProtect.channelId).toBeTruthy()
DDataMessage.test.ts37 expect(dataMessage.channelId).toBe(-1)
41 dataMessage.channelId = true;
42 expect(dataMessage.channelId).toBeTruthy()
/developtools/profiler/host/smartperf/ide/src/hdc/common/
DSerialize.ts42 let channelId = this.serializeU32(1, payloadProtect.channelId);
46 …let mergedArray = new Uint8Array(channelId.length + commandFlag.length + checkSum.length + vCode.l…
47 mergedArray.set(channelId)
48 mergedArray.set(commandFlag, channelId.length)
49 mergedArray.set(checkSum, channelId.length + commandFlag.length)
50 mergedArray.set(vCode, channelId.length + commandFlag.length + checkSum.length)
255 let channelId = this.parseU32(channelDataView, 1);
278 return new PayloadProtect(channelId, commandFlag, checkSum, vCode);
/developtools/profiler/host/smartperf/ide/src/hdc/transmission/
DDataProcessing.ts81 …public async send(sessionId: number, channelId: number, commandFlag: number, data: Uint8Array, dat…
82 …let protectBuf: PayloadProtect = new PayloadProtect(channelId, commandFlag, DataProcessing.checkSu…
/developtools/hdc/test/unittest/common/include/
DHdcJdwpTest.h36 bool ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, in ServerCommand() argument
/developtools/profiler/host/smartperf/ide/test/hdc/common/
DSerialize.test.ts33 channelId:1,

12