/dports/net/pen/pen-0.34.1/ |
H A D | conn.c | 23 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 D | pen.c | 353 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 D | net.go | 144 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 D | net.go | 162 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 D | test_synapsecollection.py | 109 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 D | test_multiple_synapses.py | 36 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 D | test_getconnections.py | 84 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 D | swarm.go | 60 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 D | anyevent_websocket_connection__finish_callback.t | 19 $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 D | 25clustering-prefer-dc.t | 18 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 D | synapsecollection.py | 90 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 D | common.go | 654 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 D | psend.cc | 69 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 D | select_sockets.cc | 111 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 D | network_get_info.cc | 63 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 D | test_SynapseCollection_distance.py | 42 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 D | conn_map.go | 27 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 D | conn_map.go | 33 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 D | client_test.go | 84 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 D | Pool.java | 129 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 D | Pool.java | 129 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 D | Pool.java | 129 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 D | Pool.java | 129 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 D | Pool.java | 129 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 D | Pool.java | 129 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 …]
|