Skip to content

Commit

Permalink
minor formatting fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
chenson42 committed Sep 19, 2017
1 parent 32023dd commit 3fdf40d
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
Expand Up @@ -380,14 +380,14 @@ protected void init() {

String updateServiceClassName = properties.get(ParameterConstants.UPDATE_SERVICE_CLASS);
if (updateServiceClassName == null) {
this.updateService = new UpdateService(this);
this.updateService = new UpdateService(this);
} else {
try {
Constructor<?> cons = Class.forName(updateServiceClassName).getConstructor(ISymmetricEngine.class);
this.updateService = (IUpdateService) cons.newInstance(this);
} catch (Exception e) {
throw new RuntimeException(e);
}
try {
Constructor<?> cons = Class.forName(updateServiceClassName).getConstructor(ISymmetricEngine.class);
this.updateService = (IUpdateService) cons.newInstance(this);
} catch (Exception e) {
throw new RuntimeException(e);
}
}

if (parameterService.isRegistrationServer()) {
Expand Down
Expand Up @@ -129,7 +129,7 @@ public void pull(String nodeId, String remoteHost, String remoteAddress,
Node targetNode = nodeService.findNode(nodeId, true);
List<OutgoingBatch> batchList = dataExtractorService.extract(processInfo, targetNode,
map.getThreadChannel(), outgoingTransport);
logDataReceivedFromPush(targetNode, batchList, processInfo, remoteHost);
logDataReceivedFromPull(targetNode, batchList, processInfo, remoteHost);

if (processInfo.getStatus() != ProcessStatus.ERROR) {
addPendingBatchCounts(targetNode.getNodeId(), res);
Expand Down Expand Up @@ -161,7 +161,7 @@ private void addPendingBatchCounts(String targetNodeId, HttpServletResponse res)
}
}

private void logDataReceivedFromPush(Node targetNode, List<OutgoingBatch> batchList, ProcessInfo processInfo, String remoteHost) {
private void logDataReceivedFromPull(Node targetNode, List<OutgoingBatch> batchList, ProcessInfo processInfo, String remoteHost) {
int batchesCount = 0;
int dataCount = 0;
for (OutgoingBatch outgoingBatch : batchList) {
Expand Down

0 comments on commit 3fdf40d

Please sign in to comment.