Home
last modified time | relevance | path

Searched refs:conns (Results 1 – 25 of 3080) sorted by relevance

12345678910>>...124

/dports/net/pen/pen-0.34.1/
H A Dconn.c23 connection *conns; variable
58 if (conns[conn].downn + conns[conn].upn == 0) { in closing_time()
102 conns[i].srx = conns[i].ssx = 0; in store_conn()
103 conns[i].crx = conns[i].csx = 0; in store_conn()
132 if (conns[i].upfd != -1 && conns[i].upfd != listenfd) { in close_conn()
160 conns[i].upfd = conns[i].downfd = -1; in close_conn()
185 conns[i].crx, conns[i].ssx, \ in close_conn()
186 conns[i].srx, conns[i].csx); in close_conn()
188 conns[i].server, servers[conns[i].server].sx, servers[conns[i].server].rx); in close_conn()
196 conns = pen_realloc(conns, size*sizeof *conns); in expand_conntable()
[all …]
H A Dpen.c353 i, conns[i].downfd, conns[i].upfd, in webstats()
354 conns[i].downn, conns[i].upn, in webstats()
355 conns[i].client, conns[i].server); in webstats()
414 i, conns[i].downfd, conns[i].upfd, in textstats()
415 conns[i].downn, conns[i].upn, in textstats()
416 conns[i].client, conns[i].server); in textstats()
632 conns[conn].downbptr = conns[conn].downb = pen_malloc(conns[conn].downn); in add_dummy_reply()
1853 n = my_send(conns[i].downfd, conns[i].downbptr, conns[i].downn, 0); in flush_down()
1861 n = my_send(conns[i].downfd, conns[i].downbptr, conns[i].downn, 0); in flush_down()
1906 n = my_send(conns[i].upfd, conns[i].upbptr, conns[i].upn, 0); in flush_up()
[all …]
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/
H A Dnet.go144 conns.mutex.Lock()
147 conns.conns = make(map[net.Conn]bool)
151 conns.mutex.Lock()
156 if conns.conns == nil {
157 conns.conns = make(map[net.Conn]bool)
159 conns.conns[conn] = true
164 conns.mutex.Lock()
166 delete(conns.conns, conn)
173 for conn := range conns.conns {
176 conns.conns = make(map[net.Conn]bool)
[all …]
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/
H A Dnet.go162 conns.mutex.Lock()
165 conns.conns = make(map[net.Conn]bool)
169 conns.mutex.Lock()
174 if conns.conns == nil {
175 conns.conns = make(map[net.Conn]bool)
177 conns.conns[conn] = true
182 conns.mutex.Lock()
184 delete(conns.conns, conn)
191 for conn := range conns.conns {
194 conns.conns = make(map[net.Conn]bool)
[all …]
/dports/science/nest/nest-simulator-3.1/testsuite/pytests/
H A Dtest_synapsecollection.py109 conns = nest.GetConnections()
112 target = conns.get('target')
116 all_values = conns.get()
151 conns = nest.GetConnections()
156 target = conns.get('target')
160 all_values = conns.get()
189 conns = nest.GetConnections()
298 conns = nest.GetConnections()
329 conns = nest.GetConnections()
366 conns = nest.GetConnections()
[all …]
H A Dtest_multiple_synapses.py36 def sort_connections(self, conns): argument
43 src = conns.source
44 trgt = conns.target
45 weight = conns.weight
46 syn_model = conns.synapse_model
59 conns = nest.GetConnections()
74 conns = nest.GetConnections()
166 weights = conns.weight
242 weights = conns.weight
269 num_conns = len(conns)
[all …]
H A Dtest_getconnections.py84 conns = nest.GetConnections(**get_conn_args)
86 len(conns), 1,
105 conns = nest.GetConnections(**get_conn_args)
107 len(conns), 1,
138 self.assertEqual(reference_list, conns.synapse_model)
142 self.assertEqual(reference_list, conns.synapse_model)
145 self.assertEqual(reference_list, conns.synapse_model)
148 self.assertEqual(reference_list, conns.synapse_model)
180 conns = nest.GetConnections(synapse_label=label)
182 self.assertEqual(reference_list, conns.synapse_model)
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-swarm/
H A Dswarm.go60 conns struct { member
150 s.conns.Lock()
151 conns := s.conns.m
152 s.conns.m = nil
234 s.conns.Lock()
243 s.conns.m[p] = append(s.conns.m[p], c)
371 conns := s.conns.m[p]
423 conns := make([]network.Conn, 0, len(s.conns.m))
426 conns = append(conns, c)
429 return conns
[all …]
/dports/www/p5-AnyEvent-WebSocket-Client/AnyEvent-WebSocket-Client-0.44/t/
H A Danyevent_websocket_connection__finish_callback.t19 $code->(\@conns);
23 $conns[0]->send("foo");
24 $conns[0]->send("bar");
30 my $conns = shift;
31 undef $conns->[1];
35 my $conns = shift;
36 $conns->[1]->close();
40 my $conns = shift;
41 $conns->[0]->close();
45 my $conns = shift;
[all …]
/dports/databases/p5-Net-Async-CassandraCQL/Net-Async-CassandraCQL-0.11/t/
H A D25clustering-prefer-dc.t18 my %conns;
22 $conns{$connect_host} = my $conn = t::MockConnection->new( $connect_host );
35 ok( my $c = $conns{"10.0.0.1"}, 'Connected to 10.0.0.1' );
51 ok( defined $conns{"10.0.0.2"}, 'Connected to 10.0.0.2' );
52 ok( defined $conns{"10.0.0.3"}, 'Connected to 10.0.0.3' );
54 ok( !defined $conns{"10.0.1.1"} &&
55 !defined $conns{"10.0.1.2"} &&
56 !defined $conns{"10.0.1.3"}, 'Not connected to DC2 hosts' );
61 undef $conns{"10.0.0.3"};
64 is( defined($conns{"10.0.1.1"}) + defined($conns{"10.0.1.2"}) + defined($conns{"10.0.1.3"}),
[all …]
/dports/science/nest/nest-simulator-3.1/pynest/examples/
H A Dsynapsecollection.py90 conns.set(w)
91 weights = conns.weight
106 conns = nest.GetConnections() variable
107 srcs = conns.source
108 tgts = conns.target
109 weights = conns.weight
138 conns = nest.GetConnections() variable
139 srcs = conns.source
140 tgts = conns.target
141 weights = conns.weight
[all …]
/dports/ftp/sftpgo/sftpgo-2.2.0/common/
H A Dcommon.go654 conns.RLock()
668 conns.Lock()
671 conns.connections = append(conns.connections, c)
682 conns.Lock()
699 conns.Lock()
706 conns.connections[idx] = conns.connections[lastIdx]
708 conns.connections = conns.connections[:lastIdx]
743 conns.Lock()
746 conns.sshConnections = append(conns.sshConnections, c)
752 conns.Lock()
[all …]
/dports/math/octave-forge-parallel/parallel-4.0.1/src/
H A Dpsend.cc69 octave_parallel_connections_rep *conns = cconns.get_rep (); variable
70 int nconns = conns->get_connections ().numel ();
72 if (conns->get_whole_network ()->is_closed ())
82 if (nconns < conns->get_all_connections ().numel ()) // it's a subnet
84 if (conns->get_connections ()(i)->is_pseudo_connection ())
91 if (! conns->is_server ())
97 if (conns->get_connections ()(i)->is_pseudo_connection ())
117 conns->close ();
131 if (conns->get_connections ()(i)->is_pseudo_connection ())
134 if (minimal_write_data (conns->get_connections ()(i)->
[all …]
H A Dselect_sockets.cc111 octave_parallel_connections_rep *conns = cconns.get_rep (); variable
112 int nconns = conns->get_connections ().numel ();
114 if (conns->get_whole_network ()->is_closed ())
123 if (conns->get_connections ()(i)->is_pseudo_connection ())
138 if (conns->get_connections ()(i)->is_pseudo_connection ())
153 if (! conns->is_server ())
187 if (conns->get_connections ()(i)->is_pseudo_connection ())
191 (conns->get_connections ()(i)->get_data_stream ()->
198 if (! conns->is_server ())
201 (conns->get_connections ()(i)->get_cmd_stream ()->
[all …]
H A Dnetwork_get_info.cc63 octave_parallel_connections_rep *conns = cconns.get_rep (); variable
64 int nconns = conns->get_connections ().numel ();
66 if (conns->get_whole_network ()->is_closed ())
73 if (conns->is_server ())
98 if (conns->get_connections ()(i)->is_pseudo_connection ())
103 node_info.setfield ("nproc", conns->get_connections ()(i)->get_nproc ());
105 conns->get_connections ()(i)->get_nlocaljobs ());
107 conns->get_connections ()(i)->get_peer_name ());
108 node_info.setfield ("open", conns->get_connections ()(i)->is_open ());
110 conns->get_connections ()(i)->get_uuid ());
[all …]
/dports/science/nest/nest-simulator-3.1/testsuite/pytests/test_spatial/
H A Dtest_SynapseCollection_distance.py42 src = conns.source
43 trgt = conns.target
66 conns = nest.GetConnections()
67 dist = conns.distance
78 conns = nest.GetConnections()
79 dist = conns.distance
94 dist = conns.distance
109 dist = conns.distance
123 dist = conns.distance
145 dist = conns.distance
[all …]
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/transport/vnet/
H A Dconn_map.go27 conns, ok := m.portMap[udpAddr.Port]
33 for _, conn := range conns {
40 conns = append(conns, conn)
42 conns = []*UDPConn{conn}
45 m.portMap[udpAddr.Port] = conns
58 if len(conns) == 0 {
63 return conns[0], true
66 for _, conn := range conns {
96 for _, conn := range conns {
125 for _, conns := range m.portMap {
[all …]
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/transport/vnet/
H A Dconn_map.go33 conns, ok := m.portMap[udpAddr.Port]
39 for _, conn := range conns {
46 conns = append(conns, conn)
48 conns = []*UDPConn{conn}
51 m.portMap[udpAddr.Port] = conns
64 if len(conns) == 0 {
69 return conns[0], true
72 for _, conn := range conns {
102 for _, conn := range conns {
131 for _, conns := range m.portMap {
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/gopkg.in/olivere/elastic.v3/
H A Dclient_test.go84 if len(client.conns) == 0 {
102 if len(client.conns) == 0 {
118 if len(client.conns) != 1 {
150 if len(client.conns) != 1 {
168 if len(client.conns) != 2 {
169 t.Fatalf("expected 2 nodes, got: %d (%v)", len(client.conns), client.conns)
200 if len(client.conns) != 1 {
201 t.Fatalf("expected 1 node, got: %d (%v)", len(client.conns), client.conns)
423 if len(client.conns) != 1 {
537 client.conns[1].MarkAsDead()
[all …]
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPool.java129 Connections conns; in getPooledConnection() local
131 conns = getConnections(id); in getPooledConnection()
132 if (conns == null) { in getPooledConnection()
175 Connections conns; in expire() local
177 conns = ref.getConnections(); in expire()
178 if (conns.expire(threshold)) { in expire()
179 d("expire(): removing ", conns); in expire()
200 Connections conns = releaseRef.getConnections(); in expungeStaleConnections() local
208 conns.close(); in expungeStaleConnections()
217 Connections conns; in showStats() local
[all …]

12345678910>>...124