facade_handler_, common::Bind(&AclManagerFacadeService::enqueue_packet, common::Unretained(this),
common::Unretained(request), common::Passed(std::move(promise))));
}
- }
- auto status = future.wait_for(std::chrono::milliseconds(1000));
- if (status != std::future_status::ready) {
- return ::grpc::Status(::grpc::StatusCode::RESOURCE_EXHAUSTED, "Can't send packet");
+ auto status = future.wait_for(std::chrono::milliseconds(1000));
+ if (status != std::future_status::ready) {
+ return ::grpc::Status(::grpc::StatusCode::RESOURCE_EXHAUSTED, "Can't send packet");
+ }
}
return ::grpc::Status::OK;
}
def turn_on_ertm(self, tx_window_size=10, max_transmit=20):
self.ertm_option = l2cap_packets.RetransmissionAndFlowControlConfigurationOption(
)
- self.ertm_option.mode = l2cap_packets.RetransmissionAndFlowControlModeOption.L2CAP_BASIC
+ self.ertm_option.mode = l2cap_packets.RetransmissionAndFlowControlModeOption.ENHANCED_RETRANSMISSION
self.ertm_option.tx_window_size = tx_window_size
self.ertm_option.max_transmit = max_transmit
self.ertm_option.retransmission_time_out = 2000
config->monitor_time_out_ = 12000;
}
configuration_state.remote_retransmission_and_flow_control_ = *config;
+ configuration_state.retransmission_and_flow_control_mode_ = config->mode_;
rsp_options.emplace_back(std::make_unique<RetransmissionAndFlowControlConfigurationOption>(*config));
break;
}