ps/base/Postoffice.cc
| Line | Branch | Exec | Source |
|---|---|---|---|
| 1 | #include "Postoffice.h" | ||
| 2 | |||
| 3 | #include "base/log.h" | ||
| 4 | |||
| 5 | #include <mutex> | ||
| 6 | |||
| 7 | DEFINE_int32(num_server_processes, 1, "# of server processes"); | ||
| 8 | DEFINE_int32(num_client_processes, 1, "# of client processes"); | ||
| 9 | DEFINE_int32(global_id, 0, ""); | ||
| 10 | |||
| 11 | ✗ | XPostoffice::XPostoffice() { | |
| 12 | ✗ | num_servers_ = FLAGS_num_server_processes; | |
| 13 | ✗ | num_clients_ = FLAGS_num_client_processes; | |
| 14 | |||
| 15 | ✗ | int g_id = FLAGS_global_id; | |
| 16 | |||
| 17 | static std::mutex m; | ||
| 18 | ✗ | std::lock_guard<std::mutex> _(m); | |
| 19 | static bool init_ = false; | ||
| 20 | |||
| 21 | ✗ | CHECK(init_ == false); | |
| 22 | ✗ | init_ = true; | |
| 23 | |||
| 24 | ✗ | global_id_ = g_id; | |
| 25 | ✗ | if (0 <= g_id && g_id < num_servers_) { | |
| 26 | ✗ | actor_ = ACTOR_SERVER; | |
| 27 | ✗ | server_id_ = g_id; | |
| 28 | ✗ | } else if (num_servers_ <= g_id && g_id < num_servers_ + num_clients_) { | |
| 29 | ✗ | actor_ = ACTOR_CLIENT; | |
| 30 | ✗ | client_id_ = g_id - num_servers_; | |
| 31 | } else { | ||
| 32 | ✗ | LOG(FATAL) << "Invalid XPostoffice" << std::endl | |
| 33 | ✗ | << "global_id = " << global_id_ << std::endl | |
| 34 | ✗ | << "server_id = " << server_id_ << std::endl | |
| 35 | ✗ | << "client_id = " << client_id_ << std::endl; | |
| 36 | } | ||
| 37 | ✗ | } | |
| 38 |