ipc-gsource.hpp

Go to the documentation of this file.

/*
*  Copyright (c) 2015 Samsung Electronics Co., Ltd All Rights Reserved
*
*  Contact: Jan Olszak <j.olszak@samsung.com>
*
*  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
*/

#ifndef CARGO_IPC_IPC_GSOURCE_HPP
#define CARGO_IPC_IPC_GSOURCE_HPP

#include <glib.h>
#include "cargo-ipc/types.hpp"
#include "utils/callback-guard.hpp"

#include <memory>
#include <mutex>
#include <list>


namespace cargo {
namespace ipc {

struct IPCGSource {
public:
    typedef std::function<void(FileDescriptor fd, short pollEvent)> HandlerCallback;
    typedef std::shared_ptr<IPCGSource> Pointer;

    ~IPCGSource();

    IPCGSource() = delete;
    IPCGSource(const IPCGSource&) = delete;
    IPCGSource& operator=(const IPCGSource&) = delete;

    void addFD(const FileDescriptor peerFD);

    void removeFD(const FileDescriptor peerFD);

    guint attach(GMainContext* context = nullptr);

    void detach();

    static Pointer create(const HandlerCallback& handlerCallback);

    static gboolean onHandlerCall(gpointer userData);

    void callHandler();

private:
    typedef std::unique_lock<std::recursive_mutex> Lock;

    static gboolean prepare(GSource* source, gint* timeout);

    static gboolean check(GSource* source);

    static gboolean dispatch(GSource* source,
                             GSourceFunc callbacks,
                             gpointer userData);

    static void  finalize(GSource* source);

    // Called only from IPCGSource::create
    IPCGSource(const HandlerCallback& handlerCallback);

    GSource mGSource;
    HandlerCallback mHandlerCallback;
    std::list<GPollFD> mGPollFDs;
    utils::CallbackGuard mGuard;
    std::recursive_mutex mStateMutex;

};

} // namespace ipc
} // namespace cargo

#endif // CARGO_IPC_IPC_GSOURCE_HPP