sclass TailFile {
File file;
int interval;
long l;
new Flag stopped;
java.util.Timer timer;
ReliableSingleThread thread;
volatile bool hasIdled, debug;
*() {}
*(final File *file, int *interval, fO onData) {
thread = new ReliableSingleThread(r {
long l2 = l(file);
if (l2 < l) l = 0; // file shrunk (log rotated!) - start over from beginning of file
if (l2 == l) hasIdled = true;
else pcall {
if (debug) print("New data in " + f2s(file) + ": " + n2(l2-l, "byte"));
S text = null;
for (S s : loadTextFilePart_iterator(file, l, l2))
pcallF(onData, s);
l = l2;
}
});
}
void start {
timer = doEvery(interval, r {
if (!stopped.isUp()) thread.trigger()
});
}
void stop {
timer.cancel();
timer = null;
if (stopped.raise())
thread.triggerAndWait(); // One last time baby
}
bool started() {
ret timer != null;
}
void debugOn {
if (debug) ret;
debug = true;
print("Watching file: " + f2s(file));
}
}Began life as a copy of #1013001
download show line numbers debug dex old transpilations
Travelled to 13 computer(s): aoiabmzegqzx, bhatertpkbcr, cbybwowwnfue, cfunsshuasjs, gwrvuhgaqvyk, ishqpsrjomds, lpdgvwnxivlt, mqqgnosmbjvj, pyentgdyhuwx, pzhvpgtvlbxg, tslmcundralx, tvejysmllsmz, vouqrxazstgt
No comments. add comment
| Snippet ID: | #1015195 |
| Snippet name: | TailFile |
| Eternal ID of this version: | #1015195/1 |
| Text MD5: | b7d14f36ef54a1bebd3e54bb3f4da8b1 |
| Author: | stefan |
| Category: | javax / i.o. |
| Type: | JavaX fragment (include) |
| Public (visible to everyone): | Yes |
| Archived (hidden from active list): | No |
| Created/modified: | 2018-05-10 17:47:22 |
| Source code size: | 1114 bytes / 48 lines |
| Pitched / IR pitched: | No / No |
| Views / Downloads: | 786 / 787 |
| Referenced in: | [show references] |