Changeset 11108

Timestamp:

Aug 4, 2010, 1:56:51 PM (12 years ago)

Author:

charles

Message:

(2.0x qt) #3481 "crash when accessing a remote session that's password protected" -- fixed

Location:

branches/2.0x/qt

Files:

• session.cc (modified) (10 diffs)
• session.h (modified) (3 diffs)

branches/2.0x/qt/session.cc

@@ -231 +231 @@
     myPrefs( prefs ),
     mySession( 0 ),
-    myConfigDir( configDir )
+    myConfigDir( configDir ),
+    myNAM( 0 )
 {
     myStats.ratio = TR_RATIO_NA;
@@ -241 +242 @@
     myCumulativeStats = myStats;
 
-    connect( &myNAM, SIGNAL(finished(QNetworkReply*)), this, SLOT(onFinished(QNetworkReply*)) );
-    connect( &myNAM, SIGNAL(authenticationRequired(QNetworkReply*,QAuthenticator*)), this, SIGNAL(httpAuthenticationRequired()) );
     connect( &myPrefs, SIGNAL(changed(int)), this, SLOT(updatePref(int)) );
 }
@@ -249 +248 @@
 {
     stop( );
+}
+
+QNetworkAccessManager *
+Session :: networkAccessManager( )
+{
+    if( myNAM == 0 )
+    {
+        myNAM = new QNetworkAccessManager;
+
+        connect( myNAM, SIGNAL(finished(QNetworkReply*)),
+                 this, SLOT(onFinished(QNetworkReply*)) );
+
+        connect( myNAM, SIGNAL(authenticationRequired(QNetworkReply*,QAuthenticator*)),
+                 this, SIGNAL(httpAuthenticationRequired()) );
+    }
+
+    return myNAM;
 }
 
@@ -258 +274 @@
 Session :: stop( )
 {
-    foreach( Reply myReply, myReplies )
-        myReply.networkReply->abort();
+    if( myNAM != 0 )
+    {
+        myNAM->deleteLater( );
+        myNAM = 0;
+    }
+
     myUrl.clear( );
 
@@ -281 +301 @@
     if( myPrefs.get<bool>(Prefs::SESSION_IS_REMOTE) )
     {
-        const int port( myPrefs.get<int>(Prefs::SESSION_REMOTE_PORT) );
-        const bool auth( myPrefs.get<bool>(Prefs::SESSION_REMOTE_AUTH) );
-        const QString host( myPrefs.get<QString>(Prefs::SESSION_REMOTE_HOST) );
-        const QString user( myPrefs.get<QString>(Prefs::SESSION_REMOTE_USERNAME) );
-        const QString pass( myPrefs.get<QString>(Prefs::SESSION_REMOTE_PASSWORD) );
-
         QUrl url;
         url.setScheme( "http" );
-        url.setHost( host );
-        url.setPort( port );
+        url.setHost( myPrefs.get<QString>(Prefs::SESSION_REMOTE_HOST) );
+        url.setPort( myPrefs.get<int>(Prefs::SESSION_REMOTE_PORT) );
         url.setPath( "/transmission/rpc" );
-        if( auth ) {
-            url.setUserName( user );
-            url.setPassword( pass );
+        if( myPrefs.get<bool>(Prefs::SESSION_REMOTE_AUTH) )
+        {
+            url.setUserName( myPrefs.get<QString>(Prefs::SESSION_REMOTE_USERNAME) );
+            url.setPassword( myPrefs.get<QString>(Prefs::SESSION_REMOTE_PASSWORD) );
         }
         myUrl = url;
@@ -584 +599 @@
 }
 
+#define REQUEST_DATA_PROPERTY_KEY "requestData"
+
 void
 Session :: exec( const char * json )
@@ -600 +617 @@
             request.setRawHeader( TR_RPC_SESSION_ID_HEADER, mySessionId.toAscii() );
 
-        QBuffer * reqbuf = new QBuffer;
-        reqbuf->setData( QByteArray( json ) );
-
-        QNetworkReply * reply = myNAM.post( request, reqbuf );
+        const QByteArray requestData( json );
+        QNetworkReply * reply = networkAccessManager()->post( request, requestData );
+        reply->setProperty( REQUEST_DATA_PROPERTY_KEY, requestData );
         connect( reply, SIGNAL(downloadProgress(qint64,qint64)), this, SIGNAL(dataReadProgress()));
         connect( reply, SIGNAL(uploadProgress(qint64,qint64)), this, SIGNAL(dataSendProgress()));
 
-        Reply myReply;
-        myReply.networkReply = reply;
-        myReply.buffer = reqbuf;
-        myReplies << myReply;
 #ifdef DEBUG_HTTP
         std::cerr << "sending " << "POST " << qPrintable( myUrl.path() ) << std::endl;
@@ -626 +638 @@
 Session :: onFinished( QNetworkReply * reply )
 {
-    QBuffer * buffer;
-    for( QList<Reply>::iterator i = myReplies.begin(); i != myReplies.end(); ++i )
-    {
-        if( reply == i->networkReply )
-        {
-            buffer = i->buffer;
-            myReplies.erase( i );
-            break;
-        }
-    }
-
 #ifdef DEBUG_HTTP
     std::cerr << "http response header: " << std::endl;
@@ -653 +654 @@
         // update it and resubmit the request.
         mySessionId = QString( reply->rawHeader( TR_RPC_SESSION_ID_HEADER ) );
-        exec( buffer->buffer().constData() );
+        exec( reply->property( REQUEST_DATA_PROPERTY_KEY ).toByteArray( ).constData( ) );
     }
     else if( reply->error() != QNetworkReply::NoError )
@@ -668 +669 @@
     }
 
-    delete buffer;
     reply->deleteLater();
 }

branches/2.0x/qt/session.h

@@ -32 +32 @@
 
 class Prefs;
-
-struct Reply
-{
-    QNetworkReply * networkReply;
-    QBuffer * buffer;
-};
-typedef QList<Reply> ReplyList;
 
 class Session: public QObject
@@ -95 +88 @@
         static void updateStats( struct tr_benc * d, struct tr_session_stats * stats );
         void refreshTorrents( const QSet<int>& torrentIds );
+        QNetworkAccessManager * networkAccessManager( );
 
     public:
@@ -147 +141 @@
         QString mySessionId;
         QUrl myUrl;
-        QNetworkAccessManager myNAM;
-        ReplyList myReplies;
+        QNetworkAccessManager * myNAM;
         struct tr_session_stats myStats;
         struct tr_session_stats myCumulativeStats;