/home/mhx/git/github/libmoost/test/io/ionotify.cpp

Go to the documentation of this file.

/* vim:set ts=3 sw=3 sts=3 et: */
#include <boost/test/unit_test.hpp>
#include <boost/test/test_tools.hpp>

#include <boost/filesystem.hpp>
#include <boost/thread.hpp>

#include "../../include/moost/io/ionotify.hpp"
#include "../../include/moost/testing/test_directory_creator.hpp"

#include <vector>
#include <fstream>

using namespace moost::io;

BOOST_AUTO_TEST_SUITE( ionotify_test )

struct Fixture
{
   moost::testing::test_directory_creator tdc;


   Fixture()
   {
   }

   ~Fixture()
   {
   }

};

namespace
{
   typedef std::vector<ionotify::file_action> file_actions_t;

   struct functor
   {
      functor(file_actions_t & file_actions) : file_actions(file_actions)
      {
      }

      file_actions_t & file_actions;

      void operator()(ionotify::file_action fa, const std::string & /*path*/)
      {
         if(file_actions.empty() || file_actions.back() != fa)
            file_actions.push_back(fa);
      }
   };
}

BOOST_FIXTURE_TEST_CASE( test_ionotify1, Fixture )
{
   std::string const & fname = tdc.GetFilePath("testfile");

   std::ofstream out(fname.c_str());

   file_actions_t file_actions;
   functor f(file_actions);

   file_actions_t expected;
   expected.push_back(ionotify::CHANGED);
   expected.push_back(ionotify::DELETED);

   ionotify ion;
   ion.insert(fname, f);
   ion.start();

   out << "hello" << std::endl;
   boost::this_thread::sleep(boost::posix_time::seconds(1));
   out << "world" << std::endl;
   boost::this_thread::sleep(boost::posix_time::seconds(1));
   out << "goodnight" << std::endl;
   boost::this_thread::sleep(boost::posix_time::seconds(1));
   out << "vienna" << std::endl;
   boost::this_thread::sleep(boost::posix_time::seconds(1));

   out.close();

   boost::filesystem::remove(fname);

   // Give the IO time to react and trigger the events
   for(size_t x = 0 ; x < 5 && file_actions.size() < expected.size() ;  ++x)
   {
      boost::this_thread::sleep(boost::posix_time::time_duration(0,0,1));
   }

   ion.stop();

// The windows version uses file_watcher and the results are not
// as accurate as inotify so there tests fail in windows :(
#ifndef WIN32
   BOOST_ASSERT(expected == file_actions);
#endif
}


BOOST_FIXTURE_TEST_CASE( test_ionotify2, Fixture )
{
   std::string const & fname = tdc.GetFilePath("testfile");

   std::ofstream out(fname.c_str());

   file_actions_t file_actions;
   functor f(file_actions);

   file_actions_t expected;
   expected.push_back(ionotify::CHANGED);
   expected.push_back(ionotify::DELETED);

   ionotify ion;
   ion.insert(fname, f);
   ion.start();

   out << "hello" << std::endl;
   out << "world" << std::endl;
   out << "goodnight" << std::endl;
   out << "vienna" << std::endl;

   out.close();

   boost::filesystem::remove(fname);

   // Give the IO time to react and trigger the events
   for(int x = 0 ; x < 5 && file_actions.size() < expected.size() ;  ++x)
   {
      boost::this_thread::sleep(boost::posix_time::time_duration(0,0,1));
   }

   ion.stop();

// The windows version uses file_watcher and the results are not
// as accurate as inotify so there tests fail in windows :(
#ifndef WIN32
   BOOST_ASSERT(expected == file_actions);
#endif
}

BOOST_AUTO_TEST_SUITE_END()