QFileSystemWatcher Problem

[Dongxd]

I had some problems when I used 'QFileSystemWatcher' to catch the QfileChanged signal. First I created my main class named A and then called a thread named B in A. Then I called a thread C in which I used QFileSystemWatcher to catch signal. But there is a problem that no signal emited. If I use QFileSystemWatcher in thread B, all going well. What' wrong? My OS is RHEL 6.1 Thanks for reply!!!

#include "threaduser.h"
#include "threadd.h"
#include "thread.h"
#include <qprocess.h>
#include <qthreadpool.h>
#include <QFile>
#include <qtextstream.h>
 
Threaduser::Threaduser(QSqlDatabase db,QObject *parent) :
    QThread(parent)
{
    this->db=db;
}
 
void Threaduser::run()
{
    //connect(&fs, SIGNAL(fileChanged(QString)), this, SLOT(changeread(QString)));
    while(1)
    {
        QProcess* pro=new QProcess();
        pro->moveToThread(this);
        pro->startDetached("./getwho.sh");
        QFile f("/tmp/who.txt");//文件名
        f.open(QFile::ReadOnly);
        QTextStream out(&f);
        QString name,address;
        QStringList newname;
        QStringList newaddress;
        //查看用户是否刚刚登录
        while((name=out.readLine())!="")
        {
            QStringList t1=name.split(" ");
            QStringList t2=name.split("(");
            name=t1[0];
            address=t2[1].remove(")");
            if(!newname.contains(name)||!newaddress.contains(address))
            {
                newname.append(name);
                newaddress.append(address);
            }
        }
        QStringList list1=stillin(namelist,newname);//保持仍然在线的进程
        QStringList list2=isout(namelist,newname);//已经推出列表
        QStringList list3=newin(namelist,newname);//新增用户列表
        QStringList list4=stillin(ipaddress,newaddress);//仍然在线用户IP地址列表
        QStringList list5=isout(ipaddress,newaddress);//已经推出用户地址列表
        QStringList list6=newin(ipaddress,newaddress);//新增用户Ip地址列表
        for(int i=0;i<list3.length();i++)//产生新用户开辟新进程
        {
            //向数据库ä¸*写入用户登录
            QString time = gettime();
            QSqlQuery sql;
            sql.prepare("INSERT INTO last (name,time,action,address) VALUES('"+list3[i]+"','"+time+"','login','"+list6[i]+"')");
            sql.exec();
            //开启线程
            Threadd* thread = new Threadd(db,list3[i]);
            thread->start();//start();
            //åŠ å…¥çº¿ç¨‹é˜Ÿåˆ—
            m.append(thread);
            namelist.append(list3[i]);
            ipaddress.append(list6[i]);
            /*QString path="/home/"+list3[i]+"/.bash_history";
            fs.addPath(path);*/
        }
        for(int i=0;i<list2.length();i++)//å…³é—*退出用户的进程
        {
            //向数据库ä¸*写入用户退出
            QString outtime = gettime();
            QSqlQuery msl;
            msl.prepare("INSERT INTO last (name,time,action,address) VALUES('"+list2[i]+"','"+outtime+"','logout','"+list5[i]+"')");
            msl.exec();
            //å…³é—*线程
            for(int k=0;k<m.length();k++)
            {
                if(m[k]->name==list2[i])
                {
                    m[k]->end();
                    m.removeAt(k);
                }
            }
            //从类表ä¸*铲除他丫的
            namelist.removeOne(list2[i]);
            ipaddress.removeOne(list5[i]);
            /*QString rmpath="/home/"+list2[i]+"/.bash_hisotry";
            fs.removePath(rmpath);*/
        }
        sleep(1);
    }
    Thread* thread = new Thread();
    thread->start();//start();
}
 
//仍然在线列表
QStringList Threaduser::stillin(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<b.length();i++)
    {
        for(int j=0;j<a.length();j++)
        {
            if(b[i]==a[j])
            {
                ll.append(b[i]);
                break;
            }
        }
    }
    return ll;
}
 
//刚刚退出列表
QStringList Threaduser::isout(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<b.length();i++)
    {
        a.removeOne(b[i]);
    }
    ll=a;
    return ll;
}
 
//新近登陆列表
QStringList Threaduser::newin(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<a.length();i++)
    {
        b.removeOne(a[i]);
    }
    ll=b;
    return ll;
}
 
