automatically close ongoing uploads when we stop sharing an extra file

libretroshare/src/ft/ftcontroller.cc

@@ -1541,6 +1541,11 @@ std::string ftController::getPartialsDirectory()
 	return mPartialsPath;
 }
 
+bool  ftController::FileServerCancel(const RsFileHash& hash)
+{
+    RsStackMutex stack(ctrlMutex); /******* LOCKED ********/
+    return mDataplex->deleteServer(hash);
+}
 bool ftController::setDestinationDirectory(const RsFileHash& hash,const std::string& dest_dir)
 {
 	RsStackMutex stack(ctrlMutex); /******* LOCKED ********/

libretroshare/src/ft/ftcontroller.h

@@ -157,6 +157,7 @@ public:
         bool  getFileDownloadChunksDetails(const RsFileHash& hash,FileChunksInfo& info);
         bool  setDestinationName(const RsFileHash& hash,const std::string& dest_name) ;
         bool  setDestinationDirectory(const RsFileHash& hash,const std::string& dest_name) ;
+        bool  FileServerCancel(const RsFileHash& hash);
 
 		// Download speed
         bool getPriority(const RsFileHash& hash,DwlSpeed& p);

libretroshare/src/ft/ftdatamultiplex.cc

@@ -1039,6 +1039,23 @@ void ftDataMultiplex::handlePendingCrcRequests()
 			}
 }
 
+bool ftDataMultiplex::deleteServer(const RsFileHash& hash)
+{
+    RsStackMutex stack(dataMtx); /******* LOCK MUTEX ******/
+
+    auto sit = mServers.find(hash);
+
+    if(sit == mServers.end())
+        return false;
+
+    // We don't delete servers that are clients at the same time !
+    if(dynamic_cast<ftFileCreator*>(sit->second) == NULL)
+        delete sit->second;
+
+    mServers.erase(sit);
+    return true;
+}
+
 void ftDataMultiplex::deleteUnusedServers()
 {
 	RsStackMutex stack(dataMtx); /******* LOCK MUTEX ******/

libretroshare/src/ft/ftdatamultiplex.h

@@ -113,9 +113,9 @@ class ftDataMultiplex: public ftDataRecv, public RsQueueThread
 		bool    FileDetails(const RsFileHash &hash, FileSearchFlags hintsflag, FileInfo &info);
 
         void deleteUnusedServers() ;
+        bool deleteServer(const RsFileHash& hash);	// deletes FtServers for the given hash. Used when removing an extra file from shares.
         void handlePendingCrcRequests() ;
 
-
 		/*************** SEND INTERFACE (calls ftDataSend) *******************/
 
 		/* Client Send */

libretroshare/src/ft/ftserver.cc

@@ -817,7 +817,10 @@ bool  ftServer::ExtraFileAdd(std::string fname, const RsFileHash& hash, uint64_t
 }
 
 bool ftServer::ExtraFileRemove(const RsFileHash& hash)
-{ return mFileDatabase->removeExtraFile(hash); }
+{
+    mFtController->FileServerCancel(hash);
+    return mFileDatabase->removeExtraFile(hash);
+}
 
 bool ftServer::ExtraFileHash( std::string localpath, rstime_t period, TransferRequestFlags flags )
 {