Home
last modified time | relevance | path

Searched refs:hChannel (Results 1 - 7 of 7) sorted by relevance

/developtools/hdc/src/common/
H A Dchannel.cpp96 HChannel hChannel = (HChannel)v.second; in ClearChannels() local
97 if (!hChannel->isDead) { in ClearChannels()
98 FreeChannel(hChannel->channelId); in ClearChannels()
117 HChannel hChannel = (HChannel)tcp->data; in ReadStream() local
118 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in ReadStream()
119 uint32_t channelId = hChannel->channelId; in ReadStream()
137 hChannel->availTailIndex += nread; in ReadStream()
139 while (hChannel->availTailIndex > DWORD_SERIALIZE_SIZE) { in ReadStream()
140 size = ntohl(*reinterpret_cast<uint32_t *>(hChannel->ioBuf + indexBuf)); // big endian in ReadStream()
146 if (hChannel in ReadStream()
179 HChannel hChannel = (HChannel)req->handle->data; WriteCallback() local
270 SendChannelWithCmd(HChannel hChannel, const uint16_t commandFlag, uint8_t *bufPtr, const int size) SendChannelWithCmd() argument
295 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); SendWithCmd() local
310 SendChannel(HChannel hChannel, uint8_t *bufPtr, const int size) SendChannel() argument
341 HChannel hChannel = reinterpret_cast<HChannel>(AdminChannel(OP_QUERY_REF, channelId, nullptr)); Send() local
380 auto hChannel = new HdcChannel(); MallocChannel() local
412 HChannel hChannel = (HChannel)handle->data; FreeChannelFinally() local
442 FreeChannelContinue(HChannel hChannel) FreeChannelContinue() argument
472 HChannel hChannel = (HChannel)handle->data; FreeChannelOpeate() local
511 HChannel hChannel = AdminChannel(OP_QUERY, channelId, nullptr); FreeChannel() local
565 EchoToClient(HChannel hChannel, uint8_t *bufPtr, const int size) EchoToClient() argument
592 HChannel hChannel = (HChannel)v.second; EchoToAllChannelsViaSessionId() local
600 DispMntnInfo(HChannel hChannel) DispMntnInfo() argument
[all...]
H A Dchannel.h44 virtual int ReadChannel(HChannel hChannel, uint8_t *bufPtr, const int bytesIO) in ReadChannel() argument
48 virtual void NotifyInstanceChannelFree(HChannel hChannel) {}; in NotifyInstanceChannelFree() argument
50 void SendChannel(HChannel hChannel, uint8_t *bufPtr, const int size);
51 void SendChannelWithCmd(HChannel hChannel, const uint16_t commandFlag, uint8_t *bufPtr, const int size);
52 void EchoToClient(HChannel hChannel, uint8_t *bufPtr, const int size);
74 void FreeChannelContinue(HChannel hChannel);
83 void DispMntnInfo(HChannel hChannel);
/developtools/hdc/src/host/
H A Dserver_for_client.h26 void EchoClient(HChannel hChannel, MessageLevel level, const char *msg, ...);
27 void EchoClientRaw(const HChannel hChannel, uint8_t *payload, const int payloadSize);
28 void SendCommandToClient(const HChannel hChannel, const uint16_t commandFlag, uint8_t *payload,
37 int ReadChannel(HChannel hChannel, uint8_t *bufPtr, const int bytesIO) override;
38 void ReportServerVersion(HChannel hChannel);
39 bool DoCommand(HChannel hChannel, void *formatCommandInput);
40 void OrderFindTargets(HChannel hChannel);
41 bool NewConnectTry(void *ptrServer, HChannel hChannel, const string &connectKey, bool isCheck = false);
43 bool SendToDaemon(HChannel hChannel, const uint16_t commandFlag, uint8_t *bufPtr, const int bufSize);
44 int BindChannelToSession(HChannel hChannel, uint8_
[all...]
H A Dserver_for_client.cpp51 HChannel hChannel = nullptr; in AcceptClient() local
52 uint32_t uid = thisClass->MallocChannel(&hChannel); in AcceptClient()
53 if (!hChannel) { in AcceptClient()
54 WRITE_LOG(LOG_FATAL, "AcceptClient hChannel is nullptr"); in AcceptClient()
57 int rc = uv_accept(server, (uv_stream_t *)&hChannel->hWorkTCP); in AcceptClient()
66 uv_recv_buffer_size((uv_handle_t *)&hChannel->hWorkTCP, &bufMaxSize); in AcceptClient()
78 uv_read_start((uv_stream_t *)&hChannel->hWorkTCP, funcChannelHeaderAlloc, ReadStream); in AcceptClient()
83 handShake.channelId = htonl(hChannel->channelId); in AcceptClient()
91 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
94 thisClass->Send(hChannel in AcceptClient()
167 EchoClient(HChannel hChannel, MessageLevel level, const char *msg, ...) EchoClient() argument
190 EchoClientRaw(const HChannel hChannel, uint8_t *payload, const int payloadSize) EchoClientRaw() argument
196 SendCommandToClient(const HChannel hChannel, const uint16_t commandFlag, uint8_t *payload, const int payloadSize) SendCommandToClient() argument
202 SendToDaemon(HChannel hChannel, const uint16_t commandFlag, uint8_t *bufPtr, const int bufSize) SendToDaemon() argument
231 OrderFindTargets(HChannel hChannel) OrderFindTargets() argument
261 HChannel hChannel = (HChannel)req->data; OrderConnecTargetResult() local
309 NewConnectTry(void *ptrServer, HChannel hChannel, const string &connectKey, bool isCheck) NewConnectTry() argument
344 CommandRemoveSession(HChannel hChannel, const char *connectKey) CommandRemoveSession() argument
386 GetTargetList(HChannel hChannel, void *formatCommandInput) GetTargetList() argument
406 GetAnyTarget(HChannel hChannel) GetAnyTarget() argument
425 WaitForAny(HChannel hChannel) WaitForAny() argument
443 RemoveForward(HChannel hChannel, const char *parameterString) RemoveForward() argument
471 DoCommandLocal(HChannel hChannel, void *formatCommandInput) DoCommandLocal() argument
552 TaskCommand(HChannel hChannel, void *formatCommandInput) TaskCommand() argument
611 HandleRemote(HChannel hChannel, string &parameters, RemoteType flag) HandleRemote() argument
632 DoCommandRemote(HChannel hChannel, void *formatCommandInput) DoCommandRemote() argument
684 DoCommand(HChannel hChannel, void *formatCommandInput) DoCommand() argument
698 FindAliveSessionFromDaemonMap(const HChannel hChannel) FindAliveSessionFromDaemonMap() argument
728 BindChannelToSession(HChannel hChannel, uint8_t *bufPtr, const int bytesIO) BindChannelToSession() argument
763 CheckAutoFillTarget(HChannel hChannel) CheckAutoFillTarget() argument
791 ChannelHandShake(HChannel hChannel, uint8_t *bufPtr, const int bytesIO) ChannelHandShake() argument
826 ReportServerVersion(HChannel hChannel) ReportServerVersion() argument
835 ReadChannel(HChannel hChannel, uint8_t *bufPtr, const int bytesIO) ReadChannel() argument
[all...]
H A Dclient.cpp49 void HdcClient::NotifyInstanceChannelFree(HChannel hChannel) in NotifyInstanceChannelFree() argument
53 ModifyTty(false, &hChannel->stdinTty); in NotifyInstanceChannelFree()
474 HChannel hChannel = (HChannel)stream->data; in ReadStd() local
475 HdcClient *thisClass = (HdcClient *)hChannel->clsChannel; in ReadStd()
476 char *cmd = hChannel->bufStd; in ReadStd()
481 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(cmd), strlen(cmd)); in ReadStd()
482 Base::ZeroArray(hChannel->bufStd); in ReadStd()
510 void HdcClient::BindLocalStd(HChannel hChannel) in BindLocalStd() argument
521 if (uv_tty_init(loopMain, &hChannel->stdoutTty, STDOUT_FILENO, 0) in BindLocalStd()
522 || uv_tty_init(loopMain, &hChannel in BindLocalStd()
542 HChannel hChannel = reinterpret_cast<HChannel>(thisClass->channel); Connect() local
572 HChannel hChannel = reinterpret_cast<HChannel>(thisClass->channel); RetryTcpConnectWorker() local
590 PreHandshake(HChannel hChannel, const uint8_t *buf) PreHandshake() argument
647 ReadChannel(HChannel hChannel, uint8_t *buf, const int bytesIO) ReadChannel() argument
797 GetRemoteTaskInfo(HChannel hChannel) GetRemoteTaskInfo() argument
[all...]
H A Dserver.cpp573 HChannel hChannel = sfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in FetchCommand() local
574 if (!hChannel) { in FetchCommand()
587 if (hChannel->isDead) { in FetchCommand()
589 --hChannel->ref; in FetchCommand()
594 sfc->EchoClientRaw(hChannel, payload, payloadSize); in FetchCommand()
600 sfc->EchoClient(hChannel, level, s.c_str()); in FetchCommand()
626 Base::TryCloseHandle((uv_handle_t *)&hChannel->hChildWorkTCP); // detch client channel in FetchCommand()
641 if (hChannel->fromClient) { in FetchCommand()
643 sfc->SendCommandToClient(hChannel, command, payload, payloadSize); in FetchCommand()
647 HSession hSessionByQuery = AdminSession(OP_QUERY, hChannel in FetchCommand()
897 HChannel hChannel = hSfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); AttachChannel() local
924 HChannel hChannel = hSfc->AdminChannel(OP_QUERY, channelId, nullptr); DeatchChannel() local
963 HChannel hChannel = hSfc->AdminChannel(OP_QUERY, channelId, nullptr); ServerCommand() local
[all...]
H A Dclient.h43 int ReadChannel(HChannel hChannel, uint8_t *buf, const int bytesIO) override;
44 int PreHandshake(HChannel hChannel, const uint8_t *buf);
50 void BindLocalStd(HChannel hChannel);
52 void NotifyInstanceChannelFree(HChannel hChannel) override;
54 HTaskInfo GetRemoteTaskInfo(HChannel hChannel);

Completed in 6 milliseconds