//获取当前系统时间
QString Threaduser::gettime()
{
    QDateTime time = QDateTime::currentDateTime();
    QString now = time.toString("yyyy-MM-dd hh:mm:ss");
    return now;
}
/*
void Threaduser::changeread(QString a)
{
     QString path=a;
     QStringList plist=path.split("/");
     QString name=plist[2];
     QFile f(a);
     f.open(QFile::ReadOnly);
     QTextStream out(&f);
     //读取后面两行
     QString action;
     while(1)
     {
         QString s=out.readLine();
         if(s!="")
         {
             action=s;
         }
         else if(s=="")
         {
             break;
         }
     }
     //写入数据库ä¸*
     QString time=gettime();
     QSqlQuery sql;
     sql.prepare("INSERT INTO action (name, time ,action) VALUES('"+name+"','"+time+"','"+action+"')");
     sql.exec();
 
}
*/

#include "threaduser.h"
#include "threadd.h"
#include "thread.h"
#include <qprocess.h>
#include <qthreadpool.h>
#include <QFile>
#include <qtextstream.h>

Threaduser::Threaduser(QSqlDatabase db,QObject *parent) :
    QThread(parent)
{
    this->db=db;
}

void Threaduser::run()
{
    //connect(&fs, SIGNAL(fileChanged(QString)), this, SLOT(changeread(QString)));
    while(1)
    {
        QProcess* pro=new QProcess();
        pro->moveToThread(this);
        pro->startDetached("./getwho.sh");
        QFile f("/tmp/who.txt");//文件名
        f.open(QFile::ReadOnly);
        QTextStream out(&f);
        QString name,address;
        QStringList newname;
        QStringList newaddress;
        //查看用户是否刚刚登录
        while((name=out.readLine())!="")
        {
            QStringList t1=name.split(" ");
            QStringList t2=name.split("(");
            name=t1[0];
            address=t2[1].remove(")");
            if(!newname.contains(name)||!newaddress.contains(address))
            {
                newname.append(name);
                newaddress.append(address);
            }
        }
        QStringList list1=stillin(namelist,newname);//保持仍然在线的进程
        QStringList list2=isout(namelist,newname);//已经推出列表
        QStringList list3=newin(namelist,newname);//新增用户列表
        QStringList list4=stillin(ipaddress,newaddress);//仍然在线用户IP地址列表
        QStringList list5=isout(ipaddress,newaddress);//已经推出用户地址列表
        QStringList list6=newin(ipaddress,newaddress);//新增用户Ip地址列表
        for(int i=0;i<list3.length();i++)//产生新用户开辟新进程
        {
            //向数据库ä¸*写入用户登录
            QString time = gettime();
            QSqlQuery sql;
            sql.prepare("INSERT INTO last (name,time,action,address) VALUES('"+list3[i]+"','"+time+"','login','"+list6[i]+"')");
            sql.exec();
            //开启线程
            Threadd* thread = new Threadd(db,list3[i]);
            thread->start();//start();
            //åŠ å…¥çº¿ç¨‹é˜Ÿåˆ—
            m.append(thread);
            namelist.append(list3[i]);
            ipaddress.append(list6[i]);
            /*QString path="/home/"+list3[i]+"/.bash_history";
            fs.addPath(path);*/
        }
        for(int i=0;i<list2.length();i++)//å…³é—*退出用户的进程
        {
            //向数据库ä¸*写入用户退出
            QString outtime = gettime();
            QSqlQuery msl;
            msl.prepare("INSERT INTO last (name,time,action,address) VALUES('"+list2[i]+"','"+outtime+"','logout','"+list5[i]+"')");
            msl.exec();
            //å…³é—*线程
            for(int k=0;k<m.length();k++)
            {
                if(m[k]->name==list2[i])
                {
                    m[k]->end();
                    m.removeAt(k);
                }
            }
            //从类表ä¸*铲除他丫的
            namelist.removeOne(list2[i]);
            ipaddress.removeOne(list5[i]);
            /*QString rmpath="/home/"+list2[i]+"/.bash_hisotry";
            fs.removePath(rmpath);*/
        }
        sleep(1);
    }
    Thread* thread = new Thread();
    thread->start();//start();
}

//仍然在线列表
QStringList Threaduser::stillin(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<b.length();i++)
    {
        for(int j=0;j<a.length();j++)
        {
            if(b[i]==a[j])
            {
                ll.append(b[i]);
                break;
            }
        }
    }
    return ll;
}

//刚刚退出列表
QStringList Threaduser::isout(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<b.length();i++)
    {
        a.removeOne(b[i]);
    }
    ll=a;
    return ll;
}

