stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

closed socket fix

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-06-29 17:29:11 +02:00
parent 04b7808b00
commit 044dbdb441
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/peerdiscovery/LocalPeerDiscoveryBroadcaster.java
View File

@@ -55,7 +55,7 @@ public class LocalPeerDiscoveryBroadcaster {
private void broadcast() {
try {
while (!Thread.interrupted()) {
while (!Thread.interrupted() && !_socket.isClosed()) {
Thread.sleep(broadcastInterval);
try {

2
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/peerdiscovery/LocalPeerDiscoveryClient.java
View File

@@ -48,7 +48,7 @@ public class LocalPeerDiscoveryClient {
}
private void client() {
while (!Thread.interrupted()) {
while (!Thread.interrupted() && !_socket.isClosed()) {
try {
byte[] buf = new byte[10000];
DatagramPacket packet = new DatagramPacket(buf, buf.length);