• Skip to content
  • Skip to link menu
  • KDE API Reference
  • kdepimlibs-4.10.5 API Reference
  • KDE Home
  • Contact Us
 

akonadi

  • akonadi
changerecorder.cpp
1 /*
2  Copyright (c) 2007 Volker Krause <vkrause@kde.org>
3 
4  This library is free software; you can redistribute it and/or modify it
5  under the terms of the GNU Library General Public License as published by
6  the Free Software Foundation; either version 2 of the License, or (at your
7  option) any later version.
8 
9  This library is distributed in the hope that it will be useful, but WITHOUT
10  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11  FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
12  License for more details.
13 
14  You should have received a copy of the GNU Library General Public License
15  along with this library; see the file COPYING.LIB. If not, write to the
16  Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
17  02110-1301, USA.
18 */
19 
20 #include "changerecorder.h"
21 #include "changerecorder_p.h"
22 
23 #include <kdebug.h>
24 #include <QtCore/QSettings>
25 
26 using namespace Akonadi;
27 
28 ChangeRecorder::ChangeRecorder( QObject * parent ) :
29  Monitor( new ChangeRecorderPrivate( 0, this ), parent )
30 {
31 }
32 
33 ChangeRecorder::ChangeRecorder( ChangeRecorderPrivate *privateclass, QObject * parent ) :
34  Monitor( privateclass, parent )
35 {
36 }
37 
38 ChangeRecorder::~ChangeRecorder()
39 {
40 }
41 
42 void ChangeRecorder::setConfig(QSettings * settings)
43 {
44  Q_D( ChangeRecorder );
45  if ( settings ) {
46  d->settings = settings;
47  Q_ASSERT( d->pendingNotifications.isEmpty() );
48  d->loadNotifications();
49  } else if ( d->settings ) {
50  if ( d->enableChangeRecording )
51  d->saveNotifications();
52  d->settings = settings;
53  }
54 }
55 
56 void ChangeRecorder::replayNext()
57 {
58  Q_D( ChangeRecorder );
59  if ( !d->pendingNotifications.isEmpty() ) {
60  const NotificationMessage msg = d->pendingNotifications.head();
61  if ( d->ensureDataAvailable( msg ) ) {
62  d->emitNotification( msg );
63  } else if ( d->translateAndCompress( d->pipeline, msg ) ) {
64  // The msg is now in both pipeline and pendingNotifications.
65  // When data is available, MonitorPrivate::flushPipeline will emitNotification.
66  // When changeProcessed is called, we'll finally remove it from pendingNotifications.
67  } else {
68  // In the case of a move where both source and destination are
69  // ignored, we ignore the message and process the next one.
70  d->dequeueNotification();
71  return replayNext();
72  }
73  } else {
74  // This is necessary when none of the notifications were accepted / processed
75  // above, and so there is no one to call changeProcessed() and the ChangeReplay task
76  // will be stuck forever in the ResourceScheduler.
77  emit nothingToReplay();
78  }
79 }
80 
81 bool ChangeRecorder::isEmpty() const
82 {
83  Q_D( const ChangeRecorder );
84  return d->pendingNotifications.isEmpty();
85 }
86 
87 void ChangeRecorder::changeProcessed()
88 {
89  Q_D( ChangeRecorder );
90 
91  // changerecordertest.cpp calls changeProcessed after receiving nothingToReplay,
92  // so test for emptiness. Not sure real code does this though.
93  // Q_ASSERT( !d->pendingNotifications.isEmpty() )
94  if ( !d->pendingNotifications.isEmpty() )
95  d->dequeueNotification();
96 }
97 
98 void ChangeRecorder::setChangeRecordingEnabled( bool enable )
99 {
100  Q_D( ChangeRecorder );
101  if ( d->enableChangeRecording == enable ) {
102  return;
103  }
104  d->enableChangeRecording = enable;
105  if ( enable ) {
106  d->m_needFullSave = true;
107  d->notificationsLoaded();
108  } else {
109  d->dispatchNotifications();
110  }
111 }
112 
113 QString Akonadi::ChangeRecorder::dumpNotificationListToString() const
114 {
115  Q_D( const ChangeRecorder );
116  return d->dumpNotificationListToString();
117 }
118 
This file is part of the KDE documentation.
Documentation copyright © 1996-2013 The KDE developers.
Generated on Sat Jul 13 2013 01:27:32 by doxygen 1.8.3.1 written by Dimitri van Heesch, © 1997-2006

KDE's Doxygen guidelines are available online.

akonadi

Skip menu "akonadi"
  • Main Page
  • Namespace List
  • Namespace Members
  • Alphabetical List
  • Class List
  • Class Hierarchy
  • Class Members
  • File List
  • Modules
  • Related Pages

kdepimlibs-4.10.5 API Reference

Skip menu "kdepimlibs-4.10.5 API Reference"
  • akonadi
  •   contact
  •   kmime
  •   socialutils
  • kabc
  • kalarmcal
  • kblog
  • kcal
  • kcalcore
  • kcalutils
  • kholidays
  • kimap
  • kioslave
  •   imap4
  •   mbox
  •   nntp
  • kldap
  • kmbox
  • kmime
  • kontactinterface
  • kpimidentities
  • kpimtextedit
  • kpimutils
  • kresources
  • ktnef
  • kxmlrpcclient
  • mailtransport
  • microblog
  • qgpgme
  • syndication
  •   atom
  •   rdf
  •   rss2
Report problems with this website to our bug tracking system.
Contact the specific authors with questions and comments about the page contents.

KDE® and the K Desktop Environment® logo are registered trademarks of KDE e.V. | Legal