summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys
Commit message (Collapse)AuthorAgeFilesLines
* Implement process id and name methods for WindowsStephen D. Huston2009-02-241-8/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747577 13f79535-47bb-0310-9956-ffa450edef68
* Fixed issue with producer flow control in a cluster.Alan Conway2009-02-241-1/+1
| | | | | | | | | | | | | | | | | | Producer flow control uses a Timer and other clock-based calculations to send flow control commands. These commands are not predictably ordered from the clusters point of view. Added getClusterOrderProxy() to SessionState. In a cluster it returns a proxy that defers sending a command to the client until it is multicast to the cluster. In a stand alone broker it is just the normal proxy. Updated producer flow control to use this proxy. Cluster flow control is turned off in shadow connections. Only the directly connected node does flow control calculations and multicasts the commands to send. All nodes sending of the commands thru SessionState to ensure consistent session state (e.g. command numbering.) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747528 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1676 - Added client process name and pid to connection object for ↵Ted Ross2009-02-243-0/+48
| | | | | | | | | | management. Supported in C++, Python, and Ruby clients. Still needs to be added to the Java clients. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747389 13f79535-47bb-0310-9956-ffa450edef68
* Merged win-pollable-condition branch changes 743545:746056 into trunkStephen D. Huston2009-02-205-93/+307
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@746061 13f79535-47bb-0310-9956-ffa450edef68
* Fix race condition with read-credit.Alan Conway2009-02-114-3/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743416 13f79535-47bb-0310-9956-ffa450edef68
* Fix compile breakage with different versions of librdma_cmAndrew Stitcher2009-01-271-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@738273 13f79535-47bb-0310-9956-ffa450edef68
* Producer side rate throttling:Andrew Stitcher2009-01-271-1/+13
| | | | | | | | | This uses the Message.Flow command to send credit from broker to client to ensure that the client doesn't exceed a rate configured on the broker per session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@738247 13f79535-47bb-0310-9956-ffa450edef68
* cluster: Add sequence number to events & framesAlan Conway2009-01-271-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737968 13f79535-47bb-0310-9956-ffa450edef68
* Some minor updates to logging levels to avoid undue alarm.Gordon Sim2009-01-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737679 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-221-2/+2
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736783 13f79535-47bb-0310-9956-ffa450edef68
* More latency metrics.Alan Conway2009-01-222-1/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736752 13f79535-47bb-0310-9956-ffa450edef68
* correct lifecycle for pollablequeue dispatch handleCarl C. Trieloff2009-01-211-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736398 13f79535-47bb-0310-9956-ffa450edef68
* Additional latency measurement points.Alan Conway2009-01-212-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736326 13f79535-47bb-0310-9956-ffa450edef68
* Latency measurements, compiled out of production code.Alan Conway2009-01-202-0/+151
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736135 13f79535-47bb-0310-9956-ffa450edef68
* Move dispatcher code from iocpDispatcher.cpp (no longer needed) to ↵Stephen D. Huston2009-01-132-57/+15
| | | | | | IocpPoller.cpp (run); mirrors migration introduced on Linux side git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734265 13f79535-47bb-0310-9956-ffa450edef68
* Small tidy upAndrew Stitcher2009-01-131-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734218 13f79535-47bb-0310-9956-ffa450edef68
* Created new Timer code in qpid::sysAndrew Stitcher2009-01-132-0/+229
| | | | | | | | | - Necessary for a timer accessible to the client code - The interface is slightly different from the existing Timer code in an attempt to fix some issues with it git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734216 13f79535-47bb-0310-9956-ffa450edef68
* Adding missing includeStephen D. Huston2009-01-121-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733967 13f79535-47bb-0310-9956-ffa450edef68
* Add support for AsynchIO::RequestCallback processingStephen D. Huston2009-01-124-11/+65
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733966 13f79535-47bb-0310-9956-ffa450edef68
* Allow any remaining events in PollableQueue to be processed after Poller ↵Gordon Sim2009-01-121-4/+22
| | | | | | | | | threads return from poll loop. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733881 13f79535-47bb-0310-9956-ffa450edef68
* Tidied up a number of TODO itemsAndrew Stitcher2009-01-084-9/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732620 13f79535-47bb-0310-9956-ffa450edef68
* Adapt to recent changes/additionsStephen D. Huston2009-01-071-8/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732551 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1560: add support for a qpid.exclusive-binding option on direct ↵Gordon Sim2009-01-071-0/+12
| | | | | | exchange that causes the binding specified to be the only one for the given key. I.e. if there is already a binding at this exchange with this key it will be atomically updated to bind the new queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732297 13f79535-47bb-0310-9956-ffa450edef68
* Work on the low level IO code:Andrew Stitcher2009-01-0610-60/+269
| | | | | | | | | * Introduce code so that you can interrupt waiting for a handle and receive a callback that is correctly serialised with the IO callbacks for that handle git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732177 13f79535-47bb-0310-9956-ffa450edef68
* Added missing include file for ::memcpyTed Ross2009-01-061-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732093 13f79535-47bb-0310-9956-ffa450edef68
* * Cyrus SASL intgeration for c++ clientGordon Sim2009-01-067-31/+299
| | | | | | | | * SASL security layer support for c++ client and broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732082 13f79535-47bb-0310-9956-ffa450edef68
* Log changes: logging default now notice+, "listening on" messages are at ↵Alan Conway2009-01-053-3/+3
| | | | | | notice level. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731649 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1412 - c++ implementation of the QMF client APITed Ross2008-12-192-0/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@728132 13f79535-47bb-0310-9956-ffa450edef68
* Revert accidental commit.Alan Conway2008-12-171-9/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727447 13f79535-47bb-0310-9956-ffa450edef68
* Default --cluster-read-max to 0.Alan Conway2008-12-171-11/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727444 13f79535-47bb-0310-9956-ffa450edef68
* Added missing ASF licenseGordon Sim2008-12-151-0/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@726684 13f79535-47bb-0310-9956-ffa450edef68
* sys/PollableQueue: dispatch in batches, allow put-back.Alan Conway2008-12-111-19/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725802 13f79535-47bb-0310-9956-ffa450edef68
* Add startReading() method required by sys::AsynchIO. Fixes QPID-1525.Stephen D. Huston2008-12-101-60/+56
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725486 13f79535-47bb-0310-9956-ffa450edef68
* Better output.Alan Conway2008-12-101-25/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724937 13f79535-47bb-0310-9956-ffa450edef68
* Fixes for 64bit.Alan Conway2008-12-091-2/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724927 13f79535-47bb-0310-9956-ffa450edef68
* Added dummy read throttling code to RDMA protocol support soAndrew Stitcher2008-12-081-0/+5
| | | | | | | it will carry on compiling git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724409 13f79535-47bb-0310-9956-ffa450edef68
* OutputControl and subclasses: added giveReadCredit() for IO level flow control.Alan Conway2008-12-0810-10/+63
| | | | | | | Cluster: Set read credit limit for cluster connections. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724233 13f79535-47bb-0310-9956-ffa450edef68
* src/qpid/sys/ActivityTimer.h: record time spent in specific code segments, ↵Alan Conway2008-12-071-0/+111
| | | | | | for profiling/debugging. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724169 13f79535-47bb-0310-9956-ffa450edef68
* PollableQueue: fix unsafe use of dequeAlan Conway2008-12-021-4/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722622 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: handle CPG flow-control conditions.Alan Conway2008-12-021-11/+19
| | | | | | | PollableQueue: allow dispatch functions to refuse dispatch. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722614 13f79535-47bb-0310-9956-ffa450edef68
* Was causing cluster failures.Alan Conway2008-11-261-0/+2
| | | | | | | QPID-1488 Mick Goulish: QueuePolicy serialization fix for cluster braindump. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720979 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1489: Tidy epoll code to remove a valgrind warning on 32bit Linux:Andrew Stitcher2008-11-261-23/+27
| | | | | | | | - We weren't initialising all 64 bits of a union that was being passed to epoll_ctl on 32 bit Linuxes git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720978 13f79535-47bb-0310-9956-ffa450edef68
* Cluster.cpp: Fixed last-node-standing logic, better logging.Alan Conway2008-11-261-2/+2
| | | | | | | Shlib.cpp: added file name to errors messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720924 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1474: Changed lock scope for PollerHandle::~PollerHandleAndrew Stitcher2008-11-191-0/+5
| | | | | | | Also check state better to make sure the impl can't be deleted more than once in a race git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718966 13f79535-47bb-0310-9956-ffa450edef68
* Fix --cluster-cman option to enable cman integration.Alan Conway2008-11-191-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718961 13f79535-47bb-0310-9956-ffa450edef68
* Remove optimistic consume options. Better default message for SSL errors.Alan Conway2008-11-171-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718277 13f79535-47bb-0310-9956-ffa450edef68
* Fix problem where broker generates empty URL if run on a host with only the ↵Alan Conway2008-11-121-3/+5
| | | | | | 127.0.0.1 loopback interface. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713405 13f79535-47bb-0310-9956-ffa450edef68
* Correct returned value on successful parseStephen D. Huston2008-11-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713201 13f79535-47bb-0310-9956-ffa450edef68
* handle case where doOutput call causes last task to be removed.Gordon Sim2008-11-111-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713114 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1438: Before registering the rdma daemon transport plugin checkAndrew Stitcher2008-11-075-5/+19
| | | | | | | whether there are any rdma devices - if not don't register git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712182 13f79535-47bb-0310-9956-ffa450edef68