Commit: c3c5ce768282208e5678f485c889484f9343cb48 - ffftp (git)

FFFTPのソースコードです。

Commit MetaInfo

• Revision: c3c5ce768282208e5678f485c889484f9343cb48 (tree)
• Time: 2012-02-07 00:36:12
• Author: s_kawamoto <s_kawamoto@user...>
• Commiter: s_kawamoto

Log Message

Fix bugs of simultaneous connection.
Fix bugs of exclusive locks for UI.

Change Summary

• modified: FFFTP_Eng_Release/FFFTP.exe
• modified: Release/FFFTP.exe
• modified: filelist.c
• modified: ftpproc.c
• modified: getput.c

Incremental Difference

Binary files a/FFFTP_Eng_Release/FFFTP.exe and b/FFFTP_Eng_Release/FFFTP.exe differ

Binary files a/Release/FFFTP.exe and b/Release/FFFTP.exe differ

--- a/filelist.c
+++ b/filelist.c
@@ -786,6 +786,9 @@ static LRESULT FileListCommonWndProc(HWND hWnd, UINT message, WPARAM wParam, LPA
 			return(CallWindowProc(ProcPtr, hWnd, message, wParam, lParam));
 
 		case WM_DROPFILES :
+			// 同時接続対応
+			if(AskUserOpeDisabled() == YES)
+				break;
 			// ドラッグ中は処理しない。ドラッグ後にWM_LBUTTONDOWNが飛んでくるため、そこで処理する。
 			if (Dragging == YES) 
 				return (FALSE);
@@ -818,6 +821,9 @@ static LRESULT FileListCommonWndProc(HWND hWnd, UINT message, WPARAM wParam, LPA
 				hCsrDrg = LoadCursor(NULL, IDC_ARROW);
 				SetCursor(hCsrDrg);
 
+				// 同時接続対応
+				if(AskUserOpeDisabled() == YES)
+					break;
 				Point.x = (long)(short)LOWORD(lParam);
 				Point.y = (long)(short)HIWORD(lParam);
 				ClientToScreen(hWnd, &Point);

--- a/ftpproc.c
+++ b/ftpproc.c
@@ -261,8 +261,9 @@ void DownLoadProc(int ChName, int ForceFile, int All)
 		}
 		DeleteFileList(&FileListBase);
 
-		strcpy(Pkt.Cmd, "GOQUIT");
-		AddTransFileList(&Pkt);
+		// 同時接続対応
+//		strcpy(Pkt.Cmd, "GOQUIT");
+//		AddTransFileList(&Pkt);
 
 		GoForwardTransWindow();
 //		KeepTransferDialog(NO);
@@ -363,8 +364,9 @@ void DirectDownLoadProc(char *Fname)
 			AddTransFileList(&Pkt);
 		}
 
-		strcpy(Pkt.Cmd, "GOQUIT");
-		AddTransFileList(&Pkt);
+		// 同時接続対応
+//		strcpy(Pkt.Cmd, "GOQUIT");
+//		AddTransFileList(&Pkt);
 
 		GoForwardTransWindow();
 //		KeepTransferDialog(NO);
@@ -629,8 +631,9 @@ void MirrorDownloadProc(int Notify)
 					AddTransFileList(&Pkt);
 				}
 
-				strcpy(Pkt.Cmd, "GOQUIT");
-				AddTransFileList(&Pkt);
+				// 同時接続対応
+//				strcpy(Pkt.Cmd, "GOQUIT");
+//				AddTransFileList(&Pkt);
 			}
 			else
 				EraseTmpTransFileList(&Base);
@@ -1056,8 +1059,9 @@ void UpLoadListProc(int ChName, int All)
 
 		DeleteFileList(&FileListBase);
 
-		strcpy(Pkt.Cmd, "GOQUIT");
-		AddTransFileList(&Pkt);
+		// 同時接続対応
+//		strcpy(Pkt.Cmd, "GOQUIT");
+//		AddTransFileList(&Pkt);
 
 		GoForwardTransWindow();
 
@@ -1223,8 +1227,9 @@ void UpLoadDragProc(WPARAM wParam)
 
 		DeleteFileList(&FileListBase);
 
