metaproxy  1.13.0
Public Member Functions | Private Attributes | Friends | List of all members
metaproxy_1::ThreadPoolSocketObserver::Rep Class Reference
Inheritance diagram for metaproxy_1::ThreadPoolSocketObserver::Rep:
Inheritance graph
Collaboration diagram for metaproxy_1::ThreadPoolSocketObserver::Rep:
Collaboration graph

Public Member Functions

 Rep (yazpp_1::ISocketObservable *obs)
 
 ~Rep ()
 

Private Attributes

yazpp_1::ISocketObservable * m_socketObservable
 
Pipe m_pipe
 
boost::thread_group m_thrds
 
boost::mutex m_mutex_input_data
 
boost::condition m_cond_input_data
 
boost::condition m_cond_input_full
 
boost::mutex m_mutex_output_data
 
std::deque< IThreadPoolMsg * > m_input
 
std::deque< IThreadPoolMsg * > m_output
 
bool m_stop_flag
 
unsigned m_no_threads
 
unsigned m_min_threads
 
unsigned m_max_threads
 
unsigned m_waiting_threads
 

Friends

class ThreadPoolSocketObserver
 

Detailed Description

Definition at line 55 of file thread_pool_observer.cpp.

Constructor & Destructor Documentation

ThreadPoolSocketObserver::Rep::Rep ( yazpp_1::ISocketObservable *  obs)

Definition at line 87 of file thread_pool_observer.cpp.

ThreadPoolSocketObserver::Rep::~Rep ( )

Definition at line 92 of file thread_pool_observer.cpp.

93 {
94 }

Friends And Related Function Documentation

friend class ThreadPoolSocketObserver
friend

Definition at line 56 of file thread_pool_observer.cpp.

Member Data Documentation

boost::condition metaproxy_1::ThreadPoolSocketObserver::Rep::m_cond_input_data
private

Definition at line 65 of file thread_pool_observer.cpp.

boost::condition metaproxy_1::ThreadPoolSocketObserver::Rep::m_cond_input_full
private

Definition at line 66 of file thread_pool_observer.cpp.

std::deque<IThreadPoolMsg *> metaproxy_1::ThreadPoolSocketObserver::Rep::m_input
private

Definition at line 68 of file thread_pool_observer.cpp.

unsigned metaproxy_1::ThreadPoolSocketObserver::Rep::m_max_threads
private

Definition at line 76 of file thread_pool_observer.cpp.

unsigned metaproxy_1::ThreadPoolSocketObserver::Rep::m_min_threads
private

Definition at line 75 of file thread_pool_observer.cpp.

boost::mutex metaproxy_1::ThreadPoolSocketObserver::Rep::m_mutex_input_data
private

Definition at line 64 of file thread_pool_observer.cpp.

boost::mutex metaproxy_1::ThreadPoolSocketObserver::Rep::m_mutex_output_data
private

Definition at line 67 of file thread_pool_observer.cpp.

unsigned metaproxy_1::ThreadPoolSocketObserver::Rep::m_no_threads
private

Definition at line 74 of file thread_pool_observer.cpp.

std::deque<IThreadPoolMsg *> metaproxy_1::ThreadPoolSocketObserver::Rep::m_output
private

Definition at line 69 of file thread_pool_observer.cpp.

Pipe metaproxy_1::ThreadPoolSocketObserver::Rep::m_pipe
private

Definition at line 62 of file thread_pool_observer.cpp.

yazpp_1::ISocketObservable* metaproxy_1::ThreadPoolSocketObserver::Rep::m_socketObservable
private

Definition at line 61 of file thread_pool_observer.cpp.

bool metaproxy_1::ThreadPoolSocketObserver::Rep::m_stop_flag
private

Definition at line 70 of file thread_pool_observer.cpp.

boost::thread_group metaproxy_1::ThreadPoolSocketObserver::Rep::m_thrds
private

Definition at line 63 of file thread_pool_observer.cpp.

unsigned metaproxy_1::ThreadPoolSocketObserver::Rep::m_waiting_threads
private

Definition at line 77 of file thread_pool_observer.cpp.


The documentation for this class was generated from the following file: