metaproxy 1.22.4
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 56 of file thread_pool_observer.cpp.

Constructor & Destructor Documentation

◆ Rep()

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

◆ ~Rep()

ThreadPoolSocketObserver::Rep::~Rep ( )

Definition at line 93 of file thread_pool_observer.cpp.

94{
95}

◆ ThreadPoolSocketObserver

friend class ThreadPoolSocketObserver
friend

Definition at line 57 of file thread_pool_observer.cpp.

References ThreadPoolSocketObserver.

Referenced by ThreadPoolSocketObserver.

Member Data Documentation

◆ m_cond_input_data

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

Definition at line 66 of file thread_pool_observer.cpp.

◆ m_cond_input_full

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

Definition at line 67 of file thread_pool_observer.cpp.

◆ m_input

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

Definition at line 69 of file thread_pool_observer.cpp.

◆ m_max_threads

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

Definition at line 77 of file thread_pool_observer.cpp.

◆ m_min_threads

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

Definition at line 76 of file thread_pool_observer.cpp.

◆ m_mutex_input_data

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

Definition at line 65 of file thread_pool_observer.cpp.

◆ m_mutex_output_data

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

Definition at line 68 of file thread_pool_observer.cpp.

◆ m_no_threads

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

Definition at line 75 of file thread_pool_observer.cpp.

◆ m_output

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

Definition at line 70 of file thread_pool_observer.cpp.

◆ m_pipe

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

Definition at line 63 of file thread_pool_observer.cpp.

Referenced by Rep().

◆ m_socketObservable

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

Definition at line 62 of file thread_pool_observer.cpp.

Referenced by Rep().

◆ m_stop_flag

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

Definition at line 71 of file thread_pool_observer.cpp.

◆ m_thrds

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

Definition at line 64 of file thread_pool_observer.cpp.

◆ m_waiting_threads

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

Definition at line 78 of file thread_pool_observer.cpp.


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