CVS log for pegasus/src/Pegasus/Common/MessageQueueService.cpp
	Help

Request diff between arbitrary revisions

PEP#: 348
TITLE: Merge head into branch.

DESCRIPTION: Merge head into branch.

BUG#: 8602
TITLE: AsyncIoClose message handling should wait for all service threads to terminate
DESCRIPTION: Wait until all service threads to terminate while handling the AsyncIoClose message for each service

BUG#: 8482
TITLE: SendWait() and SendForget() methods of MessageQueueService can be static
DESCRIPTION: Made SendWait() and SendForget() methods static

BUG#: 8483
TITLE: remove confusing  and unused _async variable from MessageQueue class
DESCRIPTION: removed the _async variable from MessageQueue class

BUG#: 8474
TITLE: CimomMessages cleanup
DESCRIPTION: removed unused variables and messages.

BUG#: 8444
TITLE: Remove the MessageQueue::getNextQueueId() parameter from the MessageQueue class construction.
DESCRIPTION: Removed queueId from the MessageQueue constructor,response queue id from the AsyncRequest constructor and the destination queueid from the AsyncReply constructor.

BUG#: 8293
TITLE: remove unnecessary MessageQueueService::_sendwait_callback
DESCRIPTION:

BUG#: 8292
TITLE: remove unused variables from AsyncOpNode class
DESCRIPTION:

BUG#: 8196
TITLE: Segmentation fault in cimservermain on shutdown
DESCRIPTION: Do not attempt to communicate from the ProviderManagerService to the IndicationService after shutdown has commenced.

BUG#: 8273
TITLE: Remove trailing space characters
DESCRIPTION: Remove meaningless whitespace.

BUG#: 8252
TITLE: metadispatcher thread may crash while monitoring the dead service
DESCRIPTION: created service registration with metadispatcher so that metadispatcher routes messages to services only if their registration is valid.

BUG#: 8249
TITLE: Segmentation fault in TestMessageQueueService
DESCRIPTION: Fixed race condition between polling thread and thread executing the MessageQueueService destructor

BUG#: 8234
TITLE: TestMessageQueueService and TestAsyncCallback hang intermittently
DESCRIPTION: added Mutex protection for serialization in MessageQueueService constructor/destructor

BUG#: 8197
TITLE: cimserver cored at polling_routine in MessageQueueService
DESCRIPTION: removed lock on polling list

BUG#: 8123
TITLE: Update copyright/license text

DESCRIPTION:

Fixing trailing spaces in copyright/license text

BUG#: 8123
TITLE: Update Coyright/License text

DESCRIPTION:

Adding the new copyright/license text to almost all files

BUG#: 8093
TITLE: AsyncIoctl cleanup.
DESCRIPTION: cleanup unnecessasary properties and incorrect logic handling the services IO close.

BUG#: 8069
TITLE: MessageQueue::messageOK() is not required.
DESCRIPTION: removed MessageQueue::messageOK() method.

BUG#: 8067
TITLE: remove unused async_results types
DESCRIPTION: removed unused result types.

BUG#: 8039
TITLE: message dispatcher routines takes unnecessary parameters
DESCRIPTION: removed unnecessary parameters

BUG#: 8033
TITLE: remove unnecessary module_capabilities
DESCRIPTION: removed module_capabilities from Cimom.h and _mask variable from MessageQueueService class.

PEP#: 305
TITLE: VxWorks Port

DESCRIPTION: Ongoing VxWorks porting

BUG#: 8002
TITLE: message dispatch optimization in Metadispatcher
DESCRIPTION: removed unnecessary locks on processing AsyncOpNode and cleaned up AsyncOpNode class and message dispatcher routines.

BUG#: 7995
TITLE: Metadispatcher & MessageQueueService cleanup
DESCRIPTION: Removed unused functionality

PEP#: 305
TITLE:VxWorks port

DESCRIPTION: Add code to allow limiting size of thread pool.  This
fixes issue with binaryMessageHandler and limited thread pool size.

