Searched refs:channel_handle (Results 1 – 8 of 8) sorted by relevance
21 LocalChannelHandle channel_handle);83 explicit ClientChannel(LocalChannelHandle channel_handle);
140 ClientChannel::ClientChannel(LocalChannelHandle channel_handle) in ClientChannel() argument141 : channel_handle_{std::move(channel_handle)} { in ClientChannel()146 LocalChannelHandle channel_handle) { in Create() argument148 new ClientChannel{std::move(channel_handle)}}; in Create()
184 Status<RemoteChannelHandle> channel_handle = in HandleMessage() local186 REPLY_MESSAGE_RETURN(message, channel_handle, {}); in HandleMessage()194 Status<RemoteChannelHandle> channel_handle = message.PushChannel( in HandleMessage() local196 REPLY_MESSAGE_RETURN(message, channel_handle, {}); in HandleMessage()
237 BorrowedHandle channel_handle = local_socket.Borrow(); in AcceptConnection() local249 status = ReceiveMessageForChannel(channel_handle, message); in AcceptConnection()251 CloseChannel(GetChannelId(channel_handle)); in AcceptConnection()
331 explicit TestClient(LocalChannelHandle channel_handle) in TestClient() argument333 std::move(channel_handle))} {} in TestClient()
17 BufferHubBase::BufferHubBase(LocalChannelHandle channel_handle) in BufferHubBase() argument19 std::move(channel_handle))}, in BufferHubBase()
564 LocalChannelHandle channel_handle; in TEST_F() local565 EXPECT_FALSE(transaction_.GetChannelHandle(2, &channel_handle)); in TEST_F()566 EXPECT_TRUE(transaction_.GetChannelHandle(2, &channel_handle)); in TEST_F()
342 const ChannelHandle<Mode>& channel_handle) {343 return GetEncodingSize(EncodeType(channel_handle)) + sizeof(std::int32_t);