Commit: 0753f12ff930efe77518679bf9523cb63efbb7f7 - ffftp (git)

Loweynet

Commit MetaInfo

• Revisão: 0753f12ff930efe77518679bf9523cb63efbb7f7 (tree)
• Hora: 2012-01-25 22:19:55
• Autor: s_kawamoto <s_kawamoto@user...>
• Commiter: s_kawamoto

Mensagem de Log

Fix bugs of simultaneous connection.
Change default settings for simultaneous connection.
Fix bugs of handling errors of transferring.

Mudança Sumário

• modified: FFFTP_Eng_Release/FFFTP.exe
• modified: Release/FFFTP.exe
• modified: common.h
• modified: getput.c
• modified: hostman.c
• modified: mbswrapper.c
• modified: registry.c
• modified: socket.c
• modified: socketwrapper.c

Diff

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/common.h
+++ b/common.h
@@ -1837,7 +1837,8 @@ int do_send(SOCKET s, const char *buf, int len, int flags, int *TimeOutErr, int
 // 同時接続対応
 void RemoveReceivedData(SOCKET s);
 int CheckClosedAndReconnect(void);
-void CheckAllEventClosed(void);
+// 同時接続対応
+int CheckClosedAndReconnectTrnSkt(SOCKET *Skt, int *CancelCheckWork);
 
 /*===== updatebell.c =====*/
 

--- a/getput.c
+++ b/getput.c
@@ -753,40 +753,40 @@ static ULONG WINAPI TransferThread(void *Dummy)
 		{
 			if(TransPacketBase && NewCmdSkt != INVALID_SOCKET && ThreadCount < AskMaxThreadCount())
 			{
+				ReleaseMutex(hListAccMutex);
 				if(TrnSkt == INVALID_SOCKET || NewCmdSkt != CmdSkt)
-				{
-					ReleaseMutex(hListAccMutex);
 					ReConnectTrnSkt(&TrnSkt, &Canceled[ThreadCount]);
-					// 同時ログイン数制限対策
-					if(TrnSkt != INVALID_SOCKET)
-						LastUsed = timeGetTime();
-					else
-					{
-						// 同時ログイン数制限に引っかかった可能性あり
-						// 負荷を下げるために約10秒間待機
-						i = 10000;
-						while(NewCmdSkt != CmdSkt && i > 0)
-						{
-							BackgrndMessageProc();
-							Sleep(1);
-							i--;
-						}
-					}
-//					WaitForSingleObject(hListAccMutex, INFINITE);
-					while(WaitForSingleObject(hListAccMutex, 0) == WAIT_TIMEOUT)
+				else
+					CheckClosedAndReconnectTrnSkt(&TrnSkt, &Canceled[ThreadCount]);
+				// 同時ログイン数制限対策
+				if(TrnSkt != INVALID_SOCKET)
+					LastUsed = timeGetTime();
+				else
+				{
+					// 同時ログイン数制限に引っかかった可能性あり
+					// 負荷を下げるために約10秒間待機
+					i = 10000;
+					while(NewCmdSkt != CmdSkt && i > 0)
 					{
 						BackgrndMessageProc();
 						Sleep(1);
+						i--;
 					}
 				}
+//				WaitForSingleObject(hListAccMutex, INFINITE);
+				while(WaitForSingleObject(hListAccMutex, 0) == WAIT_TIMEOUT)
+				{
+					BackgrndMessageProc();
+					Sleep(1);
+				}
 			}
 			else
 			{
 				if(TrnSkt != INVALID_SOCKET)
 				{
 					// 同時ログイン数制限対策
-					// 10秒間は再利用を許可
-					if(timeGetTime() - LastUsed > 10000)
+					// 60秒間使用されなければログアウト
+					if(timeGetTime() - LastUsed > 60000)
 					{
 						ReleaseMutex(hListAccMutex);
 						SendData(TrnSkt, "QUIT\r\n", 6, 0, &Canceled[ThreadCount]);
@@ -1305,7 +1305,8 @@ int DoDownLoad(SOCKET cSkt, TRANSPACKET *Pkt, int DirList, int *CancelCheckWork)
 	{
 		iRetCode = 500;
 		SetTaskMsg(MSGJPN085, GetFileName(Pkt->LocalFile));
-		DispDownloadFinishMsg(Pkt, iRetCode);
+		// エラーによってはダイアログが表示されない場合があるバグ対策
+//		DispDownloadFinishMsg(Pkt, iRetCode);
 	}
 	else if(Pkt->Mode != EXIST_IGNORE)
 	{
@@ -1352,6 +1353,8 @@ int DoDownLoad(SOCKET cSkt, TRANSPACKET *Pkt, int DirList, int *CancelCheckWork)
 		SetTaskMsg(MSGJPN089, Pkt->RemoteFile);
 		iRetCode = 200;
 	}
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+	DispDownloadFinishMsg(Pkt, iRetCode);
 	return(iRetCode);
 }
 
@@ -1466,7 +1469,8 @@ static int DownLoadNonPassive(TRANSPACKET *Pkt, int *CancelCheckWork)
 		iRetCode = 500;
 		SetErrorMsg(MSGJPN279);
 	}
-	DispDownloadFinishMsg(Pkt, iRetCode);
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+//	DispDownloadFinishMsg(Pkt, iRetCode);
 
 	return(iRetCode);
 }
@@ -1563,7 +1567,8 @@ static int DownLoadPassive(TRANSPACKET *Pkt, int *CancelCheckWork)
 	else
 		SetErrorMsg(Buf);
 
-	DispDownloadFinishMsg(Pkt, iRetCode);
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+//	DispDownloadFinishMsg(Pkt, iRetCode);
 
 	return(iRetCode);
 }
@@ -2600,7 +2605,8 @@ static int DoUpLoad(SOCKET cSkt, TRANSPACKET *Pkt)
 			SetTaskMsg(MSGJPN105, Pkt->LocalFile);
 			iRetCode = 500;
 			Pkt->Abort = ABORT_ERROR;
-			DispUploadFinishMsg(Pkt, iRetCode);
+			// エラーによってはダイアログが表示されない場合があるバグ対策
+//			DispUploadFinishMsg(Pkt, iRetCode);
 		}
 	}
 	else
