X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fclient%2Fclient.cpp;h=48c471c5a07f7aed91c16ec02f9bb4f88f37477f;hb=fa4d0a5606f0c9ed49e196278611fce6b017fb0b;hp=b0bd4df38620e2b1473d8f3a360e045af3773de6;hpb=019a59ffca44ddc32fc6b16fd6cdcc8f3e1c93c6;p=quassel.git diff --git a/src/client/client.cpp b/src/client/client.cpp index b0bd4df3..48c471c5 100644 --- a/src/client/client.cpp +++ b/src/client/client.cpp @@ -77,7 +77,6 @@ Client::Client(QObject *parent) _connectedToCore(false), _syncedToCore(false) { - _monitorBuffer = new Buffer(BufferInfo(), this); _signalProxy->synchronize(_ircListHelper); connect(_backlogManager, SIGNAL(backlog(BufferId, const QVariantList &)), @@ -161,15 +160,10 @@ Buffer *Client::statusBuffer(const NetworkId &networkId) const { return 0; } -Buffer *Client::buffer(BufferId bufferId) { - if(instance()->_buffers.contains(bufferId)) - return instance()->_buffers[bufferId]; - else - return 0; -} - Buffer *Client::buffer(BufferInfo bufferInfo) { - Buffer *buff = buffer(bufferInfo.bufferId()); + Buffer *buff = 0; + if(instance()->_buffers.contains(bufferInfo.bufferId())) + buff = instance()->_buffers[bufferInfo.bufferId()]; if(!buff) { Client *client = Client::instance(); @@ -309,7 +303,7 @@ void Client::setSyncedToCore() { // create buffersyncer Q_ASSERT(!_bufferSyncer); _bufferSyncer = new BufferSyncer(this); - connect(bufferSyncer(), SIGNAL(lastSeenMsgSet(BufferId, MsgId)), this, SLOT(updateLastSeenMsg(BufferId, MsgId))); + connect(bufferSyncer(), SIGNAL(lastSeenMsgSet(BufferId, MsgId)), _networkModel, SLOT(setLastSeenMsgId(BufferId, MsgId))); connect(bufferSyncer(), SIGNAL(bufferRemoved(BufferId)), this, SLOT(bufferRemoved(BufferId))); connect(bufferSyncer(), SIGNAL(bufferRenamed(BufferId, QString)), this, SLOT(bufferRenamed(BufferId, QString))); signalProxy()->synchronize(bufferSyncer()); @@ -450,21 +444,14 @@ void Client::receiveBacklog(BufferId bufferId, const QVariantList &msgs) { //QTime start = QTime::currentTime(); QList msglist; foreach(QVariant v, msgs) { - msglist << v.value(); + Message msg = v.value(); + msg.setFlags(msg.flags() | Message::Backlog); + msglist << msg; } messageProcessor()->process(msglist); //qDebug() << "processed" << msgs.count() << "backlog lines in" << start.msecsTo(QTime::currentTime()); } -void Client::updateLastSeenMsg(BufferId id, const MsgId &msgId) { - Buffer *b = buffer(id); - if(!b) { - qWarning() << "Client::updateLastSeen(): Unknown buffer" << id; - return; - } - b->setLastSeenMsg(msgId); -} - void Client::setBufferLastSeenMsg(BufferId id, const MsgId &msgId) { if(!bufferSyncer()) return;