-rw-r--r-- | libopie2/opiecore/ofilenotify.cpp | 15 | ||||
-rw-r--r-- | libopie2/opiecore/ofilenotify.h | 10 |
2 files changed, 23 insertions, 2 deletions
diff --git a/libopie2/opiecore/ofilenotify.cpp b/libopie2/opiecore/ofilenotify.cpp index de4c63b..270570e 100644 --- a/libopie2/opiecore/ofilenotify.cpp +++ b/libopie2/opiecore/ofilenotify.cpp | |||
@@ -155,110 +155,123 @@ void OFileNotification::stop() | |||
155 | else | 155 | else |
156 | { | 156 | { |
157 | ::close( _fd ); | 157 | ::close( _fd ); |
158 | _type = Single; | 158 | _type = Single; |
159 | _path = QString::null; | 159 | _path = QString::null; |
160 | _fd = 0; | 160 | _fd = 0; |
161 | _active = false; | 161 | _active = false; |
162 | } | 162 | } |
163 | } | 163 | } |
164 | 164 | ||
165 | 165 | ||
166 | OFileNotificationType OFileNotification::type() const | 166 | OFileNotificationType OFileNotification::type() const |
167 | { | 167 | { |
168 | return _type; | 168 | return _type; |
169 | } | 169 | } |
170 | 170 | ||
171 | 171 | ||
172 | QString OFileNotification::path() const | 172 | QString OFileNotification::path() const |
173 | { | 173 | { |
174 | return _path; | 174 | return _path; |
175 | } | 175 | } |
176 | 176 | ||
177 | 177 | ||
178 | int OFileNotification::fileno() const | 178 | int OFileNotification::fileno() const |
179 | { | 179 | { |
180 | return _fd; | 180 | return _fd; |
181 | } | 181 | } |
182 | 182 | ||
183 | 183 | ||
184 | bool OFileNotification::activate() | 184 | bool OFileNotification::activate() |
185 | { | 185 | { |
186 | if ( hasChanged() ) | 186 | if ( hasChanged() ) |
187 | { | 187 | { |
188 | emit triggered(); | 188 | emit triggered(); |
189 | _signal.activate(); | 189 | _signal.activate(); |
190 | return true; | 190 | return true; |
191 | } | 191 | } |
192 | else | 192 | else |
193 | return false; | 193 | return false; |
194 | } | 194 | } |
195 | 195 | ||
196 | 196 | ||
197 | bool OFileNotification::hasChanged() | 197 | bool OFileNotification::hasChanged() |
198 | { | 198 | { |
199 | bool c = false; | 199 | bool c = false; |
200 | 200 | ||
201 | struct stat newstat; | 201 | struct stat newstat; |
202 | ::memset( &newstat, 0, sizeof newstat ); | 202 | ::memset( &newstat, 0, sizeof newstat ); |
203 | ::stat( _path, &newstat ); | 203 | int result = ::stat( _path, &newstat ); // may fail if file has been renamed or deleted. that doesn't matter :) |
204 | 204 | ||
205 | qDebug( "result of newstat call is %d (%s=%d)", result, strerror( errno ), errno ); | ||
205 | qDebug( "stat.atime = %0lx, newstat.atime = %0lx", (long)_stat.st_atime, (long)newstat.st_atime ); | 206 | qDebug( "stat.atime = %0lx, newstat.atime = %0lx", (long)_stat.st_atime, (long)newstat.st_atime ); |
206 | qDebug( "stat.mtime = %0lx, newstat.mtime = %0lx", (long)_stat.st_mtime, (long)newstat.st_mtime ); | 207 | qDebug( "stat.mtime = %0lx, newstat.mtime = %0lx", (long)_stat.st_mtime, (long)newstat.st_mtime ); |
208 | qDebug( "stat.ctime = %0lx, newstat.ctime = %0lx", (long)_stat.st_ctime, (long)newstat.st_ctime ); | ||
209 | |||
210 | if ( !c && (_type & (Delete|Rename)) && (long)newstat.st_atime == 0 && (long)newstat.st_mtime == 0 && (long)newstat.st_ctime == 0) | ||
211 | { | ||
212 | qDebug( "OFileNotification::hasChanged(): file has been deleted or renamed" ); | ||
213 | c = true; | ||
214 | } | ||
207 | if ( !c && (_type & Access) && (long)_stat.st_atime < (long)newstat.st_atime ) | 215 | if ( !c && (_type & Access) && (long)_stat.st_atime < (long)newstat.st_atime ) |
208 | { | 216 | { |
209 | qDebug( "OFileNotification::hasChanged(): atime changed" ); | 217 | qDebug( "OFileNotification::hasChanged(): atime changed" ); |
210 | c = true; | 218 | c = true; |
211 | } | 219 | } |
212 | if ( !c && (_type & Modify) && (long)_stat.st_mtime < (long)newstat.st_mtime ) | 220 | if ( !c && (_type & Modify) && (long)_stat.st_mtime < (long)newstat.st_mtime ) |
213 | { | 221 | { |
214 | qDebug( "OFileNotification::hasChanged(): mtime changed" ); | 222 | qDebug( "OFileNotification::hasChanged(): mtime changed" ); |
215 | c = true; | 223 | c = true; |
216 | } | 224 | } |
225 | if ( !c && (_type & Attrib) && (long)_stat.st_ctime < (long)newstat.st_ctime ) | ||
226 | { | ||
227 | qDebug( "OFileNotification::hasChanged(): ctime changed" ); | ||
228 | c = true; | ||
229 | } | ||
217 | 230 | ||
218 | return c; | 231 | return c; |
219 | } | 232 | } |
220 | 233 | ||
221 | 234 | ||
222 | void OFileNotification::singleShot( const QString& path, QObject* receiver, const char* member, OFileNotificationType type ) | 235 | void OFileNotification::singleShot( const QString& path, QObject* receiver, const char* member, OFileNotificationType type ) |
223 | { | 236 | { |
224 | OFileNotification* ofn = new OFileNotification(); | 237 | OFileNotification* ofn = new OFileNotification(); |
225 | ofn->_signal.connect( receiver, member ); | 238 | ofn->_signal.connect( receiver, member ); |
226 | ofn->start( path, true, type ); | 239 | ofn->start( path, true, type ); |
227 | } | 240 | } |
228 | 241 | ||
229 | 242 | ||
230 | void OFileNotification::__signalHandler( int sig, siginfo_t *si, void *data ) | 243 | void OFileNotification::__signalHandler( int sig, siginfo_t *si, void *data ) |
231 | { | 244 | { |
232 | qWarning( "OFileNotification::__signalHandler(): reached." ); | 245 | qWarning( "OFileNotification::__signalHandler(): reached." ); |
233 | int fd = si->si_fd; | 246 | int fd = si->si_fd; |
234 | OFileNotification* fn = notification_list[fd]; | 247 | OFileNotification* fn = notification_list[fd]; |
235 | if ( fn ) | 248 | if ( fn ) |
236 | { | 249 | { |
237 | // check if it really was the file (dnotify triggers on directory granularity, not file granularity) | 250 | // check if it really was the file (dnotify triggers on directory granularity, not file granularity) |
238 | if ( !fn->activate() ) | 251 | if ( !fn->activate() ) |
239 | { | 252 | { |
240 | qDebug( "OFileNotification::__signalHandler(): false alarm ;) Restarting the trigger (if it was single)..." ); | 253 | qDebug( "OFileNotification::__signalHandler(): false alarm ;) Restarting the trigger (if it was single)..." ); |
241 | if ( !(fn->type() & Multi ) ) | 254 | if ( !(fn->type() & Multi ) ) |
242 | { | 255 | { |
243 | int result = ::fcntl( fn->fileno(), F_NOTIFY, fn->type() ); | 256 | int result = ::fcntl( fn->fileno(), F_NOTIFY, fn->type() ); |
244 | if ( result == -1 ) | 257 | if ( result == -1 ) |
245 | { | 258 | { |
246 | qWarning( "OFileNotification::__signalHandler(): Can't restart the trigger: %s.", strerror( errno ) ); | 259 | qWarning( "OFileNotification::__signalHandler(): Can't restart the trigger: %s.", strerror( errno ) ); |
247 | } | 260 | } |
248 | } | 261 | } |
249 | return; | 262 | return; |
250 | } | 263 | } |
251 | #if 1 | 264 | #if 1 |
252 | if ( !(fn->type() & Multi) ) | 265 | if ( !(fn->type() & Multi) ) |
253 | { | 266 | { |
254 | qDebug( "OFileNotification::__signalHandler(): '%d' was singleShot. Removing from list.", fd ); | 267 | qDebug( "OFileNotification::__signalHandler(): '%d' was singleShot. Removing from list.", fd ); |
255 | notification_list.remove( fd ); | 268 | notification_list.remove( fd ); |
256 | if ( notification_list.isEmpty() ) | 269 | if ( notification_list.isEmpty() ) |
257 | { | 270 | { |
258 | OFileNotification::unregisterSignalHandler(); | 271 | OFileNotification::unregisterSignalHandler(); |
259 | } | 272 | } |
260 | } | 273 | } |
261 | #endif | 274 | #endif |
262 | } | 275 | } |
263 | else | 276 | else |
264 | { | 277 | { |
diff --git a/libopie2/opiecore/ofilenotify.h b/libopie2/opiecore/ofilenotify.h index 5315896..13b5a6b 100644 --- a/libopie2/opiecore/ofilenotify.h +++ b/libopie2/opiecore/ofilenotify.h | |||
@@ -31,67 +31,75 @@ _;:, .> :=|. This program is free software; you can | |||
31 | #if defined (__GNUC__) && (__GNUC__ < 3) | 31 | #if defined (__GNUC__) && (__GNUC__ < 3) |
32 | #define _GNU_SOURCE | 32 | #define _GNU_SOURCE |
33 | #endif | 33 | #endif |
34 | 34 | ||
35 | /* QT */ | 35 | /* QT */ |
36 | #include <qobject.h> | 36 | #include <qobject.h> |
37 | #include <qsignal.h> | 37 | #include <qsignal.h> |
38 | #include <qstring.h> | 38 | #include <qstring.h> |
39 | 39 | ||
40 | /* STD */ | 40 | /* STD */ |
41 | #include <signal.h> | 41 | #include <signal.h> |
42 | #include <fcntl.h> | 42 | #include <fcntl.h> |
43 | 43 | ||
44 | namespace Opie { | 44 | namespace Opie { |
45 | namespace Core { | 45 | namespace Core { |
46 | 46 | ||
47 | enum OFileNotificationType { Single = 0x0000000, | 47 | enum OFileNotificationType { Single = 0x0000000, |
48 | Multi = DN_MULTISHOT, | 48 | Multi = DN_MULTISHOT, |
49 | Access = DN_ACCESS, | 49 | Access = DN_ACCESS, |
50 | Modify = DN_MODIFY, | 50 | Modify = DN_MODIFY, |
51 | Create = DN_CREATE, | 51 | Create = DN_CREATE, |
52 | Delete = DN_DELETE, | 52 | Delete = DN_DELETE, |
53 | Rename = DN_RENAME, | 53 | Rename = DN_RENAME, |
54 | Attrib = DN_ATTRIB }; | 54 | Attrib = DN_ATTRIB }; |
55 | 55 | ||
56 | class OFileNotification : public QObject | 56 | class OFileNotification : public QObject |
57 | { | 57 | { |
58 | Q_OBJECT | 58 | Q_OBJECT |
59 | 59 | ||
60 | public: | 60 | public: |
61 | OFileNotification( QObject* parent = 0, const char* name = 0 ); | 61 | OFileNotification( QObject* parent = 0, const char* name = 0 ); |
62 | ~OFileNotification(); | 62 | ~OFileNotification(); |
63 | 63 | ||
64 | static void singleShot( const QString& path, QObject* receiver, const char* member, OFileNotificationType type = Modify ); | 64 | static void singleShot( const QString& path, QObject* receiver, const char* member, OFileNotificationType type = Modify ); |
65 | 65 | ||
66 | int start( const QString& path, bool sshot = false, OFileNotificationType type = Modify ); | 66 | int start( const QString& path, bool sshot = false, OFileNotificationType type = Modify ); |
67 | void stop(); | 67 | void stop(); |
68 | 68 | ||
69 | OFileNotificationType type() const; | 69 | OFileNotificationType type() const; |
70 | QString path() const; | 70 | QString path() const; |
71 | int fileno() const; | 71 | int fileno() const; |
72 | bool isActive() const; | 72 | bool isActive() const; |
73 | 73 | ||
74 | signals: | 74 | signals: |
75 | void triggered(); | 75 | void triggered(); |
76 | 76 | ||
77 | protected: | 77 | protected: |
78 | bool activate(); | 78 | bool activate(); |
79 | bool hasChanged(); | 79 | virtual bool hasChanged(); |
80 | static bool registerSignalHandler(); | 80 | static bool registerSignalHandler(); |
81 | static void unregisterSignalHandler(); | 81 | static void unregisterSignalHandler(); |
82 | static void __signalHandler( int sig, siginfo_t *si, void *data ); | 82 | static void __signalHandler( int sig, siginfo_t *si, void *data ); |
83 | 83 | ||
84 | private: | 84 | private: |
85 | QString _path; | 85 | QString _path; |
86 | OFileNotificationType _type; | 86 | OFileNotificationType _type; |
87 | QSignal _signal; | 87 | QSignal _signal; |
88 | int _fd; | 88 | int _fd; |
89 | bool _active; | 89 | bool _active; |
90 | struct stat _stat; | 90 | struct stat _stat; |
91 | }; | 91 | }; |
92 | 92 | ||
93 | |||
94 | class ODirectoryNotification : public OFileNotification | ||
95 | { | ||
96 | public: | ||
97 | virtual bool hasChanged() { return true; }; | ||
98 | }; | ||
99 | |||
100 | |||
93 | } | 101 | } |
94 | } | 102 | } |
95 | 103 | ||
96 | #endif | 104 | #endif |
97 | 105 | ||