author | zecke <zecke> | 2003-11-21 09:37:54 (UTC) |
---|---|---|
committer | zecke <zecke> | 2003-11-21 09:37:54 (UTC) |
commit | 10ae99b2cbbf3e24f3568367a85b3b2d6c0fa289 (patch) (unidiff) | |
tree | ac9c821ddeef8d6e05024206e19b7dc780791611 | |
parent | 99ecb210f893437068060194b031cb37b94a0398 (diff) | |
download | opie-10ae99b2cbbf3e24f3568367a85b3b2d6c0fa289.zip opie-10ae99b2cbbf3e24f3568367a85b3b2d6c0fa289.tar.gz opie-10ae99b2cbbf3e24f3568367a85b3b2d6c0fa289.tar.bz2 |
Fix bug 1219.
If not authorized no dtp is created
so 0x000000000->close is likely to fail.
lpotter something I think Qtopia suffers from as well
-rw-r--r-- | core/launcher/transferserver.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/launcher/transferserver.cpp b/core/launcher/transferserver.cpp index eea9f3a..9519d11 100644 --- a/core/launcher/transferserver.cpp +++ b/core/launcher/transferserver.cpp | |||
@@ -316,65 +316,67 @@ ServerPI::ServerPI( int socket, QObject *parent, const char* name ) | |||
316 | connect( this, SIGNAL( readyRead() ), SLOT( read() ) ); | 316 | connect( this, SIGNAL( readyRead() ), SLOT( read() ) ); |
317 | connect( this, SIGNAL( connectionClosed() ), SLOT( connectionClosed() ) ); | 317 | connect( this, SIGNAL( connectionClosed() ), SLOT( connectionClosed() ) ); |
318 | 318 | ||
319 | passiv = FALSE; | 319 | passiv = FALSE; |
320 | for( int i = 0; i < 4; i++ ) | 320 | for( int i = 0; i < 4; i++ ) |
321 | wait[i] = FALSE; | 321 | wait[i] = FALSE; |
322 | 322 | ||
323 | send( "220 Qtopia " QPE_VERSION " FTP Server" ); // No tr | 323 | send( "220 Qtopia " QPE_VERSION " FTP Server" ); // No tr |
324 | state = Wait_USER; | 324 | state = Wait_USER; |
325 | 325 | ||
326 | dtp = new ServerDTP( this ); | 326 | dtp = new ServerDTP( this ); |
327 | connect( dtp, SIGNAL( completed() ), SLOT( dtpCompleted() ) ); | 327 | connect( dtp, SIGNAL( completed() ), SLOT( dtpCompleted() ) ); |
328 | connect( dtp, SIGNAL( failed() ), SLOT( dtpFailed() ) ); | 328 | connect( dtp, SIGNAL( failed() ), SLOT( dtpFailed() ) ); |
329 | connect( dtp, SIGNAL( error( int ) ), SLOT( dtpError( int ) ) ); | 329 | connect( dtp, SIGNAL( error( int ) ), SLOT( dtpError( int ) ) ); |
330 | 330 | ||
331 | 331 | ||
332 | directory = QDir::currentDirPath(); | 332 | directory = QDir::currentDirPath(); |
333 | 333 | ||
334 | static int p = 1024; | 334 | static int p = 1024; |
335 | 335 | ||
336 | while ( !serversocket || !serversocket->ok() ) { | 336 | while ( !serversocket || !serversocket->ok() ) { |
337 | delete serversocket; | 337 | delete serversocket; |
338 | serversocket = new ServerSocket( ++p, this ); | 338 | serversocket = new ServerSocket( ++p, this ); |
339 | } | 339 | } |
340 | connect( serversocket, SIGNAL( newIncomming( int ) ), | 340 | connect( serversocket, SIGNAL( newIncomming( int ) ), |
341 | SLOT( newConnection( int ) ) ); | 341 | SLOT( newConnection( int ) ) ); |
342 | } | 342 | } |
343 | } | 343 | } |
344 | 344 | ||
345 | ServerPI::~ServerPI() | 345 | ServerPI::~ServerPI() |
346 | { | 346 | { |
347 | close(); | 347 | close(); |
348 | dtp->close(); | 348 | |
349 | if ( dtp ) | ||
350 | dtp->close(); | ||
349 | delete dtp; | 351 | delete dtp; |
350 | delete serversocket; | 352 | delete serversocket; |
351 | } | 353 | } |
352 | 354 | ||
353 | bool ServerPI::verifyAuthorised() | 355 | bool ServerPI::verifyAuthorised() |
354 | { | 356 | { |
355 | if ( !SyncAuthentication::isAuthorized(peerAddress()) ) { | 357 | if ( !SyncAuthentication::isAuthorized(peerAddress()) ) { |
356 | state = Forbidden; | 358 | state = Forbidden; |
357 | return FALSE; | 359 | return FALSE; |
358 | } | 360 | } |
359 | return TRUE; | 361 | return TRUE; |
360 | } | 362 | } |
361 | 363 | ||
362 | void ServerPI::connectionClosed() | 364 | void ServerPI::connectionClosed() |
363 | { | 365 | { |
364 | // qDebug( "Debug: Connection closed" ); | 366 | // qDebug( "Debug: Connection closed" ); |
365 | emit connectionClosed(this); | 367 | emit connectionClosed(this); |
366 | } | 368 | } |
367 | 369 | ||
368 | void ServerPI::send( const QString& msg ) | 370 | void ServerPI::send( const QString& msg ) |
369 | { | 371 | { |
370 | QTextStream os( this ); | 372 | QTextStream os( this ); |
371 | os << msg << endl; | 373 | os << msg << endl; |
372 | //qDebug( "Reply: %s", msg.latin1() ); | 374 | //qDebug( "Reply: %s", msg.latin1() ); |
373 | } | 375 | } |
374 | 376 | ||
375 | void ServerPI::read() | 377 | void ServerPI::read() |
376 | { | 378 | { |
377 | while ( canReadLine() ) | 379 | while ( canReadLine() ) |
378 | process( readLine().stripWhiteSpace() ); | 380 | process( readLine().stripWhiteSpace() ); |
379 | } | 381 | } |
380 | 382 | ||