Skip to content
This repository was archived by the owner on Sep 27, 2019. It is now read-only.

Commit 40acdf6

Browse files
tli2pervazea
authored andcommitted
Fix ssl copy bug (#1436)
* Fix ssl copy bug * Update network_io_wrapper_factory.cpp
1 parent d22bd24 commit 40acdf6

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/network/network_io_wrapper_factory.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,7 @@ std::shared_ptr<NetworkIoWrapper> NetworkIoWrapperFactory::NewNetworkIoWrapper(
2424
conn_fd, std::make_shared<ReadBuffer>(),
2525
std::make_shared<WriteBuffer>());
2626
reusable_wrappers_[conn_fd] =
27-
std::static_pointer_cast<NetworkIoWrapper, PosixSocketIoWrapper>(
28-
wrapper);
27+
std::static_pointer_cast<NetworkIoWrapper, PosixSocketIoWrapper>(wrapper);
2928
return wrapper;
3029
}
3130

@@ -52,6 +51,7 @@ Transition NetworkIoWrapperFactory::PerformSslHandshake(
5251
throw NetworkProcessException("Failed to set ssl fd");
5352
io_wrapper =
5453
std::make_shared<SslSocketIoWrapper>(std::move(*io_wrapper), context);
54+
reusable_wrappers_[io_wrapper->sock_fd_] = io_wrapper;
5555
} else {
5656
auto ptr = std::dynamic_pointer_cast<SslSocketIoWrapper, NetworkIoWrapper>(
5757
io_wrapper);
@@ -75,4 +75,4 @@ Transition NetworkIoWrapperFactory::PerformSslHandshake(
7575
}
7676
}
7777
} // namespace network
78-
} // namespace peloton
78+
} // namespace peloton

0 commit comments

Comments
 (0)