PEP#: 305
TITLE: VxWorks Port

DESCRIPTION: Ongoing VxWorks porting

PEP#: 305
TITLE: VxWorks Port

DESCRIPTION: Ongoing VxWorks porting

BUG#: 7916
TITLE: Eliminate ListClosed exception
DESCRIPTION: Update AsyncQueue to user return values instead of exceptions to indicate the queue is closed.  Replace the use of AsyncQueue with simpler constructs where appropriate.

BUG#: 7904
TITLE: remove unused _legacy_destination variable from AsyncLegacyOperationStart class.
DESCRIPTION:

BUG#: 7912
TITLE: WaitFailed exception should include diagnostic information
DESCRIPTION: Throw an Exception on locking primitive failures instead of the WaitFailed IPCException.

BUG#: 7854
TITLE: PEP# 316 - Replace PEG_TRACE_STRING with PEG_TRACE

DESCRIPTION: Replace PEG_TRACE_STRING with PEG_TRACE

BUG#: 7844
TITLE: Permission exception is not needed
DESCRIPTION: Remove the Permission exception and its usage.  Replace with assertions where appropriate.

PEP#: 328
TITLE: Sun port. Update to new branch for test

DESCRIPTION: Update to new branch for port test with current code

BUG#: 7838
TITLE: AsyncQueue does not need a maximum capacity
DESCRIPTION: Remove the ListFull exception and associated logic.

PEP#: 328
TITLE: Solaris Porting

DESCRIPTION: Ongoing Solaris Porting

BUG#: 7769
TITLE: doxygen warnings in C++ interfaces
DESCRIPTION: Resolve doxygen warnings in the API documentation.

BUG#:7749
TITLE: Trace Level checking (everything, but Pegasus/Server)

DESCRIPTION:

BUG#:7651
TITLE: PEP#315 - Improve Trc&Log - Fix TBD-7646

DESCRIPTION:

BUG#:7645
TITLE: PEP#315 - Improve Trc&Log - Remove Logger::TRACE

DESCRIPTION:

BUG#: 7409
TITLE: Memory leak in Thread::run
DESCRIPTION: Remove unnecessary calls to Thread::exit_self and use an automatic variable to clean up dynamic memory used by Thread::run.

BUG#: 7157
TITLE: Message::_async member should be private
DESCRIPTION: Use accessors to access the Message::_async member.

BUG#: 6682
TITLE: Use MessageType enum instead of Uint32 for message types
DESCRIPTION: Use the strongly-typed MessageType enum for all message type variables.

BUG#:6300
TITLE: Performance - simplify internal Tracer interface and use the more efficent Trace macros (2.6)

DESCRIPTION:

BUG#:6207
TITLE: Performance - make OpenPegasus use its more efficent Trace macros

DESCRIPTION:

BUG#: 5840
TITLE: Common modules do not meet chksrc requirements
DESCRIPTION: Remove tab characters and author names and shorten lines that are wider than 80 characters.

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.

BUG#: 5551
TITLE: MessageQueueService declares friend class CIMServer
DESCRIPTION: Remove the friend relationship.

BUG#: 5461
TITLE: Clean up message_mask class
DESCRIPTION: Renamed message_mask to MessageMask, and removed unused members.

BUG#: 5441
TITLE: MessageQueueService should not call STAT_COPYDISPATCHER
DESCRIPTION: Remove the STAT_COPYDISPATCHER macro.

BUG#: 5429
TITLE: Use auto class for provider statistics measurement
DESCRIPTION: Clean up the provider performance statistics code in the Default and CMPI provider managers.

BUG#: 5398
TITLE: Clean up Windows compile warnings
DESCRIPTION: Minor fixes that resolve compile warnings.

BUG#: 5314
TITLE: IPC Refactoring

DESCRIPTION: This patch cleans up the IPC related classes. It (1) reorganizes
related classes into their own headers, (2) makes the mutex class recursive to
eliminate recursive lock exclusion logic, (3) reimplements condition variables,
renames dozens of global functions.

