| /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()
|
| 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
120 if (nread == UV_ENOBUFS) { in ReadStream()
123 } else if (nread == 0) { in ReadStream()
127 } else if (nread < 0) { in ReadStream()
131 uv_err_name_r(nread, buffer, bufSize); in ReadStream()
136 hChannel->availTailIndex += nread; in ReadStream()
|
| D | uart.cpp | 944 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
952 if (nread < 0) { in ReadDataFromUARTStream()
953 uv_err_name_r(nread, buffer, bufSize); in ReadDataFromUARTStream()
956 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
959 if (nread <= 0 or nread > signed(hSession->hUART->streamSize)) { in ReadDataFromUARTStream()
963 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadDataFromUARTStream()
973 hSession->hUART->streamSize -= nread; in ReadDataFromUARTStream()
974 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 | 1003 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromSession() local
1005 if (nread < 0) { in ReadCtrlFromSession()
1008 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromSession()
1013 if (nread > 64) { // 64 : max length in ReadCtrlFromSession()
1019 … hSessionBase->DispatchSessionThreadCommand(hSession, reinterpret_cast<uint8_t *>(buf), nread); in ReadCtrlFromSession()
1167 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromMain() local
1169 if (nread < 0) { in ReadCtrlFromMain()
1172 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromMain()
1176 if (nread % formatCommandSize != 0) { in ReadCtrlFromMain()
1177 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.h | 71 static void ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | forward.cpp | 244 void HdcForwardBase::ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadForwardBuf() argument
247 if (nread < 0) { in ReadForwardBuf()
252 if (nread == 0) { in ReadForwardBuf()
256 ctx->thisClass->SendToTask(ctx->id, CMD_FORWARD_DATA, (uint8_t *)buf->base, nread); in ReadForwardBuf()
|
| D | uart.h | 196 static void ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/daemon/ |
| D | jdwp.cpp | 105 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
108 if (nread == UV_ENOBUFS) { // It is definite enough, usually only 4 bytes in ReadStream()
111 } else if (nread == 0) { in ReadStream()
114 } else if (nread < JS_PKG_MIN_SIZE || nread > JS_PKG_MX_SIZE) { // valid Js package size in ReadStream()
116 } else if (nread < 0 || nread != 4) { // 4 : 4 bytes in ReadStream()
119 WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid package nread:%d.", nread); in ReadStream()
127 if (nread == sizeof(uint32_t)) { // Java: pid in ReadStream()
132 if (jsMsg->msgLen == nread) { in ReadStream()
138 … WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid js package size %d:%d.", jsMsg->msgLen, nread); in ReadStream()
|
| D | jdwp.h | 84 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 | 437 void HdcClient::ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadStd() argument
442 if (nread <= 0) { 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()
|