| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | MockAltsHandshakerResp.java | 23 import io.grpc.alts.internal.Handshaker.HandshakerResp;
74 static HandshakerResp getErrorResponse() { in getErrorResponse()
75 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getErrorResponse()
85 static HandshakerResp getOkResponse(int bytesConsumed) { in getOkResponse()
86 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getOkResponse()
94 static HandshakerResp getEmptyOutFrameResponse(int bytesConsumed) { in getEmptyOutFrameResponse()
95 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getEmptyOutFrameResponse()
102 static HandshakerResp getFinishedResponse(int bytesConsumed) { in getFinishedResponse()
103 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getFinishedResponse()
|
| D | AltsHandshakerStubTest.java | 25 import io.grpc.alts.internal.Handshaker.HandshakerResp;
63 HandshakerResp resp = stub.send(req.build()); in sendSuccessfulMessage()
133 private StreamObserver<HandshakerResp> reader;
136 private void setReader(StreamObserver<HandshakerResp> reader) { in setReader()
146 reader.onNext(HandshakerResp.newBuilder().build()); in sendUnexpectedResponse()
154 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in onNext()
|
| D | AltsTsiTest.java | 25 import io.grpc.alts.internal.Handshaker.HandshakerResp;
162 public HandshakerResp send(HandshakerReq req) { in send()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 22 import io.grpc.alts.internal.Handshaker.HandshakerResp;
31 private final StreamObserver<HandshakerResp> reader = new Reader();
33 private final ArrayBlockingQueue<Optional<HandshakerResp>> responseQueue =
34 new ArrayBlockingQueue<Optional<HandshakerResp>>(1);
52 StreamObserver<HandshakerResp> getReaderForTest() { in getReaderForTest()
57 public HandshakerResp send(HandshakerReq req) throws InterruptedException, IOException { in send()
63 Optional<HandshakerResp> result = responseQueue.take(); in send()
82 private class Reader implements StreamObserver<HandshakerResp> {
85 public void onNext(HandshakerResp resp) { in onNext()
101 Optional<HandshakerResp> result = Optional.absent(); in onError()
[all …]
|
| D | AltsHandshakerClient.java | 26 import io.grpc.alts.internal.Handshaker.HandshakerResp;
155 private void handleResponse(HandshakerResp resp) throws GeneralSecurityException { in handleResponse()
180 HandshakerResp resp; in startClientHandshake()
202 HandshakerResp resp; in startServerHandshake()
230 HandshakerResp resp; in next()
|
| /external/grpc-grpc/test/core/tsi/alts/fake_handshaker/ |
| D | fake_handshaker_server.cc | 63 ServerReaderWriter<HandshakerResp, HandshakerReq>* stream) override { in DoHandshake() argument
67 HandshakerResp response; in DoHandshake()
95 HandshakerResp* response) { in ProcessRequest()
113 HandshakerResp* response) { in ProcessClientStart()
139 HandshakerResp* response) { in ProcessServerStart()
175 HandshakerResp* response) { in ProcessNext()
220 ServerReaderWriter<HandshakerResp, HandshakerReq>* stream, in WriteErrorResponse() argument
223 HandshakerResp response; in WriteErrorResponse()
|
| D | handshaker.proto | 122 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
139 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
193 message HandshakerResp { message
222 returns (stream HandshakerResp) {
|
| /external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/ |
| D | HandshakerServiceGrpc.java | 31 io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshakeMethod;
36 responseType = io.grpc.alts.internal.Handshaker.HandshakerResp.class,
39 io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshakeMethod() { in getDoHandshakeMethod()
40 ….internal.Handshaker.HandshakerReq, io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshak… in getDoHandshakeMethod()
45 …lts.internal.Handshaker.HandshakerReq, io.grpc.alts.internal.Handshaker.HandshakerResp>newBuilder() in getDoHandshakeMethod()
53 io.grpc.alts.internal.Handshaker.HandshakerResp.getDefaultInstance())) in getDoHandshakeMethod()
100 … io.grpc.stub.StreamObserver<io.grpc.alts.internal.Handshaker.HandshakerResp> responseObserver) { in doHandshake()
111 io.grpc.alts.internal.Handshaker.HandshakerResp>( in bindService()
146 … io.grpc.stub.StreamObserver<io.grpc.alts.internal.Handshaker.HandshakerResp> responseObserver) { in doHandshake()
221 … (io.grpc.stub.StreamObserver<io.grpc.alts.internal.Handshaker.HandshakerResp>) responseObserver); in invoke()
|
| /external/grpc-grpc-java/alts/src/main/proto/grpc/gcp/ |
| D | handshaker.proto | 122 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
139 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
193 message HandshakerResp { message
222 returns (stream HandshakerResp) {
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/proto/ |
| D | handshaker.proto | 122 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
139 // Bytes in out_frames returned from the peer's HandshakerResp. It is possible
193 message HandshakerResp { message
222 returns (stream HandshakerResp) {
|
| /external/grpc-grpc-java/alts/src/generated/main/java/io/grpc/alts/internal/ |
| D | Handshaker.java | 12092 public static final class HandshakerResp extends class in Handshaker
12098 private HandshakerResp(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in HandshakerResp() method in Handshaker.HandshakerResp
12101 private HandshakerResp() { in HandshakerResp() method in Handshaker.HandshakerResp
12111 private HandshakerResp( in HandshakerResp() method in Handshaker.HandshakerResp
12194 …io.grpc.alts.internal.Handshaker.HandshakerResp.class, io.grpc.alts.internal.Handshaker.Handshaker… in internalGetFieldAccessorTable()
12356 if (!(obj instanceof io.grpc.alts.internal.Handshaker.HandshakerResp)) { in equals()
12359 …io.grpc.alts.internal.Handshaker.HandshakerResp other = (io.grpc.alts.internal.Handshaker.Handshak… in equals()
12404 public static io.grpc.alts.internal.Handshaker.HandshakerResp parseFrom( in parseFrom()
12409 public static io.grpc.alts.internal.Handshaker.HandshakerResp parseFrom( in parseFrom()
12415 public static io.grpc.alts.internal.Handshaker.HandshakerResp parseFrom( in parseFrom()
[all …]
|