опубликован 03-10-2001 10:29 MSK            

CConnectThread* pThread = (CConnectThread*)AfxBeginThread(RUNTIME_CLASS(CConnectThread),
THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED);
ASSERT(pThread);

pThread->m_hSocket = soc.Detach();
pThread->ResumeThread();
CAsyncSocket::OnAccept(nErrorCode);
}

опубликован 03-10-2001 10:44 MSK            

>Так вот вопрос. Как правильно сделать - в
>главном потоке создать сокет для работы с
>соединением, сделать accept, а потом
>передать этот сокет как параметр в ф-ию
>потока, или создать ф-цию потока, а в ней
>уже создавать новый сокет.

1. IMHO не принципиально. Но по моему лучше передать уже готовый сокет. Ведь поток может стартовать не так уж и сразу. Твоя ф-ция обработки сокетовых сообщений к тому времени может завершиться и получить новое сообщение...

2. Всё просто. Устанавливаешь евент на событие от сокета и зацикливаешь поток пока не получишь FD_CLOSE. Почитай http://www.sources.ru/cpp/cpp_network_evets_winsock2.shtml
Вот кусок исхода из моей проги:

DWORD WINAPI CCafe::SockThread(LPVOID ts)
{
//........ Тут ещё всякий код
//Устанавливаем событие на сообщения сокета
HANDLE hEvent = WSACreateEvent();
if(::WSAEventSelect(MyClass->sock, hEvent, FD_CONNECT|FD_READ|FD_CLOSE))
{
MessageBox(NULL,"SocketEventError","Socket error",MB_OK);
return 2;
}

for(;;) //Вечный цикл :)
{
//Вдруг нужно закрыть все потоки потому
// что главный поток завершается. Нужно
// корректно завершить работу.
if(WaitForSingleObject(CloseEvent,0 )==WAIT_OBJECT_0)
{
shutdown(MyClass->sock,2);
closesocket(MyClass->sock);
WSACloseEvent(hEvent);
return 0;
}

//А теперь собственно ждём события от сокета
if( WSA_WAIT_FAILED!=::WSAWaitForMultipleEvents(1, &hEvent, false,50,false))
{
WSANETWORKEVENTS NetEv;
if(0==WSAEnumNetworkEvents(MyClass->sock,hEvent,&NetEv))
{
// Если что-то пришло
if(NetEv.lNetworkEvents & FD_READ)
{
//Читаем из сокета
recv(sock,(char*)buf,sizeof(buf),NULL);
//....... Ну и т.д.
}
else
if(NetEv.lNetworkEvents & FD_CLOSE)
{ //Если хост разорвал соединение
WSACloseEvent(hEvent); //Освобождаем ресурсы
return 0; //Завершаем поток
}
} //if(0==WSAEnumNetworkEvents
} //if( WSA_WAIT_FAILED!
} //for(;;)
}//SockThread()

опубликован 03-10-2001 15:28 MSK            

pThread->soc.Attach(soc.Detach());
pThread->ResumeThread();
CSocket::OnAccept(nErrorCode);
}

class CClientSocket : public CSocket
{
public:
CServerThread *m_ServThread; //указатель на поток, в котором "живет" данный сокет
устанавливается в
CServerThread::InitInstance
///////////
}

CServerThread::InitInstance
{
soc.m_ServThread = this;
/////
}

Определяю обработчик:
CClientSocket::OnClose(int nErrorCode)
{
CSocket::OnClose(nErrorCode);
m_ServThread->PostThreadMessage(WM_QUIT,0,0);
}

И после отключения клиента от порта закрывается прога.