ServiceMonitor.h

/*
* If not stated otherwise in this file or this component's LICENSE file the
* following copyright and licenses apply:
*
* Copyright 2016 Sky UK
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/*
 * File:   ServiceMonitor.h
 *
 */
#ifndef SERVICEMONITOR_H
#define SERVICEMONITOR_H
 
#include <IDobbyIPCUtils.h>
#include <IDobbyUtils.h>
 
#include <mutex>
#include <memory>
 
// -----------------------------------------------------------------------------
class ServiceMonitor
{
public:
    enum class State
    {
        NotRunning, 
        Running,    
        Ready       
    };
 
public:
    ServiceMonitor(const std::shared_ptr<IDobbyIPCUtils> &ipcUtils,
                   const std::shared_ptr<IDobbyUtils> &utils,
                   const IDobbyIPCUtils::BusType &bus,
                   const std::string &serviceName,
                   const AI_IPC::Signal &readySignal,
                   const AI_IPC::Method &queryMethod,
                   const std::function<void(State)> &stateChangeHandler);
    ~ServiceMonitor();
 
public:
    State state() const;
 
    void forceReadyCheck();
 
private:
    void onServiceNotification(bool added);
    void onReadyNotification(const AI_IPC::VariantList &args);
 
    bool onTimer();
 
    void sendIsReadyRequest() const;
 
private:
    const std::shared_ptr<IDobbyUtils> mUtilities;
    const std::shared_ptr<IDobbyIPCUtils> mIPCUtilities;
    const IDobbyIPCUtils::BusType mBusType;
    const std::string mServiceName;
    const AI_IPC::Signal mReadySignal;
    const AI_IPC::Method mQueryMethod;
    const std::function<void(State)> mStateChangeHandler;
 
private:
    mutable std::mutex mLock;
    State mState;
 
    int mServiceHandlerId;
    int mSignalHandlerId;
    int mTimerId;
};
 
#endif // !defined(SERVICEMONITOR_H)