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

Constructor & Destructor Documentation

◆ Rep()

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

Definition at line 88 of file thread_pool_observer.cpp.

◆ ~Rep()

ThreadPoolSocketObserver::Rep::~Rep ( )

Definition at line 93 of file thread_pool_observer.cpp.

94 {
95 }

Friends And Related Function Documentation

◆ ThreadPoolSocketObserver

friend class ThreadPoolSocketObserver
friend

Definition at line 57 of file thread_pool_observer.cpp.

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.

◆ m_socketObservable

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

Definition at line 62 of file thread_pool_observer.cpp.

◆ 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: