BlockStorage/repertory
1
0
Fork 0
Code Issues 7 Pull Requests Releases 6 Wiki Activity

call shutdown before close

Browse Source
This commit is contained in:
Scott E. Graves 2024-12-28 19:31:02 -06:00
parent a788563db6
commit 26897c256b
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
repertory/librepertory/src/comm/packet/packet_client.cpp
View File

@ -49,6 +49,8 @@ packet_client::~packet_client() {
void packet_client::close(client &cli) { void packet_client::close(client &cli) {
try { try {
cli.socket.shutdown(boost::asio::socket_base::shutdown_both);
boost::system::error_code err; boost::system::error_code err;
cli.socket.close(err); cli.socket.close(err);
} catch (...) { } catch (...) {
@ -110,8 +112,8 @@ void packet_client::put_client(std::shared_ptr<client> &cli) {
} }
} }
auto packet_client::read_packet(client &cli, packet &response) auto packet_client::read_packet(client &cli,
-> packet::error_type { packet &response) -> packet::error_type {
data_buffer buffer(sizeof(std::uint32_t)); data_buffer buffer(sizeof(std::uint32_t));
const auto read_buffer = [&]() { const auto read_buffer = [&]() {
std::uint32_t offset{}; std::uint32_t offset{};
@ -152,8 +154,8 @@ void packet_client::resolve() {
.resolve(cfg_.host_name_or_ip, std::to_string(cfg_.api_port)); .resolve(cfg_.host_name_or_ip, std::to_string(cfg_.api_port));
} }
auto packet_client::send(std::string_view method, std::uint32_t &service_flags) auto packet_client::send(std::string_view method,
-> packet::error_type { std::uint32_t &service_flags) -> packet::error_type {
packet request; packet request;
return send(method, request, service_flags); return send(method, request, service_flags);
} }
@ -165,8 +167,8 @@ auto packet_client::send(std::string_view method, packet &request,
} }
auto packet_client::send(std::string_view method, packet &request, auto packet_client::send(std::string_view method, packet &request,
packet &response, std::uint32_t &service_flags) packet &response,
-> packet::error_type { std::uint32_t &service_flags) -> packet::error_type {
REPERTORY_USES_FUNCTION_NAME(); REPERTORY_USES_FUNCTION_NAME();
auto success = false; auto success = false;