[질문] WinSock 관련 질문입니다.

prix01의 이미지

안녕하세요?

지금 회사에서 기존에 동기적으로 작동하던 WIN32 소켓 프로그램을
타겟 플랫폼과 동일하게 작동하게 변경하려고 비동기적으로 바꾸는 작업을 하던 중 문제가 생겨서 질문 드립니다.

작동 방식은 제가 작성하고 있는 클라이언트 프로그램이
서버에 접속한 후 Request를 전송하고 Response를 수신한 후 접속을 끊고 다시 재접속하여
Request를 전송하고 Response를 수신하는 방식으로 작동합니다.
(원래는 한번 접속한 후 모든 Req/Res 교환이 이루어질 때까지 계속 접속을 유지하는 것이었는데
스펙에서는 한번 교환하면 접속을 끊으라고 나와 있더군요 -_-;)

어쨌던,

지금 socket()을 호출한 후 WSACreateEvent()를 이용하여 이벤트 객체를 생성하고
WSAEventSelect()를 이용하여 Connect, Read, Write, Close에 반응할 수 있는 Socket Descriptor와 이벤트 객체의 Pair를 만들어줍니다.

이벤트 처리 스레드에서는 위 4가지 이벤트에 대해서 콜백을 호출해주고
Close함수가 불리면 생성된 이벤트 객체와 SD를 닫아주고 있습니다.

문제는 첫번째 연결시도는 매우 잘되며 메시지도 잘 주고 받습니다.
하지만 두번째 연결시도시 Timeout을 내며 연결이 실패하길래 서버의 이상을 의심하여
서버에 Connect 대기를 하고 있을 때 한번 telnet XXX.XXX.XXX.XXX 8080으로 접속 해보았는데
접속 잘만 됩니다;;
로그찍어서 주소같은거 확인해도 동일하고요...
그리고 기존 소스로 빌드해서 트라이해보면 잘됩니다...

코드를 아무리 살펴보아도 WIN32쪽 포팅레이어 코드에서는 잘못된 부분이 보이질 않는데
뭐가 문제인지 도저히 모르겠습니다.
제가 WSAEventSelect 모델은 처음 사용하는거라 어디가 잘못되었는지 찾지 못하는 것일지도 모르겠지만요...

혹시 비슷한 현상 겪으시거나 해결책에 도움을 주실 수 있으신 분 계시면 답변 부탁드립니다.

관련 코드들 첨부합니다.
상용이라 몇몇 부분은 삭제 하였습니다.

추가로 오늘 오전에 나와서 접속 주소를 localhost로 바꾸어보았더니 잘됩니다.
기존에 테스트 하던 환경은 외부 서버를 포트포워딩해서 회사 서버로 회사서버에서 제 PC로 포트포워딩
이렇게 2번의 포트포워딩을 거쳐서 접속이 되게끔 해놓았었습니다.
netstat -na를 해보니 SYN_SENT를 클라이언트가 SYNC_RECEIVED도 서버프로그램이 사용하는 포트에서
현재 상태로 나오는데...접속이 안되더군요.
도대체 무슨 이유인지 잘 모르겠습니다.
첫 접속은 잘되었는데...

static int addSockInfo(SOCKET sock, _CommConnInfo_t* pConnInfo)
{
	if(s_TotalSockets >= WSA_MAXIMUM_WAIT_EVENTS) return -1;
 
	SocketInfo* pSockInfo = new SocketInfo;
	if(NULL == pSockInfo) return -2;
 
	WSAEVENT hEvent = ::WSACreateEvent();
	if(WSA_INVALID_EVENT == hEvent)
	{
		delete pSockInfo;
 
		return -3;
	}
 
	pSockInfo->sock = sock;
	pSockInfo->pConnInfo = pConnInfo;
 
	s_SockInfo[s_TotalSockets] = pSockInfo;
	s_EventArray[s_TotalSockets] = hEvent;
 
	s_TotalSockets++;
 
	return 0;
}
 
static void removeSockInfo(int index)
{
	SocketInfo* pSockInfo = s_SockInfo<ol>
</ol>
;
 
	if(pSockInfo)
	{
		closesocket (pSockInfo->sock);
 
		delete pSockInfo;
 
		s_SockInfo<ol>
</ol>
 = NULL;
 
		if(WSACloseEvent(s_EventArray<ol>
</ol>
) == FALSE)
		{
			// 오류 로그 출력
		}
		s_EventArray<ol>
</ol>
 = NULL;
 
		for(int i = index ; i < s_TotalSockets ; i++)
		{
			s_SockInfo[i] = s_SockInfo[i + 1];
			s_EventArray[i] = s_EventArray[i + 1];
		}
 
		s_TotalSockets--;
	}
}
 
static int searchSockInfo(SOCKET sock)
{
	int ret = -1;
	int i = 0;
 
	if(sock >= 0)
	{
		for(i = 0 ; i < s_TotalSockets ; i++)
		{
			if(s_SockInfo[i]->sock == sock)
			{
				ret = i;
				break;
			}
		}
	}
 
	return ret;
}
 
