/* -*- Mode: C; c-basic-offset: 4; indent-tabs-mode: nil -*- */
/*
   Copyright (C) 2009-2015 Red Hat, Inc.

   This library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Lesser General Public
   License as published by the Free Software Foundation; either
   version 2.1 of the License, or (at your option) any later version.

   This library is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Lesser General Public License for more details.

   You should have received a copy of the GNU Lesser General Public
   License along with this library; if not, see <http://www.gnu.org/licenses/>.
*/

#ifndef DISPATCHER_H_
#define DISPATCHER_H_

#include <pthread.h>

#include "red-common.h"
#include "utils.hpp"

#include "push-visibility.h"

struct Dispatcher;
struct DispatcherPrivate;
struct DispatcherMessage;

/* The function signature for handlers of a specific message type */
typedef void (*dispatcher_handle_message)(void *opaque,
                                          void *payload);

/* The signature for a function that handles all messages (see
 * dispatcher_register_universal_handler()) */
typedef void (*dispatcher_handle_any_message)(void *opaque,
                                              uint32_t message_type,
                                              void *payload);

/**
 * A Dispatcher provides inter-thread communication by serializing messages.
 * Currently the Dispatcher uses a unix socket (socketpair) for dispatching the
 * messages.
 *
 * Message types are identified by a unique integer value and must first be
 * registered with the class (see register_handler()) before they
 * can be sent. Sending threads can send a message using the
 * send_message() function. The receiving thread can monitor the
 * dispatcher's 'receive' file descriptor (see create_watch()) for
 * activity and to process incoming messages.
 */
class Dispatcher: public red::shared_ptr_counted
{
public:
    /**
     * Create a new Dispatcher object
     *
     * @param max_message_type: indicates the number of unique message types that can
     *                          be handled by this dispatcher. Each message type is
     *                          identified by an integer value between 0 and
     *                          max_message_type-1.
     */
    Dispatcher(uint32_t max_message_type);

    /**
     * Sends a message to the receiving thread. The message type must have been
     * registered first (see register_handler()).  @p payload must be a
     * buffer of the same size as the size registered for @p message_type
     *
     * If the sent message is a message type requires an ACK, this function will
     * block until it receives an ACK from the receiving thread.
     *
     * @param message_type: message type
     * @param payload:      payload
     */
    void send_message(uint32_t message_type, void *payload);

    /**
     * Sends a message to the receiving thread.
     *
     * If the sent message requires an ACK, this function will block until it
     * receives an ACK from the receiving thread.
     *
     * @param handler:      callback to handle message
     * @param[in] payload:  payload
     * @param payload_size: size of payload
     * @param ack:          acknowledge required. Make message synchronous
     */
    void send_message_custom(dispatcher_handle_message handler,
                             void *payload, uint32_t payload_size, bool ack);

    /**
     * Sends a message to the receiving thread.
     *
     * If the sent message requires an ACK, this function will block until it
     * receives an ACK from the receiving thread.
     *
     * @param handler:      callback to handle message
     * @param[in] payload:  payload
     * @param ack:          acknowledge required. Make message synchronous
     */
    template <typename T> inline void
    send_message_custom(void (*handler)(void *, T*), T *payload, bool ack)
    {
        send_message_custom((dispatcher_handle_message) handler,
                            payload, sizeof(*payload), ack);
    }

    /**
     * This function registers a message type with the dispatcher, and registers
     * @p handler as the function that will handle incoming messages of this type.
     * If @p ack is true, the dispatcher will also send an ACK in response to the
     * message after the message has been passed to the handler. You can only
     * register a given message type once. For example, you cannot register two
     * different handlers for the same message type with different @p ack values.
     *
     * @param message_type:   message type
     * @param handler:        message handler
     * @param size:           message size. Each type has a fixed associated size.
     * @param ack:            whether the dispatcher should send an ACK to the sender
     */
    void register_handler(uint32_t message_type,
                          dispatcher_handle_message handler, size_t size,
                          bool ack);

    /**
     * Register a universal handler that will be called when *any* message is
     * received by the dispatcher. When a message is received, this handler will be
     * called first. If the received message type was registered via
     * register_handler(), the message-specific handler will then be
     * called. Only one universal handler can be registered. This feature can be
     * used to record all messages to a file for replay and debugging.
     *
     * @param handler:        a handler function
     */
    void register_universal_handler(dispatcher_handle_any_message handler);

    /**
     * Create a new watch to handle events for the dispatcher.
     * You should release it before releasing the dispatcher.
     *
     * @return newly created watch
     */
    SpiceWatch *create_watch(SpiceCoreInterfaceInternal *core);

    /**
     * This @p opaque pointer is user-defined data that will be passed as the first
     * argument to all handler functions.
     *
     * @param opaque: opaque to use for callbacks
     */
    void set_opaque(void *opaque);

protected:
    virtual ~Dispatcher();

private:
    red::unique_link<DispatcherPrivate> priv;
};

#include "pop-visibility.h"

#endif /* DISPATCHER_H_ */