/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/ssh/src/ |
H A D | ssh_fsm_kexinit.erl | 78 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 D | ssh_fsm_kexinit.erl | 78 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 D | ssh_fsm_kexinit.erl | 78 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 D | ssh_fsm_kexinit.erl | 78 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 D | base.cc | 288 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 D | DTLSWrapper.cpp | 190 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 D | msgqueue2.php | 19 $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 D | rtp_format_vp8_test_helper.cc | 73 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 D | xcom_statistics.c | 45 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 D | xcom_statistics.c | 45 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 D | xcom_statistics.c | 45 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 D | xcom_statistics.c | 45 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 D | xcom_statistics.c | 45 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 D | xcom_statistics.c | 45 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 D | test-poll.c | 301 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 D | queues.py | 122 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 D | fx25_send.c | 38 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 D | writing.cc | 136 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 D | writing.cc | 137 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 D | writing.cc | 126 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 D | test_client_ws_functional.py | 62 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 D | test-poll.c | 298 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 D | test-poll.c | 308 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 D | test-poll.c | 308 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 D | test-poll.c | 308 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);
|