proton-c/bindings/cpp/include/proton/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/object.hpp"
#include "proton/duration.hpp"

struct pn_reactor_t;
struct pn_io_t;

namespace proton {

class connection;
class container;
class acceptor;
class url;
class handler;
class task;

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

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

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

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

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

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

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

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

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

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

    PN_CPP_EXTERN amqp_timestamp mark();
    PN_CPP_EXTERN amqp_timestamp now();

    PN_CPP_EXTERN task schedule(int, pn_handler_t*);

    class connection connection(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;

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

  friend class container_impl;
  friend class container_context;
};

}

/// @endcond

#endif // REACTOR_HPP