// **************************************************************************
// * This file is part of the FreeFileSync project. It is distributed under *
// * GNU General Public License: http://www.gnu.org/licenses/gpl.html       *
// * Copyright (C) 2008-2011 ZenJu (zhnmju123 AT gmx.de)                    *
// **************************************************************************
//
#include "check_exist.h"
#include "file_handling.h"
#include "boost_thread_wrap.h" //include <boost/thread.hpp>
#include <boost/shared_ptr.hpp>


/*
#ifdef __MINGW32__
//oh well, nothing is for free...
//https://svn.boost.org/trac/boost/ticket/4258
extern "C" void tss_cleanup_implemented() {};
#endif
*/

namespace
{
typedef Zbase<Zchar, StorageDeepCopy> BasicString; //thread safe string class

template <bool (*testExist)(const Zstring&)>
class ExistenceChecker
{
public:
    ExistenceChecker(const BasicString& filename, const boost::shared_ptr<bool>& isExisting) :
        filename_(filename),       //deep copy: worker thread may run longer than main! avoid shared data
        isExisting_(isExisting) {} //not accessed during thread run

    void operator()()
    {
        *isExisting_ = testExist(filename_.c_str()); //throw()
    }

private:
    const BasicString filename_; //no referencing, 'cause lifetime not known!
    boost::shared_ptr<bool> isExisting_;
};


template <bool (*fun)(const Zstring&)>
util::ResultExist checkExistence(const Zstring& objName, size_t timeout) //timeout in ms
{
    using namespace util;

    boost::shared_ptr<bool> isExisting(new bool(false));

    ExistenceChecker<fun> task(objName.c_str(), isExisting);
    boost::thread worker(task); //note: task is copied => using thread safe string!

    if (worker.timed_join(boost::posix_time::milliseconds(timeout)))
        return *isExisting ? EXISTING_TRUE : EXISTING_FALSE;
    else
        return EXISTING_TIMEOUT;
    /*
    main/worker thread may access different shared_ptr instances safely (even though they have the same target!)
    http://www.boost.org/doc/libs/1_43_0/libs/smart_ptr/shared_ptr.htm?sess=8153b05b34d890e02d48730db1ff7ddc#ThreadSafety
    */

#ifndef _MSC_VER
#warning migrate this at some time...
#endif
    /*
    unfortunately packaged_task/future is not mature enough to be used...
    boost::packaged_task<bool> pt(boost::bind(fun, objName.c_str())); //attention: Zstring is not thread-safe => make deep copy
    boost::unique_future<bool> fut = pt.get_future();

    boost::thread worker(boost::move(pt)); //launch task on a thread

    if (fut.timed_wait(boost::posix_time::milliseconds(timeout)))
        return fut.get() ? EXISTING_TRUE : EXISTING_FALSE;
    else
        return EXISTING_TIMEOUT;
    */
}
}


util::ResultExist util::fileExists(const Zstring& filename, size_t timeout) //timeout in ms
{
    assert(!filename.empty());
    return ::checkExistence<zen::fileExists>(filename, timeout);
}


util::ResultExist util::dirExists(const Zstring& dirname, size_t timeout) //timeout in ms
{
    assert(!dirname.empty());
    return ::checkExistence<zen::dirExists>(dirname, timeout);
}