summaryrefslogtreecommitdiff
authorzecke <zecke>2002-10-12 00:30:06 (UTC)
committer zecke <zecke>2002-10-12 00:30:06 (UTC)
commit0a3ffe7e5657bed4cb77d9bc23457755e2d02591 (patch) (side-by-side diff)
treea1b83e61035433668ca5c9e3af31586880535c98
parentffa7f45a2100b7c438a437fce2d3a47608bd36e3 (diff)
downloadopie-0a3ffe7e5657bed4cb77d9bc23457755e2d02591.zip
opie-0a3ffe7e5657bed4cb77d9bc23457755e2d02591.tar.gz
opie-0a3ffe7e5657bed4cb77d9bc23457755e2d02591.tar.bz2
This is targetted to the people telling
in computer science classes that I'm toolkit dependant This is a Process Controller which will be used to work around the limit of only beeing able to do one FileTransfer at a Time
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--noncore/apps/opie-console/filetransfer.cpp3
-rw-r--r--noncore/apps/opie-console/opie-console.pro4
-rw-r--r--noncore/apps/opie-console/procctl.cpp90
-rw-r--r--noncore/apps/opie-console/procctl.h33
4 files changed, 125 insertions, 5 deletions
diff --git a/noncore/apps/opie-console/filetransfer.cpp b/noncore/apps/opie-console/filetransfer.cpp
index 7b75d35..7fd9f37 100644
--- a/noncore/apps/opie-console/filetransfer.cpp
+++ b/noncore/apps/opie-console/filetransfer.cpp
@@ -191,55 +191,52 @@ void FileTransfer::slotRead() {
}
/*
* find the progress
*/
void FileTransfer::slotProgress( const QStringList& list ) {
bool complete = true;
int min, sec;
int bps;
unsigned long sent, total;
min = sec = bps = -1;
sent = total = 0;
// Data looks like this
// 0 1 2 3 4 5
// Bytes Sent 65536/11534336 BPS:7784 ETA 24:33
QStringList progi = QStringList::split('/', list[2].simplifyWhiteSpace() );
sent = progi[0].toULong(&complete );
if (!complete ) return;
total = progi[1].toULong(&complete );
if (!complete || total == 0) {
- qWarning("returning!!");
return;
}
qWarning("%s, %d, %d", progi.join("/").latin1(), sent, total );
double pro = (double)sent/total;
int prog = pro * 100;
// speed
progi = QStringList::split(':', list[3].simplifyWhiteSpace() );
bps = progi[1].toInt();
// time
progi = QStringList::split(':', list[5].simplifyWhiteSpace() );
min = progi[0].toInt();
sec = progi[1].toInt();
- qWarning("Prog!:%d", prog );
if ( prog > m_prog ) {
m_prog = prog;
emit progress(m_file, m_prog, bps, -1, min , sec );
- qWarning("Progress: %s, %d\%, %d, %d:%d", m_file.latin1(), m_prog, bps, min, sec );
}
}
void FileTransfer::cancel() {
::kill(m_pid,9 );
delete m_not;
}
diff --git a/noncore/apps/opie-console/opie-console.pro b/noncore/apps/opie-console/opie-console.pro
index 37cef92..9208042 100644
--- a/noncore/apps/opie-console/opie-console.pro
+++ b/noncore/apps/opie-console/opie-console.pro
@@ -6,59 +6,59 @@ HEADERS = io_layer.h io_serial.h io_irda.h \
file_layer.h filetransfer.h \
metafactory.h \
session.h \
mainwindow.h \
profile.h \
profileconfig.h \
profilemanager.h \
configwidget.h \
tabwidget.h \
configdialog.h \
emulation_layer.h \
vt102emulation.h \
common.h \
history.h \
screen.h \
keytrans.h \
widget_layer.h \
transferdialog.h \
profiledialogwidget.h \
profileeditordialog.h \
default.h \
terminalwidget.h \
iolayerbase.h \
serialconfigwidget.h irdaconfigwidget.h btconfigwidget.h \
- emulation_widget.h
+ emulation_widget.h procctl.h
SOURCES = io_layer.cpp io_serial.cpp io_irda.cpp \
file_layer.cpp filetransfer.cpp \
main.cpp \
metafactory.cpp \
session.cpp \
mainwindow.cpp \
profile.cpp \
profileconfig.cpp \
profilemanager.cpp \
tabwidget.cpp \
configdialog.cpp \
emulation_layer.cpp \
vt102emulation.cpp \
history.cpp \
screen.cpp \
keytrans.cpp \
widget_layer.cpp \
transferdialog.cpp \
profiledialogwidget.cpp \
profileeditordialog.cpp \
default.cpp \
terminalwidget.cpp \
iolayerbase.cpp \
serialconfigwidget.cpp irdaconfigwidget.cpp btconfigwidget.cpp \
- emulation_widget.cpp
+ emulation_widget.cpp procctl.cpp
INTERFACES = configurebase.ui editbase.ui
INCLUDEPATH += $(OPIEDIR)/include
DEPENDPATH += $(OPIEDIR)/include
LIBS += -lqpe -lopie
TARGET = opie-console
diff --git a/noncore/apps/opie-console/procctl.cpp b/noncore/apps/opie-console/procctl.cpp
new file mode 100644
index 0000000..6839a84
--- a/dev/null
+++ b/noncore/apps/opie-console/procctl.cpp
@@ -0,0 +1,90 @@
+#include <sys/wait.h>
+
+#include <fcntl.h>
+#include <unistd.h>
+
+#include "procctl.h"
+
+ProcContainer *ProcCtl::m_last = 0;
+
+ProcCtl::ProcCtl() {
+ signal( SIGCHLD, signal_handler );
+}
+ProcCtl::~ProcCtl() {
+}
+void ProcCtl::add(pid_t pi, int fd ) {
+ ProcContainer * con = new ProcContainer;
+ //memset(con, 0, sizeof(con) );
+ con->pid = pi;
+ con->fd = fd;
+ con->status = 0;
+ con->prev = m_last;
+
+ m_last = con;
+
+}
+void ProcCtl::remove( pid_t pi ) {
+ /*
+ * We first check if the last item
+ * is equal to pi the we
+ *
+ */
+ ProcContainer* con;
+ if (m_last->pid == pi ) {
+ con = m_last;
+ m_last = con->prev;
+ delete con;
+ return;
+ }
+
+ con = m_last;
+ ProcContainer* forw = 0l;
+ while (con ) {
+ /* remove it */
+ if ( pi == con->pid ) {
+ forw->prev = con->prev;
+ delete con;
+ return;
+ }
+
+ forw = con;
+ con = con->prev;
+ }
+
+}
+void ProcCtl::remove( ProcContainer con ) {
+ remove( con.pid );
+}
+int ProcCtl::status(pid_t pid )const{
+ ProcContainer *con = m_last;
+ while (con) {
+ if (con->pid == pid )
+ return con->status;
+ con = con->prev;
+ }
+ return -1;
+}
+void ProcCtl::signal_handler(int) {
+ int status;
+ signal( SIGCHLD, signal_handler );
+ pid_t pi = waitpid( -1, &status, WNOHANG );
+
+ /*
+ * find the container for pid
+ *
+ */
+ if ( pi < 0 ) {
+ return;
+ }
+
+ ProcContainer* con = m_last;
+ while (con) {
+ if ( con->pid == pi ) {
+ con->status = status;
+ char result = 1;
+ /* give a 'signal' */
+ ::write(con->fd, &result, 1 );
+ }
+ con = con->prev;
+ }
+}
diff --git a/noncore/apps/opie-console/procctl.h b/noncore/apps/opie-console/procctl.h
new file mode 100644
index 0000000..e2161f3
--- a/dev/null
+++ b/noncore/apps/opie-console/procctl.h
@@ -0,0 +1,33 @@
+#ifndef OPIE_PROC_CTL_H
+#define OPIE_PROC_CTL_H
+
+#include <sys/types.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <signal.h>
+
+#include <qmap.h>
+
+
+struct ProcContainer {
+ pid_t pid;
+ int fd;
+ int status;
+ ProcContainer* prev;
+};
+
+class ProcCtl {
+public:
+ ProcCtl();
+ ~ProcCtl();
+
+ int status(pid_t)const;
+ void add( pid_t, int fd );
+ void remove( pid_t );
+ void remove( ProcContainer );
+private:
+ static void signal_handler(int);
+ static ProcContainer* m_last;
+};
+
+#endif