cluster: Bugfix for the log timestamps.

This commit is contained in:
Gunnar Beutner 2013-09-03 10:12:07 +02:00
parent b844ea1bcb
commit 235042bbac
1 changed files with 3 additions and 1 deletions

View File

@ -656,6 +656,8 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
lmessage->Set("params", lparams);
sender->SendMessage(lmessage);
sender->SetRemoteLogPosition(message->Get("ts"));
}
Dictionary::Ptr params = message->Get("params");
@ -839,7 +841,7 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
ObjectLock olock(service);
service->ClearAcknowledgement(sender->GetName());
} else if (message->Get("method") == "cluster::SetLogPosition") {
sender->SetRemoteLogPosition(params->Get("log_position"));
sender->SetLocalLogPosition(params->Get("log_position"));
}
}