We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 6a242e3 + 19516d2 commit f3471b6Copy full SHA for f3471b6
Cargo.toml
@@ -1,6 +1,6 @@
1
[package]
2
name = "ttrpc"
3
-version = "0.4.10"
+version = "0.4.11"
4
authors = ["The AntFin Kata Team <kata@list.alibaba-inc.com>"]
5
edition = "2018"
6
license = "Apache-2.0"
src/sync/client.rs
@@ -50,7 +50,7 @@ impl Client {
50
AddressFamily::Unix,
51
SockType::Stream,
52
None,
53
- SockFlag::empty(),
+ SockFlag::SOCK_CLOEXEC,
54
)
55
.unwrap();
56
let client_close = Arc::new(ClientClose { fd, close_fd });
@@ -185,6 +185,9 @@ impl Client {
185
186
map.remove(&mh.stream_id);
187
}
188
+
189
+ close(recver_fd).unwrap();
190
191
trace!("Recver quit");
192
});
193
0 commit comments