BUG#: 5314
TITLE: IPC Refactoring

DESCRIPTION: Branch work.

BUG#: 5314
TITLE: IPC Refactoring

DESCRIPTION: IPC Refactoring Branch Work

BUG#: 5293
TITLE: Remove unused definitions from AsyncOpNode
DESCRIPTION: Clean up the AsyncOpNode class to remove unused members and methods.  Change the _request and _response members to be single pointers instead of Lists.

BUG#: 5269
TITLE: Message _routing_code does not appear to be used
DESCRIPTION: Remove the _routing_code member from the Message class and all references to it.

BUG#: 4709
TITLE: Message class has unused _key member
DESCRIPTION: Remove the _key member from the Message class.

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

BUG#: 5191
TITLE: Queue Consolidation
DESCRIPTION: Fix an abort failure when destructing a List of MessageQueueService objects.

BUG#: 5191
TITLE: Queue Consolidation

DESCRIPTION: Queue Consolidation Branch Work

PEP#: 233
TITLE: Updated Embedded Instance Support branch

DESCRIPTION:

- Merged with latest code from 2.5.1

- Modified ObjectNormalizer to use a CIMOMHandle instead of the repository and to normalize the instances in an embedded instance property.

BUG#: 4691
TITLE: Update Licenses to 2006

DESCRIPTION: Updates most of the licenses to 2006. The slp_client directories are excluded for the moment pending discussion. This change has passed unit and system tests.  Note that this changes just about EVERY file in Pegasus.

PEP#: 233
TITLE: Embedded Instance Support

DESCRIPTION:

Extend pegasus functionality to natively support Embedded Instance properties and parameters as specified in PEP 233. The support will be enabled with the standard build, but can be disabled by defining the environment variable PEGASUS_DISABLE_EMBEDDED_INSTANCES.

BUG#: 4250
TITLE: AtomicInt Performance

DESCRIPTION: This fix provides a faster AtomicInt implementation for select platforms.

BUG#: 4250
TITLE: AtomicInt Performance

DESCRIPTION: Changed usage of AtomicInt::value() to AtomicInt::get().

BUG#: 4250
TITLE: New AtomicInt implementation.

DESCRIPTION: Implementation for LINUX_IA64_GNU.

BUG#: 4245
TITLE: MessageQueueService.cpp does not define MAX_THREADS_PER_SVC_QUEUE
DESCRIPTION: Use the default value for MAX_THREADS_PER_SVC_QUEUE if it is not defined in the build environment.

BUG#: 4145
TITLE: Failure on cimserver shutdown
DESCRIPTION: Dynamically instantiate the objects used by the MessageQueueService::polling_routine instead of using statically instantiated objects to avoid a memory error on cimserver shutdown.

BUG#:4126
TITLE: On shutdown, cimom::routing_proc loops attempting to send message

DESCRIPTION: Rather than loop indefinitely, modified the code to throw away the response if the message cannot be sent because the incoming queue for the target sevice has already shutdown.

BUG#: 4103
TITLE: Timing window in MessageQueue Service - Could cause cimserver failure

DESCRIPTION: Moved responsibility for incrementing the _threads counter from the created thread (i.e., the _req_proc thread) to the thread doing the creating (i.e., the polling routine thread). This is the 2.4 version of the changes that were submitted to 2.5 (see Bugzilla 4074 for details).

BUG#: 4074
TITLE: Timing window in MessageQueue Service - Could cause cimserver failure

DESCRIPTION: Moved responsibility for incrementing the _threads counter from the created thread (i.e., the _req_proc thread) to the thread doing the creating (i.e., the polling routine thread).

BUG#: 3958
TITLE: cimserver crashs after many indications delivered

DESCRIPTION: Merge 2.5 fixes into 2.4 branch.  See Bug 3958 for details.

BUG#: 4004
TITLE: cimserver crash in MessageQueueService after running for more than 5 hours

