Home
last modified time | relevance | path

Searched refs:ServerTransport (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerImpl.java108 @GuardedBy("lock") private final Collection<ServerTransport> transports =
109 new HashSet<ServerTransport>();
234 Collection<ServerTransport> transportsCopy; in shutdownNow()
252 for (ServerTransport transport : transportsCopy) { in shutdownNow()
300 private void transportClosed(ServerTransport transport) { in transportClosed()
330 public ServerTransportListener transportCreated(ServerTransport transport) { in transportCreated()
341 ArrayList<ServerTransport> copiedTransports; in serverShutdown()
350 for (ServerTransport transport : copiedTransports) { in serverShutdown()
365 private final ServerTransport transport;
369 ServerTransportListenerImpl(ServerTransport transport) { in ServerTransportListenerImpl()
DServerListener.java31 ServerTransportListener transportCreated(ServerTransport transport); in transportCreated()
DServerTransport.java25 public interface ServerTransport extends InternalInstrumented<SocketStats> { interface
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerTest.java32 import io.grpc.internal.ServerTransport;
77 public ServerTransportListener transportCreated(ServerTransport transport) { in getPort()
153 public ServerTransportListener transportCreated(ServerTransport transport) { in childChannelOptions()
204 public ServerTransportListener transportCreated(ServerTransport transport) { in channelzListenSocket()
DNettyClientTransportTest.java60 import io.grpc.internal.ServerTransport;
758 public ServerTransportListener transportCreated(final ServerTransport transport) { in transportCreated()
/external/syzkaller/vendor/google.golang.org/grpc/transport/
Dtransport.go168 st ServerTransport // nil for client side Stream
297 func (s *Stream) ServerTransport() ServerTransport { func
347 t := s.ServerTransport()
446 func NewServerTransport(protocol string, conn net.Conn, config *ServerConfig) (ServerTransport, err…
591 type ServerTransport interface { interface
Dhandler_server.go50 …erTransport(w http.ResponseWriter, r *http.Request, stats stats.Handler) (ServerTransport, error) {
Dhttp2_server.go132 func newHTTP2Server(conn net.Conn, config *ServerConfig) (_ ServerTransport, err error) {
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
DInProcessServerTest.java25 import io.grpc.internal.ServerTransport;
70 @Override public ServerTransportListener transportCreated(ServerTransport transport) { in serverHoldsRefToScheduler()
/external/syzkaller/vendor/google.golang.org/grpc/
Dserver.go647 …s *Server) newHTTP2Transport(c net.Conn, authInfo credentials.AuthInfo) transport.ServerTransport {
674 func (s *Server) serveStreams(st transport.ServerTransport) {
755 func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceIn…
783 c.(transport.ServerTransport).Drain()
830 func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{…
853 func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport.Stream, srv *servic…
1072 func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, srv *se…
1199 func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceI…
1392 c.(transport.ServerTransport).Drain()
Dstream.go649 t transport.ServerTransport
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerTransport.java29 import io.grpc.internal.ServerTransport;
48 class NettyServerTransport implements ServerTransport {
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java50 import io.grpc.internal.ServerTransport;
71 final class InProcessTransport implements ServerTransport, ConnectionClientTransport {
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java68 import io.grpc.internal.ServerTransport;
148 private ServerTransport serverTransport;
1823 public ServerTransportListener transportCreated(ServerTransport transport) { in transportCreated()
1849 public final ServerTransport transport;
1853 public MockServerTransportListener(ServerTransport transport) { in MockServerTransportListener()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java1381 private class SimpleServerTransport implements ServerTransport {