Skip to content

Commit 563c87d

Browse files
author
chengyitian
committed
AJ-567: delete no use code for coverage;
1 parent 3b9a832 commit 563c87d

File tree

2 files changed

+0
-37
lines changed

2 files changed

+0
-37
lines changed

src/com/xxdb/DBConnection.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,10 +58,6 @@ public class DBConnection {
5858

5959
private static final Logger log = LoggerFactory.getLogger(DBConnection.class);
6060

61-
private enum ServerExceptionState {
62-
NEW_LEADER, WAIT, CONN_FAIL, OTHER_EXCEPTION, DATA_NODE_NOT_AVAILABLE
63-
}
64-
6561
private enum ExceptionType{
6662
ET_IGNORE(0),
6763
ET_UNKNOW(1),

src/com/xxdb/streaming/client/TopicManager.java

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -142,39 +142,6 @@ public AbstractClient.Site[] getSites() {
142142
}
143143
}
144144

145-
146-
private class SiteInfo {
147-
ConcurrentHashMap<String, TopicInfo> topicQueue;
148-
private int reconnectStat;
149-
150-
public SiteInfo() {
151-
topicQueue = new ConcurrentHashMap<>();
152-
reconnectStat = 0;
153-
}
154-
155-
public void addTopic(String topic) {
156-
if (!topicQueue.containsKey(topic)) {
157-
topicQueue.put(topic, new TopicInfo(topic));
158-
}
159-
}
160-
161-
public TopicInfo getTopic(String topic) {
162-
if (topicQueue.containsKey(topic))
163-
return topicQueue.get(topic);
164-
else
165-
return null;
166-
}
167-
168-
public int getReconnectStat() {
169-
return this.reconnectStat;
170-
}
171-
172-
public void setReconnectStat(int state) {
173-
this.reconnectStat = state;
174-
}
175-
}
176-
177-
178145
public static class Utils {
179146
public static String getSiteFromTopic(String topic) {
180147
String site = topic.substring(0, topic.indexOf("/"));

0 commit comments

Comments
 (0)