Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

lightclient: Fix wasm socket closure called after being dropped #1289

Merged
merged 10 commits into from
Nov 29, 2023
Merged

lightclient: Fix wasm socket closure called after being dropped #1289

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
f3eb4cd
lightclient: Close wasm socket while dropping from connecting state
lexnv Nov 23, 2023
cfac283
lightclient: Construct one time only closures
lexnv Nov 24, 2023
860f0e0
testing: Enable console logs for lightclient WASM testing
lexnv Nov 24, 2023
8660940
lightclient: Separate wakes and check connectivity on poll_read
lexnv Nov 24, 2023
b2e6d41
lightclient: Close the socket depending on internal state
lexnv Nov 24, 2023
78f4d88
Revert "lightclient: Separate wakes and check connectivity on poll_read"
lexnv Nov 24, 2023
1cdee8f
lightclient: Return pending if socket is opening from poll_read
lexnv Nov 24, 2023
bd13879
lightclient: Close the socket on `poll_close`
lexnv Nov 24, 2023
099f6ee
lightclient: Reset closures on Drop to avoid recursive invokation
lexnv Nov 27, 2023
abe77b5
lightclient: Close the socket if not already closing
lexnv Nov 27, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion lightclient/src/platform/wasm_socket.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ impl Drop for WasmSocket {
fn drop(&mut self) {
let inner = self.inner.lock().expect("Mutex is poised; qed");

if inner.state == ConnectionState::Opened {
if inner.state == ConnectionState::Opened || inner.state == ConnectionState::Connecting {
let _ = self.socket.close();
}
}
Expand Down
Loading