FCL/sf/mw/mmappfw: comparison mmappcomponents/harvester/filehandler/src/mpxharvesterfilehandlerimp.cpp

equal deleted inserted replaced

-:51035f0751c2
+:4740b34b83ce
 * Nokia Corporation - initial contribution.
 *
 * Contributors:
 *
 * Description:  Handles all file related activities
-*  Version     : %version: da1mmcf#72.1.14.2.4.1.4.1.2.1.4 % << Don't touch! Updated by Synergy at check-out.
+*  Version     : %version: da1mmcf#72.1.14.2.4.1.4.1.2.1.6 % << Don't touch! Updated by Synergy at check-out.
 *
 */
 #include <e32base.h>
 #include <f32file.h>
 #include <centralrepository.h>
-#ifdef RD_MULTIPLE_DRIVE
 #include <pathinfo.h>
 #include <driveinfo.h>
-#endif //RD_MULTIPLE_DRIVE
 #include <mpxlog.h>
 #include <mpxharvestercommon.h>
 #include <mpxmedia.h>
 #include <mpxmediaarray.h>
 //
 iDBManager = CMPXHarvesterDatabaseManager::NewL( iFs );
 // List of watchers for different drives
 //
-#ifdef RD_MULTIPLE_DRIVE
 TDriveList driveList;
 TInt driveCount(0);
 User::LeaveIfError( DriveInfo::GetUserVisibleDrives(
 iFs, driveList, driveCount ) );
 CleanupStack::PushL( dw );
 iDiskMonitors.AppendL( dw );
 CleanupStack::Pop( dw );
 }
 }
-#else
-CMPXDiskSpaceWatcher* dw_e = CMPXDiskSpaceWatcher::NewL( iFs, EDriveE, *this );
-CleanupStack::PushL( dw_e );
-iDiskMonitors.AppendL( dw_e );
-CleanupStack::Pop( dw_e );
-CMPXDiskSpaceWatcher* dw_c = CMPXDiskSpaceWatcher::NewL( iFs, EDriveC, *this );
-CleanupStack::PushL( dw_c );
-iDiskMonitors.AppendL( dw_c );
-CleanupStack::Pop( dw_c );
-#endif // RD_MULTIPLE_DRIVE
 TInt openerr = iDBManager->OpenAllDatabasesL();
 // Temporary collection utility
 //
 colUtil->Close();
 // Get the scan drives from cenrep.
 //
 ParseScanPathL();
+RefreshScanDrivesL();
 // Get the list of container types
 iContainerTypes = new(ELeave) CDesCArrayFlat(2);  // granularity
 ParseContainersL();
 }
 // Create the database synchronizer
 iDbSynchronizer = CMPXDbSynchronizer::NewL(*this,*iDBManager,iMusicCollectionId,
 iPodcastCollectionId,iFs, iDisablePodcasting);
-#ifdef RD_MULTIPLE_DRIVE
-// Use default MMC drive as the Removable drive
-User::LeaveIfError( DriveInfo::GetDefaultDrive(
-DriveInfo::EDefaultRemovableMassStorage,
-iRemovedDrive ) );
-#endif
 // Create DRM Notifier and register for AddRemove event
 iDrmNotifier = CDRMNotifier::NewL();
 iDrmNotifier->RegisterEventObserverL( *this, KEventAddRemove );
 iCurUSBEvent = KErrNotFound;
 {
 iContainerTypes->Reset();
 }
 delete iContainerTypes;
-iFilteredDrivesToScan.Reset();
 iFilteredDrivesToScan.Close();
-iDrivesToScan.Reset();
 iDrivesToScan.Close();
-iPathsToBlock.Reset();
+iConfiguredDrivesToScan.Close();
 iPathsToBlock.Close();
 // Cleans up the scanning tables and arrays
 Reset();
 return;
 }
 iCollectionUtil->Collection().NotifyL( EMcMsgRefreshStart, KErrNone );
-// Reopen databases
-iDBManager->OpenAllDatabasesL();
 // Begin transaction on databases
 iDBManager->BeginL();
 //Remove out of disk space drives from scanned drives list
 iFilteredDrivesToScan.Reset();
