stream_service.hpp

Go to the documentation of this file.

//  Copyright (c) 2005-2007 Andre Merzky (andre@merzky.net)
//  Copyright (c) 2005-2008 Hartmut Kaiser
//  Copyright (c) 2007 Ole Weidner (oweidner@cct.lsu.edu)
// 
//  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 SAGA_COMM_STREAM_STREAMSERVICE_HPP
#define SAGA_COMM_STREAM_STREAMSERVICE_HPP

// include stl
#include <string>

// include dependent spec sections
#include <saga/saga/util.hpp>
#include <saga/saga/call.hpp>
#include <saga/saga/base.hpp>
#include <saga/saga/task.hpp>
#include <saga/saga/session.hpp>
#include <saga/saga/detail/monitorable.hpp>
#include <saga/saga/detail/permissions.hpp>

// include package config
#include <saga/saga/packages/stream/config.hpp>

// need stream
#include <saga/saga/stream.hpp>

// suppress warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(push)
#pragma warning(disable: 4251 4231 4660)
#endif

namespace saga
{
  
    namespace stream {

    namespace metrics 
    {
        char const* const server_clientconnect = "server.ClientConnect";
    }
  
    class SAGA_STREAM_PACKAGE_EXPORT server 
        : public saga::object,
          public saga::detail::monitorable<server>,
          public saga::detail::permissions<server>
    {

        friend struct saga::detail::monitorable<server>;  // needs to access get_impl()
        friend struct saga::detail::permissions<server>;
        typedef saga::detail::monitorable<server> monitorable_base_type;

    protected:

        TR1::shared_ptr <saga::impl::server> get_impl (void) const;

    private:
        // stream server methods
        SAGA_CALL_CONST_PRIV_0(get_url)
        SAGA_CALL_PRIV_1(serve, double)
        SAGA_CALL_PRIV_1(close, double)

        void init_metrics();

    public:
        explicit server (session const& s, saga::url url = saga::url());

        explicit server (saga::url url);

        server ();

        explicit server (saga::object const& o);

        ~server (void);

        server &operator= (saga::object const& o);

        saga::url get_url() const 
        {
            saga::task t = get_urlpriv(saga::task_base::Sync()); 
            return t.get_result<saga::url>();
        }
        SAGA_CALL_CONST_PUB_0_DEF_0(get_url)

        
        saga::stream::stream serve(double timeout = 0.0) 
        {
            saga::task t = servepriv(timeout, saga::task_base::Sync()); 
            return t.get_result<saga::stream::stream>();
        }
        SAGA_CALL_PUB_1_DEF_1(serve, double, -1.0)

        
        void close(double timeout = 0.0) 
        {
            closepriv(timeout, saga::task_base::Sync()); 
        }
        SAGA_CALL_PUB_1_DEF_1(close, double, 0.0)
    };
    
}}

// re-enable warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(pop)
#endif

#endif // SAGA_COMM_STREAM_STREAMSERVICE_HPP

---