Searched refs:TRANSPORT_ATTR_REMOTE_ADDR (Results 1 – 12 of 12) sorted by relevance
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ProtocolNegotiators.java | 92 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress()) in serverPlaintext()
159 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress())
653 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress())
701 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress())
744 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress())
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Grpc.java | 34 public static final Attributes.Key<SocketAddress> TRANSPORT_ATTR_REMOTE_ADDR = field in Grpc
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiator.java | 126 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, ctx.channel().remoteAddress())
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 580 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, remoteAddr) in transportFilters()
599 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, remoteAddr) in transportFilters()
620 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, remoteAddr) in transportFilters()
627 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, remoteAddr).build()); in transportFilters()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinlogHelperTest.java | 837 getPeerSocket(Attributes.newBuilder().set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, peer).build())); in getPeerSocketTest()
966 return Attributes.newBuilder().set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, peer).build(); in clientInterceptor()
1130 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, peer) in serverInterceptor()
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiatorTest.java | 346 assertThat(grpcHandler.attrs.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR).toString()) in peerPropagated()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 134 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, new InProcessSocketAddress(name)) in start()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinlogHelper.java | 317 SocketAddress peer = streamAttributes.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR); in getPeerSocket()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 709 assertNotNull(serverStream.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR)); in basicStream()
1718 SocketAddress serverAddress = clientStream.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR); in socketStats()
1719 SocketAddress clientAddress = serverStream.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR); in socketStats()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 538 assertEquals(address, rpc.stream.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR)); in clientStreamGetsAttributes()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 486 .set(Grpc.TRANSPORT_ATTR_REMOTE_ADDR, sock.getRemoteSocketAddress()) in start()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 1769 return serverCallCapture.get().getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR); in obtainRemoteClientAddr()
|