tests/fswatcher/fswatchertest.cpp

   1 ///////////////////////////////////////////////////////////////////////////////
   2 // Name:        tests/fswatcher/fswatchertest.cpp
   3 // Purpose:     wxFileSystemWatcher unit test
   4 // Author:      Bartosz Bekier
   5 // Created:     2009-06-11
   6 // RCS-ID:      $Id$
   7 // Copyright:   (c) 2009 Bartosz Bekier
   8 ///////////////////////////////////////////////////////////////////////////////
   9
  10 // ----------------------------------------------------------------------------
  11 // headers
  12 // ----------------------------------------------------------------------------
  13
  14 #include "testprec.h"
  15
  16 #ifdef __BORLANDC__
  17     #pragma hdrstop
  18 #endif
  19
  20 #ifndef WX_PRECOMP
  21     #include "wx/timer.h"
  22 #endif
  23
  24 #include "wx/evtloop.h"
  25 #include "wx/filename.h"
  26 #include "wx/filefn.h"
  27 #include "wx/stdpaths.h"
  28 #include "wx/fswatcher.h"
  29
  30 #include "testfile.h"
  31
  32 // ----------------------------------------------------------------------------
  33 // local functions
  34 // ----------------------------------------------------------------------------
  35
  36 // class generating file system events
  37 class EventGenerator
  38 {
  39 public:
  40     static EventGenerator& Get()
  41     {
  42         if (!ms_instance)
  43             ms_instance = new EventGenerator(GetWatchDir());
  44
  45         return *ms_instance;
  46     }
  47
  48     EventGenerator(const wxFileName& path) : m_base(path)
  49     {
  50         m_old = wxFileName();
  51         m_file = RandomName();
  52         m_new = RandomName();
  53     }
  54
  55     // operations
  56     bool CreateFile()
  57     {
  58         wxFile file(m_file.GetFullPath(), wxFile::write);
  59         return file.IsOpened() && m_file.FileExists();
  60     }
  61
  62     bool RenameFile()
  63     {
  64         CPPUNIT_ASSERT(m_file.FileExists());
  65
  66         wxLogDebug("Renaming %s=>%s", m_file.GetFullPath(), m_new.GetFullPath());
  67
  68         bool ret = wxRenameFile(m_file.GetFullPath(), m_new.GetFullPath());
  69         if (ret)
  70         {
  71             m_old = m_file;
  72             m_file = m_new;
  73             m_new = RandomName();
  74         }
  75
  76         return ret;
  77     }
  78
  79     bool DeleteFile()
  80     {
  81         CPPUNIT_ASSERT(m_file.FileExists());
  82
  83         bool ret =  wxRemoveFile(m_file.GetFullPath());
  84         if (ret)
  85         {
  86             m_old = m_file;
  87             m_file = m_new;
  88             m_new = RandomName();
  89         }
  90
  91         return ret;
  92     }
  93
  94     bool TouchFile()
  95     {
  96         return m_file.Touch();
  97     }
  98
  99     bool ReadFile()
 100     {
 101         wxFile f(m_file.GetFullPath());
 102         CPPUNIT_ASSERT(f.IsOpened());
 103
 104         char buf[1];
 105         ssize_t count = f.Read(buf, sizeof(buf));
 106         CPPUNIT_ASSERT(count > 0);
 107
 108         return true;
 109     }
 110
 111     bool ModifyFile()
 112     {
 113         CPPUNIT_ASSERT(m_file.FileExists());
 114
 115         wxFile file(m_file.GetFullPath(), wxFile::write_append);
 116         CPPUNIT_ASSERT(file.IsOpened());
 117
 118         CPPUNIT_ASSERT(file.Write("Words of Wisdom, Lloyd. Words of wisdom\n"));
 119         return file.Close();
 120     }
 121
 122     // helpers
 123     wxFileName RandomName(int length = 10)
 124     {
 125         return RandomName(m_base, length);
 126     }
 127
 128     // static helpers
 129     static const wxFileName& GetWatchDir()
 130     {
 131         static wxFileName dir;
 132
 133         if (dir.DirExists())
 134             return dir;
 135
 136         wxString tmp = wxStandardPaths::Get().GetTempDir();
 137         dir.AssignDir(tmp);
 138
 139         // XXX look for more unique name? there is no function to generate
 140         // unique filename, the file always get created...
 141         dir.AppendDir("fswatcher_test");
 142         CPPUNIT_ASSERT(!dir.DirExists());
 143         CPPUNIT_ASSERT(dir.Mkdir());
 144
 145         return dir;
 146     }
 147
 148     static void RemoveWatchDir()
 149     {
 150         wxFileName dir = GetWatchDir();
 151         CPPUNIT_ASSERT(dir.DirExists());
 152
 153         // just to be really sure we know what we remove
 154         CPPUNIT_ASSERT_EQUAL( "fswatcher_test", dir.GetDirs().Last() );
 155
 156         // FIXME-VC6: using non-static Rmdir() results in ICE
 157         CPPUNIT_ASSERT( wxFileName::Rmdir(dir.GetFullPath(), wxPATH_RMDIR_RECURSIVE) );
 158     }
 159
 160     static wxFileName RandomName(const wxFileName& base, int length = 10)
 161     {
 162         static int ALFA_CNT = 'z' - 'a';
 163
 164         wxString s;
 165         for (int i = 0 ; i < length; ++i)
 166         {
 167             char c = 'a' + (rand() % ALFA_CNT);
 168             s += c;
 169         }
 170
 171         return wxFileName(base.GetFullPath(), s);
 172     }
 173
 174 public:
 175     wxFileName m_base;     // base dir for doing operations
 176     wxFileName m_file;     // current file name
 177     wxFileName m_old;      // previous file name
 178     wxFileName m_new;      // name after renaming
 179
 180 protected:
 181     static EventGenerator* ms_instance;
 182 };
 183
 184 EventGenerator* EventGenerator::ms_instance = 0;
 185
 186
 187 // custom event handler
 188 class EventHandler : public wxEvtHandler
 189 {
 190 public:
 191     enum { WAIT_DURATION = 3 };
 192
 193     EventHandler() :
 194         eg(EventGenerator::Get()), m_loop(0), m_count(0), m_watcher(0)
 195     {
 196         m_loop = new wxEventLoop();
 197         Connect(wxEVT_IDLE, wxIdleEventHandler(EventHandler::OnIdle));
 198         Connect(wxEVT_FSWATCHER, wxFileSystemWatcherEventHandler(
 199                                             EventHandler::OnFileSystemEvent));
 200     }
 201
 202     virtual ~EventHandler()
 203     {
 204         delete m_watcher;
 205         if (m_loop)
 206         {
 207             if (m_loop->IsRunning())
 208                 m_loop->Exit();
 209             delete m_loop;
 210         }
 211     }
 212
 213     void Exit()
 214     {
 215         m_loop->Exit();
 216     }
 217
 218     // sends idle event, so we get called in a moment
 219     void SendIdle()
 220     {
 221         wxIdleEvent* e = new wxIdleEvent();
 222         QueueEvent(e);
 223     }
 224
 225     void Run()
 226     {
 227         SendIdle();
 228         m_loop->Run();
 229     }
 230
 231     void OnIdle(wxIdleEvent& /*evt*/)
 232     {
 233         bool more = Action();
 234         m_count++;
 235
 236         if (more)
 237         {
 238             SendIdle();
 239         }
 240     }
 241
 242     // returns whether we should produce more idle events
 243     virtual bool Action()
 244     {
 245         switch (m_count)
 246         {
 247         case 0:
 248             CPPUNIT_ASSERT(Init());
 249             break;
 250         case 1:
 251             GenerateEvent();
 252             break;
 253         case 2:
 254             // actual test
 255             CheckResult();
 256             Exit();
 257             break;
 258
 259         // TODO a mechanism that will break the loop in case we
 260         // don't receive a file system event
 261         // this below doesn't quite work, so all tests must pass :-)
 262 #if 0
 263         case 2:
 264             m_loop.Yield();
 265             m_loop.WakeUp();
 266             CPPUNIT_ASSERT(KeepWaiting());
 267             m_loop.Yield();
 268             break;
 269         case 3:
 270             break;
 271         case 4:
 272             CPPUNIT_ASSERT(AfterWait());
 273             break;
 274 #endif
 275         } // switch (m_count)
 276
 277         return m_count <= 0;
 278     }
 279
 280     virtual bool Init()
 281     {
 282         // test we're good to go
 283         CPPUNIT_ASSERT(wxEventLoopBase::GetActive());
 284
 285         // XXX only now can we construct Watcher, because we need
 286         // active loop here
 287         m_watcher = new wxFileSystemWatcher();
 288         m_watcher->SetOwner(this);
 289
 290         // add dir to be watched
 291         wxFileName dir = EventGenerator::GetWatchDir();
 292         CPPUNIT_ASSERT(m_watcher->Add(dir, wxFSW_EVENT_ALL));
 293
 294         return true;
 295     }
 296
 297     virtual bool KeepWaiting()
 298     {
 299         // did we receive event already?
 300         if (!tested)
 301         {
 302             // well, let's wait a bit more
 303             wxSleep(WAIT_DURATION);
 304         }
 305
 306         return true;
 307     }
 308
 309     virtual bool AfterWait()
 310     {
 311         // fail if still no events
 312         WX_ASSERT_MESSAGE
 313         (
 314              ("No events during %d seconds!", static_cast<int>(WAIT_DURATION)),
 315              tested
 316         );
 317
 318         return true;
 319     }
 320
 321     virtual void OnFileSystemEvent(wxFileSystemWatcherEvent& evt)
 322     {
 323         wxLogDebug("--- %s ---", evt.ToString());
 324         m_lastEvent = wxDynamicCast(evt.Clone(), wxFileSystemWatcherEvent);
 325         m_events.Add(m_lastEvent);
 326
 327         // test finished
 328         SendIdle();
 329         tested = true;
 330     }
 331
 332     virtual void CheckResult()
 333     {
 334         CPPUNIT_ASSERT_MESSAGE( "No events received", !m_events.empty() );
 335
 336         const wxFileSystemWatcherEvent * const e = m_events.front();
 337
 338         // this is our "reference event"
 339         const wxFileSystemWatcherEvent expected = ExpectedEvent();
 340
 341         CPPUNIT_ASSERT_EQUAL( expected.GetChangeType(), e->GetChangeType() );
 342
 343         CPPUNIT_ASSERT_EQUAL((int)wxEVT_FSWATCHER, e->GetEventType());
 344
 345         // XXX this needs change
 346         CPPUNIT_ASSERT_EQUAL(wxEVT_CATEGORY_UNKNOWN, e->GetEventCategory());
 347
 348         CPPUNIT_ASSERT_EQUAL(expected.GetPath(), e->GetPath());
 349         CPPUNIT_ASSERT_EQUAL(expected.GetNewPath(), e->GetNewPath());
 350
 351         WX_ASSERT_EQUAL_MESSAGE
 352         (
 353             (
 354                 "Extra events received, last one is of type %x, path=\"%s\" "
 355                 "(the original event was for \"%s\" (\"%s\")",
 356                 m_events.back()->GetChangeType(),
 357                 m_events.back()->GetPath().GetFullPath(),
 358                 e->GetPath().GetFullPath(),
 359                 e->GetNewPath().GetFullPath()
 360             ),
 361             1, m_events.size()
 362         );
 363
 364     }
 365
 366     virtual void GenerateEvent() = 0;
 367
 368     virtual wxFileSystemWatcherEvent ExpectedEvent() = 0;
 369
 370
 371 protected:
 372     EventGenerator& eg;
 373     wxEventLoopBase* m_loop;    // loop reference
 374     int m_count;                // idle events count
 375
 376     wxFileSystemWatcher* m_watcher;
 377     bool tested;  // indicates, whether we have already passed the test
 378
 379     #include "wx/arrimpl.cpp"
 380     WX_DEFINE_ARRAY_PTR(wxFileSystemWatcherEvent*, wxArrayEvent);
 381     wxArrayEvent m_events;
 382     wxFileSystemWatcherEvent* m_lastEvent;
 383 };
 384
 385
 386 // ----------------------------------------------------------------------------
 387 // test class
 388 // ----------------------------------------------------------------------------
 389
 390 class FileSystemWatcherTestCase : public CppUnit::TestCase
 391 {
 392 public:
 393     FileSystemWatcherTestCase() { }
 394
 395     virtual void setUp();
 396     virtual void tearDown();
 397
 398 protected:
 399     wxEventLoopBase* m_loop;
 400
 401 private:
 402     CPPUNIT_TEST_SUITE( FileSystemWatcherTestCase );
 403         CPPUNIT_TEST( TestEventCreate );
 404         CPPUNIT_TEST( TestEventDelete );
 405
 406         // kqueue-based implementation doesn't collapse create/delete pairs in
 407         // renames and doesn't detect neither modifications nor access to the
 408         // files reliably currently so disable these tests
 409         //
 410         // FIXME: fix the code and reenable them
 411 #ifndef wxHAS_KQUEUE
 412         CPPUNIT_TEST( TestEventRename );
 413         CPPUNIT_TEST( TestEventModify );
 414
 415         // MSW implementation doesn't detect file access events currently
 416 #ifndef __WXMSW__
 417         CPPUNIT_TEST( TestEventAccess );
 418 #endif // __WXMSW__
 419 #endif // !wxHAS_KQUEUE
 420
 421         CPPUNIT_TEST( TestNoEventsAfterRemove );
 422     CPPUNIT_TEST_SUITE_END();
 423
 424     void TestEventCreate();
 425     void TestEventDelete();
 426     void TestEventRename();
 427     void TestEventModify();
 428     void TestEventAccess();
 429
 430     void TestNoEventsAfterRemove();
 431
 432     DECLARE_NO_COPY_CLASS(FileSystemWatcherTestCase)
 433 };
 434
 435 // the test currently hangs under OS X for some reason and this prevents tests
 436 // ran by buildbot from completing so disable it until someone has time to
 437 // debug it
 438 //
 439 // FIXME: debug and fix this!
 440 #ifndef __WXOSX__
 441 // register in the unnamed registry so that these tests are run by default
 442 CPPUNIT_TEST_SUITE_REGISTRATION( FileSystemWatcherTestCase );
 443 #endif
 444
 445 // also include in its own registry so that these tests can be run alone
 446 CPPUNIT_TEST_SUITE_NAMED_REGISTRATION( FileSystemWatcherTestCase,
 447                                         "FileSystemWatcherTestCase" );
 448
 449 void FileSystemWatcherTestCase::setUp()
 450 {
 451     wxLog::AddTraceMask(wxTRACE_FSWATCHER);
 452     EventGenerator::Get().GetWatchDir();
 453 }
 454
 455 void FileSystemWatcherTestCase::tearDown()
 456 {
 457     EventGenerator::Get().RemoveWatchDir();
 458 }
 459
 460 // ----------------------------------------------------------------------------
 461 // TestEventCreate
 462 // ----------------------------------------------------------------------------
 463 void FileSystemWatcherTestCase::TestEventCreate()
 464 {
 465     wxLogDebug("TestEventCreate()");
 466
 467     class EventTester : public EventHandler
 468     {
 469     public:
 470         virtual void GenerateEvent()
 471         {
 472             CPPUNIT_ASSERT(eg.CreateFile());
 473         }
 474
 475         virtual wxFileSystemWatcherEvent ExpectedEvent()
 476         {
 477             wxFileSystemWatcherEvent event(wxFSW_EVENT_CREATE);
 478             event.SetPath(eg.m_file);
 479             event.SetNewPath(eg.m_file);
 480             return event;
 481         }
 482     };
 483
 484     EventTester tester;
 485
 486     wxLogTrace(wxTRACE_FSWATCHER, "TestEventCreate tester created()");
 487
 488     tester.Run();
 489 }
 490
 491 // ----------------------------------------------------------------------------
 492 // TestEventDelete
 493 // ----------------------------------------------------------------------------
 494 void FileSystemWatcherTestCase::TestEventDelete()
 495 {
 496     wxLogDebug("TestEventDelete()");
 497
 498     class EventTester : public EventHandler
 499     {
 500     public:
 501         virtual void GenerateEvent()
 502         {
 503             CPPUNIT_ASSERT(eg.DeleteFile());
 504         }
 505
 506         virtual wxFileSystemWatcherEvent ExpectedEvent()
 507         {
 508             wxFileSystemWatcherEvent event(wxFSW_EVENT_DELETE);
 509             event.SetPath(eg.m_old);
 510
 511             // CHECK maybe new path here could be NULL or sth?
 512             event.SetNewPath(eg.m_old);
 513             return event;
 514         }
 515     };
 516
 517     // we need to create a file now, so we can delete it
 518     EventGenerator::Get().CreateFile();
 519
 520     EventTester tester;
 521     tester.Run();
 522 }
 523
 524 // ----------------------------------------------------------------------------
 525 // TestEventRename
 526 // ----------------------------------------------------------------------------
 527 void FileSystemWatcherTestCase::TestEventRename()
 528 {
 529     wxLogDebug("TestEventRename()");
 530
 531     class EventTester : public EventHandler
 532     {
 533     public:
 534         virtual void GenerateEvent()
 535         {
 536             CPPUNIT_ASSERT(eg.RenameFile());
 537         }
 538
 539         virtual wxFileSystemWatcherEvent ExpectedEvent()
 540         {
 541             wxFileSystemWatcherEvent event(wxFSW_EVENT_RENAME);
 542             event.SetPath(eg.m_old);
 543             event.SetNewPath(eg.m_file);
 544             return event;
 545         }
 546     };
 547
 548     // need a file to rename later
 549     EventGenerator::Get().CreateFile();
 550
 551     EventTester tester;
 552     tester.Run();
 553 }
 554
 555 // ----------------------------------------------------------------------------
 556 // TestEventModify
 557 // ----------------------------------------------------------------------------
 558 void FileSystemWatcherTestCase::TestEventModify()
 559 {
 560     wxLogDebug("TestEventModify()");
 561
 562     class EventTester : public EventHandler
 563     {
 564     public:
 565         virtual void GenerateEvent()
 566         {
 567             CPPUNIT_ASSERT(eg.ModifyFile());
 568         }
 569
 570         virtual wxFileSystemWatcherEvent ExpectedEvent()
 571         {
 572             wxFileSystemWatcherEvent event(wxFSW_EVENT_MODIFY);
 573             event.SetPath(eg.m_file);
 574             event.SetNewPath(eg.m_file);
 575             return event;
 576         }
 577     };
 578
 579     // we need to create a file to modify
 580     EventGenerator::Get().CreateFile();
 581
 582     EventTester tester;
 583     tester.Run();
 584 }
 585
 586 // ----------------------------------------------------------------------------
 587 // TestEventAccess
 588 // ----------------------------------------------------------------------------
 589 void FileSystemWatcherTestCase::TestEventAccess()
 590 {
 591     wxLogDebug("TestEventAccess()");
 592
 593     class EventTester : public EventHandler
 594     {
 595     public:
 596         virtual void GenerateEvent()
 597         {
 598             CPPUNIT_ASSERT(eg.ReadFile());
 599         }
 600
 601         virtual wxFileSystemWatcherEvent ExpectedEvent()
 602         {
 603             wxFileSystemWatcherEvent event(wxFSW_EVENT_ACCESS);
 604             event.SetPath(eg.m_file);
 605             event.SetNewPath(eg.m_file);
 606             return event;
 607         }
 608     };
 609
 610     // we need to create a file to read from it and write sth to it
 611     EventGenerator::Get().CreateFile();
 612     EventGenerator::Get().ModifyFile();
 613
 614     EventTester tester;
 615     tester.Run();
 616 }
 617
 618 namespace
 619 {
 620
 621 // We can't define this class locally inside TestNoEventsAfterRemove() for some
 622 // reason with g++ 4.0 under OS X 10.5, it results in the following mysterious
 623 // error:
 624 //
 625 // /var/tmp//ccTkNCkc.s:unknown:Non-global symbol:
 626 // __ZThn80_ZN25FileSystemWatcherTestCase23TestNoEventsAfterRemoveEvEN11EventTester6NotifyEv.eh
 627 // can't be a weak_definition
 628 //
 629 // So define this class outside the function instead.
 630 class NoEventsAfterRemoveEventTester : public EventHandler,
 631                                        public wxTimer
 632 {
 633 public:
 634     NoEventsAfterRemoveEventTester()
 635     {
 636         // We need to use an inactivity timer as we never get any file
 637         // system events in this test, so we consider that the test is
 638         // finished when this 1s timeout expires instead of, as usual,
 639         // stopping after getting the file system events.
 640         Start(1000, true);
 641     }
 642
 643     virtual void GenerateEvent()
 644     {
 645         m_watcher->Remove(EventGenerator::GetWatchDir());
 646         CPPUNIT_ASSERT(eg.CreateFile());
 647     }
 648
 649     virtual void CheckResult()
 650     {
 651         CPPUNIT_ASSERT( m_events.empty() );
 652     }
 653
 654     virtual wxFileSystemWatcherEvent ExpectedEvent()
 655     {
 656         CPPUNIT_FAIL( "Shouldn't be called" );
 657
 658         return wxFileSystemWatcherEvent(wxFSW_EVENT_ERROR);
 659     }
 660
 661     virtual void Notify()
 662     {
 663         SendIdle();
 664     }
 665 };
 666
 667 } // anonymous namespace
 668
 669 void FileSystemWatcherTestCase::TestNoEventsAfterRemove()
 670 {
 671     NoEventsAfterRemoveEventTester tester;
 672     tester.Run();
 673 }