X-Git-Url: http://git.sourceforge.jp/view?p=ffftp%2Fffftp.git;a=blobdiff_plain;f=socketwrapper.c;h=caae5893cf3eccf0fecd8da33d0077d537398c1a;hp=edd841827199697447ddc3011d6aebb668db9448;hb=607cd5899fe0ff3692e440cc5fd27e1b21a6cd77;hpb=700b7eb9066c105aaf9b42ad67ba43ee8c030f0b

diff --git a/socketwrapper.c b/socketwrapper.c
index edd8418..caae589 100644
--- a/socketwrapper.c
+++ b/socketwrapper.c
@@ -16,6 +16,8 @@
 #include "mbswrapper.h"
 #include "punycode.h"
 
+// FTPS対応
+
 typedef void (__cdecl* _SSL_load_error_strings)();
 typedef int (__cdecl* _SSL_library_init)();
 typedef SSL_METHOD* (__cdecl* _SSLv23_method)();
@@ -36,7 +38,7 @@ typedef X509* (__cdecl* _SSL_get_peer_certificate)(const SSL*);
 typedef long (__cdecl* _SSL_get_verify_result)(const SSL*);
 typedef SSL_SESSION* (__cdecl* _SSL_get_session)(SSL*);
 typedef int (__cdecl* _SSL_set_session)(SSL*, SSL_SESSION*);
-typedef int (__cdecl* _SSL_CTX_use_certificate)(SSL_CTX*, X509*);
+typedef X509_STORE* (__cdecl* _SSL_CTX_get_cert_store)(const SSL_CTX*);
 typedef BIO_METHOD* (__cdecl* _BIO_s_mem)();
 typedef BIO* (__cdecl* _BIO_new)(BIO_METHOD*);
 typedef int (__cdecl* _BIO_free)(BIO*);
@@ -47,6 +49,7 @@ typedef int (__cdecl* _X509_print_ex)(BIO*, X509*, unsigned long, unsigned long)
 typedef X509_NAME* (__cdecl* _X509_get_subject_name)(X509*);
 typedef int (__cdecl* _X509_NAME_print_ex)(BIO*, X509_NAME*, int, unsigned long);
 typedef X509* (__cdecl* _PEM_read_bio_X509)(BIO*, X509**, pem_password_cb*, void*);
+typedef int (__cdecl* _X509_STORE_add_cert)(X509_STORE*, X509*);
 
 _SSL_load_error_strings p_SSL_load_error_strings;
 _SSL_library_init p_SSL_library_init;
@@ -68,7 +71,7 @@ _SSL_get_peer_certificate p_SSL_get_peer_certificate;
 _SSL_get_verify_result p_SSL_get_verify_result;
 _SSL_get_session p_SSL_get_session;
 _SSL_set_session p_SSL_set_session;
-_SSL_CTX_use_certificate p_SSL_CTX_use_certificate;
+_SSL_CTX_get_cert_store p_SSL_CTX_get_cert_store;
 _BIO_s_mem p_BIO_s_mem;
 _BIO_new p_BIO_new;
 _BIO_free p_BIO_free;
@@ -79,6 +82,7 @@ _X509_print_ex p_X509_print_ex;
 _X509_get_subject_name p_X509_get_subject_name;
 _X509_NAME_print_ex p_X509_NAME_print_ex;
 _PEM_read_bio_X509 p_PEM_read_bio_X509;
+_X509_STORE_add_cert p_X509_STORE_add_cert;
 
 #define MAX_SSL_SOCKET 16
 
@@ -110,11 +114,11 @@ BOOL LoadOpenSSL()
 		return FALSE;
 #ifdef ENABLE_PROCESS_PROTECTION
 	// 同梱するOpenSSLのバージョンに合わせてSHA1ハッシュ値を変更すること
