summaryrefslogtreecommitdiffstats
path: root/messagebus
Commit message (Collapse)AuthorAgeFilesLines
* - Sample the time before message is created.Henning Baldersheim2017-01-111-3/+4
| | | | | - Use the same clock as is used by messagebus. - Allow for slow testnode by giving it 5s to complete something that should only take 1s.
* Use less/greater hamcrest matchers.Henning Baldersheim2017-01-092-2/+10
|
* Revert "Revert "Revert "Revert "Revert "Revert "Revert "Balder/avoid costly ↵Henning Baldersheim2017-01-081-1/+1
| | | | notifyall in sharedsender"""""""
* Revert "Revert "Revert "Revert "Revert "Revert "Balder/avoid costly ↵Henning Baldersheim2017-01-071-1/+1
| | | | notifyall in sharedsender""""""
* Revert "Revert "Revert "Revert "Revert "Balder/avoid costly notifyall in ↵Henning Baldersheim2017-01-071-1/+1
| | | | sharedsender"""""
* Revert "Revert "Revert "Revert "Balder/avoid costly notifyall in ↵Henning Baldersheim2017-01-071-1/+1
| | | | sharedsender""""
* Revert "Revert "Revert "Balder/avoid costly notifyall in sharedsender"""Henning Baldersheim2017-01-071-1/+1
|
* Revert "Revert "Balder/avoid costly notifyall in sharedsender""Henning Baldersheim2017-01-071-1/+1
|
* Revert "Balder/avoid costly notifyall in sharedsender"Henning Baldersheim2017-01-071-1/+1
|
* Allow for a Callback to complete early.Henning Baldersheim2017-01-071-1/+1
|
* Use EmptyReply and SwapState.Henning Baldersheim2017-01-061-17/+7
|
* Use lambda for thread and l -> L for long constants.Henning Baldersheim2017-01-061-5/+4
|
* Need only one notify methodHenning Baldersheim2017-01-061-9/+3
|
* Avoid race condition in waitComplete.Henning Baldersheim2017-01-061-1/+3
|
* Avoid double negation.Henning Baldersheim2017-01-061-2/+1
|
* Remove unused import.Henning Baldersheim2017-01-061-1/+0
|
* Convert to long before multiplying to avoid overflow.Henning Baldersheim2017-01-061-1/+1
|
* Only do early expire in interval driven thread, not on every reply. Also use ↵Henning Baldersheim2017-01-061-12/+22
| | | | the same lock to avoid Q jumping messages.
* Expire stalled messages in BlockedQ earlier.Henning Baldersheim2017-01-061-3/+14
|
* At 0 you are already out of time.Henning Baldersheim2017-01-061-1/+1
|
* Revert "Revert "First pass at a scalable blocking send.""Henning Baldersheim2017-01-062-37/+188
|
* Revert "First pass at a scalable blocking send."Henning Baldersheim2017-01-062-188/+37
|
* - Added a test for sendBlocking with and without blocking sendQ.Henning Baldersheim2017-01-062-60/+149
| | | | | | | | | - Redesigned based on @bratseth comments. - Now you will be timed out either by the reply thread in mbus or by the new thread that will handle sending of leftover messages. Timeout is not honoured correctly if there is a variation in timeout and system overload. A short timeout message might not be expired if an earlier message with alonger timeout is still on the Q. But I will let factory have a go at it before completing.
* First pass at a scalable blocking send.Henning Baldersheim2017-01-041-12/+74
|
* Wake up more often to check if room.Henning Baldersheim2017-01-031-2/+2
| | | | This allows us to let a few be a few and not many.
* Avoid the excessive ping-pong when many threads are blocking.Henning Baldersheim2017-01-031-3/+13
| | | | If less then 100 give all a chance to send, if more only select 1.
* whitespace fixups.Arne H Juul2017-01-0329-2400/+2400
|
* Further decouple some hpp files, config and the attributevector.Henning Baldersheim2016-12-2012-73/+80
|
* Only include what you needHenning Baldersheim2016-12-1984-335/+134
|
* Do not include fastos.h in header files.Henning Baldersheim2016-12-191-1/+3
|
* Do not include fastos.h in header files.Henning Baldersheim2016-12-191-4/+4
|
* Split in hash_xxx, array, lru, cache ++ in hpp files. To reduce clinon buildHenning Baldersheim2016-12-154-10/+3
|
* Avoid pulling in all of slobrok and config everywhere.Henning Baldersheim2016-12-1210-37/+38
|
* Split out so documentprotocol.h does not pull in everything.Henning Baldersheim2016-12-125-3/+7
|
* Include what you need as gcc 6 provides less.Henning Baldersheim2016-12-121-2/+3
|
* No need to include log.h when not loggingHenning Baldersheim2016-12-1247-133/+16
|
* Reduce inlining of large destructors.Henning Baldersheim2016-11-244-18/+11
|
* Removed TestApp::GetSourceDirectoryArnstein Ressem2016-11-021-3/+3
|
* We only need one vtagHenning Baldersheim2016-10-219-138/+31
|
* Nonfunctional changesJon Bratseth2016-10-171-0/+1
|
* Remove the XXXFactory indirection. Just use static method on Alloc.Henning Baldersheim2016-10-161-4/+5
|
* Revert rename of public HostName.getLocalhostHåkon Hallingstad2016-10-141-1/+1
|
* Revert "Revert "Use HostName for message bus, but fix HostName to work with ↵hakonhall2016-10-141-10/+1
| | | | dev machines""
* Revert "Use HostName for message bus, but fix HostName to work with dev ↵Eirik Nygaard2016-10-141-1/+10
| | | | machines"
* Rename getLocalhost to getHostNameHåkon Hallingstad2016-10-131-1/+1
|
* Fall back to picking another resolvable and reachable address if the systemHåkon Hallingstad2016-10-131-10/+1
| | | | hostname isn't.
* Checkpoint 1Henning Baldersheim2016-10-031-4/+4
|
* Merge pull request #738 from yahoo/bratseth/support-document-api-in-applicationsJon Bratseth2016-09-296-97/+135
|\ | | | | Bratseth/support document api in applications
| * CleanupJon Bratseth2016-09-293-30/+66
| |
| * Support document-api in applicationJon Bratseth2016-09-284-67/+69
| |