mirror/tomahawk
1
0
Fork 0
mirror of https://github.com/tomahawk-player/tomahawk.git synced 2025-04-05 08:32:42 +02:00
Code Issues Releases Wiki Activity

* This might prevent dupe db-ops.

Browse Source
This commit is contained in:
Christian Muehlhaeuser 2012-06-22 02:41:53 +02:00
parent 6572f9820a
commit 82794ed207
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/libtomahawk/network/DbSyncConnection.cpp
View File

@ -47,6 +47,7 @@ DBSyncConnection::DBSyncConnection( Servent* s, const source_ptr& src )
: Connection( s )
, m_source( src )
, m_state( UNKNOWN )
, m_fetchCount( 0 )
{
qDebug() << Q_FUNC_INFO << src->id() << thread();
@ -127,6 +128,7 @@ DBSyncConnection::check()
if ( m_source->lastCmdGuid().isEmpty() )
{
tDebug() << "Fetching lastCmdGuid from database!";
DatabaseCommand_CollectionStats* cmd_them = new DatabaseCommand_CollectionStats( m_source );
connect( cmd_them, SIGNAL( done( QVariantMap ) ), SLOT( gotThem( QVariantMap ) ) );
Database::instance()->enqueue( QSharedPointer<DatabaseCommand>(cmd_them) );
@ -225,6 +227,8 @@ DBSyncConnection::handleMsg( msg_ptr msg )
if ( m.value( "method" ).toString() == "fetchops" )
{
++m_fetchCount;
tDebug() << "Fetching new dbops:" << m["lastop"].toString() << m_fetchCount;
m_uscache = m;
sendOps();
return;
@ -232,7 +236,7 @@ DBSyncConnection::handleMsg( msg_ptr msg )
if ( m.value( "method" ).toString() == "trigger" )
{
tLog( LOGVERBOSE ) << "Got trigger msg on dbsyncconnection, checking for new stuff.";
tLog() << "Got trigger msg on dbsyncconnection, checking for new stuff.";
check();
return;
}
@ -255,7 +259,7 @@ DBSyncConnection::lastOpApplied()
void
DBSyncConnection::sendOps()
{
tLog( LOGVERBOSE ) << "Will send peer" << m_source->id() << "all ops since" << m_uscache.value( "lastop" ).toString();
tLog() << "Will send peer" << m_source->id() << "all ops since" << m_uscache.value( "lastop" ).toString();
source_ptr src = SourceList::instance()->getLocal();
@ -263,6 +267,8 @@ DBSyncConnection::sendOps()
connect( cmd, SIGNAL( done( QString, QString, QList< dbop_ptr > ) ),
SLOT( sendOpsData( QString, QString, QList< dbop_ptr > ) ) );
m_uscache.clear();
Database::instance()->enqueue( QSharedPointer<DatabaseCommand>( cmd ) );
}

1
src/libtomahawk/network/DbSyncConnection.h
View File

@ -78,6 +78,7 @@ private:
void synced();
void changeState( State newstate );
int m_fetchCount;
Tomahawk::source_ptr m_source;
QVariantMap m_uscache;