| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | balancer_conn_wrappers.go | 42 backlog []*scStateUpdate member
54 if len(b.backlog) == 0 {
61 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DelegatingServerSocketFactory.java | 48 public ServerSocket createServerSocket(int port, int backlog) throws IOException { in createServerSocket() argument
49 ServerSocket serverSocket = delegate.createServerSocket(port, backlog); in createServerSocket()
54 public ServerSocket createServerSocket(int port, int backlog, InetAddress ifAddress) in createServerSocket() argument
56 ServerSocket serverSocket = delegate.createServerSocket(port, backlog, ifAddress); in createServerSocket()
|
| /external/conscrypt/repackaged/common/src/main/java/com/android/org/conscrypt/ |
| D | OpenSSLServerSocketFactoryImpl.java | 92 public ServerSocket createServerSocket(int port, int backlog) throws IOException { in createServerSocket() argument
93 return new ConscryptServerSocket(port, backlog, (SSLParametersImpl) sslParameters.clone()) in createServerSocket()
98 public ServerSocket createServerSocket(int port, int backlog, InetAddress iAddress) in createServerSocket() argument
101 port, backlog, iAddress, (SSLParametersImpl) sslParameters.clone()) in createServerSocket()
|
| D | ConscryptServerSocket.java | 43 ConscryptServerSocket(int port, int backlog, SSLParametersImpl sslParameters) in ConscryptServerSocket() argument
45 super(port, backlog); in ConscryptServerSocket()
50 int backlog, in ConscryptServerSocket() argument
54 super(port, backlog, iAddress); in ConscryptServerSocket()
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| D | OpenSSLServerSocketFactoryImpl.java | 91 public ServerSocket createServerSocket(int port, int backlog) throws IOException { in createServerSocket() argument
92 return new ConscryptServerSocket(port, backlog, (SSLParametersImpl) sslParameters.clone()) in createServerSocket()
97 public ServerSocket createServerSocket(int port, int backlog, InetAddress iAddress) in createServerSocket() argument
100 port, backlog, iAddress, (SSLParametersImpl) sslParameters.clone()) in createServerSocket()
|
| D | ConscryptServerSocket.java | 42 ConscryptServerSocket(int port, int backlog, SSLParametersImpl sslParameters) in ConscryptServerSocket() argument
44 super(port, backlog); in ConscryptServerSocket()
49 int backlog, in ConscryptServerSocket() argument
53 super(port, backlog, iAddress); in ConscryptServerSocket()
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | transport.go | 60 backlog []recvMsg member
80 if len(b.backlog) == 0 {
88 b.backlog = append(b.backlog, r)
94 if len(b.backlog) > 0 {
96 case b.c <- b.backlog[0]:
97 b.backlog[0] = recvMsg{}
98 b.backlog = b.backlog[1:]
|
| /external/nist-sip/java/gov/nist/core/net/ |
| D | DefaultNetworkLayer.java | 69 public ServerSocket createServerSocket(int port, int backlog, in createServerSocket() argument
71 return new ServerSocket(port, backlog, bindAddress); in createServerSocket()
98 public SSLServerSocket createSSLServerSocket(int port, int backlog, in createSSLServerSocket() argument
101 port, backlog, bindAddress); in createSSLServerSocket()
|
| D | SslNetworkLayer.java | 88 public ServerSocket createServerSocket(int port, int backlog, in createServerSocket() argument
90 return new ServerSocket(port, backlog, bindAddress); in createServerSocket()
108 public SSLServerSocket createSSLServerSocket(int port, int backlog, in createSSLServerSocket() argument
111 port, backlog, bindAddress); in createSSLServerSocket()
|
| D | NetworkLayer.java | 57 public ServerSocket createServerSocket(int port, int backlog, in createServerSocket() argument
69 public SSLServerSocket createSSLServerSocket(int port, int backlog, in createSSLServerSocket() argument
|
| /external/libevent/ |
| D | listener.c | 110 evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,
157 evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, in evconnlistener_new() argument
168 backlog, fd); in evconnlistener_new()
172 if (backlog > 0) { in evconnlistener_new()
173 if (listen(fd, backlog) < 0) in evconnlistener_new()
175 } else if (backlog < 0) { in evconnlistener_new()
211 void *ptr, unsigned flags, int backlog, const struct sockaddr *sa, in evconnlistener_new_bind() argument
220 if (backlog == 0) in evconnlistener_new_bind()
253 listener = evconnlistener_new(base, cb, ptr, flags, backlog, fd); in evconnlistener_new_bind()
805 evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, in evconnlistener_new_async() argument
[all …]
|
| /external/strace/tests/ |
| D | nlattr_tcmsg.c | 94 .backlog = 0xbdeabeab in main()
96 char buf[offsetofend(struct tc_stats, backlog)]; in main()
108 PRINT_FIELD_U(", ", st, backlog); in main()
|
| /external/strace/tests-mx32/ |
| D | nlattr_tcmsg.c | 94 .backlog = 0xbdeabeab in main()
96 char buf[offsetofend(struct tc_stats, backlog)]; in main()
108 PRINT_FIELD_U(", ", st, backlog); in main()
|
| /external/strace/tests-m32/ |
| D | nlattr_tcmsg.c | 94 .backlog = 0xbdeabeab in main()
96 char buf[offsetofend(struct tc_stats, backlog)]; in main()
108 PRINT_FIELD_U(", ", st, backlog); in main()
|
| /external/grpc-grpc/test/core/util/ |
| D | trickle_endpoint.cc | 194 size_t backlog = te->write_buffer.length; in grpc_trickle_endpoint_trickle() local
196 return backlog; in grpc_trickle_endpoint_trickle()
202 size_t backlog = te->write_buffer.length; in grpc_trickle_get_backlog() local
204 return backlog; in grpc_trickle_get_backlog()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | connection.py | 124 def __init__(self, address=None, family=None, backlog=1, authkey=None): argument
130 self._listener = PipeListener(address, backlog)
132 self._listener = SocketListener(address, family, backlog)
251 def __init__(self, address, family, backlog=1): argument
257 self._socket.listen(backlog)
335 def __init__(self, address, backlog=None): argument
|
| /external/ltp/include/old/ |
| D | old_safe_net.h | 37 #define SAFE_LISTEN(cleanup_fn, socket, backlog) \ argument
38 safe_listen(__FILE__, __LINE__, (cleanup_fn), socket, backlog)
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| D | NettyHttpClient.java | 56 private final Deque<HttpUrl> backlog = new ArrayDeque<>(); field in NettyHttpClient
99 backlog.add(url); // Enqueue this for later, to be picked up when another request completes. in enqueue()
112 return backlog.size() < targetBacklog || hasFreeChannels(); in acceptingJobs()
123 url = backlog.pop(); in release()
|
| /external/libevent/include/event2/ |
| D | listener.h | 120 evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,
139 evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,
|
| /external/python/cpython2/Lib/multiprocessing/dummy/ |
| D | connection.py | 45 def __init__(self, address=None, family=None, backlog=1): argument
46 self._backlog_queue = Queue(backlog)
|
| /external/swiftshader/src/System/ |
| D | Socket.cpp | 65 void Socket::listen(int backlog) in listen() argument
67 ::listen(socket, backlog); in listen()
|
| /external/swiftshader/src/Common/ |
| D | Socket.cpp | 65 void Socket::listen(int backlog) in listen() argument
67 ::listen(socket, backlog); in listen()
|
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| D | connection.py | 20 def __init__(self, address=None, family=None, backlog=1): argument
21 self._backlog_queue = Queue(backlog)
|
| /external/ltp/testcases/kernel/syscalls/listen/ |
| D | listen01.c | 70 int backlog; /* connect's 3rd argument */ member
98 TEST(listen(s, tdat[testno].backlog)); in main()
|
| /external/strace/ |
| D | rtnl_tc.c | 54 offsetofend(struct tc_stats, backlog); in decode_tc_stats()
66 PRINT_FIELD_U(", ", st, backlog); in decode_tc_stats()
153 PRINT_FIELD_U(", ", qstats, backlog); in decode_gnet_stats_queue()
|