/dports/www/squid/squid-4.15/src/ip/ |
H A D | Intercept.cc | 141 if ( getsockopt(newConn->fd, in NetfilterInterception() 151 debugs(89, 9, "address: " << newConn); in NetfilterInterception() 154 newConn->local = lookup; in NetfilterInterception() 206 if (newConn->remote.isIPv6()) { in IpfInterception() 296 if (newConn->remote.isIPv6()) 346 if (newConn->remote.isIPv6()) { in PfInterception() 357 nl.dport = htons(newConn->local.port()); in PfInterception() 375 if (newConn->remote.isIPv6()) in PfInterception() 376 newConn->local = nl.rdaddr.v6; in PfInterception() 378 newConn->local = nl.rdaddr.v4; in PfInterception() [all …]
|
H A D | Intercept.h | 37 bool Lookup(const Comm::ConnectionPointer &newConn, const Comm::ConnectionPointer &listenConn); 102 bool TproxyTransparent(const Comm::ConnectionPointer &newConn, int silent); 111 bool NetfilterInterception(const Comm::ConnectionPointer &newConn, int silent); 120 bool IpfwInterception(const Comm::ConnectionPointer &newConn, int silent); 129 bool IpfInterception(const Comm::ConnectionPointer &newConn, int silent); 138 bool PfInterception(const Comm::ConnectionPointer &newConn, int silent);
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/client/state/ |
H A D | ClientStateMachine.cpp | 32 newConn->qLogger = conn->qLogger; in undoAllClientStateForRetry() 46 newConn->version = conn->version; in undoAllClientStateForRetry() 58 newConn->earlyDataAppParamsValidator = in undoAllClientStateForRetry() 63 newConn->pendingOneRttData.reserve( in undoAllClientStateForRetry() 70 newConn->congestionController = in undoAllClientStateForRetry() 86 newConn->lossState = conn->lossState; in undoAllClientStateForRetry() 87 newConn->nodeType = conn->nodeType; in undoAllClientStateForRetry() 89 *newConn, in undoAllClientStateForRetry() 90 newConn->nodeType, in undoAllClientStateForRetry() 91 newConn->transportSettings, in undoAllClientStateForRetry() [all …]
|
/dports/games/openra/OpenRA-release-20200503/OpenRA.Game/Server/ |
H A D | Server.cs | 299 PreConns.Add(newConn); in AcceptConnection() 318 DropClient(newConn); in AcceptConnection() 333 DropClient(newConn); in ValidateClient() 343 DropClient(newConn); in ValidateClient() 369 DropClient(newConn); in ValidateClient() 379 DropClient(newConn); in ValidateClient() 389 DropClient(newConn); in ValidateClient() 399 DropClient(newConn); in ValidateClient() 422 Conns.Add(newConn); in ValidateClient() 430 newConn.PlayerIndex, newConn.Socket.RemoteEndPoint); in ValidateClient() [all …]
|
/dports/mail/trojita/trojita-0.7/src/Imap/Tasks/ |
H A D | GetAnyConnectionTask.cpp | 36 ImapTask(model), newConn(0) in GetAnyConnectionTask() 53 newConn = new OfflineConnectionTask(model); in GetAnyConnectionTask() 54 newConn->addDependentTask(this); in GetAnyConnectionTask() 56 newConn = model->m_taskFactory->createOpenConnectionTask(model); in GetAnyConnectionTask() 57 newConn->addDependentTask(this); in GetAnyConnectionTask() 66 newConn = it->maintainingTask; in GetAnyConnectionTask() 67 newConn->addDependentTask(this); in GetAnyConnectionTask() 88 if (newConn) { in perform() 91 parser = newConn->parser; in perform() 103 return ! isFinished() && ! newConn; in isReadyToRun()
|
/dports/net/tcptrace/tcptrace-508f73a/ |
H A D | mod_inbounds.c | 384 newConn->qNum = 0; in inbounds_tcp_newconn() 385 newConn->aNum = 0; in inbounds_tcp_newconn() 386 newConn->qSum = 0; in inbounds_tcp_newconn() 387 newConn->aSum = 0; in inbounds_tcp_newconn() 388 newConn->q2aIdle.tv_sec = 0; newConn->q2aIdle.tv_usec = 0; in inbounds_tcp_newconn() 389 newConn->a2qIdle.tv_sec = 0; newConn->a2qIdle.tv_usec = 0; in inbounds_tcp_newconn() 403 return newConn; in inbounds_tcp_newconn() 685 newConn->qNum = 0; in inbounds_udp_newconn() 686 newConn->aNum = 0; in inbounds_udp_newconn() 687 newConn->qSum = 0; in inbounds_udp_newconn() [all …]
|
/dports/audio/ampache/ampache-php74-5.0.0/vendor/cboden/ratchet/tests/unit/Wamp/ |
H A D | TopicTest.php | 18 $topic->add($this->newConn()); 19 $topic->add($this->newConn()); 20 $topic->add($this->newConn()); 27 $tracked = $this->newConn(); 29 $topic->add($this->newConn()); 31 $topic->add($this->newConn()); 116 $first = $this->newConn(); 138 $conn = $this->newConn(); 146 $conn = $this->newConn(); 153 $conn = $this->newConn(); [all …]
|
H A D | ServerProtocolTest.php | 21 protected function newConn() { function in Ratchet\\Wamp\\ServerProtocolTest 41 $conn = $this->newConn(); 47 $conn = $this->newConn(); 76 $conn = $this->newConn(); 169 $conn = new WampConnection($this->newConn()); 211 $conn = new WampConnection($this->newConn()); 264 $conn = $this->newConn(); 272 $conn = new WampConnection($this->newConn()); 281 $conn = new WampConnection($this->newConn()); 290 $conn = new WampConnection($this->newConn());
|
/dports/audio/ampache/ampache-php74-5.0.0/vendor/cboden/ratchet/tests/unit/Server/ |
H A D | IpBlackListComponentTest.php | 20 $conn1 = $this->newConn(); 21 $conn2 = $this->newConn(); 22 $conn3 = $this->newConn(); 30 $conn = $this->newConn(); 40 $conn = $this->newConn(); 50 $conn = $this->newConn(); 59 $conn = $this->newConn(); 67 $conn = $this->newConn(); 91 $conn = $this->newConn(); 119 protected function newConn() { function in Ratchet\\Server\\IpBlackListTest
|
/dports/games/hedgewars-server/hedgewars-src-1.0.0/project_files/frontlib/net/ |
H A D | netconn.c | 38 if(newConn) { in flib_netconn_create() 45 newConn->isChief = false; in flib_netconn_create() 50 newConn->teamlist.teams = NULL; in flib_netconn_create() 51 newConn->scheme = NULL; in flib_netconn_create() 52 newConn->style = NULL; in flib_netconn_create() 53 newConn->weaponset = NULL; in flib_netconn_create() 55 newConn->running = false; in flib_netconn_create() 58 if(newConn->netBase && newConn->playerName && newConn->dataDirPath && newConn->map) { in flib_netconn_create() 59 result = newConn; in flib_netconn_create() 60 newConn = NULL; in flib_netconn_create() [all …]
|
/dports/games/hedgewars/hedgewars-src-1.0.0/project_files/frontlib/net/ |
H A D | netconn.c | 38 if(newConn) { in flib_netconn_create() 45 newConn->isChief = false; in flib_netconn_create() 50 newConn->teamlist.teams = NULL; in flib_netconn_create() 51 newConn->scheme = NULL; in flib_netconn_create() 52 newConn->style = NULL; in flib_netconn_create() 53 newConn->weaponset = NULL; in flib_netconn_create() 55 newConn->running = false; in flib_netconn_create() 58 if(newConn->netBase && newConn->playerName && newConn->dataDirPath && newConn->map) { in flib_netconn_create() 59 result = newConn; in flib_netconn_create() 60 newConn = NULL; in flib_netconn_create() [all …]
|
/dports/mail/mailhog/MailHog-1.0.0/vendor/github.com/gorilla/websocket/ |
H A D | conn_test.go | 182 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 183 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 209 wc := newConn(fakeNetConn{Reader: nil, Writer: &b}, false, 1024, 1024) 210 rc := newConn(fakeNetConn{Reader: &b, Writer: nil}, true, 1024, 1024) 243 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 244 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 295 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, readLimit-2) 296 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 324 c := newConn(&fakeNetConn{}, true, 1024, 1024) 336 c := newConn(fc, true, 1024, 1024) [all …]
|
H A D | json_test.go | 18 wc := newConn(c, true, 1024, 1024) 19 rc := newConn(c, false, 1024, 1024) 44 wc := newConn(c, true, 1024, 1024) 45 rc := newConn(c, false, 1024, 1024) 98 wc := newConn(c, true, 1024, 1024) 99 rc := newConn(c, false, 1024, 1024)
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/github.com/gorilla/websocket/ |
H A D | conn_test.go | 182 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 183 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 209 wc := newConn(fakeNetConn{Reader: nil, Writer: &b}, false, 1024, 1024) 210 rc := newConn(fakeNetConn{Reader: &b, Writer: nil}, true, 1024, 1024) 243 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 244 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 295 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, readLimit-2) 296 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 324 c := newConn(&fakeNetConn{}, true, 1024, 1024) 336 c := newConn(fc, true, 1024, 1024) [all …]
|
H A D | json_test.go | 18 wc := newConn(c, true, 1024, 1024) 19 rc := newConn(c, false, 1024, 1024) 44 wc := newConn(c, true, 1024, 1024) 45 rc := newConn(c, false, 1024, 1024) 98 wc := newConn(c, true, 1024, 1024) 99 rc := newConn(c, false, 1024, 1024)
|
/dports/sysutils/hared/hared-hare-1.0-45-g8341d8a/vendor/github.com/gorilla/websocket/ |
H A D | conn_test.go | 182 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 183 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 209 wc := newConn(fakeNetConn{Reader: nil, Writer: &b}, false, 1024, 1024) 210 rc := newConn(fakeNetConn{Reader: &b, Writer: nil}, true, 1024, 1024) 243 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 244 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 295 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, readLimit-2) 296 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 324 c := newConn(&fakeNetConn{}, true, 1024, 1024) 336 c := newConn(fc, true, 1024, 1024) [all …]
|
H A D | json_test.go | 18 wc := newConn(c, true, 1024, 1024) 19 rc := newConn(c, false, 1024, 1024) 44 wc := newConn(c, true, 1024, 1024) 45 rc := newConn(c, false, 1024, 1024) 98 wc := newConn(c, true, 1024, 1024) 99 rc := newConn(c, false, 1024, 1024)
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/gorilla/websocket/websocket-4201258b820c/ |
H A D | conn_test.go | 182 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 183 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 209 wc := newConn(fakeNetConn{Reader: nil, Writer: &b}, false, 1024, 1024) 210 rc := newConn(fakeNetConn{Reader: &b, Writer: nil}, true, 1024, 1024) 243 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, bufSize) 244 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 295 wc := newConn(fakeNetConn{Reader: nil, Writer: &b1}, false, 1024, readLimit-2) 296 rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, 1024, 1024) 324 c := newConn(&fakeNetConn{}, true, 1024, 1024) 336 c := newConn(fc, true, 1024, 1024) [all …]
|
H A D | json_test.go | 18 wc := newConn(c, true, 1024, 1024) 19 rc := newConn(c, false, 1024, 1024) 44 wc := newConn(c, true, 1024, 1024) 45 rc := newConn(c, false, 1024, 1024) 98 wc := newConn(c, true, 1024, 1024) 99 rc := newConn(c, false, 1024, 1024)
|
/dports/databases/pglogical/pglogical-REL2_4_0/pglogical_dump/ |
H A D | pg_backup_db.c | 72 PGconn *newConn; in ReconnectToServer() local 91 newConn = _connectDB(AH, newdbname, newusername); in ReconnectToServer() 94 AH->connection = newConn; in ReconnectToServer() 111 PGconn *newConn; in _connectDB() local 162 if (!newConn) in _connectDB() 165 if (PQstatus(newConn) == CONNECTION_BAD) in _connectDB() 167 if (!PQconnectionNeedsPassword(newConn)) in _connectDB() 169 PQerrorMessage(newConn)); in _connectDB() 170 PQfinish(newConn); in _connectDB() 196 if (PQconnectionUsedPassword(newConn)) in _connectDB() [all …]
|
/dports/games/spring/spring_98.0/rts/System/Net/ |
H A D | UDPListener.cpp | 174 …boost::shared_ptr<UDPConnection> newConn(new UDPConnection(mySocket, ip::udp::endpoint(WrapIP(ip),… in SpawnConnection() local 175 conn[newConn->GetEndpoint()] = newConn; in SpawnConnection() 176 return newConn; in SpawnConnection() 201 boost::shared_ptr<UDPConnection> newConn = waiting.front(); in AcceptConnection() local 203 conn[newConn->GetEndpoint()] = newConn; in AcceptConnection() 204 return newConn; in AcceptConnection()
|
/dports/www/squid/squid-4.15/src/ipc/ |
H A D | Coordinator.cc | 262 Comm::ConnectionPointer newConn = new Comm::Connection; in openListenSocket() local 263 newConn->local = p.addr; // comm_open_listener may modify it in openListenSocket() 264 newConn->flags = p.flags; in openListenSocket() 267 comm_open_listener(p.sock_type, p.proto, newConn, FdNote(p.fdNote)); in openListenSocket() 268 errNo = Comm::IsConnOpen(newConn) ? 0 : errno; in openListenSocket() 271 debugs(54, 6, HERE << "tried listening on " << newConn << " for kid" << in openListenSocket() 275 if (Comm::IsConnOpen(newConn)) in openListenSocket() 276 listeners[request.params] = newConn; in openListenSocket() 278 return newConn; in openListenSocket()
|
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/credentials/internal/ |
H A D | syscallconn.go | 52 func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn { 55 return newConn 58 Conn: newConn,
|
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/credentials/internal/ |
H A D | syscallconn.go | 52 func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn { 55 return newConn 58 Conn: newConn,
|
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/credentials/internal/ |
H A D | syscallconn.go | 52 func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn { 55 return newConn 58 Conn: newConn,
|