-rw-r--r-- | libkdepim/ksyncmanager.cpp | 18 |
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 | } |
900 | void KServerSocket::end_connect() | 900 | void KServerSocket::end_connect() |
901 | { | 901 | { |
902 | delete mSyncActionDialog; | 902 | delete mSyncActionDialog; |
903 | mSyncActionDialog = 0; | 903 | mSyncActionDialog = 0; |
904 | } | 904 | } |
905 | void KServerSocket::send_file() | 905 | void 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 | } |
951 | void KServerSocket::get_file() | 951 | void 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 | ||
961 | void KServerSocket::readBackFileFromSocket() | 961 | void 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 | ||
1008 | KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) | 1008 | KCommandSocket::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 | } |
1019 | void KCommandSocket::readFile( QString fn ) | 1019 | void 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 | ||
1036 | void KCommandSocket::writeFile( QString fileName ) | 1036 | void 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 | } |
1046 | void KCommandSocket::writeFileToSocket() | 1046 | void 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 | } |
1070 | void KCommandSocket::sendStop() | 1070 | void 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 | ||
1085 | void KCommandSocket::startReadFileFromSocket() | 1085 | void 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 | } |
1096 | void KCommandSocket::readFileFromSocket() | 1096 | void 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 | ||
1135 | void KCommandSocket::deleteSocket() | 1135 | void 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 | ||