| /developtools/profiler/host/smartperf/client/client_command/include/ |
| H A D | sp_thread_socket.h | 104 spSocket.Send("init::False,\"error\":" + errorInfo); in InitRecv()
109 spSocket.Send(std::string("init::") + ((code == ErrCode::OK) ? "True" : "False")); in InitRecv()
115 spSocket.Send("SP_daemon is running"); in StartRecv()
125 spSocket.Send("start::True"); in StartRecv()
128 spSocket.Send("start::False"); in StartRecv()
133 auto lambdaTask = [&spSocket](const std::string &data) { spSocket.Send(data); }; in StartRecvRealtime()
137 spSocket.Send("start::True"); in StartRecvRealtime()
139 spSocket.Send("start::False"); in StartRecvRealtime()
146 spSocket.Send("stop::True"); in StopRecvRealtime()
155 spSocket.Send("startRecor in StartRecvRecord()
[all...] |
| H A D | sp_server_socket.h | 37 int Send(const std::string &sendBuf) const;
|
| /developtools/hdc/hdc_rust/src/common/ |
| H A D | taskbase.rs | 20 pub trait TaskBase: Send + Sync + 'static {
|
| H A D | jdwp.rs | 50 pub trait JdwpBase: Send + Sync + 'static {}
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| H A D | base.rs | 64 pub trait Reader: Send + Sync + 'static {
|
| /developtools/hdc/src/daemon/ |
| H A D | daemon.cpp | 437 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, in InitMod()
796 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)failedString.c_str(), in InitMod()
881 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in InitMod()
901 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in InitMod()
913 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in InitMod()
955 return Send(sessionId, channelId, command, reinterpret_cast<uint8_t *>(bufPtr), size) > 0; in InitMod()
1108 Send(sessionid, channelid, CMD_KERNEL_HANDSHAKE, in InitMod()
1111 Send(sessionid, channelid, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in InitMod()
1120 Send(sessionid, channelId, CMD_KERNEL_HANDSHAKE, in InitMod()
|
| /developtools/hdc/hdc_rust/src/ |
| H A D | utils.rs | 83 T : Send + 'static, in spawn()
86 ylong_runtime::spawn(Box::into_pin(Box::new(fun) as Box<dyn Future<Output = ()> + Send + Sync>)) in spawn()
|
| /developtools/hdc/src/host/ |
| H A D | client.cpp | 456 thisClass->Send(thisClass->channel->channelId, in CommandWorker()
481 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(cmd), strlen(cmd)); in ReadStd()
631 Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), sizeof(ChannelHandShake)); in PreHandshake()
634 Send(hChannel->channelId, reinterpret_cast<uint8_t *>(hShake), offsetof(struct ChannelHandShake, version)); in PreHandshake()
639 Send(hChannel->channelId, in PreHandshake()
731 Send(this->channel->channelId, reinterpret_cast<uint8_t *>(const_cast<char *>(this->command.c_str())), in WaitFor()
|
| H A D | server.cpp | 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()
928 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in DeatchChannel()
939 Send(hSession->sessionId, hChannel->channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in DeatchChannel()
|
| H A D | server_for_client.cpp | 91 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
94 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
221 if (ptrServer->Send(hdi->hSession->sessionId, hChannel->channelId, commandFlag, bufPtr, bufSize) < 0) { in SendToDaemon()
222 WRITE_LOG(LOG_FATAL, "SendToDaemon Send failed channelId:%u", hChannel->channelId); in SendToDaemon()
603 } else { // Send to Daemon-side to do in TaskCommand()
|
| /developtools/hdc/src/common/ |
| H A D | channel.h | 49 void Send(const uint32_t channelId, uint8_t *bufPtr, const int size);
|
| H A D | task.cpp | 73 return sessionBase->Send(taskInfo->sessionId, taskInfo->channelId, command, bufPtr, size) > 0; in SendToAnother()
|
| H A D | session.h | 95 int Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, const uint8_t *data,
|
| H A D | channel.cpp | 338 void HdcChannelBase::Send(const uint32_t channelId, uint8_t *bufPtr, const int size) in Send() function in Hdc::HdcChannelBase
340 StartTraceScope("HdcChannelBase::Send"); in Send()
343 WRITE_LOG(LOG_FATAL, "Send hChannel nullptr channelId:%u", channelId); in Send()
348 WRITE_LOG(LOG_FATAL, "Send isDead channelId:%u", channelId); in Send()
|
| H A D | session.cpp | 831 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag, in Send() function in Hdc::HdcSessionBase
834 StartTraceScope("HdcSessionBase::Send"); in Send()
837 WRITE_LOG(LOG_WARN, "Send to offline device, drop it, sessionId:%u", sessionId); in Send()
1119 Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, in WorkThreadStartSession()
|
| /developtools/profiler/host/smartperf/client/client_command/ |
| H A D | sp_server_socket.cpp | 83 int SpServerSocket::Send(const std::string &sendBuf) const in Send() function in OHOS::SmartPerf::SpServerSocket
87 LOGE("SpServerSocket::Send Error(%d) fd(%d)", sendBytes, connFd); in Send()
|