Home
last modified time | relevance | path

Searched refs:send_state (Results 1 – 25 of 124) sorted by relevance

12345

/dports/net/iaxmodem/iaxmodem-1.2.0/lib/spandsp/tests/
H A Dt4_tests.c53 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 Dgcs_state_msg_test.cpp19 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 Dps2.c19 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 Dtest_power_levels.py84 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 Dt4_tests.c53 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 Dt4_t6_tests.c50 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 Dt4_tests.c53 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 Dt4_t6_tests.c50 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 Dtransaction_client.rs126 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 Dtransaction_server.rs37 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 Dtcp_stream.rs85 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 Dtcp_stream.rs85 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 Dtracker_timeout_test.cc53 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 Dtracker_list_features_test.cc204 …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 Dgcs_state_msg_test.cpp21 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 Dtcp_stream.rs85 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 Dtcp_stream.rs84 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 Dsip_util.c1704 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 Dpacket.c241 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 Dstream.c119 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 Dtest_btrack.c16 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 Dtest_btrack.c16 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 Dproto.c137 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 Dsmtp_proto.c1494 (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 Dconnection.cc118 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 …]

12345