Home
last modified time | relevance | path

Searched refs:newConn (Results 1 – 25 of 1162) sorted by relevance

12345678910>>...47

/dports/www/squid/squid-4.15/src/ip/
H A DIntercept.cc141 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 DIntercept.h37 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 DClientStateMachine.cpp32 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 DServer.cs299 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 DGetAnyConnectionTask.cpp36 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 Dmod_inbounds.c384 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 DTopicTest.php18 $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 DServerProtocolTest.php21 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 DIpBlackListComponentTest.php20 $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 Dnetconn.c38 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 Dnetconn.c38 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 Dconn_test.go182 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 Djson_test.go18 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 Dconn_test.go182 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 Djson_test.go18 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 Dconn_test.go182 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 Djson_test.go18 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 Dconn_test.go182 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 Djson_test.go18 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 Dpg_backup_db.c72 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 DUDPListener.cpp174 …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 DCoordinator.cc262 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 Dsyscallconn.go52 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 Dsyscallconn.go52 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 Dsyscallconn.go52 func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn {
55 return newConn
58 Conn: newConn,

12345678910>>...47