-rw-r--r-- | korganizer/calendarview.cpp | 2 | ||||
-rw-r--r-- | libkcal/calendarlocal.cpp | 2 | ||||
-rw-r--r-- | libkdepim/ksyncmanager.cpp | 8 |
3 files changed, 6 insertions, 6 deletions
diff --git a/korganizer/calendarview.cpp b/korganizer/calendarview.cpp index 6128137..538325e 100644 --- a/korganizer/calendarview.cpp +++ b/korganizer/calendarview.cpp | |||
@@ -1880,65 +1880,65 @@ bool CalendarView::synchronizeCalendar( Calendar* local, Calendar* remote, int | |||
1880 | remRem = er.count(); | 1880 | remRem = er.count(); |
1881 | inR = er.first(); | 1881 | inR = er.first(); |
1882 | QDateTime dt; | 1882 | QDateTime dt; |
1883 | QDateTime cur = QDateTime::currentDateTime().addDays( -(mSyncManager->mWriteBackInPast * 7) ); | 1883 | QDateTime cur = QDateTime::currentDateTime().addDays( -(mSyncManager->mWriteBackInPast * 7) ); |
1884 | QDateTime end = QDateTime::currentDateTime().addDays( (mSyncManager->mWriteBackInFuture ) *7 ); | 1884 | QDateTime end = QDateTime::currentDateTime().addDays( (mSyncManager->mWriteBackInFuture ) *7 ); |
1885 | while ( inR ) { | 1885 | while ( inR ) { |
1886 | if ( inR->typeID() == todoID ) { | 1886 | if ( inR->typeID() == todoID ) { |
1887 | Todo * t = (Todo*)inR; | 1887 | Todo * t = (Todo*)inR; |
1888 | if ( t->hasDueDate() ) | 1888 | if ( t->hasDueDate() ) |
1889 | dt = t->dtDue(); | 1889 | dt = t->dtDue(); |
1890 | else | 1890 | else |
1891 | dt = cur.addSecs( 62 ); | 1891 | dt = cur.addSecs( 62 ); |
1892 | } | 1892 | } |
1893 | else if (inR->typeID() == eventID ) { | 1893 | else if (inR->typeID() == eventID ) { |
1894 | bool ok; | 1894 | bool ok; |
1895 | dt = inR->getNextOccurence( cur, &ok ); | 1895 | dt = inR->getNextOccurence( cur, &ok ); |
1896 | if ( !ok ) | 1896 | if ( !ok ) |
1897 | dt = cur.addSecs( -62 ); | 1897 | dt = cur.addSecs( -62 ); |
1898 | } | 1898 | } |
1899 | else | 1899 | else |
1900 | dt = inR->dtStart(); | 1900 | dt = inR->dtStart(); |
1901 | if ( dt < cur || dt > end ) { | 1901 | if ( dt < cur || dt > end ) { |
1902 | remote->deleteIncidence( inR ); | 1902 | remote->deleteIncidence( inR ); |
1903 | ++delFut; | 1903 | ++delFut; |
1904 | } | 1904 | } |
1905 | inR = er.next(); | 1905 | inR = er.next(); |
1906 | } | 1906 | } |
1907 | } | 1907 | } |
1908 | bar.hide(); | 1908 | bar.hide(); |
1909 | mLastCalendarSync = QDateTime::currentDateTime().addSecs( 1 ); | 1909 | mLastCalendarSync = QDateTime::currentDateTime().addSecs( 1 ); |
1910 | if ( mMultiResourceSync ) { | 1910 | if ( mMultiResourceSync ) { |
1911 | remote->removeSyncInfo( "" ); //all | 1911 | remote->removeSyncInfo( "" ); //all |
1912 | 1912 | qDebug("KO: Remoing all sync info on remote "); | |
1913 | } else { | 1913 | } else { |
1914 | eventLSync->setReadOnly( false ); | 1914 | eventLSync->setReadOnly( false ); |
1915 | eventLSync->setDtStart( mLastCalendarSync ); | 1915 | eventLSync->setDtStart( mLastCalendarSync ); |
1916 | eventRSync->setDtStart( mLastCalendarSync ); | 1916 | eventRSync->setDtStart( mLastCalendarSync ); |
1917 | eventLSync->setDtEnd( mLastCalendarSync.addSecs( 3600 ) ); | 1917 | eventLSync->setDtEnd( mLastCalendarSync.addSecs( 3600 ) ); |
1918 | eventRSync->setDtEnd( mLastCalendarSync.addSecs( 3600 ) ); | 1918 | eventRSync->setDtEnd( mLastCalendarSync.addSecs( 3600 ) ); |
1919 | eventRSync->setLocation( i18n("Remote from: ")+mCurrentSyncName ) ; | 1919 | eventRSync->setLocation( i18n("Remote from: ")+mCurrentSyncName ) ; |
1920 | eventLSync->setLocation(i18n("Local from: ") + mCurrentSyncName ); | 1920 | eventLSync->setLocation(i18n("Local from: ") + mCurrentSyncName ); |
1921 | eventLSync->setReadOnly( true ); | 1921 | eventLSync->setReadOnly( true ); |
1922 | } | 1922 | } |
1923 | qDebug("KO: Normal sync: %d ",mGlobalSyncMode == SYNC_MODE_NORMAL ); | 1923 | qDebug("KO: Normal sync: %d ",mGlobalSyncMode == SYNC_MODE_NORMAL ); |
1924 | if ( mGlobalSyncMode == SYNC_MODE_NORMAL && !mSyncManager->syncWithDesktop() && !mMultiResourceSync ) // kde is abnormal... | 1924 | if ( mGlobalSyncMode == SYNC_MODE_NORMAL && !mSyncManager->syncWithDesktop() && !mMultiResourceSync ) // kde is abnormal... |
1925 | remote->addEvent( eventRSync ); | 1925 | remote->addEvent( eventRSync ); |
1926 | else | 1926 | else |
1927 | delete eventRSync; | 1927 | delete eventRSync; |
1928 | qDebug("KO: Sync with desktop %d ",mSyncManager->syncWithDesktop() ); | 1928 | qDebug("KO: Sync with desktop %d ",mSyncManager->syncWithDesktop() ); |
1929 | QString mes; | 1929 | QString mes; |
1930 | mes .sprintf( i18n("Synchronization summary:\n\n %d items added to local\n %d items added to remote\n %d items updated on local\n %d items updated on remote\n %d items deleted on local\n %d items deleted on remote\n %d incoming filtered out\n %d outgoing filtered out\n"),addedEvent, addedEventR, changedLocal, changedRemote, deletedEventL, deletedEventR, filteredIN, filteredOUT ); | 1930 | mes .sprintf( i18n("Synchronization summary:\n\n %d items added to local\n %d items added to remote\n %d items updated on local\n %d items updated on remote\n %d items deleted on local\n %d items deleted on remote\n %d incoming filtered out\n %d outgoing filtered out\n"),addedEvent, addedEventR, changedLocal, changedRemote, deletedEventL, deletedEventR, filteredIN, filteredOUT ); |
1931 | QString delmess; | 1931 | QString delmess; |
1932 | if ( delFut ) { | 1932 | if ( delFut ) { |
1933 | delmess.sprintf( i18n("%d items skipped on remote,\nbecause they are more\nthan %d weeks in the past or\nmore than %d weeks in the future.\nAfter skipping, remote has\n%d calendar/todo items."), delFut,mSyncManager->mWriteBackInPast,mSyncManager->mWriteBackInFuture, remRem-delFut); | 1933 | delmess.sprintf( i18n("%d items skipped on remote,\nbecause they are more\nthan %d weeks in the past or\nmore than %d weeks in the future.\nAfter skipping, remote has\n%d calendar/todo items."), delFut,mSyncManager->mWriteBackInPast,mSyncManager->mWriteBackInFuture, remRem-delFut); |
1934 | mes += delmess; | 1934 | mes += delmess; |
1935 | } | 1935 | } |
1936 | mes = i18n("Local calendar changed!\n") +mes; | 1936 | mes = i18n("Local calendar changed!\n") +mes; |
1937 | mCalendar->checkAlarmForIncidence( 0, true ); | 1937 | mCalendar->checkAlarmForIncidence( 0, true ); |
1938 | qDebug( mes ); | 1938 | qDebug( mes ); |
1939 | if ( mSyncManager->mShowSyncSummary ) { | 1939 | if ( mSyncManager->mShowSyncSummary ) { |
1940 | if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(this, mes, | 1940 | if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(this, mes, |
1941 | i18n("KO/Pi Synchronization"),i18n("Write back"))) { | 1941 | i18n("KO/Pi Synchronization"),i18n("Write back"))) { |
1942 | qDebug("KO: WB cancelled "); | 1942 | qDebug("KO: WB cancelled "); |
1943 | mSyncManager->mWriteBackFile = false; | 1943 | mSyncManager->mWriteBackFile = false; |
1944 | return syncOK; | 1944 | return syncOK; |
diff --git a/libkcal/calendarlocal.cpp b/libkcal/calendarlocal.cpp index c33581c..c82ea92 100644 --- a/libkcal/calendarlocal.cpp +++ b/libkcal/calendarlocal.cpp | |||
@@ -956,65 +956,65 @@ Journal *CalendarLocal::journal( const QDate &date ) | |||
956 | } | 956 | } |
957 | 957 | ||
958 | Journal *CalendarLocal::journal( const QString &uid ) | 958 | Journal *CalendarLocal::journal( const QString &uid ) |
959 | { | 959 | { |
960 | Journal * retVal = 0; | 960 | Journal * retVal = 0; |
961 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) | 961 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) |
962 | if ( it->calEnabled() && it->uid() == uid ) { | 962 | if ( it->calEnabled() && it->uid() == uid ) { |
963 | if ( retVal ) { | 963 | if ( retVal ) { |
964 | if ( retVal->calID() > it->calID() ) { | 964 | if ( retVal->calID() > it->calID() ) { |
965 | retVal = it; | 965 | retVal = it; |
966 | } | 966 | } |
967 | } else { | 967 | } else { |
968 | retVal = it; | 968 | retVal = it; |
969 | } | 969 | } |
970 | } | 970 | } |
971 | return retVal; | 971 | return retVal; |
972 | } | 972 | } |
973 | 973 | ||
974 | QPtrList<Journal> CalendarLocal::journals() | 974 | QPtrList<Journal> CalendarLocal::journals() |
975 | { | 975 | { |
976 | QPtrList<Journal> el; | 976 | QPtrList<Journal> el; |
977 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) | 977 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) |
978 | if ( it->calEnabled() ) el.append( it ); | 978 | if ( it->calEnabled() ) el.append( it ); |
979 | return el; | 979 | return el; |
980 | } | 980 | } |
981 | void CalendarLocal::setCalendarRemove( int id ) | 981 | void CalendarLocal::setCalendarRemove( int id ) |
982 | { | 982 | { |
983 | 983 | ||
984 | { | 984 | { |
985 | QPtrList<Event> EventList = mEventList; | 985 | QPtrList<Event> EventList = mEventList; |
986 | Event * ev = EventList.first(); | 986 | Event * ev = EventList.first(); |
987 | while ( ev ) { | 987 | while ( ev ) { |
988 | if ( ev->calID() == id ) | 988 | if ( ev->calID() == id && ev->uid().left( 15 ) != QString("last-syncEvent-") ) |
989 | deleteEvent( ev ); | 989 | deleteEvent( ev ); |
990 | ev = EventList.next(); | 990 | ev = EventList.next(); |
991 | } | 991 | } |
992 | } | 992 | } |
993 | { | 993 | { |
994 | 994 | ||
995 | QPtrList<Todo> TodoList = mTodoList; | 995 | QPtrList<Todo> TodoList = mTodoList; |
996 | Todo * ev = TodoList.first(); | 996 | Todo * ev = TodoList.first(); |
997 | while ( ev ) { | 997 | while ( ev ) { |
998 | if ( ev->calID() == id ) | 998 | if ( ev->calID() == id ) |
999 | deleteTodo( ev ); | 999 | deleteTodo( ev ); |
1000 | ev = TodoList.next(); | 1000 | ev = TodoList.next(); |
1001 | } | 1001 | } |
1002 | } | 1002 | } |
1003 | { | 1003 | { |
1004 | QPtrList<Journal> JournalList = mJournalList; | 1004 | QPtrList<Journal> JournalList = mJournalList; |
1005 | Journal * ev = JournalList.first(); | 1005 | Journal * ev = JournalList.first(); |
1006 | while ( ev ) { | 1006 | while ( ev ) { |
1007 | if ( ev->calID() == id ) | 1007 | if ( ev->calID() == id ) |
1008 | deleteJournal( ev ); | 1008 | deleteJournal( ev ); |
1009 | ev = JournalList.next(); | 1009 | ev = JournalList.next(); |
1010 | } | 1010 | } |
1011 | } | 1011 | } |
1012 | 1012 | ||
1013 | clearUndo(0); | 1013 | clearUndo(0); |
1014 | 1014 | ||
1015 | } | 1015 | } |
1016 | 1016 | ||
1017 | void CalendarLocal::setAllCalendarEnabled( bool enable ) | 1017 | void CalendarLocal::setAllCalendarEnabled( bool enable ) |
1018 | { | 1018 | { |
1019 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) | 1019 | for ( Journal *it = mJournalList.first(); it; it = mJournalList.next() ) |
1020 | it->setCalEnabled( enable ); | 1020 | it->setCalEnabled( enable ); |
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp index 8bf0d27..fa7804e 100644 --- a/libkdepim/ksyncmanager.cpp +++ b/libkdepim/ksyncmanager.cpp | |||
@@ -1246,65 +1246,65 @@ void KSyncManager::readFileFromSocket() | |||
1246 | bool syncOK = true; | 1246 | bool syncOK = true; |
1247 | mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") ); | 1247 | mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") ); |
1248 | if ( ! syncWithFile( fileName , true ) ) { | 1248 | if ( ! syncWithFile( fileName , true ) ) { |
1249 | mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") ); | 1249 | mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") ); |
1250 | syncOK = false; | 1250 | syncOK = false; |
1251 | } | 1251 | } |
1252 | KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote,mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget() ); | 1252 | KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote,mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget() ); |
1253 | connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); | 1253 | connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); |
1254 | if ( mWriteBackFile && syncOK ) { | 1254 | if ( mWriteBackFile && syncOK ) { |
1255 | mParent->topLevelWidget()->setCaption( i18n("Sending back file ...") ); | 1255 | mParent->topLevelWidget()->setCaption( i18n("Sending back file ...") ); |
1256 | commandSocket->writeFile( fileName ); | 1256 | commandSocket->writeFile( fileName ); |
1257 | } | 1257 | } |
1258 | else { | 1258 | else { |
1259 | commandSocket->sendStop(); | 1259 | commandSocket->sendStop(); |
1260 | if ( syncOK ) | 1260 | if ( syncOK ) |
1261 | mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") ); | 1261 | mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") ); |
1262 | mPisyncFinished = true; | 1262 | mPisyncFinished = true; |
1263 | } | 1263 | } |
1264 | } | 1264 | } |
1265 | 1265 | ||
1266 | KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ) | 1266 | KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ) |
1267 | { | 1267 | { |
1268 | mPendingConnect = 0; | 1268 | mPendingConnect = 0; |
1269 | mPassWord = pw; | 1269 | mPassWord = pw; |
1270 | mSocket = 0; | 1270 | mSocket = 0; |
1271 | mSyncActionDialog = 0; | 1271 | mSyncActionDialog = 0; |
1272 | blockRC = false; | 1272 | blockRC = false; |
1273 | mErrorMessage = 0; | 1273 | mErrorMessage = 0; |
1274 | } | 1274 | } |
1275 | void KServerSocket::waitForSocketFinish() | 1275 | void KServerSocket::waitForSocketFinish() |
1276 | { | 1276 | { |
1277 | if ( mSocket ) { | 1277 | if ( mSocket ) { |
1278 | qDebug("KSS:: waiting for finish operation"); | 1278 | //qDebug("KSS:: waiting for finish operation"); |
1279 | QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish())); | 1279 | QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish())); |
1280 | return; | 1280 | return; |
1281 | } | 1281 | } |
1282 | mSocket = new QSocket( this ); | 1282 | mSocket = new QSocket( this ); |
1283 | connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); | 1283 | connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); |
1284 | connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); | 1284 | connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); |
1285 | mSocket->setSocket( mPendingConnect ); | 1285 | mSocket->setSocket( mPendingConnect ); |
1286 | mPendingConnect = 0; | 1286 | mPendingConnect = 0; |
1287 | } | 1287 | } |
1288 | void KServerSocket::newConnection ( int socket ) | 1288 | void KServerSocket::newConnection ( int socket ) |
1289 | { | 1289 | { |
1290 | // qDebug("KServerSocket:New connection %d ", socket); | 1290 | // qDebug("KServerSocket:New connection %d ", socket); |
1291 | if ( mPendingConnect ) { | 1291 | if ( mPendingConnect ) { |
1292 | qDebug("KSS::Error : new Connection"); | 1292 | qDebug("KSS::Error : new Connection"); |
1293 | return; | 1293 | return; |
1294 | } | 1294 | } |
1295 | if ( mSocket ) { | 1295 | if ( mSocket ) { |
1296 | mPendingConnect = socket; | 1296 | mPendingConnect = socket; |
1297 | QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish())); | 1297 | QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish())); |
1298 | return; | 1298 | return; |
1299 | qDebug("KSS::newConnection Socket deleted! "); | 1299 | qDebug("KSS::newConnection Socket deleted! "); |
1300 | delete mSocket; | 1300 | delete mSocket; |
1301 | mSocket = 0; | 1301 | mSocket = 0; |
1302 | } | 1302 | } |
1303 | mPendingConnect = 0; | 1303 | mPendingConnect = 0; |
1304 | mSocket = new QSocket( this ); | 1304 | mSocket = new QSocket( this ); |
1305 | connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); | 1305 | connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); |
1306 | connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); | 1306 | connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); |
1307 | mSocket->setSocket( socket ); | 1307 | mSocket->setSocket( socket ); |
1308 | } | 1308 | } |
1309 | 1309 | ||
1310 | void KServerSocket::discardClient() | 1310 | void KServerSocket::discardClient() |
@@ -1559,89 +1559,89 @@ KCommandSocket::KCommandSocket ( QString remres, QString password, Q_UINT16 port | |||
1559 | mFirst = false; | 1559 | mFirst = false; |
1560 | mFirstLine = true; | 1560 | mFirstLine = true; |
1561 | mPort = port; | 1561 | mPort = port; |
1562 | mHost = host; | 1562 | mHost = host; |
1563 | tlw = cap; | 1563 | tlw = cap; |
1564 | mRetVal = quiet; | 1564 | mRetVal = quiet; |
1565 | mTimerSocket = new QTimer ( this ); | 1565 | mTimerSocket = new QTimer ( this ); |
1566 | connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( updateConnectDialog() ) ); | 1566 | connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( updateConnectDialog() ) ); |
1567 | mConnectProgress.setCaption( i18n("Pi-Sync") ); | 1567 | mConnectProgress.setCaption( i18n("Pi-Sync") ); |
1568 | connect( &mConnectProgress, SIGNAL ( cancelled () ), this, SLOT ( deleteSocket() ) ); | 1568 | connect( &mConnectProgress, SIGNAL ( cancelled () ), this, SLOT ( deleteSocket() ) ); |
1569 | mConnectCount = -1; | 1569 | mConnectCount = -1; |
1570 | } | 1570 | } |
1571 | void KCommandSocket::sendFileRequest() | 1571 | void KCommandSocket::sendFileRequest() |
1572 | { | 1572 | { |
1573 | if ( tlw ) | 1573 | if ( tlw ) |
1574 | tlw->setCaption( i18n("Connected! Sending request for remote file ...") ); | 1574 | tlw->setCaption( i18n("Connected! Sending request for remote file ...") ); |
1575 | mConnectProgress.hide(); | 1575 | mConnectProgress.hide(); |
1576 | mConnectCount = 300;mConnectMax = 300; | 1576 | mConnectCount = 300;mConnectMax = 300; |
1577 | mConnectProgress.setCaption( i18n("Pi-Sync: Connected!") ); | 1577 | mConnectProgress.setCaption( i18n("Pi-Sync: Connected!") ); |
1578 | mConnectProgress.setLabelText( i18n("Waiting for remote file...") ); | 1578 | mConnectProgress.setLabelText( i18n("Waiting for remote file...") ); |
1579 | mTimerSocket->start( 100, true ); | 1579 | mTimerSocket->start( 100, true ); |
1580 | QTextStream os( mSocket ); | 1580 | QTextStream os( mSocket ); |
1581 | os.setEncoding( QTextStream::Latin1 ); | 1581 | os.setEncoding( QTextStream::Latin1 ); |
1582 | 1582 | ||
1583 | QString curDt = " " +KGlobal::locale()->formatDateTime(QDateTime::currentDateTime().addSecs(-1),true, true,KLocale::ISODate ); | 1583 | QString curDt = " " +KGlobal::locale()->formatDateTime(QDateTime::currentDateTime().addSecs(-1),true, true,KLocale::ISODate ); |
1584 | os << "GET " << mPassWord << curDt << " " << mRemoteResource << "\r\n\r\n"; | 1584 | os << "GET " << mPassWord << curDt << " " << mRemoteResource << "\r\n\r\n"; |
1585 | } | 1585 | } |
1586 | 1586 | ||
1587 | void KCommandSocket::readFile( QString fn ) | 1587 | void KCommandSocket::readFile( QString fn ) |
1588 | { | 1588 | { |
1589 | if ( !mSocket ) { | 1589 | if ( !mSocket ) { |
1590 | mSocket = new QSocket( this ); | 1590 | mSocket = new QSocket( this ); |
1591 | qDebug("KCS: read file - new socket"); | 1591 | //qDebug("KCS: read file - new socket"); |
1592 | connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); | 1592 | connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); |
1593 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); | 1593 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); |
1594 | connect( mSocket, SIGNAL(connected ()), this, SLOT(sendFileRequest() )); | 1594 | connect( mSocket, SIGNAL(connected ()), this, SLOT(sendFileRequest() )); |
1595 | } | 1595 | } |
1596 | mFileString = ""; | 1596 | mFileString = ""; |
1597 | mFileName = fn; | 1597 | mFileName = fn; |
1598 | mFirst = true; | 1598 | mFirst = true; |
1599 | if ( tlw ) | 1599 | if ( tlw ) |
1600 | tlw->setCaption( i18n("Trying to connect to remote...") ); | 1600 | tlw->setCaption( i18n("Trying to connect to remote...") ); |
1601 | mConnectCount = 30;mConnectMax = 30; | 1601 | mConnectCount = 30;mConnectMax = 30; |
1602 | mTimerSocket->start( 1000, true ); | 1602 | mTimerSocket->start( 1000, true ); |
1603 | mSocket->connectToHost( mHost, mPort ); | 1603 | mSocket->connectToHost( mHost, mPort ); |
1604 | qDebug("KCS: Waiting for connection"); | 1604 | qDebug("KCS: Waiting for connection"); |
1605 | } | 1605 | } |
1606 | void KCommandSocket::updateConnectDialog() | 1606 | void KCommandSocket::updateConnectDialog() |
1607 | { | 1607 | { |
1608 | 1608 | ||
1609 | if ( mConnectCount == mConnectMax ) { | 1609 | if ( mConnectCount == mConnectMax ) { |
1610 | qDebug("MAXX %d", mConnectMax); | 1610 | //qDebug("MAXX %d", mConnectMax); |
1611 | mConnectProgress.setTotalSteps ( 30 ); | 1611 | mConnectProgress.setTotalSteps ( 30 ); |
1612 | mConnectProgress.show(); | 1612 | mConnectProgress.show(); |
1613 | mConnectProgress.setLabelText( i18n("Trying to connect to remote...") ); | 1613 | mConnectProgress.setLabelText( i18n("Trying to connect to remote...") ); |
1614 | } | 1614 | } |
1615 | qDebug("updateConnectDialog() %d", mConnectCount); | 1615 | //qDebug("updateConnectDialog() %d", mConnectCount); |
1616 | mConnectProgress.raise(); | 1616 | mConnectProgress.raise(); |
1617 | mConnectProgress.setProgress( (mConnectMax - mConnectCount)%30 ); | 1617 | mConnectProgress.setProgress( (mConnectMax - mConnectCount)%30 ); |
1618 | --mConnectCount; | 1618 | --mConnectCount; |
1619 | if ( mConnectCount > 0 ) | 1619 | if ( mConnectCount > 0 ) |
1620 | mTimerSocket->start( 1000, true ); | 1620 | mTimerSocket->start( 1000, true ); |
1621 | else | 1621 | else |
1622 | deleteSocket(); | 1622 | deleteSocket(); |
1623 | 1623 | ||
1624 | } | 1624 | } |
1625 | void KCommandSocket::writeFile( QString fileName ) | 1625 | void KCommandSocket::writeFile( QString fileName ) |
1626 | { | 1626 | { |
1627 | if ( !mSocket ) { | 1627 | if ( !mSocket ) { |
1628 | mSocket = new QSocket( this ); | 1628 | mSocket = new QSocket( this ); |
1629 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); | 1629 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); |
1630 | connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); | 1630 | connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); |
1631 | } | 1631 | } |
1632 | mFileName = fileName ; | 1632 | mFileName = fileName ; |
1633 | mConnectCount = 30;mConnectMax = 30; | 1633 | mConnectCount = 30;mConnectMax = 30; |
1634 | mTimerSocket->start( 1000, true ); | 1634 | mTimerSocket->start( 1000, true ); |
1635 | mSocket->connectToHost( mHost, mPort ); | 1635 | mSocket->connectToHost( mHost, mPort ); |
1636 | } | 1636 | } |
1637 | void KCommandSocket::writeFileToSocket() | 1637 | void KCommandSocket::writeFileToSocket() |
1638 | { | 1638 | { |
1639 | mTimerSocket->stop(); | 1639 | mTimerSocket->stop(); |
1640 | QFile file2( mFileName ); | 1640 | QFile file2( mFileName ); |
1641 | if (!file2.open( IO_ReadOnly ) ) { | 1641 | if (!file2.open( IO_ReadOnly ) ) { |
1642 | mConnectProgress.hide(); | 1642 | mConnectProgress.hide(); |
1643 | mConnectCount = -1; | 1643 | mConnectCount = -1; |
1644 | mRetVal= errorW; | 1644 | mRetVal= errorW; |
1645 | mSocket->close(); | 1645 | mSocket->close(); |
1646 | if ( mSocket->state() == QSocket::Idle ) | 1646 | if ( mSocket->state() == QSocket::Idle ) |
1647 | QTimer::singleShot( 10, this , SLOT ( deleteSocket())); | 1647 | QTimer::singleShot( 10, this , SLOT ( deleteSocket())); |