| #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 |