Home
last modified time | relevance | path

Searched refs:clientAddr (Results 1 – 25 of 382) sorted by relevance

12345678910>>...16

/dports/net/wangle/wangle-2021.12.27.00/wangle/acceptor/
H A DAcceptor.cpp247 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 DSSLAcceptorHandshakeHelper.h33 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 DPeekingAcceptorHandshakeHelper.h48 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 Dterminal.go28 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 Dterminal.go28 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 Dauthcontroller.cpp47 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 DQuorumPeerInstance.java57 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 Dtype_changelog_test.cpp51 << 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 Dtype_changelog.cpp46 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 Dupnp_clients.cc191 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 DCpp2Worker.cpp193 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 Dproxy_proto.go11 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 DSecureServerSocket.cpp102 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 Dnetudpserver.cpp40 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 Dnetudpwidget.cpp53 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 Dnetudpserver.cpp40 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 Dnetudpwidget.cpp53 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 Dudphook.go34 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 DAresHandler.cxx81 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 DAresHandler.cxx81 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 DNettyRpcEnv.scala576 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 DGenericMediaServer.cpp187 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 DSocketAddressTest.cpp717 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 DServerSocket.cpp145 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 Dcreator-utils.cc72 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()

12345678910>>...16