00001 /* *\ 00002 ** Copyright (C) 2009-2010 ** 00003 ** Dominik Charousset < Dominik.Charousset (at) haw-hamburg.de > ** 00004 ** ** 00005 ** MMM MMMMMM MMMMMMMMM MMMMMMM MMM MMM ** 00006 ** MMMMM MMMMMMMM MMMMMMMMM MMMMMMMM MMM MMMMM ** 00007 ** MMM MMM MMM MMMM MMM MMM MMM MMM MMM ** 00008 ** MMM MMM MMM MMMMMMMMM MMM MMM MMM MMM MMM ** 00009 ** MMMMMMMMMMM MMMM MMM MMMM MMM MMM MMM MMMMMMMMMMM ** 00010 ** MMM MMM MMMMMMMM MMMMMMMMM MMMMMMMM MMM MMM MMM ** 00011 ** MMM MMM MMMMMM MMMMMMMMM MMMMMMM MMM MMM MMM ** 00012 ** ** 00013 ** ** 00014 ** This file is part of the acedia library. ** 00015 ** ** 00016 ** This library is free software: you can redistribute it and/or modify ** 00017 ** it under the terms of the GNU Lesser General Public License as published ** 00018 ** by the Free Software Foundation, either version 3 of the License, or ** 00019 ** (at your option) any later version. ** 00020 ** ** 00021 ** This library is distributed in the hope that it will be useful, ** 00022 ** but WITHOUT ANY WARRANTY; without even the implied warranty of ** 00023 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the ** 00024 ** GNU Lesser General Public License for more details. ** 00025 ** ** 00026 ** You should have received a copy of the GNU Lesser General Public License ** 00027 ** along with acedia. If not, see <http://www.gnu.org/licenses/>. ** 00028 \* */ 00029 00030 #ifndef ACEDIA_INVOKING_MESSAGE_PROCESSOR_H 00031 #define ACEDIA_INVOKING_MESSAGE_PROCESSOR_H 00032 00033 #include <list> 00034 00035 #include "rulebuilder.hpp" 00036 #include "tuple.hpp" 00037 #include "message.hpp" 00038 00039 namespace acedia 00040 { 00041 00042 class Invoker 00043 { 00044 00045 friend class Actor; 00046 00047 std::list<details::AnyArrayProcessor *> m_processors; 00048 // last checked message 00049 Message m_lcm; 00050 00051 Invoker &prepend(details::AnyArrayProcessor *proc); 00052 void pop_front(); 00053 void pop_back(); 00054 00055 public: 00056 00057 Invoker(); 00058 00065 Invoker(details::AnyArrayProcessor *proc); 00066 00067 ~Invoker(); 00068 00069 Invoker &add(details::AnyArrayProcessor *proc); 00070 00075 bool operator()(const Message &msg, bool trapExit); 00076 00082 details::ContinuationInvoker *matchingInvokerTo(Message msg, bool trapExit); 00083 00084 }; 00085 00086 } // namespace acedia 00087 00088 #endif // ACEDIA_INVOKING_MESSAGE_PROCESSOR_H
1.6.2