1 files changed, 51 insertions, 0 deletions
diff --git a/src/components/application_manager/include/application_manager/event_engine/event_dispatcher_impl.h b/src/components/application_manager/include/application_manager/event_engine/event_dispatcher_impl.h
index ed923369ac..75e77e603c 100644
--- a/src/components/application_manager/include/application_manager/event_engine/event_dispatcher_impl.h
+++ b/src/components/application_manager/include/application_manager/event_engine/event_dispatcher_impl.h
@@ -52,6 +52,8 @@ class EventDispatcherImpl : public EventDispatcher {
   typedef std::vector<EventObserver*> ObserverVector;
   typedef std::map<int32_t, ObserverVector> ObserversMap;
   typedef std::map<Event::EventID, ObserversMap> EventObserverMap;
+  typedef std::map<MobileEvent::MobileEventID, ObserversMap>
+      MobileEventObserverMap;
   /*
    * @brief Destructor
    */
@@ -66,6 +68,9 @@ class EventDispatcherImpl : public EventDispatcher {
   EventObserverMap get_observers() const {
     return observers_event_;
   }
+  MobileEventObserverMap get_mobile_observers() const {
+    return mobile_observers_event_;
+  }
   ObserverVector get_observers_list() const {
     return observers_;
   }
@@ -105,6 +110,41 @@ class EventDispatcherImpl : public EventDispatcher {
    */
   void remove_observer(EventObserver& observer) OVERRIDE;
 
+  // Mobile requests
+  /*
+   * @brief Delivers the event to all subscribers
+   *
+   * @param event Received event
+   */
+  void raise_mobile_event(const MobileEvent& event) OVERRIDE;
+
+  /*
+   * @brief Subscribe the observer to event
+   *
+   * @param event_id    The event ID to subscribe for
+   * @param hmi_correlation_id  The event HMI correlation ID
+   * @param observer    The observer to subscribe for event
+   */
+  void add_mobile_observer(const MobileEvent::MobileEventID& event_id,
+                           int32_t mobile_correlation_id,
+                           EventObserver& observer) OVERRIDE;
+
+  /*
+   * @brief Unsubscribes the observer from specific event
+   *
+   * @param event_id    The event ID to unsubscribe from
+   * @param observer    The observer to be unsubscribed
+   */
+  void remove_mobile_observer(const MobileEvent::MobileEventID& event_id,
+                              EventObserver& observer) OVERRIDE;
+
+  /*
+   * @brief Unsubscribes the observer from all events
+   *
+   * @param observer  The observer to be unsubscribed
+   */
+  void remove_mobile_observer(EventObserver& observer) OVERRIDE;
+
  private:
   /*
    * @brief removes observer
@@ -113,14 +153,25 @@ class EventDispatcherImpl : public EventDispatcher {
    */
   void remove_observer_from_vector(EventObserver& observer);
 
+  /*
+   * @brief removes observer
+   * when occurs unsubscribe from event
+   * @param observer to be removed
+   */
+  void remove_mobile_observer_from_vector(EventObserver& observer);
+
   DISALLOW_COPY_AND_ASSIGN(EventDispatcherImpl);
 
  private:
   // Members section
   sync_primitives::Lock state_lock_;
+  sync_primitives::Lock mobile_state_lock_;
   sync_primitives::RecursiveLock observer_lock_;
+  sync_primitives::RecursiveLock mobile_observer_lock_;
   EventObserverMap observers_event_;
+  MobileEventObserverMap mobile_observers_event_;
   ObserverVector observers_;
+  ObserverVector mobile_observers_;
 };
 
 }  // namespace event_engine