| 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 |
0/2
✗ Branch 1 not taken.
✗ Branch 2 not taken.
|
✗ |
std::lock_guard<std::mutex> _(m); |
| 19 |
|
|
static bool init_ = false; |
| 20 |
|
|
|
| 21 |
0/12
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
|
✗ |
CHECK(init_ == false); |
| 22 |
|
✗ |
init_ = true; |
| 23 |
|
|
|
| 24 |
|
✗ |
global_id_ = g_id; |
| 25 |
0/4
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
✗ |
if (0 <= g_id && g_id < num_servers_) { |
| 26 |
|
✗ |
actor_ = ACTOR_SERVER; |
| 27 |
|
✗ |
server_id_ = g_id; |
| 28 |
0/4
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
✗ |
} 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 |
0/8
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
|
✗ |
LOG(FATAL) << "Invalid XPostoffice" << std::endl |
| 33 |
0/6
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
|
✗ |
<< "global_id = " << global_id_ << std::endl |
| 34 |
0/6
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
|
✗ |
<< "server_id = " << server_id_ << std::endl |
| 35 |
0/6
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
|
✗ |
<< "client_id = " << client_id_ << std::endl; |
| 36 |
|
|
} |
| 37 |
|
✗ |
} |
| 38 |
|
|
|