| /external/syzkaller/vendor/google.golang.org/grpc/internal/channelz/ |
| D | types.go | 296 type listenSocket struct { struct
304 func (ls *listenSocket) addChild(id int64, e entry) { argument
308 func (ls *listenSocket) deleteChild(id int64) { argument
312 func (ls *listenSocket) triggerDelete() { argument
317 func (ls *listenSocket) deleteSelfIfReady() { argument
396 case *listenSocket:
|
| D | funcs.go | 82 listenSockets: make(map[int64]*listenSocket),
203 ls := &listenSocket{refName: ref, s: s, id: id, pid: pid}
240 listenSockets map[int64]*listenSocket
271 func (c *channelMap) addListenSocket(id int64, ls *listenSocket, pid int64, ref string) {
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerTest.java | 215 InternalInstrumented<SocketStats> listenSocket = getOnlyElement(ns.getListenSockets()); in channelzListenSocket() local
216 assertSame(listenSocket, channelz.getSocket(id(listenSocket))); in channelzListenSocket()
219 SocketStats socketStats = listenSocket.getStats().get(); in channelzListenSocket()
232 assertNull(channelz.getSocket(id(listenSocket))); in channelzListenSocket()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServer.java | 259 InternalInstrumented<SocketStats> listenSocket = new ListenSocket(channel); in start()
260 listenSockets = ImmutableList.of(listenSocket); in start()
261 channelz.addListenSocket(listenSocket); in start()
283 for (InternalInstrumented<SocketStats> listenSocket : listenSockets) { in shutdown()
284 channelz.removeListenSocket(listenSocket); in shutdown()
|
| /external/swiftshader/src/Main/ |
| D | SwiftConfig.cpp | 47 SwiftConfig::SwiftConfig(bool disableServerOverride) : listenSocket(0) in SwiftConfig()
75 listenSocket = new Socket("localhost", "8080"); in createServer()
76 listenSocket->listen(); in createServer()
90 delete listenSocket; in destroyServer()
91 listenSocket = 0; in destroyServer()
132 if(listenSocket->select(100000)) in serverLoop()
134 Socket *clientSocket = listenSocket->accept(); in serverLoop()
|
| D | SwiftConfig.hpp | 108 Socket *listenSocket; member in sw::SwiftConfig
|
| /external/swiftshader/src/Device/ |
| D | SwiftConfig.cpp | 47 SwiftConfig::SwiftConfig(bool disableServerOverride) : listenSocket(0) in SwiftConfig()
75 listenSocket = new Socket("localhost", "8080"); in createServer()
76 listenSocket->listen(); in createServer()
90 delete listenSocket; in destroyServer()
91 listenSocket = 0; in destroyServer()
132 if(listenSocket->select(100000)) in serverLoop()
134 Socket *clientSocket = listenSocket->accept(); in serverLoop()
|
| D | SwiftConfig.hpp | 108 Socket *listenSocket; member in sw::SwiftConfig
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzProtoUtilTest.java | 262 private final TestListenSocket listenSocket = new TestListenSocket(); field in ChannelzProtoUtilTest
265 .setName(listenSocket.toString())
266 .setSocketId(id(listenSocket))
274 ((InetSocketAddress) listenSocket.listenAddress).getAddress().getAddress()))
383 ChannelzProtoUtil.toSocket(listenSocket)); in toSocket_noDataWithOptions()
541 .setListenSockets(ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket)) in toServer()
555 ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket, otherListenSocket)) in toServer()
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | server.go | 477 type listenSocket struct { struct
482 func (l *listenSocket) ChannelzMetric() *channelz.SocketInternalMetric { argument
489 func (l *listenSocket) Close() error { argument
525 ls := &listenSocket{Listener: lis}
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 129 for (InternalInstrumented<SocketStats> listenSocket : stats.listenSockets) { in toServer()
130 builder.addListenSocket(toSocketRef(listenSocket)); in toServer()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/net/ |
| D | SocketFacade.java | 497 public Boolean listenSocket(String id) { in listenSocket() method in SocketFacade
|