/dports/net/wangle/wangle-2021.12.27.00/wangle/acceptor/ |
H A D | Acceptor.cpp | 247 const SocketAddress& clientAddr, in connectionAccepted() argument 252 if (!canAccept(clientAddr)) { in connectionAccepted() 264 onDoneAcceptingConnection(fd, clientAddr, acceptTime, info); in connectionAccepted() 269 const SocketAddress& clientAddr, in onDoneAcceptingConnection() argument 279 const SocketAddress& clientAddr, in processEstablishedConnection() argument 324 const SocketAddress& clientAddr, in startHandshakeManager() argument 328 this, clientAddr, acceptTime, tinfo); in startHandshakeManager() 388 const SocketAddress& clientAddr, in connectionReady() argument 413 &clientAddr, in connectionReady() 421 const SocketAddress& clientAddr, in plaintextConnectionReady() argument [all …]
|
H A D | SSLAcceptorHandshakeHelper.h | 33 const folly::SocketAddress& clientAddr, in SSLAcceptorHandshakeHelper() argument 36 : clientAddr_(clientAddr), acceptTime_(acceptTime), tinfo_(tinfo) {} in SSLAcceptorHandshakeHelper() 76 const folly::SocketAddress& clientAddr, in getHelper() argument 80 new SSLAcceptorHandshakeHelper(clientAddr, acceptTime, tinfo)); in getHelper()
|
H A D | PeekingAcceptorHandshakeHelper.h | 48 const folly::SocketAddress& clientAddr, 57 const folly::SocketAddress& clientAddr, in PeekingAcceptorHandshakeHelper() argument 62 : clientAddr_(clientAddr), in PeekingAcceptorHandshakeHelper() 145 const folly::SocketAddress& clientAddr, in PeekingAcceptorHandshakeManager() argument 152 clientAddr, in PeekingAcceptorHandshakeManager()
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gitlab.com/gitlab-org/gitlab-terminal/ |
H A D | terminal.go | 28 clientAddr := getClientAddr(r) // We can't know the port with confidence 31 "clientAddr": clientAddr, 89 clientAddr := getClientAddr(r) // We can't know the port with confidence 92 "clientAddr": clientAddr, 100 if err := proxy.Serve(server, client, serverAddr, clientAddr); err != nil { 122 clientAddr := getClientAddr(r) // We can't know the port with confidence 126 "clientAddr": clientAddr, 134 if err := proxy.Serve(fd, client, serverAddr, clientAddr); err != nil {
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gitlab.com/gitlab-org/gitlab-terminal/gitlab-terminal-2a71b03b44621289b28493d8bf3eaa9f64dbb6c9/ |
H A D | terminal.go | 28 clientAddr := getClientAddr(r) // We can't know the port with confidence 31 "clientAddr": clientAddr, 89 clientAddr := getClientAddr(r) // We can't know the port with confidence 92 "clientAddr": clientAddr, 100 if err := proxy.Serve(server, client, serverAddr, clientAddr); err != nil { 122 clientAddr := getClientAddr(r) // We can't know the port with confidence 126 "clientAddr": clientAddr, 134 if err := proxy.Serve(fd, client, serverAddr, clientAddr); err != nil {
|
/dports/net-p2p/qbittorrent/qbittorrent-4.3.9/src/webui/api/ |
H A D | authcontroller.cpp | 47 const QString clientAddr {sessionManager()->clientId()}; in loginAction() local 54 .arg(clientAddr, usernameFromWeb) in loginAction() 69 m_clientFailedLogins.remove(clientAddr); in loginAction() 73 LogMsg(tr("WebAPI login success. IP: %1").arg(clientAddr)); in loginAction() 81 .arg(QString::number(failedAttemptsCount()), clientAddr, usernameFromWeb) in loginAction()
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-it/src/main/java/org/apache/zookeeper/test/system/ |
H A D | QuorumPeerInstance.java | 57 InetSocketAddress clientAddr; field in QuorumPeerInstance 97 if (clientAddr == null) { in configure() 113 clientAddr = (InetSocketAddress) ss.getLocalSocketAddress(); in configure() 132 String report = clientAddr.getHostString() + ':' + clientAddr.getPort() + in configure() 164 new Socket("127.0.0.1", clientAddr.getPort()).close(); in configure() 188 … LOG.debug("Starting quorumPeer " + serverId + " on port " + clientAddr.getPort()); in configure() 195 …peer = new QuorumPeer(peers, snapDir, logDir, clientAddr.getPort(), 3, serverId, tickTime, initLim… in configure() 201 new Socket("127.0.0.1", clientAddr.getPort()).close(); in configure()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/catalog/ |
H A D | type_changelog_test.cpp | 51 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST() 76 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST() 89 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST() 116 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST() 129 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST() 142 << ChangeLogType::clientAddr("192.168.0.189:51128") in TEST()
|
H A D | type_changelog.cpp | 46 const BSONField<std::string> ChangeLogType::clientAddr("clientAddr"); member in mongo::ChangeLogType 73 Status status = bsonExtractStringField(source, clientAddr.name(), &changeLogClientAddr); in fromBSON() 124 str::stream() << "missing " << clientAddr.name() << " field"}; in validate() 146 builder.append(clientAddr.name(), getClientAddr()); in toBSON() 167 void ChangeLogType::setClientAddr(const std::string& clientAddr) { in setClientAddr() argument 168 _clientAddr = clientAddr; in setClientAddr()
|
/dports/net/gerbera/gerbera-1.9.2/src/util/ |
H A D | upnp_clients.cc | 191 struct sockaddr_in clientAddr = {}; in getInfoByAddr() local 192 clientAddr.sin_family = AF_INET; in getInfoByAddr() 193 clientAddr.sin_addr.s_addr = inet_addr(c.match.c_str()); in getInfoByAddr() 194 …if (sockAddrCmpAddr(reinterpret_cast<const struct sockaddr*>(&clientAddr), reinterpret_cast<const … in getInfoByAddr() 199 struct sockaddr_in6 clientAddr = {}; in getInfoByAddr() local 200 clientAddr.sin6_family = AF_INET6; in getInfoByAddr() 201 if (inet_pton(AF_INET6, c.match.c_str(), &clientAddr.sin6_addr) == 1) { in getInfoByAddr() 202 …if (sockAddrCmpAddr(reinterpret_cast<const struct sockaddr*>(&clientAddr), reinterpret_cast<const … in getInfoByAddr()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/server/ |
H A D | Cpp2Worker.cpp | 193 const folly::SocketAddress& clientAddr, in plaintextConnectionReady() argument 198 clientAddr, in plaintextConnectionReady() 279 const folly::SocketAddress& clientAddr, in createSSLHelper() argument 287 return getFizzPeeker()->getHelper(bytes, clientAddr, acceptTime, tInfo); in createSSLHelper() 290 bytes, clientAddr, acceptTime, tInfo); in createSSLHelper() 294 const std::vector<uint8_t>& bytes, const folly::SocketAddress& clientAddr) { in shouldPerformSSL() argument 301 clientAddr.isLoopbackAddress() && !TLSHelper::looksLikeTLS(bytes)); in shouldPerformSSL() 330 const folly::SocketAddress& clientAddr, in getHelper() argument 333 if (!shouldPerformSSL(bytes, clientAddr)) { in getHelper() 337 return createSSLHelper(bytes, clientAddr, acceptTime, ti); in getHelper()
|
/dports/www/fabio/fabio-1.5.14/proxy/tcp/ |
H A D | proxy_proto.go | 11 clientAddr, clientPort, _ := net.SplitHostPort(in.RemoteAddr().String()) 15 if net.ParseIP(clientAddr).To4() != nil { 21 …header := "PROXY " + proto + " " + clientAddr + " " + serverAddr + " " + clientPort + " " + server…
|
/dports/devel/poco/poco-1.10.1-all/NetSSL_OpenSSL/src/ |
H A D | SecureServerSocket.cpp | 102 StreamSocket SecureServerSocket::acceptConnection(SocketAddress& clientAddr) in acceptConnection() argument 104 return SecureStreamSocket(impl()->acceptConnection(clientAddr)); in acceptConnection() 110 SocketAddress clientAddr; in acceptConnection() local 111 return SecureStreamSocket(impl()->acceptConnection(clientAddr)); in acceptConnection()
|
/dports/games/hedgewars-server/hedgewars-src-1.0.0/QTfrontend/net/ |
H A D | netudpserver.cpp | 40 QHostAddress clientAddr; in onClientRead() local 42 pUdpSocket->readDatagram(datagram.data(), datagram.size(), &clientAddr, &clientPort); in onClientRead() 46 …cket->writeDatagram(QString("hedgewars server\n%1").arg(m_descr).toUtf8(), clientAddr, clientPort); in onClientRead()
|
H A D | netudpwidget.cpp | 53 QHostAddress clientAddr; in onClientRead() local 56 pUdpSocket->readDatagram(datagram.data(), datagram.size(), &clientAddr, &clientPort); in onClientRead() 62 … sl << packet.remove(0, 17) << clientAddr.toString() << QString::number(NETGAME_DEFAULT_PORT); in onClientRead()
|
/dports/games/hedgewars/hedgewars-src-1.0.0/QTfrontend/net/ |
H A D | netudpserver.cpp | 40 QHostAddress clientAddr; in onClientRead() local 42 pUdpSocket->readDatagram(datagram.data(), datagram.size(), &clientAddr, &clientPort); in onClientRead() 46 …cket->writeDatagram(QString("hedgewars server\n%1").arg(m_descr).toUtf8(), clientAddr, clientPort); in onClientRead()
|
H A D | netudpwidget.cpp | 53 QHostAddress clientAddr; in onClientRead() local 56 pUdpSocket->readDatagram(datagram.data(), datagram.size(), &clientAddr, &clientPort); in onClientRead() 62 … sl << packet.remove(0, 17) << clientAddr.toString() << QString::number(NETGAME_DEFAULT_PORT); in onClientRead()
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/gravitational/trace/ |
H A D | udphook.go | 34 if f.clientAddr == "" { 35 f.clientAddr = UDPDefaultAddr 37 addr, err := net.ResolveUDPAddr(f.clientNet, f.clientAddr) 53 clientAddr string member
|
/dports/games/bzflag-server/bzflag-2.4.22/src/net/ |
H A D | AresHandler.cxx | 81 void AresHandler::queryHostname(const struct sockaddr *clientAddr) in queryHostname() argument 88 ares_gethostbyaddr(aresChannel, &((const sockaddr_in *)clientAddr)->sin_addr, in queryHostname() 157 *clientAddr) in getHostAddress() argument 160 memcpy(clientAddr, &hostAddress, sizeof(hostAddress)); in getHostAddress()
|
/dports/games/bzflag/bzflag-2.4.22/src/net/ |
H A D | AresHandler.cxx | 81 void AresHandler::queryHostname(const struct sockaddr *clientAddr) in queryHostname() argument 88 ares_gethostbyaddr(aresChannel, &((const sockaddr_in *)clientAddr)->sin_addr, in queryHostname() 157 *clientAddr) in getHostAddress() argument 160 memcpy(clientAddr, &hostAddress, sizeof(hostAddress)); in getHostAddress()
|
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rpc/netty/ |
H A D | NettyRpcEnv.scala | 576 val clientAddr = RpcAddress(addr.getHostString, addr.getPort) constant 585 if (remoteAddresses.putIfAbsent(clientAddr, remoteEnvAddress) == null) { 597 val clientAddr = RpcAddress(addr.getHostString, addr.getPort) constant 598 dispatcher.postToAll(RemoteProcessConnectionError(cause, clientAddr)) 601 val remoteEnvAddress = remoteAddresses.get(clientAddr) 616 val clientAddr = RpcAddress(addr.getHostString, addr.getPort) constant 617 dispatcher.postToAll(RemoteProcessConnected(clientAddr)) 623 val clientAddr = RpcAddress(addr.getHostString, addr.getPort) constant 624 nettyEnv.removeOutbox(clientAddr) 625 dispatcher.postToAll(RemoteProcessDisconnected(clientAddr)) [all …]
|
/dports/net/liveMedia/live/liveMedia/ |
H A D | GenericMediaServer.cpp | 187 struct sockaddr_storage clientAddr; in incomingConnectionHandlerOnSocket() local 188 SOCKLEN_T clientAddrLen = sizeof clientAddr; in incomingConnectionHandlerOnSocket() 189 int clientSocket = accept(serverSocket, (struct sockaddr*)&clientAddr, &clientAddrLen); in incomingConnectionHandlerOnSocket() 202 envir() << "accept()ed connection from " << AddressString(clientAddr).val() << "\n"; in incomingConnectionHandlerOnSocket() 206 (void)createNewClientConnection(clientSocket, clientAddr); in incomingConnectionHandlerOnSocket() 213 …nnection(GenericMediaServer& ourServer, int clientSocket, struct sockaddr_storage const&clientAddr) in ClientConnection() argument 214 : fOurServer(ourServer), fOurSocket(clientSocket), fClientAddr(clientAddr) { in ClientConnection()
|
/dports/devel/folly/folly-2021.12.27.00/folly/test/ |
H A D | SocketAddressTest.cpp | 717 sockaddr_storage clientAddr; in testSetFromSocket() local 760 SocketAddress clientAddr; in TEST() local 770 &clientAddr, in TEST() 786 EXPECT_EQ(acceptAddr, clientAddr); in TEST() 806 SocketAddress clientAddr; in TEST() local 816 &clientAddr, in TEST() 847 SocketAddress clientAddr; in TEST() local 860 &clientAddr, in TEST() 881 EXPECT_EQ(acceptAddr, clientAddr); in TEST() 894 SocketAddress clientAddr; in TEST() local [all …]
|
/dports/devel/poco/poco-1.10.1-all/Net/src/ |
H A D | ServerSocket.cpp | 145 StreamSocket ServerSocket::acceptConnection(SocketAddress& clientAddr) in acceptConnection() argument 147 return StreamSocket(impl()->acceptConnection(clientAddr)); in acceptConnection() 153 SocketAddress clientAddr; in acceptConnection() local 154 return StreamSocket(impl()->acceptConnection(clientAddr)); in acceptConnection()
|
/dports/net/ns3/ns-allinone-3.35/ns-3.35/src/fd-net-device/helper/ |
H A D | creator-utils.cc | 72 struct sockaddr_un clientAddr; in SendSocket() local 75 bool rc = ns3::StringToBuffer (path, (uint8_t *)&clientAddr, &clientAddrLen); in SendSocket() 79 int status = connect (sock, (struct sockaddr*)&clientAddr, clientAddrLen); in SendSocket()
|