-		strcpy(Pkt.Cmd, "GOQUIT");
-		AddTransFileList(&Pkt);
+		// 同時接続対応
+//		strcpy(Pkt.Cmd, "GOQUIT");
+//		AddTransFileList(&Pkt);
 
 		GoForwardTransWindow();
 
@@ -1494,8 +1499,9 @@ void MirrorUploadProc(int Notify)
 					AddTransFileList(&Pkt);
 				}
 
-				strcpy(Pkt.Cmd, "GOQUIT");
-				AddTransFileList(&Pkt);
+				// 同時接続対応
+//				strcpy(Pkt.Cmd, "GOQUIT");
+//				AddTransFileList(&Pkt);
 			}
 			else
 				EraseTmpTransFileList(&Base);

--- a/getput.c
+++ b/getput.c
@@ -537,7 +537,7 @@ static void EraseTransFileList(void)
 	TRANSPACKET *New;
 	TRANSPACKET *Next;
 	TRANSPACKET *NotDel;
-	TRANSPACKET Pkt;
+//	TRANSPACKET Pkt;
 
 	NotDel = NULL;
 
@@ -582,8 +582,9 @@ static void EraseTransFileList(void)
 	// 同時接続対応
 	WaitForMainThread = NO;
 
-	strcpy(Pkt.Cmd, "GOQUIT");
-	AddTransFileList(&Pkt);
+	// 同時接続対応
+//	strcpy(Pkt.Cmd, "GOQUIT");
+//	AddTransFileList(&Pkt);
 	return;
 }
 
@@ -742,6 +743,8 @@ static ULONG WINAPI TransferThread(void *Dummy)
 			Pos = TransPacketBase;
 			TransPacketBase = TransPacketBase->Next;
 			free(Pos);
+			if(TransPacketBase == NULL)
+				GoExit = YES;
 		}
 		NewCmdSkt = AskCmdCtrlSkt();
 		if(AskReuseCmdSkt() == YES && ThreadCount == 0)
@@ -759,9 +762,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 				else
 					CheckClosedAndReconnectTrnSkt(&TrnSkt, &Canceled[ThreadCount]);
 				// 同時ログイン数制限対策
-				if(TrnSkt != INVALID_SOCKET)
-					LastUsed = timeGetTime();
-				else
+				if(TrnSkt == INVALID_SOCKET)
 				{
 					// 同時ログイン数制限に引っかかった可能性あり
 					// 負荷を下げるために約10秒間待機
@@ -773,6 +774,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 						i--;
 					}
 				}
