author | mickeyl <mickeyl> | 2004-03-24 00:20:42 (UTC) |
---|---|---|
committer | mickeyl <mickeyl> | 2004-03-24 00:20:42 (UTC) |
commit | cc2fd242ec29023784748e6c9d662cb1f89e83ec (patch) (unidiff) | |
tree | 55fa7676f1c64607e9a9327c2b206dd3a95625a4 | |
parent | f08adf125dbaa2a411fad9fba22443c7364afca3 (diff) | |
download | opie-cc2fd242ec29023784748e6c9d662cb1f89e83ec.zip opie-cc2fd242ec29023784748e6c9d662cb1f89e83ec.tar.gz opie-cc2fd242ec29023784748e6c9d662cb1f89e83ec.tar.bz2 |
convert to libopie2
-rw-r--r-- | core/qws/config.in | 13 | ||||
-rw-r--r-- | core/qws/oqwsserver.cpp | 2 | ||||
-rw-r--r-- | core/qws/oqwsserver.h | 2 | ||||
-rw-r--r-- | core/qws/qws.pro | 4 | ||||
-rw-r--r-- | core/qws/transferserver.cpp | 47 | ||||
-rw-r--r-- | core/qws/transferserver.h | 15 |
6 files changed, 37 insertions, 46 deletions
diff --git a/core/qws/config.in b/core/qws/config.in index 3706405..903eaa1 100644 --- a/core/qws/config.in +++ b/core/qws/config.in | |||
@@ -1,16 +1,5 @@ | |||
1 | config QWS | 1 | config QWS |
2 | boolean "Minimal QWS Server" | 2 | boolean "Minimal QWS Server" |
3 | default "n" | 3 | default "n" |
4 | depends ( LIBQPE || LIBQPE-X11 ) && LIBOPIE && EXPERIMENTAL | 4 | depends ( LIBQPE || LIBQPE-X11 ) && LIBOPIE2CORE && LIBOPIE2UI && EXPERIMENTAL |
5 | 5 | ||
6 | # menu "Advanced QWS Server Config" | ||
7 | # config QWS_QCOP | ||
8 | # bool "QCop bridge and Transfer server (sync)" | ||
9 | # default y | ||
10 | # depends on QWS | ||
11 | # | ||
12 | # config QWS_PACKAGE | ||
13 | # bool "Package Slave (package installs via sync software)" | ||
14 | # default n | ||
15 | # depends on QWS | ||
16 | # endmenu | ||
diff --git a/core/qws/oqwsserver.cpp b/core/qws/oqwsserver.cpp index 907686a..d6b6504 100644 --- a/core/qws/oqwsserver.cpp +++ b/core/qws/oqwsserver.cpp | |||
@@ -20,25 +20,25 @@ | |||
20 | 20 | ||
21 | #include <syslog.h> | 21 | #include <syslog.h> |
22 | 22 | ||
23 | #include "oqwsserver.h" | 23 | #include "oqwsserver.h" |
24 | #include "qcopbridge.h" | 24 | #include "qcopbridge.h" |
25 | #include "transferserver.h" | 25 | #include "transferserver.h" |
26 | 26 | ||
27 | 27 | ||
28 | #if defined( QT_QWS_SL5XXX ) || defined( QT_QWS_IPAQ ) | 28 | #if defined( QT_QWS_SL5XXX ) || defined( QT_QWS_IPAQ ) |
29 | #include <qpe/custom.h> | 29 | #include <qpe/custom.h> |
30 | #endif | 30 | #endif |
31 | 31 | ||
32 | #include <opie/odevice.h> | 32 | #include <opie2/odevice.h> |
33 | 33 | ||
34 | 34 | ||
35 | 35 | ||
36 | #include <stdlib.h> | 36 | #include <stdlib.h> |
37 | #include <unistd.h> | 37 | #include <unistd.h> |
38 | #include <fcntl.h> | 38 | #include <fcntl.h> |
39 | 39 | ||
40 | using namespace Opie; | 40 | using namespace Opie; |
41 | 41 | ||
42 | OQWSServer::OQWSServer( int& argc, char **argv, Type appType ) | 42 | OQWSServer::OQWSServer( int& argc, char **argv, Type appType ) |
43 | : QPEApplication( argc, argv, appType ) | 43 | : QPEApplication( argc, argv, appType ) |
44 | { | 44 | { |
diff --git a/core/qws/oqwsserver.h b/core/qws/oqwsserver.h index b95c3fb..c8622d4 100644 --- a/core/qws/oqwsserver.h +++ b/core/qws/oqwsserver.h | |||
@@ -14,25 +14,25 @@ | |||
14 | ** See http://www.trolltech.com/gpl/ for GPL licensing information. | 14 | ** See http://www.trolltech.com/gpl/ for GPL licensing information. |
15 | ** | 15 | ** |
16 | ** Contact info@trolltech.com if any conditions of this licensing are | 16 | ** Contact info@trolltech.com if any conditions of this licensing are |
17 | ** not clear to you. | 17 | ** not clear to you. |
18 | ** | 18 | ** |
19 | **********************************************************************/ | 19 | **********************************************************************/ |
20 | 20 | ||
21 | #ifndef __DESKTOP_H__ | 21 | #ifndef __DESKTOP_H__ |
22 | #define __DESKTOP_H__ | 22 | #define __DESKTOP_H__ |
23 | 23 | ||
24 | 24 | ||
25 | #include <qpe/qpeapplication.h> | 25 | #include <qpe/qpeapplication.h> |
26 | #include <opie/odevicebutton.h> | 26 | #include <opie2/odevicebutton.h> |
27 | 27 | ||
28 | #include <qwidget.h> | 28 | #include <qwidget.h> |
29 | #include <qdatetime.h> | 29 | #include <qdatetime.h> |
30 | 30 | ||
31 | class QCopBridge; | 31 | class QCopBridge; |
32 | class TransferServer; | 32 | class TransferServer; |
33 | 33 | ||
34 | class OQWSServer : public QPEApplication | 34 | class OQWSServer : public QPEApplication |
35 | { | 35 | { |
36 | Q_OBJECT | 36 | Q_OBJECT |
37 | public: | 37 | public: |
38 | OQWSServer( int& argc, char **argv, Type t ); | 38 | OQWSServer( int& argc, char **argv, Type t ); |
diff --git a/core/qws/qws.pro b/core/qws/qws.pro index 5656a59..50d0b2b 100644 --- a/core/qws/qws.pro +++ b/core/qws/qws.pro | |||
@@ -5,16 +5,16 @@ DESTDIR = $(OPIEDIR)/bin | |||
5 | HEADERS = \ | 5 | HEADERS = \ |
6 | transferserver.h \ | 6 | transferserver.h \ |
7 | qcopbridge.h \ | 7 | qcopbridge.h \ |
8 | oqwsserver.h | 8 | oqwsserver.h |
9 | SOURCES = \ | 9 | SOURCES = \ |
10 | main.cpp \ | 10 | main.cpp \ |
11 | transferserver.cpp \ | 11 | transferserver.cpp \ |
12 | qcopbridge.cpp \ | 12 | qcopbridge.cpp \ |
13 | oqwsserver.cpp | 13 | oqwsserver.cpp |
14 | 14 | ||
15 | INCLUDEPATH+= $(OPIEDIR)/include | 15 | INCLUDEPATH+= $(OPIEDIR)/include |
16 | DEPENDPATH+= $(OPIEDIR)/include . | 16 | DEPENDPATH+= $(OPIEDIR)/include . |
17 | TARGET = op-qws | 17 | TARGET = qws |
18 | LIBS += -lqpe -lopie | 18 | LIBS += -lqpe -lopiecore2 -lopieui2 |
19 | 19 | ||
20 | include ( $(OPIEDIR)/include.pro ) | 20 | include ( $(OPIEDIR)/include.pro ) |
diff --git a/core/qws/transferserver.cpp b/core/qws/transferserver.cpp index daf63ec..d0fec89 100644 --- a/core/qws/transferserver.cpp +++ b/core/qws/transferserver.cpp | |||
@@ -55,25 +55,26 @@ extern "C" | |||
55 | 55 | ||
56 | #include <qtextstream.h> | 56 | #include <qtextstream.h> |
57 | #include <qmessagebox.h> | 57 | #include <qmessagebox.h> |
58 | //#include <qpe/qcopchannel_qws.h> | 58 | //#include <qpe/qcopchannel_qws.h> |
59 | #include <qpe/process.h> | 59 | #include <qpe/process.h> |
60 | #include <qpe/global.h> | 60 | #include <qpe/global.h> |
61 | #include <qpe/config.h> | 61 | #include <qpe/config.h> |
62 | #include <qpe/contact.h> | 62 | #include <qpe/contact.h> |
63 | #include <qpe/version.h> | 63 | #include <qpe/version.h> |
64 | #include <qpe/qcopenvelope_qws.h> | 64 | #include <qpe/qcopenvelope_qws.h> |
65 | 65 | ||
66 | #include "transferserver.h" | 66 | #include "transferserver.h" |
67 | #include <opie/oprocess.h> | 67 | #include <opie2/oprocess.h> |
68 | using namespace Opie::Core; | ||
68 | 69 | ||
69 | const int block_size = 51200; | 70 | const int block_size = 51200; |
70 | 71 | ||
71 | TransferServer::TransferServer( Q_UINT16 port, QObject *parent , | 72 | TransferServer::TransferServer( Q_UINT16 port, QObject *parent , |
72 | const char* name ) | 73 | const char* name ) |
73 | : QServerSocket( port, 1, parent, name ) | 74 | : QServerSocket( port, 1, parent, name ) |
74 | { | 75 | { |
75 | if ( !ok() ) | 76 | if ( !ok() ) |
76 | qWarning( "Failed to bind to port %d", port ); | 77 | qWarning( "Failed to bind to port %d", port ); |
77 | } | 78 | } |
78 | 79 | ||
79 | TransferServer::~TransferServer() | 80 | TransferServer::~TransferServer() |
@@ -1040,37 +1041,37 @@ void ServerPI::timerEvent( QTimerEvent * ) | |||
1040 | 1041 | ||
1041 | 1042 | ||
1042 | ServerDTP::ServerDTP( QObject *parent, const char* name) | 1043 | ServerDTP::ServerDTP( QObject *parent, const char* name) |
1043 | : QSocket( parent, name ), mode( Idle ), createTargzProc( 0 ), | 1044 | : QSocket( parent, name ), mode( Idle ), createTargzProc( 0 ), |
1044 | retrieveTargzProc( 0 ), gzipProc( 0 ) | 1045 | retrieveTargzProc( 0 ), gzipProc( 0 ) |
1045 | { | 1046 | { |
1046 | 1047 | ||
1047 | connect( this, SIGNAL( connected() ), SLOT( connected() ) ); | 1048 | connect( this, SIGNAL( connected() ), SLOT( connected() ) ); |
1048 | connect( this, SIGNAL( connectionClosed() ), SLOT( connectionClosed() ) ); | 1049 | connect( this, SIGNAL( connectionClosed() ), SLOT( connectionClosed() ) ); |
1049 | connect( this, SIGNAL( bytesWritten(int) ), SLOT( bytesWritten(int) ) ); | 1050 | connect( this, SIGNAL( bytesWritten(int) ), SLOT( bytesWritten(int) ) ); |
1050 | connect( this, SIGNAL( readyRead() ), SLOT( readyRead() ) ); | 1051 | connect( this, SIGNAL( readyRead() ), SLOT( readyRead() ) ); |
1051 | 1052 | ||
1052 | gzipProc = new OProcess( this, "gzipProc" ); | 1053 | gzipProc = new Opie::Core::OProcess( this, "gzipProc" ); |
1053 | 1054 | ||
1054 | createTargzProc = new OProcess( QString("tar"), this, "createTargzProc"); | 1055 | createTargzProc = new Opie::Core::OProcess( QString("tar"), this, "createTargzProc"); |
1055 | createTargzProc->setWorkingDirectory( QDir::rootDirPath() ); | 1056 | createTargzProc->setWorkingDirectory( QDir::rootDirPath() ); |
1056 | connect( createTargzProc, SIGNAL( processExited(OProcess*) ), SLOT( targzDone() ) ); | 1057 | connect( createTargzProc, SIGNAL( processExited(Opie::Core::OProcess*) ), SLOT( targzDone() ) ); |
1057 | 1058 | ||
1058 | QStringList args = "tar"; | 1059 | QStringList args = "tar"; |
1059 | args += "-xv"; | 1060 | args += "-xv"; |
1060 | retrieveTargzProc = new OProcess( args, this, "retrieveTargzProc" ); | 1061 | retrieveTargzProc = new Opie::Core::OProcess( args, this, "retrieveTargzProc" ); |
1061 | retrieveTargzProc->setWorkingDirectory( QDir::rootDirPath() ); | 1062 | retrieveTargzProc->setWorkingDirectory( QDir::rootDirPath() ); |
1062 | connect( retrieveTargzProc, SIGNAL( processExited(OProcess*) ), | 1063 | connect( retrieveTargzProc, SIGNAL( processExited(Opie::Core::OProcess*) ), |
1063 | SIGNAL( completed() ) ); | 1064 | SIGNAL( completed() ) ); |
1064 | connect( retrieveTargzProc, SIGNAL( processExited(OProcess*) ), | 1065 | connect( retrieveTargzProc, SIGNAL( processExited(Opie::Core::OProcess*) ), |
1065 | SLOT( extractTarDone() ) ); | 1066 | SLOT( extractTarDone() ) ); |
1066 | } | 1067 | } |
1067 | 1068 | ||
1068 | ServerDTP::~ServerDTP() | 1069 | ServerDTP::~ServerDTP() |
1069 | { | 1070 | { |
1070 | buf.close(); | 1071 | buf.close(); |
1071 | file.close(); | 1072 | file.close(); |
1072 | createTargzProc->kill(); | 1073 | createTargzProc->kill(); |
1073 | } | 1074 | } |
1074 | 1075 | ||
1075 | void ServerDTP::extractTarDone() | 1076 | void ServerDTP::extractTarDone() |
1076 | { | 1077 | { |
@@ -1112,25 +1113,25 @@ void ServerDTP::connected() | |||
1112 | } | 1113 | } |
1113 | } | 1114 | } |
1114 | break; | 1115 | break; |
1115 | case SendGzipFile: | 1116 | case SendGzipFile: |
1116 | if ( createTargzProc->isRunning() ) { | 1117 | if ( createTargzProc->isRunning() ) { |
1117 | // SHOULDN'T GET HERE, BUT DOING A SAFETY CHECK ANYWAY | 1118 | // SHOULDN'T GET HERE, BUT DOING A SAFETY CHECK ANYWAY |
1118 | qWarning("Previous tar --gzip process is still running; killing it..."); | 1119 | qWarning("Previous tar --gzip process is still running; killing it..."); |
1119 | createTargzProc->kill(); | 1120 | createTargzProc->kill(); |
1120 | } | 1121 | } |
1121 | 1122 | ||
1122 | bytes_written = 0; | 1123 | bytes_written = 0; |
1123 | qDebug("==>start send tar process"); | 1124 | qDebug("==>start send tar process"); |
1124 | if ( !createTargzProc->start(OProcess::NotifyOnExit, OProcess::Stdout) ) | 1125 | if ( !createTargzProc->start(Opie::Core::OProcess::NotifyOnExit, Opie::Core::OProcess::Stdout) ) |
1125 | qWarning("Error starting %s or %s", | 1126 | qWarning("Error starting %s or %s", |
1126 | createTargzProc->args()[0].data(), | 1127 | createTargzProc->args()[0].data(), |
1127 | gzipProc->args()[0].data()); | 1128 | gzipProc->args()[0].data()); |
1128 | break; | 1129 | break; |
1129 | case SendBuffer: | 1130 | case SendBuffer: |
1130 | if ( !buf.open( IO_ReadOnly) ) { | 1131 | if ( !buf.open( IO_ReadOnly) ) { |
1131 | emit failed(); | 1132 | emit failed(); |
1132 | mode = Idle; | 1133 | mode = Idle; |
1133 | return ; | 1134 | return ; |
1134 | } | 1135 | } |
1135 | 1136 | ||
1136 | // qDebug( "Debug: Sending byte array" ); | 1137 | // qDebug( "Debug: Sending byte array" ); |
@@ -1247,68 +1248,68 @@ void ServerDTP::bytesWritten( int bytes ) | |||
1247 | 1248 | ||
1248 | void ServerDTP::readyRead() | 1249 | void ServerDTP::readyRead() |
1249 | { | 1250 | { |
1250 | // retrieve file mode | 1251 | // retrieve file mode |
1251 | if ( RetrieveFile == mode ) { | 1252 | if ( RetrieveFile == mode ) { |
1252 | QCString s; | 1253 | QCString s; |
1253 | s.resize( bytesAvailable() ); | 1254 | s.resize( bytesAvailable() ); |
1254 | readBlock( s.data(), bytesAvailable() ); | 1255 | readBlock( s.data(), bytesAvailable() ); |
1255 | file.writeBlock( s.data(), s.size() ); | 1256 | file.writeBlock( s.data(), s.size() ); |
1256 | } | 1257 | } |
1257 | else if ( RetrieveGzipFile == mode ) { | 1258 | else if ( RetrieveGzipFile == mode ) { |
1258 | if ( !gzipProc->isRunning() ) | 1259 | if ( !gzipProc->isRunning() ) |
1259 | gzipProc->start(OProcess::NotifyOnExit, (OProcess::Communication) ( OProcess::Stdin | OProcess::Stdout )); | 1260 | gzipProc->start(Opie::Core::OProcess::NotifyOnExit, (Opie::Core::OProcess::Communication) ( Opie::Core::OProcess::Stdin | Opie::Core::OProcess::Stdout )); |
1260 | 1261 | ||
1261 | QByteArray s; | 1262 | QByteArray s; |
1262 | s.resize( bytesAvailable() ); | 1263 | s.resize( bytesAvailable() ); |
1263 | readBlock( s.data(), bytesAvailable() ); | 1264 | readBlock( s.data(), bytesAvailable() ); |
1264 | gzipProc->writeStdin( s.data(), s.size() ); | 1265 | gzipProc->writeStdin( s.data(), s.size() ); |
1265 | qDebug("wrote %d bytes to ungzip ", s.size() ); | 1266 | qDebug("wrote %d bytes to ungzip ", s.size() ); |
1266 | } | 1267 | } |
1267 | // retrieve buffer mode | 1268 | // retrieve buffer mode |
1268 | else if ( RetrieveBuffer == mode ) { | 1269 | else if ( RetrieveBuffer == mode ) { |
1269 | QCString s; | 1270 | QCString s; |
1270 | s.resize( bytesAvailable() ); | 1271 | s.resize( bytesAvailable() ); |
1271 | readBlock( s.data(), bytesAvailable() ); | 1272 | readBlock( s.data(), bytesAvailable() ); |
1272 | buf.writeBlock( s.data(), s.size() ); | 1273 | buf.writeBlock( s.data(), s.size() ); |
1273 | } | 1274 | } |
1274 | } | 1275 | } |
1275 | 1276 | ||
1276 | void ServerDTP::writeTargzBlock(OProcess *, char *buffer, int buflen) | 1277 | void ServerDTP::writeTargzBlock(Opie::Core::OProcess *, char *buffer, int buflen) |
1277 | { | 1278 | { |
1278 | writeBlock( buffer, buflen ); | 1279 | writeBlock( buffer, buflen ); |
1279 | qDebug("writeTargzBlock %d", buflen); | 1280 | qDebug("writeTargzBlock %d", buflen); |
1280 | if ( !createTargzProc->isRunning() ) { | 1281 | if ( !createTargzProc->isRunning() ) { |
1281 | qDebug("tar and gzip done"); | 1282 | qDebug("tar and gzip done"); |
1282 | emit completed(); | 1283 | emit completed(); |
1283 | mode = Idle; | 1284 | mode = Idle; |
1284 | disconnect( gzipProc, SIGNAL( receivedStdout(OProcess*,char*,int) ), | 1285 | disconnect( gzipProc, SIGNAL( receivedStdout(Opie::Core::OProcess*,char*,int) ), |
1285 | this, SLOT( writeTargzBlock(OProcess*,char*,int) ) ); | 1286 | this, SLOT( writeTargzBlock(Opie::Core::OProcess*,char*,int) ) ); |
1286 | } | 1287 | } |
1287 | } | 1288 | } |
1288 | 1289 | ||
1289 | void ServerDTP::targzDone() | 1290 | void ServerDTP::targzDone() |
1290 | { | 1291 | { |
1291 | //qDebug("targz done"); | 1292 | //qDebug("targz done"); |
1292 | disconnect( createTargzProc, SIGNAL( receivedStdout(OProcess*,char*,int) ), | 1293 | disconnect( createTargzProc, SIGNAL( receivedStdout(Opie::Core::OProcess*,char*,int) ), |
1293 | this, SLOT( gzipTarBlock(OProcess*,char*,int) ) ); | 1294 | this, SLOT( gzipTarBlock(Opie::Core::OProcess*,char*,int) ) ); |
1294 | gzipProc->closeStdin(); | 1295 | gzipProc->closeStdin(); |
1295 | } | 1296 | } |
1296 | 1297 | ||
1297 | void ServerDTP::gzipTarBlock(OProcess *, char *buffer, int buflen) | 1298 | void ServerDTP::gzipTarBlock(Opie::Core::OProcess *, char *buffer, int buflen) |
1298 | { | 1299 | { |
1299 | //qDebug("gzipTarBlock"); | 1300 | //qDebug("gzipTarBlock"); |
1300 | if ( !gzipProc->isRunning() ) { | 1301 | if ( !gzipProc->isRunning() ) { |
1301 | //qDebug("auto start gzip proc"); | 1302 | //qDebug("auto start gzip proc"); |
1302 | gzipProc->start(OProcess::NotifyOnExit, (OProcess::Communication) ( OProcess::Stdin | OProcess::Stdout )); | 1303 | gzipProc->start(Opie::Core::OProcess::NotifyOnExit, (Opie::Core::OProcess::Communication) ( Opie::Core::OProcess::Stdin | Opie::Core::OProcess::Stdout )); |
1303 | } | 1304 | } |
1304 | gzipProc->writeStdin( buffer, buflen ); | 1305 | gzipProc->writeStdin( buffer, buflen ); |
1305 | } | 1306 | } |
1306 | 1307 | ||
1307 | void ServerDTP::sendFile( const QString fn, const QHostAddress& host, Q_UINT16 port ) | 1308 | void ServerDTP::sendFile( const QString fn, const QHostAddress& host, Q_UINT16 port ) |
1308 | { | 1309 | { |
1309 | file.setName( fn ); | 1310 | file.setName( fn ); |
1310 | mode = SendFile; | 1311 | mode = SendFile; |
1311 | connectToHost( host.toString(), port ); | 1312 | connectToHost( host.toString(), port ); |
1312 | } | 1313 | } |
1313 | 1314 | ||
1314 | void ServerDTP::sendFile( const QString fn ) | 1315 | void ServerDTP::sendFile( const QString fn ) |
@@ -1329,48 +1330,48 @@ void ServerDTP::sendGzipFile( const QString &fn, | |||
1329 | const QStringList &archiveTargets ) | 1330 | const QStringList &archiveTargets ) |
1330 | { | 1331 | { |
1331 | mode = SendGzipFile; | 1332 | mode = SendGzipFile; |
1332 | file.setName( fn ); | 1333 | file.setName( fn ); |
1333 | 1334 | ||
1334 | QStringList args = "tar"; | 1335 | QStringList args = "tar"; |
1335 | args += "-cv"; | 1336 | args += "-cv"; |
1336 | args += archiveTargets; | 1337 | args += archiveTargets; |
1337 | qDebug("sendGzipFile %s", args.join(" ").latin1() ); | 1338 | qDebug("sendGzipFile %s", args.join(" ").latin1() ); |
1338 | createTargzProc->clearArguments( ); | 1339 | createTargzProc->clearArguments( ); |
1339 | *createTargzProc << args; | 1340 | *createTargzProc << args; |
1340 | connect( createTargzProc, | 1341 | connect( createTargzProc, |
1341 | SIGNAL( receivedStdout(OProcess*,char*,int) ), SLOT( gzipTarBlock(OProcess*,char*,int) ) ); | 1342 | SIGNAL( receivedStdout(Opie::Core::OProcess*,char*,int) ), SLOT( gzipTarBlock(Opie::Core::OProcess*,char*,int) ) ); |
1342 | 1343 | ||
1343 | gzipProc->clearArguments( ); | 1344 | gzipProc->clearArguments( ); |
1344 | *gzipProc << "gzip"; | 1345 | *gzipProc << "gzip"; |
1345 | connect( gzipProc, SIGNAL( receivedStdout(OProcess*,char*,int) ), | 1346 | connect( gzipProc, SIGNAL( receivedStdout(Opie::Core::OProcess*,char*,int) ), |
1346 | SLOT( writeTargzBlock(OProcess*,char*,int) ) ); | 1347 | SLOT( writeTargzBlock(Opie::Core::OProcess*,char*,int) ) ); |
1347 | } | 1348 | } |
1348 | 1349 | ||
1349 | void ServerDTP::gunzipDone() | 1350 | void ServerDTP::gunzipDone() |
1350 | { | 1351 | { |
1351 | qDebug("gunzipDone"); | 1352 | qDebug("gunzipDone"); |
1352 | disconnect( gzipProc, SIGNAL( processExited() ), | 1353 | disconnect( gzipProc, SIGNAL( processExited() ), |
1353 | this, SLOT( gunzipDone() ) ); | 1354 | this, SLOT( gunzipDone() ) ); |
1354 | retrieveTargzProc->closeStdin(); | 1355 | retrieveTargzProc->closeStdin(); |
1355 | disconnect( gzipProc, SIGNAL( receivedStdout(OProcess*,char*,int) ), | 1356 | disconnect( gzipProc, SIGNAL( receivedStdout(Opie::Core::OProcess*,char*,int) ), |
1356 | this, SLOT( tarExtractBlock(OProcess*,char*,int) ) ); | 1357 | this, SLOT( tarExtractBlock(Opie::Core::OProcess*,char*,int) ) ); |
1357 | } | 1358 | } |
1358 | 1359 | ||
1359 | void ServerDTP::tarExtractBlock(OProcess *, char *buffer, int buflen) | 1360 | void ServerDTP::tarExtractBlock(Opie::Core::OProcess *, char *buffer, int buflen) |
1360 | { | 1361 | { |
1361 | qDebug("tarExtractBlock"); | 1362 | qDebug("tarExtractBlock"); |
1362 | if ( !retrieveTargzProc->isRunning() ) { | 1363 | if ( !retrieveTargzProc->isRunning() ) { |
1363 | qDebug("auto start ungzip proc"); | 1364 | qDebug("auto start ungzip proc"); |
1364 | if ( !retrieveTargzProc->start(OProcess::NotifyOnExit, OProcess::Stdin) ) | 1365 | if ( !retrieveTargzProc->start(Opie::Core::OProcess::NotifyOnExit, Opie::Core::OProcess::Stdin) ) |
1365 | qWarning(" failed to start tar -x process"); | 1366 | qWarning(" failed to start tar -x process"); |
1366 | } | 1367 | } |
1367 | retrieveTargzProc->writeStdin( buffer, buflen ); | 1368 | retrieveTargzProc->writeStdin( buffer, buflen ); |
1368 | } | 1369 | } |
1369 | 1370 | ||
1370 | 1371 | ||
1371 | void ServerDTP::retrieveFile( const QString fn, const QHostAddress& host, Q_UINT16 port ) | 1372 | void ServerDTP::retrieveFile( const QString fn, const QHostAddress& host, Q_UINT16 port ) |
1372 | { | 1373 | { |
1373 | file.setName( fn ); | 1374 | file.setName( fn ); |
1374 | mode = RetrieveFile; | 1375 | mode = RetrieveFile; |
1375 | connectToHost( host.toString(), port ); | 1376 | connectToHost( host.toString(), port ); |
1376 | } | 1377 | } |
diff --git a/core/qws/transferserver.h b/core/qws/transferserver.h index 1c5ab4b..82dae40 100644 --- a/core/qws/transferserver.h +++ b/core/qws/transferserver.h | |||
@@ -15,25 +15,26 @@ | |||
15 | ** | 15 | ** |
16 | ** Contact info@trolltech.com if any conditions of this licensing are | 16 | ** Contact info@trolltech.com if any conditions of this licensing are |
17 | ** not clear to you. | 17 | ** not clear to you. |
18 | ** | 18 | ** |
19 | **********************************************************************/ | 19 | **********************************************************************/ |
20 | #include <qserversocket.h> | 20 | #include <qserversocket.h> |
21 | #include <qsocket.h> | 21 | #include <qsocket.h> |
22 | #include <qdir.h> | 22 | #include <qdir.h> |
23 | #include <qfile.h> | 23 | #include <qfile.h> |
24 | #include <qbuffer.h> | 24 | #include <qbuffer.h> |
25 | 25 | ||
26 | class QFileInfo; | 26 | class QFileInfo; |
27 | class OProcess; | 27 | namespace Opie { namespace Core { class OProcess; } } |
28 | |||
28 | class TransferServer : public QServerSocket | 29 | class TransferServer : public QServerSocket |
29 | { | 30 | { |
30 | Q_OBJECT | 31 | Q_OBJECT |
31 | 32 | ||
32 | public: | 33 | public: |
33 | TransferServer( Q_UINT16 port, QObject *parent = 0, const char* name = 0 ); | 34 | TransferServer( Q_UINT16 port, QObject *parent = 0, const char* name = 0 ); |
34 | virtual ~TransferServer(); | 35 | virtual ~TransferServer(); |
35 | 36 | ||
36 | void newConnection( int socket ); | 37 | void newConnection( int socket ); |
37 | }; | 38 | }; |
38 | 39 | ||
39 | class SyncAuthentication : QObject | 40 | class SyncAuthentication : QObject |
@@ -83,41 +84,41 @@ public: | |||
83 | 84 | ||
84 | void setSocket( int socket ); | 85 | void setSocket( int socket ); |
85 | 86 | ||
86 | signals: | 87 | signals: |
87 | void completed(); | 88 | void completed(); |
88 | void failed(); | 89 | void failed(); |
89 | 90 | ||
90 | private slots: | 91 | private slots: |
91 | void connectionClosed(); | 92 | void connectionClosed(); |
92 | void connected(); | 93 | void connected(); |
93 | void bytesWritten( int bytes ); | 94 | void bytesWritten( int bytes ); |
94 | void readyRead(); | 95 | void readyRead(); |
95 | void writeTargzBlock(OProcess *, char *, int); | 96 | void writeTargzBlock(Opie::Core::OProcess *, char *, int); |
96 | void targzDone(); | 97 | void targzDone(); |
97 | 98 | ||
98 | void gzipTarBlock(OProcess *, char *, int); | 99 | void gzipTarBlock(Opie::Core::OProcess *, char *, int); |
99 | void tarExtractBlock(OProcess *, char *, int); | 100 | void tarExtractBlock(Opie::Core::OProcess *, char *, int); |
100 | void gunzipDone(); | 101 | void gunzipDone(); |
101 | void extractTarDone(); | 102 | void extractTarDone(); |
102 | 103 | ||
103 | private: | 104 | private: |
104 | 105 | ||
105 | unsigned long bytes_written; | 106 | unsigned long bytes_written; |
106 | Mode mode; | 107 | Mode mode; |
107 | QFile file; | 108 | QFile file; |
108 | QBuffer buf; | 109 | QBuffer buf; |
109 | OProcess *createTargzProc; | 110 | Opie::Core::OProcess *createTargzProc; |
110 | OProcess *retrieveTargzProc; | 111 | Opie::Core::OProcess *retrieveTargzProc; |
111 | OProcess *gzipProc; | 112 | Opie::Core::OProcess *gzipProc; |
112 | }; | 113 | }; |
113 | 114 | ||
114 | class ServerSocket : public QServerSocket | 115 | class ServerSocket : public QServerSocket |
115 | { | 116 | { |
116 | Q_OBJECT | 117 | Q_OBJECT |
117 | 118 | ||
118 | public: | 119 | public: |
119 | ServerSocket( Q_UINT16 port, QObject *parent = 0, const char* name = 0 ) | 120 | ServerSocket( Q_UINT16 port, QObject *parent = 0, const char* name = 0 ) |
120 | : QServerSocket( port, 1, parent, name ) {} | 121 | : QServerSocket( port, 1, parent, name ) {} |
121 | 122 | ||
122 | void newConnection( int socket ) { emit newIncomming( socket ); } | 123 | void newConnection( int socket ) { emit newIncomming( socket ); } |
123 | signals: | 124 | signals: |