8000 Bug fix/increase replication timeouts (#6740) · davinash/arangodb@9b6d526 · GitHub
[go: up one dir, main page]

Skip to content

Commit 9b6d526

Browse files
authored
Bug fix/increase replication timeouts (arangodb#6740)
1 parent ea915d3 commit 9b6d526

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

arangod/MMFiles/MMFilesRestReplicationHandler.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ void MMFilesRestReplicationHandler::handleCommandBarrier() {
186186

187187
// extract ttl
188188
double ttl =
189-
VelocyPackHelper::getNumericValue<double>(input->slice(), "ttl", 30.0);
189+
VelocyPackHelper::getNumericValue<double>(input->slice(), "ttl", replutils::BarrierInfo::DefaultTimeout);
190190

191191
TRI_voc_tick_t minTick = 0;
192192
VPackSlice const v = input->slice().get("tick");
@@ -230,7 +230,7 @@ void MMFilesRestReplicationHandler::handleCommandBarrier() {
230230

231231
// extract ttl
232232
double ttl =
233-
VelocyPackHelper::getNumericValue<double>(input->slice(), "ttl", 30.0);
233+
VelocyPackHelper::getNumericValue<double>(input->slice(), "ttl", replutils::BarrierInfo::DefaultTimeout);
234234

235235
TRI_voc_tick_t minTick = 0;
236236
VPackSlice const v = input->slice().get("tick");
@@ -667,7 +667,7 @@ void MMFilesRestReplicationHandler::handleCommandCreateKeys() {
667667

668668
// initialize a container with the keys
669669
auto keys = std::make_unique<MMFilesCollectionKeys>(
670-
_vocbase, std::move(guard), id, 300.0
670+
_vocbase, std::move(guard), id, 900.0
671671
);
672672

673673
std::string const idString(std::to_string(keys->id()));

arangod/Replication/utilities.h

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,11 @@ struct ProgressInfo {
101101
};
102102

103103
struct BarrierInfo {
104+
static constexpr double DefaultTimeout = 900.0;
104105
/// @brief WAL barrier id
105106
uint64_t id{0};
106107
/// @brief ttl for WAL barrier
107-
int ttl{600};
108+
int ttl{static_cast<int>(DefaultTimeout)};
108109
/// @brief WAL barrier last update time
109110
double updateTime{0.0};
110111

@@ -117,7 +118,7 @@ struct BarrierInfo {
117118
};
118119

119120
struct BatchInfo {
120-
static constexpr double DefaultTimeout = 300.0;
121+
static constexpr double DefaultTimeout = 7200.0;
121122

122123
/// @brief dump batch id
123124
uint64_t id{0};

0 commit comments

Comments
 (0)
0