NetworkAdapter.h

Go to the documentation of this file.

/*******************************************************************************
 *
 * Copyright (c) 2008-2010 Michael Schulze <mschulze@ivs.cs.uni-magdeburg.de>
 * All rights reserved.
 *
 *    Redistribution and use in source and binary forms, with or without
 *    modification, are permitted provided that the following conditions
 *    are met:
 *
 *    * Redistributions of source code must retain the above copyright
 *      notice, this list of conditions and the following disclaimer.
 *
 *    * Redistributions in binary form must reproduce the above copyright
 *      notice, this list of conditions and the following disclaimer in
 *      the documentation and/or other materials provided with the
 *      distribution.
 *
 *    * Neither the name of the copyright holders nor the names of
 *      contributors may be used to endorse or promote products derived
 *      from this software without specific prior written permission.
 *
 *
 *    THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
 *    IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 *    TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
 *    PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 *    OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 *    SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 *    LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 *    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 *    THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 *    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 *    OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 *
 * $Id$
 *
 ******************************************************************************/

#ifndef __NetworkAdapter_h__
#define __NetworkAdapter_h__

#include "mw/nl/DistinctNL.h"
#include "mw/el/EventLayer.h"
#include "mw/api/SubscriberEventChannel.h"
#include "mw/gwl/GatewayEventChannel.h"
#include "mw/common/Event.h"

namespace famouso {
    namespace mw {
        namespace nal {

            template < class ANL_A, class ANL_B >
            class NetworkAdapter {
                    typedef NetworkAdapter< ANL_A, ANL_B> this_type;

                    ANL_A  _ANL_A;
                    ANL_B  _ANL_B;
                    famouso::mw::nl::DistinctNL *_bnl;

                protected:

                    struct SNN {
                        typename ANL_A::SNN SNN_A;
                        typename ANL_B::SNN SNN_B;
                    };

                    void init() {
                        _ANL_A.init();
                        _ANL_B.init();
                    }

                public:
                    void publish_to_network_with_id(const SNN &snn, const Event &e, const famouso::mw::nl::DistinctNL *bnl) {
                        if (_ANL_A.id() == bnl)
                            _ANL_A.publish(snn.SNN_A , e);
                        else
                            _ANL_B.publish(snn.SNN_B , e);
                    }

                    const bool event_from_network_with_id(const famouso::mw::nl::DistinctNL *b) const {
                        if ((!_bnl)  || (_bnl == b))
                            return true;
                        else
                            return false;
                    }

                    const famouso::mw::nl::DistinctNL * const get_network_id() const {
                        return _bnl;
                    }

                protected:

                    void announce(const Subject &s, SNN &snn) {
                        _ANL_A.announce(s, snn.SNN_A);
                        _ANL_B.announce(s, snn.SNN_B);
                    }

                    void publish(const SNN &snn, const Event &e) {
                        _ANL_A.publish(snn.SNN_A , e);
                        _ANL_B.publish(snn.SNN_B , e);
                    }

                    void subscribe(const Subject &s, SNN &snn) {
                        _ANL_A.subscribe(s, snn.SNN_A);
                        _ANL_B.subscribe(s, snn.SNN_B);
                    }

                    int8_t fetch(const SNN &snn, Event &e, const famouso::mw::nl::DistinctNL *bnl) {
                        if (_ANL_A.id() == bnl)
                            return _ANL_A.fetch(snn.SNN_A, e, bnl);
                        else
                            return _ANL_B.fetch(snn.SNN_B, e, bnl);
                    }

                    void event_process_request(famouso::mw::nl::DistinctNL * const bnl) {
                        _bnl = bnl;
                        if (_ANL_A.id() == bnl)
                            _ANL_A.event_process_request(bnl);
                        else
                            _ANL_B.event_process_request(bnl);
                    }

                    void event_processed() {
                        if (_ANL_A.id() == _bnl)
                            _ANL_A.event_processed();
                        else
                            _ANL_B.event_processed();
                        _bnl = 0;
                    }
            };
        } // namespace nal
    } // namespace mw
} //namespace famouso

#endif /* __NetworkAdapter_h__ */