| OZ++ Sample: InodeWatcher |
/****************************************************************************** * * Copyright (c) 2015 Antillia.com TOSHIYUKI ARAI. ALL RIGHTS RESERVED. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions, and the following disclaimer. * * 2. The name of the author may not be used to endorse or promote products * derived from this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * * * InodeWatcher.cpp * *****************************************************************************/ #include <oz++/motif/ApplicationView.h> #include <oz++/motif/ScrolledListBox.h> #include <oz++/motif/CompoundString.h> #include <oz++/motif/RenderTable.h> #include <oz++/NonblockingInodeWatcher.h> #include <oz++/Logger.h> namespace OZ { class MainView :public ApplicationView { private: //Inner class start class MotifInodeWatcher :public NonblockingInodeWatcher { private: static const int MAX_LISTITEM = 1000; ListBox* listBox; //Shallow copy. public: //Create a nonblocking InodeWatcher. MotifInodeWatcher(ListBox* list) :NonblockingInodeWatcher(), listBox(list) { } virtual void display(struct inotify_event* event) { int count = listBox -> getItemCount(); if (count > MAX_LISTITEM) { listBox -> deletePos(count); //printf("ListBox::deletePos %d\n", count); } const char* name = ""; if (event->len >0) { name = event->name; } LocalDateTime ldt; CharString now = ldt.nowToSeconds(); const char* path = ""; CharString* folder = lookupFolderName(event->wd); if (folder) { path = (const char*)(*folder); } const char* mask = maskToString(event->mask); char item[PATH_MAX]; sprintf(item, "%s %s %s/%s", (const char*)now, mask, path, name); CompoundString cs(item); listBox -> addFirstUnselected(cs); listBox -> flush(); } }; //Inner class end SmartPtr<RenderTable> rtable; SmartPtr<ScrolledListBox> sclist; SmartPtr<MotifInodeWatcher> inodeWatcher; public: MainView(Application& applet, const char* name, Args& args, int watchCount, char** watchPath) :ApplicationView(applet, name, args), inodeWatcher(NULL) { Args ar; ar.set(XmNscrollBarDisplayPolicy, XmVARIABLE); ar.set(XmNlistSizePolicy, XmCONSTANT); ar.set(XmNvisibleItemCount, 30); sclist = new ScrolledListBox(this, "list", ar); ListBox* listBox = sclist -> getList(); // Create an instance of RenderTable based on a Rendition object. ar.reset(); ar.set(XmNfontSize, 12); ar.set(XmNfontName, "Courier"); rtable = new RenderTable(listBox, "", ar); // Set the renderTable to the ListBox instance. listBox -> set(XmNrenderTable, rtable); inodeWatcher = new MotifInodeWatcher(listBox); inodeWatcher -> setSleepMilliSec(500); for (int i = 0; i< watchCount; i++) { try { printf("Adding a watchpath %s\n", watchPath[i]); inodeWatcher -> addWatch(watchPath[i]); } catch (Exception& ex) { caught(ex); } } inodeWatcher -> start(); } ~MainView() { } }; } // You can specify pathnames to watch on the command line, as shown below: // InodeWatcher /etc /tmp int main(int argc, char** argv) { sigignore(SIGPIPE); if (argc == 1) { printf("Usage: %s watchpath1 watchpath2,...\n", argv[0]); return 1; } XInitThreads(); try { const char* appclass = argv[0]; Application applet(appclass, argc, argv); Args args; args.set(XmNgeometry, "600x400"); MainView view(applet, argv[0], args, argc-1, &argv[1]); view.realize(); applet.run(); } catch (Exception& ex) { caught(ex); } return 0; }