-	// ssleay32.dll 1.0.0e
-	// libssl32.dll 1.0.0e
-	RegisterTrustedModuleSHA1Hash("\x4E\xB7\xA0\x22\x14\x4B\x58\x6D\xBC\xF5\x21\x0D\x96\x78\x0D\x79\x7D\x66\xB2\xB0");
-	// libeay32.dll 1.0.0e
-	RegisterTrustedModuleSHA1Hash("\x01\x32\x7A\xAE\x69\x26\xE6\x58\xC7\x63\x22\x1E\x53\x5A\x78\xBC\x61\xC7\xB5\xC1");
+	// ssleay32.dll 1.0.0g
+	// libssl32.dll 1.0.0g
+	RegisterTrustedModuleSHA1Hash("\x42\x32\x3E\x44\x35\xBC\x98\x6C\x45\xC9\xA2\xB8\x41\xE7\xDA\x7B\x6A\x98\xB2\x28");
+	// libeay32.dll 1.0.0g
+	RegisterTrustedModuleSHA1Hash("\x3F\xC8\x07\x84\xB3\xF0\x71\x4A\x18\x59\x52\x1F\x99\x09\x65\xB9\x49\xA7\x15\x36");
 #endif
 	g_hOpenSSL = LoadLibrary("ssleay32.dll");
 	// バージョン固定のためlibssl32.dllの読み込みは脆弱性の原因になり得るので廃止
@@ -141,7 +145,7 @@ BOOL LoadOpenSSL()
 		|| !(p_SSL_get_verify_result = (_SSL_get_verify_result)GetProcAddress(g_hOpenSSL, "SSL_get_verify_result"))
 		|| !(p_SSL_get_session = (_SSL_get_session)GetProcAddress(g_hOpenSSL, "SSL_get_session"))
 		|| !(p_SSL_set_session = (_SSL_set_session)GetProcAddress(g_hOpenSSL, "SSL_set_session"))
-		|| !(p_SSL_CTX_use_certificate = (_SSL_CTX_use_certificate)GetProcAddress(g_hOpenSSL, "SSL_CTX_use_certificate")))
+		|| !(p_SSL_CTX_get_cert_store = (_SSL_CTX_get_cert_store)GetProcAddress(g_hOpenSSL, "SSL_CTX_get_cert_store")))
 	{
 		if(g_hOpenSSL)
 			FreeLibrary(g_hOpenSSL);
@@ -159,7 +163,8 @@ BOOL LoadOpenSSL()
 		|| !(p_X509_print_ex = (_X509_print_ex)GetProcAddress(g_hOpenSSLCommon, "X509_print_ex"))
 		|| !(p_X509_get_subject_name = (_X509_get_subject_name)GetProcAddress(g_hOpenSSLCommon, "X509_get_subject_name"))
 		|| !(p_X509_NAME_print_ex = (_X509_NAME_print_ex)GetProcAddress(g_hOpenSSLCommon, "X509_NAME_print_ex"))
-		|| !(p_PEM_read_bio_X509 = (_PEM_read_bio_X509)GetProcAddress(g_hOpenSSLCommon, "PEM_read_bio_X509")))
+		|| !(p_PEM_read_bio_X509 = (_PEM_read_bio_X509)GetProcAddress(g_hOpenSSLCommon, "PEM_read_bio_X509"))
+		|| !(p_X509_STORE_add_cert = (_X509_STORE_add_cert)GetProcAddress(g_hOpenSSLCommon, "X509_STORE_add_cert")))
 	{
 		if(g_hOpenSSL)
 			FreeLibrary(g_hOpenSSL);
@@ -283,7 +288,7 @@ BOOL ConfirmSSLCertificate(SSL* pSSL, BOOL* pbAborted)
 		}
 		p_X509_free(pX509);
 	}
-	if(p_SSL_get_verify_result(pSSL) == X509_V_OK)
+	if(pX509 && p_SSL_get_verify_result(pSSL) == X509_V_OK)
 		bVerified = TRUE;
 	pCN = pSubject;
 	while(pCN)
