|
[PATCH 28/50] [mama] Minor Header Adjustments
From: Mike Schonberg <mschonberg@...>
Moved #includes outside of #extern "C" in types.h to avoid issues on Windows
where standard headers may contain C++ templates.
Include port.h from
From: Mike Schonberg <mschonberg@...>
Moved #includes outside of #extern "C" in types.h to avoid issues on Windows
where standard headers may contain C++ templates.
Include port.h from
|
By
Michael Schonberg <mschonberg@...>
·
#137
·
|
|
[PATCH 27/50] [mama] Log Messages with MAMA_MSG_STATUS_UNKNOWN
From: Mike Schonberg <mschonberg@...>
On receiving a message with a status of MAMA_MSG_STATUS_UNKNOWN, log the message
if at FINEST and track it update the statistics for the transport, queue
From: Mike Schonberg <mschonberg@...>
On receiving a message with a status of MAMA_MSG_STATUS_UNKNOWN, log the message
if at FINEST and track it update the statistics for the transport, queue
|
By
Michael Schonberg <mschonberg@...>
·
#136
·
|
|
[PATCH 26/50] [mama] Do not modify attached messages
From: Mike Schonberg <mschonberg@...>
For some middlewares with "zero-copy" semantics like shared memory or RDMA, applications share message payloads. Others may re-use buffers. In these cases,
From: Mike Schonberg <mschonberg@...>
For some middlewares with "zero-copy" semantics like shared memory or RDMA, applications share message payloads. Others may re-use buffers. In these cases,
|
By
Michael Schonberg <mschonberg@...>
·
#161
·
|
|
[PATCH 25/50] [mama] Add closure to mamaQueue
From: Mike Schonberg <mschonberg@...>
Added a closure to mamaQueue to allow applcations to store queue specific
context.
The new methods are:
mamaQueue_setClosure()
From: Mike Schonberg <mschonberg@...>
Added a closure to mamaQueue to allow applcations to store queue specific
context.
The new methods are:
mamaQueue_setClosure()
|
By
Michael Schonberg <mschonberg@...>
·
#135
·
|
|
[PATCH 24/50] [mama] mama.c cleanup
From: Mike Schonberg <mschonberg@...>
Moved MAMA_PAYLOAD_MAX from mama.c to mamainternal.h.
Removed uncessary comments and conditionally compiled debug blocks.
Moved #includes out extern "C"
From: Mike Schonberg <mschonberg@...>
Moved MAMA_PAYLOAD_MAX from mama.c to mamainternal.h.
Removed uncessary comments and conditionally compiled debug blocks.
Moved #includes out extern "C"
|
By
Michael Schonberg <mschonberg@...>
·
#134
·
|
|
[PATCH 23/50] [mama] Cleaup Statistics Handling in mama_close
From: Mike Schonberg <mschonberg@...>
Properly cleanup the StatsGenerator, StatsCollector and StatsPublisher to avoid
resource leaks.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
From: Mike Schonberg <mschonberg@...>
Properly cleanup the StatsGenerator, StatsCollector and StatsPublisher to avoid
resource leaks.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
|
By
Michael Schonberg <mschonberg@...>
·
#133
·
|
|
[PATCH 22/50] [mama] Change static mutexes to be recursive
From: Mike Schonberg <mschonberg@...>
This change avoids rare instances of deadlock when starting, stoping, opening
and closing OpenMAMA.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
From: Mike Schonberg <mschonberg@...>
This change avoids rare instances of deadlock when starting, stoping, opening
and closing OpenMAMA.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
|
By
Michael Schonberg <mschonberg@...>
·
#132
·
|
|
[PATCH 21/50] [mama] mamaTransport_forceClientDisconnect
From: Mike Schonberg <mschonberg@...>
Add method to MAMA API that allows connection based middlewares (TCP) to
disconnect poorly behaved clients.
Signed-off-by: Mike Schonberg
From: Mike Schonberg <mschonberg@...>
Add method to MAMA API that allows connection based middlewares (TCP) to
disconnect poorly behaved clients.
Signed-off-by: Mike Schonberg
|
By
Michael Schonberg <mschonberg@...>
·
#131
·
|
|
[PATCH 20/50] [mama] transport write queue high and low watermarks
From: Mike Schonberg <mschonberg@...>
Allow applications to set high and low watermarks for internal write queues if
the underlying middleware queues writes. Socket based middlewares that
From: Mike Schonberg <mschonberg@...>
Allow applications to set high and low watermarks for internal write queues if
the underlying middleware queues writes. Socket based middlewares that
|
By
Michael Schonberg <mschonberg@...>
·
#130
·
|
|
[PATCH 19/50] [mama] Create an Internal Transport for Monitoring
From: Mike Schonberg <mschonberg@...>
OpenMAMA creates a dedicated internal transport for publishing statistics for
monitoring and other internal communication. This transport disables
From: Mike Schonberg <mschonberg@...>
OpenMAMA creates a dedicated internal transport for publishing statistics for
monitoring and other internal communication. This transport disables
|
By
Michael Schonberg <mschonberg@...>
·
#129
·
|
|
[PATCH 18/50] [mama] Subscription: don't put invalid actions on the throttle queue
From: Mike Schonberg <mschonberg@...>
Added code to avoid race conditions when enqueing shutdown logic on the
throttle.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
From: Mike Schonberg <mschonberg@...>
Added code to avoid race conditions when enqueing shutdown logic on the
throttle.
Signed-off-by: Mike Schonberg <mschonberg@...>
---
|
By
Michael Schonberg <mschonberg@...>
·
#128
·
|
|
[PATCH 17/50] [mama] Configurable Schemes for data quality
From: Mike Schonberg <mschonberg@...>
The dqStratgyScheme deterines whether or not OpenMAMA ignores duplicate
messages. Valid values are:
DQ_SCHEME_DELIVER_ALL deliver all messages including
From: Mike Schonberg <mschonberg@...>
The dqStratgyScheme deterines whether or not OpenMAMA ignores duplicate
messages. Valid values are:
DQ_SCHEME_DELIVER_ALL deliver all messages including
|
By
Michael Schonberg <mschonberg@...>
·
#127
·
|
|
[PATCH 16/50] [mama] dqpublisher destroy
From: Mike Schonberg <mschonberg@...>
Added proper destroy implementation for dqpublisher to allow applications to
clean up and shutdown properly.
Signed-off-by: Mike Schonberg
From: Mike Schonberg <mschonberg@...>
Added proper destroy implementation for dqpublisher to allow applications to
clean up and shutdown properly.
Signed-off-by: Mike Schonberg
|
By
Michael Schonberg <mschonberg@...>
·
#126
·
|
|
[PATCH 15/50] [mama] dqpublisher manager bug fixes
From: Mike Schonberg <mschonberg@...>
Only invoke the application on create callback if it is not NULL. This avoids
core dumps if the application does not provide a callback.
The manager was not
From: Mike Schonberg <mschonberg@...>
Only invoke the application on create callback if it is not NULL. This avoids
core dumps if the application does not provide a callback.
The manager was not
|
By
Michael Schonberg <mschonberg@...>
·
#125
·
|
|
[PATCH 14/50] [mama] Add cache and closure to dqpublisher
From: Mike Schonberg <mschonberg@...>
These are both application supplied callbacks. The closure is intended for
application specific context for the publisher and the cache is for caching
data
From: Mike Schonberg <mschonberg@...>
These are both application supplied callbacks. The closure is intended for
application specific context for the publisher and the cache is for caching
data
|
By
Michael Schonberg <mschonberg@...>
·
#124
·
|
|
[PATCH 13/50] [mama] mamaDQPublisher_sendReplyWithHandle
From: Mike Schonberg <mschonberg@...>
This method allows applications to use a reply handle rather than detaching and
holding on to the original message. Since OpenMAMA attempts to reuse
From: Mike Schonberg <mschonberg@...>
This method allows applications to use a reply handle rather than detaching and
holding on to the original message. Since OpenMAMA attempts to reuse
|
By
Michael Schonberg <mschonberg@...>
·
#123
·
|
|
[PATCH 12/50] [mama][dqpublisher] Improved Message Handling
From: Mike Schonberg <mschonberg@...>
Since the caller may pass messages with the reserved files (ie. senderid,
seqno, etc.) populated, the dq publisher should try to be robust and update
From: Mike Schonberg <mschonberg@...>
Since the caller may pass messages with the reserved files (ie. senderid,
seqno, etc.) populated, the dq publisher should try to be robust and update
|
By
Michael Schonberg <mschonberg@...>
·
#122
·
|
|
[PATCH 11/50] [mama] minor datetime fixes
From: Mike Schonberg <mschonberg@...>
When formatting a date time with a time, separate the date and time with a
space.
Added parameter checking to makeTime to handle invalid values sanely: set
From: Mike Schonberg <mschonberg@...>
When formatting a date time with a time, separate the date and time with a
space.
Added parameter checking to makeTime to handle invalid values sanely: set
|
By
Michael Schonberg <mschonberg@...>
·
#121
·
|
|
[PATCH 10/50] [mama] Free CM Subscription in Destroy Callback
From: Mike Schonberg <mschonberg@...>
The CM subscription can not be freed until it destruction completes and invokes
the onDestroy() callback. This avoids potential core dumps on
From: Mike Schonberg <mschonberg@...>
The CM subscription can not be freed until it destruction completes and invokes
the onDestroy() callback. This avoids potential core dumps on
|
By
Michael Schonberg <mschonberg@...>
·
#120
·
|
|
[PATCH 09/50] [bridge] Added mamaTransport_forceClientDisconnect()
From: Mike Schonberg <mschonberg@...>
For TCP socket based middleware, allow transports to disconnect individual
clients. This is usefull for eliminating slow consumers or other applications
that
From: Mike Schonberg <mschonberg@...>
For TCP socket based middleware, allow transports to disconnect individual
clients. This is usefull for eliminating slow consumers or other applications
that
|
By
Michael Schonberg <mschonberg@...>
·
#119
·
|