| /dports/www/mitmproxy/mitmproxy-7.0.4/test/mitmproxy/proxy/ |
| H A D | test_commands.py | 11 def tconn() -> connection.Server: function
15 def test_dataclasses(tconn): argument
16 assert repr(commands.SendData(tconn, b"foo"))
17 assert repr(commands.OpenConnection(tconn))
18 assert repr(commands.CloseConnection(tconn))
19 assert repr(commands.GetSocket(tconn))
|
| H A D | test_events.py | 10 def tconn() -> connection.Server: function
14 def test_dataclasses(tconn): argument
16 assert repr(events.DataReceived(tconn, b"foo"))
17 assert repr(events.ConnectionClosed(tconn))
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/devel/etcd31/etcd-3.1.20/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/www/minio-client/etcd-3.5.0/client/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.readTimeout != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.readTimeout, time.Hour)
53 if tconn.writeTimeout != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.writeTimeout, time.Hour)
|
| /dports/devel/etcd32/etcd-3.2.32/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/devel/etcd33/etcd-3.3.23/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/devel/etcd/etcd-2.3.8/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/devel/etcd34/etcd-3.4.18/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/pkg/transport/ |
| H A D | timeout_transport_test.go | 46 tconn, ok := conn.(*timeoutConn)
50 if tconn.rdtimeoutd != time.Hour {
51 t.Errorf("read timeout = %s, want %s", tconn.rdtimeoutd, time.Hour)
53 if tconn.wtimeoutd != time.Hour {
54 t.Errorf("write timeout = %s, want %s", tconn.wtimeoutd, time.Hour)
|
| /dports/net/samba412/samba-4.12.15/ctdb/ib/ |
| H A D | ibwrapper_test.c | 80 struct ibwtest_conn *tconn = talloc_zero(tcx, struct ibwtest_conn); in ibwtest_connect_everybody() local
84 conn = ibw_conn_new(tcx->ibwctx, tconn); in ibwtest_connect_everybody()
85 if (ibw_connect(conn, &tcx->addrs[i], tconn)) { in ibwtest_connect_everybody()
237 struct ibwtest_conn *tconn = NULL; /* userdata */ in ibwtest_connstate_handler() local
251 tconn = talloc_zero(conn, struct ibwtest_conn); in ibwtest_connstate_handler()
252 if (ibw_accept(ctx, conn, tconn)) { in ibwtest_connstate_handler()
300 struct ibwtest_conn *tconn; in ibwtest_receive_handler() local
307 tconn = talloc_get_type(conn->conn_userdata, struct ibwtest_conn); in ibwtest_receive_handler()
311 tconn->id = talloc_strdup(tconn, ((char *)buf)+sizeof(uint32_t)+1); in ibwtest_receive_handler()
315 tconn->id ? tconn->id : "NULL", ((char *)buf)+sizeof(uint32_t)+1, n)); in ibwtest_receive_handler()
[all …]
|
| /dports/audio/lewton/lewton-0.10.2/cargo-crates/curl-sys-0.4.25/curl/lib/vquic/ |
| H A D | ngtcp2.c | 337 (void)tconn; in cb_handshake_completed()
343 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
348 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
375 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
388 (void)tconn; in cb_acked_stream_data_offset()
409 (void)tconn; in cb_stream_close()
430 (void)tconn; in cb_stream_reset()
450 (void)tconn; in cb_recv_retry()
463 (void)tconn; in cb_extend_max_local_streams_bidi()
476 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/graphics/mupdf/mupdf-1.18.0-source/thirdparty/curl/lib/vquic/ |
| H A D | ngtcp2.c | 331 (void)tconn; in cb_handshake_completed()
359 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
372 (void)tconn; in cb_acked_stream_data_offset()
387 static int cb_stream_close(ngtcp2_conn *tconn, int64_t stream_id, in cb_stream_close() argument
393 (void)tconn; in cb_stream_close()
414 (void)tconn; in cb_stream_reset()
434 (void)tconn; in cb_recv_retry()
443 static int cb_extend_max_local_streams_bidi(ngtcp2_conn *tconn, in cb_extend_max_local_streams_bidi() argument
447 (void)tconn; in cb_extend_max_local_streams_bidi()
460 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/stats/ |
| H A D | test-client-reader.c | 137 struct test_connection *tconn = in test_reader_server_input_args_group_by() local
143 tconn->row_count++; in test_reader_server_input_args_group_by()
145 if (tconn->row_count == 1) { in test_reader_server_input_args_group_by()
148 } else if (tconn->row_count == 2) { in test_reader_server_input_args_group_by()
|
| /dports/www/mirrorselect/mirrorselect-0.9.0/vendor/github.com/jlaffaye/ftp/ |
| H A D | ftp.go | 91 tconn := do.conn
92 if tconn == nil {
96 tconn, err = do.dialFunc("tcp", addr)
98 tconn, err = tls.DialWithDialer(&do.dialer, "tcp", addr, do.tlsConfig)
106 tconn, err = do.dialer.DialContext(ctx, "tcp", addr)
116 remoteAddr := tconn.RemoteAddr().(*net.TCPAddr)
121 conn: textproto.NewConn(do.wrapConn(tconn)),
136 tconn = tls.Client(tconn, do.tlsConfig)
137 c.conn = textproto.NewConn(do.wrapConn(tconn))
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/curl-sys-0.4.51+curl-7.80.0/curl/lib/vquic/ |
| H A D | ngtcp2.c | 503 (void)tconn; in cb_handshake_completed()
507 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
512 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
538 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
551 (void)tconn; in cb_acked_stream_data_offset()
570 (void)tconn; in cb_stream_close()
593 (void)tconn; in cb_stream_reset()
612 (void)tconn; in cb_stream_stop_sending()
628 (void)tconn; in cb_extend_max_local_streams_bidi()
641 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | ngtcp2.c | 501 (void)tconn; in cb_handshake_completed()
505 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
510 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
536 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
549 (void)tconn; in cb_acked_stream_data_offset()
568 (void)tconn; in cb_stream_close()
591 (void)tconn; in cb_stream_reset()
610 (void)tconn; in cb_stream_stop_sending()
626 (void)tconn; in cb_extend_max_local_streams_bidi()
639 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | ngtcp2.c | 501 (void)tconn; in cb_handshake_completed()
505 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
510 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
536 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
549 (void)tconn; in cb_acked_stream_data_offset()
568 (void)tconn; in cb_stream_close()
591 (void)tconn; in cb_stream_reset()
610 (void)tconn; in cb_stream_stop_sending()
626 (void)tconn; in cb_extend_max_local_streams_bidi()
639 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/net/proby/proby-1.0.2/cargo-crates/curl-sys-0.4.34+curl-7.71.1/curl/lib/vquic/ |
| H A D | ngtcp2.c | 570 (void)tconn; in cb_handshake_completed()
576 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
581 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
609 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
622 (void)tconn; in cb_acked_stream_data_offset()
643 (void)tconn; in cb_stream_close()
664 (void)tconn; in cb_stream_reset()
679 static int cb_extend_max_local_streams_bidi(ngtcp2_conn *tconn, in cb_extend_max_local_streams_bidi() argument
683 (void)tconn; in cb_extend_max_local_streams_bidi()
696 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/curl-sys-0.4.41+curl-7.75.0/curl/lib/vquic/ |
| H A D | ngtcp2.c | 562 (void)tconn; in cb_handshake_completed()
566 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
571 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
597 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
610 (void)tconn; in cb_acked_stream_data_offset()
629 (void)tconn; in cb_stream_close()
648 (void)tconn; in cb_stream_reset()
661 static int cb_extend_max_local_streams_bidi(ngtcp2_conn *tconn, in cb_extend_max_local_streams_bidi() argument
665 (void)tconn; in cb_extend_max_local_streams_bidi()
678 (void)tconn; in cb_extend_max_stream_data()
[all …]
|
| /dports/devel/cmake/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | ngtcp2.c | 501 (void)tconn; in cb_handshake_completed()
505 static void extend_stream_window(ngtcp2_conn *tconn, in extend_stream_window() argument
510 ngtcp2_conn_extend_max_offset(tconn, thismuch); in extend_stream_window()
536 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
549 (void)tconn; in cb_acked_stream_data_offset()
568 (void)tconn; in cb_stream_close()
591 (void)tconn; in cb_stream_reset()
610 (void)tconn; in cb_stream_stop_sending()
626 (void)tconn; in cb_extend_max_local_streams_bidi()
639 (void)tconn; in cb_extend_max_stream_data()
[all …]
|