+				LastUsed = timeGetTime();
 //				WaitForSingleObject(hListAccMutex, INFINITE);
 				while(WaitForSingleObject(hListAccMutex, 0) == WAIT_TIMEOUT)
 				{
@@ -786,7 +788,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 				{
 					// 同時ログイン数制限対策
 					// 60秒間使用されなければログアウト
-					if(timeGetTime() - LastUsed > 60000)
+					if(timeGetTime() - LastUsed > 60000 || NewCmdSkt == INVALID_SOCKET)
 					{
 						ReleaseMutex(hListAccMutex);
 						SendData(TrnSkt, "QUIT\r\n", 6, 0, &Canceled[ThreadCount]);
@@ -806,13 +808,6 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //		if(TransPacketBase != NULL)
 		if(TrnSkt != INVALID_SOCKET && NextTransPacketBase != NULL)
 		{
-			if(strcmp(NextTransPacketBase->Cmd, "GOQUIT") == 0 && NextTransPacketBase != TransPacketBase)
-			{
-				ReleaseMutex(hListAccMutex);
-				BackgrndMessageProc();
-				Sleep(1);
-				continue;
-			}
 			Pos = NextTransPacketBase;
 			NextTransPacketBase = NextTransPacketBase->Next;
 			// ディレクトリ操作は非同期で行わない
@@ -841,6 +836,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //			TransPacketBase->hWndTrans = hWndTrans;
 			Pos->hWndTrans = hWndTrans;
 			Pos->ctrl_skt = TrnSkt;
+			Pos->Abort = ABORT_NONE;
 			Pos->ThreadCount = ThreadCount;
 
 			if(hWndTrans != NULL)
@@ -856,6 +852,9 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //				SendMessage(hWndTrans, WM_SET_PACKET, 0, (LPARAM)TransPacketBase);
 				SendMessage(hWndTrans, WM_SET_PACKET, 0, (LPARAM)Pos);
 
+			// 中断後に受信バッファに応答が残っていると次のコマンドの応答が正しく処理できない
+			RemoveReceivedData(TrnSkt);
+
 			/* ダウンロード */
 //			if(strncmp(TransPacketBase->Cmd, "RETR", 4) == 0)
 			if(strncmp(Pos->Cmd, "RETR", 4) == 0)
@@ -1110,11 +1109,11 @@ static ULONG WINAPI TransferThread(void *Dummy)
 			}
 			/* 自動終了のための通知 */
 //			else if(strcmp(TransPacketBase->Cmd, "GOQUIT") == 0)
-			else if(strcmp(Pos->Cmd, "GOQUIT") == 0)
-			{
-				ReleaseMutex(hListAccMutex);
-				GoExit = YES;
-			}
+//			else if(strcmp(Pos->Cmd, "GOQUIT") == 0)
+//			{
+//				ReleaseMutex(hListAccMutex);
+//				GoExit = YES;
+//			}
 			else
 				ReleaseMutex(hListAccMutex);
 
@@ -1134,6 +1133,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 					for(i = 0; i < MAX_DATA_CONNECTION; i++)
 						Canceled[i] = YES;
 					EraseTransFileList();
+					GoExit = YES;
 					Pos = NULL;
 				}
 				else
@@ -1152,7 +1152,7 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //					TransPacketBase = TransPacketBase->Next;
 //					free(Pos);
 				}
-				ClearAll = NO;
+//				ClearAll = NO;
 				ReleaseMutex(hListAccMutex);
 
 				if(BackgrndMessageProc() == YES)
@@ -1171,8 +1171,25 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //		else
 		else if(TransPacketBase == NULL)
 		{
+			ClearAll = NO;
 			DelNotify = NO;
 
+			if(GoExit == YES)
+			{
+				SoundPlay(SND_TRANS);
+				if(AskAutoExit() == NO)
+				{
+					if(Down == YES)
+						PostMessage(GetMainHwnd(), WM_REFRESH_LOCAL_FLG, 0, 0);
+					if(Up == YES)
+						PostMessage(GetMainHwnd(), WM_REFRESH_REMOTE_FLG, 0, 0);
+				}
+				Down = NO;
+				Up = NO;
+				PostMessage(GetMainHwnd(), WM_COMMAND, MAKEWPARAM(MENU_AUTO_EXIT, 0), 0);
+				GoExit = NO;
+			}
+
 			ReleaseMutex(hListAccMutex);
 			if(KeepDlg == NO)
 			{
@@ -1201,22 +1218,6 @@ static ULONG WINAPI TransferThread(void *Dummy)
 //			Sleep(1);
 			Sleep(100);
 
-			if(GoExit == YES)
-			{
-				SoundPlay(SND_TRANS);
-				if(AskAutoExit() == NO)
-				{
-					if(Down == YES)
-						PostMessage(GetMainHwnd(), WM_REFRESH_LOCAL_FLG, 0, 0);
-					if(Up == YES)
-						PostMessage(GetMainHwnd(), WM_REFRESH_REMOTE_FLG, 0, 0);
-				}
-				Down = NO;
-				Up = NO;
-				PostMessage(GetMainHwnd(), WM_COMMAND, MAKEWPARAM(MENU_AUTO_EXIT, 0), 0);
-				GoExit = NO;
-			}
-
 			// 再転送対応
 			TransferErrorMode = AskTransferErrorMode();
 			TransferErrorNotify = AskTransferErrorNotify();
@@ -1346,6 +1347,8 @@ int DoDownLoad(SOCKET cSkt, TRANSPACKET *Pkt, int DirList, int *CancelCheckWork)
 		}
 		else
 			SetErrorMsg(Reply);
+		// エラーによってはダイアログが表示されない場合があるバグ対策
+		DispDownloadFinishMsg(Pkt, iRetCode);
 	}
 	else
 	{
@@ -1353,8 +1356,6 @@ int DoDownLoad(SOCKET cSkt, TRANSPACKET *Pkt, int DirList, int *CancelCheckWork)
 		SetTaskMsg(MSGJPN089, Pkt->RemoteFile);
 		iRetCode = 200;
 	}
-	// エラーによってはダイアログが表示されない場合があるバグ対策
-	DispDownloadFinishMsg(Pkt, iRetCode);
 	return(iRetCode);
 }
 
