fix compile errors

This commit is contained in:
Evan Tschannen 2020-07-09 22:53:02 -07:00
parent 717242a0ee
commit f6163d0a79
2 changed files with 1 additions and 3 deletions

View File

@ -483,8 +483,6 @@ ACTOR Future<Void> connectionKeeper( Reference<Peer> self,
self->transport->countConnClosedWithError++;
throw e;
}
ASSERT( false );
} catch (Error& e) {
if(now() - self->lastConnectTime > FLOW_KNOBS->RECONNECTION_RESET_TIME) {
self->reconnectionDelay = FLOW_KNOBS->INITIAL_RECONNECTION_TIME;

View File

@ -150,7 +150,7 @@ ACTOR Future<TLogPeekReply> recordRequestMetrics( ILogSystem::ServerPeekCursor*
try {
state double startTime = now();
TLogPeekReply t = wait(in);
if(now()-lastReset > SERVER_KNOBS->PEEK_RESET_INTERVAL) {
if(now()-self->lastReset > SERVER_KNOBS->PEEK_RESET_INTERVAL) {
if(now()-startTime > SERVER_KNOBS->PEEK_MAX_LATENCY) {
if(t.messages.size() >= SERVER_KNOBS->DESIRED_TOTAL_BYTES || SERVER_KNOBS->PEEK_COUNT_SMALL_MESSAGES) {
if(self->resetCheck.isReady()) {