*release mutex
This commit is contained in:
parent
1bd159c19e
commit
44a9838490
|
@ -433,6 +433,8 @@ async function handleSyncProtomux(aq: ActiveQuery) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
debugger;
|
||||||
|
|
||||||
const mux = Protomux.from(socket);
|
const mux = Protomux.from(socket);
|
||||||
let mutex: Mutex | null = null;
|
let mutex: Mutex | null = null;
|
||||||
if (mux.mutex) {
|
if (mux.mutex) {
|
||||||
|
@ -482,6 +484,8 @@ async function handleSyncProtomux(aq: ActiveQuery) {
|
||||||
}
|
}
|
||||||
|
|
||||||
aq.respond(ret);
|
aq.respond(ret);
|
||||||
|
|
||||||
|
mutex.release();
|
||||||
}
|
}
|
||||||
|
|
||||||
function getSwarmToSocketConnectionId(socket: any) {
|
function getSwarmToSocketConnectionId(socket: any) {
|
||||||
|
|
Loading…
Reference in New Issue