@@ -326,9 +331,14 @@ void SetSSLConfirmCallback(LPSSLCONFIRMCALLBACK pCallback)
 }
 
 // SSLルート証明書を設定
-BOOL SetSSLRootCertificate(void* pData, DWORD Length)
+// PEM形式のみ指定可能
+BOOL SetSSLRootCertificate(const void* pData, DWORD Length)
 {
 	BOOL r;
+	X509_STORE* pStore;
+	BYTE* p;
+	BYTE* pBegin;
+	BYTE* pEnd;
 	BIO* pBIO;
 	X509* pX509;
 	if(!g_bOpenSSLLoaded)
@@ -339,15 +349,45 @@ BOOL SetSSLRootCertificate(void* pData, DWORD Length)
 		g_pOpenSSLCTX = p_SSL_CTX_new(p_SSLv23_method());
 	if(g_pOpenSSLCTX)
 	{
-		if(pBIO = p_BIO_new_mem_buf(pData, Length))
+		if(pStore = p_SSL_CTX_get_cert_store(g_pOpenSSLCTX))
 		{
-			if(pX509 = p_PEM_read_bio_X509(pBIO, NULL, NULL, NULL))
+			p = (BYTE*)pData;
+			pBegin = NULL;
+			pEnd = NULL;
+			while(Length > 0)
 			{
-				if(p_SSL_CTX_use_certificate(g_pOpenSSLCTX, pX509) == 1)
-					r = TRUE;
-				p_X509_free(pX509);
+				if(!pBegin)
+				{
+					if(Length < 27)
+						break;
+					if(memcmp(p, "-----BEGIN CERTIFICATE-----", 27) == 0)
+						pBegin = p;
+				}
+				else if(!pEnd)
+				{
+					if(Length < 25)
+						break;
+					if(memcmp(p, "-----END CERTIFICATE-----", 25) == 0)
+						pEnd = p + 25;
+				}
+				if(pBegin && pEnd)
+				{
+					if(pBIO = p_BIO_new_mem_buf(pBegin, (int)((size_t)pEnd - (size_t)pBegin)))
+					{
+						if(pX509 = p_PEM_read_bio_X509(pBIO, NULL, NULL, NULL))
+						{
+							if(p_X509_STORE_add_cert(pStore, pX509) == 1)
+								r = TRUE;
+							p_X509_free(pX509);
+						}
+						p_BIO_free(pBIO);
+					}
+					pBegin = NULL;
+					pEnd = NULL;
+				}
+				p++;
+				Length--;
 			}
-			p_BIO_free(pBIO);
 		}
 	}
 	LeaveCriticalSection(&g_OpenSSLLock);
@@ -359,20 +399,34 @@ BOOL SetSSLRootCertificate(void* pData, DWORD Length)
 BOOL IsHostNameMatched(LPCSTR HostName, LPCSTR CommonName)
 {
 	BOOL bResult;
-	char* pAsterisk;
+	const char* pAsterisk;
+	size_t BeforeAsterisk;
+	const char* pBeginAsterisk;
+	const char* pEndAsterisk;
+	const char* pDot;
 	bResult = FALSE;
 	if(HostName && CommonName)
 	{
 		if(pAsterisk = strchr(CommonName, '*'))
 		{
-			if(_strnicmp(HostName, CommonName, ((size_t)pAsterisk - (size_t)CommonName) / sizeof(char)) == 0)
+			BeforeAsterisk = ((size_t)pAsterisk - (size_t)CommonName) / sizeof(char);
+			pBeginAsterisk = HostName + BeforeAsterisk;
+			while(*pAsterisk == '*')
 			{
-				while(*pAsterisk == '*')
+				pAsterisk++;
+			}
+			pEndAsterisk = HostName + strlen(HostName) - strlen(pAsterisk);
+			// "*"より前は大文字小文字を無視して完全一致
+			if(_strnicmp(HostName, CommonName, BeforeAsterisk) == 0)
+			{
+				// "*"より後は大文字小文字を無視して完全一致
+				if(_stricmp(pEndAsterisk, pAsterisk) == 0)
 				{
-					pAsterisk++;
+					// "*"と一致する範囲に"."が含まれてはならない
+					pDot = strchr(pBeginAsterisk, '.');
+					if(!pDot || pDot >= pEndAsterisk)
+						bResult = TRUE;
 				}
-				if(_stricmp(HostName + strlen(HostName) - strlen(pAsterisk), pAsterisk) == 0)
-					bResult = TRUE;
 			}
 		}
 		else if(_stricmp(HostName, CommonName) == 0)
@@ -504,24 +558,24 @@ BOOL IsSSLAttached(SOCKET s)
 	return TRUE;
 }
 
-SOCKET socketS(int af, int type, int protocol)
+SOCKET FTPS_socket(int af, int type, int protocol)
 {
 	return socket(af, type, protocol);
 }
 
-int bindS(SOCKET s, const struct sockaddr *addr, int namelen)
+int FTPS_bind(SOCKET s, const struct sockaddr *addr, int namelen)
 {
 	return bind(s, addr, namelen);
 }
 
-int listenS(SOCKET s, int backlog)
+int FTPS_listen(SOCKET s, int backlog)
 {
 	return listen(s, backlog);
 }
 
 // accept相当の関数
 // ただし初めからSSLのネゴシエーションを行う
-SOCKET acceptS(SOCKET s, struct sockaddr *addr, int *addrlen)
+SOCKET FTPS_accept(SOCKET s, struct sockaddr *addr, int *addrlen)
 {
 	SOCKET r;
 	BOOL bAborted;
@@ -537,7 +591,7 @@ SOCKET acceptS(SOCKET s, struct sockaddr *addr, int *addrlen)
 
 // connect相当の関数
 // ただし初めからSSLのネゴシエーションを行う
-int connectS(SOCKET s, const struct sockaddr *name, int namelen)
+int FTPS_connect(SOCKET s, const struct sockaddr *name, int namelen)
 {
 	int r;
 	BOOL bAborted;
@@ -549,14 +603,14 @@ int connectS(SOCKET s, const struct sockaddr *name, int namelen)
 }
 
 // closesocket相当の関数
-int closesocketS(SOCKET s)
+int FTPS_closesocket(SOCKET s)
 {
 	DetachSSL(s);
 	return closesocket(s);
 }
 
 // send相当の関数
-int sendS(SOCKET s, const char * buf, int len, int flags)
+int FTPS_send(SOCKET s, const char * buf, int len, int flags)
 {
 	SSL** ppSSL;
 	if(!g_bOpenSSLLoaded)
@@ -570,7 +624,7 @@ int sendS(SOCKET s, const char * buf, int len, int flags)
 }
 
 // recv相当の関数
-int recvS(SOCKET s, char * buf, int len, int flags)
+int FTPS_recv(SOCKET s, char * buf, int len, int flags)
 {
 	SSL** ppSSL;
 	if(!g_bOpenSSLLoaded)
@@ -587,6 +641,8 @@ int recvS(SOCKET s, char * buf, int len, int flags)
 
 // IPv6対応
 
+const struct in6_addr IN6ADDR_NONE = {{0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00}};
+
 typedef struct
 {
 	HANDLE h;
@@ -628,7 +684,7 @@ DWORD WINAPI WSAAsyncGetHostByNameIPv6ThreadProc(LPVOID lpParameter)
 						pHost->h_addr_list[0] = (char*)(&pHost->h_addr_list[2]);
 						pHost->h_addr_list[1] = NULL;
 						memcpy(pHost->h_addr_list[0], &((struct sockaddr_in*)p->ai_addr)->sin_addr, sizeof(struct in_addr));
-						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(sizeof(struct hostent) + sizeof(char*) * 2 + p->ai_addrlen));
+						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(sizeof(struct hostent) + sizeof(char*) * 2 + sizeof(struct in_addr)));
 					}
 					else
 						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(WSAENOBUFS << 16));
@@ -646,7 +702,7 @@ DWORD WINAPI WSAAsyncGetHostByNameIPv6ThreadProc(LPVOID lpParameter)
 						pHost->h_addr_list[0] = (char*)(&pHost->h_addr_list[2]);
 						pHost->h_addr_list[1] = NULL;
 						memcpy(pHost->h_addr_list[0], &((struct sockaddr_in6*)p->ai_addr)->sin6_addr, sizeof(struct in6_addr));
-						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(sizeof(struct hostent) + sizeof(char*) * 2 + p->ai_addrlen));
+						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(sizeof(struct hostent) + sizeof(char*) * 2 + sizeof(struct in6_addr)));
 					}
 					else
 						PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(WSAENOBUFS << 16));
