Committed by
Gerrit Code Review
Removed dead code + Dropped log level down to debug to reduce verbosity
Change-Id: I565775261a63b391011e1b341903390a9f26b6a6
Showing
2 changed files
with
2 additions
and
16 deletions
... | @@ -31,7 +31,6 @@ import net.kuujo.copycat.cluster.internal.coordinator.DefaultClusterCoordinator; | ... | @@ -31,7 +31,6 @@ import net.kuujo.copycat.cluster.internal.coordinator.DefaultClusterCoordinator; |
31 | import net.kuujo.copycat.log.BufferedLog; | 31 | import net.kuujo.copycat.log.BufferedLog; |
32 | import net.kuujo.copycat.log.FileLog; | 32 | import net.kuujo.copycat.log.FileLog; |
33 | import net.kuujo.copycat.log.Log; | 33 | import net.kuujo.copycat.log.Log; |
34 | -import net.kuujo.copycat.netty.NettyTcpProtocol; | ||
35 | import net.kuujo.copycat.protocol.Consistency; | 34 | import net.kuujo.copycat.protocol.Consistency; |
36 | import net.kuujo.copycat.protocol.Protocol; | 35 | import net.kuujo.copycat.protocol.Protocol; |
37 | import net.kuujo.copycat.util.concurrent.NamedThreadFactory; | 36 | import net.kuujo.copycat.util.concurrent.NamedThreadFactory; |
... | @@ -233,19 +232,6 @@ public class DatabaseManager implements StorageService, StorageAdminService { | ... | @@ -233,19 +232,6 @@ public class DatabaseManager implements StorageService, StorageAdminService { |
233 | .collect(Collectors.toList()); | 232 | .collect(Collectors.toList()); |
234 | } | 233 | } |
235 | 234 | ||
236 | - @SuppressWarnings("unused") | ||
237 | - private Protocol newNettyProtocol() { | ||
238 | - return new NettyTcpProtocol() | ||
239 | - .withSsl(false) | ||
240 | - .withConnectTimeout(60000) | ||
241 | - .withAcceptBacklog(1024) | ||
242 | - .withTrafficClass(-1) | ||
243 | - .withSoLinger(-1) | ||
244 | - .withReceiveBufferSize(32768) | ||
245 | - .withSendBufferSize(8192) | ||
246 | - .withThreads(1); | ||
247 | - } | ||
248 | - | ||
249 | private Log newPersistentLog() { | 235 | private Log newPersistentLog() { |
250 | String logDir = System.getProperty("karaf.data", "./data"); | 236 | String logDir = System.getProperty("karaf.data", "./data"); |
251 | return new FileLog() | 237 | return new FileLog() | ... | ... |
... | @@ -158,7 +158,7 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr | ... | @@ -158,7 +158,7 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr |
158 | 158 | ||
159 | @Override | 159 | @Override |
160 | public void triggerProbe(DeviceId deviceId) { | 160 | public void triggerProbe(DeviceId deviceId) { |
161 | - LOG.info("Triggering probe on device {}", deviceId); | 161 | + LOG.debug("Triggering probe on device {}", deviceId); |
162 | 162 | ||
163 | final Dpid dpid = dpid(deviceId.uri()); | 163 | final Dpid dpid = dpid(deviceId.uri()); |
164 | OpenFlowSwitch sw = controller.getSwitch(dpid); | 164 | OpenFlowSwitch sw = controller.getSwitch(dpid); |
... | @@ -199,7 +199,7 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr | ... | @@ -199,7 +199,7 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr |
199 | LOG.error("Unknown Mastership state : {}", newRole); | 199 | LOG.error("Unknown Mastership state : {}", newRole); |
200 | 200 | ||
201 | } | 201 | } |
202 | - LOG.info("Accepting mastership role change for device {}", deviceId); | 202 | + LOG.debug("Accepting mastership role change for device {}", deviceId); |
203 | } | 203 | } |
204 | 204 | ||
205 | private void pushPortMetrics(Dpid dpid, List<OFPortStatsEntry> portStatsEntries) { | 205 | private void pushPortMetrics(Dpid dpid, List<OFPortStatsEntry> portStatsEntries) { | ... | ... |
-
Please register or login to post a comment