Home
last modified time | relevance | path

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

12

/developtools/hdc/src/common/
Dchannel.cpp98 FreeChannel(hChannel->channelId); in ClearChannels()
119 uint32_t channelId = hChannel->channelId; in ReadStream() local
122 WRITE_LOG(LOG_FATAL, "ReadStream nobufs channelId:%u", channelId); in ReadStream()
126 WRITE_LOG(LOG_FATAL, "ReadStream idle read channelId:%u", channelId); in ReadStream()
133 WRITE_LOG(LOG_DEBUG, "ReadStream channelId:%u failed:%s", channelId, buffer); in ReadStream()
142 WRITE_LOG(LOG_FATAL, "ReadStream size:%d channelId:%u", size, channelId); in ReadStream()
153 childRet, channelId, hChannel->keepAlive); in ReadStream()
172 thisClass->FreeChannel(hChannel->channelId); in ReadStream()
173 WRITE_LOG(LOG_DEBUG, "Read Stream needExit, FreeChannel finish channelId:%u", channelId); in ReadStream()
184 hChannel->channelId, hChannel->isDead, int32_t(hChannel->ref)); in WriteCallback()
[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()
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()
59 …WRITE_LOG(LOG_FATAL, "TaskFinish singalStop channelId:%u command:%u", taskInfo->channelId, command… in SendToAnother()
64 channelBase->SendWithCmd(taskInfo->channelId, command, bufPtr, size); in SendToAnother()
68 … return sessionBase->Send(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size) > 0; in SendToAnother()
96 sessionBase->LogMsg(taskInfo->sessionId, taskInfo->channelId, level, log.c_str()); in LogMsg()
103 return hSession->ServerCommand(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size); in ServerCommand()
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…
93 …int Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, const uin…
99 …HTaskInfo AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, HTaskInfo hInpu…
100 …bool DispatchTaskData(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t…
108 …virtual bool FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uin… in FetchCommand() argument
[all …]
Dsession.cpp83 WRITE_LOG(LOG_WARN, "TryRemoveTask channelId:%u", hTask->channelId); in TryRemoveTask()
103 hTask->channelId, hTask->taskStop, hTask->taskFree); in BeginRemoveTask()
107 …RITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
110 …(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
119 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
124 WRITE_LOG(LOG_WARN, "TaskDelay TryRemoveTask false channelId:%u", hTask->channelId); in BeginRemoveTask()
127 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
152 uint32_t channelId = iter->first; in ClearOwnTasks() local
155 if (channelIDInput != channelId) { in ClearOwnTasks()
730 idx++, ti->channelId, ti->taskType, ti->closeRetryCount); in DumpTasksInfo()
[all …]
/developtools/hdc/src/daemon/
Ddaemon.h50 …bool FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *pa…
52 …bool ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t command, uin…
67 …bool RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, const uint16…
72 bool HandDaemonAuth(HSession hSession, const uint32_t channelId, SessionHandShake &handshake);
78 …bool DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payload, int pay…
82 … bool HandDaemonAuthInit(HSession hSession, const uint32_t channelId, SessionHandShake &handshake);
83 …bool HandDaemonAuthPubkey(HSession hSession, const uint32_t channelId, SessionHandShake &handshake…
84 …bool HandDaemonAuthSignature(HSession hSession, const uint32_t channelId, SessionHandShake &handsh…
94 uint32_t channelId, uint32_t sessionid, string pubkey, string token);
Ddaemon.cpp191 bool HdcDaemon::RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, in InitMod() argument
408 bool HdcDaemon::HandDaemonAuthInit(HSession hSession, const uint32_t channelId, SessionHandShake &h… in InitMod() argument
414 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in InitMod()
422 bool HdcDaemon::HandDaemonAuthPubkey(HSession hSession, const uint32_t channelId, SessionHandShake … in InitMod() argument
442 std::ref(handshake), channelId, hSession->sessionId, confirmmsg); in InitMod()
460 SendAuthSignMsg(handshake, channelId, hSession->sessionId, pubkey, hSession->tokenRSA); in InitMod()
466 EchoHandshakeMsg(handshake, channelId, hSession->sessionId, notifymsg); in InitMod()
525 bool HdcDaemon::HandDaemonAuthSignature(HSession hSession, const uint32_t channelId, SessionHandSha… in InitMod() argument
537 …EchoHandshakeMsg(handshake, channelId, hSession->sessionId, "[E000010]:Auth failed, cannt login th… in InitMod()
542 SendAuthOkMsg(handshake, channelId, hSession->sessionId); in InitMod()
[all …]
Ddaemon_app.cpp28 WRITE_LOG(LOG_INFO, "~HdcDaemonApp channelId:%u", taskInfo->channelId); in ~HdcDaemonApp()
34 WRITE_LOG(LOG_WARN, "HdcTaskBase not ready for release channelId:%u", taskInfo->channelId); in ReadyForRelease()
38 WRITE_LOG(LOG_WARN, "asyncCommand not ready for release channelId:%u", taskInfo->channelId); in ReadyForRelease()
41 WRITE_LOG(LOG_INFO, "ReadyForRelease channelId:%u", taskInfo->channelId); in ReadyForRelease()
49 command, taskInfo->channelId); in CommandDispatch()
Dshell.cpp45 WRITE_LOG(LOG_DEBUG, "~HdcShell channelId:%u", taskInfo->channelId); in ~HdcShell()
51 WRITE_LOG(LOG_WARN, "not ready for release channelId:%u", taskInfo->channelId); in ReadyForRelease()
55 WRITE_LOG(LOG_WARN, "childReady false channelId:%u", taskInfo->channelId); in ReadyForRelease()
59 WRITE_LOG(LOG_WARN, "childShell not ready for release channelId:%u", taskInfo->channelId); in ReadyForRelease()
313 … WRITE_LOG(LOG_DEBUG, "StartShell pid:%d channelId:%u ret:%d", pidShell, taskInfo->channelId, ret); in StartShell()
/developtools/smartperf_host/ide/src/hdc/message/
DPayloadProtect.ts25 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
DDataMessage.ts49 this._channelId = payloadProtect.channelId;
83 get channelId(): number {
87 set channelId(value: number) {
/developtools/hdc/src/host/
Dserver.cpp526 bool HdcServer::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u… in FetchCommand() argument
538 HChannel hChannel = sfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in FetchCommand()
543 WRITE_LOG(LOG_DEBUG, "Die channelId :%lu recv CMD_KERNEL_CHANNEL_CLOSE", channelId); in FetchCommand()
546 WRITE_LOG(LOG_DEBUG, "channelId :%lu die", channelId); in FetchCommand()
549 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &flag, 1); in FetchCommand()
553 WRITE_LOG(LOG_FATAL, "FetchCommand channelId:%u isDead", channelId); 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()
[all …]
Dhost_unity.cpp26 WRITE_LOG(LOG_DEBUG, "~HdcHostUnity channelId:%u", taskInfo->channelId); in ~HdcHostUnity()
32 WRITE_LOG(LOG_WARN, "not ready for release channelId:%u", taskInfo->channelId); in ReadyForRelease()
36 … WRITE_LOG(LOG_WARN, "enableLog true hasFilelogClosed false channelId:%u", taskInfo->channelId); in ReadyForRelease()
46 WRITE_LOG(LOG_WARN, "StopTask hasFilelogClosed true channelId:%u", taskInfo->channelId); in StopTask()
52 … WRITE_LOG(LOG_DEBUG, "taskInfo->channelId:%u fileLog:%d", taskInfo->channelId, opContext.fileLog); in StopTask()
73 …WRITE_LOG(LOG_FATAL, "InitLocalLog uv_fs_open failed taskInfo->channelId:%u", taskInfo->channelId); in InitLocalLog()
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_for_client.cpp82 handShake.channelId = htonl(hChannel->channelId); in AcceptClient()
90 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
93 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
220 …if (ptrServer->Send(hdi->hSession->sessionId, hChannel->channelId, commandFlag, bufPtr, bufSize) <… in SendToDaemon()
221 WRITE_LOG(LOG_FATAL, "SendToDaemon Send failed channelId:%u", hChannel->channelId); in SendToDaemon()
303 thisClass->FreeChannel(hChannel->channelId); in OrderConnecTargetResult()
378 ptrServer->ClearOwnTasks(hSession, hfi->channelId); in RemoveFportkey()
379 FreeChannel(hfi->channelId); in RemoveFportkey()
595 … WRITE_LOG(LOG_DEBUG, "command send back to remote client channelId:%u", hChannel->channelId); in TaskCommand()
601 ptrServer->DispatchTaskData(hSession, hChannel->channelId, formatCommand->cmdFlag, in TaskCommand()
[all …]
Dclient.cpp424 thisClass->Send(thisClass->channel->channelId, in CommandWorker()
449 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(cmd), strlen(cmd)); in ReadStd()
512 thisClass->FreeChannel(hChannel->channelId); in Connect()
529 uint32_t unOld = hChannel->channelId; in PreHandshake()
530 hChannel->channelId = ntohl(hShake->channelId); in PreHandshake()
555 Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), sizeof(ChannelHandShake)); in PreHandshake()
558 …Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), offsetof(struct ChannelHandShake, v… in PreHandshake()
563 Send(hChannel->channelId, in PreHandshake()
655 …Send(this->channel->channelId, reinterpret_cast<uint8_t *>(const_cast<char *>(this->command.c_str(… in WaitFor()
724 hTaskInfo->channelId = hChannel->channelId; in GetRemoteTaskInfo()
/developtools/smartperf_host/ide/test/hdc/message/
DPayloadProtect.test.ts25 expect(payloadProtect.channelId).toBeUndefined();
29 payloadProtect.channelId = true;
30 expect(payloadProtect.channelId).toBeTruthy();
DDataMessage.test.ts36 expect(dataMessage.channelId).toBe(-1);
40 dataMessage.channelId = true;
41 expect(dataMessage.channelId).toBeTruthy();
/developtools/smartperf_host/ide/src/hdc/hdcclient/
DHdcStream.ts27 private readonly channelId: number; property in HdcStream
34 this.channelId = Utils.getLocalId();
35 this.hdcClient.bindStream(this.channelId, this);
138 this.channelId,
154 this.hdcClient.unbindStream(this.channelId);
/developtools/smartperf_host/ide/src/hdc/common/
DSerialize.ts44 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/transmission/
DDataProcessing.ts83 channelId: number,
89 channelId,
/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/hdc/hdc_rust/src/cffi/
Dserial_struct.cpp53 .channelId = value.channelId, in SerializePayloadProtect()
173 .channelId = pp.channelId, in ParsePayloadProtect()
Dserial_struct.h50 uint32_t channelId; member
101 uint32_t channelId; member
234 return Message(Field<fieldOne, &BaseStruct::PayloadProtect::channelId>("channelId"),
/developtools/smartperf_host/ide/src/trace/component/trace/sheet/vmtracker/
DTabPaneGpuResourceVmTracker.ts42 name: SpSystemTrace.DATA_DICT.get(results[i].channelId),

12