Skip to content

Commit 6717a35

Browse files
committed
bug fixed :- dead data server not removed.
1 parent 68bdfa2 commit 6717a35

File tree

2 files changed

+9
-7
lines changed

2 files changed

+9
-7
lines changed

nbproject/private/private.xml

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,13 @@
33
<editor-bookmarks xmlns="http://www.netbeans.org/ns/editor-bookmarks/2" lastBookmarkId="0"/>
44
<open-files xmlns="http://www.netbeans.org/ns/projectui-open-files/2">
55
<group>
6-
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/lib/dT/problemManipulate/ProgramDetail.java</file>
7-
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/programtester/ProgramTester.java</file>
6+
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/SerDetails.java</file>
87
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainLogFlowTest.java</file>
98
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainDataFlowTest.java</file>
109
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/programtester/config/Configurator.java</file>
1110
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/lib/ui/gui/QuestionPage.java</file>
1211
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainSerFlowTest.java</file>
1312
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/userStatus/UserStatus.java</file>
14-
<file>file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/userStatus/IntUserStatus.java</file>
1513
</group>
1614
</open-files>
1715
</project-private>

src/net/mainSer/SerDetails.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,11 @@
77

88
import java.rmi.Naming;
99
import java.rmi.RemoteException;
10+
import java.util.Collections;
11+
import java.util.HashMap;
1012
import java.util.HashSet;
1113
import java.util.Map;
1214
import java.util.Set;
13-
import java.util.concurrent.ConcurrentHashMap;
14-
import java.util.logging.Level;
15-
import java.util.logging.Logger;
1615
import net.dataSer.IntDataSer;
1716
import net.logSer.IntRemoteLog;
1817

@@ -24,7 +23,8 @@ public class SerDetails {
2423
private SerDetails(){}
2524
private static IntRemoteLog log;
2625
private static IntDataSer mainDataSer;
27-
private final static Map<IntDataSer,Long> dataSer=new ConcurrentHashMap<>();
26+
private final static Map<IntDataSer,Long> dataSer=
27+
Collections.synchronizedMap(new HashMap<>());
2828

2929
/**
3030
*
@@ -72,13 +72,17 @@ private synchronized static String findDataSer(){
7272
}).orElse(mainDataSer);
7373
try {
7474
if(d.aya()){
75+
IntDataSer d1=(IntDataSer)Naming.lookup(d.toUrl());
7576
dataSer.replace(d,System.currentTimeMillis());
77+
System.out.println("c2");
7678
return d.toUrl();
7779
}else{
80+
System.out.println("c3");
7881
assert true:"remote data Server say 'not alive'";
7982
return null;
8083
}
8184
} catch (Exception ex) {
85+
System.out.println("c4");
8286
dataSer.remove(d);
8387
return null;
8488
}

0 commit comments

Comments
 (0)