FileSynchronize.h

/*
 * File:   ServersFileSysc.h
 * Author: root
 *
 * Created on 2009年12月21日, 下午1:29
 */
#include <string>
#include "Initialize.h"
#include "Interface.h"
#include "main.h"
#include <boost/shared_ptr.hpp>
#ifndef _SERVERSFILESYSC_H
#define _SERVERSFILESYSC_H

class FileSynchronize
{
public:
    static std::string m_plugin;
    ptrInitialize m_init;
    ptrQFilter m_qf;
    ptrQRetry m_qr;
    static std::string watch;
    static std::vector<ptrRmtServer> rmtServers;
    static int m_crontab;
    static int sleep_group;                     // 用于统计当前处于sleep状态的线程数量
    static boost::condition_variable work_cond; // 工作条件对象
    static boost::mutex worklock;               // 用于统计工作线程数量的锁定
    static std::string m_users;
    static std::string m_password;
    static std::string m_delete;
    static vector<string> cfilter;
    static int firstflag;
    static std::string ssh;
    static std::string port;
    static std::string file_name;
    static int time;
    static bool debug;
    static string timeout;
    static string params;

public:
    FileSynchronize(ptrInitialize init, ptrQFilter qf, ptrQRetry qr);
    static int XmlParse(ptrInitialize init);
    void ThreadAwaken();
    static bool RsyncOnce();

protected:
    static std::string StrEscaped(std::string); // escaped the '$' in the path
    static std::string AddExclude();
    static void ExecuteScript(std::string file_name);
    static void *ServerSyncThread(ptrQFilter qf, ptrQRetry qr, ptrInterface itf);
    static void *RsyncThread(ptrQRetry qr, Event event, std::string ip, std::string module, std::string watch);
    static void *QueueRetryThread(ptrQRetry qr);
    static std::string DelPathCombine(std::string str, bool dir);
};

#endif /* _SERVERSFILESYSC_H */