Searched refs:event_message (Results 1 – 2 of 2) sorted by relevance
154 EventMessage event_message; in BroadcastEvent() local155 event_message.set_event(event); in BroadcastEvent()156 event_message.set_node_id(node_info_.node_id_); in BroadcastEvent()158 …if (!SendMessageSync(client_to_scheduler_, message_meta, Protos::PROTOBUF, event_message.Serialize… in BroadcastEvent()159 event_message.ByteSizeLong())) { in BroadcastEvent()
323 EventMessage event_message; in ProcessSendEvent() local324 event_message.ParseFromArray(data, SizeToInt(size)); in ProcessSendEvent()325 std::string node_id = event_message.node_id(); in ProcessSendEvent()326 uint32_t event = event_message.event(); in ProcessSendEvent()