[Boost-users] Having trouble with boost thread library

From: Fei Liu (fei.liu_at_[hidden])
Date: 2007-08-15 15:57:26

#ifndef UTILS_NETWORK_TCP_CONNECTION_HPP
#define UTILS_NETWORK_TCP_CONNECTION_HPP

namespace utils{
    namespace thread{

        template <typename shared_obj_type, typename thread_pool_type,
            typename serverlet_type>
        class tcp_connection{
        private:
            int newsockfd;
            shared_obj_type obj;
            thread_pool_type pool;
            serverlet_type serverlet;

            bool initialized_;
        public:
            tcp_connection() : initialized_ (false) {}
            tcp_connection(int newsockfd, shared_obj_type obj, 
thread_pool_type pool, serverlet_type serverlet)
                : newsockfd(newsockfd), obj(obj), pool(pool), 
serverlet(serverlet), initialized_(true)
            {
            }
            bool initialized() { return initialized_; }

            bool initialize(int newsockfd, shared_obj_type obj, 
thread_pool_type pool, serverlet_type serverlet);
            void operator ()();
        };

        template <typename shared_obj_type, typename thread_pool_type, 
typename serverlet_type>
        bool tcp_connection<shared_obj_type, thread_pool_type, 
serverlet_type>::initialize
            (int newsockfd, shared_obj_type obj, thread_pool_type pool, 
serverlet_type serverlet)
        {
            this->newsockfd = newsockfd;
            this->obj = obj;
            this->pool = pool;
            this->serverlet = serverlet;
            initialized_ = true;
            return initialized_;
        }

        template <typename shared_obj_type, typename thread_pool_type, 
typename serverlet_type>
        void tcp_connection<shared_obj_type, thread_pool_type, 
serverlet_type>::operator() ()
        {
            //if(initialized_) serverlet_type(newsockfd, obj); <---- 
causes error
            pool->release();
        }
    }
}

#endif
main.cpp: provides definition of serverlet_type
#include "utils/thread/tcp_server.hpp"
#include "utils/thread/thread_pool.h"
#include <boost/shared_ptr.hpp>

#include <vector>
#include <iostream>

typedef std::vector<int> shared_obj_type;
typedef boost::shared_ptr<boost_thread::thread_pool> thread_pool_type;
typedef void (*serverlet_type)(int, shared_obj_type);

void servlet(int sock, shared_obj_type ){
    std::cout << "got a new socket for a new connection: " << sock << 
std::endl;
}

int main(){

    shared_obj_type x;
    thread_pool_type p( new boost_thread::thread_pool(20) );

    utils::thread::tcp_server<shared_obj_type, thread_pool_type, 
serverlet_type> server;
    server.initialize(x, p, servlet, 10000, 5);

    boost::thread s(server);
    s.join();

}