+iFilteredOutOfDisk = EFalse;
 CopyArrayL(iDrivesToScan.Array(),iFilteredDrivesToScan);
 iOutOfDisk = EFalse;
 TInt driveCount (iDiskMonitors.Count());
 TBool outOfDisk(EFalse);
 TFileName driveName(fileNameParser.Drive());
 TInt driveNumber = TDriveUnit( driveName );
 if (currentDriveNumber == driveNumber)
 {
 iFilteredDrivesToScan.Remove(index);
+iFilteredOutOfDisk = ETrue;
 count--;
 }
 else
 {
 index++;
 }
 }
-TRAP_IGNORE(iDBManager->RemoveDatabaseL(static_cast<TDriveNumber>(currentDriveNumber)));
+iDBManager->CloseDatabase(static_cast<TDriveNumber>(currentDriveNumber));
 }
 }
 iSynchronizing = CheckDbInSyncL();
 // 4: USB end we re-open all db and scan for new files
 // 5: MTP start we stop monitoring for new files (no dismount)
 // 6: MTP end we re-open all db, files added already, restart monitor
 // 7: Disk dismount: stop scanning, close the dismounting DB
 //
-#ifdef RD_MULTIPLE_DRIVE
 // Get all visible drives
 TDriveList driveList;
 TInt driveCount(0);
 TPtrC drivePresent(_L("present"));
 TPtrC driveNotPresent(_L("not present"));
 (driveStatus&DriveInfo::EDrivePresent)?&drivePresent:&driveNotPresent,
 (driveStatus&DriveInfo::EDriveInUse)?&driveInUse:&driveAvailable,
 (driveStatus&DriveInfo::EDriveFormatted)?&driveFormatted:&driveNotFormatted);
 }
 }
