router.h

Go to the documentation of this file.

//    sampalib.org ESL library and tools
//    Copyright (C) 2007  Thierry Grellier
//
//    This program is free software; you can redistribute it and/or modify
//    it under the terms of the GNU General Public License version 2 as
//    published by the Free Software Foundation.
//
//    This program is distributed in the hope that it will be useful,
//    but WITHOUT ANY WARRANTY; without even the implied warranty of
//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//    GNU General Public License for more details.
//
//    You should have received a copy of the GNU General Public License along
//    with this program; if not, write to the Free Software Foundation, Inc.,
//    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
//    contact: www.sampalib.org

#ifndef SAMPA_ROUTER_H
#define SAMPA_ROUTER_H

#include "sampa/component/protocol.h"
#include "sampa/core/gated.h"
#include "sampa/core/sarray.h"
#include "sampa/core/fifo.h"

namespace Sampa {

  class Router : public Module, public TargetRequestInterface, public InitiatorResponseInterface {
    SAMPA_MODULE(Router);
  public:
    Router(const Name&);

    void bind_clock(Clock*);
    void bind_initiator(Initiator*);
    Target* get_target() { return &p_target; }
    void bind_target(Target*);
    Initiator* get_initiator(const std::string&);

    const char* get_target_name() const;    
    bool recieve_request(const Request& request);
    bool recieve_response(const Response& response);
    
    class Destination : public Initiator {
      SAMPA_PERSISTENT(Destination);
    public:
      Destination(const Name&);
      bool accept_address(const Address& address) const;
    private:
      HexParameter    m_start_address;
      Address         m_end_address;
    };
    
  private:
    void complete_restart();
    int  decode(const Address&);
    int  check(int);
    void push();
    void sync_route();
    void route();

    Target                 p_target;
    SizeParameter          m_num_destination;
    int                    m_bound;
    Array<Destination>     m_destinations;
    Fifo                   m_fifo;
    Gated<Request>         m_request;
    Array<Request>         m_requests;
    Array<int>             m_decoded;
    EventListenerSingle    e_push;
    ClockedEventSingle     e_sync_route;
    EventSingle            e_route;
    int                    m_num_pending;
    int                    m_num_responses;
    int                    m_destination;
    bool                   m_pending_routing;
    bool                   m_blocked_on_response;
    bool                   m_pushing;
  };


}

#endif

---