Searched refs:ServerTransport (Results 1 – 17 of 17) sorted by relevance
108 @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()
31 ServerTransportListener transportCreated(ServerTransport transport); in transportCreated()
25 public interface ServerTransport extends InternalInstrumented<SocketStats> { interface
32 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()
60 import io.grpc.internal.ServerTransport;758 public ServerTransportListener transportCreated(final ServerTransport transport) { in transportCreated()
168 st ServerTransport // nil for client side Stream297 func (s *Stream) ServerTransport() ServerTransport { func347 t := s.ServerTransport()446 func NewServerTransport(protocol string, conn net.Conn, config *ServerConfig) (ServerTransport, err…591 type ServerTransport interface { interface
50 …erTransport(w http.ResponseWriter, r *http.Request, stats stats.Handler) (ServerTransport, error) {
132 func newHTTP2Server(conn net.Conn, config *ServerConfig) (_ ServerTransport, err error) {
25 import io.grpc.internal.ServerTransport;70 @Override public ServerTransportListener transportCreated(ServerTransport transport) { in serverHoldsRefToScheduler()
647 …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()
649 t transport.ServerTransport
29 import io.grpc.internal.ServerTransport;48 class NettyServerTransport implements ServerTransport {
50 import io.grpc.internal.ServerTransport;71 final class InProcessTransport implements ServerTransport, ConnectionClientTransport {
68 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()
1381 private class SimpleServerTransport implements ServerTransport {
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...