proton-c/bindings/cpp/src/include/reactor.hpp

#ifndef REACTOR_HPP
#define REACTOR_HPP

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.
 */

/// @cond INTERNAL
/// XXX remove

#include "proton/internal/object.hpp"
#include "proton/duration.hpp"
#include "proton/timestamp.hpp"

struct pn_reactor_t;
struct pn_handler_t;
struct pn_io_t;

namespace proton {

class connection;
class container;
class acceptor;
class url;
class messaging_handler;
class task;

class reactor : public internal::object<pn_reactor_t> {
  public:
    reactor(pn_reactor_t* r = 0) : internal::object<pn_reactor_t>(r) {}

    /** Create a new reactor. */
    static reactor create();

    /** Open a connection to url and create a receiver with source=url.path() */
    acceptor listen(const proton::url &);

    /** Run the event loop, return when all connections and acceptors are closed. */
    void run();

    /** Start the reactor, you must call process() to process events */
    void start();

    /** Process events, return true if there are more events to process. */
    bool process();

    /** Stop the reactor, causes run() to return and process() to return false. */
    void stop();

    /// Identifier for the container
    std::string id() const;

    /// Get timeout, process() will return if there is no activity within the timeout.
    duration timeout();

    /// Set timeout, process() will return if there is no activity within the timeout.
    void timeout(duration timeout);

    timestamp mark();
    timestamp now();

    task schedule(int, pn_handler_t*);

    class connection connection(pn_handler_t*) const;

    class connection connection_to_host(const std::string &host, const std::string &port, pn_handler_t*) const;

    pn_handler_t* pn_handler() const;

    void pn_handler(pn_handler_t* );

    pn_handler_t* pn_global_handler() const;

    void pn_global_handler(pn_handler_t* );

    pn_io_t* pn_io() const;

    void wakeup();
    bool quiesced();
    void yield();

  friend class container_impl;
  friend class container_context;
  friend class internal::factory<reactor>;
};

}

/// @endcond

#endif // REACTOR_HPP