summaryrefslogtreecommitdiffstats
path: root/storage
Commit message (Collapse)AuthorAgeFilesLines
* Add bucket space to more storage commands.Tor Egge2017-10-164-52/+71
|
* Merge pull request #3747 from ↵Tor Brede Vekterli2017-10-166-67/+52
|\ | | | | | | | | vespa-engine/toregge/add-bucket-space-to-storage-commands Adjust API for storage messages: Replace virtual getBucketId() method…
| * Reduce number of calls to document::BucketSpace::placeHolder() by usingTor Egge2017-10-134-45/+36
| | | | | | | | bucket space information from storage commands.
| * Adjust API for storage messages: Replace virtual getBucketId() method withTor Egge2017-10-133-22/+16
| | | | | | | | | | | | | | virtual getBucket() method that also contains bucket space. Adjust BucketCommand/BucketReply intermediate storage message classes to use document::Bucket members instead of document::BucketId.
* | Merge pull request #3742 from vespa-engine/balder/looking-for-missing-joinHenning Baldersheim2017-10-137-224/+109
|\ \ | | | | | | Balder/looking for missing join
| * | Remove unused method declaration and allign code.Henning Baldersheim2017-10-131-22/+12
| | |
| * | You can only start threads that operates on this in the constructor if you ↵Henning Baldersheim2017-10-131-1/+1
| | | | | | | | | | | | are final.
| * | No longer set unused parameterHenning Baldersheim2017-10-131-2/+1
| | |
| * | Cleanup while looking for missing join.Henning Baldersheim2017-10-136-200/+96
| |/
* | Merge pull request #3745 from ↵Henning Baldersheim2017-10-133-15/+41
|\ \ | |/ |/| | | | | vespa-engine/vekterli/abort-priority-queued-requests-on-distributor-shutdown Abort priority-queued requests on distributor shutdown
| * Abort priority-queued requests on distributor shutdownTor Brede Vekterli2017-10-133-15/+41
| |
* | Prefer static cast over C style castHenning Baldersheim2017-10-131-1/+1
| |
* | Allow -Wformat-security + some c++11ification based on Clions advise.Henning Baldersheim2017-10-122-147/+66
|/
* Merge pull request #3736 from ↵Henning Baldersheim2017-10-123-12/+128
|\ | | | | | | | | vespa-engine/vekterli/use-priority-queue-for-external-client-operations Use priority queue for external client operations
| * Use priority queue for external client operationsTor Brede Vekterli2017-10-123-12/+128
| | | | | | | | Internal operations and replies and handled in FIFO order as before.
* | Simplify with using directive.Henning Baldersheim2017-10-112-26/+19
| |
* | - Add the mandatory guard to th emethod signature.Henning Baldersheim2017-10-114-144/+117
| | | | | | | | | | | | - (smartptr.get() != nullptr/0) -> (smartptr) - smartptr.reset(0) -> smartptr.reset() - Avoid excessive vertical bloat.
* | Protect initial setup from reconfigs with explicit mutexTor Brede Vekterli2017-10-112-8/+28
| | | | | | | | | | | | Mutex will only be attempted concurrently taken if a live reconfig happens during node initialize(), and will not deadlock when config is initially propagated via the ConfigFetcher.
* | Don't start config thread until _after_ components are set upTor Brede Vekterli2017-10-111-5/+6
|/ | | | | Avoids race where new config received after initial fetch but before node is fully set up gets lost.
* Merge pull request #3663 from ↵Tor Brede Vekterli2017-10-056-12/+12
|\ | | | | | | | | vespa-engine/toregge/add-bucketspace-parameter-to-spi-methods Add BucketSpace parameter to listBuckets() and getModifiedBuckets() SPI methods.
| * Add BucketSpace parameter to listBuckets() and getModifiedBuckets() SPITor Egge2017-10-056-12/+12
| | | | | | | | methods.
* | Merge pull request #3660 from ↵Tor Brede Vekterli2017-10-051-0/+18
|\ \ | |/ |/| | | | | vespa-engine/vekterli/log-with-backtrace-on-empty-bucketdb-update Log with backtrace when inserting an empty bucket into the database
| * Log with backtrace when inserting an empty bucket into the databaseTor Brede Vekterli2017-10-051-0/+18
| | | | | | | | | | | | | | | | The database should not contain empty buckets, but there exists an unknown edge case where this appears to happen. This logging should help us track down where it happens from. Should replace logging with assertion once we're confident it doesn't trigger in any common scenarios.
* | Use document::Bucket in storage::spi::Bucket to add bucket space.Tor Egge2017-10-0416-79/+99
|/
* Revert "Revert "Havardpe/avoid reading past json value in slime json parser""Arnstein Ressem2017-10-022-4/+4
|
* Revert "Havardpe/avoid reading past json value in slime json parser"Arnstein Ressem2017-10-022-4/+4
|
* avoid implicit cast to boolHåvard Pettersen2017-09-292-2/+2
|
* avoid requiring that json parsing consumes all inputHåvard Pettersen2017-09-292-4/+4
| | | | (the input could end with \n if human readable)
* Revert "Revert "Aressem/remove post install script""Arnstein Ressem2017-09-273-15/+15
|
* Revert "Aressem/remove post install script"Arnstein Ressem2017-09-273-15/+15
|
* Create function to install config definitions.Arnstein Ressem2017-09-273-15/+15
|
* This add slime encoding of headers for future TLS usage,Henning Baldersheim2017-09-191-0/+5
| | | | | and slime encoded body containing normal mbus payload. Both supporting compression.
* Revert "- Use C++11 for loops."Henning Baldersheim2017-09-191-5/+0
|
* Merge pull request #3238 from vespa-engine/balder/mbus-transported-with-slime-2Henning Baldersheim2017-09-191-0/+5
|\ | | | | - Use C++11 for loops.
| * - Use C++11 for loops.Henning Baldersheim2017-08-281-0/+5
| | | | | | | | | | | | | | - Detangle some includes and include what you need. - Refactor to subclass to avoid code duplication. - Add config for compression too. - V1 up to 142, V2 above.
* | Reduce need to rename config definition files in post install step.Tor Egge2017-09-183-15/+15
| |
* | Inhibit scheduling of merges towards nodes that are marked busyTor Brede Vekterli2017-09-1415-127/+234
| | | | | | | | | | | | | | | | | | Utilizes existing maintenance operation scheduler system which checks if an operation is considered blocked and does not start it if this is the case. We now block a merge operation if any of the nodes in its node set are marked busy by the pending message tracker. Duration for which nodes are marked busy is live-configurable.
* | Align membersHenning Baldersheim2017-09-051-3/+2
| |
* | WE must listen to everyone who wants to stop.Henning Baldersheim2017-09-052-8/+10
| |
* | Request shutdown instead of doing a std::quick_exit.Henning Baldersheim2017-09-051-3/+2
| |
* | Revert "Request shutdown instead of doing a std::quick_exit."Henning Baldersheim2017-09-051-2/+3
| |
* | Merge pull request #3331 from ↵Tor Brede Vekterli2017-09-053-10/+45
|\ \ | | | | | | | | | | | | vespa-engine/vekterli/evict-merge-throttler-queues-on-backpressure Evict all queued merges from throttler on back-pressure
| * | Evict all queued merges from throttler on backpressureTor Brede Vekterli2017-09-053-10/+45
| | |
* | | Request shutdown instead of doing a std::quick_exit.Henning Baldersheim2017-09-051-3/+2
|/ /
* | De-dupe backpressure mode checking codeTor Brede Vekterli2017-09-012-11/+16
| |
* | Remove TODO that probably won't be neededTor Brede Vekterli2017-09-011-1/+0
| |
* | Don't perform expression-embedded variable assignmentTor Brede Vekterli2017-09-011-2/+2
| |
* | Update function name to reflect current semantics of fatal errorsTor Brede Vekterli2017-08-312-3/+3
| |
* | De-dupe some error listener test codeTor Brede Vekterli2017-08-314-23/+12
| |
* | Wire together new listener to propagate errorsTor Brede Vekterli2017-08-3117-117/+210
| |