DESCRIPTION: Merge 2.5 fixes into 2.4 branch.  See Bug 4004 for details.

BUG#: 4059
TITLE: MessageQueueService trace message could cause cimserver crash

DESCRIPTION: Changed %s to %d in trace message.

BUG#: 3888

TITLE: Thread limit needs to be set.

DESCRIPTION: Set MAX_THREADS_PER_SVC_QUEUE default value to 5.

BUG#: 972
TITLE: Thread::run errors are not handled

DESCRIPTION:

BUG#: 3635
TITLE: ~MessageQueueService finishes while _req_proc is still

DESCRIPTION:
Adding a try / catch for the permisson exception.

BUG#: 3072

TITLE: cimserver crashs after many indications delivered

DESCRIPTION: remove include of iostream.h

BUG#: 3072

TITLE: cimserver crashs after many indications delivered

DESCRIPTION:
    - added logic to limit the number of threads per service queue to a value
    controlled by the build config variable PEGASUS_MAX_THREADS_PER_SVC_QUEUE

BUG#: 3635
TITLE: ~MessageQueueService finishes while _req_proc is still processing requests

DESCRIPTION:
Adding a catch for ListClosed exception. This can happend when the queue has been shut down.

BUG#: 3635
TITLE: ~MessageQueueService finishes while _req_proc is still processing requests

DESCRIPTION:

BUG#: 3625
TITLE: ~MessageQueueService finishes while _req_proc is still processing requests

DESCRIPTION:

BUG#: 3582
TITLE: MQS _callback thread, list , and semaphore are deprecated

DESCRIPTION:

BUG#: 3555
TITLE: async_callback test case is not enabled in unit test. Legacy message passing with callback is not working

DESCRIPTION:

BUG#: 3520
TITLE: Unused Thread member in MessageQueueService
DESCRIPTION: Removed the unused _req_thread member.  Also took the opportunity to do some formatting cleanup.

BUG#: 3501
TITLE: Throws without catches cause server process to go down
DESCRIPTION: Added DiscardedData trace messages where exceptions are caught in thread top-level functions.

BUG#: 2544
TITLE: polling_routine immediately exits after first time run
DESCRIPTION: Reset the _stop_polling variable to 0 when the meta-dispatcher is initialized.

BUG#: 3164

TITLE:Crash on Linux IPF in Message::endServer

DESCRIPTION: checking t fix

BUG#: 3259
TITLE: polling_routine immediately exits after first time run

DESCRIPTION: Fixed as proposed

BUG#: 3055
TITLE: Reverting changes made for bug 3055

DESCRIPTION: Bug 3055 was considered invalid and the chages were reverted, returning to prior state.

BUG#: 2239
TITLE: ThreadPool Test Failure
DESCRIPTION: Numerous fixes to the ThreadPool class and unit test to fix an intermittent problem with a missed thread in the ThreadPool destructor.  Includes general cleanup of the ThreadPool implementation.

BUG#: 3090
TITLE: MessageQueueService::force_shutdown - unreachable code warning on OpenVMS.

DESCRIPTION: Remove routine. No longer needed.

BUG#: 3090
TITLE: MessageQueueService::force_shutdown - unreachable code warning on OpenVMS

DESCRIPTION: #ifdef the code for OS_VMS to clear the warning and fix the build. Marking bug as a blocker until the right solution is found.

BUG#: 3055
TITLE: WBEM core file found when a SIGTERM signal 15 was sent to the cimserver process.

DESCRIPTION: DESCRIPTION: Modifications in MessageQueueService.cpp in order to catch the WaitInterrupted exception.

BUG#: 3004
TITLE: Obsolete code in ThreadPool
DESCRIPTION: Removed the ThreadPool deadlock_time member and constructor parameter.

BUG#: 2766
TITLE:   Rename compile flag PEGASUS_ARCHITECTURE_IA64 to PEGASUS_POINTER_64BIT

DESCRIPTION: Port of bug 2686 to 2.4.

