| /developtools/hdc/src/test/jdwp/ |
| D | HdcJdwpSimulator.cpp | 96 void HdcJdwpSimulator::ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) in ProcessIncoming() argument
98 HiLog::Debug(LABEL, "ProcessIncoming :%{public}d", nread); in ProcessIncoming()
100 if (nread > 0) { in ProcessIncoming()
101 std::unique_ptr<char[]> recv = std::make_unique<char[]>(nread + 1); in ProcessIncoming()
102 if (memset_s(recv.get(), nread, 0, nread) != EOK) { in ProcessIncoming()
106 if (memcpy_s(recv.get(), nread, buf->base, nread) != EOK) { in ProcessIncoming()
110 for (int i = 0; i < (nread + 1); i++) { in ProcessIncoming()
118 reply.insert(reply.end(), buf->base, buf->base + nread); in ProcessIncoming()
122 for (int i = 0; i < (HANDSHAKE_MESSAGE.size() + nread + 1); i++) { in ProcessIncoming()
125 SendToStream(client, buf, HANDSHAKE_MESSAGE.size() + nread + 1, in ProcessIncoming()
[all …]
|
| D | HdcJdwpSimulator.h | 48 static void ReceiveNewFd(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf);
49 static void ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/common/ |
| D | tcp.cpp | 35 void HdcTCPBase::RecvUDP(uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sock… in RecvUDP() argument
40 if (nread <= 0) { in RecvUDP()
70 void HdcTCPBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
77 if (nread == UV_ENOBUFS) { in ReadStream()
80 } else if (nread < 0) { in ReadStream()
85 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadStream()
89 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadStream()
90 WRITE_LOG(LOG_FATAL, "ReadStream FetchIOBuf error nread:%zd", nread); in ReadStream()
|
| D | tcp.h | 24 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
32 …uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, unsigned fla…
|
| D | channel.cpp | 110 void HdcChannelBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
121 if (nread == UV_ENOBUFS) { in ReadStream()
124 } else if (nread == 0) { in ReadStream()
128 } else if (nread < 0) { in ReadStream()
132 uv_err_name_r(nread, buffer, bufSize); in ReadStream()
137 hChannel->availTailIndex += nread; in ReadStream()
|
| D | uart.cpp | 946 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
954 if (nread < 0) { in ReadDataFromUARTStream()
955 uv_err_name_r(nread, buffer, bufSize); in ReadDataFromUARTStream()
958 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
961 if (nread <= 0 or nread > signed(hSession->hUART->streamSize)) { in ReadDataFromUARTStream()
965 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadDataFromUARTStream()
975 hSession->hUART->streamSize -= nread; in ReadDataFromUARTStream()
976 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread:%d", __FUNCTION__, hSession->sessionId, nread); in ReadDataFromUARTStream()
|
| D | usb.h | 47 static void ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | usb.cpp | 29 void HdcUSBBase::ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadUSB() argument
34 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadUSB()
|
| D | session.cpp | 1024 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_MAIN], buf, size); in ReadCtrlFromSession() local
1026 if (nread < 0) { in ReadCtrlFromSession()
1029 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromSession()
1034 if (nread == 0) { in ReadCtrlFromSession()
1040 … hSessionBase->DispatchSessionThreadCommand(hSession, reinterpret_cast<uint8_t *>(buf), nread); in ReadCtrlFromSession()
1190 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromMain() local
1192 if (nread < 0) { in ReadCtrlFromMain()
1195 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromMain()
1199 if (nread % formatCommandSize != 0) { in ReadCtrlFromMain()
1200 WRITE_LOG(LOG_FATAL, "ReadCtrlFromMain size failed, nread == %d", nread); in ReadCtrlFromMain()
[all …]
|
| D | channel.h | 26 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
|
| D | forward.cpp | 254 void HdcForwardBase::ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadForwardBuf() argument
257 if (nread < 0) { in ReadForwardBuf()
258 WRITE_LOG(LOG_INFO, "ReadForwardBuf nread:%zd id:%u", nread, ctx->id); in ReadForwardBuf()
263 if (nread == 0) { in ReadForwardBuf()
268 ctx->thisClass->SendToTask(ctx->id, CMD_FORWARD_DATA, (uint8_t *)buf->base, nread); in ReadForwardBuf()
|
| D | forward.h | 77 static void ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | uart.h | 196 static void ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/daemon/ |
| D | daemon_bridge.cpp | 60 void HdcDaemonBridge::AcceptClient(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf) in AcceptClient() argument
71 if (nread != SOCKET_FD_LEN) { in AcceptClient()
72 WRITE_LOG(LOG_FATAL, "AcceptClient err nread %d", nread); in AcceptClient()
|
| D | jdwp.cpp | 111 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
114 if (nread == UV_ENOBUFS) { // It is definite enough, usually only 4 bytes in ReadStream()
117 } else if (nread == 0) { in ReadStream()
120 } else if (nread < signed(JS_PKG_MIN_SIZE + sizeof(JsMsgHeader)) || in ReadStream()
121 nread > signed(JS_PKG_MAX_SIZE + sizeof(JsMsgHeader))) { in ReadStream()
123 } else if (nread < 0 || nread != 4) { // 4 : 4 bytes in ReadStream()
126 WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid package nread:%d.", nread); in ReadStream()
134 if (nread == sizeof(uint32_t)) { // Java: pid in ReadStream()
140 if (jsMsg->msgLen == nread) { in ReadStream()
147 … WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid js package size %d:%d.", jsMsg->msgLen, nread); in ReadStream()
|
| D | daemon_bridge.h | 42 static void AcceptClient(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf);
|
| D | jdwp.h | 88 static void ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/host/ |
| D | client.h | 39 static void ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | client.cpp | 440 void HdcClient::ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadStd() argument
445 if (nread <= 0) { in ReadStd()
446 WRITE_LOG(LOG_FATAL, "ReadStd error nread:%zd", nread); in ReadStd()
|
| /developtools/hdc/src/test/ |
| D | ut_mod.cpp | 172 auto funcOnRead = [](uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) -> void { in UtForwardWaiter() argument
173 if (nread > 0 && !strcmp(buf->base, MESSAGE_SUCCESS.c_str())) { in UtForwardWaiter()
|