OZ++ Sample: IPAddressWatcher

/******************************************************************************  *  * 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.  *  *  *  IPAddressWatcher.cpp  *  *****************************************************************************/ #include <oz++/CommonObject.h> #include <oz++/LocalDateTime.h> #include <oz++/Exception.h> #include <oz++/SmartArray.h> #include <oz++/Thread.h> #include <oz++/CharString.h> #include <oz++/LinkedList.h> #include <oz++/Property.h> #include <oz++/netlink/SocketNetlink.h> #include <oz++/netlink/SockAddrNetlink.h> #include <oz++/netlink/NetlinkReply.h> #include <oz++/netlink/NetlinkMsgHeader.h> #include <oz++/netlink/InterfaceAddrAttribute.h> #include <oz++/netlink/InterfaceAddrMsg.h> #include <oz++/motif/ApplicationView.h> #include <oz++/motif/TableView.h> namespace OZ { class IPAddressWatcher: public Thread { private:   View*                    view; //Shallow copy   int                      rtmGroups;   SocketNetlink            socketNetlink;   NetlinkReply<ifaddrmsg>  reply;   bool                     looping;      public:   IPAddressWatcher(View* v, int group = RTMGRP_IPV4_IFADDR)                             //|RTMGRP_IPV6_IFADDR)   :view(v),   rtmGroups(group)   {     looping = true;   }        int bind()   {     SockAddrNetlink  addrNetlink;     addrNetlink.setFamily(AF_NETLINK);     addrNetlink.setGroups(rtmGroups);     return socketNetlink.bind(addrNetlink);   }        void recv()   {     while (looping) {       bzero(&reply, sizeof(reply));       int n = socketNetlink.recv((char*)&reply, sizeof(reply), 0);       if ( n < 0 ){         perror("recv");         break;       }       try {                  NetlinkMsgHeader netlinkMsgHeader(&reply.head);         if (netlinkMsgHeader.isDone() || netlinkMsgHeader.isError()) {           break;         }         do {           LocalDateTime dateTime;           CharString now = dateTime.nowToSeconds();           InterfaceAddrMsg addrMsg(&reply.body);                  InterfaceAddrAttribute attribute(netlinkMsgHeader, addrMsg);                    do {             attribute.parse();           } while (attribute.next() );                        LinkedListT<Property> list;           list.add(new Property("DateTime", (const char*)now) );           addrMsg.getPropertyList(list);                        //Call updateModel                           view -> updateModel(&list);                      } while (netlinkMsgHeader.next());                } catch (Exception& ex) {         caught(ex);          }       fflush(stdout);            }   }   void stop()   {     looping = false;     socketNetlink.close();   }   //Thread main procedure method   void run()   {     try {       this -> bind();       this -> recv();     } catch (Exception& ex) {       caught(ex);        }   } };      class MainView :public ApplicationView { private:   SmartPtr<TableView>        table;   SmartArray<CharString*>    model;   SmartPtr<IPAddressWatcher> watcher;    private:   virtual void updateModel(CommonObject* object)   {     if (object) {       //Update model       LinkedListT<Property>* list = (LinkedListT<Property>*)object;       model.removeAllItems();       size_t size = list->getLength();       for (size_t i = 0; i < size; i++) {         Property* prop = list->getNth(i);         model[i] = new CharString(prop -> value());       }       //Call updateView       updateView();     }   }   virtual void updateView()   {     table -> removeAllItems();     int size = model.getSize();     for (int i = 0; i<size; i++) {       CharString* value = model[i];       if (value) {         printf("%d %s\n", i, (const char*)(*value));         table -> setItem(i, 0, (const char*)(*value));       }     }     // Call flush to update items of the table immediately.      flush();   } public:   MainView(Application& applet, const char* name, Args& args)   :ApplicationView(applet, name, args),   table(NULL)   {     ColumnData columnData[]  = {       {"Value", 500, XmALIGNMENT_BEGINNING},      };     RowData rowData[]  = {     {"DateTime",          160, XmALIGNMENT_BEGINNING},     {"IFADDR family",     0, XmALIGNMENT_BEGINNING},     {"IFADDR prefixlen",  0, XmALIGNMENT_BEGINNING},     {"IFADDR flags",      0, XmALIGNMENT_BEGINNING},     {"IFADDR scope",      0, XmALIGNMENT_BEGINNING},     {"IFADDR index",      0, XmALIGNMENT_BEGINNING},     {"IFA_ADDRESS",       0, XmALIGNMENT_BEGINNING},     {"IFA_LOCAL",         0, XmALIGNMENT_BEGINNING},     {"IFA_LABEL",         0, XmALIGNMENT_BEGINNING},     {"IFA_BROADCAST",     0, XmALIGNMENT_BEGINNING},     {"IFA_ANYCAST",       0, XmALIGNMENT_BEGINNING},     {"IFA_CACHEINFO",     0, XmALIGNMENT_BEGINNING},     {"IFA_MULTICAST",     0, XmALIGNMENT_BEGINNING},     };     int numColumns = XtNumber(columnData);     int numRows    = XtNumber(rowData);     Args ar;     ar.set(XmNtableNumColumns, numColumns);     ar.set(XmNtableColumnData, (XtArgVal)columnData);     ar.set(XmNtableNumRows, numRows);     ar.set(XmNtableRowData, (XtArgVal)rowData);     table = new TableView(this, "", ar);     table -> removeAllItems();     watcher = new IPAddressWatcher(this);     watcher -> start();   }      ~MainView()    {     watcher -> cancel();     watcher -> wait();     model.clear();   } }; } // int main(int argc, char** argv) {   XInitThreads(); //2015/06/10   try {     const char*  appclass = argv[0];     Application applet(appclass, argc, argv);     Args args;     args.set(XmNgeometry, "700x300");     MainView view(applet, argv[0], args);          view.realize();     applet.run();        } catch (Exception& ex) {     caught(ex);    }   return 0; }