You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdeadmin/kpackage/procbuf.cpp

166 lines
3.4 KiB

/*
** Copyright (C) 1999,2000 Toivo Pedaste <toivo@ucs.uwa.edu.au>
**
*/
/*
** This program is free software; you can redistribute it and/or modify
** it under the terms of the GNU General Public License as published by
** the Free Software Foundation; either version 2 of the License, or
** (at your option) any later version.
**
** This program is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
** GNU General Public License for more details.
**
** You should have received a copy of the GNU General Public License
** along with this program in a file called COPYING; if not, write to
** the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
** MA 02110-1301, USA.
*/
/*
** Bug reports and questions can be sent to kde-devel@kde.org
*/
#include "../config.h"
#include "procbuf.h"
#include <kprocess.h>
#include "kpackage.h"
#include <tdelocale.h>
#include <tqlabel.h>
#include <kdebug.h>
Modal::Modal(TQString msg, TQWidget *parent, const char * name )
: KDialog( parent, name, TRUE )
{
TQLabel *line1 = new TQLabel(msg,this);
line1->setAlignment(AlignCenter);
line1->setAutoResize(true);
}
void Modal::terminate()
{
done(0);
}
procbuf::procbuf()
{
m = NULL;
tm = new TQTimer(this);
connect(tm, TQT_SIGNAL(timeout()), this, TQT_SLOT(slotTimeout()));
}
procbuf::~procbuf()
{
}
void procbuf::setup(TQString cmd)
{
buf.truncate(0);
proc = new TDEProcess();
connect(proc, TQT_SIGNAL( receivedStdout(TDEProcess *, char *, int)),
this, TQT_SLOT(slotReadInfo(TDEProcess *, char *, int)));
connect(proc, TQT_SIGNAL( receivedStderr(TDEProcess *, char *, int)),
this, TQT_SLOT(slotReadInfo(TDEProcess *, char *, int)));
connect(proc, TQT_SIGNAL( processExited(TDEProcess *)),
this, TQT_SLOT(slotExited(TDEProcess *)));
proc->clearArguments();
*proc << cmd;
command = cmd;
}
void procbuf::slotReadInfo(TDEProcess *, char *buffer, int buflen)
{
char last;
last = buffer[buflen - 1];
buffer[buflen - 1] = 0;
buf += buffer;
buf += last;
if (timed) {
timed = FALSE;
tm->stop();
}
}
void procbuf::slotExited(TDEProcess *)
{
if (m) {
m->terminate();
}
if (timed) {
timed = FALSE;
tm->stop();
}
}
void procbuf::slotTimeout()
{
if (m) {
m->terminate();
}
// kdDebug() << "TTT\n";
}
int procbuf::start (TQString msg, bool errorDlg,
int timeout, TQString timeMsg )
{
if (timeout) {
tm->start(timeout*1000, TRUE);
timed = true;
}
if (!proc->start(!msg.isNull() ? TDEProcess::NotifyOnExit : TDEProcess::Block,
TDEProcess::All)) {
if (errorDlg) {
KpMsgE(i18n("Kprocess Failure"),TRUE);
}
return 0;
};
if (!msg.isEmpty()) {
m = new Modal(msg,kpkg, "wait");
m->exec();
delete m;
m = 0;
}
kdDebug() << command
<< " dialog=" << errorDlg
<< " normal=" << proc->normalExit()
<< " exit=" << proc->exitStatus() << endl;
if (timed) {
kdDebug() << "timeout..................\n";
KpMsg("Error",i18n("Timeout: %1").arg(timeMsg), TRUE);
delete proc; proc = 0;
return 0;
} else {
if (!proc->normalExit() || proc->exitStatus()) {
if (errorDlg) {
KpMsg("Error",i18n("Kprocess error:%1").arg(buf), TRUE);
}
delete proc; proc = 0;
return 0;
}
}
delete proc; proc = 0;
return 1;
}
#include "procbuf.moc"