diff --git a/source/shared_lib/sources/feathery_ftp/ftpRuntime.c b/source/shared_lib/sources/feathery_ftp/ftpRuntime.c index 8d5e7e0a..848f5636 100644 --- a/source/shared_lib/sources/feathery_ftp/ftpRuntime.c +++ b/source/shared_lib/sources/feathery_ftp/ftpRuntime.c @@ -146,18 +146,6 @@ int ftpExecute(void) int sessionId=0; int activeJobs=0; - activeJobs = ftpGetActiveTransCnt(); // are there any active transmitions? - for(n = 0; (activeJobs > 0) && (n < MAX_CONNECTIONS); n++) - { - pSession = ftpGetSession(n); - if(pSession->activeTrans.op) // has this session an active transmition? - { - processedWork = 1; - ftpExecTransmission(n); // do the job - activeJobs--; - } - } - if(ftpGetActiveTransCnt()) // don't block if there's still something to do { socksRdy = ftpSelect(TRUE); @@ -233,6 +221,18 @@ if(VERBOSE_MODE_ENABLED) printf("ERROR: Connection refused; Session limit reache } } } + + activeJobs = ftpGetActiveTransCnt(); // are there any active transmitions? + for(n = 0; (activeJobs > 0) && (n < MAX_CONNECTIONS); n++) + { + pSession = ftpGetSession(n); + if(pSession->activeTrans.op) // has this session an active transmition? + { + processedWork = 1; + ftpExecTransmission(n); // do the job + activeJobs--; + } + } return processedWork; } diff --git a/source/shared_lib/sources/feathery_ftp/ftpTargetPosix.c b/source/shared_lib/sources/feathery_ftp/ftpTargetPosix.c index f7017d39..84545910 100644 --- a/source/shared_lib/sources/feathery_ftp/ftpTargetPosix.c +++ b/source/shared_lib/sources/feathery_ftp/ftpTargetPosix.c @@ -289,7 +289,7 @@ socket_t ftpEstablishDataConnection(int passive, ip_t *ip, port_t *port, int ses if(VERBOSE_MODE_ENABLED) printf("\nPASSIVE CONNECTION for sessionId = %d using port #: %d about to listen on port: %d using listener socket: %d\n",sessionId,passivePort,*port,dataSocket); - if(listen(dataSocket, 1)) + if(listen(dataSocket, 100)) { if(VERBOSE_MODE_ENABLED) printf("\nPASSIVE CONNECTION for sessionId = %d using port #: %d FAILED #2: %d\n",sessionId,passivePort,dataSocket); @@ -357,7 +357,7 @@ socket_t ftpCreateServerSocket(int portNumber) return -2; } - if(listen(theServer, 16)) + if(listen(theServer, 100)) { ftpCloseSocket(&theServer); return -3; diff --git a/source/shared_lib/sources/feathery_ftp/ftpTargetWin32.c b/source/shared_lib/sources/feathery_ftp/ftpTargetWin32.c index a7548811..93494428 100644 --- a/source/shared_lib/sources/feathery_ftp/ftpTargetWin32.c +++ b/source/shared_lib/sources/feathery_ftp/ftpTargetWin32.c @@ -321,7 +321,7 @@ socket_t ftpEstablishDataConnection(int passive, ip_t *ip, port_t *port, int ses if(VERBOSE_MODE_ENABLED) printf("\nPASSIVE CONNECTION for sessionId = %d using port #: %d about to listen on port: %d using listener socket: %d\n",sessionId,passivePort,*port,dataSocket); - if(listen(dataSocket, 1)) + if(listen(dataSocket, 100)) { if(VERBOSE_MODE_ENABLED) printf("\nPASSIVE CONNECTION for sessionId = %d using port #: %d FAILED #2: %d\n",sessionId,passivePort,dataSocket); @@ -390,7 +390,7 @@ socket_t ftpCreateServerSocket(int portNumber) return -2; } - if(listen(theServer, 16)) + if(listen(theServer, 100)) { ftpCloseSocket(&theServer); return -3; diff --git a/source/shared_lib/sources/platform/common/platform_common.cpp b/source/shared_lib/sources/platform/common/platform_common.cpp index 5eb1e216..56a4f18a 100644 --- a/source/shared_lib/sources/platform/common/platform_common.cpp +++ b/source/shared_lib/sources/platform/common/platform_common.cpp @@ -339,8 +339,6 @@ void removeFolder(const string path) { SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] path [%s]\n",__FILE__,__FUNCTION__,__LINE__,path.c_str()); string deletePath = path + "*"; - //vector results; - //findAll(deletePath, results, false, false); vector results = getFolderTreeContentsListRecursively(deletePath, "", true); SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] path [%s] results.size() = %d\n",__FILE__,__FUNCTION__,__LINE__,path.c_str(),results.size()); @@ -367,6 +365,9 @@ void removeFolder(const string path) { SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] item [%s] result = %d\n",__FILE__,__FUNCTION__,__LINE__,item.c_str(),result); } } + + int result = rmdir(path.c_str()); + SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] path [%s] result = %d\n",__FILE__,__FUNCTION__,__LINE__,path.c_str(),result); } bool StartsWith(const std::string &str, const std::string &key) {