-#endif //RD_MULTIPLE_DRIVE
 switch( aEvent )
 {
 case EFormatStartEvent:
 {
-MPX_DEBUG1("Disk Format start event");
+MPX_DEBUG2("Disk Format start event, drive %d", aData);
+iIdle->Cancel();
 CancelScan();
 iDBManager->CloseDatabase( (TDriveNumber) aData );
+RefreshScanDrivesL();
 break;
 }
 case EDiskRemovedEvent:
 {
-MPX_DEBUG1("Disk Removed event");
+MPX_DEBUG2("Disk Removed event, drive %d", aData);
 iIdle->Cancel();
 CancelScan();
-#ifdef RD_MULTIPLE_DRIVE
+iDBManager->DropDatabase ( TDriveNumber( aData ) );
-TBool dbClosed( EFalse );
+RefreshScanDrivesL();
-for( TInt driveNum = EDriveA; driveNum <= EDriveZ; driveNum++ )
-{
-if (driveList[driveNum] && (!iDBManager->IsRemoteDrive(static_cast<TDriveNumber>(driveNum))))
-{
-TUint driveStatus(0);
-User::LeaveIfError( DriveInfo::GetDriveStatus(
-iFs, driveNum, driveStatus ) );
-if (!(driveStatus & DriveInfo::EDrivePresent ))
-{
-// Close database for non-present drive
-iDBManager->CloseDatabase( (TDriveNumber) driveNum );
-// Save the drive
-iRemovedDrive = driveNum;
-dbClosed = ETrue;
-break;
-}
-}
-}
-if( !dbClosed )
-{
-// GetUserVisibleDrives / RFs::DriveList does not return drive at all
-// if it is dismounted using file server methods. This occurs at least
-// when removing card using power menu eject.
-// If the drive reported as removed is not ready, close db on that drive.
-TUint driveStatus(0);
-TInt err( DriveInfo::GetDriveStatus( iFs, aData, driveStatus ) );
-MPX_DEBUG4("Drive %d status 0x%x, err %d", aData, driveStatus, err);
-if( err == KErrNotReady )
-{
-iDBManager->CloseDatabase( (TDriveNumber) aData );
-iRemovedDrive = aData;
-}
-}
-#else
-iDBManager->CloseDatabase( (TDriveNumber) aData );
-#endif // RD_MULTIPLE_DRIVE
 break;
 }
 case EFormatEndEvent:
 {
-MPX_DEBUG1("Disk Format end event");
+MPX_DEBUG2("Disk Format end event, drive %d", aData);
 CancelScan();
 iDBManager->OpenDatabaseL( (TDriveNumber) aData );
+RefreshScanDrivesL();
 break;
 }
 case EDiskInsertedEvent:
 {
-MPX_DEBUG1("Disk Insert event");
+MPX_DEBUG2("Disk Insert event %d", aData);
 CancelScan();
-#ifdef RD_MULTIPLE_DRIVE
-iDBManager->OpenDatabaseL( (TDriveNumber) iRemovedDrive );
-#else
 iDBManager->OpenDatabaseL( (TDriveNumber) aData );
-#endif // RD_MULTIPLE_DRIVE
+RefreshScanDrivesL();
 break;
 }
 case EUSBMassStorageStartEvent:
 {
 if (iCurUSBEvent == EUSBMassStorageStartEvent)
-	{
+{
-	break;
+break;
-	}
+}
 iIdle->Cancel();
+iDBManager->CloseMassStorageDatabases();
+RefreshScanDrivesL();
 CancelScan();
-#ifdef RD_MULTIPLE_DRIVE
-// Close all databases other than the phone memory database
-for( TInt driveNum = EDriveA; driveNum <= EDriveZ; driveNum++ )
-{
-if (driveList[driveNum]  && (!iDBManager->IsRemoteDrive(static_cast<TDriveNumber>(driveNum))))
-{
-if ( driveNum != EDriveC )
-{
-iDBManager->CloseDatabase( (TDriveNumber) driveNum );
-}
-}
-}
-#else
-iDBManager->CloseDatabase( (TDriveNumber) aData );
-#endif // RD_MULTIPLE_DRIVE
 iCurUSBEvent = EUSBMassStorageStartEvent;
 break;
 }
 case EUSBMassStorageEndEvent:
 {
-#ifdef RD_MULTIPLE_DRIVE
+iDBManager->OpenAllDatabasesL();
-// Open all databases other than the phone memory
+RefreshScanDrivesL();
-for( TInt driveNum = EDriveA; driveNum <= EDriveZ; driveNum++ )
-{
-if (driveList[driveNum] && (!iDBManager->IsRemoteDrive(static_cast<TDriveNumber>(driveNum))))
-{
-if ( driveNum != EDriveC )
-{
-iDBManager->OpenDatabaseL( (TDriveNumber) driveNum );
-}
-}
-}
-#else
-iDBManager->OpenDatabaseL( (TDriveNumber) aData );
-#endif // RD_MULTIPLE_DRIVE
 iCurUSBEvent = EUSBMassStorageEndEvent;
 break;
 }
-case EUSBMTPNotActiveEvent: // deliberate fall through
+case EUSBMTPNotActiveEvent:
 {
 if (iCurUSBEvent == EUSBMTPNotActiveEvent)
 	{
 	break;
 	}
 }
 case EUSBMTPStartEvent:
 {
 CancelScan();
 iCurUSBEvent = EUSBMTPStartEvent;
-// nothing to do, db is needed for MTP
 #ifdef __RAMDISK_PERF_ENABLE
-// if statement needed because of fall through above.
+iDBManager->CopyDBsToRamL(ETrue);
-if ( aEvent == EUSBMTPStartEvent )
-{
-// copy dbs to ram drive
-iDBManager->CopyDBsToRamL(ETrue);
-}
 #endif //__RAMDISK_PERF_ENABLE
 break;
 }
 case EUSBMTPEndEvent:
 {
 iCurUSBEvent = EUSBMTPEndEvent;
-// nothing to do, db is updated by MTP
 #ifdef __RAMDISK_PERF_ENABLE
 // copy dbs from ram drive
 iDBManager->CopyDBsFromRamL();
 #endif //__RAMDISK_PERF_ENABLE
 break;
 }
 case EDiskDismountEvent:
 {
 MPX_DEBUG2("Disk dismount notification, drive %d", aData);
+iIdle->Cancel();
+if ( aData < 0 )
+{
+iDBManager->CloseMassStorageDatabases();
+}
+else
+{
+iDBManager->CloseDatabase( (TDriveNumber) aData );
+}
+RefreshScanDrivesL();
 CancelScan();
-iDBManager->CloseDatabase( (TDriveNumber) aData );
 break;
 }
 default:
 {
 MPX_DEBUG1("CCMPXHarvesterFileHandlerImp::HandleSystemEventL Unknown system event!");
 // Re-create all databases
 // ---------------------------------------------------------------------------
 //
 void CMPXHarvesterFileHandlerImp::RecreateDatabases()
 {
-MPX_DEBUG1("CMPXHarvesterFileHandlerImp::RecreateDatabasesL <--");
+MPX_DEBUG1("CMPXHarvesterFileHandlerImp::RecreateDatabases <--");
 iDBManager->RecreateDatabases();
-MPX_DEBUG1("CMPXHarvesterFileHandlerImp::RecreateDatabasesL -->");
+TRAP_IGNORE(RefreshScanDrivesL());
+MPX_DEBUG1("CMPXHarvesterFileHandlerImp::RecreateDatabases -->");
 }
 // ---------------------------------------------------------------------------
 // Close database transaction
 // ---------------------------------------------------------------------------
 // Handle a change in the file system, could be a file added/removed
 // ---------------------------------------------------------------------------
 //
 void CMPXHarvesterFileHandlerImp::HandleDirectoryChangedL( const TDesC& aPath )
 {
+MPX_DEBUG2("--->CMPXHarvesterFileHandlerImp::HandleDirectoryChangedL path=%S", &aPath);
 // Delay the scanning for a few seconds so the files are finished
 // copying. If already active, means we just append onto the list
-//
+// But don't scan if there is no DB == drive does not exist any more
-iAutoScanPaths.AppendL( aPath );
+TParsePtrC parse( aPath );
-if( !iIdle->IsActive() )
+TDriveUnit drive ( parse.Drive() );
-{
+if ( iDBManager->DatabaseIsOpen ((TDriveNumber) (TInt) drive) )
-TCallBack cb( Callback, this );
+{
-iIdle->Start( TTimeIntervalMicroSeconds32( KAutoScanDelay ),
+MPX_DEBUG1("CMPXHarvesterFileHandlerImp::HandleDirectoryChangedL adding in iAutoScanPaths");
-TTimeIntervalMicroSeconds32( KAutoScanAfter ),
+iAutoScanPaths.AppendL( aPath );
-cb );
+if( !iIdle->IsActive() )
-}
+{
+TCallBack cb( Callback, this );
+iIdle->Start( TTimeIntervalMicroSeconds32( KAutoScanDelay ),
+TTimeIntervalMicroSeconds32( KAutoScanAfter ),
+cb );
+}
+}
 }
 // ---------------------------------------------------------------------------
 // Handles opening the drive
 // ---------------------------------------------------------------------------
 //
 void CMPXHarvesterFileHandlerImp::HandleOpenDriveL( TDriveNumber aDrive,
 const TDesC& aFolder )
 {
+MPX_DEBUG3("--->CMPXHarvesterFileHandlerImp::HandleOpenDriveL drive=%d, folder=%S", aDrive, &aFolder);
 #ifdef __PRINTDB__
 if( iCurTable )
 iCurTable->PrintItemsInTableL();
 #endif //__PRINTDB__
 Reset();
 #ifdef __RAMDISK_PERF_ENABLE
 // EnsureRamSpaceL will copy dbs from ram if ram space is low or dbs exceeded max space.
 iDBManager->EnsureRamSpaceL();
 #endif // __RAMDISK_PERF_ENABLE
-MPX_TRAPD( err, iCurDB = &iDBManager->GetDatabaseL( aDrive ) );
+iCurDB = &iDBManager->GetDatabaseL( aDrive );
-if ( err != KErrNone )
-{
-iDBManager->OpenAllDatabasesL();
-iCurDB = &iDBManager->GetDatabaseL( aDrive );
-}
 if( iDrivesToScan.Find( aFolder ) != KErrNotFound )
 {
 iCurTable = iCurDB->OpenAllFilesTableL();
 }
 else
 {
 iCurTable = iCurDB->OpenDirectoryL( aFolder );
 }
 iCurList = iCurTable->CreateTableRepresentationL();
+MPX_DEBUG1("<--CMPXHarvesterFileHandlerImp::HandleOpenDriveL");
 }
 // ---------------------------------------------------------------------------
 // Is this a media file we are interested in
 // ---------------------------------------------------------------------------
 blockPath = KDefaultBlockPath;
 }
 MPX_DEBUG2("ParseScanPathL scanPaths: %S", &scanPath);
 MPX_DEBUG2("ParseScanPathL blockPaths: %S", &blockPath);
-::ExtractTokensL( scanPath, iDrivesToScan );
+::ExtractTokensL( scanPath, iConfiguredDrivesToScan );
 ::ExtractTokensL( blockPath, iPathsToBlock );
 }
 // ---------------------------------------------------------------------------
 // Parses cenrep setting for container file types
 monitor->StartL( array->MdcaPoint(i) );
 }
 CleanupStack::PopAndDestroy( array );
 }
