C:/Development/boost_sandbox/rpc/boost/rpc/registry.hpp

// Copyright Stjepan Rajko 2007. Use, modification and
// distribution is subject to the Boost Software License, Version
// 1.0. (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)

#ifndef BOOST_RPC_REGISTRY_HPP
#define BOOST_RPC_REGISTRY_HPP

#include <boost/ptr_container/ptr_map.hpp>
#include <boost/call_traits.hpp>
#include <boost/rpc/function.hpp>
#include <boost/rpc/marshaled.hpp>

namespace boost {
namespace rpc {


template<typename Id, typename ArchivePair = binary_archive>
class registry
{
public:
    typedef Id id_type;
    typedef ArchivePair archive_type;


    template<typename Signature>
    void set(Id id, const boost::function<Signature> &f)
    {
       reg.insert(id, new marshaled<Signature>(f));
    }


    void operator()(const std::string &id_and_params, const call_options &options,
        std::string *result = NULL)
    {
        // prepare input archive to extract id and parameters
        std::stringstream p_stream(id_and_params, std::ios::in | std::ios::out | std::ios::binary);
        typename archive_type::iarchive_type p_archive(p_stream);
       
        id_type id;
        p_archive & id;
     
        // make the call
        if (options.marshal_option >= call_options::return_only)
        {
            BOOST_ASSERT(result);
            std::stringstream r_stream(std::ios::in | std::ios::out | std::ios::binary);
                typename archive_type::oarchive_type r_archive(r_stream);
            reg[id].call(options, p_archive, &r_archive);
            *result = r_stream.str();
        }
        else
            reg[id].call(options, p_archive, NULL);
    }
private:
    boost::ptr_map<Id, detail::function<ArchivePair> > reg;
};

} // namespace rpc
} // namespace boost

#endif // BOOST_RPC_REGISTRY_HPP

---