#ifndef QPID_CLUSTER_CONNECTION_H #define QPID_CLUSTER_CONNECTION_H /* * * 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. * */ #include "types.h" #include "Cluster.h" #include "WriteEstimate.h" #include "OutputInterceptor.h" #include "qpid/broker/Connection.h" #include "qpid/amqp_0_10/Connection.h" #include "qpid/sys/ConnectionInputHandler.h" #include "qpid/sys/ConnectionOutputHandler.h" namespace qpid { namespace framing { class AMQFrame; } namespace cluster { /** * Plug-in associated with broker::Connections, both local and shadow. */ class Connection : public RefCounted, public sys::ConnectionInputHandler, public sys::ConnectionOutputHandler, public framing::AMQP_AllOperations::ClusterConnectionHandler { public: /** Local connection, use this in ConnectionId */ Connection(Cluster&, sys::ConnectionOutputHandler& out, const std::string& id, MemberId); /** Shadow connection */ Connection(Cluster&, sys::ConnectionOutputHandler& out, const std::string& id, ConnectionId); ~Connection(); ConnectionId getId() const { return self; } bool isLocal() const { return self.second == this; } // self-delivery of intercepted extension points. void deliver(framing::AMQFrame& f); void deliverClose(); void deliverDoOutput(size_t requested); void codecDeleted(); Cluster& getCluster() { return cluster; } // ConnectionOutputHandler methods void close() {} void send(framing::AMQFrame&) {} void activateOutput() {} virtual size_t getBuffered() const { assert(0); return 0; } // ConnectionInputHandler methods void received(framing::AMQFrame&); void closed(); bool doOutput(); bool hasOutput() { return connection.hasOutput(); } void idleOut() { idleOut(); } void idleIn() { idleIn(); } // ConnectionInputHandlerFactory sys::ConnectionInputHandler* create(sys::ConnectionOutputHandler* out, const std::string& id, bool isClient); broker::Connection& getBrokerConnection() { return connection; } private: void sendDoOutput(); Cluster& cluster; ConnectionId self; NoOpConnectionOutputHandler discardHandler; WriteEstimate writeEstimate; OutputInterceptor output; broker::Connection connection; }; }} // namespace qpid::cluster #endif /*!QPID_CLUSTER_CONNECTION_H*/