| /dports/net/storj/storj-1.45.3/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/multimedia/navidrome/navidrome-0.40.0/vendor/golang.org/x/tools/internal/jsonrpc2/ |
| H A D | conn.go | 59 type conn struct { struct
61 writeMu sync.Mutex // protects writes to the stream
62 stream Stream
63 pendingMu sync.Mutex // protects the pending map
64 pending map[ID]chan *Response
66 done chan struct{}
67 err atomic.Value
235 func (c *conn) Close() error {
239 func (c *conn) Done() <-chan struct{} {
243 func (c *conn) Err() error {
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/multimedia/navidrome/navidrome-0.40.0/vendor/github.com/lib/pq/ |
| H A D | conn.go | 122 type conn struct { struct
123 c net.Conn
125 namei int
128 txnFinish func()
131 dialer Dialer
132 opts values
135 processID int
136 secretKey int
145 bad *atomic.Value
157 inCopy bool
[all …]
|
| /dports/audio/lash/lash-0.5.4/lashd/ |
| H A D | conn.c | 36 conn_init(conn_t * conn) in conn_init()
47 conn_free(conn_t * conn) in conn_free()
58 conn_t *conn; in conn_new() local
66 conn_destroy(conn_t * conn) in conn_destroy()
73 conn_lock(conn_t * conn) in conn_lock()
79 conn_unlock(conn_t * conn) in conn_unlock()
85 conn_get_str_id(conn_t * conn) in conn_get_str_id()
118 conn_get_recv_stamp(conn_t * conn) in conn_get_recv_stamp()
124 conn_get_pinged(conn_t * conn) in conn_get_pinged()
145 conn_set_recv_stamp(conn_t * conn) in conn_set_recv_stamp()
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib-smtp/ |
| H A D | smtp-client-connection.c | 58 struct smtp_client_connection *conn) in smtp_client_connection_get_size_capability()
79 struct smtp_client_connection *conn, in smtp_client_connection_accept_extra_capability()
187 struct smtp_client_connection *conn, in smtp_client_connection_transactions_fail()
296 struct smtp_client_connection *conn) in smtp_client_connection_start_cmd_timeout()
323 struct smtp_client_connection *conn) in smtp_client_connection_update_cmd_timeout()
438 struct smtp_client_connection *conn) in smtp_client_connection_handle_output_error()
1643 struct smtp_client_connection *conn) in smtp_client_connection_delayed_connect_error()
1734 struct smtp_client_connection *conn) in smtp_client_connection_delayed_host_lookup_failure()
1871 struct smtp_client_connection *conn, in smtp_client_connection_connect()
2003 struct smtp_client_connection *conn; in smtp_client_connection_do_create() local
[all …]
|
| /dports/security/s2n/s2n-tls-1.1.2/tls/ |
| H A D | s2n_handshake_io.c | 53 static int s2n_always_fail_send(struct s2n_connection *conn) in s2n_always_fail_send()
59 static int s2n_always_fail_recv(struct s2n_connection *conn) in s2n_always_fail_recv()
647 static int s2n_advance_message(struct s2n_connection *conn) in s2n_advance_message()
711 int s2n_set_hello_retry_required(struct s2n_connection *conn) in s2n_set_hello_retry_required()
735 bool s2n_is_hello_retry_message(struct s2n_connection *conn) in s2n_is_hello_retry_message()
742 bool s2n_is_hello_retry_handshake(struct s2n_connection *conn) in s2n_is_hello_retry_handshake()
788 int s2n_conn_set_handshake_type(struct s2n_connection *conn) in s2n_conn_set_handshake_type()
938 static int s2n_handshake_write_io(struct s2n_connection *conn) in s2n_handshake_write_io()
1103 static S2N_RESULT s2n_wipe_record(struct s2n_connection *conn) in s2n_wipe_record()
1112 static S2N_RESULT s2n_finish_read(struct s2n_connection *conn) in s2n_finish_read()
[all …]
|
| /dports/net-im/libstrophe/libstrophe-0.11.0/src/ |
| H A D | conn.c | 99 xmpp_conn_t *conn = NULL; in xmpp_conn_new() local
254 int xmpp_conn_release(xmpp_conn_t *conn) in xmpp_conn_release()
586 int xmpp_connect_client(xmpp_conn_t *conn, in xmpp_connect_client()
732 int xmpp_connect_raw(xmpp_conn_t *conn, in xmpp_connect_raw()
743 void conn_established(xmpp_conn_t *conn) in conn_established()
822 int xmpp_conn_tls_start(xmpp_conn_t *conn) in xmpp_conn_tls_start()
847 void conn_disconnect(xmpp_conn_t *conn) in conn_disconnect()
872 void conn_parser_reset(xmpp_conn_t *conn) in conn_parser_reset()
887 void xmpp_disconnect(xmpp_conn_t *conn) in xmpp_disconnect()
1008 void conn_open_stream(xmpp_conn_t *conn) in conn_open_stream()
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-tls/ |
| H A D | conn.go | 11 type conn struct { struct
12 *tls.Conn
14 localPeer peer.ID
15 privKey ci.PrivKey
17 remotePeer peer.ID
18 remotePubKey ci.PubKey
23 func (c *conn) LocalPeer() peer.ID {
27 func (c *conn) LocalPrivateKey() ci.PrivKey {
31 func (c *conn) RemotePeer() peer.ID {
35 func (c *conn) RemotePublicKey() ci.PubKey {
|
| /dports/security/vuls/vuls-0.13.7/vendor/github.com/lib/pq/ |
| H A D | conn.go | 116 type conn struct { struct
117 c net.Conn
119 namei int
122 txnFinish func()
125 dialer Dialer
126 opts values
129 processID int
130 secretKey int
139 bad bool
151 inCopy bool
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/lib/pq/ |
| H A D | conn.go | 116 type conn struct { struct
117 c net.Conn
119 namei int
122 txnFinish func()
125 dialer Dialer
126 opts values
129 processID int
130 secretKey int
139 bad bool
151 inCopy bool
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/lib/pq/ |
| H A D | conn.go | 116 type conn struct { struct
117 c net.Conn
119 namei int
122 txnFinish func()
125 dialer Dialer
126 opts values
129 processID int
130 secretKey int
139 bad bool
151 inCopy bool
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/moby/buildkit/session/grpchijack/ |
| H A D | dial.go | 48 type conn struct { struct
49 stream stream
50 buf []byte
51 lastBuf []byte
53 closedOnce sync.Once
54 readMu sync.Mutex
55 writeMu sync.Mutex
56 closeCh chan struct{}
97 func (c *conn) Close() (err error) {
134 func (c *conn) LocalAddr() net.Addr {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/vendor/github.com/moby/buildkit/session/grpchijack/ |
| H A D | dial.go | 48 type conn struct { struct
49 stream stream
50 buf []byte
51 lastBuf []byte
53 closedOnce sync.Once
54 readMu sync.Mutex
55 writeMu sync.Mutex
56 closeCh chan struct{}
97 func (c *conn) Close() (err error) {
134 func (c *conn) LocalAddr() net.Addr {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/session/grpchijack/ |
| H A D | dial.go | 48 type conn struct { struct
49 stream stream
50 buf []byte
51 lastBuf []byte
53 closedOnce sync.Once
54 readMu sync.Mutex
55 writeMu sync.Mutex
56 closeCh chan struct{}
97 func (c *conn) Close() (err error) {
134 func (c *conn) LocalAddr() net.Addr {
[all …]
|