std::bind(&process::ctrl_close, this, _1));
while (ctrl_close_pending) {
comm.ctrl_flush(false);
- XBT_DEBUG("waiting for %d CTRL CLOSE", ctrl_close_pending);
+ XBT_DEBUG("waiting for %d CTRL_CLOSE", ctrl_close_pending);
ctrl_receive(-1.0);
}
comm.ctrl_flush(true);
std::bind(&process::data_close, this, _1));
while (data_close_pending) {
comm.data_flush(false);
- XBT_DEBUG("waiting for %d DATA CLOSE", data_close_pending);
+ XBT_DEBUG("waiting for %d DATA_CLOSE", data_close_pending);
data_receive(-1.0);
}
comm.data_flush(true);