Return to AsyncOpNode.h CVS log | Up to [Pegasus] / pegasus / src / Pegasus / Common |
File: [Pegasus] / pegasus / src / Pegasus / Common / AsyncOpNode.h
(download)
Revision: 1.53, Tue Oct 3 17:16:03 2006 UTC (17 years, 9 months ago) by kumpf Branch: MAIN CVS Tags: TASK_PEP328_SOLARIS_NEVADA_PORT, TASK-TASK-BUG4011_WinLocalConnect-branch-New-root, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_out_to_branch, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_out_from_trunk, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_in_to_trunk, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_in_from_branch, TASK-TASK-BUG4011_WinLocalConnect-branch-New-branch, TASK-PEP328_SOLARIS_NEVADA_PORT_v2-root, TASK-PEP328_SOLARIS_NEVADA_PORT_v2-branch, TASK-PEP328_SOLARIS_NEVADA_PORT-root, TASK-PEP328_SOLARIS_NEVADA_PORT-branch, TASK-PEP328_SOLARIS_IX86_CC_PORT-root, TASK-PEP328_SOLARIS_IX86_CC_PORT-branch-v2, TASK-PEP328_SOLARIS_IX86_CC_PORT-branch, TASK-PEP311_WSMan-root, TASK-PEP311_WSMan-branch, TASK-PEP305_VXWORKS-root, TASK-PEP305_VXWORKS-branch-pre-solaris-port, TASK-PEP305_VXWORKS-branch-post-solaris-port, TASK-PEP305_VXWORKS-branch-beta2, TASK-PEP305_VXWORKS-branch, TASK-PEP305_VXWORKS-2008-10-23, TASK-PEP291_IPV6-root, TASK-PEP291_IPV6-branch, TASK-PEP286_PRIVILEGE_SEPARATION-root, TASK-PEP286_PRIVILEGE_SEPARATION-branch, TASK-PEP274_dacim-root, TASK-PEP274_dacim-merged_out_to_branch, TASK-PEP274_dacim-merged_out_from_trunk, TASK-PEP274_dacim-merged_in_to_trunk, TASK-PEP274_dacim-merged_in_from_branch, TASK-PEP274_dacim-branch, TASK-PEP268_SSLClientCertificatePropagation-root, TASK-PEP268_SSLClientCertificatePropagation-merged_out_to_branch, TASK-PEP268_SSLClientCertificatePropagation-merged_out_from_trunk, TASK-PEP268_SSLClientCertificatePropagation-merged_in_to_trunk, TASK-PEP268_SSLClientCertificatePropagation-merged_in_from_branch, TASK-PEP268_SSLClientCertificatePropagation-branch, TASK-PEP267_SLPReregistrationSupport-root, TASK-PEP267_SLPReregistrationSupport-merging_out_to_branch, TASK-PEP267_SLPReregistrationSupport-merging_out_from_trunk, TASK-PEP267_SLPReregistrationSupport-merged_out_to_branch, TASK-PEP267_SLPReregistrationSupport-merged_out_from_trunk, TASK-PEP267_SLPReregistrationSupport-merged_in_to_trunk, TASK-PEP267_SLPReregistrationSupport-merged_in_from_branch, TASK-PEP267_SLPReregistrationSupport-branch, TASK-Bugs5690_3913_RemoteCMPI-root, TASK-Bugs5690_3913_RemoteCMPI-merged_out_to_branch, TASK-Bugs5690_3913_RemoteCMPI-merged_out_from_trunk, TASK-Bugs5690_3913_RemoteCMPI-merged_in_to_trunk, TASK-Bugs5690_3913_RemoteCMPI-merged_in_from_branch, TASK-Bugs5690_3913_RemoteCMPI-branch, TASK-Bug2102_RCMPIWindows-root, TASK-Bug2102_RCMPIWindows-merged_out_to_branch, TASK-Bug2102_RCMPIWindows-merged_out_from_trunk, TASK-Bug2102_RCMPIWindows-merged_in_to_trunk, TASK-Bug2102_RCMPIWindows-merged_in_from_branch, TASK-Bug2102_RCMPIWindows-branch, TASK-Bug2102Final-root, TASK-Bug2102Final-merged_out_to_branch, TASK-Bug2102Final-merged_out_from_trunk, TASK-Bug2102Final-merged_in_to_trunk, TASK-Bug2102Final-merged_in_from_branch, TASK-Bug2102Final-branch, TASK-Bug2021_RemoteCMPIonWindows-root, TASK-Bug2021_RemoteCMPIonWindows-merged_out_to_branch, TASK-Bug2021_RemoteCMPIonWindows-merged_out_from_trunk, TASK-Bug2021_RemoteCMPIonWindows-merged_in_to_trunk, TASK-Bug2021_RemoteCMPIonWindows-merged_in_from_branch, TASK-Bug2021_RemoteCMPIonWindows-branch, TASK-Bug2021_RCMPIonWindows-root, TASK-Bug2021_RCMPIonWindows-merged_out_to_branch, TASK-Bug2021_RCMPIonWindows-merged_out_from_trunk, TASK-Bug2021_RCMPIonWindows-merged_in_to_trunk, TASK-Bug2021_RCMPIonWindows-merged_in_from_branch, TASK-Bug2021_RCMPIonWindows-branch, TASK-BUG7240-root, TASK-BUG7240-branch, TASK-BUG7146_SqlRepositoryPrototype-root, TASK-BUG7146_SqlRepositoryPrototype-merged_out_to_branch, TASK-BUG7146_SqlRepositoryPrototype-merged_out_from_trunk, TASK-BUG7146_SqlRepositoryPrototype-merged_in_to_trunk, TASK-BUG7146_SqlRepositoryPrototype-merged_in_from_branch, TASK-BUG7146_SqlRepositoryPrototype-branch, TASK-BUG4011_WinLocalConnect-branch-New, RELEASE_2_8_2-RC1, RELEASE_2_8_2, RELEASE_2_8_1-RC1, RELEASE_2_8_1, RELEASE_2_8_0_BETA, RELEASE_2_8_0-RC2, RELEASE_2_8_0-RC1, RELEASE_2_8_0-FC, RELEASE_2_8_0, RELEASE_2_8-root, RELEASE_2_8-branch, RELEASE_2_7_3-RC1, RELEASE_2_7_3, RELEASE_2_7_2-RC1, RELEASE_2_7_2, RELEASE_2_7_1-RC1, RELEASE_2_7_1, RELEASE_2_7_0-RC1, RELEASE_2_7_0-BETA, RELEASE_2_7_0, RELEASE_2_7-root, RELEASE_2_7-branch, RELEASE_2_6_3-RC2, RELEASE_2_6_3-RC1, RELEASE_2_6_3, RELEASE_2_6_2-RC1, RELEASE_2_6_2, RELEASE_2_6_1-RC1, RELEASE_2_6_1, RELEASE_2_6_0-RC1, RELEASE_2_6_0-FC, RELEASE_2_6_0, RELEASE_2_6-root, RELEASE_2_6-branch-clean, RELEASE_2_6-branch, PEP286_PRIVILEGE_SEPARATION_ROOT, PEP286_PRIVILEGE_SEPARATION_CODE_FREEZE, PEP286_PRIVILEGE_SEPARATION_BRANCH, PEP286_PRIVILEGE_SEPARATION_1, Makefile Changes since 1.52: +2 -3 lines BUG#: 5650 TITLE: Cleaning up idle threads uses a thread DESCRIPTION: Clean up idle threads on the current thread rather than launching a new thread for that purpose. |
//%2006//////////////////////////////////////////////////////////////////////// // // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.; // IBM Corp.; EMC Corporation, The Open Group. // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.; // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; // EMC Corporation; VERITAS Software Corporation; The Open Group. // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.; // EMC Corporation; Symantec Corporation; The Open Group. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to // deal in the Software without restriction, including without limitation the // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or // sell copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // //============================================================================== // //%///////////////////////////////////////////////////////////////////////////// #ifndef Pegasus_AsyncOpNode_h #define Pegasus_AsyncOpNode_h #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Linkage.h> #include <Pegasus/Common/Linkable.h> #include <Pegasus/Common/AutoPtr.h> #include <Pegasus/Common/Message.h> #include <Pegasus/Common/MessageQueue.h> #include <Pegasus/Common/Thread.h> PEGASUS_NAMESPACE_BEGIN #define ASYNC_OPFLAGS_UNKNOWN 0x00000000 #define ASYNC_OPFLAGS_NORMAL 0x00000000 #define ASYNC_OPFLAGS_SINGLE 0x00000008 #define ASYNC_OPFLAGS_META_DISPATCHER 0x00000040 #define ASYNC_OPFLAGS_FIRE_AND_FORGET 0x00000080 #define ASYNC_OPFLAGS_SIMPLE_STATUS 0x00000100 #define ASYNC_OPFLAGS_CALLBACK 0x00000200 #define ASYNC_OPFLAGS_PSEUDO_CALLBACK 0x00000400 #define ASYNC_OPFLAGS_SAFE_CALLBACK 0x00000800 #define ASYNC_OPSTATE_UNKNOWN 0x00000000 #define ASYNC_OPSTATE_PROCESSING 0x00000008 #define ASYNC_OPSTATE_COMPLETE 0x00000040 #define ASYNC_OPSTATE_RELEASED 0x00002000 class PEGASUS_COMMON_LINKAGE AsyncOpNode : public Linkable { public: AsyncOpNode(); ~AsyncOpNode(); void setRequest(Message* request); Message* getRequest(); Message* removeRequest(); void setResponse(Message* response); Message* getResponse(); Message* removeResponse(); Uint32 getState(); void lock(); void unlock(); void processing(); void complete(); void release(); private: AsyncOpNode(const AsyncOpNode&); AsyncOpNode& operator=(const AsyncOpNode&); Semaphore _client_sem; Mutex _mut; AutoPtr<Message> _request; AutoPtr<Message> _response; Uint32 _state; Uint32 _flags; Uint32 _completion_code; MessageQueue *_op_dest; void (*_async_callback)(AsyncOpNode *, MessageQueue *, void *); void (*__async_callback)(Message *, void *, void *); // pointers for async callbacks - don't use AsyncOpNode *_callback_node; MessageQueue *_callback_request_q; MessageQueue *_callback_response_q; void *_callback_ptr; void *_callback_parameter; void *_callback_handle; // pointers to help static class message handlers - don't use MessageQueue *_service_ptr; Thread *_thread_ptr; friend class cimom; friend class MessageQueueService; friend class ProviderManagerService; friend class BinaryMessageHandler; }; inline void AsyncOpNode::setRequest(Message* request) { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_request.get() == 0); PEGASUS_ASSERT(request != 0); _request.reset(request); } inline Message* AsyncOpNode::getRequest() { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_request.get() != 0); return _request.get(); } inline Message* AsyncOpNode::removeRequest() { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_request.get() != 0); Message* request = _request.get(); _request.release(); return request; } inline void AsyncOpNode::setResponse(Message* response) { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_response.get() == 0); PEGASUS_ASSERT(response != 0); _response.reset(response); } inline Message* AsyncOpNode::getResponse() { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_response.get() != 0); return _response.get(); } inline Message* AsyncOpNode::removeResponse() { AutoMutex autoMut(_mut); PEGASUS_ASSERT(_response.get() != 0); Message* response = _response.get(); _response.release(); return response; } inline Uint32 AsyncOpNode::getState() { AutoMutex autoMut(_mut); return _state; } inline void AsyncOpNode::lock() { _mut.lock(); } inline void AsyncOpNode::unlock() { _mut.unlock(); } inline void AsyncOpNode::processing() { AutoMutex autoMut(_mut); _state |= ASYNC_OPSTATE_PROCESSING; } inline void AsyncOpNode::complete() { AutoMutex autoMut(_mut); _state |= ASYNC_OPSTATE_COMPLETE; } inline void AsyncOpNode::release() { AutoMutex autoMut(_mut); _state |= ASYNC_OPSTATE_RELEASED; } PEGASUS_NAMESPACE_END #endif //Pegasus_AsyncOpNode_h
No CVS admin address has been configured |
Powered by ViewCVS 0.9.2 |