|
version 1.23, 2002/04/12 00:58:21
|
version 1.28, 2002/06/07 00:56:01
|
|
|
|
| //%////-*-c++-*-//////////////////////////////////////////////////////////////// | //%////-*-c++-*-//////////////////////////////////////////////////////////////// |
| // | // |
| // Copyright (c) 2000, 2001 The Open group, BMC Software, Tivoli Systems, IBM |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, |
| |
// The Open Group, Tivoli Systems |
| // | // |
| // Permission is hereby granted, free of charge, to any person obtaining a copy | // Permission is hereby granted, free of charge, to any person obtaining a copy |
| // of this software and associated documentation files (the "Software"), to | // of this software and associated documentation files (the "Software"), to |
|
|
|
| void (*callback)(AsyncOpNode *, MessageQueue *, void *), | void (*callback)(AsyncOpNode *, MessageQueue *, void *), |
| MessageQueue *callback_q, | MessageQueue *callback_q, |
| void *callback_ptr); | void *callback_ptr); |
| |
|
| |
Boolean SendAsync(Message *msg, |
| |
Uint32 destination, |
| |
void (*callback)(Message *response, void *handle, void *parameter), |
| |
void *handle, |
| |
void *parameter); |
| |
|
| |
Uint32 get_pending_callback_count(void); |
| |
|
| Boolean SendForget(Message *msg); | Boolean SendForget(Message *msg); |
| Boolean ForwardOp(AsyncOpNode *, Uint32 destination); | Boolean ForwardOp(AsyncOpNode *, Uint32 destination); |
| | |
|
|
|
| Array<Uint32> *results); | Array<Uint32> *results); |
| void enumerate_service(Uint32 queue, message_module *result); | void enumerate_service(Uint32 queue, message_module *result); |
| Uint32 get_next_xid(void); | Uint32 get_next_xid(void); |
| AsyncOpNode *get_op(void); |
static AsyncOpNode *get_op(void); |
| void return_op(AsyncOpNode *op); | void return_op(AsyncOpNode *op); |
| | |
| |
Boolean operator ==(const MessageQueueService & svce) |
| |
{ |
| |
return operator==((const void *)&svce); |
| |
} |
| |
Boolean operator ==(const void *svce) |
| |
{ |
| |
if((void *)this == svce) |
| |
return true; |
| |
return false; |
| |
} |
| |
|
| |
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *); |
| |
static int kill_idle_threads(void); |
| |
static int pooled_threads(void) |
| |
{ |
| |
return _thread_pool.running_count() + _thread_pool.dead_count() + _thread_pool.pool_count(); |
| |
} |
| |
|
| Uint32 _mask; | Uint32 _mask; |
| AtomicInt _die; | AtomicInt _die; |
| protected: | protected: |
|
|
|
| | |
| private: | private: |
| | |
| DQueue<AsyncOpNode> _pending; |
|
| AsyncDQueue<AsyncOpNode> _incoming; | AsyncDQueue<AsyncOpNode> _incoming; |
| AsyncDQueue<AsyncOpNode> _callback; |
DQueue<AsyncOpNode> _callback; |
| |
static Thread _polling_thread; |
| |
static Semaphore _polling_sem; |
| |
static AtomicInt _stop_polling; |
| |
|
| |
static DQueue<MessageQueueService> _polling_list; |
| | |
| static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *); | static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *); |
| |
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *); |
| |
|
| static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *); | static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *); |
| AtomicInt _incoming_queue_shutdown; | AtomicInt _incoming_queue_shutdown; |
| |
Semaphore _callback_ready; |
| |
|
| Thread _req_thread; | Thread _req_thread; |
| |
Thread _callback_thread; |
| |
protected: |
| |
static ThreadPool _thread_pool; |
| |
private: |
| struct timeval _default_op_timeout; | struct timeval _default_op_timeout; |
| static AtomicInt _xid; | static AtomicInt _xid; |
| friend class cimom; | friend class cimom; |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common