开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
ListenServer.cpp
资源名称：GGBT.rar　[点击查看]
上传用户：lds876
上传日期：2013-05-25
资源大小：567k
文件大小：2k
源码类别：

P2P编程

开发平台：

Visual C++

ListenServer.cpp：源码内容
  1. // ListenServer.cpp: implementation of the CListenServer class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "testbt.h"
  7. #include "ListenServer.h"
  10. #ifdef _DEBUG
  11. #undef THIS_FILE
  12. static char THIS_FILE[]=__FILE__;
  13. #define new DEBUG_NEW
  14. #endif
  17. //////////////////////////////////////////////////////////////////////
  18. // Construction/Destruction
  19. //////////////////////////////////////////////////////////////////////
  21. CListenServer::CListenServer()
  22. {
  23. m_hServer = INVALID_SOCKET;
  24. m_hevAccept = 0;
  25. m_hnewSocket = INVALID_SOCKET;
  26. }
  28. CListenServer::~CListenServer()
  29. {
  30. if (m_hServer)
  31. {
  32. closesocket(m_hServer);
  33. if (m_hevAccept)
  34. WaitForSingleObject(m_hevAccept, INFINITE);
  35. }
  36. }
  39. void CListenServer::StopListening()
  40. {
  42. }
  43. CListenServer::operator SOCKET()
  44. {
  45. return m_hServer;
  46. }
  47. long CListenServer::Bind(long lminport, long lmaxport)
  48. {
  49. SOCKET hserver = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP, 0, 0, WSA_FLAG_OVERLAPPED);
  50. if (hserver == INVALID_SOCKET)
  51. return false;
  53. long lport = 0;
  54. int iRet = -1;
  56. sockaddr_in addr = {0};
  57. addr.sin_family = AF_INET;
  59. for (lport=lminport; lport<=lmaxport; lport++)
  60. {
  61. addr.sin_port = lport;
  62. iRet = bind(hserver, (sockaddr*)&addr, sizeof(addr));
  63. if (iRet  == 0)
  64. break;
  65. else
  66. {
  67. // string strErr = WSAShowError();
  68. // errorFunc("bind() server error:bind to port error: " + WSAShowError());
  69. }
  70. }
  72. if (iRet != 0)
  73. return false;
  75. iRet = listen(hserver, 10);
  76. if (iRet != 0)
  77. return false;
  79. m_hServer = hserver;
  80. return lport;
  82. }
  84. bool CListenServer::Accept(HANDLE hevAccept)
  85. {
  86. if (m_hevAccept || m_hServer == INVALID_SOCKET)
  87. {
  88. assert(false);
  89. return false;
  90. }
  92. m_hevAccept = hevAccept;
  94. DWORD dwThreadId = 0;
  95. ::CreateThread(0, 0, ListenProc, this, 0, &dwThreadId);
  96. TRACE("rnlisten thread = (%x)", dwThreadId);
  97. return true;
  98. }
  100. DWORD WINAPI CListenServer::ListenProc(void *pParam)
  101. {
  102. CListenServer* pListenServer = (CListenServer*) pParam;
  103. pListenServer->Listening();
  104. return 0;
  105. }
  107. void CListenServer::Listening()
  108. {
  109. CWinsockInit();
  111. sockaddr_in addr = {0};
  112. int iaddrlen = sizeof(addr);
  113. m_hnewSocket = WSAAccept(m_hServer, (sockaddr *)&addr, &iaddrlen, 0, 0);
  114. if (m_hnewSocket == INVALID_SOCKET)
  115. {
  116. string strErr = WSAShowError();
  117. }
  119. SetEvent(m_hevAccept);
  120. }
  122. SOCKET CListenServer::GetResult()
  123. {
  124. m_hevAccept = 0;
  125. return m_hnewSocket;
  126. }