@@ -2609,6 +2615,8 @@ static int DoUpLoad(SOCKET cSkt, TRANSPACKET *Pkt)
 		SetTaskMsg(MSGJPN107, Pkt->LocalFile);
 		iRetCode = 200;
 	}
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+	DispUploadFinishMsg(Pkt, iRetCode);
 	return(iRetCode);
 }
 
@@ -2737,7 +2745,8 @@ static int UpLoadNonPassive(TRANSPACKET *Pkt)
 		SetErrorMsg(MSGJPN279);
 		iRetCode = 500;
 	}
-	DispUploadFinishMsg(Pkt, iRetCode);
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+//	DispUploadFinishMsg(Pkt, iRetCode);
 
 	return(iRetCode);
 }
@@ -2854,7 +2863,8 @@ static int UpLoadPassive(TRANSPACKET *Pkt)
 	else
 		SetErrorMsg(Buf);
 
-	DispUploadFinishMsg(Pkt, iRetCode);
+	// エラーによってはダイアログが表示されない場合があるバグ対策
+//	DispUploadFinishMsg(Pkt, iRetCode);
 
 	return(iRetCode);
 }

--- a/hostman.c
+++ b/hostman.c
@@ -1344,7 +1344,7 @@ void CopyDefaultHost(HOSTDATA *Set)
 	strcpy(Set->PrivateKey, "");
 	// 同時接続対応
 	Set->MaxThreadCount = 1;
-	Set->ReuseCmdSkt = NO;
+	Set->ReuseCmdSkt = YES;
 	Set->NoDisplayUI = NO;
 	// MLSD対応
 	Set->Feature = 0;

--- a/mbswrapper.c
+++ b/mbswrapper.c
@@ -699,10 +699,28 @@ END_ROUTINE
 ATOM RegisterClassExM(CONST WNDCLASSEXA * v0)
 {
 	ATOM r = 0;
+	wchar_t* pw0 = NULL;
+	wchar_t* pw1 = NULL;
+	WNDCLASSEXW a0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
-	r = RegisterClassExA(v0);
+	a0.cbSize = sizeof(WNDCLASSEXW);
+	a0.style = v0->style;
+	a0.lpfnWndProc = v0->lpfnWndProc;
+	a0.cbClsExtra = v0->cbClsExtra;
+	a0.cbWndExtra = v0->cbWndExtra;
+	a0.hInstance = v0->hInstance;
+	a0.hIcon = v0->hIcon;
+	a0.hCursor = v0->hCursor;
+	a0.hbrBackground = v0->hbrBackground;
+	pw0 = DuplicateMtoW(v0->lpszMenuName, -1);
+	a0.lpszMenuName = pw0;
+	pw1 = DuplicateMtoW(v0->lpszClassName, -1);
+	a0.lpszClassName = pw1;
+	a0.hIconSm = v0->hIconSm;
+	r = RegisterClassExW(&a0);
 END_ROUTINE
+	FreeDuplicatedString(pw0);
+	FreeDuplicatedString(pw1);
 	return r;
 }
 
