Home
last modified time | relevance | path

Searched refs:send_bytes (Results 1 – 25 of 547) sorted by relevance

12345678910>>...22

/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_fsm_kexinit.erl78 ssh_connection_handler:send_bytes(NewKeys, D),
80 ssh_connection_handler:send_bytes(ExtInfo, D),
85 ssh_connection_handler:send_bytes(NewKeys, D),
87 ssh_connection_handler:send_bytes(ExtInfo, D),
93 ssh_connection_handler:send_bytes(GexGroup, D),
113 ssh_connection_handler:send_bytes(NewKeys, D),
115 ssh_connection_handler:send_bytes(ExtInfo, D),
120 ssh_connection_handler:send_bytes(NewKeys, D),
122 ssh_connection_handler:send_bytes(ExtInfo, D),
132 ssh_connection_handler:send_bytes(NewKeys, D),
[all …]
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_fsm_kexinit.erl78 ssh_connection_handler:send_bytes(NewKeys, D),
80 ssh_connection_handler:send_bytes(ExtInfo, D),
85 ssh_connection_handler:send_bytes(NewKeys, D),
87 ssh_connection_handler:send_bytes(ExtInfo, D),
93 ssh_connection_handler:send_bytes(GexGroup, D),
113 ssh_connection_handler:send_bytes(NewKeys, D),
115 ssh_connection_handler:send_bytes(ExtInfo, D),
120 ssh_connection_handler:send_bytes(NewKeys, D),
122 ssh_connection_handler:send_bytes(ExtInfo, D),
132 ssh_connection_handler:send_bytes(NewKeys, D),
[all …]
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_fsm_kexinit.erl78 ssh_connection_handler:send_bytes(NewKeys, D),
80 ssh_connection_handler:send_bytes(ExtInfo, D),
85 ssh_connection_handler:send_bytes(NewKeys, D),
87 ssh_connection_handler:send_bytes(ExtInfo, D),
93 ssh_connection_handler:send_bytes(GexGroup, D),
113 ssh_connection_handler:send_bytes(NewKeys, D),
115 ssh_connection_handler:send_bytes(ExtInfo, D),
120 ssh_connection_handler:send_bytes(NewKeys, D),
122 ssh_connection_handler:send_bytes(ExtInfo, D),
132 ssh_connection_handler:send_bytes(NewKeys, D),
[all …]
/dports/lang/erlang/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_fsm_kexinit.erl78 ssh_connection_handler:send_bytes(NewKeys, D),
80 ssh_connection_handler:send_bytes(ExtInfo, D),
85 ssh_connection_handler:send_bytes(NewKeys, D),
87 ssh_connection_handler:send_bytes(ExtInfo, D),
93 ssh_connection_handler:send_bytes(GexGroup, D),
113 ssh_connection_handler:send_bytes(NewKeys, D),
115 ssh_connection_handler:send_bytes(ExtInfo, D),
120 ssh_connection_handler:send_bytes(NewKeys, D),
122 ssh_connection_handler:send_bytes(ExtInfo, D),
132 ssh_connection_handler:send_bytes(NewKeys, D),
[all …]
/dports/devel/pecl-swoole/swoole-4.8.5/src/reactor/
H A Dbase.cc288 ssize_t send_bytes = 0; in _write() local
289 auto send_fn = [&send_bytes, socket, buf, n]() -> ssize_t { in _write()
290 send_bytes = socket->send(buf, n, 0); in _write()
291 return send_bytes; in _write()
293 auto append_fn = [&send_bytes, buf, n](Buffer *buffer) { in _write()
294 ssize_t offset = send_bytes > 0 ? send_bytes : 0; in _write()
308 ssize_t send_bytes = 0; in _writev() local
314 send_bytes = socket->writev(iov, iovcnt); in _writev()
315 return send_bytes; in _writev()
317 auto append_fn = [&send_bytes, iov, iovcnt](Buffer *buffer) { in _writev()
[all …]
/dports/www/librtcdcpp/librtcdcpp-2fe92c38b48b6acf1217a8a812c2408310dec437/src/
H A DDTLSWrapper.cpp190 int send_bytes = 0; in RunDecrypt() local
192 send_bytes += BIO_read(out_bio, out_buf + send_bytes, sizeof(out_buf) - send_bytes); in RunDecrypt()
194 if (send_bytes > 0) { in RunDecrypt()
195 this->encrypted_callback(std::make_shared<Chunk>(out_buf, send_bytes)); in RunDecrypt()
/dports/devel/pecl-swoole/swoole-4.8.5/examples/process/
H A Dmsgqueue2.php19 $send_bytes = 0; variable
24 $send_bytes += strlen($data);
35 echo "send={$send_bytes}, recv=$recv_bytes\n";
/dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/modules/rtp_rtcp/source/
H A Drtp_format_vp8_test_helper.cc73 size_t send_bytes = 0; in GetAllPacketsAndCheck() local
79 EXPECT_TRUE(packetizer->NextPacket(buffer_, &send_bytes, &last)); in GetAllPacketsAndCheck()
80 CheckPacket(send_bytes, expected_sizes[i], last, in GetAllPacketsAndCheck()
239 void RtpFormatVp8TestHelper::CheckPacket(size_t send_bytes, in CheckPacket() argument
243 EXPECT_EQ(expect_bytes, send_bytes); in CheckPacket()
245 CheckPayload(send_bytes); in CheckPacket()
/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_statistics.c45 uint64_t send_bytes[LAST_OP]; variable
136 send_bytes[i] = 0; in xcom_statistics()
148 send_bytes[i], receive_bytes[i]); in xcom_statistics()
154 send_bytes[i] = 0; in xcom_statistics()
/dports/net/cjdns/cjdns-cjdns-v21.1/node_build/dependencies/libuv/test/
H A Dtest-poll.c301 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); in connection_poll_cb() local
302 ASSERT(send_bytes > 0); in connection_poll_cb()
304 r = send(context->sock, buffer, send_bytes, 0); in connection_poll_cb()
323 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); in connection_poll_cb() local
324 ASSERT(send_bytes > 0); in connection_poll_cb()
326 r = send(context->sock, buffer, send_bytes, 0); in connection_poll_cb()
339 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); in connection_poll_cb()
340 ASSERT(send_bytes > 0); in connection_poll_cb()
342 r = send(context->sock, buffer, send_bytes, 0); in connection_poll_cb()
/dports/devel/py-joblib/joblib-1.1.0/joblib/externals/loky/backend/
H A Dqueues.py122 def _feed(buffer, notempty, send_bytes, writelock, close, reducers, argument
155 send_bytes(obj_)
159 send_bytes(obj_)
192 self._send_bytes = self._writer.send_bytes
244 self._writer.send_bytes(obj)
247 self._writer.send_bytes(obj)
/dports/comms/direwolf/direwolf-1.6/src/
H A Dfx25_send.c38 static void send_bytes (int chan, unsigned char *b, int count);
222 send_bytes (chan, &b, 1); in fx25_send_frame()
224 send_bytes (chan, data, k_data_radio); in fx25_send_frame()
225 send_bytes (chan, check, NROOTS); in fx25_send_frame()
234 static void send_bytes (int chan, unsigned char *b, int count) in send_bytes() function
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/chttp2/transport/
H A Dwriting.cc136 int64_t send_bytes, grpc_chttp2_write_cb** list, in update_list() argument
141 *ctr += send_bytes; in update_list()
341 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushUncompressedBytes() local
343 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
347 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
349 s_->flow_control->SentData(send_bytes); in FlushUncompressedBytes()
350 s_->sending_bytes += send_bytes; in FlushUncompressedBytes()
357 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushCompressedBytes() local
360 (send_bytes == s_->compressed_data_buffer.length && in FlushCompressedBytes()
382 grpc_chttp2_encode_data(s_->id, &s_->compressed_data_buffer, send_bytes, in FlushCompressedBytes()
[all …]
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/chttp2/transport/
H A Dwriting.cc137 int64_t send_bytes, grpc_chttp2_write_cb** list, in update_list() argument
142 *ctr += send_bytes; in update_list()
350 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushUncompressedBytes() local
352 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
356 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
358 s_->flow_control->SentData(send_bytes); in FlushUncompressedBytes()
359 s_->sending_bytes += send_bytes; in FlushUncompressedBytes()
366 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushCompressedBytes() local
369 (send_bytes == s_->compressed_data_buffer.length && in FlushCompressedBytes()
391 grpc_chttp2_encode_data(s_->id, &s_->compressed_data_buffer, send_bytes, in FlushCompressedBytes()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/transport/chttp2/transport/
H A Dwriting.cc126 int64_t send_bytes, grpc_chttp2_write_cb** list, in update_list() argument
131 *ctr += send_bytes; in update_list()
338 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushUncompressedBytes() local
340 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
344 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
346 s_->flow_control->SentData(send_bytes); in FlushUncompressedBytes()
347 s_->sending_bytes += send_bytes; in FlushUncompressedBytes()
354 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushCompressedBytes() local
357 (send_bytes == s_->compressed_data_buffer.length && in FlushCompressedBytes()
379 grpc_chttp2_encode_data(s_->id, &s_->compressed_data_buffer, send_bytes, in FlushCompressedBytes()
[all …]
/dports/www/py-aiohttp/aiohttp-3.7.4.post0/tests/
H A Dtest_client_ws_functional.py62 await ws.send_bytes(msg + b"/answer")
71 await resp.send_bytes(b"ask")
94 await resp.send_bytes(b"ask")
147 await resp.send_bytes(b"ask")
183 await resp.send_bytes(b"ask")
217 await resp.send_bytes(b"ask")
250 await ws.send_bytes(b"ask")
280 await resp.send_bytes(b"ask")
313 await resp.send_bytes(b"ask")
343 await resp.send_bytes(b"ask")
[all …]
/dports/archivers/maxcso/maxcso-1.10.0/libuv/test/
H A Dtest-poll.c298 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
299 ASSERT(send_bytes > 0);
301 r = send(context->sock, buffer, send_bytes, 0);
320 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
321 ASSERT(send_bytes > 0);
323 r = send(context->sock, buffer, send_bytes, 0);
336 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer);
337 ASSERT(send_bytes > 0);
339 r = send(context->sock, buffer, send_bytes, 0);
/dports/www/R-cran-httpuv/httpuv/src/libuv/test/
H A Dtest-poll.c308 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
309 ASSERT(send_bytes > 0);
312 r = send(context->sock, buffer, send_bytes, 0);
332 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
333 ASSERT(send_bytes > 0);
336 r = send(context->sock, buffer, send_bytes, 0);
350 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer);
351 ASSERT(send_bytes > 0);
354 r = send(context->sock, buffer, send_bytes, 0);
/dports/devel/py-uvloop/uvloop-0.16.0/vendor/libuv/test/
H A Dtest-poll.c308 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
309 ASSERT(send_bytes > 0);
312 r = send(context->sock, buffer, send_bytes, 0);
332 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
333 ASSERT(send_bytes > 0);
336 r = send(context->sock, buffer, send_bytes, 0);
350 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer);
351 ASSERT(send_bytes > 0);
354 r = send(context->sock, buffer, send_bytes, 0);
/dports/devel/libuv/libuv-v1.42.0/test/
H A Dtest-poll.c308 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
309 ASSERT(send_bytes > 0);
312 r = send(context->sock, buffer, send_bytes, 0);
332 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
333 ASSERT(send_bytes > 0);
336 r = send(context->sock, buffer, send_bytes, 0);
350 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer);
351 ASSERT(send_bytes > 0);
354 r = send(context->sock, buffer, send_bytes, 0);

12345678910>>...22