-rw-r--r-- | korganizer/mainwindow.cpp | 46 | ||||
-rw-r--r-- | korganizer/mainwindow.h | 2 |
2 files changed, 34 insertions, 14 deletions
diff --git a/korganizer/mainwindow.cpp b/korganizer/mainwindow.cpp index 460bbdc..f4ac0d6 100644 --- a/korganizer/mainwindow.cpp +++ b/korganizer/mainwindow.cpp | |||
@@ -2034,8 +2034,8 @@ void MainWindow::getFile(QSocket* socket) | |||
2034 | #endif | 2034 | #endif |
2035 | } | 2035 | } |
2036 | setCaption( i18n("File received - reloading calendar...") ); | 2036 | setCaption( i18n("File received - reloading calendar...") ); |
2037 | file.close(); | ||
2038 | socket->close(); | 2037 | socket->close(); |
2038 | file.close(); | ||
2039 | mView->watchSavedFile(); | 2039 | mView->watchSavedFile(); |
2040 | mView->openCalendar( defaultFileName() ); | 2040 | mView->openCalendar( defaultFileName() ); |
2041 | setCaption( i18n("Easy-Pi-Sync successful!") ); | 2041 | setCaption( i18n("Easy-Pi-Sync successful!") ); |
@@ -2123,7 +2123,7 @@ QString fileName; | |||
2123 | QFile file( fileName ); | 2123 | QFile file( fileName ); |
2124 | if (!file.open( IO_WriteOnly ) ) { | 2124 | if (!file.open( IO_WriteOnly ) ) { |
2125 | setCaption( i18n("Error: Cannot open temp file for write.") ); | 2125 | setCaption( i18n("Error: Cannot open temp file for write.") ); |
2126 | qDebug("Error open calender file for writing: %s",fileName.latin1() ); | 2126 | qDebug("Error open temp calender file for writing: %s",fileName.latin1() ); |
2127 | return ; | 2127 | return ; |
2128 | } | 2128 | } |
2129 | 2129 | ||
@@ -2150,6 +2150,7 @@ QString fileName; | |||
2150 | } | 2150 | } |
2151 | file.close(); | 2151 | file.close(); |
2152 | mCommandSocket->close(); | 2152 | mCommandSocket->close(); |
2153 | // pending: deleting after signal SIGNAL(delayedCloseFinished()) | ||
2153 | //delete mCommandSocket; | 2154 | //delete mCommandSocket; |
2154 | setCaption( i18n("Remote file saved to temp file.") ); | 2155 | setCaption( i18n("Remote file saved to temp file.") ); |
2155 | //mCommandSocket = 0; | 2156 | //mCommandSocket = 0; |
@@ -2181,6 +2182,7 @@ QString fileName; | |||
2181 | } | 2182 | } |
2182 | mCommandSocketFinish->connectToHost( KOPrefs::instance()->mActiveSyncIP, KOPrefs::instance()->mActiveSyncPort.toUInt() ); | 2183 | mCommandSocketFinish->connectToHost( KOPrefs::instance()->mActiveSyncIP, KOPrefs::instance()->mActiveSyncPort.toUInt() ); |
2183 | 2184 | ||
2185 | // pending connect signals connected () and error to new slots | ||
2184 | QString host = KOPrefs::instance()->mActiveSyncIP; | 2186 | QString host = KOPrefs::instance()->mActiveSyncIP; |
2185 | QFile file2( fileName ); | 2187 | QFile file2( fileName ); |
2186 | if (!file2.open( IO_ReadOnly ) ) { | 2188 | if (!file2.open( IO_ReadOnly ) ) { |
@@ -2205,6 +2207,7 @@ QString fileName; | |||
2205 | } | 2207 | } |
2206 | mCommandSocketFinish->close(); | 2208 | mCommandSocketFinish->close(); |
2207 | file.close(); | 2209 | file.close(); |
2210 | // pending: deleting after signal SIGNAL(delayedCloseFinished()) | ||
2208 | //delete ( mCommandSocket); | 2211 | //delete ( mCommandSocket); |
2209 | //mCommandSocket = 0; | 2212 | //mCommandSocket = 0; |
2210 | qDebug("Syncing succesful! "); | 2213 | qDebug("Syncing succesful! "); |
@@ -2491,36 +2494,51 @@ void MainWindow::printCal() | |||
2491 | 2494 | ||
2492 | 2495 | ||
2493 | 2496 | ||
2494 | KServerSocket:: KServerSocket ( Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ){;}; | 2497 | KServerSocket:: KServerSocket ( Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ) |
2498 | { | ||
2499 | |||
2500 | mSocket = 0; | ||
2501 | }; | ||
2495 | 2502 | ||
2496 | void KServerSocket::newConnection ( int socket ) | 2503 | void KServerSocket::newConnection ( int socket ) |
2497 | { | 2504 | { |
2498 | qDebug("KServerSocket:New connection %d ", socket); | 2505 | qDebug("KServerSocket:New connection %d ", socket); |
2499 | QSocket* s = new QSocket( this ); | 2506 | if ( mSocket ) { |
2500 | connect( s, SIGNAL(readyRead()), this, SLOT(readClient()) ); | 2507 | qDebug("KServerSocket::newConnection Socket deleted! "); |
2501 | connect( s, SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); | 2508 | delete mSocket; |
2502 | s->setSocket( socket ); | 2509 | mSocket = 0; |
2510 | } | ||
2511 | mSocket = new QSocket( this ); | ||
2512 | connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); | ||
2513 | connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); | ||
2514 | mSocket->setSocket( socket ); | ||
2503 | } | 2515 | } |
2504 | 2516 | ||
2505 | void KServerSocket::discardClient() | 2517 | void KServerSocket::discardClient() |
2506 | { | 2518 | { |
2507 | qDebug(" KServerSocket::discardClient()"); | 2519 | qDebug(" KServerSocket::discardClient()"); |
2508 | QSocket* socket = (QSocket*)sender(); | 2520 | if ( mSocket ) { |
2509 | delete socket; | 2521 | qDebug("delete "); |
2522 | delete mSocket; | ||
2523 | mSocket = 0; | ||
2524 | } | ||
2510 | //emit endConnect(); | 2525 | //emit endConnect(); |
2511 | } | 2526 | } |
2512 | void KServerSocket::readClient() | 2527 | void KServerSocket::readClient() |
2513 | { | 2528 | { |
2529 | if ( mSocket == 0 ) { | ||
2530 | qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 "); | ||
2531 | return; | ||
2532 | } | ||
2514 | qDebug("KServerSocket readClient()"); | 2533 | qDebug("KServerSocket readClient()"); |
2515 | QSocket* socket = (QSocket*)sender(); | 2534 | if ( mSocket->canReadLine() ) { |
2516 | if ( socket->canReadLine() ) { | 2535 | QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), mSocket->readLine() ); |
2517 | QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), socket->readLine() ); | ||
2518 | qDebug("KServerSocket socket->canReadLine()"); | 2536 | qDebug("KServerSocket socket->canReadLine()"); |
2519 | if ( tokens[0] == "GET" ) { | 2537 | if ( tokens[0] == "GET" ) { |
2520 | emit sendFile( socket ); | 2538 | emit sendFile( mSocket ); |
2521 | } | 2539 | } |
2522 | if ( tokens[0] == "PUT" ) { | 2540 | if ( tokens[0] == "PUT" ) { |
2523 | emit getFile( socket ); | 2541 | emit getFile( mSocket ); |
2524 | } | 2542 | } |
2525 | if ( tokens[0] == "STOP" ) { | 2543 | if ( tokens[0] == "STOP" ) { |
2526 | emit endConnect(); | 2544 | emit endConnect(); |
diff --git a/korganizer/mainwindow.h b/korganizer/mainwindow.h index 7b4fd27..cc656a3 100644 --- a/korganizer/mainwindow.h +++ b/korganizer/mainwindow.h | |||
@@ -38,6 +38,8 @@ signals: | |||
38 | private slots: | 38 | private slots: |
39 | void discardClient(); | 39 | void discardClient(); |
40 | void readClient(); | 40 | void readClient(); |
41 | private : | ||
42 | QSocket* mSocket; | ||
41 | }; | 43 | }; |
42 | 44 | ||
43 | 45 | ||