//新近登陆列表
QStringList Threaduser::newin(QStringList a,QStringList b)
{
    QStringList ll;
    for(int i=0;i<a.length();i++)
    {
        b.removeOne(a[i]);
    }
    ll=b;
    return ll;
}

//获取当前系统时间
QString Threaduser::gettime()
{
    QDateTime time = QDateTime::currentDateTime();
    QString now = time.toString("yyyy-MM-dd hh:mm:ss");
    return now;
}
/*
void Threaduser::changeread(QString a)
{
     QString path=a;
     QStringList plist=path.split("/");
     QString name=plist[2];
     QFile f(a);
     f.open(QFile::ReadOnly);
     QTextStream out(&f);
     //读取后面两行
     QString action;
     while(1)
     {
         QString s=out.readLine();
         if(s!="")
         {
             action=s;
         }
         else if(s=="")
         {
             break;
         }
     }
     //写入数据库ä¸*
     QString time=gettime();
     QSqlQuery sql;
     sql.prepare("INSERT INTO action (name, time ,action) VALUES('"+name+"','"+time+"','"+action+"')");
     sql.exec();

}
*/

To copy to clipboard, switch view to plain text mode 

#include "threadd.h"
#include <qfilesystemwatcher.h>
#include <qtextstream.h>
#include <qfile.h>
//监控在线用户行为
 
Threadd::Threadd(QSqlDatabase db,QString name,QObject *parent) :
    QThread(parent)
{
    this->name=name;
    this->db=db;
}
 
void Threadd::run()
{
    QString path="D:/123.txt";//"/home/"+name+"/.bash_history";
    fs.addPath(path);
    connect(&fs, SIGNAL(fileChanged(QString)), this, SLOT(changeread(QString)));
}
 
void Threadd::changeread(QString a)
{
    QFile f(a);
    f.open(QFile::ReadOnly);
    QTextStream out(&f);
    //读取后面两行
    QString action;
    while(1)
    {
        QString s=out.readLine();
        if(s!="")
        {
            action=s;
        }
        else if(s=="")
        {
            break;
        }
    }
    //写入数据库ä¸*
    QString time=gettime();
    QSqlQuery sql;
    sql.prepare("INSERT INTO action (name, time ,action) VALUES('"+name+"','"+time+"','"+action+"')");
    sql.exec();
}
 
//强制终æ*¢çº¿ç¨‹
void Threadd::end()
{
    this->terminate();
}
 
QString Threadd::gettime()
{
    QDateTime time = QDateTime::currentDateTime();
    QString now = time.toString("yyyy-MM-dd hh:mm:ss");
    return now;
}

#include "threadd.h"
#include <qfilesystemwatcher.h>
#include <qtextstream.h>
#include <qfile.h>
//监控在线用户行为

Threadd::Threadd(QSqlDatabase db,QString name,QObject *parent) :
    QThread(parent)
{
    this->name=name;
    this->db=db;
}

void Threadd::run()
{
    QString path="D:/123.txt";//"/home/"+name+"/.bash_history";
    fs.addPath(path);
    connect(&fs, SIGNAL(fileChanged(QString)), this, SLOT(changeread(QString)));
}

void Threadd::changeread(QString a)
{
    QFile f(a);
    f.open(QFile::ReadOnly);
    QTextStream out(&f);
    //读取后面两行
    QString action;
    while(1)
    {
        QString s=out.readLine();
        if(s!="")
        {
            action=s;
        }
        else if(s=="")
        {
            break;
        }
    }
    //写入数据库ä¸*
    QString time=gettime();
    QSqlQuery sql;
    sql.prepare("INSERT INTO action (name, time ,action) VALUES('"+name+"','"+time+"','"+action+"')");
    sql.exec();
}

//强制终æ*¢çº¿ç¨‹
void Threadd::end()
{
    this->terminate();
}

QString Threadd::gettime()
{
    QDateTime time = QDateTime::currentDateTime();
    QString now = time.toString("yyyy-MM-dd hh:mm:ss");
    return now;
}

To copy to clipboard, switch view to plain text mode 

[sonulohani]

Could you please share your code? It will give us much more informations on that.

[anda_skoa]

The file system watcher requires a running event loop.

Make sure the thread in which the watcher was created or to which it was moved runs its event loop.
Either by calling exec() in run() or not overwriting run() at all (base implementation runs an event loop).

Btw, some parts of your code do not make any sense.
For example you create a QProcess and then call a static method (startDetached), making the QProcess instance totally unneeded and useless.

Cheers,
_