if (peering_state.state_test(PG_STATE_WAIT)) {
auto prior_readable_until_ub = peering_state.get_prior_readable_until_ub();
if (mnow < prior_readable_until_ub) {
- logger().info("{} will wait (mnow {} < prior_readable_until_ub {})",
- __func__, mnow, prior_readable_until_ub);
+ logger().info(
+ "{}: {} will wait (mnow {} < prior_readable_until_ub {})",
+ *this, __func__, mnow, prior_readable_until_ub);
queue_check_readable(
peering_state.get_last_peering_reset(),
prior_readable_until_ub - mnow);
} else {
- logger().info("{} no longer wait (mnow {} >= prior_readable_until_ub {})",
- __func__, mnow, prior_readable_until_ub);
+ logger().info(
+ "{}:{} no longer wait (mnow {} >= prior_readable_until_ub {})",
+ *this, __func__, mnow, prior_readable_until_ub);
peering_state.state_clear(PG_STATE_WAIT);
peering_state.clear_prior_readable_until_ub();
changed = true;
if (peering_state.state_test(PG_STATE_LAGGY)) {
auto readable_until = peering_state.get_readable_until();
if (readable_until == readable_until.zero()) {
- logger().info("{} still laggy (mnow {}, readable_until zero)",
- __func__, mnow);
+ logger().info(
+ "{}:{} still laggy (mnow {}, readable_until zero)",
+ *this, __func__, mnow);
} else if (mnow >= readable_until) {
- logger().info("{} still laggy (mnow {} >= readable_until {})",
- __func__, mnow, readable_until);
+ logger().info(
+ "{}:{} still laggy (mnow {} >= readable_until {})",
+ *this, __func__, mnow, readable_until);
} else {
- logger().info("{} no longer laggy (mnow {} < readable_until {})",
- __func__, mnow, readable_until);
+ logger().info(
+ "{}:{} no longer laggy (mnow {} < readable_until {})",
+ *this, __func__, mnow, readable_until);
peering_state.state_clear(PG_STATE_LAGGY);
changed = true;
}