@@ -663,10 +719,11 @@ DWORD WINAPI WSAAsyncGetHostByNameIPv6ThreadProc(LPVOID lpParameter)
 	}
 	else
 		PostMessage(pData->hWnd, pData->wMsg, (WPARAM)pData->h, (LPARAM)(ERROR_INVALID_FUNCTION << 16));
-	free(pData->name);
-	free(pData);
 	// CreateThreadが返すハンドルが重複するのを回避
 	Sleep(10000);
+	CloseHandle(pData->h);
+	free(pData->name);
+	free(pData);
 	return 0;
 }
 
@@ -713,7 +770,10 @@ int WSACancelAsyncRequestIPv6(HANDLE hAsyncTaskHandle)
 	int Result;
 	Result = SOCKET_ERROR;
 	if(TerminateThread(hAsyncTaskHandle, 0))
+	{
+		CloseHandle(hAsyncTaskHandle);
 		Result = 0;
+	}
 	return Result;
 }
 
@@ -789,7 +849,7 @@ struct in6_addr inet6_addr(const char* cp)
 	{
 		if(!cp)
 		{
-			memset(&Result, 0xff, sizeof(Result));
+			memcpy(&Result, &IN6ADDR_NONE, sizeof(struct in6_addr));
 			break;
 		}
 		if(i >= AfterZero)
@@ -813,7 +873,7 @@ struct in6_addr inet6_addr(const char* cp)
 				Result.u.Word[i] = ((Result.u.Word[i] & 0xff00) >> 8) | ((Result.u.Word[i] & 0x00ff) << 8);
 				if(strncmp(p, ":", 1) != 0 && strlen(p) > 0)
 				{
-					memset(&Result, 0xff, sizeof(Result));
+					memcpy(&Result, &IN6ADDR_NONE, sizeof(struct in6_addr));
 					break;
 				}
 				if(cp = strstr(cp, ":"))
@@ -937,3 +997,349 @@ HANDLE WSAAsyncGetHostByNameIPv6M(HWND hWnd, u_int wMsg, const char * name, char
 	return r;
 }
 
+// SFTP対応
+
+typedef void* (__cdecl* _SFTP_Create)();
+typedef void (__cdecl* _SFTP_Destroy)(void*);
+typedef BOOL (__cdecl* _SFTP_IsExited)(void*);
+typedef BOOL (__cdecl* _SFTP_SetTimeoutCallback)(void*, void*);
+typedef size_t (__cdecl* _SFTP_PeekStdOut)(void*, void*, size_t);
+typedef size_t (__cdecl* _SFTP_ReadStdOut)(void*, void*, size_t);
+typedef size_t (__cdecl* _SFTP_WriteStdIn)(void*, const void*, size_t);
+typedef size_t (__cdecl* _SFTP_PeekDataOut)(void*, void*, size_t);
+typedef size_t (__cdecl* _SFTP_ReadDataOut)(void*, void*, size_t);
+typedef size_t (__cdecl* _SFTP_WriteDataIn)(void*, const void*, size_t);
+typedef BOOL (__cdecl* _SFTP_SetFilePosition)(void*, LONGLONG);
+
+_SFTP_Create p_SFTP_Create;
+_SFTP_Destroy p_SFTP_Destroy;
+_SFTP_IsExited p_SFTP_IsExited;
+_SFTP_SetTimeoutCallback p_SFTP_SetTimeoutCallback;
+_SFTP_PeekStdOut p_SFTP_PeekStdOut;
+_SFTP_ReadStdOut p_SFTP_ReadStdOut;
+_SFTP_WriteStdIn p_SFTP_WriteStdIn;
+_SFTP_PeekDataOut p_SFTP_PeekDataOut;
+_SFTP_ReadDataOut p_SFTP_ReadDataOut;
+_SFTP_WriteDataIn p_SFTP_WriteDataIn;
+_SFTP_SetFilePosition p_SFTP_SetFilePosition;
+
+typedef struct
+{
+	SOCKET Control;
+	SOCKET Data;
+	void* Handle;
+	char Host[1024];
+	int Port;
+	char User[1024];
+	char Password[1024];
+} SFTPDATA;
+
+#define MAX_SFTP_SOCKET 16
+
+BOOL g_bPuTTYLoaded;
+HMODULE g_hPuTTY;
+CRITICAL_SECTION g_PuTTYLock;
+SFTPDATA g_SFTPData[MAX_SFTP_SOCKET];
+
+// PuTTYを初期化
+BOOL LoadPuTTY()
+{
+	int i;
+	if(g_bPuTTYLoaded)
+		return FALSE;
+#ifdef ENABLE_PROCESS_PROTECTION
+	// ビルドした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
+	// デバッグ用
+#ifdef _DEBUG
+	{
+		char Path[MAX_PATH];
+		GetModuleFileName(NULL, Path, MAX_PATH);
+		strcpy(strrchr(Path, '\\'), "\\..\\putty\\Debug\\PuTTY.dll");
+		g_hPuTTY = LoadLibrary(Path);
+	}
+#else
+	g_hPuTTY = LoadLibrary("putty.dll");
+#endif
+	if(!g_hPuTTY
+		|| !(p_SFTP_Create = (_SFTP_Create)GetProcAddress(g_hPuTTY, "SFTP_Create"))
+		|| !(p_SFTP_Destroy = (_SFTP_Destroy)GetProcAddress(g_hPuTTY, "SFTP_Destroy"))
+		|| !(p_SFTP_IsExited = (_SFTP_IsExited)GetProcAddress(g_hPuTTY, "SFTP_IsExited"))
+		|| !(p_SFTP_SetTimeoutCallback = (_SFTP_SetTimeoutCallback)GetProcAddress(g_hPuTTY, "SFTP_SetTimeoutCallback"))
+		|| !(p_SFTP_PeekStdOut = (_SFTP_PeekStdOut)GetProcAddress(g_hPuTTY, "SFTP_PeekStdOut"))
+		|| !(p_SFTP_ReadStdOut = (_SFTP_ReadStdOut)GetProcAddress(g_hPuTTY, "SFTP_ReadStdOut"))
+		|| !(p_SFTP_WriteStdIn = (_SFTP_WriteStdIn)GetProcAddress(g_hPuTTY, "SFTP_WriteStdIn"))
+		|| !(p_SFTP_PeekDataOut = (_SFTP_PeekDataOut)GetProcAddress(g_hPuTTY, "SFTP_PeekDataOut"))
+		|| !(p_SFTP_ReadDataOut = (_SFTP_ReadDataOut)GetProcAddress(g_hPuTTY, "SFTP_ReadDataOut"))
+		|| !(p_SFTP_WriteDataIn = (_SFTP_WriteDataIn)GetProcAddress(g_hPuTTY, "SFTP_WriteDataIn"))
+		|| !(p_SFTP_SetFilePosition = (_SFTP_SetFilePosition)GetProcAddress(g_hPuTTY, "SFTP_SetFilePosition")))
+	{
+		if(g_hPuTTY)
+			FreeLibrary(g_hPuTTY);
+		g_hPuTTY = NULL;
+		return FALSE;
+	}
+	for(i = 0; i < MAX_SFTP_SOCKET; i++)
+	{
+		g_SFTPData[i].Control = INVALID_SOCKET;
+		g_SFTPData[i].Data = INVALID_SOCKET;
+	}
+	InitializeCriticalSection(&g_PuTTYLock);
+	g_bPuTTYLoaded = TRUE;
+	return TRUE;
+}
+
+// PuTTYを解放
+void FreePuTTY()
+{
+	int i;
+	if(!g_bPuTTYLoaded)
+		return;
+	EnterCriticalSection(&g_PuTTYLock);
+	for(i = 0; i < MAX_SFTP_SOCKET; i++)
+	{
+		if(g_SFTPData[i].Control != INVALID_SOCKET)
+		{
+			closesocket(g_SFTPData[i].Control);
+			g_SFTPData[i].Control = INVALID_SOCKET;
+			p_SFTP_Destroy(g_SFTPData[i].Handle);
+		}
+		if(g_SFTPData[i].Data != INVALID_SOCKET)
+		{
+			closesocket(g_SFTPData[i].Data);
+			g_SFTPData[i].Data = INVALID_SOCKET;
+		}
+	}
+	FreeLibrary(g_hPuTTY);
+	g_hPuTTY = NULL;
+	LeaveCriticalSection(&g_PuTTYLock);
+	DeleteCriticalSection(&g_PuTTYLock);
+	g_bPuTTYLoaded = FALSE;
+}
+
+// PuTTYが使用可能かどうか確認
+BOOL IsPuTTYLoaded()
+{
+	return g_bPuTTYLoaded;
+}
+
+SFTPDATA* GetUnusedSFTPData()
+{
+	int i;
+	for(i = 0; i < MAX_SFTP_SOCKET; i++)
+	{
+		if(g_SFTPData[i].Control == INVALID_SOCKET)
+		{
+			memset(&g_SFTPData[i], 0, sizeof(SFTPDATA));
+			return &g_SFTPData[i];
+		}
+	}
+	return NULL;
+}
+
+SFTPDATA* FindSFTPDataFromSocket(SOCKET s)
+{
+	int i;
+	for(i = 0; i < MAX_SFTP_SOCKET; i++)
+	{
+		if(g_SFTPData[i].Control == s || g_SFTPData[i].Data == s)
+			return &g_SFTPData[i];
+	}
+	return NULL;
+}
+
+// SFTPとしてマークされているか確認
+// マークされていればTRUEを返す
+BOOL IsSFTPAttached(SOCKET s)
+{
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return FALSE;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return FALSE;
+	return TRUE;
+}
+
+// コントロール用の仮想的なソケットを取得
+// 識別子としてダミーのソケットを返す
+SOCKET SFTP_socket(int af, int type, int protocol)
+{
+	SOCKET r;
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return INVALID_SOCKET;
+	r = INVALID_SOCKET;
+	EnterCriticalSection(&g_PuTTYLock);
+	if(pSFTPData = GetUnusedSFTPData())
+	{
+		r = socket(af, type, protocol);
+		pSFTPData->Control = r;
+		pSFTPData->Data = INVALID_SOCKET;
+		pSFTPData->Handle = p_SFTP_Create();
+	}
+	LeaveCriticalSection(&g_PuTTYLock);
+	return r;
+}
+
+int SFTP_bind(SOCKET s, const struct sockaddr *addr, int namelen)
+{
+	return SOCKET_ERROR;
+}
+
+int SFTP_listen(SOCKET s, int backlog)
+{
+	return SOCKET_ERROR;
+}
+
+// accept相当の関数
+SOCKET SFTP_accept(SOCKET s, struct sockaddr *addr, int *addrlen)
+{
+	return INVALID_SOCKET;
+}
+
+// connect相当の関数
+int SFTP_connect(SOCKET s, const struct sockaddr *name, int namelen)
+{
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return SOCKET_ERROR;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return SOCKET_ERROR;
+	if(namelen == sizeof(struct sockaddr_in))
+	{
+	}
+	else if(namelen == sizeof(struct sockaddr_in6))
+	{
+	}
+	else
+		return SOCKET_ERROR;
+	return 0;
+}
+
+// closesocket相当の関数
+int SFTP_closesocket(SOCKET s)
+{
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return SOCKET_ERROR;
+	EnterCriticalSection(&g_PuTTYLock);
+	if(pSFTPData = FindSFTPDataFromSocket(s))
+	{
+		if(pSFTPData->Control == s)
+		{
+			pSFTPData->Control = INVALID_SOCKET;
+			p_SFTP_Destroy(pSFTPData->Handle);
+		}
+		if(pSFTPData->Data == s)
+			pSFTPData->Data = INVALID_SOCKET;
+	}
+	LeaveCriticalSection(&g_PuTTYLock);
+	return closesocket(s);
+}
+
+// send相当の関数
+int SFTP_send(SOCKET s, const char * buf, int len, int flags)
+{
+	int r;
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return SOCKET_ERROR;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return SOCKET_ERROR;
+	if(p_SFTP_IsExited(pSFTPData->Handle))
+		return SOCKET_ERROR;
+	r = SOCKET_ERROR;
+	if(pSFTPData->Control == s)
+		r = (int)p_SFTP_WriteStdIn(pSFTPData->Handle, buf, len);
+	else if(pSFTPData->Data == s)
+		r = (int)p_SFTP_WriteDataIn(pSFTPData->Handle, buf, len);
+	return r;
+}
+
+// recv相当の関数
+int SFTP_recv(SOCKET s, char * buf, int len, int flags)
+{
+	int r;
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return SOCKET_ERROR;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return SOCKET_ERROR;
+	if(p_SFTP_IsExited(pSFTPData->Handle))
+		return SOCKET_ERROR;
+	r = SOCKET_ERROR;
+	if(pSFTPData->Control == s)
+	{
+		if(flags & MSG_PEEK)
+			r = (int)p_SFTP_PeekStdOut(pSFTPData->Handle, buf, len);
+		else
+			r = (int)p_SFTP_ReadStdOut(pSFTPData->Handle, buf, len);
+	}
+	else if(pSFTPData->Data == s)
+	{
+		if(flags & MSG_PEEK)
+			r = (int)p_SFTP_PeekDataOut(pSFTPData->Handle, buf, len);
+		else
+			r = (int)p_SFTP_ReadDataOut(pSFTPData->Handle, buf, len);
+	}
+	return r;
+}
+
+BOOL SFTP_SetTimeoutCallback(SOCKET s, void* pCallback)
+{
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return FALSE;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return FALSE;
+	return p_SFTP_SetTimeoutCallback(pSFTPData->Handle, pCallback);
+}
+
+// データ用の仮想的なソケットを取得
+// 識別子としてダミーのソケットを返す
+SOCKET SFTP_GetDataHandle(SOCKET s, int af, int type, int protocol)
+{
+	SOCKET r;
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return INVALID_SOCKET;
+	r = INVALID_SOCKET;
+	EnterCriticalSection(&g_PuTTYLock);
+	if(pSFTPData = FindSFTPDataFromSocket(s))
+	{
+		r = socket(af, type, protocol);
+		pSFTPData->Data = r;
+	}
+	LeaveCriticalSection(&g_PuTTYLock);
+	return r;
+}
+
+BOOL SFTP_SetFilePosition(SOCKET s, LONGLONG Position)
+{
+	SFTPDATA* pSFTPData;
+	if(!g_bPuTTYLoaded)
+		return FALSE;
+	EnterCriticalSection(&g_PuTTYLock);
+	pSFTPData = FindSFTPDataFromSocket(s);
+	LeaveCriticalSection(&g_PuTTYLock);
+	if(!pSFTPData)
+		return FALSE;
+	return p_SFTP_SetFilePosition(pSFTPData->Handle, Position);
+}
+