BUG#: 2686
TITLE:  Rename compile flag PEGASUS_ARCHITECTURE_IA64 to PEGASUS_POINTER_64BIT

DESCRIPTION: Renamed PEGASUS_ARCHITECTURE_64BIT to PEGASUS_POINTER_64BIT.

BUG#: 2657
TITLE: CIMServer -s does not want to exit.

DESCRIPTION: Fixed as suggested by Konrad.

BUG#: 2686
TITLE:  Rename compile flag PEGASUS_ARCHITECTURE_IA64 to PEGASUS_ARCHITECTURE_64BIT

DESCRIPTION: Renamed the compile flag and fixed compiler warnings.

BUG#: 2656
TITLE: License statement update to 2005

DESCRIPTION: All .h, .cpp and the wql, cql, compile *.l and *.y files along
with the .java files in providermanager2/jmpi updated to use the license
statement in doc/license.txt
Tested on windows and visual test of all diffs.

BUG#:2230
TITLE: TestClient Failure running Nightly Tests
DESCRIPTION:

This a day one bug that got exacerbated by PEP140/phase2 changes.
The hang was because not all the message responses got to the
resequencer in Server/CIMOperationRequestDispatcher.cpp , in
which case it never sent out the completion flag to the
client indicating the chunks are complete (hence the client
waits until timeout).

The culprit is MessageQueueService::_req_proc in
MessageQueueService.cpp. It does not loop on all queued
AsyncOpNodes queued by cimom::_routing_proc. It is possible that
many messages may get queued before the semaphore signal can
be processed (which is _req_proc). Objects like
CIM_ManagedSystemElement can cause many threads and evokes
the problem sporadically (CPU usage and number of CPUs play
a role in whether it failed or not)

PEP#: 140
TITLE: HTTP chunked transfer encoding support/phase 2
DESCRIPTION: see title

BUG#: 2196
TITLE: Copyright update

