summaryrefslogtreecommitdiff
path: root/qpid
Commit message (Collapse)AuthorAgeFilesLines
* fixed the error in receivingRajith Muditha Attapattu2007-12-031-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600599 13f79535-47bb-0310-9956-ffa450edef68
* Updated ofr converting request text in upercase textArnaud Simon2007-12-033-67/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600561 13f79535-47bb-0310-9956-ffa450edef68
* merged the three writes in a single oneArnaud Simon2007-12-031-10/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600501 13f79535-47bb-0310-9956-ffa450edef68
* Added Session.h to list of distributed headers.Gordon Sim2007-12-031-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600442 13f79535-47bb-0310-9956-ffa450edef68
* Fix problem where client does notice disconnection from Broker. Alan Conway2007-12-016-65/+115
| | | | | | | | | src/qpid/client/SessionCore.cpp: close/open Demux on suspend/resume. src/tests/exception_test.cpp: convert to Session API, boost test. - Temporarily disabled due issues noted in TODO comments git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600046 13f79535-47bb-0310-9956-ffa450edef68
* Default --worker-threads is max(2, cores), performs better on 1 core boxes.Alan Conway2007-11-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599887 13f79535-47bb-0310-9956-ffa450edef68
* Python examplesAlan Conway2007-11-3010-0/+782
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599876 13f79535-47bb-0310-9956-ffa450edef68
* added latency testsArnaud Simon2007-11-301-8/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599868 13f79535-47bb-0310-9956-ffa450edef68
* Added a very basic plain nio transport. You could flip between the ↵Rajith Muditha Attapattu2007-11-306-5/+246
| | | | | | | | | transports using -Dtransport="nio". By default it's the MINA transport. You can also turn on batching for the nio transport by using -Dbatch="true". This option has no effect on MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599856 13f79535-47bb-0310-9956-ffa450edef68
* Altered topic test to use the new session api.Gordon Sim2007-11-305-70/+95
| | | | | | | | Exposed start() through the subscription manager in addition to run(). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599832 13f79535-47bb-0310-9956-ffa450edef68
* added latency testsArnaud Simon2007-11-302-0/+231
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599810 13f79535-47bb-0310-9956-ffa450edef68
* added interval rateArnaud Simon2007-11-303-32/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599725 13f79535-47bb-0310-9956-ffa450edef68
* Printing summary before closing session, as this sometimes results in an errorRajith Muditha Attapattu2007-11-291-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599637 13f79535-47bb-0310-9956-ffa450edef68
* Modified the scriptsRajith Muditha Attapattu2007-11-293-3/+5
| | | | | | | And made the default log frequency to every 1000 msgs git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599624 13f79535-47bb-0310-9956-ffa450edef68
* Removed all the fancy threading with the test cases as these interfer with ↵Rajith Muditha Attapattu2007-11-297-559/+154
| | | | | | the test cases git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599611 13f79535-47bb-0310-9956-ffa450edef68
* Rolled back changes from rev 598440, the _real_ cause of the St9exception ↵Kim van der Riet2007-11-291-25/+22
| | | | | | error has been solved (elsewhere) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599592 13f79535-47bb-0310-9956-ffa450edef68
* Cleaned up the calculations and added an option to disable interval stat ↵Rajith Muditha Attapattu2007-11-292-102/+164
| | | | | | collection git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599528 13f79535-47bb-0310-9956-ffa450edef68
* Temp hack to fix as yet unclear issue with concurrent flush() and ↵Gordon Sim2007-11-291-1/+1
| | | | | | enqueueComplete() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599495 13f79535-47bb-0310-9956-ffa450edef68
* added flushArnaud Simon2007-11-291-0/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599452 13f79535-47bb-0310-9956-ffa450edef68
* added interval thoughput calculationArnaud Simon2007-11-291-12/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599424 13f79535-47bb-0310-9956-ffa450edef68
* Further missing fileGordon Sim2007-11-291-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599422 13f79535-47bb-0310-9956-ffa450edef68
* Fixed wrong file added in last commitGordon Sim2007-11-291-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599413 13f79535-47bb-0310-9956-ffa450edef68
* Added extra file to posix sourcesGordon Sim2007-11-291-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599412 13f79535-47bb-0310-9956-ffa450edef68
* added interval thoughput calculationArnaud Simon2007-11-291-6/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599403 13f79535-47bb-0310-9956-ffa450edef68
* Changes to threading: queues serialiser removed, io threads used to drive ↵Gordon Sim2007-11-2930-435/+631
| | | | | | | | | | dispatch to consumers Fix to PersistableMessage: use correct lock when accessing synclist, don't hold enqueue lock when notifying queues git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599395 13f79535-47bb-0310-9956-ffa450edef68
* - Eliminated a race condition on deletion of PollerHandlesAndrew Stitcher2007-11-294-5/+162
| | | | | | | | * Added DeletionManager class to delete handles * Used to stop PollerHandles being deleted whilst still in use git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599390 13f79535-47bb-0310-9956-ffa450edef68
* Setting the message to null to mark for garbage collectionRajith Muditha Attapattu2007-11-293-4/+8
| | | | | | | | noAck still has to clear our internal command ids. increased the default max prefetch to 1000 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599255 13f79535-47bb-0310-9956-ffa450edef68
* Enabled the broker module again, and Commented out the offending class that ↵Rajith Muditha Attapattu2007-11-293-36/+43
| | | | | | had compilation errors due missing classes from the new mina version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599216 13f79535-47bb-0310-9956-ffa450edef68
* src/tests/perfdist: Remove useless output.Alan Conway2007-11-281-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599203 13f79535-47bb-0310-9956-ffa450edef68
* Modified the code to not keep the command in the map if ↵Rajith Muditha Attapattu2007-11-281-17/+13
| | | | | | | | | | | | | | | | "enable_command_replay" is false. However we still need to keep the command_id to implement sync properly. By default "enable_command_replay" is false. The earlier implementation completely avoided incrementing the command count and putting it in the map. This causes a problem as it will break the contract for sync. When the client code calls sync we need to only return when the broker has sent the EM that is at or above that command_id. So we need to keep that around. Keeping track of command_ids is different from keeping commands around. We keep commands around for reply, but we need to keep track of command_id's to implement the execution layer properly. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599144 13f79535-47bb-0310-9956-ffa450edef68
* Add unit_test.h to distribution.Alan Conway2007-11-284-27/+29
| | | | | | | Updated/removed sundry FIXME comments. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599128 13f79535-47bb-0310-9956-ffa450edef68
* Added header file to list of sourcesGordon Sim2007-11-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599124 13f79535-47bb-0310-9956-ffa450edef68
* Added the -DuseQueue option to switch between pub/sub and p2p.Rajith Muditha Attapattu2007-11-283-2/+5
| | | | | | | If useQueue is present then we use p2p. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599117 13f79535-47bb-0310-9956-ffa450edef68
* Changed the MINA version to 1.1.5.Rajith Muditha Attapattu2007-11-282-6/+8
| | | | | | | | Now the Broker module does not compile as it seem to depend on an obselete package. So I haev commented the broker module in the build. We can move the broker code to work with the new MINA version during the f2f. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599116 13f79535-47bb-0310-9956-ffa450edef68
* Fix exception handling bug.Alan Conway2007-11-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599103 13f79535-47bb-0310-9956-ffa450edef68
* Fixed to build with boost 1.34 as well as boost 1.33Alan Conway2007-11-2826-83/+265
| | | | | | | | - boost::ptr_map API changed. - Boost.Test unit test framework changes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599067 13f79535-47bb-0310-9956-ffa450edef68
* src/tests/perfdist: Restore trace option, still used by some tests.Alan Conway2007-11-281-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599047 13f79535-47bb-0310-9956-ffa450edef68
* added enable_replay optionArnaud Simon2007-11-281-4/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599030 13f79535-47bb-0310-9956-ffa450edef68
* src/tests/perfdist: Updated for changes to perftest.Alan Conway2007-11-281-18/+42
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599028 13f79535-47bb-0310-9956-ffa450edef68
* src/tests/perftest.cpp:Alan Conway2007-11-282-17/+43
| | | | | | | | - Added help text explaining multi-process use. - Fixed bug in multi-process mode, too many threads were started. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599025 13f79535-47bb-0310-9956-ffa450edef68
* Disable recoding of frames for replay where replay will not be required.Gordon Sim2007-11-285-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598992 13f79535-47bb-0310-9956-ffa450edef68
* Removed obsolete commentAndrew Stitcher2007-11-281-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598939 13f79535-47bb-0310-9956-ffa450edef68
* Fixed test in line with changes made to defaults.Gordon Sim2007-11-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598924 13f79535-47bb-0310-9956-ffa450edef68
* perftest improvements.Alan Conway2007-11-279-241/+441
| | | | | | | | | | | | | | | | | | | | | | NOTE: options have changed, see perftest --help. - Supports multiple publishers. - Subscribers set credit to receive exactly the expected no. of messages. - All transfers unconfirmed by default. client/Connector.cpp: Added connector ID to RECV/SENT logging client/Completion.h: Added default ctor. broker/Broker.cpp: --ack defaults to 0 - session acks disabled. client/SessionCore.cpp: Ignore surplus frames in CLOSING state. log/Options.cpp: By default log to stdout instead of stderr. Easier to grep. framing/AMQContentBody.h: Log message content even in NDEBUG mode. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598770 13f79535-47bb-0310-9956-ffa450edef68
* Added the JVM switch -DnoAck to disable the sending the semantic ackRajith Muditha Attapattu2007-11-271-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598719 13f79535-47bb-0310-9956-ffa450edef68
* added a jvm switch called -DnoAck to disable the semantic ack, the current ↵Rajith Muditha Attapattu2007-11-271-2/+1
| | | | | | solution used a Qpid specific NO_ACK method in the extended session. However if people are using a pure JMS API then they have no way of taking use of this feature, therefore I added this jvm switch git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598717 13f79535-47bb-0310-9956-ffa450edef68
* new fileArnaud Simon2007-11-271-0/+95
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598684 13f79535-47bb-0310-9956-ffa450edef68
* optimized message creationArnaud Simon2007-11-271-5/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598559 13f79535-47bb-0310-9956-ffa450edef68
* optimized message creationArnaud Simon2007-11-271-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598556 13f79535-47bb-0310-9956-ffa450edef68
* Switched all regular PersistentMessage* and PersistentMessage& to ↵Kim van der Riet2007-11-2611-58/+76
| | | | | | intrusive_ptr<PersistentMessage>, so as to hook into the refcount for a message while it is in the store. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598440 13f79535-47bb-0310-9956-ffa450edef68