@@ -2281,6 +2282,8 @@ static void DispDownloadFinishMsg(TRANSPACKET *Pkt, int iRetCode)
 {
 	char Fname[FMAX_PATH+1];
 
+	// 同時接続対応
+	ReleaseMutex(hListAccMutex);
 	if(ForceAbort == NO)
 	{
 		if((iRetCode/100) >= FTP_CONTINUE)
@@ -2300,7 +2303,9 @@ static void DispDownloadFinishMsg(TRANSPACKET *Pkt, int iRetCode)
 				return;
 #endif
 
-			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0))
+			// MLSD対応
+//			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0))
+			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0) || (strncmp(Pkt->Cmd, "MLSD", 4) == 0))
 			{
 				SetTaskMsg(MSGJPN097);
 				strcpy(Fname, MSGJPN098);
@@ -2337,7 +2342,9 @@ static void DispDownloadFinishMsg(TRANSPACKET *Pkt, int iRetCode)
 		}
 		else
 		{
-			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0))
+			// MLSD対応
+//			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0))
+			if((strncmp(Pkt->Cmd, "NLST", 4) == 0) || (strncmp(Pkt->Cmd, "LIST", 4) == 0) || (strncmp(Pkt->Cmd, "MLSD", 4) == 0))
 				SetTaskMsg(MSGJPN101, Pkt->ExistSize);
 			// 同時接続対応
 //			else if((Pkt->hWndTrans != NULL) && (TimeStart != 0))
@@ -2610,6 +2617,8 @@ static int DoUpLoad(SOCKET cSkt, TRANSPACKET *Pkt)
 			// エラーによってはダイアログが表示されない場合があるバグ対策
 //			DispUploadFinishMsg(Pkt, iRetCode);
 		}
+		// エラーによってはダイアログが表示されない場合があるバグ対策
+		DispUploadFinishMsg(Pkt, iRetCode);
 	}
 	else
 	{
@@ -2617,8 +2626,6 @@ static int DoUpLoad(SOCKET cSkt, TRANSPACKET *Pkt)
 		SetTaskMsg(MSGJPN107, Pkt->LocalFile);
 		iRetCode = 200;
 	}
-	// エラーによってはダイアログが表示されない場合があるバグ対策
-	DispUploadFinishMsg(Pkt, iRetCode);
 	return(iRetCode);
 }
 
@@ -3579,6 +3586,8 @@ static int TermCodeConvAndSend(TERMCODECONVINFO *tInfo, SOCKET Skt, char *Data,
 
 static void DispUploadFinishMsg(TRANSPACKET *Pkt, int iRetCode)
 {
+	// 同時接続対応
+	ReleaseMutex(hListAccMutex);
 	if(ForceAbort == NO)
 	{
 		if((iRetCode/100) >= FTP_CONTINUE)
@@ -3738,8 +3747,6 @@ static LRESULT CALLBACK TransDlgProc(HWND hDlg, UINT Msg, WPARAM wParam, LPARAM
 //				if(!(Pkt = (TRANSPACKET*)GetWindowLong(hDlg, GWL_USERDATA)))
 				if(!(Pkt = (TRANSPACKET*)GetWindowLongPtr(hDlg, GWLP_USERDATA)))
 					break;
-				if(Canceled[Pkt->ThreadCount] == YES)
-					Pkt->Abort = ABORT_USER;
 				DispTransferStatus(hDlg, NO, Pkt);
 				SetTimer(hDlg, TIMER_DISPLAY, DISPLAY_TIMING, NULL);
 			}