init

w1146869587

2022-01-24 0408576e9da10015ffa9da0079b8c985113ce4b3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
#pragma once
#include "stdafx.h"
#include "MBTaskLoopMgr.h"
#include "MBFileMD5Mgr.h"
 
/************************************************************************/
/*  ÓÃÓÚ½«ÎļþÉÏ´«µ½·þÎñÆ÷µÄÏ̠߳                                       */
/************************************************************************/ 
class AFX_EXT_CLASS CMBThreadUploadSvr :
    protected CThreadObject
{
public:
    CMBThreadUploadSvr(void);
    ~CMBThreadUploadSvr(void);
private:
    CMBTransMgr               *m_pTransMgr;              // ´«Êä¹ÜÀíÆ÷
    CMBServerMgr              *m_pSvrMgr;             // ·þÎñ¹ÜÀíÆ÷
    CMBFileMD5Mgr             *m_pFileMD5Mgr;            // ÎļþMD5¹ÜÀíÆ÷
    BOOL                       m_bStop;                     // Í£Ö¹±êʶ
    HWND                       m_hWnd;                     // ´°¿Ú¾ä±ú£¨Ö÷£©
    int                        m_nMaxUploadQueueCount;   // ÉÏ´«¶ÓÁÐĬÈÏ´óС
    CMBTaskLoopMgr            *m_pTaskLoopMgr;             // ÈÎÎñ¹ÜÀíÆ÷
public:
    virtual UINT Run();
public:
    void StartThread();  // ¿ªÊ¼Ïß³Ì
    void OverThread();   // ½áÊøÏ̠߳
public:
    void SetTransAndServerMgr( CMBTransMgr *pTransMgr,CMBServerMgr *pServerMgr );
    void SetFileMD5Mgr(CMBFileMD5Mgr  *pFileMD5Mgr);
    void SetHwnd( HWND hWnd  );
    void SetTaskLoopMgr(CMBTaskLoopMgr *pTaskLoopMgr);
private:
    bool TransTimerUpload(CMBUploadQueue  *pUploadQueue,BOOL &bThreadStop );
    void DmsGenMD5( CMBUploadFileInfo *pUploadFileInfo );
private:
    void EventMsgUploadFile(CAutoRefPtr<CMBUploadFileInfo>  &curClient);    
};