From 3354535849812a62c00bc568ea9df51cf6153e0d Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 26 Jun 2007 16:39:07 +0000 Subject: * src/qpid/framing/Handler.h: Tempates for handlers and handler chains. * src/qpid/framing/FrameHandler.h: Use Handler.h templates. * src/tests/Handler.cpp: handler chain test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@550846 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/framing/FrameHandler.h | 10 +--- cpp/src/qpid/framing/Handler.h | 98 +++++++++++++++++++++++++++++++++++++ 2 files changed, 100 insertions(+), 8 deletions(-) create mode 100644 cpp/src/qpid/framing/Handler.h (limited to 'cpp/src/qpid/framing') diff --git a/cpp/src/qpid/framing/FrameHandler.h b/cpp/src/qpid/framing/FrameHandler.h index 817c569119..c552fbb9df 100644 --- a/cpp/src/qpid/framing/FrameHandler.h +++ b/cpp/src/qpid/framing/FrameHandler.h @@ -21,18 +21,12 @@ * */ -#include +#include "Handler.h" namespace qpid { namespace framing { class AMQFrame; - -class FrameHandler : private boost::noncopyable { - public: - virtual ~FrameHandler() {} - virtual void handle(AMQFrame& frame) = 0; -}; - +typedef Handler FrameHandler; }} diff --git a/cpp/src/qpid/framing/Handler.h b/cpp/src/qpid/framing/Handler.h new file mode 100644 index 0000000000..05a02a30b1 --- /dev/null +++ b/cpp/src/qpid/framing/Handler.h @@ -0,0 +1,98 @@ +#ifndef QPID_FRAMING_HANDLER_H +#define QPID_FRAMING_HANDLER_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 "qpid/shared_ptr.h" +#include +#include + +namespace qpid { +namespace framing { + +/** Handler for objects of type T. */ +template struct Handler { + typedef T Type; + typedef shared_ptr Ptr; + + virtual ~Handler() {} + virtual void handle(T) = 0; + virtual void link(Ptr next_) { next=next_; } + protected: + void nextHandler(T data) { if (next) next->handle(data); } + private: + Ptr next; +}; + + +/** Factory interface that takes a context of type C */ +template struct HandlerFactory { + virtual ~HandlerFactory() {} + typedef typename Handler::Ptr Ptr; + + /** Create a handler */ + virtual Ptr create(C context) = 0; + + /** Create a handler and link it to next */ + Ptr create(C context, Ptr next) { + Ptr h=create(context); + h->link(next); + } +}; + +/** Factory implementation template */ +template +struct HandlerFactoryImpl : public HandlerFactory { + shared_ptr > create(C context) { + return typename FH::Ptr(new FH(context)); + } +}; + +/** A factory chain is a vector of handler factories used to create + * handler chains. The chain does not own the factories. + */ +template +struct HandlerFactoryChain : public std::vector* > { + typedef typename Handler::Ptr Ptr; + + /** Create a handler chain, return the first handler. + *@param context - passed to each factory. + */ + Ptr create(C context) { + return this->create(context, this->begin()); + } + + private: + typedef typename std::vector*>::iterator iterator; + Ptr create(C context, iterator i) { + if (i != this->end()) { + Ptr h=(*i)->create(context); + h->link(create(context, i+1)); + return h; + } + return Ptr(); + } +}; + +}} + + +#endif /*!QPID_FRAMING_HANDLER_H*/ -- cgit v1.2.1