|
a/src/internfile/mh_exec.cpp |
|
b/src/internfile/mh_exec.cpp |
|
... |
|
... |
| 40 |
// command.
|
40 |
// command.
|
| 41 |
class MEAdv : public ExecCmdAdvise {
|
41 |
class MEAdv : public ExecCmdAdvise {
|
| 42 |
public:
|
42 |
public:
|
| 43 |
MEAdv(int maxsecs) : m_filtermaxseconds(maxsecs) {m_start = time(0L);}
|
43 |
MEAdv(int maxsecs) : m_filtermaxseconds(maxsecs) {m_start = time(0L);}
|
| 44 |
void newData(int n) {
|
44 |
void newData(int n) {
|
| 45 |
LOGDEB1(("MHExec: new data, count %d\n", n));
|
45 |
LOGDEB1(("MHExec:newData(%d)\n", n));
|
|
|
46 |
if (m_filtermaxseconds > 0 &&
|
| 46 |
if (time(0L) - m_start > m_filtermaxseconds) {
|
47 |
time(0L) - m_start > m_filtermaxseconds) {
|
| 47 |
LOGERR(("MimeHandlerExec: filter timeout (%d S)\n",
|
48 |
LOGERR(("MimeHandlerExec: filter timeout (%d S)\n",
|
| 48 |
m_filtermaxseconds));
|
49 |
m_filtermaxseconds));
|
| 49 |
CancelCheck::instance().setCancel();
|
50 |
CancelCheck::instance().setCancel();
|
| 50 |
}
|
51 |
}
|
| 51 |
// If a cancel request was set by the signal handler (or by us
|
52 |
// If a cancel request was set by the signal handler (or by us
|