/dports/net/iaxmodem/iaxmodem-1.2.0/lib/spandsp/tests/ |
H A D | t4_tests.c | 53 t4_state_t send_state; variable 273 memset(&send_state, 0, sizeof(send_state)); in main() 374 if (t4_tx_restart_page(&send_state)) in main() 397 if (t4_tx_start_page(&send_state)) in main() 405 bit = t4_tx_get_bit(&send_state); in main() 477 t4_tx_end_page(&send_state); in main() 481 t4_tx_end(&send_state); in main() 542 if (t4_tx_start_page(&send_state)) in main() 547 bit = t4_tx_get_bit(&send_state); in main() 564 t4_tx_end_page(&send_state); in main() [all …]
|
/dports/databases/galera26/galera-release_26.4.10/gcs/src/unit_tests/ |
H A D | gcs_state_msg_test.cpp | 19 gcs_state_msg_t* send_state; in START_TEST() local 47 send_state = gcs_state_msg_create (&state_uuid, in START_TEST() 72 ck_assert(NULL != send_state); in START_TEST() 74 ck_assert(send_state->flags == flags); in START_TEST() 80 send_state->received, received); in START_TEST() 81 ck_assert_msg(send_state->cached == cached, in START_TEST() 83 send_state->cached, cached); in START_TEST() 91 ck_assert(!strcmp(send_state->name, name)); in START_TEST() 103 ck_assert(send_state->cached == cached); in START_TEST() 112 send_len = gcs_state_msg_len (send_state); in START_TEST() [all …]
|
/dports/emulators/x16-emulator/x16-emulator-r38/ |
H A D | ps2.c | 19 int send_state; member 95 state[i].send_state = 0; in ps2_step() 99 if (state[i].send_state <= HOLD) { in ps2_step() 103 if (state[i].send_state == 0 && state[i].bit_index == 10) { in ps2_step() 108 if (state[i].send_state == HOLD) { in ps2_step() 112 state[i].send_state++; in ps2_step() 113 } else if (state[i].send_state <= 2 * HOLD) { in ps2_step() 117 if (state[i].send_state == 2 * HOLD) { in ps2_step() 120 state[i].send_state = 0; in ps2_step() 125 if (state[i].send_state) { in ps2_step() [all …]
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/rest/client/ |
H A D | test_power_levels.py | 84 self.helper.send_state( 93 self.helper.send_state( 102 self.helper.send_state( 112 self.helper.send_state( 125 self.helper.send_state( 144 self.helper.send_state( 156 self.helper.send_state( 169 self.helper.send_state( 179 self.helper.send_state( 198 self.helper.send_state( [all …]
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/spandsp/tests/ |
H A D | t4_tests.c | 53 t4_tx_state_t *send_state; variable 492 t4_tx_set_min_bits_per_row(send_state, min_row_bits); in main() 493 t4_tx_set_local_ident(send_state, "111 2222 3333"); in main() 513 t4_tx_set_header_info(send_state, "Header"); in main() 515 t4_tx_set_header_info(send_state, NULL); in main() 519 t4_tx_set_header_tz(send_state, &tz); in main() 525 if (t4_tx_restart_page(send_state)) in main() 539 if (t4_tx_set_tx_image_format(send_state, in main() 570 if (t4_tx_start_page(send_state)) in main() 642 t4_tx_end_page(send_state); in main() [all …]
|
H A D | t4_t6_tests.c | 50 t4_t6_encode_state_t *send_state; variable 334 … if ((send_state = t4_t6_encode_init(NULL, compression, 1728, -1, row_read_handler, NULL)) == NULL) in main() 339 …span_log_set_level(t4_t6_encode_get_logging_state(send_state), SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_S… in main() 340 t4_t6_encode_set_min_bits_per_row(send_state, min_row_bits); in main() 341 t4_t6_encode_set_max_2d_rows_per_1d_row(send_state, 2); in main() 364 t4_t6_encode_set_encoding(send_state, compression); in main() 367 if (t4_t6_encode_restart(send_state, 1728, -1)) in main() 378 bit = t4_t6_encode_get_bit(send_state); in main() 395 len = t4_t6_encode_get(send_state, chunk_buf, block_size); in main() 415 t4_t6_encode_free(send_state); in main()
|
/dports/comms/spandsp/spandsp-284fe91/tests/ |
H A D | t4_tests.c | 53 t4_tx_state_t *send_state; variable 492 t4_tx_set_min_bits_per_row(send_state, min_row_bits); in main() 493 t4_tx_set_local_ident(send_state, "111 2222 3333"); in main() 513 t4_tx_set_header_info(send_state, "Header"); in main() 515 t4_tx_set_header_info(send_state, NULL); in main() 519 t4_tx_set_header_tz(send_state, &tz); in main() 525 if (t4_tx_restart_page(send_state)) in main() 539 if (t4_tx_set_tx_image_format(send_state, in main() 570 if (t4_tx_start_page(send_state)) in main() 642 t4_tx_end_page(send_state); in main() [all …]
|
H A D | t4_t6_tests.c | 50 t4_t6_encode_state_t *send_state; variable 334 … if ((send_state = t4_t6_encode_init(NULL, compression, 1728, -1, row_read_handler, NULL)) == NULL) in main() 339 …span_log_set_level(t4_t6_encode_get_logging_state(send_state), SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_S… in main() 340 t4_t6_encode_set_min_bits_per_row(send_state, min_row_bits); in main() 341 t4_t6_encode_set_max_2d_rows_per_1d_row(send_state, 2); in main() 364 t4_t6_encode_set_encoding(send_state, compression); in main() 367 if (t4_t6_encode_restart(send_state, 1728, -1)) in main() 378 bit = t4_t6_encode_get_bit(send_state); in main() 395 len = t4_t6_encode_get(send_state, chunk_buf, block_size); in main() 415 t4_t6_encode_free(send_state); in main()
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-http3/src/ |
H A D | transaction_client.rs | 126 send_state: TransactionSendState, field 144 send_state: TransactionSendState::SendingHeaders { in new() 158 self.send_state, in send_request_body() 161 match self.send_state { in send_request_body() 210 match self.send_state { in is_sending_closed() 230 self.send_state == TransactionSendState::SendingData in is_state_sending_data() 250 } = self.send_state in send() 255 self.send_state = TransactionSendState::Closed; in send() 284 self.send_state = TransactionSendState::Closed; in stop_sending() 292 match self.send_state { in close_send() [all …]
|
H A D | transaction_server.rs | 37 send_state: TransactionSendState, field 48 send_state: TransactionSendState::Initial, in new() 72 self.send_state = TransactionSendState::SendingResponse { buf: d.into() }; in set_response() 117 if let TransactionSendState::SendingResponse { ref mut buf } = self.send_state { in send() 122 self.send_state = TransactionSendState::Closed; in send() 263 matches!(self.send_state, TransactionSendState::SendingResponse { .. }) in has_data_to_send() 273 self.send_state == TransactionSendState::Closed in done()
|
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/trust-dns-proto-0.20.3/src/tcp/ |
H A D | tcp_stream.rs | 85 send_state: Option<WriteTcpState>, field 148 send_state: None, in connect() 178 &mut self.send_state, in pollable_split() 206 send_state: None, in from_stream_with_receiver() 231 if send_state.is_some() { in poll_next() 233 match send_state { in poll_next() 256 let current_state = send_state.take(); in poll_next() 269 *send_state = Some(WriteTcpState::Bytes { pos, bytes }); in poll_next() 273 *send_state = Some(WriteTcpState::Flushing); in poll_next() 278 send_state.take(); in poll_next() [all …]
|
/dports/net/oha/oha-0.4.7/cargo-crates/trust-dns-proto-0.20.3/src/tcp/ |
H A D | tcp_stream.rs | 85 send_state: Option<WriteTcpState>, field 148 send_state: None, in connect() 178 &mut self.send_state, in pollable_split() 206 send_state: None, in from_stream_with_receiver() 231 if send_state.is_some() { in poll_next() 233 match send_state { in poll_next() 256 let current_state = send_state.take(); in poll_next() 269 *send_state = Some(WriteTcpState::Bytes { pos, bytes }); in poll_next() 273 *send_state = Some(WriteTcpState::Flushing); in poll_next() 278 send_state.take(); in poll_next() [all …]
|
/dports/net-p2p/libtorrent/libtorrent-0.13.8/test/torrent/ |
H A D | tracker_timeout_test.cc | 53 tracker.send_state(torrent::Tracker::EVENT_NONE); in test_timeout_tracker() 55 tracker.send_state(torrent::Tracker::EVENT_SCRAPE); in test_timeout_tracker() 64 tracker.send_state(torrent::Tracker::EVENT_NONE); in test_timeout_tracker() 66 tracker.send_state(torrent::Tracker::EVENT_SCRAPE); in test_timeout_tracker() 80 tracker.send_state(torrent::Tracker::EVENT_NONE); in test_timeout_tracker() 82 tracker.send_state(torrent::Tracker::EVENT_SCRAPE); in test_timeout_tracker() 94 tracker.send_state(torrent::Tracker::EVENT_SCRAPE); in test_timeout_update() 96 tracker.send_state(torrent::Tracker::EVENT_NONE); in test_timeout_update() 116 tracker.send_state(torrent::Tracker::EVENT_SCRAPE); in test_timeout_requesting() 118 tracker.send_state(torrent::Tracker::EVENT_NONE); in test_timeout_requesting()
|
H A D | tracker_list_features_test.cc | 204 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 209 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 215 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 221 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 225 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 233 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard() 241 …CPPUNIT_ASSERT(verify_did_internal_error(std::bind(&torrent::TrackerList::send_state, &tracker_lis… in test_request_safeguard()
|
/dports/databases/galera/galera-release_25.3.35/gcs/src/unit_tests/ |
H A D | gcs_state_msg_test.cpp | 21 gcs_state_msg_t* send_state; in START_TEST() local 28 send_state = gcs_state_msg_create (&state_uuid, in START_TEST() 49 ck_assert(NULL != send_state); in START_TEST() 51 send_len = gcs_state_msg_len (send_state); in START_TEST() 57 ret = gcs_state_msg_write (send_buf, send_state); in START_TEST() 65 ck_assert(send_state->flags == recv_state->flags); in START_TEST() 80 send_state->received, recv_state->received); in START_TEST() 81 ck_assert_msg(send_state->cached == recv_state->cached, in START_TEST() 83 send_state->cached, recv_state->cached); in START_TEST() 91 ck_assert(!strcmp(send_state->name, recv_state->name)); in START_TEST() [all …]
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/trust-dns-proto-0.19.5/src/tcp/ |
H A D | tcp_stream.rs | 85 send_state: Option<WriteTcpState>, field 107 &mut self.send_state, in pollable_split() 174 send_state: None, in connect() 215 send_state: None, in from_stream_with_receiver() 240 if send_state.is_some() { in poll_next() 242 match send_state { in poll_next() 265 let current_state = send_state.take(); in poll_next() 272 send_state, in poll_next() 285 mem::replace(send_state, Some(WriteTcpState::Flushing)); in poll_next() 290 send_state.take(); in poll_next() [all …]
|
/dports/net/proby/proby-1.0.2/cargo-crates/trust-dns-proto-0.18.0-alpha.2/src/tcp/ |
H A D | tcp_stream.rs | 84 send_state: Option<WriteTcpState>, field 106 &mut self.send_state, in pollable_split() 179 send_state: None, in connect() 220 send_state: None, in from_stream_with_receiver() 245 if send_state.is_some() { in poll_next() 247 match send_state { in poll_next() 270 let current_state = send_state.take(); in poll_next() 277 send_state, in poll_next() 290 mem::replace(send_state, Some(WriteTcpState::Flushing)); in poll_next() 295 send_state.take(); in poll_next() [all …]
|
/dports/net/pjsip/pjproject-2.11.1/pjsip/src/pjsip/ |
H A D | sip_util.c | 1704 if (send_state->app_cb) in send_response_transport_cb() 1705 (*send_state->app_cb)(send_state, sent, &cont); in send_response_transport_cb() 1723 if (send_state->app_cb) { in send_response_resolver_cb() 1725 (*send_state->app_cb)(send_state, -status, &cont); in send_response_resolver_cb() 1742 if (send_state->app_cb) { in send_response_resolver_cb() 1744 (*send_state->app_cb)(send_state, -status, &cont); in send_response_resolver_cb() 1755 send_state->tdata, in send_response_resolver_cb() 1758 send_state, in send_response_resolver_cb() 1763 send_response_transport_cb(send_state, send_state->tdata, sent); in send_response_resolver_cb() 1768 send_response_transport_cb(send_state, send_state->tdata, -status); in send_response_resolver_cb() [all …]
|
/dports/polish/libgadu/libgadu-1.12.2/test/automatic/ |
H A D | packet.c | 241 static unsigned int send_state = 0; variable 267 if (send_state >= sizeof(send_list) / sizeof(send_list[0])) { in my_send() 272 if ((size_t)len != send_list[send_state].expect_len) { in my_send() 273 …fprintf(stderr, "Expected %d bytes instead of %d\n", (int) send_list[send_state].expect_len, (int)… in my_send() 277 if (memcmp(buf, send_list[send_state].expect_buf, len) != 0) { in my_send() 282 errno = send_list[send_state].result_errno; in my_send() 283 res = send_list[send_state].result_value; in my_send() 284 send_state++; in my_send() 374 if (send_state != sizeof(send_list) / sizeof(send_list[0])) { in test_send_packet()
|
/dports/www/h2o-devel/h2o-dcc7134/lib/http2/ |
H A D | stream.c | 119 h2o_send_state_t send_state) in commit_data_header() argument 123 if (length || send_state == H2O_SEND_STATE_FINAL) { in commit_data_header() 134 if (send_state == H2O_SEND_STATE_ERROR) { in commit_data_header() 141 size_t *off_within_buf, h2o_send_state_t send_state) in send_data() argument 181 if (dst.len != max_payload_size || !h2o_send_state_is_in_progress(send_state)) { in send_data() 184 send_state = H2O_SEND_STATE_IN_PROGRESS; in send_data() 186 commit_data_header(conn, stream, &conn->_write.buf, payload_len, send_state); in send_data() 345 stream->send_state = state; in finalostream_send() 402 h2o_send_state_t send_state = stream->send_state; in h2o_http2_stream_send_pending_data() local 408 stream->send_state = H2O_SEND_STATE_ERROR; in h2o_http2_stream_send_pending_data() [all …]
|
/dports/security/tor-devel/tor-0.4.7.2-alpha/src/test/ |
H A D | test_btrack.c | 16 send_state(const orconn_state_msg_t *msg_in) in send_state() function 57 send_state(&conn); in test_btrack_launch() 75 send_state(&conn); in test_btrack_launch() 108 send_state(&state); in test_btrack_delete()
|
/dports/security/tor/tor-0.4.6.8/src/test/ |
H A D | test_btrack.c | 16 send_state(const orconn_state_msg_t *msg_in) in send_state() function 57 send_state(&conn); in test_btrack_launch() 75 send_state(&conn); in test_btrack_launch() 108 send_state(&state); in test_btrack_delete()
|
/dports/games/3omns/3omns-0.2/n3/ |
H A D | proto.c | 137 struct simplex_channel_state *restrict send_state in next_send_sequence() argument 139 sequence seq = ++send_state->seq; in next_send_sequence() 141 seq = ++send_state->seq; in next_send_sequence() 318 struct simplex_channel_state *send_state = get_send_state(link, channel); in send_buffer() local 322 .seq = (reliable ? next_send_sequence(send_state) : 0), in send_buffer() 330 add_packet(&send_state->pool, &p, NULL); in send_buffer() 349 struct simplex_channel_state *send_state in handle_ack() local 352 remove_packet(&send_state->pool, &packet->seq, NULL); in handle_ack() 592 struct simplex_channel_state *restrict send_state, in resend_packets() argument 596 for(int i = 0; i < send_state->pool.count; i++) { in resend_packets() [all …]
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/smtp/ |
H A D | smtp_proto.c | 1494 (send_state == SMTP_STATE_DOT || send_state == SMTP_STATE_LAST) in smtp_loop() 1543 || send_state > SMTP_STATE_QUIT) in smtp_loop() 1545 myname, send_state, recv_state); in smtp_loop() 1550 send_state); in smtp_loop() 1552 xfer_states[send_state]) : -1); in smtp_loop() 1563 switch (send_state) { in smtp_loop() 1909 myname, recv_state, send_state); in smtp_loop() 2254 if (send_state == SMTP_STATE_LAST) in smtp_loop() 2388 send_state = next_state; in smtp_loop() 2401 int send_state; in smtp_xfer() local [all …]
|
/dports/devel/gearmand/gearmand-1.0.6/libgearman/ |
H A D | connection.cc | 118 send_state(GEARMAN_CON_SEND_STATE_NONE), in gearman_connection_st() 166 send_state(GEARMAN_CON_SEND_STATE_NONE), in gearman_connection_st() 354 send_state= GEARMAN_CON_SEND_STATE_NONE; in close_socket() 474 switch (send_state) in _send_packet() 516 send_state= GEARMAN_CON_SEND_UNIVERSAL_PRE_FLUSH; in _send_packet() 555 send_state= GEARMAN_CON_SEND_UNIVERSAL_FORCE_FLUSH; in _send_packet() 571 send_state= GEARMAN_CON_SEND_UNIVERSAL_FLUSH_DATA; in _send_packet() 588 send_state= GEARMAN_CON_SEND_UNIVERSAL_FLUSH_DATA; in _send_packet() 597 send_state= GEARMAN_CON_SEND_UNIVERSAL_FLUSH; in _send_packet() 601 send_state= GEARMAN_CON_SEND_STATE_NONE; in _send_packet() [all …]
|