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

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

P2P编程

开发平台：

Visual C++

MonitorDetailWnd.cpp：源码内容
  1. // MonitorDetailWnd.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "testbt.h"
  6. #include "MonitorDetailWnd.h"
  8. #include "CategoryBarWnd.h"
  11. #ifdef _DEBUG
  12. #define new DEBUG_NEW
  13. #undef THIS_FILE
  14. static char THIS_FILE[] = __FILE__;
  15. #endif
  17. #define IDC_LIST_PEERS 56831
  18. #define IDC_LIST_INFOMATION 56832
  19. #define IDC_TREE_SUBFILES_MONITOR 56833
  20. #define IDC_EDIT_MSG 56834
  21. #define IDC_LIST_MSG 56834
  22. #define IDC_GRAPH_MSG 56835
  23. #define IDC_PEERINFO 56836
  25. /////////////////////////////////////////////////////////////////////////////
  26. // CMonitorDetailWnd
  28. CMonitorDetailWnd::CMonitorDetailWnd()
  29. {
  30. m_pFileDBItem = 0;
  31. m_pCategoryBarWnd = 0;
  32. m_pSetupRegister = 0;
  34. m_bShowSubFiles = false;
  35. m_bShowInfomation = false;
  36. m_iCurImageID = -1;
  37. m_bShowFileDBLog = false;
  40. }
  42. CMonitorDetailWnd::~CMonitorDetailWnd()
  43. {
  44. }
  47. BEGIN_MESSAGE_MAP(CMonitorDetailWnd, CWnd)
  48. //{{AFX_MSG_MAP(CMonitorDetailWnd)
  49. ON_WM_CREATE()
  50. ON_WM_SIZE()
  51. //}}AFX_MSG_MAP
  52. ON_MESSAGE(WM_FILE_TORRENT_OPENED, OnFileTorrentOpened)
  53. END_MESSAGE_MAP()
  56. /////////////////////////////////////////////////////////////////////////////
  57. // CMonitorDetailWnd message handlers
  60. void CMonitorDetailWnd::SetCateGoryBarWnd(CCategoryBarWnd* pCategoryBarWnd)
  61. {
  62. m_pCategoryBarWnd = pCategoryBarWnd;
  63. m_treeSubFiles.SetCateGoryBarWnd(pCategoryBarWnd);
  64. }
  66. BOOL CMonitorDetailWnd::CreateEx(CWnd *pParent, CRect rc, long lID, long lParam, CSetupRegister* pSetupRegister)
  67. {
  68. m_pSetupRegister = pSetupRegister;
  69. return Create(0, 0, WS_VISIBLE|WS_CHILD|WS_BORDER, rc, pParent, lID);
  70. }
  72. int CMonitorDetailWnd::OnCreate(LPCREATESTRUCT lpCreateStruct) 
  73. {
  74. if (CWnd::OnCreate(lpCreateStruct) == -1)
  75. return -1;
  78. m_listPeers.CreateEx(this, CRect(0, 0, 100, 100), IDC_LIST_PEERS, 0, m_pSetupRegister, (CMonitorWnd*)GetParent());
  79. m_listInfomation.CreateEx(this, CRect(0, 0, 100, 100), IDC_LIST_INFOMATION, 0, m_pSetupRegister, (CMonitorWnd*)GetParent());
  80. m_listMsg.CreateEx(this, CRect(0, 0, 100, 100), IDC_LIST_MSG, 0, (CMonitorWnd*)GetParent());
  81. m_treeSubFiles.CreateEx(this, CRect(0, 0, 100, 100), IDC_TREE_SUBFILES_MONITOR, true, (CMonitorWnd*)GetParent());
  82. m_graphWnd.CreateEx(this, CRect(0, 0, 100, 100), IDC_GRAPH_MSG, 0, (CMonitorWnd*)GetParent());
  83. m_listPeers.m_PeerInfoWnd.CreateEx(this, CRect(0,0, 100, 100),  &m_listPeers, IDC_PEERINFO, 0);
  85. /*
  86. m_listMsg.ShowWindow(false);
  87. m_listPeers.ShowWindow(false);
  88. m_listInfomation.ShowWindow(false);
  89. m_treeSubFiles.ShowWindow(false);
  90. m_graphWnd.ShowWindow(false);
  91. //*/
  92. m_listMsg.ShowWindow(false);
  93. m_listPeers.ShowWindow(false);
  94. m_treeSubFiles.ShowWindow(false);
  95. m_graphWnd.ShowWindow(false);
  96. m_listPeers.m_PeerInfoWnd.ShowWindow(false);
  98. return 0;
  99. }
  102. void CMonitorDetailWnd::OnSize(UINT nType, int cx, int cy) 
  103. {
  104. CWnd::OnSize(nType, cx, cy);
  106. m_listMsg.MoveWindow(CRect(0, 0, cx, cy));
  107. m_listPeers.MoveWindow(CRect(0, 0, cx, cy));
  108. m_listInfomation.MoveWindow(CRect(0, 0, cx, cy));
  109. m_treeSubFiles.MoveWindow(CRect(0, 0, cx, cy));
  110. m_graphWnd.MoveWindow(CRect(0, 0, cx, cy));
  111. m_listPeers.m_PeerInfoWnd.MoveWindow(CRect(0, 0, cx, cy));
  112. }
  114. /////////////////////////////////////////////////////////////////////////////
  115. // CMonitorDetailWnd function
  117. void CMonitorDetailWnd::Monitor(CFileDBItem* pFileDBItem)
  118. {
  119. m_pFileDBItem = pFileDBItem;
  121. if (pFileDBItem)
  122. {
  123. m_treeSubFiles.Monitor(pFileDBItem->m_strTorrentFileName, pFileDBItem->m_strFileName, pFileDBItem);
  124. // m_treeSubFiles.Monitor(&m_fileTorrent, pFileDBItem->m_strFileName);
  125. }
  126. else
  127. m_treeSubFiles.Monitor();
  129. m_listInfomation.Monitor(pFileDBItem);
  130. m_listPeers.Monitor(pFileDBItem);
  131. m_listMsg.Monitor(pFileDBItem);
  132. m_graphWnd.Monitor(pFileDBItem);
  134. m_fileTorrent.Close();
  136. m_bShowSubFiles = false;
  137. m_bShowInfomation = false;
  138. m_iCurImageID = -1;
  139. }
  141. void CMonitorDetailWnd::OnFileTorrentOpened(long lParam, long lwParam)
  142. {
  143. if (m_fileTorrent.GetOpenIndex() != lParam)
  144. return;
  146. if (!m_fileTorrent.IsOpen())
  147. {
  148. assert(false);
  149. if (m_fileTorrent.IsBad())
  150. {
  151. string strBad = m_fileTorrent.GetBadMsg();
  152. }
  153. return;
  154. }
  156. if (m_iCurImageID == IID_SUBFILES)
  157. {
  158. m_bShowSubFiles = true;
  159. m_treeSubFiles.ShowSubFiles();
  160. }
  161. else if (m_iCurImageID == IID_INFOMATION)
  162. {
  163. m_listInfomation.ShowInfomation(true);
  164. }
  165. }
  167. void CMonitorDetailWnd::ShowNode(CTreeCursor& cursor, bool bRefreshInfo)
  168. {
  169. assert(cursor);
  171. int iImageID = cursor.GetImageID();
  173. if (bRefreshInfo)
  174. {
  175. m_listMsg.ShowWindow(iImageID == IID_PEER || iImageID == IID_LOG);
  176. m_listPeers.ShowWindow(iImageID == IID_ALL_PEERS);
  177. m_listInfomation.ShowWindow(iImageID == IID_INFOMATION);
  178. m_treeSubFiles.ShowWindow(iImageID == IID_SUBFILES);
  179. m_graphWnd.ShowWindow(iImageID == IID_RUN_GRAPH);
  180. m_listPeers.m_PeerInfoWnd.ShowWindow(false);
  181. }
  183. switch (iImageID)
  184. {
  185. case IID_SUBFILES:
  186. {
  187. /*
  188. if (m_pFileDBItem && !m_fileTorrent.IsOpen() && !m_fileTorrent.IsBad())
  189. {
  190. m_fileTorrent.OpenFileEx(m_pCategoryBarWnd->GetDBSavePath() + 
  191. m_pFileDBItem->m_strTorrentFileName, string(), GetSafeHwnd());
  192. }
  193. else
  194. {
  195. //*/
  196. //*
  197. if (!m_bShowSubFiles)
  198. {
  199. m_bShowSubFiles = true;
  200. m_treeSubFiles.ShowSubFiles();
  201. }
  202. //*/
  203. // }
  204. }
  205. break;
  206. case IID_INFOMATION:
  207. {
  208. /*
  209. if (m_pFileDBItem && !m_fileTorrent.IsOpen() && !m_fileTorrent.IsBad())
  210. {
  211. m_fileTorrent.OpenFileEx(m_pCategoryBarWnd->GetDBSavePath() + 
  212. m_pFileDBItem->m_strTorrentFileName, string(), GetSafeHwnd());
  213. }
  214. else
  215. {
  216. //*/
  217. m_listInfomation.ShowInfomation(bRefreshInfo);
  218. // }
  219. // if (m_iCurImageID != iImageID)
  220. // ShowInfomation();
  221. }
  222. break;
  224. case IID_ALL_PEERS:
  225. {
  226. /*
  227. m_listPeers.SetRedraw(false);
  228. ShowAllPeers(bRefreshInfo);
  229. m_listPeers.SetRedraw(true);
  230. //*/
  231. m_listPeers.ShowAllPeers(bRefreshInfo);
  232. }
  233. break;
  234. case IID_PEER:
  235. {
  236. // ShowPeer(cursor, bRefreshInfo);
  237. }
  238. break;
  240. case IID_LOG:
  241. {
  242. m_listMsg.ShowLogs(bRefreshInfo);
  243. // ShowLogs(bRefreshInfo);
  244. }
  245. break;
  247. case IID_RUN_GRAPH:
  248. {
  249. m_graphWnd.ShowGraph(bRefreshInfo);
  250. }
  251. break;
  253. default:
  254. assert(false);
  255. }
  257. m_iCurImageID = iImageID;
  258. }
  260. /*
  261. void CMonitorDetailWnd::ShowInfomation()
  262. {
  263. m_listInfomation.DeleteAllItems();
  265. if (!m_pFileDBItem)
  266. return;
  269. m_listInfomation.InsertItem(0, "保存文件名", eASTERISK);
  270. m_listInfomation.SetItemText(0, 1, m_pFileDBItem->m_strFileName.data());
  272. m_listInfomation.InsertItem(1, "torrent文件名", eASTERISK);
  273. m_listInfomation.SetItemText(1, 1, m_pFileDBItem->m_strTorrentFileName.data());
  276. m_listInfomation.InsertItem(2, "认证码(hash)", eASTERISK);
  277. m_listInfomation.SetItemText(2, 1, m_pFileDBItem->m_strHash.data());
  279. m_listInfomation.InsertItem(3, "文件大小", eASTERISK);
  280. m_listInfomation.SetItemText(3, 1, FormatSize(m_pFileDBItem->m_lFileSize).data());
  282. CTime tCreatedTime(m_pFileDBItem->m_tTime);
  283. m_listInfomation.InsertItem(4, "创建时间", eASTERISK);
  284. m_listInfomation.SetItemText(4, 1, tCreatedTime.Format("%Y-%m-%d %H:%M"));
  287. CString strText;
  288. m_listInfomation.InsertItem(5, "已完成", eASTERISK);
  289. strText.Format("%d%%", (long)((m_pFileDBItem->m_fComplete)*100));
  290. m_listInfomation.SetItemText(5, 1, strText);
  292. m_listInfomation.InsertItem(6, "", -1);
  295. long lRunParamInx = 7;
  296. m_listInfomation.InsertItem(lRunParamInx, "绑定端口:", eASTERISK);
  297. m_listInfomation.InsertItem(lRunParamInx + 1, "最小下载者数:", eASTERISK);
  298. m_listInfomation.InsertItem(lRunParamInx + 2, "最大下载者数:", eASTERISK);
  299. m_listInfomation.InsertItem(lRunParamInx + 3, "显示间隔:", eASTERISK);
  300. m_listInfomation.InsertItem(lRunParamInx + 4, "文件安置模式:", eASTERISK);
  301. m_listInfomation.InsertItem(lRunParamInx + 5, "最大打开文件:", eASTERISK);
  302. m_listInfomation.InsertItem(lRunParamInx + 6, "最大上传速度:", eASTERISK);
  303. m_listInfomation.InsertItem(lRunParamInx + 7, "最大上传连接:", eASTERISK);
  306. if (m_pFileDBItem && m_pFileDBItem->m_pDownload && m_pFileDBItem->m_pDownload->IsDownloading())
  307. {
  308. CString strText;
  309. long lPort = 0, lPeerMin = 0, lPeerMax = 0, lDisplayItval = 0, lAllocType = 0, lFileOpenMax =0;
  310. m_pFileDBItem->m_pDownload->GetRunParameter(lPort,lPeerMin, lPeerMax, lDisplayItval, lAllocType, lFileOpenMax);
  312. strText.Format("%d", lPort);
  313. m_listInfomation.SetItemText(lRunParamInx, 1, strText);
  315. strText.Format("%d", lPeerMin);
  316. m_listInfomation.SetItemText(lRunParamInx + 1, 1, strText);
  318. strText.Format("%d", lPeerMax);
  319. m_listInfomation.SetItemText(lRunParamInx + 2, 1, strText);
  321. strText.Format("%d微秒", lDisplayItval);
  322. m_listInfomation.SetItemText(lRunParamInx + 3, 1, strText);
  324. switch (lAllocType)
  325. {
  326. case CStorageWrapperEx::eAllocNormal:
  327. strText = "普通分配";
  328. break;
  329. case CStorageWrapperEx::eAllocSparse:
  330. strText = "特殊分配";
  331. break;
  332. case CStorageWrapperEx::eAllocPreAllocate:
  333. strText = "预分配";
  334. break;
  335. case CStorageWrapperEx::eAllocBackGound:
  336. strText = "后台分配";
  337. break;
  338. }
  339. m_listInfomation.SetItemText(lRunParamInx + 4, 1, strText);
  341. strText.Format("%d", lFileOpenMax);
  342. m_listInfomation.SetItemText(lRunParamInx + 5, 1, strText);
  344. strText.Format("%d(K)", m_pFileDBItem->m_lUploadSpeedMax);
  345. m_listInfomation.SetItemText(lRunParamInx + 6, 1, strText);
  347. strText.Format("%d", m_pFileDBItem->m_lUploadPeerMax);
  348. m_listInfomation.SetItemText(lRunParamInx + 7, 1, strText);
  349. }
  350. }
  352. void CMonitorDetailWnd::ShowRunStatics()
  353. {
  354. m_listInfomation.DeleteAllItems();
  356. if (!m_pFileDBItem || !m_pFileDBItem->m_pDownload || !m_pFileDBItem->m_pDownload->IsDownloading())
  357. return;
  359. CString strText;
  360. long lPort = 0, lPeerMin = 0, lPeerMax = 0, lDisplayItval = 0, lAllocType = 0, lFileOpenMax =0;
  362. m_pFileDBItem->m_pDownload->GetRunParameter(lPort,lPeerMin, lPeerMax, lDisplayItval, lAllocType, lFileOpenMax);
  364. m_listInfomation.InsertItem(0, "绑定端口:", eASTERISK);
  365. strText.Format("%d", lPort);
  366. m_listInfomation.SetItemText(0, 1, strText);
  368. m_listInfomation.InsertItem(1, "最小下载者数:", eASTERISK);
  369. strText.Format("%d", lPeerMin);
  370. m_listInfomation.SetItemText(1, 1, strText);
  372. m_listInfomation.InsertItem(2, "最大下载者数:", eASTERISK);
  373. strText.Format("%d", lPeerMax);
  374. m_listInfomation.SetItemText(2, 1, strText);
  376. m_listInfomation.InsertItem(3, "显示间隔:", eASTERISK);
  377. strText.Format("%d微秒", lDisplayItval);
  378. m_listInfomation.SetItemText(3, 1, strText);
  380. m_listInfomation.InsertItem(4, "文件安置模式:", eASTERISK);
  381. switch (lAllocType)
  382. {
  383. case CStorageWrapperEx::eAllocNormal:
  384. strText = "普通分配";
  385. break;
  386. case CStorageWrapperEx::eAllocSparse:
  387. strText = "特殊分配";
  388. break;
  389. case CStorageWrapperEx::eAllocPreAllocate:
  390. strText = "预分配";
  391. break;
  392. case CStorageWrapperEx::eAllocBackGound:
  393. strText = "后台分配";
  394. break;
  395. }
  396. m_listInfomation.SetItemText(4, 1, strText);
  398. m_listInfomation.InsertItem(5, "最大打开文件:", eASTERISK);
  399. strText.Format("%d", lFileOpenMax);
  400. m_listInfomation.SetItemText(5, 1, strText);
  402. m_listInfomation.InsertItem(6, "最大上传速度:", eASTERISK);
  403. strText.Format("%d(K)", m_pFileDBItem->m_lUploadSpeedMax);
  404. m_listInfomation.SetItemText(6, 1, strText);
  406. m_listInfomation.InsertItem(7, "最大上传连接:", eASTERISK);
  407. strText.Format("%d", m_pFileDBItem->m_lUploadPeerMax);
  408. m_listInfomation.SetItemText(7, 1, strText);
  409. }
  411. void CMonitorDetailWnd::ShowPeer(CTreeCursor& cursor, bool bRefreshInfo)
  412. {
  413. m_listMsg.DeleteAllItems();
  415. if (m_pFileDBItem && m_pFileDBItem->m_pDownload && m_pFileDBItem->m_pDownload->IsDownloading())
  416. {
  417. CAddrPort* pData = (CAddrPort*)cursor.GetData();
  418. m_listMsg.InsertItem(m_listMsg.GetItemCount(), 
  419. m_pFileDBItem->m_pDownload->GetSocketMessage(pData->m_lAddr, pData->m_sPort).data());
  420. }
  421. else 
  422. assert(false);
  423. }
  425. void CMonitorDetailWnd::ShowLogs(bool bRefreshInfo)
  426. {
  428. if (bRefreshInfo)
  429. {
  430. m_bShowFileDBLog = false;
  431. m_listMsg.DeleteAllItems();
  432. }
  434. if (m_pFileDBItem )
  435. {
  436. if (m_pFileDBItem->m_pDownload)
  437. {
  438. vector<string> vSystemMsg;
  439. m_pFileDBItem->m_pDownload->GetSystemMessage(vSystemMsg);
  441. int iStart = 0;
  442. if (!bRefreshInfo)
  443. {
  444. iStart = m_listMsg.GetItemCount();
  445. if (m_bShowFileDBLog)
  446. {
  447. assert(iStart > 0);
  448. iStart -= 1;
  449. }
  450. }
  452. for (int i=iStart; i<vSystemMsg.size(); i++)
  453. {
  454. m_listMsg.InsertItem(i, vSystemMsg[i].data());
  455. }
  456. }
  457. else
  458. {
  459. if (!bRefreshInfo)
  460. {
  461. int iCount = m_listMsg.GetItemCount();
  462. if (m_bShowFileDBLog)
  463. iCount -= 1;
  465. for (int i=0; i<iCount; i++)
  466. m_listMsg.DeleteItem(0);
  467. }
  468. }
  470. if (!m_pFileDBItem->m_strBad.empty())
  471. {
  472. m_bShowFileDBLog = true;
  474. if (bRefreshInfo)
  475. m_listMsg.InsertItem(m_listMsg.GetItemCount(), m_pFileDBItem->m_strBad.data());
  476. }
  477. }
  479. }
  480. void CMonitorDetailWnd::OnRclickListInfomation(NMHDR* pNMHDR, LRESULT* pResult) 
  481. {
  483. CListCtrl* pListCtrl = 0;
  484. if (m_listInfomation.IsWindowVisible())
  485. pListCtrl = &m_listInfomation;
  486. // else if (m_listPeers.IsWindowVisible())
  487. // pListCtrl = &m_listPeers;
  488. // else if (m_listMsg.IsWindowVisible())
  489. // pListCtrl = &m_listMsg;
  491. if (!pListCtrl) return;
  493. bool bcopy = false;
  494. if (pListCtrl->GetSelectedCount())
  495. bcopy = true;
  497. CMenu menu_bar;
  498. menu_bar.CreatePopupMenu();
  500. if (bcopy)
  501. menu_bar.AppendMenu(MF_STRING, ID_EDIT_COPY, "复制(&C)t");
  503. /*
  504. if (pListCtrl == &m_listPeers)
  505. {
  506. menu_bar.AppendMenu(MF_STRING, ID_MENUITEM_PAUSE_PEERS, "暂停选中的连接(&P)t");
  507. menu_bar.AppendMenu(MF_STRING, ID_MENUITEM_STOP_PEERS, "关闭选中的连接(&P)t");
  508. }
  509. //*/
  510. /*
  511. menu_bar.AppendMenu(MF_STRING, ID_MENUITEM_SELECT_ALL, "全选(&A)t");
  513. CPoint posMouse;
  514. GetCursorPos(&posMouse);
  515. menu_bar.TrackPopupMenu(TPM_LEFTALIGN |TPM_RIGHTBUTTON,posMouse.x,posMouse.y,this);
  516. }
  517. //*/
  518. /*
  519. void CMonitorDetailWnd::OnMenuitemCopy()
  520. {
  521. CListCtrl* pListCtrl = 0;
  522. if (m_listInfomation.IsWindowVisible())
  523. pListCtrl = &m_listInfomation;
  524. // else if (m_listPeers.IsWindowVisible())
  525. // pListCtrl = &m_listPeers;
  526. // else if (m_listMsg.IsWindowVisible())
  527. // pListCtrl = &m_listMsg;
  528. if (!pListCtrl) return;
  531. CString strSource; 
  533. int nColumnCount = pListCtrl->GetHeaderCtrl()->GetItemCount();
  534. POSITION pos = pListCtrl->GetFirstSelectedItemPosition();
  535. while (pos)
  536. {
  537. int index = pListCtrl->GetNextSelectedItem(pos);
  538. for (int i=0; i<nColumnCount; i++)
  539. strSource += pListCtrl->GetItemText(index, i) + "  ";
  541. strSource += "rn";
  542. }
  544. if (!CopyTextToClipboard(strSource))
  545. AfxMessageBox("复制失败");
  546. }
  547. void CMonitorDetailWnd::OnMenuitemSelectAll()
  548. {
  549. CListCtrl* pListCtrl = 0;
  550. if (m_listInfomation.IsWindowVisible())
  551. pListCtrl = &m_listInfomation;
  552. // else if (m_listPeers.IsWindowVisible())
  553. // pListCtrl = &m_listPeers;
  554. // else if (m_listMsg.IsWindowVisible())
  555. // pListCtrl = &m_listMsg;
  557. if (!pListCtrl) return;
  560. for (int i=0; i<pListCtrl->GetItemCount(); i++)
  561. pListCtrl->SetItemState(i, LVIS_SELECTED, LVIS_SELECTED);
  563. pListCtrl->SetFocus();
  564. }
  566. //*/
  567. /*
  568. void CMonitorDetailWnd::OnMenuItemPeers(UINT uID)
  569. {
  570. if (!m_pFileDBItem || !m_pFileDBItem->m_pDownload || !m_pFileDBItem->m_pDownload->IsDownloading())
  571. {
  572. assert(false);
  573. return;
  574. }
  576. switch (uID)
  577. {
  578. case ID_MENUITEM_PAUSE_PEERS:
  579. {
  581. // m_pFileDBItem->m_pDownload->PausePeer
  582. }
  583. break;
  584. case ID_MENUITEM_STOP_PEERS:
  585. {
  586. POSITION pos = m_listPeers.GetFirstSelectedItemPosition();
  587. while (pos)
  588. {
  589. int nItem = m_listPeers.GetNextSelectedItem(pos);
  590. CAddrPort* pData = (CAddrPort*)m_listPeers.GetItemData(nItem);
  591. if (!pData)
  592. {
  593. assert(false);
  594. return;
  595. }
  597. m_pFileDBItem->m_pDownload->ClosePeer(pData);
  598. }
  601. }
  602. break;
  603. default:
  604. assert(false);
  605. }
  606. }
  607. //*/