Searched refs:ReceiverMessage (Results 1 – 8 of 8) sorted by relevance
| /external/openscreen/cast/streaming/ |
| D | receiver_message.cc | 24 EnumNameTable<ReceiverMessage::Type, 5> kMessageTypeNames{
25 {{kMessageTypeAnswer, ReceiverMessage::Type::kAnswer},
26 {"STATUS_RESPONSE", ReceiverMessage::Type::kStatusResponse},
27 {"CAPABILITIES_RESPONSE", ReceiverMessage::Type::kCapabilitiesResponse},
28 {"RPC", ReceiverMessage::Type::kRpc}}};
30 ReceiverMessage::Type GetMessageType(const Json::Value& root) { in GetMessageType()
33 return ReceiverMessage::Type::kUnknown; in GetMessageType()
37 ErrorOr<ReceiverMessage::Type> parsed = GetEnum(kMessageTypeNames, type); in GetMessageType()
39 return parsed.value(ReceiverMessage::Type::kUnknown); in GetMessageType()
130 ErrorOr<ReceiverMessage> ReceiverMessage::Parse(const Json::Value& value) { in Parse()
[all …]
|
| D | session_messager_unittest.cc | 63 return [this](ReceiverMessage message) { in GetReplyCallback()
79 std::vector<ReceiverMessage> receiver_messages;
103 sender_messager_.SetHandler(ReceiverMessage::Type::kRpc, in SetUp()
144 .SendMessage(ReceiverMessage{ReceiverMessage::Type::kRpc, 123, in TEST_F()
150 EXPECT_EQ(ReceiverMessage::Type::kRpc, in TEST_F()
161 ReceiverMessage::Type::kStatusResponse, in TEST_F()
174 .SendMessage(ReceiverMessage{ in TEST_F()
175 ReceiverMessage::Type::kStatusResponse, 3123, true /* valid */, in TEST_F()
181 EXPECT_EQ(ReceiverMessage::Type::kStatusResponse, in TEST_F()
196 ReceiverMessage::Type::kCapabilitiesResponse, in TEST_F()
[all …]
|
| D | session_messager.cc | 21 ReceiverMessage::Type reply_type, in ReplyIfTimedOut()
30 it->second(ReceiverMessage{reply_type, sequence_number}); in ReplyIfTimedOut()
81 void SenderSessionMessager::SetHandler(ReceiverMessage::Type type, in SetHandler()
84 OSP_DCHECK(type == ReceiverMessage::Type::kRpc); in SetHandler()
100 ReceiverMessage::Type reply_type, in SendRequest()
104 OSP_DCHECK(reply_type != ReceiverMessage::Type::kRpc); in SendRequest()
160 ErrorOr<ReceiverMessage> receiver_message = in OnMessage()
161 ReceiverMessage::Parse(message_body.value()); in OnMessage()
168 if (receiver_message.value().type == ReceiverMessage::Type::kRpc) { in OnMessage()
202 Error ReceiverSessionMessager::SendMessage(ReceiverMessage message) { in SendMessage()
[all …]
|
| D | session_messager.h | 55 using ReplyCallback = std::function<void(ReceiverMessage)>;
66 void SetHandler(ReceiverMessage::Type type, ReplyCallback cb);
71 ReceiverMessage::Type reply_type,
110 [[nodiscard]] Error SendMessage(ReceiverMessage message);
|
| D | receiver_message.h | 56 struct ReceiverMessage { struct
76 static ErrorOr<ReceiverMessage> Parse(const Json::Value& value); argument
|
| D | receiver_session.cc | 196 const Error result = messager_.SendMessage(ReceiverMessage{ in InitializeSession()
197 ReceiverMessage::Type::kAnswer, properties.sequence_number, in InitializeSession()
302 const Error result = messager_.SendMessage(ReceiverMessage{ in SendErrorAnswerReply()
303 ReceiverMessage::Type::kAnswer, sequence_number, false /* valid */, in SendErrorAnswerReply()
|
| D | sender_session.cc | 187 ReceiverMessage::Type::kAnswer, in NegotiateMirroring()
188 [this](ReceiverMessage message) { OnAnswer(message); }); in NegotiateMirroring()
195 void SenderSession::OnAnswer(ReceiverMessage message) { in OnAnswer()
|
| D | sender_session.h | 120 void OnAnswer(ReceiverMessage message);
|