Home
last modified time | relevance | path

Searched refs:send_pos (Results 1 – 25 of 38) sorted by relevance

12

/dports/databases/pgbouncer/pgbouncer-1.16.0/src/
H A Dpktbuf.c75 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 Dvirtualsocket_unittest.cc507 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 Dsocket_unittest.cc681 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 Dvirtualsocket_unittest.cc473 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 Dsocket_unittest.cc461 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 Dvirtualsocket_unittest.cc462 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 Dsocket_unittest.cc681 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 Dvirtual_socket_unittest.cc544 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 Dvirtual_socket_unittest.cc545 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 Dvirtual_socket_unittest.cc545 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 Dvirtual_socket_unittest.cc545 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 Dvirtualsocket_unittest.cc525 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 Dvirtualsocket_unittest.cc508 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 Dvirtualsocket_unittest.cc525 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 Dvirtualsocket_unittest.cc525 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 Deffects.c936 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 Dhinic_devlink.c127 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 Dhinic_devlink.c127 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 Dhinic_devlink.c127 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 Dpacket.c806 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 Dpacket.c798 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 Dprotocol.c314 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 Dpacket.c851 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 Dpacket.c851 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 Dimapc-connection.c47 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 …]

12