| /device/google/cuttlefish/host/frontend/gcastv2/libsource/ |
| D | InputSink.cpp | 144 size_t offset = mOutBuffer.size(); in sendRawEvents()
145 mOutBuffer.resize(offset + size); in sendRawEvents()
146 memcpy(mOutBuffer.data() + offset, evt_buffer, size); in sendRawEvents()
188 while (!mOutBuffer.empty()) { in onSocketSend()
190 n = ::send(mClientFd, mOutBuffer.data(), mOutBuffer.size(), 0); in onSocketSend()
197 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + n); in onSocketSend()
211 if (!mOutBuffer.empty()) { in onSocketSend()
|
| D | HostToGuestComms.cpp | 141 size_t offset = mOutBuffer.size(); in send()
147 mOutBuffer.resize(offset + totalSize); in send()
148 memcpy(mOutBuffer.data() + offset, &packetLen, sizeof(packetLen)); in send()
149 memcpy(mOutBuffer.data() + offset + sizeof(packetLen), data, size); in send()
151 mOutBuffer.resize(offset + size); in send()
152 memcpy(mOutBuffer.data() + offset, data, size); in send()
184 if (!mOutBuffer.empty()) { in onServerConnection()
280 while (!mOutBuffer.empty()) { in onSocketSend()
282 n = ::send(mSock, mOutBuffer.data(), mOutBuffer.size(), 0); in onSocketSend()
289 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + n); in onSocketSend()
[all …]
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/ |
| D | BaseConnection.cpp | 75 std::copy(data, data + size, std::back_inserter(mOutBuffer)); in send()
87 const size_t size = mOutBuffer.size(); in sendOutputData()
91 ssize_t n = mSocket->send(mOutBuffer.data() + offset, size - offset); in sendOutputData()
108 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + offset); in sendOutputData()
110 if (!mOutBuffer.empty()) { in sendOutputData()
|
| D | ClientSocket.cpp | 184 std::copy(data, data + size, std::back_inserter(mOutBuffer)); in queueOutputData()
198 std::copy(response.begin(), response.end(), std::back_inserter(mOutBuffer)); in queueResponse()
199 std::copy(body.begin(), body.end(), std::back_inserter(mOutBuffer)); in queueResponse()
210 const size_t size = mOutBuffer.size(); in sendOutputData()
214 ssize_t n = getImpl()->send(mOutBuffer.data() + offset, size - offset); in sendOutputData()
232 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + offset); in sendOutputData()
234 if (!mOutBuffer.empty()) { in sendOutputData()
|
| D | HTTPClientConnection.cpp | 116 std::copy(request.begin(), request.end(), std::back_inserter(mOutBuffer)); in sendRequest()
237 std::copy(data, &data[size], std::back_inserter(mOutBuffer)); in queueOutputData()
249 const size_t size = mOutBuffer.size(); in sendOutputData()
253 ssize_t n = mImpl->send(mOutBuffer.data() + offset, size - offset); in sendOutputData()
276 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + offset); in sendOutputData()
278 if (!mOutBuffer.empty()) { in sendOutputData()
|
| D | SSLSocket.cpp | 345 const size_t pos = mOutBuffer.size(); in queueOutputData()
346 mOutBuffer.resize(pos + size); in queueOutputData()
347 memcpy(mOutBuffer.data() + pos, data, size); in queueOutputData()
360 const size_t size = mOutBuffer.size(); in sendOutputData()
365 fd(), mOutBuffer.data() + offset, size - offset, 0); in sendOutputData()
380 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + offset); in sendOutputData()
386 if (!mOutBuffer.empty()) { in sendOutputData()
|
| /device/google/cuttlefish/host/frontend/gcastv2/webrtc/ |
| D | RTPSocketHandler.cpp | 574 std::copy(framing, framing + sizeof(framing), std::back_inserter(mOutBuffer)); in queueTCPOutputPacket()
575 std::copy(data, data + size, std::back_inserter(mOutBuffer)); in queueTCPOutputPacket()
588 const size_t size = mOutBuffer.size(); in sendTCPOutputData()
594 auto n = mSocket->send(mOutBuffer.data() + offset, size - offset); in sendTCPOutputData()
611 mOutBuffer.erase(mOutBuffer.begin(), mOutBuffer.begin() + offset); in sendTCPOutputData()
613 if (!mOutBuffer.empty() && !disconnected) { in sendTCPOutputData()
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/include/https/ |
| D | BaseConnection.h | 55 std::vector<uint8_t> mOutBuffer; member
|
| D | HTTPClientConnection.h | 54 std::vector<uint8_t> mOutBuffer; member
|
| D | ClientSocket.h | 66 std::vector<uint8_t> mOutBuffer; member
|
| D | SSLSocket.h | 94 std::vector<uint8_t> mOutBuffer; member
|
| /device/google/cuttlefish/host/frontend/gcastv2/libsource/include/source/ |
| D | InputSink.h | 52 std::vector<uint8_t> mOutBuffer; member
|
| D | HostToGuestComms.h | 61 std::vector<uint8_t> mOutBuffer; member
|
| /device/google/cuttlefish/host/frontend/gcastv2/webrtc/include/webrtc/ |
| D | RTPSocketHandler.h | 110 std::vector<uint8_t> mOutBuffer; member
|