summaryrefslogtreecommitdiffabout
path: root/libkdepim/ksyncmanager.cpp
Unidiff
Diffstat (limited to 'libkdepim/ksyncmanager.cpp') (more/less context) (ignore whitespace changes)
-rw-r--r--libkdepim/ksyncmanager.cpp22
1 files changed, 16 insertions, 6 deletions
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp
index 47d00a4..d59f4a4 100644
--- a/libkdepim/ksyncmanager.cpp
+++ b/libkdepim/ksyncmanager.cpp
@@ -1061,41 +1061,43 @@ void KSyncManager::syncPi()
1061 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") ); 1061 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") );
1062 mPisyncFinished = true; 1062 mPisyncFinished = true;
1063 return; 1063 return;
1064 } 1064 }
1065 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() ); 1065 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() );
1066 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) ); 1066 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) );
1067 commandSocket->readFile( syncFileName() ); 1067 commandSocket->readFile( syncFileName() );
1068} 1068}
1069 1069
1070void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state) 1070void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state)
1071{ 1071{
1072 //enum { success, errorW, errorR, quiet }; 1072 //enum { success, errorW, errorR, quiet };
1073 1073
1074 1074
1075 1075
1076 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ||state == KCommandSocket::errorPW || 1076 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ||state == KCommandSocket::errorPW ||
1077 state == KCommandSocket::errorCA ||state == KCommandSocket::errorFI ||state == KCommandSocket::errorUN ) { 1077 state == KCommandSocket::errorCA ||state == KCommandSocket::errorFI ||state == KCommandSocket::errorUN||state == KCommandSocket::errorED ) {
1078 if ( state == KCommandSocket::errorPW ) 1078 if ( state == KCommandSocket::errorPW )
1079 mParent->topLevelWidget()->setCaption( i18n("Wrong password: Receiving remote file failed.") ); 1079 mParent->topLevelWidget()->setCaption( i18n("Wrong password: Receiving remote file failed.") );
1080 else if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ) 1080 else if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO )
1081 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") ); 1081 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") );
1082 else if ( state == KCommandSocket::errorCA ) 1082 else if ( state == KCommandSocket::errorCA )
1083 mParent->topLevelWidget()->setCaption( i18n("Sync cancelled from remote.") ); 1083 mParent->topLevelWidget()->setCaption( i18n("Sync cancelled from remote.") );
1084 else if ( state == KCommandSocket::errorFI ) 1084 else if ( state == KCommandSocket::errorFI )
1085 mParent->topLevelWidget()->setCaption( i18n("File error on remote.") ); 1085 mParent->topLevelWidget()->setCaption( i18n("File error on remote.") );
1086 else if ( state == KCommandSocket::errorED )
1087 mParent->topLevelWidget()->setCaption( i18n("Please close error dialog on remote.") );
1086 else if ( state == KCommandSocket::errorUN ) 1088 else if ( state == KCommandSocket::errorUN )
1087 mParent->topLevelWidget()->setCaption( i18n("Unknown error on remote.") ); 1089 mParent->topLevelWidget()->setCaption( i18n("Unknown error on remote.") );
1088 delete s; 1090 delete s;
1089 if ( state == KCommandSocket::errorR ) { 1091 if ( state == KCommandSocket::errorR ) {
1090 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget()); 1092 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget());
1091 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); 1093 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
1092 commandSocket->sendStop(); 1094 commandSocket->sendStop();
1093 } 1095 }
1094 mPisyncFinished = true; 1096 mPisyncFinished = true;
1095 return; 1097 return;
1096 1098
1097 } else if ( state == KCommandSocket::errorW ) { 1099 } else if ( state == KCommandSocket::errorW ) {
1098 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") ); 1100 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") );
1099 mPisyncFinished = true; 1101 mPisyncFinished = true;
1100 1102
1101 } else if ( state == KCommandSocket::successR ) { 1103 } else if ( state == KCommandSocket::successR ) {
@@ -1170,33 +1172,33 @@ void KServerSocket::deleteSocket()
1170 delete mSocket; 1172 delete mSocket;
1171 mSocket = 0; 1173 mSocket = 0;
1172 } 1174 }
1173 if ( mErrorMessage ) 1175 if ( mErrorMessage )
1174 QTimer::singleShot( 10, this , SLOT ( displayErrorMessage())); 1176 QTimer::singleShot( 10, this , SLOT ( displayErrorMessage()));
1175} 1177}
1176void KServerSocket::readClient() 1178void KServerSocket::readClient()
1177{ 1179{
1178 if ( blockRC ) 1180 if ( blockRC )
1179 return; 1181 return;
1180 if ( mSocket == 0 ) { 1182 if ( mSocket == 0 ) {
1181 qDebug("ERROR::KSS::readClient(): mSocket == 0 "); 1183 qDebug("ERROR::KSS::readClient(): mSocket == 0 ");
1182 return; 1184 return;
1183 } 1185 }
1184 if ( mErrorMessage ) { 1186 if ( mErrorMessage ) {
1185 mErrorMessage = 999; 1187 mErrorMessage = 999;
1186 error_connect("ERROR_UN\r\n\r\n"); 1188 error_connect("ERROR_ED\r\n\r\n");
1187 return; 1189 return;
1188 } 1190 }
1189 mErrorMessage = 0; 1191 mErrorMessage = 0;
1190 //qDebug("KServerSocket::readClient()"); 1192 //qDebug("KServerSocket::readClient()");
1191 if ( mSocket->canReadLine() ) { 1193 if ( mSocket->canReadLine() ) {
1192 QString line = mSocket->readLine(); 1194 QString line = mSocket->readLine();
1193 //qDebug("KServerSocket readline: %s ", line.latin1()); 1195 //qDebug("KServerSocket readline: %s ", line.latin1());
1194 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line ); 1196 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line );
1195 if ( tokens[0] == "GET" ) { 1197 if ( tokens[0] == "GET" ) {
1196 if ( tokens[1] == mPassWord ) { 1198 if ( tokens[1] == mPassWord ) {
1197 //emit sendFile( mSocket ); 1199 //emit sendFile( mSocket );
1198 bool ok = false; 1200 bool ok = false;
1199 QDateTime dt = KGlobal::locale()->readDateTime( tokens[2], KLocale::ISODate, &ok); 1201 QDateTime dt = KGlobal::locale()->readDateTime( tokens[2], KLocale::ISODate, &ok);
1200 if ( ok ) { 1202 if ( ok ) {
1201 KSyncManager::mRequestedSyncEvent = dt; 1203 KSyncManager::mRequestedSyncEvent = dt;
1202 } 1204 }
@@ -1216,69 +1218,72 @@ void KServerSocket::readClient()
1216 get_file(); 1218 get_file();
1217 } 1219 }
1218 else { 1220 else {
1219 mErrorMessage = 2; 1221 mErrorMessage = 2;
1220 error_connect("ERROR_PW\r\n\r\n"); 1222 error_connect("ERROR_PW\r\n\r\n");
1221 end_connect(); 1223 end_connect();
1222 } 1224 }
1223 } 1225 }
1224 if ( tokens[0] == "STOP" ) { 1226 if ( tokens[0] == "STOP" ) {
1225 //emit endConnect(); 1227 //emit endConnect();
1226 end_connect(); 1228 end_connect();
1227 } 1229 }
1228 } 1230 }
1229} 1231}
1230void KServerSocket::displayErrorMessage() 1232void KServerSocket::displayErrorMessage()
1231{ 1233{
1232 if ( mErrorMessage == 1 ) 1234 if ( mErrorMessage == 1 ) {
1233 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password")); 1235 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password"));
1234 else if ( mErrorMessage == 2 ) 1236 mErrorMessage = 0;
1237 }
1238 else if ( mErrorMessage == 2 ) {
1235 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password")); 1239 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password"));
1236 mErrorMessage = 0; 1240 mErrorMessage = 0;
1241 }
1237} 1242}
1238void KServerSocket::error_connect( QString errmess ) 1243void KServerSocket::error_connect( QString errmess )
1239{ 1244{
1240 QTextStream os( mSocket ); 1245 QTextStream os( mSocket );
1241 os.setEncoding( QTextStream::Latin1 ); 1246 os.setEncoding( QTextStream::Latin1 );
1242 os << errmess ; 1247 os << errmess ;
1243 mSocket->close(); 1248 mSocket->close();
1244 if ( mSocket->state() == QSocket::Idle ) { 1249 if ( mSocket->state() == QSocket::Idle ) {
1245 QTimer::singleShot( 0, this , SLOT ( discardClient())); 1250 QTimer::singleShot( 0, this , SLOT ( discardClient()));
1246 } 1251 }
1247} 1252}
1248void KServerSocket::end_connect() 1253void KServerSocket::end_connect()
1249{ 1254{
1250 delete mSyncActionDialog; 1255 delete mSyncActionDialog;
1251 mSyncActionDialog = 0; 1256 mSyncActionDialog = 0;
1252} 1257}
1253void KServerSocket::send_file() 1258void KServerSocket::send_file()
1254{ 1259{
1255 //qDebug("MainWindow::sendFile(QSocket* s) "); 1260 //qDebug("MainWindow::sendFile(QSocket* s) ");
1256 if ( mSyncActionDialog ) 1261 if ( mSyncActionDialog )
1257 delete mSyncActionDialog; 1262 delete mSyncActionDialog;
1258 mSyncActionDialog = new QDialog ( 0, "input-dialog", true ); 1263 mSyncActionDialog = new QDialog ( 0, "input-dialog", true );
1259 mSyncActionDialog->setCaption(i18n("Received sync request")); 1264 mSyncActionDialog->setCaption(i18n("Received sync request"));
1260 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog ); 1265 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog );
1261 label->setAlignment ( Qt::AlignHCenter ); 1266 label->setAlignment ( Qt::AlignHCenter );
1262 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog ); 1267 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog );
1263 lay->addWidget( label); 1268 lay->addWidget( label);
1264 lay->setMargin(7); 1269 lay->setMargin(7);
1265 lay->setSpacing(7); 1270 lay->setSpacing(7);
1266 if ( KSyncManager::mRequestedSyncEvent.isValid() ) { 1271 if ( KSyncManager::mRequestedSyncEvent.isValid() ) {
1267 int secs = QDateTime::currentDateTime().secsTo( KSyncManager::mRequestedSyncEvent ); 1272 int secs = QDateTime::currentDateTime().secsTo( KSyncManager::mRequestedSyncEvent );
1268 secs = 333; 1273 //secs = 333;
1269 if ( secs < 0 ) 1274 if ( secs < 0 )
1270 secs = secs * (-1); 1275 secs = secs * (-1);
1271 if ( secs > 30 ) 1276 if ( secs > 30 )
1272 //if ( true ) 1277 //if ( true )
1273 { 1278 {
1274 QString warning = i18n("Clock skew of\nsyncing devices\nis %1 seconds!").arg( secs ); 1279 QString warning = i18n("Clock skew of\nsyncing devices\nis %1 seconds!").arg( secs );
1275 QLabel* label = new QLabel( warning, mSyncActionDialog ); 1280 QLabel* label = new QLabel( warning, mSyncActionDialog );
1276 label->setAlignment ( Qt::AlignHCenter ); 1281 label->setAlignment ( Qt::AlignHCenter );
1277 lay->addWidget( label); 1282 lay->addWidget( label);
1278 if ( secs > 180 ) 1283 if ( secs > 180 )
1279 { 1284 {
1280 if ( secs > 300 ) { 1285 if ( secs > 300 ) {
1281 if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(0, i18n("The clocks of the syncing\ndevices have a difference\nof more than 5 minutes.\nPlease adjust your clocks.\nYou may get wrong syncing results!\nPlease confirm synchronization!"), i18n("High clock skew!"),i18n("Synchronize!"))) { 1286 if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(0, i18n("The clocks of the syncing\ndevices have a difference\nof more than 5 minutes.\nPlease adjust your clocks.\nYou may get wrong syncing results!\nPlease confirm synchronization!"), i18n("High clock skew!"),i18n("Synchronize!"))) {
1282 qDebug("KSS::Sync cancelled ,cs"); 1287 qDebug("KSS::Sync cancelled ,cs");
1283 mErrorMessage = 0; 1288 mErrorMessage = 0;
1284 end_connect(); 1289 end_connect();
@@ -1508,32 +1513,37 @@ void KCommandSocket::readFileFromSocket()
1508 if ( line.left( 6 ) == "ERROR_" ) { 1513 if ( line.left( 6 ) == "ERROR_" ) {
1509 if ( line.left( 8 ) == "ERROR_PW" ) { 1514 if ( line.left( 8 ) == "ERROR_PW" ) {
1510 mRetVal = errorPW; 1515 mRetVal = errorPW;
1511 deleteSocket(); 1516 deleteSocket();
1512 return ; 1517 return ;
1513 } 1518 }
1514 if ( line.left( 8 ) == "ERROR_CA" ) { 1519 if ( line.left( 8 ) == "ERROR_CA" ) {
1515 mRetVal = errorCA; 1520 mRetVal = errorCA;
1516 deleteSocket(); 1521 deleteSocket();
1517 return ; 1522 return ;
1518 } 1523 }
1519 if ( line.left( 8 ) == "ERROR_FI" ) { 1524 if ( line.left( 8 ) == "ERROR_FI" ) {
1520 mRetVal = errorFI; 1525 mRetVal = errorFI;
1521 deleteSocket(); 1526 deleteSocket();
1522 return ; 1527 return ;
1523 } 1528 }
1529 if ( line.left( 8 ) == "ERROR_ED" ) {
1530 mRetVal = errorED;
1531 deleteSocket();
1532 return ;
1533 }
1524 mRetVal = errorUN; 1534 mRetVal = errorUN;
1525 deleteSocket(); 1535 deleteSocket();
1526 return ; 1536 return ;
1527 } 1537 }
1528 } 1538 }
1529 mFileString += line; 1539 mFileString += line;
1530 //qDebug("readline: %s ", line.latin1()); 1540 //qDebug("readline: %s ", line.latin1());
1531 } 1541 }
1532 if ( mTime.elapsed () < 3000 ) { 1542 if ( mTime.elapsed () < 3000 ) {
1533 // wait for more 1543 // wait for more
1534 //qDebug("waitformore "); 1544 //qDebug("waitformore ");
1535 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) )); 1545 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) ));
1536 return; 1546 return;
1537 } 1547 }
1538 QString fileName = mFileName; 1548 QString fileName = mFileName;
1539 QFile file ( fileName ); 1549 QFile file ( fileName );