/root/cpp-utils-header-lib/include/utils/thread/tcp_connection.hpp: In 
member function `void utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, serverlet_type>::operator()() [with shared_obj_type = 
shared_obj_type, thread_pool_type = thread_pool_type, serverlet_type = 
void (*)(int, shared_obj_type)]':
/usr/include/boost/function/function_template.hpp:155:   instantiated 
from `static void 
boost::detail::function::void_function_obj_invoker0<FunctionObj, 
R>::invoke(boost::detail::function::function_buffer&) [with FunctionObj 
= utils::thread::tcp_connection<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type)>, R = void]'
/usr/include/boost/function/function_template.hpp:368:   instantiated 
from `void boost::detail::function::basic_vtable0<R, 
Allocator>::init(FunctionObj, boost::detail::function::function_obj_tag) 
[with FunctionObj = utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type)>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:298:   instantiated 
from `void boost::detail::function::basic_vtable0<R, Allocator>::init(F) 
[with F = utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type)>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:277:   instantiated 
from `boost::detail::function::basic_vtable0<R, 
Allocator>::basic_vtable0(F) [with F = 
utils::thread::tcp_connection<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type)>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:655:   instantiated 
from `void boost::function0<R, Allocator>::assign_to(Functor) [with 
Functor = utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type)>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:513:   instantiated 
from `boost::function0<R, Allocator>::function0(Functor, typename 
boost::enable_if_c< boost::type_traits::ice_not< 
boost::is_integral<Functor>::value>::value, int>::type) [with Functor = 
utils::thread::tcp_connection<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type)>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/root/cpp-utils-header-lib/include/utils/thread/tcp_server.hpp:107:   
instantiated from `void utils::thread::tcp_server<shared_obj_type, 
thread_pool_type, serverlet_type, accept_fail_policy>::operator()() 
[with shared_obj_type = shared_obj_type, thread_pool_type = 
thread_pool_type, serverlet_type = void (*)(int, shared_obj_type), 
accept_fail_policy = utils::thread::default_accept_fail_policy]'
/usr/include/boost/function/function_template.hpp:155:   instantiated 
from `static void 
boost::detail::function::void_function_obj_invoker0<FunctionObj, 
R>::invoke(boost::detail::function::function_buffer&) [with FunctionObj 
= utils::thread::tcp_server<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type), utils::thread::default_accept_fail_policy>, R 
= void]'
/usr/include/boost/function/function_template.hpp:368:   instantiated 
from `void boost::detail::function::basic_vtable0<R, 
Allocator>::init(FunctionObj, boost::detail::function::function_obj_tag) 
[with FunctionObj = utils::thread::tcp_server<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type), 
utils::thread::default_accept_fail_policy>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:298:   instantiated 
from `void boost::detail::function::basic_vtable0<R, Allocator>::init(F) 
[with F = utils::thread::tcp_server<shared_obj_type, thread_pool_type, 
void (*)(int, shared_obj_type), 
utils::thread::default_accept_fail_policy>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:277:   instantiated 
from `boost::detail::function::basic_vtable0<R, 
Allocator>::basic_vtable0(F) [with F = 
utils::thread::tcp_server<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type), utils::thread::default_accept_fail_policy>, R 
= void, Allocator = std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:655:   instantiated 
from `void boost::function0<R, Allocator>::assign_to(Functor) [with 
Functor = utils::thread::tcp_server<shared_obj_type, thread_pool_type, 
void (*)(int, shared_obj_type), 
utils::thread::default_accept_fail_policy>, R = void, Allocator = 
std::allocator<boost::function_base>]'
/usr/include/boost/function/function_template.hpp:513:   instantiated 
from `boost::function0<R, Allocator>::function0(Functor, typename 
boost::enable_if_c< boost::type_traits::ice_not< 
boost::is_integral<Functor>::value>::value, int>::type) [with Functor = 
utils::thread::tcp_server<shared_obj_type, thread_pool_type, void 
(*)(int, shared_obj_type), utils::thread::default_accept_fail_policy>, R 
= void, Allocator = std::allocator<boost::function_base>]'
tests/boost_tcp_server_test.cpp:24:   instantiated from here
/root/cpp-utils-header-lib/include/utils/thread/tcp_connection.hpp:61: 
error: functional cast expression list treated as compound expression
/root/cpp-utils-header-lib/include/utils/thread/tcp_connection.hpp:61: 
warning: left-hand operand of comma has no effect
/root/cpp-utils-header-lib/include/utils/thread/tcp_connection.hpp:61: 
error: cannot convert 
`((void)((utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, 
shared_obj_type)>*)this)->utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type)>::newsockfd, 
((utils::thread::tcp_connection<shared_obj_type, thread_pool_type, void 
(*)(int, 
shared_obj_type)>*)this)->utils::thread::tcp_connection<shared_obj_type, 
thread_pool_type, void (*)(int, shared_obj_type)>::obj)' from type 
`shared_obj_type' to type `void (*)(int, shared_obj_type)'