| /developtools/hdc/src/common/ |
| D | channel.cpp | 98 FreeChannel(hChannel->channelId); in ClearChannels()
168 thisClass->FreeChannel(hChannel->channelId); in ReadStream()
181 thisClass->FreeChannel(hChannel->channelId); in WriteCallback()
230 void HdcChannelBase::PushAsyncMessage(const uint32_t channelId, const uint8_t method, const void *d… in PushAsyncMessage() argument
240 param->sid = channelId; // Borrow SID storage in PushAsyncMessage()
286 void HdcChannelBase::SendWithCmd(const uint32_t channelId, const uint16_t commandFlag, uint8_t *buf… in SendWithCmd() argument
289 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); in SendWithCmd()
330 void HdcChannelBase::Send(const uint32_t channelId, uint8_t *bufPtr, const int size) in Send() argument
333 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); in Send()
371 uint32_t channelId = GetChannelPseudoUid(); in MallocChannel() local
[all …]
|
| D | task.cpp | 32 WRITE_LOG(LOG_DEBUG, "HdcTaskBase channelId:%u", taskInfo->channelId); in HdcTaskBase()
37 WRITE_LOG(LOG_DEBUG, "~HdcTaskBase channelId:%u", taskInfo->channelId); in ~HdcTaskBase()
50 WRITE_LOG(LOG_DEBUG, "HdcTaskBase::TaskFinish notify begin channelId:%u", taskInfo->channelId); in TaskFinish()
52 WRITE_LOG(LOG_DEBUG, "HdcTaskBase::TaskFinish notify end channelId:%u", taskInfo->channelId); in TaskFinish()
63 channelBase->SendWithCmd(taskInfo->channelId, command, bufPtr, size); in SendToAnother()
67 … return sessionBase->Send(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size) > 0; in SendToAnother()
95 sessionBase->LogMsg(taskInfo->sessionId, taskInfo->channelId, level, log.c_str()); in LogMsg()
102 return hSession->ServerCommand(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size); in ServerCommand()
|
| D | channel.h | 24 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);
|
| D | session.h | 49 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 …]
|
| D | session.cpp | 104 …RITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
107 …(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
116 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
123 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
148 uint32_t channelId = iter->first; in ClearOwnTasks() local
151 if (channelIDInput != channelId) { in ClearOwnTasks()
710 idx++, ti->channelId, ti->taskType, ti->closeRetryCount); in DumpTasksInfo()
715 HTaskInfo HdcSessionBase::AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, … in AdminTask() argument
726 hRet = mapTask[channelId]; in AdminTask()
730 mapTask[channelId] = hInput; in AdminTask()
[all …]
|
| D | define_plus.h | 273 uint32_t channelId; member
488 uint32_t channelId; member
535 uint32_t channelId; member
|
| /developtools/smartperf_host/ide/src/hdc/message/ |
| D | PayloadProtect.ts | 25 constructor(channelId: number, commandFlag: number, checkSum: number, vCode: number) {
27 this._channelId = channelId;
37 get channelId(): number { method in PayloadProtect
41 set channelId(value: number) { method in PayloadProtect
|
| D | DataMessage.ts | 49 this._channelId = payloadProtect.channelId;
83 get channelId(): number {
87 set channelId(value: number) {
|
| /developtools/profiler/host/smartperf/ide/src/hdc/message/ |
| D | PayloadProtect.ts | 25 constructor(channelId: number, commandFlag: number, checkSum: number, vCode: number) {
27 this._channelId = channelId;
37 get channelId(): number { method in PayloadProtect
41 set channelId(value: number) { method in PayloadProtect
|
| D | DataMessage.ts | 49 this._channelId = payloadProtect.channelId;
83 get channelId(): number {
87 set channelId(value: number) {
|
| /developtools/hdc/src/daemon/ |
| D | daemon.cpp | 146 bool HdcDaemon::RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, in RedirectToTask() argument
201 bool HdcDaemon::HandDaemonAuth(HSession hSession, const uint32_t channelId, SessionHandShake &hands… in HandDaemonAuth() argument
210 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in HandDaemonAuth()
230 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in HandDaemonAuth()
248 bool HdcDaemon::DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payloa… in DaemonSessionHandshake() argument
287 if (enableSecure && !HandDaemonAuth(hSession, channelId, handshake)) { in DaemonSessionHandshake()
301 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)failedString.c_str(), in DaemonSessionHandshake()
320 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in DaemonSessionHandshake()
381 bool HdcDaemon::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u… in FetchCommand() argument
397 WRITE_LOG(LOG_DEBUG, "FetchCommand channelId:%u command:%u", channelId, command); in FetchCommand()
[all …]
|
| D | daemon.h | 33 …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…
51 bool HandDaemonAuth(HSession hSession, const uint32_t channelId, SessionHandShake &handshake);
53 …bool DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payload, int pay…
|
| /developtools/profiler/host/smartperf/ide/src/hdc/hdcclient/ |
| D | HdcStream.ts | 28 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);
145 this.channelId,
161 this.hdcClient.unbindStream(this.channelId);
165 this.hdcClient.unbindStopStream(this.channelId);
|
| /developtools/smartperf_host/ide/src/hdc/hdcclient/ |
| D | HdcStream.ts | 28 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);
145 this.channelId,
161 this.hdcClient.unbindStream(this.channelId);
165 this.hdcClient.unbindStopStream(this.channelId);
|
| /developtools/hdc/src/host/ |
| D | server.h | 24 …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…
|
| D | server.cpp | 527 bool HdcServer::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u… in FetchCommand() argument
539 HChannel hChannel = sfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in FetchCommand()
544 WRITE_LOG(LOG_DEBUG, "Die channelId :%lu recv CMD_KERNEL_CHANNEL_CLOSE", channelId); in FetchCommand()
547 WRITE_LOG(LOG_DEBUG, "channelId :%lu die", channelId); in FetchCommand()
550 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &flag, 1); in FetchCommand()
566 WRITE_LOG(LOG_INFO, "CMD_KERNEL_ECHO size:%d channelId:%u", payloadSize - 1, channelId); in FetchCommand()
570 WRITE_LOG(LOG_DEBUG, "CMD_KERNEL_CHANNEL_CLOSE channelid:%u", channelId); in FetchCommand()
572 ClearOwnTasks(hSession, channelId); in FetchCommand()
574 sfc->PushAsyncMessage(channelId, ASYNC_FREE_CHANNEL, nullptr, 0); in FetchCommand()
577 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
[all …]
|
| D | client.cpp | 421 thisClass->Send(thisClass->channel->channelId, in CommandWorker()
445 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(cmd), strlen(cmd)); in ReadStd()
508 thisClass->FreeChannel(hChannel->channelId); in Connect()
525 uint32_t unOld = hChannel->channelId; in PreHandshake()
526 hChannel->channelId = ntohl(hShake->channelId); in PreHandshake()
551 Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), sizeof(ChannelHandShake)); in PreHandshake()
554 …Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), offsetof(struct ChannelHandShake, v… in PreHandshake()
559 Send(hChannel->channelId, in PreHandshake()
638 …Send(this->channel->channelId, reinterpret_cast<uint8_t *>(const_cast<char *>(this->command.c_str(… in WaitFor()
707 hTaskInfo->channelId = hChannel->channelId; in GetRemoteTaskInfo()
|
| D | server_for_client.cpp | 79 handShake.channelId = htonl(hChannel->channelId); in AcceptClient()
87 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
90 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
214 …if (ptrServer->Send(hdi->hSession->sessionId, hChannel->channelId, commandFlag, bufPtr, bufSize) <… in SendToDaemon()
296 thisClass->FreeChannel(hChannel->channelId); in OrderConnecTargetResult()
359 ptrServer->ClearOwnTasks(hSession, hfi->channelId); in CommandRemoveForward()
360 FreeChannel(hfi->channelId); in CommandRemoveForward()
576 … WRITE_LOG(LOG_DEBUG, "command send back to remote client channelId:%u", hChannel->channelId); in TaskCommand()
582 ptrServer->DispatchTaskData(hSession, hChannel->channelId, formatCommand->cmdFlag, in TaskCommand()
602 WRITE_LOG(LOG_DEBUG, "remote client mode channelId:%u", hChannel->channelId); in HandleRemote()
[all …]
|
| /developtools/smartperf_host/ide/test/hdc/message/ |
| D | PayloadProtect.test.ts | 26 expect(payloadProtect.channelId).toBeUndefined();
30 payloadProtect.channelId = true;
31 expect(payloadProtect.channelId).toBeTruthy();
|
| D | DataMessage.test.ts | 37 expect(dataMessage.channelId).toBe(-1);
41 dataMessage.channelId = true;
42 expect(dataMessage.channelId).toBeTruthy();
|
| /developtools/profiler/host/smartperf/ide/src/hdc/common/ |
| D | Serialize.ts | 44 let channelId = this.serializeU32(1, payloadProtect.channelId);
48 …let mergedArray = new Uint8Array(channelId.length + commandFlag.length + checkSum.length + vCode.l…
49 mergedArray.set(channelId);
50 mergedArray.set(commandFlag, channelId.length);
51 mergedArray.set(checkSum, channelId.length + commandFlag.length);
52 mergedArray.set(vCode, channelId.length + commandFlag.length + checkSum.length);
267 let channelId = this.parseU32(channelDataView, 1);
290 return new PayloadProtect(channelId, commandFlag, checkSum, vCode);
|
| /developtools/smartperf_host/ide/src/hdc/common/ |
| D | Serialize.ts | 44 let channelId = this.serializeU32(1, payloadProtect.channelId);
48 …let mergedArray = new Uint8Array(channelId.length + commandFlag.length + checkSum.length + vCode.l…
49 mergedArray.set(channelId);
50 mergedArray.set(commandFlag, channelId.length);
51 mergedArray.set(checkSum, channelId.length + commandFlag.length);
52 mergedArray.set(vCode, channelId.length + commandFlag.length + checkSum.length);
267 let channelId = this.parseU32(channelDataView, 1);
290 return new PayloadProtect(channelId, commandFlag, checkSum, vCode);
|
| /developtools/profiler/host/smartperf/ide/src/hdc/transmission/ |
| D | DataProcessing.ts | 83 channelId: number,
89 channelId,
|
| /developtools/smartperf_host/ide/src/hdc/transmission/ |
| D | DataProcessing.ts | 83 channelId: number,
89 channelId,
|
| /developtools/hdc/test/unittest/common/include/ |
| D | HdcJdwpTest.h | 36 bool ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, in ServerCommand() argument
|