mirror of https://gitee.com/bigwinds/arangodb
clang format
This commit is contained in:
parent
6f2ce0cd5a
commit
341891ed74
|
@ -370,7 +370,7 @@ bool VppCommTask::processRead() {
|
||||||
_request = new VppRequest(_connectionInfo, std::move(message));
|
_request = new VppRequest(_connectionInfo, std::move(message));
|
||||||
GeneralServerFeature::HANDLER_FACTORY->setRequestContext(_request);
|
GeneralServerFeature::HANDLER_FACTORY->setRequestContext(_request);
|
||||||
|
|
||||||
//make sure we have a dabase
|
// make sure we have a dabase
|
||||||
if (_request->requestContext() == nullptr) {
|
if (_request->requestContext() == nullptr) {
|
||||||
handleSimpleError(GeneralResponse::ResponseCode::NOT_FOUND,
|
handleSimpleError(GeneralResponse::ResponseCode::NOT_FOUND,
|
||||||
TRI_ERROR_ARANGO_DATABASE_NOT_FOUND,
|
TRI_ERROR_ARANGO_DATABASE_NOT_FOUND,
|
||||||
|
|
|
@ -83,13 +83,13 @@ class VppCommTask : public GeneralCommTask {
|
||||||
};
|
};
|
||||||
std::unordered_map<MessageID, IncompleteVPackMessage> _incompleteMessages;
|
std::unordered_map<MessageID, IncompleteVPackMessage> _incompleteMessages;
|
||||||
|
|
||||||
static size_t const _bufferLength = 4096UL;
|
static size_t const _bufferLength = 4096UL;
|
||||||
static size_t const _chunkMaxBytes = 1000;
|
static size_t const _chunkMaxBytes = 1000;
|
||||||
struct ProcessReadVariables {
|
struct ProcessReadVariables {
|
||||||
ProcessReadVariables()
|
ProcessReadVariables()
|
||||||
: _currentChunkLength(0),
|
: _currentChunkLength(0),
|
||||||
_readBufferCursor(nullptr),
|
_readBufferCursor(nullptr),
|
||||||
_cleanupLength(_bufferLength - _chunkMaxBytes - 1 ) {}
|
_cleanupLength(_bufferLength - _chunkMaxBytes - 1) {}
|
||||||
uint32_t
|
uint32_t
|
||||||
_currentChunkLength; // size of chunk processed or 0 when expecting
|
_currentChunkLength; // size of chunk processed or 0 when expecting
|
||||||
// new chunk
|
// new chunk
|
||||||
|
|
Loading…
Reference in New Issue