| -rw-r--r-- | korganizer/mainwindow.cpp | 178 | ||||
| -rw-r--r-- | korganizer/mainwindow.h | 34 | ||||
| -rw-r--r-- | version | 2 |
3 files changed, 143 insertions, 71 deletions
diff --git a/korganizer/mainwindow.cpp b/korganizer/mainwindow.cpp index 10cb2a2..e4b7869 100644 --- a/korganizer/mainwindow.cpp +++ b/korganizer/mainwindow.cpp @@ -73,4 +73,2 @@ MainWindow::MainWindow( QWidget *parent, const char *name, QString msg) : mPassWordPiSync = "abc"; - mTimerCommandSocket = new QTimer ( this ); - connect( mTimerCommandSocket, SIGNAL ( timeout () ), this, SLOT ( deleteCommandSocket() ) ); #ifdef DESKTOP_VERSION @@ -2105,30 +2103,23 @@ void MainWindow::performQuickQuick() } - if ( !mCommandSocket ) { - mCommandSocket = new QSocket( this ); - // delete mCommandSocket; - //mCommandSocket = new QSocket( this ); - connect( mCommandSocket, SIGNAL(readyRead()), this, SLOT(readFileFromSocket()) ); - connect( mCommandSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteCommandSocket()) ); - } - QString host = KOPrefs::instance()->mActiveSyncIP; - mCommandSocket->connectToHost( host, port ); - QTextStream os( mCommandSocket ); - os.setEncoding( QTextStream::UnicodeUTF8 ); - os << "GET " << mPassWordPiSync << "\r\n"; + mCommandSocket = new KCommandSocket( mPassWordPiSync, port, KOPrefs::instance()->mActiveSyncIP, this ); + connect( mCommandSocket, SIGNAL(commandFinished( bool )), this, SLOT(deleteCommandSocket(bool)) ); setCaption( i18n("Sending request for remote file ...") ); - mTimerCommandSocket->start( 10000 ); - + QString fileName; +#ifdef _WIN32_ + fileName = defaultFileName() +"sync"; +#else + fileName = "/tmp/kopitempfile.ics"; +#endif + mCommandSocket->readFile( fileName ); } -void MainWindow::deleteCommandSocket() +void MainWindow::deleteCommandSocket( bool success) { - if ( !mCommandSocket) + if ( ! success ) { + setCaption( i18n("ERROR:Receiving remote file failed.") ); + // pending : send stop return; - if ( mTimerCommandSocket->isActive () ) { - KMessageBox::information( 0, i18n("ERROR:\nConnection to remote host timed out ")); - mTimerCommandSocket->stop(); + } - //KMessageBox::information( 0, i18n("MainWindow::deleteCommandSocket ")); - qDebug("MainWindow::deletemCommandSocket() "); - delete mCommandSocket; - mCommandSocket = 0; + QTimer::singleShot( 1, this , SLOT ( readFileFromSocket())); + delete mCommandSocket; } @@ -2145,3 +2136,3 @@ void MainWindow::readFileFromSocket() { - mTimerCommandSocket->stop(); + // mTimerCommandSocket->stop(); setCaption( i18n("Receiving remote file ...") ); @@ -2154,36 +2145,3 @@ void MainWindow::readFileFromSocket() #endif - QFile file( fileName ); - if (!file.open( IO_WriteOnly ) ) { - setCaption( i18n("Error: Cannot open temp file for write.") ); - qDebug("Error open temp calender file for writing: %s",fileName.latin1() ); - return ; - } - - //QTextStream os2( mCommandSocket ); - //os2.setEncoding( QTextStream::UnicodeUTF8 ); - - QTextStream ts( &file ); - ts.setCodec( QTextCodec::codecForName("utf8") ); - bool first = true; - while ( mCommandSocket->canReadLine () || first) { - first = false; - while ( mCommandSocket->canReadLine () ) { - ts << mCommandSocket->readLine (); - } - QTime ti; - ti.start(); - while ( ti.elapsed () < 3000 && !mCommandSocket->canReadLine () ) { - qApp->processEvents(); - qDebug("waiting2 %d ",ti.elapsed () ); - if ( !mCommandSocket->canReadLine () ) - mCommandSocket->waitForMore ( 100 ); - } - //mCommandSocket->waitForMore ( 5000 ); - } - file.close(); - mCommandSocket->close(); - if ( mCommandSocket->state() == QSocket::Idle ) - deleteCommandSocket(); - // pending: deleting after signal SIGNAL(delayedCloseFinished()) - //delete mCommandSocket; + setCaption( i18n("Remote file saved to temp file.") ); @@ -2219,3 +2177,2 @@ void MainWindow::readFileFromSocket() - // pending connect signals connected () and error to new slots QString host = KOPrefs::instance()->mActiveSyncIP; @@ -2245,3 +2202,3 @@ void MainWindow::readFileFromSocket() QTimer::singleShot( 10, this , SLOT ( deleteCommandSocketFinish())); - file.close(); + file2.close(); qDebug("Syncing succesful! "); @@ -2593,12 +2550,99 @@ void KServerSocket::readClient() +KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) +{ + mPassWord = password; + mSocket = 0; + mPort = port; + mHost = host; + mRetVal = false; + mTimerSocket = new QTimer ( this ); + connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) ); +} +void KCommandSocket::readFile( QString fn ) +{ + if ( !mSocket ) { + mSocket = new QSocket( this ); + connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); + connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); + } + mFileString = ""; + mFileName = fn; + mFirst = true; + mSocket->connectToHost( mHost, mPort ); + QTextStream os( mSocket ); + os.setEncoding( QTextStream::UnicodeUTF8 ); + os << "GET " << mPassWord << "\r\n"; + mTimerSocket->start( 10000 ); +} +void KCommandSocket::writeFile( QString ) +{ +} +void KCommandSocket::startReadFileFromSocket() +{ + if ( ! mFirst ) + return; + mFirst = false; + mTimerSocket->stop(); + mFileString = ""; + mTime.start(); + QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) )); +} +void KCommandSocket::readFileFromSocket() +{ + qDebug("readBackFileFromSocket() %d ", mTime.elapsed ()); + while ( mSocket->canReadLine () ) { + mTime.restart(); + QString line = mSocket->readLine (); + mFileString += line; + qDebug("readline: %s ", line.latin1()); + } + if ( mTime.elapsed () < 3000 ) { + // wait for more + qDebug("waitformore "); + QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) )); + return; + } + QString fileName = mFileName; + QFile file ( fileName ); + if (!file.open( IO_WriteOnly ) ) { + mFileString = ""; + mRetVal = false; + qDebug("Error open temp calender file for writing: %s",fileName.latin1() ); + deleteSocket(); + return ; + + } + // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); + QTextStream ts ( &file ); + ts.setCodec( QTextCodec::codecForName("utf8") ); + qDebug("finish "); + ts << mFileString; + file.close(); + mFileString = ""; + mRetVal = true; + mSocket->close(); + // if state is not idle, deleteSocket(); is called via + // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); + if ( mSocket->state() == QSocket::Idle ) + deleteSocket(); +} - - - - - +void KCommandSocket::deleteSocket() +{ + if ( !mSocket) + return; + if ( mTimerSocket->isActive () ) { + mTimerSocket->stop(); + KMessageBox::information( 0, i18n("ERROR:\nConnection to remote host timed out ")); + mRetVal = false; + } + qDebug("KCommandSocket::deleteSocket() %d", mRetVal); + delete mSocket; + mSocket = 0; + emit commandFinished( mRetVal ); +} diff --git a/korganizer/mainwindow.h b/korganizer/mainwindow.h index d217578..11a816c 100644 --- a/korganizer/mainwindow.h +++ b/korganizer/mainwindow.h @@ -48,2 +48,30 @@ private slots: +class KCommandSocket : public QObject +{ + Q_OBJECT + +public: + KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent=0, const char * name=0 ); + void readFile( QString ); + void writeFile( QString ); + + +signals: + void commandFinished( bool ); +private slots: + void startReadFileFromSocket(); + void readFileFromSocket(); + void deleteSocket(); + private : + QSocket* mSocket; + QString mPassWord; + Q_UINT16 mPort; + QString mHost; + QString mFileName; + QTimer* mTimerSocket; + bool mRetVal; + QTime mTime; + QString mFileString; + bool mFirst; +}; @@ -123,3 +151,3 @@ class MainWindow : public QMainWindow QTime piTime; - void deleteCommandSocket(); + void deleteCommandSocket(bool); void deleteCommandSocketFinish(); @@ -132,5 +160,5 @@ class MainWindow : public QMainWindow private: - QTimer* mTimerCommandSocket; + //QTimer* mTimerCommandSocket; QString mPassWordPiSync; - QSocket* mCommandSocket; + KCommandSocket* mCommandSocket; QSocket* mCommandSocketFinish; @@ -1 +1 @@ -version = "1.9.6"; +version = "1.9.7"; |