static unsigned int WINAPI networkEventWorker(PVOID pData)
{
	int index;
	int retval;
	WSANETWORKEVENTS networkEvents;
 
	s_ThreadRun = true;
 
	while(s_ThreadRun)
	{
		index = ::WSAWaitForMultipleEvents(s_TotalSockets, s_EventArray, FALSE, 50, FALSE);
 
		if(WSA_WAIT_FAILED == index)
		{
			continue;
		}
 
		index -= WSA_WAIT_EVENT_0;
 
		if(s_SockInfo<ol>
</ol>
 && WSA_INVALID_EVENT != s_EventArray<ol>
</ol>
)
		{
			retval = ::WSAEnumNetworkEvents(s_SockInfo<ol>
</ol>
->sock, s_EventArray<ol>
</ol>
, &networkEvents);
 
			if(SOCKET_ERROR == retval)
			{
				continue;
			}
 
			if(networkEvents.lNetworkEvents & FD_CONNECT)
			{
				if(networkEvents.iErrorCode[FD_CONNECT_BIT] != 0)
				{
					// 오류 로그 출력
					s_SockInfo<ol>
</ol>
->pConnInfo->rc = TCP_RC_ERROR;
				}
				else
				{
					s_SockInfo<ol>
</ol>
->pConnInfo->rc = TCP_RC_OK;
				}
 
				if(true == EsQueryAbortNoti())
				{
					continue;
				}
				else
				{
					// Callback 호출
				}
			}
			else if(networkEvents.lNetworkEvents & FD_READ)
			{
				if(networkEvents.iErrorCode[FD_READ_BIT] != 0)
				{
					// 오류 로그 출력
				}
				else
				{
					s_SockInfo<ol>
</ol>
->pConnInfo->rc = TCP_RC_OK;
				}
 
				if(true == EsQueryAbortNoti())
				{
					continue;
				}
				else
				{
					//Callback 호출
				}
			}
			else if(networkEvents.lNetworkEvents & FD_WRITE)
			{
				if(networkEvents.iErrorCode[FD_WRITE_BIT] != 0)
				{
					// 오류 로그 출력
				}
				else
				{
					s_SockInfo<ol>
</ol>
->pConnInfo->rc = TCP_RC_OK;
				}
 
				if(true == EsQueryAbortNoti())
				{
					continue;
				}
				else
				{
					//Callback 호출
				}
			}
			else if(networkEvents.lNetworkEvents & FD_CLOSE)
			{
				if(networkEvents.iErrorCode[FD_CLOSE_BIT] != 0)
				{
					// 오류 로그 출력
				}
 
				removeSockInfo(index);
			}
		}
	}
 
	_endthreadex(0);
 
	return 0;
}
 
TcpRc_t win32TcpOpenConnectionEx (CString_t            pszPort,
		SocketPtr_t          pSocket,
		CString_t            pszOpenMode,
		_CommConnInfo_t*	   connInfo,
		TcpFirewallInfoPtr_t pFirewallInfo )
{
	TcpRc_t rc = TCP_RC_OK;
	int ret = 0;
	int iTcpRc;
 
	SOCKET lSocket = -1L;
	struct sockaddr_in socket_address;
	char *defaultPort = HTTP_PORT;
	Bool_t useSSL = false;
 
	*pSocket = (Socket_t) 0L;
	if (rc == TCP_RC_OK)
	{
		lSocket = socket(AF_INET, SOCK_STREAM, 0);
		rc = CHKERROR ((int)lSocket);
 
		if(TCP_RC_OK == rc)
		{
			if(addSockInfo(lSocket, connInfo) != 0) rc = TCP_RC_ERROR;
		}
		else
		{
			rc = TCP_RC_ERROR;
		}
 
		*pSocket = (Socket_t) lSocket;
	}
 
	connInfo->sock = (int*) pSocket;
	connInfo->descAddress = (unsigned long) pSocket;
 
	if ((pszOpenMode [0] == 'c') || (pszOpenMode [0] == 'C'))
	{
		if(TCP_RC_OK == rc)
		{
			ret = WSAEventSelect(lSocket, s_EventArray[s_TotalSockets - 1], FD_CONNECT | FD_READ | FD_WRITE | FD_CLOSE);
			if(SOCKET_ERROR == ret)
			{
				removeSockInfo(s_TotalSockets - 1);
 
				rc = TCP_RC_ERROR;
			}
		}
 
		if (rc == TCP_RC_OK) {
			iTcpRc = WSAConnect (lSocket, (struct sockaddr *)&socket_address, sizeof (socket_address), NULL, NULL, NULL, NULL);
			if(SOCKET_ERROR == iTcpRc && WSAEWOULDBLOCK != WSAGetLastError())
			{
				rc = TCP_RC_ERROR;
			}
			else if(SOCKET_ERROR == iTcpRc && WSAEWOULDBLOCK == WSAGetLastError())
			{
				rc = TCP_RC_REQ_OK;
			}
			else if(0 == iTcpRc)
			{
				rc = TCP_RC_OK;
			}
		}
	}
	else
	{
		rc = TCP_RC_ERROR;
	}
 
	return rc;
}


댓글 달기

Filtered HTML

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

BBCode

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param>
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

Textile

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • You can use Textile markup to format text.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Markdown

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • Quick Tips:
    • Two or more spaces at a line's end = Line break
    • Double returns = Paragraph
    • *Single asterisks* or _single underscores_ = Emphasis
    • **Double** or __double__ = Strong
    • This is [a link](http://the.link.example.com "The optional title text")
    For complete details on the Markdown syntax, see the Markdown documentation and Markdown Extra documentation for tables, footnotes, and more.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Plain text

  • HTML 태그를 사용할 수 없습니다.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 줄과 단락은 자동으로 분리됩니다.
댓글 첨부 파일
이 댓글에 이미지나 파일을 업로드 합니다.
파일 크기는 8 MB보다 작아야 합니다.
허용할 파일 형식: txt pdf doc xls gif jpg jpeg mp3 png rar zip.
CAPTCHA
이것은 자동으로 스팸을 올리는 것을 막기 위해서 제공됩니다.