mirror of
https://github.com/kingk85/uFTP.git
synced 2025-04-12 10:48:40 +03:00
Wait for thread cancel
This commit is contained in:
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
BIN
build/uFTP
BIN
build/uFTP
Binary file not shown.
@ -501,7 +501,7 @@ int parseCommandPasv(ftpDataType * data, int socketId)
|
||||
{
|
||||
printf("\nQuit command received the Pasv Thread has been cancelled!!!");
|
||||
usleep(10000);
|
||||
} while (ftpData->clients[socketId].workerData.threadIsAlive == 1);
|
||||
} while (data->clients[socketId].workerData.threadIsAlive == 1);
|
||||
}
|
||||
|
||||
if (data->clients[socketId].workerData.threadHasBeenCreated == 1)
|
||||
@ -542,7 +542,7 @@ int parseCommandPort(ftpDataType * data, int socketId)
|
||||
{
|
||||
printf("\nQuit command received the Pasv Thread has been cancelled!!!");
|
||||
usleep(10000);
|
||||
} while (ftpData->clients[socketId].workerData.threadIsAlive == 1);
|
||||
} while (data->clients[socketId].workerData.threadIsAlive == 1);
|
||||
}
|
||||
if (data->clients[socketId].workerData.threadHasBeenCreated == 1)
|
||||
{
|
||||
@ -580,7 +580,7 @@ int parseCommandAbor(ftpDataType * data, int socketId)
|
||||
{
|
||||
printf("\nQuit command received the Pasv Thread has been cancelled!!!");
|
||||
usleep(10000);
|
||||
} while (ftpData->clients[socketId].workerData.threadIsAlive == 1);
|
||||
} while (data->clients[socketId].workerData.threadIsAlive == 1);
|
||||
}
|
||||
|
||||
returnCode = socketPrintf(data, socketId, "s", "426 ABORT\r\n");
|
||||
|
@ -638,7 +638,7 @@ void resetClientData(ftpDataType *data, int clientId, int isInitialization)
|
||||
{
|
||||
printf("\nQuit command received the Pasv Thread has been cancelled!!!");
|
||||
usleep(10000);
|
||||
} while (ftpData->clients[clientId].workerData.threadIsAlive == 1);
|
||||
} while (data->clients[clientId].workerData.threadIsAlive == 1);
|
||||
|
||||
}
|
||||
pthread_mutex_destroy(&data->clients[clientId].conditionMutex);
|
||||
|
Reference in New Issue
Block a user