+// ---------------------------------------------------------------------------
+// Refreshes scan drives
+// ---------------------------------------------------------------------------
+//
+void CMPXHarvesterFileHandlerImp::RefreshScanDrivesL()
+{
+iDrivesToScan.Reset();
+for (TInt i = 0; i < iConfiguredDrivesToScan.Count(); ++i)
+{
+const TDesC& path = iConfiguredDrivesToScan[i];
+TParsePtrC parse(path);
+TDriveUnit drive(parse.Drive());
+if ( iDBManager->DatabaseIsOpen( (TDriveNumber)(TInt) drive) )
+{
+iDrivesToScan.AppendL(path);
+}
+}
+}
 // ---------------------------------------------------------------------------
 // Resets the scanning table and array
 // ---------------------------------------------------------------------------
 //
 void CMPXHarvesterFileHandlerImp::Reset()
 {
 // If no error or cancel, return the final number of items added
 MPX_DEBUG2("Scan error %i", aErr );
-// Reopen databases (in case we removed them for out of disk drives before scan)
+if( aErr == KErrNone || aErr == KErrCancel )
-iDBManager->OpenAllDatabasesL();
-if( aErr == KErrNone )
 {
 // Commit the changes on databases in transaction
 iDBManager->CommitL();
 }
 else
 #ifdef __RAMDISK_PERF_ENABLE
 // copy dbs from ram drive
 iDBManager->CopyDBsFromRamL();
 #endif //__RAMDISK_PERF_ENABLE
+// Reopen databases (in case we removed them for out of disk drives before scan)
+for (TInt i = 0, j = 0; i < iDrivesToScan.Count(); ++i)
+{
+if ( j < iFilteredDrivesToScan.Count() && ! iDrivesToScan[i].Compare( iFilteredDrivesToScan[j] ) )
+{
+++j;
+}
+else
+{
+TParsePtrC fileNameParser ( iDrivesToScan[i] );
+TDriveUnit drive ( fileNameParser.Drive() );
+TRAP_IGNORE( iDBManager->OpenDatabaseL( TDriveNumber ( (TInt) drive ) ) );
+}
+}
 if( aErr == KErrNone || aErr == KErrCancel )
 {
 aErr = iAddedCount;
 }
-if (iFilteredDrivesToScan.Count() != iDrivesToScan.Count())
+if ( iFilteredOutOfDisk )
 {
 aErr = KErrDiskFull;
 }
 if( iRefreshing )
 {
 // Add a path to scan
 iRefreshCount++;
 CancelScan();
 Reset();
-iFolderScanner->ScanL( iAutoScanPaths );
+// ensure you don't try to scan paths that are on closed drives
+for (TInt i = 0; i < iAutoScanPaths.Count(); )
+{
+TParsePtr parse(iAutoScanPaths[i]);
+TDriveUnit drive(parse.Drive());
+if ( iDBManager->DatabaseIsOpen( (TDriveNumber) (TInt) drive ) )
+{
+++i;
+}
+else
+{
+iAutoScanPaths.Remove(i);
+}
+}
+if ( iAutoScanPaths.Count() )
+{
+iFolderScanner->ScanL( iAutoScanPaths );
+}
 // Cleanup
 iAutoScanPaths.Reset();
 iIdle->Cancel();
 }
 RPointerArray<CMPXHarvesterDbItem>* tempList=NULL;
 RPointerArray<CMPXHarvesterDbItem>* drmFileList = new (ELeave) RPointerArray<CMPXHarvesterDbItem>;
 CleanupStack::PushL( drmFileList );
-#ifdef RD_MULTIPLE_DRIVE
 TDriveList driveList;
 TInt driveCount(0);
 // Get all visible drives
 if ( KErrNone == DriveInfo::GetUserVisibleDrives(
 CleanupStack::PopAndDestroy( tempList );
 CleanupStack::PopAndDestroy( table );
 }
 }
 	}
