Made the `StatusUpdateManagerProcess` process ID configurable. Review: https://reviews.apache.org/r/64509/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/9d7da9b7 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/9d7da9b7 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/9d7da9b7 Branch: refs/heads/master Commit: 9d7da9b77ad33530e0a436614479cafd08c13ec3 Parents: e70097c Author: Gaston Kleiman <[email protected]> Authored: Tue Dec 12 16:18:19 2017 -0800 Committer: Greg Mann <[email protected]> Committed: Tue Dec 12 16:55:47 2017 -0800 ---------------------------------------------------------------------- src/status_update_manager/offer_operation.cpp | 4 +++- src/status_update_manager/status_update_manager_process.hpp | 6 ++++-- 2 files changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/9d7da9b7/src/status_update_manager/offer_operation.cpp ---------------------------------------------------------------------- diff --git a/src/status_update_manager/offer_operation.cpp b/src/status_update_manager/offer_operation.cpp index 8ffce61..986310e 100644 --- a/src/status_update_manager/offer_operation.cpp +++ b/src/status_update_manager/offer_operation.cpp @@ -38,7 +38,9 @@ OfferOperationStatusUpdateManager::OfferOperationStatusUpdateManager() new StatusUpdateManagerProcess< UUID, OfferOperationStatusUpdateRecord, - OfferOperationStatusUpdate>("offer operation status update")) + OfferOperationStatusUpdate>( + "offer-operation-status-update-manager", + "offer operation status update")) { spawn(process.get()); } http://git-wip-us.apache.org/repos/asf/mesos/blob/9d7da9b7/src/status_update_manager/status_update_manager_process.hpp ---------------------------------------------------------------------- diff --git a/src/status_update_manager/status_update_manager_process.hpp b/src/status_update_manager/status_update_manager_process.hpp index 935f754..8c9e06f 100644 --- a/src/status_update_manager/status_update_manager_process.hpp +++ b/src/status_update_manager/status_update_manager_process.hpp @@ -108,8 +108,10 @@ public: State() : streams(), errors(0) {} }; - StatusUpdateManagerProcess(const std::string& _statusUpdateType) - : process::ProcessBase(process::ID::generate("status-update-manager")), + StatusUpdateManagerProcess( + const std::string& id, + const std::string& _statusUpdateType) + : process::ProcessBase(process::ID::generate(id)), statusUpdateType(_statusUpdateType), paused(false) {}
