33
34
void AddJob(tFileItemPtr m_pItem, tHttpUrl hi);
34
void AddJob(tFileItemPtr m_pItem,
35
acfg::tRepoData *pBackends, const mstring & sPatSuffix);
35
void AddJob(tFileItemPtr m_pItem, const acfg::tRepoData *pBackends,
36
const mstring & sPatSuffix);
36
37
void EnqJob(tDlJob *);
38
39
mstring m_sXForwardedFor;
43
44
dlcon & operator=(const dlcon&);
44
45
dlcon(const dlcon&);
47
//friend class tDlJob;
48
MYSTD::list<tDlJob*> m_qToReceive;
53
53
// flags and local copies for input parsing
54
54
/// remember being attached to an fitem
58
/// shared blacklist for bad hosts
59
MYSTD::set<mstring> m_MirrorHostBlacklist;
61
//! will establish the connection, keep its object pointer
62
//! in m_pConnection and return its file descriptor (negative on failure)
63
// int Connect(cmstring & sHostname, mstring &sErrOut);
60
/// blacklist for permanently failing hosts, with error message
61
MYSTD::map<MYSTD::pair<cmstring,cmstring>, mstring> m_blacklist;
62
void BlacklistMirror(tDlJobPtr &failJob, cmstring &msg);
63
bool SetupJobConfig(tDlJobPtr &job, mstring *pReasonMsg);
65
tSS m_sendBuf, m_inBuf;
67
UINT ExchangeData(mstring &sErrorMsg, int fd, tDljQueue &qActive);
67
typedef MYSTD::list<tDlJob*>::iterator dljIter;