summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--libkdepim/ksyncmanager.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp
index a663427..28af135 100644
--- a/libkdepim/ksyncmanager.cpp
+++ b/libkdepim/ksyncmanager.cpp
@@ -889,260 +889,260 @@ void KServerSocket::readClient()
889 else { 889 else {
890 KMessageBox::information( 0, i18n("ERROR:\nGot receive file request\nwith invalid password")); 890 KMessageBox::information( 0, i18n("ERROR:\nGot receive file request\nwith invalid password"));
891 qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); 891 qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() );
892 } 892 }
893 } 893 }
894 if ( tokens[0] == "STOP" ) { 894 if ( tokens[0] == "STOP" ) {
895 //emit endConnect(); 895 //emit endConnect();
896 end_connect(); 896 end_connect();
897 } 897 }
898 } 898 }
899} 899}
900void KServerSocket::end_connect() 900void KServerSocket::end_connect()
901{ 901{
902 delete mSyncActionDialog; 902 delete mSyncActionDialog;
903 mSyncActionDialog = 0; 903 mSyncActionDialog = 0;
904} 904}
905void KServerSocket::send_file() 905void KServerSocket::send_file()
906{ 906{
907 //qDebug("MainWindow::sendFile(QSocket* s) "); 907 //qDebug("MainWindow::sendFile(QSocket* s) ");
908 if ( mSyncActionDialog ) 908 if ( mSyncActionDialog )
909 delete mSyncActionDialog; 909 delete mSyncActionDialog;
910 mSyncActionDialog = new QDialog ( 0, "input-dialog", true ); 910 mSyncActionDialog = new QDialog ( 0, "input-dialog", true );
911 mSyncActionDialog->setCaption(i18n("Received sync request")); 911 mSyncActionDialog->setCaption(i18n("Received sync request"));
912 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog ); 912 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog );
913 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog ); 913 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog );
914 lay->addWidget( label); 914 lay->addWidget( label);
915 lay->setMargin(7); 915 lay->setMargin(7);
916 lay->setSpacing(7); 916 lay->setSpacing(7);
917 mSyncActionDialog->setFixedSize( 230, 120); 917 mSyncActionDialog->setFixedSize( 230, 120);
918 mSyncActionDialog->show(); 918 mSyncActionDialog->show();
919 mSyncActionDialog->raise(); 919 mSyncActionDialog->raise();
920 qDebug("KSS::saving ... "); 920 qDebug("KSS::saving ... ");
921 emit request_file(); 921 emit request_file();
922 qApp->processEvents(); 922 qApp->processEvents();
923 QString fileName = mFileName; 923 QString fileName = mFileName;
924 QFile file( fileName ); 924 QFile file( fileName );
925 if (!file.open( IO_ReadOnly ) ) { 925 if (!file.open( IO_ReadOnly ) ) {
926 delete mSyncActionDialog; 926 delete mSyncActionDialog;
927 mSyncActionDialog = 0; 927 mSyncActionDialog = 0;
928 qDebug("KSS::error open file "); 928 qDebug("KSS::error open file ");
929 mSocket->close(); 929 mSocket->close();
930 if ( mSocket->state() == QSocket::Idle ) 930 if ( mSocket->state() == QSocket::Idle )
931 QTimer::singleShot( 10, this , SLOT ( discardClient())); 931 QTimer::singleShot( 10, this , SLOT ( discardClient()));
932 return ; 932 return ;
933 933
934 } 934 }
935 mSyncActionDialog->setCaption( i18n("Sending file...") ); 935 mSyncActionDialog->setCaption( i18n("Sending file...") );
936 QTextStream ts( &file ); 936 QTextStream ts( &file );
937 ts.setCodec( QTextCodec::codecForName("utf8") ); 937 ts.setEncoding( QTextStream::Latin1 );
938
938 QTextStream os( mSocket ); 939 QTextStream os( mSocket );
939 os.setCodec( QTextCodec::codecForName("utf8") ); 940 os.setEncoding( QTextStream::Latin1 );
940 //os.setEncoding( QTextStream::UnicodeUTF8 );
941 while ( ! ts.atEnd() ) { 941 while ( ! ts.atEnd() ) {
942 os << ts.readLine() << "\n"; 942 os << ts.readLine() << "\n";
943 } 943 }
944 //os << ts.read(); 944 //os << ts.read();
945 file.close(); 945 file.close();
946 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") ); 946 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") );
947 mSocket->close(); 947 mSocket->close();
948 if ( mSocket->state() == QSocket::Idle ) 948 if ( mSocket->state() == QSocket::Idle )
949 QTimer::singleShot( 10, this , SLOT ( discardClient())); 949 QTimer::singleShot( 10, this , SLOT ( discardClient()));
950} 950}
951void KServerSocket::get_file() 951void KServerSocket::get_file()
952{ 952{
953 mSyncActionDialog->setCaption( i18n("Receiving synced file...") ); 953 mSyncActionDialog->setCaption( i18n("Receiving synced file...") );
954 954
955 piTime.start(); 955 piTime.start();
956 piFileString = ""; 956 piFileString = "";
957 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) )); 957 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) ));
958} 958}
959 959
960 960
961void KServerSocket::readBackFileFromSocket() 961void KServerSocket::readBackFileFromSocket()
962{ 962{
963 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ()); 963 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ());
964 while ( mSocket->canReadLine () ) { 964 while ( mSocket->canReadLine () ) {
965 piTime.restart(); 965 piTime.restart();
966 QString line = mSocket->readLine (); 966 QString line = mSocket->readLine ();
967 piFileString += line; 967 piFileString += line;
968 //qDebug("readline: %s ", line.latin1()); 968 //qDebug("readline: %s ", line.latin1());
969 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) ); 969 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) );
970 970
971 } 971 }
972 if ( piTime.elapsed () < 3000 ) { 972 if ( piTime.elapsed () < 3000 ) {
973 // wait for more 973 // wait for more
974 //qDebug("waitformore "); 974 //qDebug("waitformore ");
975 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) )); 975 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) ));
976 return; 976 return;
977 } 977 }
978 QString fileName = mFileName; 978 QString fileName = mFileName;
979 QFile file ( fileName ); 979 QFile file ( fileName );
980 if (!file.open( IO_WriteOnly ) ) { 980 if (!file.open( IO_WriteOnly ) ) {
981 delete mSyncActionDialog; 981 delete mSyncActionDialog;
982 mSyncActionDialog = 0; 982 mSyncActionDialog = 0;
983 qDebug("error open cal file "); 983 qDebug("error open cal file ");
984 piFileString = ""; 984 piFileString = "";
985 emit file_received( false ); 985 emit file_received( false );
986 blockRC = false; 986 blockRC = false;
987 return ; 987 return ;
988 988
989 } 989 }
990 990
991 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 991 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
992 QTextStream ts ( &file ); 992 QTextStream ts ( &file );
993 ts.setCodec( QTextCodec::codecForName("utf8") ); 993 ts.setEncoding( QTextStream::Latin1 );
994 mSyncActionDialog->setCaption( i18n("Writing file to disk...") ); 994 mSyncActionDialog->setCaption( i18n("Writing file to disk...") );
995 ts << piFileString; 995 ts << piFileString;
996 mSocket->close(); 996 mSocket->close();
997 if ( mSocket->state() == QSocket::Idle ) 997 if ( mSocket->state() == QSocket::Idle )
998 QTimer::singleShot( 10, this , SLOT ( discardClient())); 998 QTimer::singleShot( 10, this , SLOT ( discardClient()));
999 file.close(); 999 file.close();
1000 delete mSyncActionDialog; 1000 delete mSyncActionDialog;
1001 mSyncActionDialog = 0; 1001 mSyncActionDialog = 0;
1002 piFileString = ""; 1002 piFileString = "";
1003 blockRC = false; 1003 blockRC = false;
1004 emit file_received( true ); 1004 emit file_received( true );
1005 1005
1006} 1006}
1007 1007
1008KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) 1008KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name )
1009{ 1009{
1010 mPassWord = password; 1010 mPassWord = password;
1011 mSocket = 0; 1011 mSocket = 0;
1012 mPort = port; 1012 mPort = port;
1013 mHost = host; 1013 mHost = host;
1014 1014
1015 mRetVal = quiet; 1015 mRetVal = quiet;
1016 mTimerSocket = new QTimer ( this ); 1016 mTimerSocket = new QTimer ( this );
1017 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) ); 1017 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) );
1018} 1018}
1019void KCommandSocket::readFile( QString fn ) 1019void KCommandSocket::readFile( QString fn )
1020{ 1020{
1021 if ( !mSocket ) { 1021 if ( !mSocket ) {
1022 mSocket = new QSocket( this ); 1022 mSocket = new QSocket( this );
1023 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); 1023 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) );
1024 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1024 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1025 } 1025 }
1026 mFileString = ""; 1026 mFileString = "";
1027 mFileName = fn; 1027 mFileName = fn;
1028 mFirst = true; 1028 mFirst = true;
1029 mSocket->connectToHost( mHost, mPort ); 1029 mSocket->connectToHost( mHost, mPort );
1030 QTextStream os( mSocket ); 1030 QTextStream os( mSocket );
1031 os.setEncoding( QTextStream::UnicodeUTF8 ); 1031 os.setEncoding( QTextStream::Latin1 );
1032 os << "GET " << mPassWord << "\r\n"; 1032 os << "GET " << mPassWord << "\r\n";
1033 mTimerSocket->start( 10000 ); 1033 mTimerSocket->start( 10000 );
1034} 1034}
1035 1035
1036void KCommandSocket::writeFile( QString fileName ) 1036void KCommandSocket::writeFile( QString fileName )
1037{ 1037{
1038 if ( !mSocket ) { 1038 if ( !mSocket ) {
1039 mSocket = new QSocket( this ); 1039 mSocket = new QSocket( this );
1040 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1040 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1041 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); 1041 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) );
1042 } 1042 }
1043 mFileName = fileName ; 1043 mFileName = fileName ;
1044 mSocket->connectToHost( mHost, mPort ); 1044 mSocket->connectToHost( mHost, mPort );
1045} 1045}
1046void KCommandSocket::writeFileToSocket() 1046void KCommandSocket::writeFileToSocket()
1047{ 1047{
1048 QFile file2( mFileName ); 1048 QFile file2( mFileName );
1049 if (!file2.open( IO_ReadOnly ) ) { 1049 if (!file2.open( IO_ReadOnly ) ) {
1050 mRetVal= errorW; 1050 mRetVal= errorW;
1051 mSocket->close(); 1051 mSocket->close();
1052 if ( mSocket->state() == QSocket::Idle ) 1052 if ( mSocket->state() == QSocket::Idle )
1053 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1053 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1054 return ; 1054 return ;
1055 } 1055 }
1056 QTextStream ts2( &file2 ); 1056 QTextStream ts2( &file2 );
1057 ts2.setCodec( QTextCodec::codecForName("utf8") ); 1057 ts2.setEncoding( QTextStream::Latin1 );
1058 QTextStream os2( mSocket ); 1058 QTextStream os2( mSocket );
1059 os2.setCodec( QTextCodec::codecForName("utf8") ); 1059 os2.setEncoding( QTextStream::Latin1 );
1060 os2 << "PUT " << mPassWord << "\r\n";; 1060 os2 << "PUT " << mPassWord << "\r\n";;
1061 while ( ! ts2.atEnd() ) { 1061 while ( ! ts2.atEnd() ) {
1062 os2 << ts2.readLine() << "\n"; 1062 os2 << ts2.readLine() << "\n";
1063 } 1063 }
1064 mRetVal= successW; 1064 mRetVal= successW;
1065 file2.close(); 1065 file2.close();
1066 mSocket->close(); 1066 mSocket->close();
1067 if ( mSocket->state() == QSocket::Idle ) 1067 if ( mSocket->state() == QSocket::Idle )
1068 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1068 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1069} 1069}
1070void KCommandSocket::sendStop() 1070void KCommandSocket::sendStop()
1071{ 1071{
1072 if ( !mSocket ) { 1072 if ( !mSocket ) {
1073 mSocket = new QSocket( this ); 1073 mSocket = new QSocket( this );
1074 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1074 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1075 } 1075 }
1076 mSocket->connectToHost( mHost, mPort ); 1076 mSocket->connectToHost( mHost, mPort );
1077 QTextStream os2( mSocket ); 1077 QTextStream os2( mSocket );
1078 os2.setCodec( QTextCodec::codecForName("utf8") ); 1078 os2.setEncoding( QTextStream::Latin1 );
1079 os2 << "STOP\r\n"; 1079 os2 << "STOP\r\n";
1080 mSocket->close(); 1080 mSocket->close();
1081 if ( mSocket->state() == QSocket::Idle ) 1081 if ( mSocket->state() == QSocket::Idle )
1082 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1082 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1083} 1083}
1084 1084
1085void KCommandSocket::startReadFileFromSocket() 1085void KCommandSocket::startReadFileFromSocket()
1086{ 1086{
1087 if ( ! mFirst ) 1087 if ( ! mFirst )
1088 return; 1088 return;
1089 mFirst = false; 1089 mFirst = false;
1090 mTimerSocket->stop(); 1090 mTimerSocket->stop();
1091 mFileString = ""; 1091 mFileString = "";
1092 mTime.start(); 1092 mTime.start();
1093 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) )); 1093 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) ));
1094 1094
1095} 1095}
1096void KCommandSocket::readFileFromSocket() 1096void KCommandSocket::readFileFromSocket()
1097{ 1097{
1098 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ()); 1098 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ());
1099 while ( mSocket->canReadLine () ) { 1099 while ( mSocket->canReadLine () ) {
1100 mTime.restart(); 1100 mTime.restart();
1101 QString line = mSocket->readLine (); 1101 QString line = mSocket->readLine ();
1102 mFileString += line; 1102 mFileString += line;
1103 //qDebug("readline: %s ", line.latin1()); 1103 //qDebug("readline: %s ", line.latin1());
1104 } 1104 }
1105 if ( mTime.elapsed () < 3000 ) { 1105 if ( mTime.elapsed () < 3000 ) {
1106 // wait for more 1106 // wait for more
1107 //qDebug("waitformore "); 1107 //qDebug("waitformore ");
1108 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) )); 1108 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) ));
1109 return; 1109 return;
1110 } 1110 }
1111 QString fileName = mFileName; 1111 QString fileName = mFileName;
1112 QFile file ( fileName ); 1112 QFile file ( fileName );
1113 if (!file.open( IO_WriteOnly ) ) { 1113 if (!file.open( IO_WriteOnly ) ) {
1114 mFileString = ""; 1114 mFileString = "";
1115 mRetVal = errorR; 1115 mRetVal = errorR;
1116 qDebug("Error open temp calender file for writing: %s",fileName.latin1() ); 1116 qDebug("Error open temp calender file for writing: %s",fileName.latin1() );
1117 deleteSocket(); 1117 deleteSocket();
1118 return ; 1118 return ;
1119 1119
1120 } 1120 }
1121 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 1121 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
1122 QTextStream ts ( &file ); 1122 QTextStream ts ( &file );
1123 ts.setCodec( QTextCodec::codecForName("utf8") ); 1123 ts.setEncoding( QTextStream::Latin1 );
1124 ts << mFileString; 1124 ts << mFileString;
1125 file.close(); 1125 file.close();
1126 mFileString = ""; 1126 mFileString = "";
1127 mRetVal = successR; 1127 mRetVal = successR;
1128 mSocket->close(); 1128 mSocket->close();
1129 // if state is not idle, deleteSocket(); is called via 1129 // if state is not idle, deleteSocket(); is called via
1130 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1130 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1131 if ( mSocket->state() == QSocket::Idle ) 1131 if ( mSocket->state() == QSocket::Idle )
1132 deleteSocket(); 1132 deleteSocket();
1133} 1133}
1134 1134
1135void KCommandSocket::deleteSocket() 1135void KCommandSocket::deleteSocket()
1136{ 1136{
1137 if ( mTimerSocket->isActive () ) { 1137 if ( mTimerSocket->isActive () ) {
1138 mTimerSocket->stop(); 1138 mTimerSocket->stop();
1139 KMessageBox::information( 0, i18n("ERROR:\nConnection to remote host timed out!\nDid you forgot to enable\nsyncing on remote host? ")); 1139 KMessageBox::information( 0, i18n("ERROR:\nConnection to remote host timed out!\nDid you forgot to enable\nsyncing on remote host? "));
1140 mRetVal = errorR; 1140 mRetVal = errorR;
1141 } 1141 }
1142 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal ); 1142 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal );
1143 if ( mSocket) 1143 if ( mSocket)
1144 delete mSocket; 1144 delete mSocket;
1145 mSocket = 0; 1145 mSocket = 0;
1146 emit commandFinished( this, mRetVal ); 1146 emit commandFinished( this, mRetVal );
1147} 1147}
1148 1148