L:/channel/channel/include/Binder.h

Go to the documentation of this file.

// Copyright (c) 2005, 2006 Yigong Liu
// Permission to use, copy, modify, distribute and sell this software for any 
//     purpose is hereby granted without fee, provided that the above copyright 
//     notice appear in all copies and that both that copyright notice and this 
//     permission notice appear in supporting documentation.
// The author makes no representations about the 
//     suitability of this software for any purpose. It is provided "as is" 
//     without express or implied warranty.

#ifndef _BINDER_H_
#define _BINDER_H_

//ACE headers
#include "ace/Thread_Mutex.h"
//for ACE_GUARD macros, need the following 2 headers
#include "ace/Synch.h"
#include "ace/OS.h"

#include <map>

#include <BaseDef.h>

namespace channel {

  class ConnInfo;

  template <class IdType, class IdTrait>
    class Filter {
    public:
    virtual bool block_inward (IdType id) {
      ACE_UNUSED_ARG(id);
      return false;
    }
    virtual bool block_outward (IdType id) {
      ACE_UNUSED_ARG(id);
      return false;
    }
  };

  template <class IdType, class IdTrait>
    class Translator {
    public:
    virtual Status translate_inward (IdType &id) { 
      ACE_UNUSED_ARG(id);
      return SUCCESS;
    }
    virtual Status translate_outward (IdType &id) { 
      ACE_UNUSED_ARG(id);
      return SUCCESS;
    }
  };

  template <class IdType, class IdTrait>
    class Binder {
    public:
    typedef Filter<IdType, IdTrait> Filter;
    typedef Translator<IdType, IdTrait> Translator;
    Filter *filter;
    Translator *translator;
    Binder (Filter *f = NULL, Translator *t = NULL) {
      filter = f;
      translator = t;
    }
  };

  template <class IdType, class IdTrait>
  class BinderRegistry {
  private:
    //marshaler registration
    typedef Binder<IdType, IdTrait> Binder;
    std::map<ConnInfo, Binder*> binder_tbl_;
    ACE_Thread_Mutex binder_tbl_lock_;
  public:
    BinderRegistry () {
    }

    Status register_binder(ConnInfo ci, Binder *b)
      {
        ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, binder_tbl_lock_, FAILURE);
        binder_tbl_[ci] = b;
        return SUCCESS;
      }

    Binder * get_binder(ConnInfo ci)
      {
        ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, binder_tbl_lock_, NULL);
        if (binder_tbl_.find(ci) != binder_tbl_.end())
          return binder_tbl_[ci];
        else
          return NULL;
      }
  };

};

#endif

---