@@ -725,7 +743,6 @@ LONG GetWindowLongM(HWND hWnd, int nIndex)
 {
 	LONG r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = GetWindowLongW(hWnd, nIndex);
 	else
@@ -738,7 +755,6 @@ LONG SetWindowLongM(HWND hWnd, int nIndex, LONG dwNewLong)
 {
 	LONG r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = SetWindowLongW(hWnd, nIndex, dwNewLong);
 	else
@@ -751,7 +767,6 @@ LONG_PTR GetWindowLongPtrM(HWND hWnd, int nIndex)
 {
 	LONG_PTR r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = GetWindowLongPtrW(hWnd, nIndex);
 	else
@@ -764,7 +779,6 @@ LONG_PTR SetWindowLongPtrM(HWND hWnd, int nIndex, LONG_PTR dwNewLong)
 {
 	LONG_PTR r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = SetWindowLongPtrW(hWnd, nIndex, dwNewLong);
 	else
@@ -777,7 +791,6 @@ LRESULT DefWindowProcM(HWND hWnd, UINT Msg, WPARAM wParam, LPARAM lParam)
 {
 	LRESULT r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = DefWindowProcW(hWnd, Msg, wParam, lParam);
 	else
@@ -790,7 +803,6 @@ LRESULT CallWindowProcM(WNDPROC lpPrevWndFunc, HWND hWnd, UINT Msg, WPARAM wPara
 {
 	LRESULT r = 0;
 START_ROUTINE
-	// WNDPROCがShift_JIS用であるため
 	if(IsWindowUnicode(hWnd))
 		r = CallWindowProcW(lpPrevWndFunc, hWnd, Msg, wParam, lParam);
 	else
@@ -1978,6 +1990,7 @@ BOOL ChooseFontM(LPCHOOSEFONTA v0)
 {
 	BOOL r = FALSE;
 	wchar_t* pw0 = NULL;
+	wchar_t* pw1 = NULL;
 	CHOOSEFONTW a0;
 	LOGFONTW* pwlf;
 START_ROUTINE
@@ -2010,9 +2023,11 @@ START_ROUTINE
 	a0.rgbColors = v0->rgbColors;
 	a0.lCustData = v0->lCustData;
 	a0.lpfnHook = v0->lpfnHook;
-	a0.lpTemplateName = DuplicateMtoW(v0->lpTemplateName, -1);
+	pw0 = DuplicateMtoW(v0->lpTemplateName, -1);
+	a0.lpTemplateName = pw0;
 	a0.hInstance = v0->hInstance;
-	a0.lpszStyle = DuplicateMtoWBuffer(v0->lpszStyle, -1, LF_FACESIZE * 4);
+	pw1 = DuplicateMtoWBuffer(v0->lpszStyle, -1, LF_FACESIZE * 4);
+	a0.lpszStyle = pw1;
 	a0.nFontType = v0->nFontType;
 	a0.nSizeMin = v0->nSizeMin;
 	a0.nSizeMax = v0->nSizeMax;
@@ -2036,15 +2051,14 @@ START_ROUTINE
 		TerminateStringM(v0->lpLogFont->lfFaceName, LF_FACESIZE);
 	}
 	v0->rgbColors = a0.rgbColors;
-	WtoM(v0->lpszStyle, LF_FACESIZE, a0.lpszStyle, -1);
+	WtoM(v0->lpszStyle, LF_FACESIZE, pw1, -1);
 	TerminateStringM(v0->lpszStyle, LF_FACESIZE);
 	v0->nFontType = a0.nFontType;
 	if(pwlf)
 		free(pwlf);
-	FreeDuplicatedString((void*)a0.lpTemplateName);
-	FreeDuplicatedString(a0.lpszStyle);
 END_ROUTINE
 	FreeDuplicatedString(pw0);
+	FreeDuplicatedString(pw1);
 	return r;
 }
 

--- a/registry.c
+++ b/registry.c
@@ -960,6 +960,12 @@ int LoadRegistory(void)
 					// 同時接続対応
 					ReadIntValueFromReg(hKey5, "ThreadCount", &Host.MaxThreadCount);
 					ReadIntValueFromReg(hKey5, "ReuseCmdSkt", &Host.ReuseCmdSkt);
+					// 1.98d以前で同時接続数が1より大きい場合はソケットの再利用なし
+					if(Version < 1985)
+					{
+						if(Host.MaxThreadCount > 1)
+							Host.ReuseCmdSkt = NO;
+					}
 					// MLSD対応
 					ReadIntValueFromReg(hKey5, "MLSD", &Host.UseMLSD);
 					// IPv6対応

--- a/socket.c
+++ b/socket.c
@@ -1225,3 +1225,19 @@ int CheckClosedAndReconnect(void)
 
 
 
+// 同時接続対応
+int CheckClosedAndReconnectTrnSkt(SOCKET *Skt, int *CancelCheckWork)
+{
+	int Error;
+	int Sts;
+
+//SetTaskMsg("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+
+	Sts = FFFTP_SUCCESS;
+	if(AskAsyncDone(*Skt, &Error, FD_CLOSE) == YES)
+	{
+		Sts = ReConnectTrnSkt(Skt, CancelCheckWork);
+	}
+	return(Sts);
+}
+

--- a/socketwrapper.c
+++ b/socketwrapper.c
@@ -1045,6 +1045,7 @@ BOOL LoadPuTTY()
 	// ビルドしたputty.dllに合わせてSHA1ハッシュ値を変更すること
 	RegisterTrustedModuleSHA1Hash("\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00");
 #endif
+	// デバッグ用
 //	g_hPuTTY = LoadLibrary("putty.dll");
 	g_hPuTTY = LoadLibrary("C:\\SourceForge\\ffftp\\putty\\Debug\\PuTTY.dll");
 	if(!g_hPuTTY