Clean up SQLite replay log on log position change

refs #7752
This commit is contained in:
Alexander A. Klimov 2020-04-09 16:39:18 +02:00
parent 7a48bb856b
commit 8a335ce4e6
2 changed files with 10 additions and 0 deletions

View File

@ -17,6 +17,15 @@ REGISTER_TYPE(Endpoint);
boost::signals2::signal<void(const Endpoint::Ptr&, const JsonRpcConnection::Ptr&)> Endpoint::OnConnected;
boost::signals2::signal<void(const Endpoint::Ptr&, const JsonRpcConnection::Ptr&)> Endpoint::OnDisconnected;
INITIALIZE_ONCE(&Endpoint::ConfigStaticInitialize);
void Endpoint::ConfigStaticInitialize()
{
OnLocalLogPositionChanged.connect([](const Endpoint::Ptr& ep, const Value&) {
ep->GetReplayLog().Cleanup(ep->GetLocalLogPosition());
});
}
void Endpoint::OnAllConfigLoaded()
{
ObjectImpl<Endpoint>::OnAllConfigLoaded();

View File

@ -43,6 +43,7 @@ public:
bool GetConnected() const override;
static Endpoint::Ptr GetLocalEndpoint();
static void ConfigStaticInitialize();
inline ReplayLog& GetReplayLog()
{