| | |
|---|
| | | #include "CMaster.h" |
|---|
| | | #include <future> |
|---|
| | | #include <vector> |
|---|
| | | #include <algorithm> |
|---|
| | | #include "RecipeManager.h" |
|---|
| | | #include <fstream> |
|---|
| | | #include "SerializeUtil.h" |
|---|
| | |
|---|
| | | |
|---|
| | | bool CMaster::ceidDefined(uint32_t ceid) const |
|---|
| | | { |
|---|
| | | return true; |
|---|
| | | if (m_allowedCeids.empty()) return true; // backward compatible: treat as all allowed when not configured |
|---|
| | | return m_allowedCeids.find(ceid) != m_allowedCeids.end(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | void CMaster::handleCollectionEvent(uint32_t ceid) |
|---|
| | | { |
|---|
| | | // 遍历当前 PJ，命中 pauseEvents 时可在此扩展暂停动作 |
|---|
| | | for (auto pj : m_processJobs) { |
|---|
| | | if (pj == nullptr) continue; |
|---|
| | | const auto& pauseList = pj->pauseEvents(); |
|---|
| | | if (std::find(pauseList.begin(), pauseList.end(), ceid) != pauseList.end()) { |
|---|
| | | LOGW("<Master>PauseEvent hit: CEID=%u, PJ=%s, state=%d", ceid, pj->id().c_str(), (int)pj->state()); |
|---|
| | | // TODO: 衔接具体暂停策略（如暂停 PJ/CJ、停止调度/搬送），此处仅留桩位 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | void CMaster::setAllowedCeids(const std::vector<unsigned int>& ceids) |
|---|
| | | { |
|---|
| | | m_allowedCeids.clear(); |
|---|
| | | m_allowedCeids.reserve(ceids.size()); |
|---|
| | | for (auto id : ceids) { |
|---|
| | | m_allowedCeids.insert(id); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | bool CMaster::saveState() const |
|---|
