update udp close

This commit is contained in:
zizifn
2023-03-07 00:51:50 +08:00
committed by zizifn
parent 14822d2fdf
commit 0cbadf872a
4 changed files with 25 additions and 7 deletions

View File

@@ -319,7 +319,7 @@ function makeUDPSocketStream(portRemote, address) {
if (err) {
console.log(err);
controller.error('Failed to send UDP packet !!');
udpClient.close();
safeCloseUDP(udpClient);
}
});
index = index;
@@ -331,9 +331,19 @@ function makeUDPSocketStream(portRemote, address) {
},
flush(controller) {
udpClient.close();
safeCloseUDP(udpClient);
controller.terminate();
},
});
return transformStream;
}
function safeCloseUDP(client: UDPSocket){
try{
client.close()
}catch(error){
console.log('error close udp', error);
}
}

View File

@@ -5698,7 +5698,7 @@ function processVlessHeader(vlessBuffer, userID
// controller.error('in valid user');
return {
hasError: true,
message: 'in valid user',
message: 'invalid user',
};
}
const optLength = new Uint8Array(vlessBuffer.slice(17, 18))[0];
@@ -6297,7 +6297,7 @@ function makeUDPSocketStream(portRemote, address) {
if (err) {
console.log(err);
controller.error('Failed to send UDP packet !!');
udpClient.close();
safeCloseUDP(udpClient);
}
});
index = index;
@@ -6307,12 +6307,20 @@ function makeUDPSocketStream(portRemote, address) {
// port is big-Endian in raw data etc 80 == 0x005d
},
flush(controller) {
udpClient.close();
safeCloseUDP(udpClient);
controller.terminate();
},
});
return transformStream;
}
function safeCloseUDP(client) {
try {
client.close();
}
catch (error) {
console.log('error close udp', error);
}
}
})();

File diff suppressed because one or more lines are too long

View File

@@ -121,7 +121,7 @@ export function processVlessHeader(
// controller.error('in valid user');
return {
hasError: true,
message: 'in valid user',
message: 'invalid user',
};
}