From 2a99a7ca0816fd68b7fcf2f1fee023aef019000d Mon Sep 17 00:00:00 2001 From: zautrix Date: Mon, 04 Oct 2004 17:32:48 +0000 Subject: more sync fixes --- diff --git a/korganizer/mainwindow.cpp b/korganizer/mainwindow.cpp index 10cb2a2..e4b7869 100644 --- a/korganizer/mainwindow.cpp +++ b/korganizer/mainwindow.cpp @@ -71,8 +71,6 @@ MainWindow::MainWindow( QWidget *parent, const char *name, QString msg) : QMainWindow( parent, name ) { mPassWordPiSync = "abc"; - mTimerCommandSocket = new QTimer ( this ); - connect( mTimerCommandSocket, SIGNAL ( timeout () ), this, SLOT ( deleteCommandSocket() ) ); #ifdef DESKTOP_VERSION setFont( QFont("Arial"), 14 ); #endif @@ -2103,34 +2101,27 @@ void MainWindow::performQuickQuick() setCaption( i18n("Sorry, no valid port.Syncing cancelled.") ); return; } - 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; } void MainWindow::deleteCommandSocketFinish() { @@ -2143,7 +2134,7 @@ void MainWindow::deleteCommandSocketFinish() } void MainWindow::readFileFromSocket() { - mTimerCommandSocket->stop(); + // mTimerCommandSocket->stop(); setCaption( i18n("Receiving remote file ...") ); qDebug("MainWindow::readFileFromSocket() "); QString fileName; @@ -2152,40 +2143,7 @@ void MainWindow::readFileFromSocket() #else fileName = "/tmp/kopitempfile.ics"; #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.") ); //mCommandSocket = 0; mCurrentSyncProfile = 2 ; // last file @@ -2217,7 +2175,6 @@ void MainWindow::readFileFromSocket() } mCommandSocketFinish->connectToHost( KOPrefs::instance()->mActiveSyncIP, KOPrefs::instance()->mActiveSyncPort.toUInt() ); - // pending connect signals connected () and error to new slots QString host = KOPrefs::instance()->mActiveSyncIP; QFile file2( fileName ); if (!file2.open( IO_ReadOnly ) ) { @@ -2243,7 +2200,7 @@ void MainWindow::readFileFromSocket() mCommandSocketFinish->close(); if ( mCommandSocketFinish->state() == QSocket::Idle ) QTimer::singleShot( 10, this , SLOT ( deleteCommandSocketFinish())); - file.close(); + file2.close(); qDebug("Syncing succesful! "); setCaption( i18n("Pi-Sync succesful!") ); @@ -2591,14 +2548,101 @@ 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 @@ -46,6 +46,34 @@ private slots: QString mPassWord; }; +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; +}; namespace KCal { class CalendarLocal; @@ -121,7 +149,7 @@ class MainWindow : public QMainWindow QSocket* piSocket; QString piFileString; QTime piTime; - void deleteCommandSocket(); + void deleteCommandSocket(bool); void deleteCommandSocketFinish(); void fillSyncMenu(); void sendFile(QSocket* s); @@ -130,9 +158,9 @@ class MainWindow : public QMainWindow void readBackFileFromSocket(); void endConnect(); private: - QTimer* mTimerCommandSocket; + //QTimer* mTimerCommandSocket; QString mPassWordPiSync; - QSocket* mCommandSocket; + KCommandSocket* mCommandSocket; QSocket* mCommandSocketFinish; KServerSocket * mServerSocket; bool mClosed; diff --git a/version b/version index 576852d..f085278 100644 --- a/version +++ b/version @@ -1 +1 @@ -version = "1.9.6"; +version = "1.9.7"; -- cgit v0.9.0.2