/dports/databases/pgbouncer/pgbouncer-1.16.0/src/ |
H A D | pktbuf.c | 75 pkt->send_pos = 0; in pktbuf_reset() 107 uint8_t *pos = buf->buf + buf->send_pos; in pktbuf_send_immediate() 108 int amount = buf->write_pos - buf->send_pos; in pktbuf_send_immediate() 131 amount = buf->write_pos - buf->send_pos; in pktbuf_send_func() 132 res = sbuf_op_send(sbuf, buf->buf + buf->send_pos, amount); in pktbuf_send_func() 142 buf->send_pos += res; in pktbuf_send_func() 144 if (buf->send_pos < buf->write_pos) { in pktbuf_send_func()
|
/dports/multimedia/mswebrtc/mswebrtc-1.1.1/webrtc/webrtc/base/ |
H A D | virtualsocket_unittest.cc | 507 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 510 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 512 send_pos += result; in TcpSendTest() 519 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 521 send_pos += result; in TcpSendTest() 528 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 542 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 544 send_pos += result; in TcpSendTest() 572 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 574 send_pos += result; in TcpSendTest() [all …]
|
H A D | socket_unittest.cc | 681 size_t send_pos = 0, recv_pos = 0; in TcpInternal() local 722 while (!send_waiting_for_writability && send_pos < kDataSize) { in TcpInternal() 723 int tosend = static_cast<int>(kDataSize - send_pos); in TcpInternal() 724 int sent = accepted->Send(send_buffer.get() + send_pos, tosend); in TcpInternal() 733 send_pos += sent; in TcpInternal() 782 EXPECT_EQ(kDataSize, send_pos); in TcpInternal()
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/base/ |
H A D | virtualsocket_unittest.cc | 473 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 476 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 478 send_pos += result; in TcpSendTest() 485 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 487 send_pos += result; in TcpSendTest() 494 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 508 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 510 send_pos += result; in TcpSendTest() 538 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 540 send_pos += result; in TcpSendTest() [all …]
|
H A D | socket_unittest.cc | 461 size_t send_pos = 0, recv_pos = 0; in TestTcp() local 500 while (!send_waiting_for_writability && send_pos < kDataSize) { in TestTcp() 501 int tosend = static_cast<int>(kDataSize - send_pos); in TestTcp() 502 int sent = accepted->Send(send_buffer.get() + send_pos, tosend); in TestTcp() 511 send_pos += sent; in TestTcp() 558 EXPECT_EQ(kDataSize, send_pos); in TestTcp()
|
/dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/base/ |
H A D | virtualsocket_unittest.cc | 462 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 465 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 467 send_pos += result; in TcpSendTest() 474 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 476 send_pos += result; in TcpSendTest() 483 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 497 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 499 send_pos += result; in TcpSendTest() 527 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 529 send_pos += result; in TcpSendTest() [all …]
|
H A D | socket_unittest.cc | 681 size_t send_pos = 0, recv_pos = 0; in TcpInternal() local 722 while (!send_waiting_for_writability && send_pos < kDataSize) { in TcpInternal() 723 int tosend = static_cast<int>(kDataSize - send_pos); in TcpInternal() 724 int sent = accepted->Send(send_buffer.get() + send_pos, tosend); in TcpInternal() 733 send_pos += sent; in TcpInternal() 782 EXPECT_EQ(kDataSize, send_pos); in TcpInternal()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/rtc_base/ |
H A D | virtual_socket_unittest.cc | 544 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 547 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 549 send_pos += result; in TcpSendTest() 556 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 558 send_pos += result; in TcpSendTest() 565 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 579 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 581 send_pos += result; in TcpSendTest() 609 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 611 send_pos += result; in TcpSendTest() [all …]
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/rtc_base/ |
H A D | virtual_socket_unittest.cc | 545 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 548 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 550 send_pos += result; in TcpSendTest() 557 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 559 send_pos += result; in TcpSendTest() 566 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 580 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 582 send_pos += result; in TcpSendTest() 610 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 612 send_pos += result; in TcpSendTest() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/rtc_base/ |
H A D | virtual_socket_unittest.cc | 545 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 548 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 550 send_pos += result; in TcpSendTest() 557 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 559 send_pos += result; in TcpSendTest() 566 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 580 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 582 send_pos += result; in TcpSendTest() 610 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 612 send_pos += result; in TcpSendTest() [all …]
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/rtc_base/ |
H A D | virtual_socket_unittest.cc | 545 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 548 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 550 send_pos += result; in TcpSendTest() 557 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 559 send_pos += result; in TcpSendTest() 566 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 580 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 582 send_pos += result; in TcpSendTest() 610 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 612 send_pos += result; in TcpSendTest() [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
H A D | virtualsocket_unittest.cc | 525 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 528 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 530 send_pos += result; in TcpSendTest() 537 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 539 send_pos += result; in TcpSendTest() 546 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 560 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 562 send_pos += result; in TcpSendTest() 590 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 592 send_pos += result; in TcpSendTest() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/base/ |
H A D | virtualsocket_unittest.cc | 508 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 511 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 513 send_pos += result; in TcpSendTest() 520 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 522 send_pos += result; in TcpSendTest() 529 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 543 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 545 send_pos += result; in TcpSendTest() 573 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 575 send_pos += result; in TcpSendTest() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
H A D | virtualsocket_unittest.cc | 525 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 528 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 530 send_pos += result; in TcpSendTest() 537 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 539 send_pos += result; in TcpSendTest() 546 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 560 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 562 send_pos += result; in TcpSendTest() 590 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 592 send_pos += result; in TcpSendTest() [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/rtc_base/ |
H A D | virtualsocket_unittest.cc | 525 size_t send_pos = 0, recv_pos = 0; in TcpSendTest() local 528 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 530 send_pos += result; in TcpSendTest() 537 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 539 send_pos += result; in TcpSendTest() 546 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 560 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 562 send_pos += result; in TcpSendTest() 590 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 592 send_pos += result; in TcpSendTest() [all …]
|
/dports/audio/schismtracker/schismtracker-20211116/player/ |
H A D | effects.c | 936 uint32_t send_pos = 0; 938 while (send_pos < write_pos) { 940 if (outbuffer[send_pos] == 0xF0) { 942 if ((write_pos - send_pos >= 4) && outbuffer[send_pos + 1] == 0xF0) 952 send_length = i - send_pos + 1; 959 send_length = write_pos - send_pos; 966 send_pos--; 970 send_pos++; 976 send_length = MIN(midi_event_length(outbuffer[send_pos]), write_pos - send_pos); 983 if (outbuffer[send_pos] < 0xF0) { [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
H A D | hinic_devlink.c | 127 u32 section_remain_send_len, send_fragment_len, send_pos, up_total_len; in hinic_flash_fw() local 166 send_pos = 0; in hinic_flash_fw() 200 fw_update_msg->section_offset = send_pos; in hinic_flash_fw() 216 section_offset + send_pos, in hinic_flash_fw() 233 send_pos = send_fragment_len; in hinic_flash_fw()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
H A D | hinic_devlink.c | 127 u32 section_remain_send_len, send_fragment_len, send_pos, up_total_len; in hinic_flash_fw() local 166 send_pos = 0; in hinic_flash_fw() 200 fw_update_msg->section_offset = send_pos; in hinic_flash_fw() 216 section_offset + send_pos, in hinic_flash_fw() 233 send_pos = send_fragment_len; in hinic_flash_fw()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
H A D | hinic_devlink.c | 127 u32 section_remain_send_len, send_fragment_len, send_pos, up_total_len; in hinic_flash_fw() local 166 send_pos = 0; in hinic_flash_fw() 200 fw_update_msg->section_offset = send_pos; in hinic_flash_fw() 216 section_offset + send_pos, in hinic_flash_fw() 233 send_pos = send_fragment_len; in hinic_flash_fw()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds100/freetds/tds/ |
H A D | packet.c | 806 if (conn->send_pos == 0) in tds_packet_write() 820 sent = tds_connection_write(conn->in_net_tds, packet->buf + conn->send_pos, in tds_packet_write() 821 packet->len - conn->send_pos, final); in tds_packet_write() 830 conn->send_pos += sent; in tds_packet_write() 832 if (conn->send_pos >= packet->len) { in tds_packet_write() 839 conn->send_pos = 0; in tds_packet_write()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds95/freetds/tds/ |
H A D | packet.c | 798 if (conn->send_pos == 0) in tds_packet_write() 802 sent = tds_connection_write(conn->in_net_tds, packet->buf + conn->send_pos, in tds_packet_write() 803 packet->len - conn->send_pos, packet->next == NULL); in tds_packet_write() 812 conn->send_pos += sent; in tds_packet_write() 814 if (conn->send_pos >= packet->len) { in tds_packet_write() 821 conn->send_pos = 0; in tds_packet_write()
|
/dports/audio/moc/moc-2.5.2/ |
H A D | protocol.c | 314 size_t send_pos = 0; in send_all() local 316 while (send_pos < size) { in send_all() 317 sent = send (sock, buf + send_pos, size - send_pos, 0); in send_all() 322 send_pos += sent; in send_all()
|
/dports/databases/freetds-devel/freetds-dev.1.3.7/src/tds/ |
H A D | packet.c | 851 if (conn->send_pos == 0) in tds_packet_write() 863 sent = tds_connection_write(conn->in_net_tds, packet->buf + conn->send_pos, in tds_packet_write() 864 packet->data_start + packet->data_len - conn->send_pos, final); in tds_packet_write() 873 conn->send_pos += sent; in tds_packet_write() 875 if (conn->send_pos >= packet->data_start + packet->data_len) { in tds_packet_write() 886 conn->send_pos = 0; in tds_packet_write()
|
/dports/databases/freetds/freetds-1.3.4/src/tds/ |
H A D | packet.c | 851 if (conn->send_pos == 0) in tds_packet_write() 863 sent = tds_connection_write(conn->in_net_tds, packet->buf + conn->send_pos, in tds_packet_write() 864 packet->data_start + packet->data_len - conn->send_pos, final); in tds_packet_write() 873 conn->send_pos += sent; in tds_packet_write() 875 if (conn->send_pos >= packet->data_start + packet->data_len) { in tds_packet_write() 886 conn->send_pos = 0; in tds_packet_write()
|
/dports/mail/dovecot/dovecot-2.3.17/src/lib-imap-client/ |
H A D | imapc-connection.c | 47 unsigned int send_pos; member 309 cmd->send_pos = 0; in imapc_connection_abort_commands_array() 2058 if (stream->pos != cmd->send_pos) in imapc_command_get_sending_stream() 2101 i_assert(cmd->send_pos != cmd->data->used); in imapc_command_try_send_stream() 2185 i_assert(cmd->send_pos < cmd->data->used); in imapc_command_send_more() 2189 } else if (cmd->send_pos == 0 && in imapc_command_send_more() 2235 seek_pos = cmd->send_pos; in imapc_command_send_more() 2257 data = CONST_PTR_OFFSET(cmd->data->data, cmd->send_pos); in imapc_command_send_more() 2258 size = end_pos - cmd->send_pos; in imapc_command_send_more() 2260 cmd->send_pos = end_pos; in imapc_command_send_more() [all …]
|