-#else
-//ensure drive E is ready
-//otherwise GetDataBaseL will leave if MMC is removed
-if ( IsDriveReady( EDriveE ) )
-{
-// Get DRM files from database in E drive
-db = &iDBManager->GetDatabaseL( EDriveE );
-table = db->OpenDrmFileL();
-CleanupStack::PushL( table );
-tempList = table->CreateTableRepresentationL();
-CleanupStack::PushL( tempList );
-// copy content to drm file list
-for ( TInt i=0; i<tempList->Count(); i++ )
-{
-drmFileList->AppendL( (*tempList)[i] );
-}
-// reset
-tempList->Reset();
-CleanupStack::PopAndDestroy( tempList );
-CleanupStack::PopAndDestroy( table );
-}
-// Get DRM files from database in C drive
-db = &iDBManager->GetDatabaseL( EDriveC );
-table = db->OpenDrmFileL();
-CleanupStack::PushL( table );
-tempList = table->CreateTableRepresentationL();
-CleanupStack::PushL( tempList );
-// copy content to iCurList
-for ( TInt i=0; i<tempList->Count(); i++ )
-{
-drmFileList->AppendL( (*tempList)[i] );
-}
-tempList->Reset();
-CleanupStack::PopAndDestroy( tempList );
-CleanupStack::PopAndDestroy( table );
-#endif
 CleanupStack::Pop( drmFileList );
 MPX_DEBUG1("CMPXHarvesterFileHandlerImp::GetDrmFiles --->");
 return drmFileList;
 }
-// ---------------------------------------------------------------------------
-// Verifies if aDrive is ready.
-// ---------------------------------------------------------------------------
-//
-TBool CMPXHarvesterFileHandlerImp::IsDriveReady( TDriveNumber aDrive )
-{
-MPX_DEBUG1("CMPXHarvesterFileHandlerImp::IsDriveReady <---");
-TDriveInfo driveInfo;
-TInt error = iFs.Drive( driveInfo, aDrive );
-TBool ready = ETrue;
-if ( error != KErrNone )
-{
-ready = EFalse;
-}
-else if ( driveInfo.iDriveAtt == static_cast<TUint>( KDriveAbsent ) )
-{
-//aDrive is absent
-ready = EFalse;
-}
-else
-{
-TVolumeInfo volumeInfo;
-TInt errCode = iFs.Volume( volumeInfo, aDrive );
-if( errCode != KErrNone )
-{
-//aDrive is ready for use
-ready = EFalse;
-}
-}
-MPX_DEBUG1("CMPXHarvesterFileHandlerImp::IsDriveReady --->");
-return ready;
-}
 // END OF FILE

branch	RCL_3
changeset 23	4740b34b83ce
parent 19	51035f0751c2
child 30	6f9f6e99a23e