DESCRIPTION: Update all .cpp and .h files for new license and
update the doc/license.txt file.  Note that there were also
a couple of files that had to be fixed because they had violated
the comments rules (ex. blank line at head of file or in the case of
xmlwriter.cpp a comment line //=========  which drove the strip
function nuts.  These were fixed.  This has been compiled and tested
on windows.

BUG#: 1090
TITLE: Mutex's May Not Be Unlocked Resulting in Hang
DESCRIPTION:  Updated files to use AutoMutex.

PEP#: 072
TITLE: [HP-RK] Out-of-Process Provider Support

DESCRIPTION: Remove an unnecessary unload_idle_providers() function declaration in MessageQueueService.cpp.

HP-WO HTTPConnection must return 413 response on oversized requests (Bugzilla 89)

HP-[DME] Bugzilla 994 - Modify polling_routine to use ThreadPool for kill_idle_thread proc.

HP-RK Bugzilla 962 (Missing logic to handle system thread limit).

tuning branch

PEP 55 Update license on source files to current license text and date

HP-[DME] Commit for Bugzilla 832 - Remove debug statements (couts) from MessageQueueService.cpp.

Bugzilla 592: Pointer being compared to a 'bool'

bugzilla 662 - ShutdownService should send a CLOSE message, disable MessageQueueService::force_shutdown

bugzilla 662 - added synchronization object to MessageQueueService::get_next_xid()

bugzilla 662 - remove console messages

bugzilla 662 - pegasus/src/Pegasus/Common changes

HP-[DME] Commit for Bugzilla 583 - placed DEBUG flags around couts.

IBM:HR:BUG459

merge with 2.3 localized code

IBM-KR: Bug #399. In the 2.3 branch

IBM-KR: Errate to the previous check-in. The patch mangled up the file.

IBM-KR: Bug #399 MessageQueueService fails to shut down queues durring shutdown fixed

IBM-KR: Bug #340, #405 in 2.2 release

IBM-KR: Bug #340, 05. Memory leak during deinitializing of MessageQueueService

IBM:HR,PEP58,r2.3:Globalization Changes - Common

ProviderManager & Provider Merge - Interim

merged src/Pegasus/Common/ directory

merged mday-2-0-patches into pegasus/src/Pegasus/Server directory

fixed shutdown leak in message queue service

fixed shutdown message leak

IBM-CC: Bug 172, throw WaitFailed in Semaphore::wait()

HP-RK Fix memory leak.

restored thread pool cleanup to previous algorithm

merged production changes with stable

merged with STABLE branch

merged IBM production fixes into TOG CVS

HP-RK API Review: Restructured exceptions to move internal exceptions to an InternalExceptions module.  Combined definitions of overlapping CIMClientExceptions and Exceptions.  Removed unused exception definitions.  This is just the first step in cleaning up the exceptions from a developer API perspective.

fixed segfault when running subscription tests

HP-RK Fix the abort-on-exit problem that was caused by the polling thread using already-destructed objects in the case that the MessageQueueService destructor is not called (because of C++ semantics on exit()).

fixed hang in MQS when application exits without destroying MQS

fixed a bug in HTTPAcceptor that would cause the cimserver to stop processing incoming tcp data

fixed typo that caused bug in thread pool kill_dead_threads routine

Monitor rewritten to integrate IP state information in one place

changes to Monitor.cpp to make the connection entries thread-safe. Unsafe windows was exposed most frequently on preemptive OS's with multiple processors but could occur on any pegasus platform

fixed exception handling and destructor bug in Thread.cpp and Monitor.cpp related to thread pool management

fixed bug that deleted static thread pools when cimserver run as a daemon

HP-RK Fix Copyright statement.

thread reduction changes

diagnostic variable for provider manager

HP-RK Update license header.

 removed redundant join in destructor

*** empty log message ***

 fixed module controller sendasync methods

 fixes and tests for module controller functionality

HP-RK Add hack to work around problem with HTTPConnections.  Basic problem is that HTTPConnection objects are getting deleted while threads are still trying to access them.  A memory error results.  The fix is to put a reference count on the HTTPConnection object.  It gets incremented just before a thread is launched to run in the HTTPConnection.  It gets decremented with the thread finishes running.  The HTTPAcceptor spins until the reference count is 0 before deleting the HTTPConnection object.

HP-RK Set _meta_dispatcher pointer to 0 after it is deleted.

 removed slow code

*** empty log message ***

*** empty log message ***

 bugs fixed in message system, new async call added that performs all memory management, speed enhancements and leak protection added

*** empty log message ***

 fixed bugs in messaging system

 added suballocator to dq classes

DME: Add additional trace code.

 ModuleController fleshed out

*** empty log message ***

*** empty log message ***

SendAsync now the low level routine that SendWait uses. Also allowed creation of an AsyncDQueue with unlimited capacity. Fixed a race condition that possibly interferes with service queue destruction.

 async callback test written and misc. optimizations to meta dispatcher. Async callback messages work great.

*** empty log message ***

 send async added, callback handling, ForwardOp added

*** empty log message ***

*** empty log message ***

Add more trace code.

fixes and hacks in usage of asynchronous queues within cimoprequestdispatcher

fixed bug that caused segv when deleted HTTP connection

 lots of changes to support mixing of legacy and async messages in queues

fixed problem with MessageQueueService::_enqueueResponse handling of legacy messages

fixed bug in _enqueueResponse

 tested SendForget, fixed bugs in metadispatcher

 finished async callback code and optimized dispatcher routing code

added some async callback capability in meta dispatcher

*** empty log message ***

additional metadispatcher interfaces

meta dispatcher in and running testclient to completion

 fixed termination bug in messagequeueservice

MessageQueueService integration

 legacy operations support

tested support of service pause, service resume

Added PEGASUS_USING_STD to fix compile error on Windows

*** empty log message ***

*** empty log message ***

*** empty log message ***

*** empty log message ***

*** empty log message ***

*** empty log message ***

fixed hellacious bug in asyncopnode

*** empty log message ***

*** empty log message ***

*** empty log message ***

meta dispatcher added to common