mirror of https://gitee.com/bigwinds/arangodb
cosmetics
This commit is contained in:
parent
cfdb7ababa
commit
a1003cb5d3
|
@ -123,9 +123,6 @@ class GeneralCommTask : public SocketTask {
|
||||||
std::unordered_map<uint64_t, RequestStatisticsAgent> _agents;
|
std::unordered_map<uint64_t, RequestStatisticsAgent> _agents;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
void handleTimeout() /* override final */ { /* _clientClosed = true; */
|
|
||||||
}
|
|
||||||
|
|
||||||
bool handleRequest(std::shared_ptr<RestHandler>);
|
bool handleRequest(std::shared_ptr<RestHandler>);
|
||||||
void handleRequestDirectly(std::shared_ptr<RestHandler>);
|
void handleRequestDirectly(std::shared_ptr<RestHandler>);
|
||||||
bool handleRequestAsync(std::shared_ptr<RestHandler>,
|
bool handleRequestAsync(std::shared_ptr<RestHandler>,
|
||||||
|
|
|
@ -58,14 +58,13 @@ HttpCommTask::HttpCommTask(EventLoop loop, GeneralServer* server,
|
||||||
_allowMethodOverride(GeneralServerFeature::allowMethodOverride()),
|
_allowMethodOverride(GeneralServerFeature::allowMethodOverride()),
|
||||||
_denyCredentials(true),
|
_denyCredentials(true),
|
||||||
_newRequest(true),
|
_newRequest(true),
|
||||||
_requestType(rest::RequestType::ILLEGAL), // TODO(fc) remove
|
_requestType(rest::RequestType::ILLEGAL),
|
||||||
_fullUrl(), // TODO(fc) remove
|
_fullUrl(),
|
||||||
_origin(), // TODO(fc) remove
|
_origin(),
|
||||||
_sinceCompactification(0),
|
_sinceCompactification(0),
|
||||||
_originalBodyLength(0) { // TODO(fc) remove
|
_originalBodyLength(0) {
|
||||||
_protocol = "http";
|
_protocol = "http";
|
||||||
connectionStatisticsAgentSetHttp(); // this agent is inherited form
|
connectionStatisticsAgentSetHttp();
|
||||||
// sockettask or task
|
|
||||||
_agents.emplace(std::make_pair(1UL, RequestStatisticsAgent(true)));
|
_agents.emplace(std::make_pair(1UL, RequestStatisticsAgent(true)));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -72,7 +72,6 @@ VppCommTask::VppCommTask(EventLoop loop, GeneralServer* server,
|
||||||
_readBuffer.reserve(
|
_readBuffer.reserve(
|
||||||
_bufferLength); // ATTENTION <- this is required so we do not
|
_bufferLength); // ATTENTION <- this is required so we do not
|
||||||
// loose information during a resize
|
// loose information during a resize
|
||||||
// connectionStatisticsAgentSetVpp();
|
|
||||||
_agents.emplace(std::make_pair(0UL, RequestStatisticsAgent(true)));
|
_agents.emplace(std::make_pair(0UL, RequestStatisticsAgent(true)));
|
||||||
getAgent(0UL)->acquire();
|
getAgent(0UL)->acquire();
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,8 +22,8 @@
|
||||||
/// @author Achim Brandt
|
/// @author Achim Brandt
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
#ifndef ARANGOD_SCHEDULER_SOCKET_TASK2_H
|
#ifndef ARANGOD_SCHEDULER_SOCKET_TASK_H
|
||||||
#define ARANGOD_SCHEDULER_SOCKET_TASK2_H 1
|
#define ARANGOD_SCHEDULER_SOCKET_TASK_H 1
|
||||||
|
|
||||||
#include "Scheduler/Task.h"
|
#include "Scheduler/Task.h"
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue