diff -r 866b4af7ffbe -r 841f70763fbe localconnectivityservice/dun/utils/src/DunDataPusher.cpp --- a/localconnectivityservice/dun/utils/src/DunDataPusher.cpp Tue Sep 28 20:14:08 2010 +0800 +++ b/localconnectivityservice/dun/utils/src/DunDataPusher.cpp Thu Nov 04 15:31:42 2010 +0800 @@ -202,34 +202,11 @@ // Stops sending for write endpoint // --------------------------------------------------------------------------- // -TInt CDunDataPusher::Stop() +void CDunDataPusher::Stop() { FTRACE(FPrint( _L("CDunDataPusher::Stop()" ))); - if ( iPushState != EDunStateDataPushing ) - { - FTRACE(FPrint( _L("CDunDataPusher::Stop() (not ready) complete" ))); - return KErrNotReady; - } - // As the EDunStateDataPushing can be on even with multiple requests, - // cancel the actual operation in DoCancel() Cancel(); - iPushState = EDunStateIdle; FTRACE(FPrint( _L("CDunDataPusher::Stop() complete" ))); - return KErrNone; - } - -// --------------------------------------------------------------------------- -// Stops sending for write endpoint and clears event queue -// --------------------------------------------------------------------------- -// -TInt CDunDataPusher::StopAndClearQueue() - { - FTRACE(FPrint( _L("CDunDataPusher::StopAndClearQueue()" ))); - TInt retVal = Stop(); - iEventQueue.Reset(); - iEventIndex = 0; - FTRACE(FPrint( _L("CDunDataPusher::StopAndClearQueue() complete" ))); - return retVal; } // --------------------------------------------------------------------------- @@ -309,7 +286,6 @@ { // Don't initialize iUtility here (it is set through NewL) // Don't initialize iStreamCallback here (it is set through NewL) - iPushState = EDunStateIdle; iEventIndex = 0; iSocket = NULL; iComm = NULL; @@ -336,16 +312,12 @@ const TDesC8* dataToPush = iEventQueue[iEventIndex].iDataToPush; if ( iComm ) { - iStatus = KRequestPending; - iPushState = EDunStateDataPushing; iComm->Write( iStatus, *dataToPush ); SetActive(); FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() RComm Write() requested for %d bytes... (buffer=0x%08X)" ), dataToPush->Length(), dataToPush )); } else if ( iSocket ) { - iStatus = KRequestPending; - iPushState = EDunStateDataPushing; iSocket->Send( *dataToPush, 0, iStatus ); SetActive(); FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() RSocket Send() requested for %d bytes... (buffer=0x%08X)" ), dataToPush->Length(), dataToPush )); @@ -408,13 +380,11 @@ else { // Last was served so stop processing and notify - iPushState = EDunStateIdle; iStreamCallback->NotifyDataPushComplete( ETrue ); } } // if ( !stop ) else // stop -> tear down connection { - iPushState = EDunStateIdle; TDunConnectionReason connReason; connReason.iReasonType = EDunReasonTypeRW; connReason.iContext = EDunMediaContextLocal; @@ -449,5 +419,9 @@ iSocket->CancelWrite(); FTRACE(FPrint( _L("CDunDataPusher::DoCancel() (RSocket) cancelled" ))); } + else + { + FTRACE(FPrint( _L("CDunDataPusher::DoCancel() (ERROR) complete" ))); + } FTRACE(FPrint( _L("CDunDataPusher::DoCancel() complete" ))); }