Home
last modified time | relevance | path

Searched refs:transportBuffer (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
DFakeTsiTest.java88 ByteBuffer transportBuffer = ByteBuffer.wrap(transportBufferBytes); in handshakeStateOrderTest() local
89 transportBuffer.limit(0); // Start off with an empty buffer in handshakeStateOrderTest()
91 transportBuffer.clear(); in handshakeStateOrderTest()
92 clientHandshaker.getBytesToSendToPeer(transportBuffer); in handshakeStateOrderTest()
93 transportBuffer.flip(); in handshakeStateOrderTest()
96 new String(transportBufferBytes, 4, transportBuffer.remaining(), UTF_8).trim()); in handshakeStateOrderTest()
98 serverHandshaker.processBytesFromPeer(transportBuffer); in handshakeStateOrderTest()
99 assertFalse(transportBuffer.hasRemaining()); in handshakeStateOrderTest()
102 transportBuffer.clear(); in handshakeStateOrderTest()
103 clientHandshaker.getBytesToSendToPeer(transportBuffer); in handshakeStateOrderTest()
[all …]
DAltsTsiHandshakerTest.java107 ByteBuffer transportBuffer = ByteBuffer.allocate(TRANSPORT_BUFFER_SIZE); in processBytesFromPeerFalseStart() local
108 assertTrue(handshakerClient.processBytesFromPeer(transportBuffer)); in processBytesFromPeerFalseStart()
113 ByteBuffer transportBuffer = ByteBuffer.allocate(TRANSPORT_BUFFER_SIZE); in processBytesFromPeerStartServer() local
118 transportBuffer.position(transportBuffer.limit()); in processBytesFromPeerStartServer()
119 when(mockServer.startServerHandshake(transportBuffer)).thenReturn(outputFrame); in processBytesFromPeerStartServer()
122 assertTrue(handshakerServer.processBytesFromPeer(transportBuffer)); in processBytesFromPeerStartServer()
127 ByteBuffer transportBuffer = ByteBuffer.allocate(TRANSPORT_BUFFER_SIZE); in processBytesFromPeerStartServerEmptyOutput() local
133 transportBuffer.position(transportBuffer.limit()); in processBytesFromPeerStartServerEmptyOutput()
134 when(mockServer.startServerHandshake(transportBuffer)).thenReturn(emptyOutputFrame); in processBytesFromPeerStartServerEmptyOutput()
137 assertFalse(handshakerServer.processBytesFromPeer(transportBuffer)); in processBytesFromPeerStartServerEmptyOutput()
[all …]
DTsiTest.java85 ByteBuffer transportBuffer = ByteBuffer.wrap(transportBufferBytes); in performHandshake() local
86 transportBuffer.limit(0); // Start off with an empty buffer in performHandshake()
92 if (transportBuffer.hasRemaining()) { in performHandshake()
93 handshaker.processBytesFromPeer(transportBuffer); in performHandshake()
97 transportBuffer.clear(); in performHandshake()
98 handshaker.getBytesToSendToPeer(transportBuffer); in performHandshake()
99 transportBuffer.flip(); in performHandshake()