* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
package org.onap.appc.ccadaptor;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.sun.jersey.api.client.Client;
+import com.sun.jersey.api.client.ClientResponse;
+import com.sun.jersey.api.client.WebResource;
+import com.sun.jersey.core.util.Base64;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
+import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
-import java.io.FileReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.util.HashMap;
import java.util.Map;
+import java.util.NoSuchElementException;
import java.util.Properties;
import java.util.StringTokenizer;
-import java.util.NoSuchElementException;
import org.onap.ccsdk.sli.core.sli.SvcLogicAdaptor;
import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-import com.sun.jersey.api.client.WebResource;
-import com.sun.jersey.core.util.Base64;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-public class ConfigComponentAdaptor implements SvcLogicAdaptor
-{
+public class ConfigComponentAdaptor implements SvcLogicAdaptor {
private static final EELFLogger log = EELFManager.getInstance().getLogger(ConfigComponentAdaptor.class);
-
+ DebugLog debugLog = new DebugLog();
private String configUrl = null;
private String configUser = null;
private String configPassword = null;
private String auditPassword = null;
private String configCallbackUrl = null;
private String auditCallbackUrl = null;
- DebugLog debugLog = new DebugLog();
- public ConfigComponentAdaptor(Properties props)
- {
- if (props != null)
- {
+ public ConfigComponentAdaptor(Properties props) {
+ if (props != null) {
configUrl = props.getProperty("configComponent.url", "");
configUser = props.getProperty("configComponent.user", "");
configPassword = props.getProperty("configComponent.passwd", "");
auditPassword = props.getProperty("auditComponent.passwd", "");
configCallbackUrl = props.getProperty("service-configuration-notification-url", "");
auditCallbackUrl = props.getProperty("audit-configuration-notification-url", "");
- }
- else
- {
+ } else {
configUrl = "";
configUser = "";
configPassword = "";
}
@Override
- public ConfigStatus configure(String key, Map<String, String> parameters, SvcLogicContext ctx)
- {
+ public ConfigStatus configure(String key, Map<String, String> parameters, SvcLogicContext ctx) {
String fnName = "ConfigComponentAdaptor.configure";
HttpResponse r = new HttpResponse();
r.code = 200;
debugLog.printRTAriDebug(fnName, "key = " + key);
log.debug("Parameters:");
debugLog.printRTAriDebug(fnName, "Parameters:");
- for (String parmName : parameters.keySet())
- {
+ for (String parmName : parameters.keySet()) {
log.debug(" " + parmName + " = " + parameters.get(parmName));
debugLog.printRTAriDebug(fnName, " " + parmName + " = " + parameters.get(parmName));
}
String parmval = parameters.get("config-component-configUrl");
- if ((parmval != null) && (parmval.length() > 0))
- {
+ if ((parmval != null) && (parmval.length() > 0)) {
log.debug("Overwriting URL with " + parmval);
configUrl = parmval;
}
parmval = parameters.get("config-component-configPassword");
- if ((parmval != null) && (parmval.length() > 0))
- {
+ if ((parmval != null) && (parmval.length() > 0)) {
log.debug("Overwriting configPassword with " + parmval);
configPassword = parmval;
}
parmval = parameters.get("config-component-configUser");
- if ((parmval != null) && (parmval.length() > 0))
- {
+ if ((parmval != null) && (parmval.length() > 0)) {
log.debug("Overwriting configUser id with " + parmval);
configUser = parmval;
}
String action = parameters.get("action");
String chg = ctx.getAttribute(
- "service-data.vnf-config-parameters-list.vnf-config-parameters[0].update-configuration[0].block-key-name");
- if (chg != null && "prepare".equalsIgnoreCase(action))
+ "service-data.vnf-config-parameters-list.vnf-config-parameters[0].update-configuration[0].block-key-name");
+ if (chg != null && "prepare".equalsIgnoreCase(action)) {
return prepare(ctx, "CHANGE", "change");
- if (chg != null && "activate".equalsIgnoreCase(action))
+ }
+ if (chg != null && "activate".equalsIgnoreCase(action)) {
return activate(ctx, true);
+ }
String scale = ctx.getAttribute(
- "service-data.vnf-config-parameters-list.vnf-config-parameters[0].scale-configuration[0].network-type");
- if (scale != null && "prepare".equalsIgnoreCase(action))
+ "service-data.vnf-config-parameters-list.vnf-config-parameters[0].scale-configuration[0].network-type");
+ if (scale != null && "prepare".equalsIgnoreCase(action)) {
return prepare(ctx, "CHANGE", "scale");
- if (scale != null && "activate".equalsIgnoreCase(action))
+ }
+ if (scale != null && "activate".equalsIgnoreCase(action)) {
return activate(ctx, true);
+ }
- if ("prepare".equalsIgnoreCase(action))
+ if ("prepare".equalsIgnoreCase(action)) {
return prepare(ctx, "BASE", "create");
- if ("activate".equalsIgnoreCase(action))
+ }
+ if ("activate".equalsIgnoreCase(action)) {
return activate(ctx, false);
+ }
- if ("backup".equalsIgnoreCase(action))
+ if ("backup".equalsIgnoreCase(action)) {
return prepare(ctx, "BACKUP", "backup");
- if ("restorebackup".equalsIgnoreCase(action))
+ }
+ if ("restorebackup".equalsIgnoreCase(action)) {
return prepare(ctx, "RESTOREBACKUP", "restorebackup");
- if ("deletebackup".equalsIgnoreCase(action))
+ }
+ if ("deletebackup".equalsIgnoreCase(action)) {
return prepare(ctx, "DELETEBACKUP", "deletebackup");
- if ("audit".equalsIgnoreCase(action))
+ }
+ if ("audit".equalsIgnoreCase(action)) {
return audit(ctx, "FULL");
- if ("getrunningconfig".equalsIgnoreCase(action))
+ }
+ if ("getrunningconfig".equalsIgnoreCase(action)) {
return audit(ctx, "RUNNING");
+ }
- if ((key.equals("put")) || (key.equals("get")))
- {
+ if ((key.equals("put")) || (key.equals("get"))) {
String loginId = parameters.get("loginId");
String host = parameters.get("host");
String password = parameters.get("password");
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
log.debug("SCP: SshJcraftWrapper has been instantiated");
debugLog.printRTAriDebug(fnName, "SCP: SshJcraftWrapper has been instantiated");
- try
- {
- if (key.equals("put"))
- {
+ try {
+ if (key.equals("put")) {
data = parameters.get("data");
if (data != null) {
debugLog.printRTAriDebug(fnName, "Command is for put: Length of data is: " + data.length());
log.debug("SCP: Doing a put: fullPathFileName=" + fullPathFileName);
debugLog.printRTAriDebug(fnName, "SCP: Doing a put: fullPathFileName=" + fullPathFileName);
sshJcraftWrapper.put(is, fullPathFileName, host, loginId, password);
- try
- {
+ try {
debugLog.printRTAriDebug(fnName, "Sleeping for 180 seconds....");
Thread.sleep(1000 * 180);
debugLog.printRTAriDebug(fnName, "Woke up....");
- }
- catch (java.lang.InterruptedException ee)
- {
+ } catch (java.lang.InterruptedException ee) {
boolean ignore = true;
}
} else {
- r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
+ r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
log.debug(fnName + " Command is for put: data is null");
- }
- }
- else // Must be a get
+ }
+ } else // Must be a get
{
log.debug("SCP: Doing a get: fullPathFileName=" + fullPathFileName);
debugLog.printRTAriDebug(fnName, "SCP: Doing a get: fullPathFileName=" + fullPathFileName);
}
sshJcraftWrapper = null;
return (setResponseStatus(ctx, r));
- }
- catch (IOException e)
- {
+ } catch (IOException e) {
DebugLog.printAriDebug(fnName, "Caught a IOException e=" + e);
log.debug(fnName + " : Caught a IOException e=" + e);
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
return (setResponseStatus(ctx, r));
}
}
- if (key.equals("cli"))
- {
+ if (key.equals("cli")) {
String loginId = parameters.get("loginId");
String host = parameters.get("host");
String password = parameters.get("password");
String cliCommand = parameters.get("cli");
String portNumber = parameters.get("portNumber");
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
- try
- {
+ try {
log.debug("CLI: Attempting to login: host=" + host + " loginId=" + loginId + " password=" + password +
- " portNumber=" + portNumber);
+ " portNumber=" + portNumber);
debugLog.printRTAriDebug(fnName, "CLI: Attempting to login: host=" + host + " loginId=" + loginId +
- " password=" + password + " portNumber=" + portNumber);
+ " password=" + password + " portNumber=" + portNumber);
sshJcraftWrapper.connect(host, loginId, password, Integer.parseInt(portNumber));
DebugLog.printAriDebug(fnName, "Sending 'sdc'");
r.code = 200;
sshJcraftWrapper = null;
return (setResponseStatus(ctx, r));
- }
- catch (IOException e)
- {
+ } catch (IOException e) {
DebugLog.printAriDebug(fnName, "Caught a IOException e=" + e);
log.debug(fnName + " : Caught a IOException e=" + e);
sshJcraftWrapper.closeConnection();
return (setResponseStatus(ctx, r));
}
}
- if (key.equals("escapeSql"))
- {
+ if (key.equals("escapeSql")) {
String data = parameters.get("artifactContents");
log.debug("ConfigComponentAdaptor.configure - escapeSql");
data = escapeMySql(data);
ctx.setAttribute("escapedData", data);
return (setResponseStatus(ctx, r));
}
- if(key.equals("GetCliRunningConfig"))
- {
- debugLog.printRTAriDebug (fnName, "key was: GetCliRunningConfig: ");
+ if (key.equals("GetCliRunningConfig")) {
+ debugLog.printRTAriDebug(fnName, "key was: GetCliRunningConfig: ");
log.debug("key was: GetCliRunningConfig: ");
String User_name = parameters.get("User_name");
String Host_ip_address = parameters.get("Host_ip_address");
String Get_config_template = parameters.get("Get_config_template");
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
log.debug("GetCliRunningConfig: sshJcraftWrapper was instantiated");
- debugLog.printRTAriDebug (fnName, "GetCliRunningConfig: sshJcraftWrapper was instantiated");
- try
- {
- DebugLog.printAriDebug(fnName, "GetCliRunningConfig: User_name="+User_name +
- " Host_ip_address="+Host_ip_address +" Password="+Password +" Port_number="+Port_number);
- log.debug("GetCliRunningConfig: Attempting to login: Host_ip_address="+Host_ip_address +
- " User_name="+User_name+" Password="+Password+" Port_number="+Port_number);
+ debugLog.printRTAriDebug(fnName, "GetCliRunningConfig: sshJcraftWrapper was instantiated");
+ try {
+ DebugLog.printAriDebug(fnName, "GetCliRunningConfig: User_name=" + User_name +
+ " Host_ip_address=" + Host_ip_address + " Password=" + Password + " Port_number="
+ + Port_number);
+ log.debug("GetCliRunningConfig: Attempting to login: Host_ip_address=" + Host_ip_address +
+ " User_name=" + User_name + " Password=" + Password + " Port_number=" + Port_number);
StringBuffer sb = new StringBuffer();
String response = "";
String CliResponse = "";
boolean showConfigFlag = false;
- sshJcraftWrapper.connect (Host_ip_address, User_name, Password, "", 30000, Integer.parseInt(Port_number));
+ sshJcraftWrapper.connect(Host_ip_address,
+ User_name,
+ Password,
+ "",
+ 30000,
+ Integer.parseInt(Port_number));
DebugLog.printAriDebug(fnName, "GetCliRunningConfig: On the VNF device");
StringTokenizer st = new StringTokenizer(Get_config_template, "\n");
String command = null;
- try
- {
- while (st.hasMoreTokens())
- {
+ try {
+ while (st.hasMoreTokens()) {
String line = st.nextToken();
- DebugLog.printAriDebug(fnName, "line="+line);
- if (line.indexOf("Request:") != -1)
- {
- DebugLog.printAriDebug(fnName, "Found a Request line: line="+line);
+ DebugLog.printAriDebug(fnName, "line=" + line);
+ if (line.indexOf("Request:") != -1) {
+ DebugLog.printAriDebug(fnName, "Found a Request line: line=" + line);
command = getStringBetweenQuotes(line);
- DebugLog.printAriDebug(fnName, "Sending command="+command);
+ DebugLog.printAriDebug(fnName, "Sending command=" + command);
sshJcraftWrapper.send(command);
DebugLog.printAriDebug(fnName, "command has been sent");
- if (line.indexOf("show config") != -1)
- {
+ if (line.indexOf("show config") != -1) {
showConfigFlag = true;
DebugLog.printAriDebug(fnName, "GetCliRunningConfig: setting 'showConfigFlag' to true");
log.debug("GetCliRunningConfig: GetCliRunningConfig: setting 'showConfigFlag' to true");
}
}
- if (line.indexOf("Response: Ends_With") != -1)
- {
- DebugLog.printAriDebug(fnName, "Found a Response line: line="+line);
+ if (line.indexOf("Response: Ends_With") != -1) {
+ DebugLog.printAriDebug(fnName, "Found a Response line: line=" + line);
String delemeter = getStringBetweenQuotes(line);
- DebugLog.printAriDebug(fnName, "The delemeter="+delemeter);
- String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter, 30*1000, command);
+ DebugLog.printAriDebug(fnName, "The delemeter=" + delemeter);
+ String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter, 30 * 1000, command);
response += tmpResponse;
- if (showConfigFlag)
- {
+ if (showConfigFlag) {
showConfigFlag = false;
StringTokenizer st2 = new StringTokenizer(tmpResponse, "\n");
// Strip off the last line which is the command prompt from the VNF device.
- while (st2.hasMoreTokens())
- {
+ while (st2.hasMoreTokens()) {
String line2 = st2.nextToken();
- if (line2.indexOf("#") == -1)
- CliResponse += line2 +"\n";
+ if (line2.indexOf("#") == -1) {
+ CliResponse += line2 + "\n";
+ }
}
}
}
}
+ } catch (NoSuchElementException e) {
+ DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e=" + e);
}
- catch (NoSuchElementException e)
- {
- DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e="+e);
- }
- DebugLog.printAriDebug(fnName, "CliResponse=\n"+CliResponse);
+ DebugLog.printAriDebug(fnName, "CliResponse=\n" + CliResponse);
ctx.setAttribute("cliOutput", CliResponse);
sshJcraftWrapper.closeConnection();
r.code = 200;
sshJcraftWrapper = null;
- return(setResponseStatus(ctx, r));
- }
- catch(IOException e)
- {
- DebugLog.printAriDebug(fnName, "GetCliRunningConfig: Caught a IOException e="+e);
- log.debug(fnName +" : GetCliRunningConfig: Caught a IOException e="+e);
+ return (setResponseStatus(ctx, r));
+ } catch (IOException e) {
+ DebugLog.printAriDebug(fnName, "GetCliRunningConfig: Caught a IOException e=" + e);
+ log.debug(fnName + " : GetCliRunningConfig: Caught a IOException e=" + e);
sshJcraftWrapper.closeConnection();
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = e.getMessage();
sshJcraftWrapper = null;
DebugLog.printAriDebug(fnName, "GetCliRunningConfig: Returning error message");
- return(setResponseStatus(ctx, r));
+ return (setResponseStatus(ctx, r));
}
}
- if(key.equals("xml-download"))
- {
+ if (key.equals("xml-download")) {
log(fnName, "key was: xml-download");
String User_name = parameters.get("User_name");
String Host_ip_address = parameters.get("Host_ip_address");
String terminateConnectionCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <rpc message-id=\"terminateConnection\" xmlns:netconf=\"urn:ietf:params:xml:ns:netconf:base:1.0\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n <close-session/> \n </rpc>\n ]]>]]>";
String commitCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <rpc> <commit/> </rpc>\n ]]>]]>";
- log(fnName, "xml-download: User_name="+User_name +" Host_ip_address="+Host_ip_address +" Password="+Password +" Port_number="+Port_number);
+ log(fnName,
+ "xml-download: User_name=" + User_name + " Host_ip_address=" + Host_ip_address + " Password=" + Password
+ + " Port_number=" + Port_number);
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
- try
- {
- sshJcraftWrapper.connect (Host_ip_address, User_name, Password, "]]>]]>", 30000, Integer.parseInt(Port_number), "netconf");
+ try {
+ sshJcraftWrapper.connect(Host_ip_address,
+ User_name,
+ Password,
+ "]]>]]>",
+ 30000,
+ Integer.parseInt(Port_number),
+ "netconf");
String NetconfHelloCmd = netconfHelloCmd;
- NetconfHelloCmd = NetconfHelloCmd +"]]>]]>";
+ NetconfHelloCmd = NetconfHelloCmd + "]]>]]>";
log(fnName, "Sending the hello command");
sshJcraftWrapper.send(NetconfHelloCmd);
String response = sshJcraftWrapper.receiveUntil("]]>]]>", 10000, "");
log(fnName, "Sending xmlCmd cmd");
String xmlCmd = Contents;
String messageId = "1";
- messageId= "\"" +messageId+"\"";
- String loadConfigurationString = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id="+messageId+"> <edit-config> <target> <candidate /> </target> <default-operation>merge</default-operation> <config xmlns:xc=\"urn:ietf:params:xml:ns:netconf:base:1.0\">"+xmlCmd+"</config> </edit-config> </rpc>";
- loadConfigurationString = loadConfigurationString +"]]>]]>";
+ messageId = "\"" + messageId + "\"";
+ String loadConfigurationString =
+ "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id="
+ + messageId
+ + "> <edit-config> <target> <candidate /> </target> <default-operation>merge</default-operation> <config xmlns:xc=\"urn:ietf:params:xml:ns:netconf:base:1.0\">"
+ + xmlCmd + "</config> </edit-config> </rpc>";
+ loadConfigurationString = loadConfigurationString + "]]>]]>";
sshJcraftWrapper.send(loadConfigurationString);
- DebugLog.printAriDebug(fnName,":After sending loadConfigurationString");
+ DebugLog.printAriDebug(fnName, ":After sending loadConfigurationString");
response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 600000, "");
- if (response.indexOf("rpc-error") != -1)
- {
- DebugLog.printAriDebug(fnName,"Error from device: Response from device had 'rpc-error'");
- DebugLog.printAriDebug(fnName,"response=\n"+response +"\n");
+ if (response.indexOf("rpc-error") != -1) {
+ DebugLog.printAriDebug(fnName, "Error from device: Response from device had 'rpc-error'");
+ DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = response;
- }
- else
- {
- DebugLog.printAriDebug(fnName,":LoadConfiguration was a success, sending commit cmd");
+ } else {
+ DebugLog.printAriDebug(fnName, ":LoadConfiguration was a success, sending commit cmd");
sshJcraftWrapper.send(commitCmd);
- DebugLog.printAriDebug(fnName,":After sending commitCmd");
+ DebugLog.printAriDebug(fnName, ":After sending commitCmd");
response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 180000, "");
- if (response.indexOf("rpc-error") != -1)
- {
- DebugLog.printAriDebug(fnName,"Error from device: Response from device had 'rpc-error'");
- DebugLog.printAriDebug(fnName,"response=\n"+response +"\n");
+ if (response.indexOf("rpc-error") != -1) {
+ DebugLog.printAriDebug(fnName, "Error from device: Response from device had 'rpc-error'");
+ DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = response;
- }
- else
- {
- DebugLog.printAriDebug(fnName,":Looks like a success");
- DebugLog.printAriDebug(fnName,"response=\n"+response +"\n");
+ } else {
+ DebugLog.printAriDebug(fnName, ":Looks like a success");
+ DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
r.code = 200;
}
}
sshJcraftWrapper.send(terminateConnectionCmd);
sshJcraftWrapper.closeConnection();
sshJcraftWrapper = null;
- return(setResponseStatus(ctx, r));
- }
- catch (Exception e)
- {
- log(fnName, "Caught an Exception, e="+e);
- log(fnName, "StackTrace="+DebugLog.getStackTraceString(e));
+ return (setResponseStatus(ctx, r));
+ } catch (Exception e) {
+ log(fnName, "Caught an Exception, e=" + e);
+ log(fnName, "StackTrace=" + DebugLog.getStackTraceString(e));
sshJcraftWrapper.closeConnection();
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = e.getMessage();
return (setResponseStatus(ctx, r));
}
}
- if(key.equals("xml-getrunningconfig"))
- {
+ if (key.equals("xml-getrunningconfig")) {
log(fnName, "key was: : xml-getrunningconfig");
String xmlGetRunningConfigCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id=\"1\"> <get-config> <source> <running /> </source> </get-config> </rpc>\n";
String Host_ip_address = parameters.get("Host_ip_address");
String Protocol = parameters.get("Protocol");
String netconfHelloCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <hello xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n <capabilities>\n <capability>urn:ietf:params:netconf:base:1.0</capability>\n <capability>urn:com:ericsson:ebase:1.1.0</capability> </capabilities>\n </hello>";
String terminateConnectionCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <rpc message-id=\"terminateConnection\" xmlns:netconf=\"urn:ietf:params:xml:ns:netconf:base:1.0\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n <close-session/> \n </rpc>\n ]]>]]>";
- log(fnName, "xml-getrunningconfig: User_name="+User_name +" Host_ip_address="+Host_ip_address +" Password="+Password +" Port_number="+Port_number);
+ log(fnName,
+ "xml-getrunningconfig: User_name=" + User_name + " Host_ip_address=" + Host_ip_address + " Password="
+ + Password + " Port_number=" + Port_number);
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
- try
- {
+ try {
String NetconfHelloCmd = netconfHelloCmd;
- sshJcraftWrapper.connect (Host_ip_address, User_name, Password, "]]>]]>", 30000, Integer.parseInt(Port_number), "netconf");
- NetconfHelloCmd = NetconfHelloCmd +"]]>]]>";
+ sshJcraftWrapper.connect(Host_ip_address,
+ User_name,
+ Password,
+ "]]>]]>",
+ 30000,
+ Integer.parseInt(Port_number),
+ "netconf");
+ NetconfHelloCmd = NetconfHelloCmd + "]]>]]>";
log(fnName, ":Sending the hello command");
sshJcraftWrapper.send(NetconfHelloCmd);
String response = sshJcraftWrapper.receiveUntil("]]>]]>", 10000, "");
log(fnName, "Sending get running config command");
- sshJcraftWrapper.send(xmlGetRunningConfigCmd +"]]>]]>\n");
+ sshJcraftWrapper.send(xmlGetRunningConfigCmd + "]]>]]>\n");
response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 180000, "");
- DebugLog.printAriDebug(fnName,"Response from getRunningconfigCmd="+response);
+ DebugLog.printAriDebug(fnName, "Response from getRunningconfigCmd=" + response);
response = trimResponse(response);
ctx.setAttribute("xmlRunningConfigOutput", response);
sshJcraftWrapper.send(terminateConnectionCmd);
sshJcraftWrapper.closeConnection();
r.code = 200;
sshJcraftWrapper = null;
- return(setResponseStatus(ctx, r));
- }
- catch (Exception e)
- {
- log(fnName, "Caught an Exception, e="+e);
- log(fnName, "StackTrace="+DebugLog.getStackTraceString(e));
+ return (setResponseStatus(ctx, r));
+ } catch (Exception e) {
+ log(fnName, "Caught an Exception, e=" + e);
+ log(fnName, "StackTrace=" + DebugLog.getStackTraceString(e));
sshJcraftWrapper.closeConnection();
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = e.getMessage();
return (setResponseStatus(ctx, r));
}
}
- if(key.equals("DownloadCliConfig"))
- {
- debugLog.printRTAriDebug (fnName, "key was: DownloadCliConfig: ");
+ if (key.equals("DownloadCliConfig")) {
+ debugLog.printRTAriDebug(fnName, "key was: DownloadCliConfig: ");
log.debug("key was: DownloadCliConfig: ");
String User_name = parameters.get("User_name");
String Host_ip_address = parameters.get("Host_ip_address");
String Port_number = parameters.get("Port_number");
String Download_config_template = parameters.get("Download_config_template");
String Config_contents = parameters.get("Config_contents");
- DebugLog.printAriDebug(fnName, "Contents of the 'Config_contents' are: "+Config_contents);
+ DebugLog.printAriDebug(fnName, "Contents of the 'Config_contents' are: " + Config_contents);
SshJcraftWrapper sshJcraftWrapper = new SshJcraftWrapper();
log.debug("DownloadCliConfig: sshJcraftWrapper was instantiated");
- debugLog.printRTAriDebug (fnName, "DownloadCliConfig: sshJcraftWrapper was instantiated");
- int timeout = 4*60*1000;
- try
- {
- DebugLog.printAriDebug(fnName, "DownloadCliConfig: User_name="+User_name +
- " Host_ip_address="+Host_ip_address +" Password="+Password +" Port_number="+Port_number);
- log.debug("DownloadCliConfig: Attempting to login: Host_ip_address="+Host_ip_address +
- " User_name="+User_name+" Password="+Password+" Port_number="+Port_number);
+ debugLog.printRTAriDebug(fnName, "DownloadCliConfig: sshJcraftWrapper was instantiated");
+ int timeout = 4 * 60 * 1000;
+ try {
+ DebugLog.printAriDebug(fnName, "DownloadCliConfig: User_name=" + User_name +
+ " Host_ip_address=" + Host_ip_address + " Password=" + Password + " Port_number="
+ + Port_number);
+ log.debug("DownloadCliConfig: Attempting to login: Host_ip_address=" + Host_ip_address +
+ " User_name=" + User_name + " Password=" + Password + " Port_number=" + Port_number);
StringBuffer sb = new StringBuffer();
String response = "";
String CliResponse = "";
- sshJcraftWrapper.connect (Host_ip_address, User_name, Password, "", 30000, Integer.parseInt(Port_number));
+ sshJcraftWrapper.connect(Host_ip_address,
+ User_name,
+ Password,
+ "",
+ 30000,
+ Integer.parseInt(Port_number));
DebugLog.printAriDebug(fnName, "DownloadCliConfig: On the VNF device");
StringTokenizer st = new StringTokenizer(Download_config_template, "\n");
String command = null;
String executeConfigContentsDelemeter = null;
- try
- {
- while (st.hasMoreTokens())
- {
+ try {
+ while (st.hasMoreTokens()) {
String line = st.nextToken();
- DebugLog.printAriDebug(fnName, "line="+line);
- if (line.indexOf("Request:") != -1)
- {
- DebugLog.printAriDebug(fnName, "Found a Request line: line="+line);
+ DebugLog.printAriDebug(fnName, "line=" + line);
+ if (line.indexOf("Request:") != -1) {
+ DebugLog.printAriDebug(fnName, "Found a Request line: line=" + line);
command = getStringBetweenQuotes(line);
- DebugLog.printAriDebug(fnName, "Sending command="+command);
+ DebugLog.printAriDebug(fnName, "Sending command=" + command);
sshJcraftWrapper.send(command);
DebugLog.printAriDebug(fnName, "command has been sent");
- }
- else if ((line.indexOf("Response: Ends_With") != -1) && (line.indexOf("Execute_config_contents Response: Ends_With") == -1))
- {
- DebugLog.printAriDebug(fnName, "Found a Response line: line="+line);
+ } else if ((line.indexOf("Response: Ends_With") != -1) && (
+ line.indexOf("Execute_config_contents Response: Ends_With") == -1)) {
+ DebugLog.printAriDebug(fnName, "Found a Response line: line=" + line);
String delemeter = getStringBetweenQuotes(line);
- DebugLog.printAriDebug(fnName, "The delemeter="+delemeter);
- String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter, timeout, command);
+ DebugLog.printAriDebug(fnName, "The delemeter=" + delemeter);
+ String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter, timeout, command);
response += tmpResponse;
CliResponse += tmpResponse;
- }
- else if (line.indexOf("Execute_config_contents Response: Ends_With") != -1)
- {
- DebugLog.printAriDebug(fnName, "Found a 'Execute_config_contents Response:' line="+line);
+ } else if (line.indexOf("Execute_config_contents Response: Ends_With") != -1) {
+ DebugLog.printAriDebug(fnName, "Found a 'Execute_config_contents Response:' line=" + line);
executeConfigContentsDelemeter = getStringBetweenQuotes(line);
- DebugLog.printAriDebug(fnName, "executeConfigContentsDelemeter="+executeConfigContentsDelemeter);
+ DebugLog.printAriDebug(fnName,
+ "executeConfigContentsDelemeter=" + executeConfigContentsDelemeter);
StringTokenizer st2 = new StringTokenizer(Config_contents, "\n");
- while (st2.hasMoreTokens())
- {
+ while (st2.hasMoreTokens()) {
String cmd = st2.nextToken();
- DebugLog.printAriDebug(fnName, "Config_contents: cmd="+cmd);
+ DebugLog.printAriDebug(fnName, "Config_contents: cmd=" + cmd);
sshJcraftWrapper.send(cmd);
- String tmpResponse = sshJcraftWrapper.receiveUntil(executeConfigContentsDelemeter, timeout, command);
+ String tmpResponse = sshJcraftWrapper.receiveUntil(executeConfigContentsDelemeter,
+ timeout,
+ command);
CliResponse += tmpResponse;
}
}
}
- }
- catch (NoSuchElementException e)
- {
- DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e="+e);
+ } catch (NoSuchElementException e) {
+ DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e=" + e);
}
sshJcraftWrapper.closeConnection();
sshJcraftWrapper = null;
DebugLog.printAriDebug(fnName, ":Escaping all the single and double quotes in the response");
CliResponse = CliResponse.replaceAll("\"", "\\\\\"");
CliResponse = CliResponse.replaceAll("\'", "\\\\'");
- DebugLog.printAriDebug(fnName, "CliResponse=\n"+CliResponse);
+ DebugLog.printAriDebug(fnName, "CliResponse=\n" + CliResponse);
ctx.setAttribute("cliOutput", CliResponse);
r.code = 200;
- return(setResponseStatus(ctx, r));
- }
- catch(IOException e)
- {
- DebugLog.printAriDebug(fnName, "DownloadCliConfig: Caught a IOException e="+e);
- log.debug(fnName +" : DownloadCliConfig: Caught a IOException e="+e);
+ return (setResponseStatus(ctx, r));
+ } catch (IOException e) {
+ DebugLog.printAriDebug(fnName, "DownloadCliConfig: Caught a IOException e=" + e);
+ log.debug(fnName + " : DownloadCliConfig: Caught a IOException e=" + e);
sshJcraftWrapper.closeConnection();
r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
r.message = e.getMessage();
sshJcraftWrapper = null;
DebugLog.printAriDebug(fnName, "DownloadCliConfig: Returning error message");
- return(setResponseStatus(ctx, r));
+ return (setResponseStatus(ctx, r));
}
}
- debugLog.printRTAriDebug (fnName, "Unsupported action - " + action);
+ debugLog.printRTAriDebug(fnName, "Unsupported action - " + action);
log.error("Unsupported action - " + action);
return ConfigStatus.FAILURE;
}
- private void log (String fileName, String messg)
- {
- debugLog.printRTAriDebug (fileName, messg);
- log.debug(fileName +": "+messg);
+ private void log(String fileName, String messg) {
+ debugLog.printRTAriDebug(fileName, messg);
+ log.debug(fileName + ": " + messg);
}
- private ConfigStatus prepare(SvcLogicContext ctx, String requestType, String operation)
- {
+ private ConfigStatus prepare(SvcLogicContext ctx, String requestType, String operation) {
String templateName = requestType.equals("BASE") ? "/config-base.xml" : "/config-data.xml";
String ndTemplate = readFile(templateName);
String nd = buildNetworkData2(ctx, ndTemplate, operation);
param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
param.put("request-type", requestType);
param.put("callback-url", configCallbackUrl);
- if (operation.equals("create") || operation.equals("change") || operation.equals("scale"))
+ if (operation.equals("create") || operation.equals("change") || operation.equals("scale")) {
param.put("action", "GenerateOnly");
+ }
param.put("equipment-name", ctx.getAttribute("service-data.service-information.service-instance-id"));
param.put("equipment-ip-address", ctx.getAttribute("service-data.vnf-config-information.vnf-host-ip-address"));
param.put("vendor", ctx.getAttribute("service-data.vnf-config-information.vendor"));
param.put("network-data", nd);
String req = null;
- try
- {
+ try {
req = buildXmlRequest(param, reqTemplate);
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.error("Error building the XML request: ", e);
HttpResponse r = new HttpResponse();
return setResponseStatus(ctx, r);
}
- private ConfigStatus activate(SvcLogicContext ctx, boolean change)
- {
+ private ConfigStatus activate(SvcLogicContext ctx, boolean change) {
String reqTemplate = readFile("/config-request.xml");
Map<String, String> param = new HashMap<String, String>();
param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
param.put("equipment-name", ctx.getAttribute("service-data.service-information.service-instance-id"));
String req = null;
- try
- {
+ try {
req = buildXmlRequest(param, reqTemplate);
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.error("Error building the XML request: ", e);
HttpResponse r = new HttpResponse();
return setResponseStatus(ctx, r);
}
- private ConfigStatus audit(SvcLogicContext ctx, String auditLevel)
- {
+ private ConfigStatus audit(SvcLogicContext ctx, String auditLevel) {
String reqTemplate = readFile("/audit-request.xml");
Map<String, String> param = new HashMap<String, String>();
param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
param.put("audit-level", auditLevel);
String req = null;
- try
- {
+ try {
req = buildXmlRequest(param, reqTemplate);
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.error("Error building the XML request: ", e);
HttpResponse r = new HttpResponse();
}
@Override
- public ConfigStatus activate(String key, SvcLogicContext ctx)
- {
+ public ConfigStatus activate(String key, SvcLogicContext ctx) {
return ConfigStatus.SUCCESS;
}
@Override
- public ConfigStatus deactivate(String key, SvcLogicContext ctx)
- {
+ public ConfigStatus deactivate(String key, SvcLogicContext ctx) {
return ConfigStatus.SUCCESS;
}
- private String escapeMySql(String input)
- {
- if (input == null)
+ private String escapeMySql(String input) {
+ if (input == null) {
return null;
+ }
- input = input.replace("\\", "\\\\");
+ input = input.replace("\\", "\\\\");
input = input.replace("\'", "\\'");
return input;
}
- private String readFile(String fileName)
- {
+ private String readFile(String fileName) {
InputStream is = getClass().getResourceAsStream(fileName);
InputStreamReader isr = new InputStreamReader(is);
BufferedReader in = new BufferedReader(isr);
StringBuilder ss = new StringBuilder();
- try
- {
+ try {
String s = in.readLine();
- while (s != null)
- {
+ while (s != null) {
ss.append(s).append('\n');
s = in.readLine();
}
- }
- catch (IOException e)
- {
+ } catch (IOException e) {
System.out.println("Error reading " + fileName + ": " + e.getMessage());
throw new RuntimeException("Error reading " + fileName + ": " + e.getMessage(), e);
- }
- finally
- {
- try
- {
+ } finally {
+ try {
in.close();
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.warn("Could not close BufferedReader", e);
}
- try
- {
+ try {
isr.close();
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.warn("Could not close InputStreamReader", e);
}
- try
- {
+ try {
is.close();
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.warn("Could not close InputStream", e);
}
}
return ss.toString();
}
- private String buildXmlRequest(Map<String, String> param, String template)
- {
+ private String buildXmlRequest(Map<String, String> param, String template) {
StringBuilder ss = new StringBuilder();
int i = 0;
- while (i < template.length())
- {
+ while (i < template.length()) {
int i1 = template.indexOf("${", i);
- if (i1 < 0)
- {
+ if (i1 < 0) {
ss.append(template.substring(i));
break;
}
int i2 = template.indexOf('}', i1 + 2);
- if (i2 < 0)
+ if (i2 < 0) {
throw new RuntimeException("Template error: Matching } not found");
+ }
String var1 = template.substring(i1 + 2, i2);
String value1 = param.get(var1);
- if (value1 == null || value1.trim().length() == 0)
- {
+ if (value1 == null || value1.trim().length() == 0) {
// delete the whole element (line)
int i3 = template.lastIndexOf('\n', i1);
- if (i3 < 0)
+ if (i3 < 0) {
i3 = 0;
+ }
int i4 = template.indexOf('\n', i1);
- if (i4 < 0)
+ if (i4 < 0) {
i4 = template.length();
+ }
- if (i < i3)
+ if (i < i3) {
ss.append(template.substring(i, i3));
+ }
i = i4;
- }
- else
- {
+ } else {
ss.append(template.substring(i, i1)).append(value1);
i = i2 + 1;
}
return ss.toString();
}
- private String buildNetworkData2(SvcLogicContext ctx, String template, String operation)
- {
+ private String buildNetworkData2(SvcLogicContext ctx, String template, String operation) {
log.info("Building XML started");
long t1 = System.currentTimeMillis();
template = expandRepeats(ctx, template, 1);
Map<String, String> mm = new HashMap<>();
- for (String s : ctx.getAttributeKeySet())
+ for (String s : ctx.getAttributeKeySet()) {
mm.put(s, ctx.getAttribute(s));
+ }
mm.put("operation", operation);
StringBuilder ss = new StringBuilder();
int i = 0;
- while (i < template.length())
- {
+ while (i < template.length()) {
int i1 = template.indexOf("${", i);
- if (i1 < 0)
- {
+ if (i1 < 0) {
ss.append(template.substring(i));
break;
}
int i2 = template.indexOf('}', i1 + 2);
- if (i2 < 0)
+ if (i2 < 0) {
throw new RuntimeException("Template error: Matching } not found");
+ }
String var1 = template.substring(i1 + 2, i2);
String value1 = XmlUtil.getXml(mm, var1);
- if (value1 == null || value1.trim().length() == 0)
- {
+ if (value1 == null || value1.trim().length() == 0) {
// delete the whole element (line)
int i3 = template.lastIndexOf('\n', i1);
- if (i3 < 0)
+ if (i3 < 0) {
i3 = 0;
+ }
int i4 = template.indexOf('\n', i1);
- if (i4 < 0)
+ if (i4 < 0) {
i4 = template.length();
+ }
- if (i < i3)
+ if (i < i3) {
ss.append(template.substring(i, i3));
+ }
i = i4;
- }
- else
- {
+ } else {
ss.append(template.substring(i, i1)).append(value1);
i = i2 + 1;
}
return ss.toString();
}
- private String expandRepeats(SvcLogicContext ctx, String template, int level)
- {
+ private String expandRepeats(SvcLogicContext ctx, String template, int level) {
StringBuilder newTemplate = new StringBuilder();
int k = 0;
- while (k < template.length())
- {
+ while (k < template.length()) {
int i1 = template.indexOf("${repeat:", k);
- if (i1 < 0)
- {
+ if (i1 < 0) {
newTemplate.append(template.substring(k));
break;
}
int i2 = template.indexOf(':', i1 + 9);
- if (i2 < 0)
+ if (i2 < 0) {
throw new RuntimeException(
"Template error: Context variable name followed by : is required after repeat");
+ }
// Find the closing }, store in i3
int nn = 1;
int i3 = -1;
int i = i2;
- while (nn > 0 && i < template.length())
- {
+ while (nn > 0 && i < template.length()) {
i3 = template.indexOf('}', i);
- if (i3 < 0)
+ if (i3 < 0) {
throw new RuntimeException("Template error: Matching } not found");
+ }
int i32 = template.indexOf('{', i);
- if (i32 >= 0 && i32 < i3)
- {
+ if (i32 >= 0 && i32 < i3) {
nn++;
i = i32 + 1;
- }
- else
- {
+ } else {
nn--;
i = i3 + 1;
}
String value1 = ctx.getAttribute(var1);
log.info(" " + var1 + ": " + value1);
int n = 0;
- try
- {
+ try {
n = Integer.parseInt(value1);
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
n = 0;
}
String rpt = template.substring(i2 + 1, i3);
- for (int ii = 0; ii < n; ii++)
- {
+ for (int ii = 0; ii < n; ii++) {
String ss = rpt.replaceAll("\\[\\$\\{" + level + "\\}\\]", "[" + ii + "]");
newTemplate.append(ss);
}
k = i3 + 1;
}
- if (k == 0)
+ if (k == 0) {
return newTemplate.toString();
+ }
return expandRepeats(ctx, newTemplate.toString(), level + 1);
}
- private HttpResponse sendXmlRequest(String xmlRequest, String url, String user, String password)
- {
- try
- {
+ private HttpResponse sendXmlRequest(String xmlRequest, String url, String user, String password) {
+ try {
Client client = Client.create();
client.setConnectTimeout(5000);
WebResource webResource = client.resource(url);
r.message = message;
return r;
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
log.error("Error sending the request: ", e);
HttpResponse r = new HttpResponse();
}
}
- private static class HttpResponse
- {
+ private static class HttpResponse {
public int code;
+
public String message;
}
- private ConfigStatus setResponseStatus(SvcLogicContext ctx, HttpResponse r)
- {
+ private ConfigStatus setResponseStatus(SvcLogicContext ctx, HttpResponse r) {
ctx.setAttribute("error-code", String.valueOf(r.code));
ctx.setAttribute("error-message", r.message);
return r.code > 299 ? ConfigStatus.FAILURE : ConfigStatus.SUCCESS;
}
- private String getStringBetweenQuotes(String string)
- {
+ private String getStringBetweenQuotes(String string) {
String fnName = "ConfigComponentAdaptor.getStringBetweenQuotes";
- DebugLog.printAriDebug(fnName, "string="+string);
+ DebugLog.printAriDebug(fnName, "string=" + string);
String retString = null;
int start = string.indexOf("\"");
int end = string.lastIndexOf("\"");
- retString = string.substring(start+1, end);
- DebugLog.printAriDebug(fnName, "retString="+retString);
- return(retString);
+ retString = string.substring(start + 1, end);
+ DebugLog.printAriDebug(fnName, "retString=" + retString);
+ return (retString);
}
- public static String _readFile(String fileName)
- {
+ public static String _readFile(String fileName) {
StringBuffer strBuff = new StringBuffer();
String line;
- try (BufferedReader in = new BufferedReader(new FileReader(fileName)))
- {
- while ((line = in.readLine()) != null)
- {
- strBuff.append(line+"\n");
+ try (BufferedReader in = new BufferedReader(new FileReader(fileName))) {
+ while ((line = in.readLine()) != null) {
+ strBuff.append(line + "\n");
}
- }
- catch (IOException e)
- {
- System.out.println("Caught an IOException in method readFile(): e="+e.toString());
+ } catch (IOException e) {
+ System.out.println("Caught an IOException in method readFile(): e=" + e.toString());
}
return (strBuff.toString());
}
- private String trimResponse(String response)
- {
+ private String trimResponse(String response) {
StringTokenizer line = new StringTokenizer(response, "\n");
StringBuffer sb = new StringBuffer();
boolean captureText = false;
- while (line.hasMoreTokens())
- {
+ while (line.hasMoreTokens()) {
String token = line.nextToken();
- if (token.indexOf("<configuration xmlns=") != -1)
+ if (token.indexOf("<configuration xmlns=") != -1) {
captureText = true;
- if (captureText)
- sb.append(token +"\n");
- if (token.indexOf("</configuration>") != -1)
+ }
+ if (captureText) {
+ sb.append(token + "\n");
+ }
+ if (token.indexOf("</configuration>") != -1) {
captureText = false;
+ }
}
- return(sb.toString());
+ return (sb.toString());
}
- public static void main (String args[]) throws Exception
- {
+ public static void main(String args[]) throws Exception {
Properties props = null;
System.out.println("*************************Hello*****************************");
ConfigComponentAdaptor cca = new ConfigComponentAdaptor(props);
- String Get_config_template = _readFile ("/home/userID/data/Get_config_template");
- String Download_config_template = _readFile ("/home/userID/data/Download_config_template_2");
+ String Get_config_template = _readFile("/home/userID/data/Get_config_template");
+ String Download_config_template = _readFile("/home/userID/data/Download_config_template_2");
String key = "GetCliRunningConfig";
Map<String, String> parameters = new HashMap();
parameters.put("Host_ip_address", "000.00.000.00");
System.out.println("*************************TRACE 1*****************************");
cca.configure(key, parameters, ctx);
}
-
}
package org.onap.appc.ccadaptor;
+import com.jcraft.jsch.Channel;
+import com.jcraft.jsch.ChannelSftp;
+import com.jcraft.jsch.ChannelShell;
+import com.jcraft.jsch.ChannelSubsystem;
+import com.jcraft.jsch.JSch;
+import com.jcraft.jsch.JSchException;
+import com.jcraft.jsch.Session;
+import com.jcraft.jsch.SftpException;
+import com.jcraft.jsch.UIKeyboardInteractive;
+import com.jcraft.jsch.UserInfo;
+import java.io.BufferedInputStream;
import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
-import java.io.*;
-import java.util.*;
+import java.io.OutputStream;
+import java.io.RandomAccessFile;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Calendar;
-import com.jcraft.jsch.*;
+import java.util.Date;
+import java.util.StringTokenizer;
-public class SshJcraftWrapper
-{
+public class SshJcraftWrapper {
- private String debugLogFileName = "/tmp/sshJcraftWrapperDebug";
InputStream inputStream = null;
OutputStream outputStream = null;
+ DebugLog debugLog = new DebugLog();
+ private String debugLogFileName = "/tmp/sshJcraftWrapperDebug";
private TelnetListener listener = null;
private String routerLogFileName = null;
- DebugLog debugLog = new DebugLog();
private String host = null;
private String RouterName = null;
private int BUFFER_SIZE = 512000;
+ char[] charBuffer = new char[BUFFER_SIZE];
// private int BUFFER_SIZE = 4000000;
private DataInputStream dis = null;
private BufferedReader reader = null;
- char[] charBuffer = new char[BUFFER_SIZE];
private BufferedWriter out = null;
private File _tmpFile = null;
private JSch jsch = null;
private File extraDebugFile = new File("/tmp/sshJcraftWrapperDEBUG");
private String routerCmdType = "XML";
private String routerFileName = null;
- private File jcraftReadSwConfigFileFromDisk = new File("/tmp/jcraftReadSwConfigFileFromDisk");
- private String equipNameCode = null;
- private String hostName = null;
- private String userName = null;
- private String passWord = null;
+ private File jcraftReadSwConfigFileFromDisk = new File("/tmp/jcraftReadSwConfigFileFromDisk");
+ private String equipNameCode = null;
+ private String hostName = null;
+ private String userName = null;
+ private String passWord = null;
private StringBuffer charactersFromBufferFlush = new StringBuffer();
- private Runtime runtime = Runtime.getRuntime();
- private DebugLog dbLog = new DebugLog();
+ private Runtime runtime = Runtime.getRuntime();
+ private DebugLog dbLog = new DebugLog();
- public void SshJcraftWrapper()
- {
+ public void SshJcraftWrapper() {
String fn = "SshJcraftWrapper.SshJcraftWrapper";
- debugLog.printRTAriDebug (fn, "SshJcraftWrapper has been instantated");
- routerLogFileName = "/tmp/" +host;
+ debugLog.printRTAriDebug(fn, "SshJcraftWrapper has been instantated");
+ routerLogFileName = "/tmp/" + host;
this.host = host;
}
- public void connect (String hostname, String username, String password, String prompt, int timeOut) throws IOException
- {
+ public void connect(String hostname, String username, String password, String prompt, int timeOut)
+ throws IOException {
String fn = "SshJcraftWrapper.connect";
jsch = new JSch();
- debugLog.printRTAriDebug (fn, "Attempting to connect to "+hostname +" username="+username +" password="+password + " prompt='"+prompt +"' timeOut="+timeOut);
- debugLog.printRTAriDebug (fn, "Trace A");
+ debugLog.printRTAriDebug(fn,
+ "Attempting to connect to " + hostname + " username=" + username + " password=" + password + " prompt='"
+ + prompt + "' timeOut=" + timeOut);
+ debugLog.printRTAriDebug(fn, "Trace A");
RouterName = hostname;
- hostName = hostname;
- userName = username;
- passWord = password;
- try
- {
+ hostName = hostname;
+ userName = username;
+ passWord = password;
+ try {
session = jsch.getSession(username, hostname, 22);
UserInfo ui = new MyUserInfo();
session.setPassword(password);
session.setUserInfo(ui);
session.connect(timeOut);
channel = session.openChannel("shell");
- session.setServerAliveCountMax(0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
- ((ChannelShell)channel).setPtyType("vt102");
+ session.setServerAliveCountMax(
+ 0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
+ ((ChannelShell) channel).setPtyType("vt102");
inputStream = channel.getInputStream();
dis = new DataInputStream(inputStream);
reader = new BufferedReader(new InputStreamReader(dis), BUFFER_SIZE);
channel.connect();
- debugLog.printRTAriDebug (fn, "Successfully connected.");
- debugLog.printRTAriDebug (fn, "Flushing input buffer");
- try
- {
- receiveUntil(prompt, 3000, "No cmd was sent, just waiting");
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception: Nothing to flush out.");
- }
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception. e="+e);
- // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostname +" "+e);
+ debugLog.printRTAriDebug(fn, "Successfully connected.");
+ debugLog.printRTAriDebug(fn, "Flushing input buffer");
+ try {
+ receiveUntil(prompt, 3000, "No cmd was sent, just waiting");
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception: Nothing to flush out.");
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception. e=" + e);
+ // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostname +" "+e);
throw new IOException(e.toString());
}
}
// User specifies the port number.
- public void connect (String hostname, String username, String password, String prompt, int timeOut, int portNum) throws IOException
- {
+ public void connect(String hostname, String username, String password, String prompt, int timeOut, int portNum)
+ throws IOException {
String fn = "SshJcraftWrapper.connect";
- debugLog.printRTAriDebug (fn, ":Attempting to connect to "+hostname +" username="+username +" password="+password + " prompt='"+prompt +"' timeOut="+timeOut +" portNum="+portNum);
+ debugLog.printRTAriDebug(fn,
+ ":Attempting to connect to " + hostname + " username=" + username + " password=" + password + " prompt='"
+ + prompt + "' timeOut=" + timeOut + " portNum=" + portNum);
RouterName = hostname;
- hostName = hostname;
- userName = username;
- passWord = password;
+ hostName = hostname;
+ userName = username;
+ passWord = password;
RouterName = hostname;
jsch = new JSch();
- try
- {
+ try {
session = jsch.getSession(username, hostname, portNum);
UserInfo ui = new MyUserInfo();
session.setPassword(password);
session.setUserInfo(ui);
- session.setConfig("StrictHostKeyChecking", "no");
- debugLog.printRTAriDebug (fn, ":StrictHostKeyChecking set to 'no'");
+ session.setConfig("StrictHostKeyChecking", "no");
+ debugLog.printRTAriDebug(fn, ":StrictHostKeyChecking set to 'no'");
session.connect(timeOut);
- session.setServerAliveCountMax(0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
+ session.setServerAliveCountMax(
+ 0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
channel = session.openChannel("shell");
- ((ChannelShell)channel).setPtyType("vt102");
+ ((ChannelShell) channel).setPtyType("vt102");
inputStream = channel.getInputStream();
dis = new DataInputStream(inputStream);
reader = new BufferedReader(new InputStreamReader(dis), BUFFER_SIZE);
channel.connect();
- debugLog.printRTAriDebug (fn, ":Successfully connected.");
- debugLog.printRTAriDebug (fn, ":Flushing input buffer");
- try
- {
- if (prompt.equals("]]>]]>"))
- receiveUntil("]]>]]>", 10000, "No cmd was sent, just waiting");
- else
- receiveUntil(":~#", 5000, "No cmd was sent, just waiting");
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception::: Nothing to flush out.");
- }
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, ":Caught an Exception. e="+e);
- dbLog.outputStackTrace(e);
+ debugLog.printRTAriDebug(fn, ":Successfully connected.");
+ debugLog.printRTAriDebug(fn, ":Flushing input buffer");
+ try {
+ if (prompt.equals("]]>]]>")) {
+ receiveUntil("]]>]]>", 10000, "No cmd was sent, just waiting");
+ } else {
+ receiveUntil(":~#", 5000, "No cmd was sent, just waiting");
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception::: Nothing to flush out.");
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, ":Caught an Exception. e=" + e);
+ dbLog.outputStackTrace(e);
- // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostname +" "+e);
+ // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostname +" "+e);
throw new IOException(e.toString());
}
}
- public String receiveUntil (String delimeters, int timeout, String cmdThatWasSent) throws TimedOutException, IOException
- {
+ public String receiveUntil(String delimeters, int timeout, String cmdThatWasSent)
+ throws TimedOutException, IOException {
String fn = "SshJcraftWrapper.receiveUntil";
boolean match = false;
boolean cliPromptCmd = false;
StringBuffer sb2 = new StringBuffer();
StringBuffer sbReceive = new StringBuffer();
- debugLog.printRTAriDebug (fn, "delimeters='"+delimeters +"' timeout="+timeout +" cmdThatWasSent='"+cmdThatWasSent +"'");
- appendToFile(debugLogFileName, fn +" delimeters='"+delimeters +"' timeout="+timeout +" cmdThatWasSent='"+cmdThatWasSent +"'\n");
+ debugLog.printRTAriDebug(fn,
+ "delimeters='" + delimeters + "' timeout=" + timeout + " cmdThatWasSent='" + cmdThatWasSent + "'");
+ appendToFile(debugLogFileName,
+ fn + " delimeters='" + delimeters + "' timeout=" + timeout + " cmdThatWasSent='" + cmdThatWasSent + "'\n");
String CmdThatWasSent = removeWhiteSpaceAndNewLineCharactersAroundString(cmdThatWasSent);
int readCounts = 0;
aggregatedReceivedString = "";
- long deadline = new Date().getTime() + timeout;
- try
- {
+ long deadline = new Date().getTime() + timeout;
+ try {
session.setTimeout(timeout); // This is the socket timeout value.
- while (!match)
- {
- if(new Date().getTime() > deadline)
- {
- debugLog.printRTAriDebug (fn, "Throwing a TimedOutException: time in routine has exceed our deadline: RouterName:"+RouterName +" CmdThatWasSent="+ CmdThatWasSent);
+ while (!match) {
+ if (new Date().getTime() > deadline) {
+ debugLog.printRTAriDebug(fn,
+ "Throwing a TimedOutException: time in routine has exceed our deadline: RouterName:"
+ + RouterName + " CmdThatWasSent=" + CmdThatWasSent);
throw new TimedOutException("Timeout: time in routine has exceed our deadline");
}
- try
- {
+ try {
Thread.sleep(500);
- }
- catch (java.lang.InterruptedException ee)
- {
+ } catch (java.lang.InterruptedException ee) {
boolean ignore = true;
}
- int len = reader.read(charBuffer, 0, BUFFER_SIZE);
- appendToFile(debugLogFileName, fn +" After reader.read cmd: len="+len +"\n");
- if (len <= 0)
- {
- debugLog.printRTAriDebug (fn, "Reader read "+len +" bytes. Looks like we timed out, router="+RouterName);
- throw new TimedOutException ("Received a SocketTimeoutException router="+RouterName);
+ int len = reader.read(charBuffer, 0, BUFFER_SIZE);
+ appendToFile(debugLogFileName, fn + " After reader.read cmd: len=" + len + "\n");
+ if (len <= 0) {
+ debugLog.printRTAriDebug(fn,
+ "Reader read " + len + " bytes. Looks like we timed out, router=" + RouterName);
+ throw new TimedOutException("Received a SocketTimeoutException router=" + RouterName);
}
- if (!cliPromptCmd)
- {
- if (cmdThatWasSent.indexOf("IOS_XR_uploadedSwConfigCmd") != -1)
- {
- if (out == null)
- {
+ if (!cliPromptCmd) {
+ if (cmdThatWasSent.indexOf("IOS_XR_uploadedSwConfigCmd") != -1) {
+ if (out == null) {
// This is a IOS XR sw config file. We will write it to the disk.
timeout = timeout * 2;
deadline = new Date().getTime() + timeout;
- debugLog.printRTAriDebug (fn, "IOS XR upload for software config: timeout="+timeout);
+ debugLog.printRTAriDebug(fn, "IOS XR upload for software config: timeout=" + timeout);
StringTokenizer st = new StringTokenizer(cmdThatWasSent);
st.nextToken();
routerFileName = st.nextToken();
out = new BufferedWriter(new FileWriter(routerFileName));
- routerLogFileName = "/tmp/"+RouterName;
+ routerLogFileName = "/tmp/" + RouterName;
_tmpFile = new File(routerLogFileName);
- debugLog.printRTAriDebug (fn, "Will write the swConfigFile to disk, routerFileName="+routerFileName);
+ debugLog.printRTAriDebug(fn,
+ "Will write the swConfigFile to disk, routerFileName=" + routerFileName);
}
int c;
out.write(charBuffer, 0, len);
out.flush();
- appendToFile(debugLogFileName, fn +" Wrote "+len +" bytes to the disk\n");
- if (_tmpFile.exists())
+ appendToFile(debugLogFileName, fn + " Wrote " + len + " bytes to the disk\n");
+ if (_tmpFile.exists()) {
appendToRouterFile(routerLogFileName, len);
+ }
match = checkIfReceivedStringMatchesDelimeter(len, "\nXML>");
- if (match == true)
- {
+ if (match == true) {
out.flush();
out.close();
- out = null;
+ out = null;
return null;
}
- }
- else
- {
- readCounts ++;
- appendToFile(debugLogFileName, fn +" readCounts="+readCounts +" Reader read "+len +" of data\n");
+ } else {
+ readCounts++;
+ appendToFile(debugLogFileName,
+ fn + " readCounts=" + readCounts + " Reader read " + len + " of data\n");
int c;
sb2.setLength(0);
- for(int i=0; i<len; i++ )
- {
+ for (int i = 0; i < len; i++) {
c = charBuffer[i];
- if ((c != 7) && (c != 13) && (c != 0) && (c != 27))
- {
- sbReceive.append((char)charBuffer[i]);
- sb2.append((char)charBuffer[i]);
+ if ((c != 7) && (c != 13) && (c != 0) && (c != 27)) {
+ sbReceive.append((char) charBuffer[i]);
+ sb2.append((char) charBuffer[i]);
}
}
- appendToRouterFile("/tmp/"+RouterName, len);
- if (listener != null)
+ appendToRouterFile("/tmp/" + RouterName, len);
+ if (listener != null) {
listener.receivedString(sb2.toString());
+ }
- appendToFile(debugLogFileName, fn +" Trace 1\n");
+ appendToFile(debugLogFileName, fn + " Trace 1\n");
match = checkIfReceivedStringMatchesDelimeter(delimeters, sb2.toString(), cmdThatWasSent);
- appendToFile(debugLogFileName, fn +" Trace 2\n");
- if (match == true)
- {
- appendToFile(debugLogFileName, fn +" Match was true, breaking...\n");
+ appendToFile(debugLogFileName, fn + " Trace 2\n");
+ if (match == true) {
+ appendToFile(debugLogFileName, fn + " Match was true, breaking...\n");
break;
}
}
- }
- else
- {
- debugLog.printRTAriDebug (fn, "cliPromptCmd, Trace 2");
+ } else {
+ debugLog.printRTAriDebug(fn, "cliPromptCmd, Trace 2");
sb2.setLength(0);
- for(int i=0; i<len; i++ )
- {
- sbReceive.append( (char)charBuffer[i] );
- sb2.append( (char)charBuffer[i] );
+ for (int i = 0; i < len; i++) {
+ sbReceive.append((char) charBuffer[i]);
+ sb2.append((char) charBuffer[i]);
}
- appendToRouterFile("/tmp/"+RouterName, sb2);
- if (listener != null)
+ appendToRouterFile("/tmp/" + RouterName, sb2);
+ if (listener != null) {
listener.receivedString(sb2.toString());
- debugLog.printRTAriDebug (fn, "sb2='"+sb2.toString() +"' delimeters='" +delimeters +"'");
- if (sb2.toString().indexOf("\nariPrompt>") != -1)
- {
- debugLog.printRTAriDebug (fn, "Found our prompt");
+ }
+ debugLog.printRTAriDebug(fn, "sb2='" + sb2.toString() + "' delimeters='" + delimeters + "'");
+ if (sb2.toString().indexOf("\nariPrompt>") != -1) {
+ debugLog.printRTAriDebug(fn, "Found our prompt");
match = true;
break;
}
}
}
- }
- catch (JSchException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an JSchException e="+e.toString());
- dbLog.outputStackTrace(e);
- throw new TimedOutException (e.toString());
- }
- catch (IOException ee)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException: ee="+ee.toString());
- dbLog.outputStackTrace(ee);
- throw new TimedOutException (ee.toString());
+ } catch (JSchException e) {
+ debugLog.printRTAriDebug(fn, "Caught an JSchException e=" + e.toString());
+ dbLog.outputStackTrace(e);
+ throw new TimedOutException(e.toString());
+ } catch (IOException ee) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException: ee=" + ee.toString());
+ dbLog.outputStackTrace(ee);
+ throw new TimedOutException(ee.toString());
}
String result = stripOffCmdFromRouterResponse(sbReceive.toString());
- debugLog.printRTAriDebug (fn, "Leaving method successfully");
+ debugLog.printRTAriDebug(fn, "Leaving method successfully");
return (result);
}
- public boolean checkIfReceivedStringMatchesDelimeter(String delimeters, String receivedString, String cmdThatWasSent)
- {
+ public boolean checkIfReceivedStringMatchesDelimeter(String delimeters, String receivedString,
+ String cmdThatWasSent) {
// The delimeters are in a '|' seperated string. Return true on the first match.
String fn = "SshJcraftWrapper.checkIfReceivedStringMatchesDelimeter";
- appendToFile(debugLogFileName, fn +" Entered: delimeters='"+delimeters +" cmdThatWasSent='"+cmdThatWasSent +"' receivedString='"+receivedString +"'\n");
+ appendToFile(debugLogFileName,
+ fn + " Entered: delimeters='" + delimeters + " cmdThatWasSent='" + cmdThatWasSent + "' receivedString='"
+ + receivedString + "'\n");
StringTokenizer st = new StringTokenizer(delimeters, "|");
if ((delimeters.indexOf("#$") != -1) || (routerCmdType.equals("CLI"))) // This would be an IOS XR, CLI command.
{
int x = receivedString.lastIndexOf("#");
int y = receivedString.length() - 1;
- appendToFile(debugLogFileName, fn +" IOS XR, CLI command\n");
- if (extraDebugFile.exists())
- appendToFile(debugLogFileName, fn +" :::cmdThatWasSent='"+cmdThatWasSent +"' x="+x +" y="+y +"\n");
- if ((x != -1) && (y == x))
- return(true);
- else
- return(false);
+ appendToFile(debugLogFileName, fn + " IOS XR, CLI command\n");
+ if (extraDebugFile.exists()) {
+ appendToFile(debugLogFileName,
+ fn + " :::cmdThatWasSent='" + cmdThatWasSent + "' x=" + x + " y=" + y + "\n");
+ }
+ if ((x != -1) && (y == x)) {
+ return (true);
+ } else {
+ return (false);
+ }
}
- if (cmdThatWasSent.indexOf("show config") != -1)
- {
- appendToFile(debugLogFileName, fn +"In the block for 'show config'\n");
- while (st.hasMoreTokens())
- {
+ if (cmdThatWasSent.indexOf("show config") != -1) {
+ appendToFile(debugLogFileName, fn + "In the block for 'show config'\n");
+ while (st.hasMoreTokens()) {
String delimeter = st.nextToken();
// Make sure we don't get faked out by a response of " #".
// Proc #0
// # signaling-local-address ipv6 FD00:F4D5:EA06:1::110:136:254
// LAAR2#
int x = receivedString.lastIndexOf(delimeter);
- if ((receivedString.lastIndexOf(delimeter) != -1) && (receivedString.lastIndexOf(" #") != x-1))
- {
- appendToFile(debugLogFileName, fn +"receivedString=\n'" +receivedString +"'\n");
- appendToFile(debugLogFileName, fn +"Returning true for the 'show config' command. We found our real delmeter. \n\n");
+ if ((receivedString.lastIndexOf(delimeter) != -1) && (receivedString.lastIndexOf(" #") != x - 1)) {
+ appendToFile(debugLogFileName, fn + "receivedString=\n'" + receivedString + "'\n");
+ appendToFile(debugLogFileName,
+ fn + "Returning true for the 'show config' command. We found our real delmeter. \n\n");
return (true);
}
}
- }
- else
- {
+ } else {
aggregatedReceivedString = aggregatedReceivedString + receivedString;
- _appendToFile ("/tmp/aggregatedReceivedString.debug", aggregatedReceivedString);
+ _appendToFile("/tmp/aggregatedReceivedString.debug", aggregatedReceivedString);
- while (st.hasMoreTokens())
- {
+ while (st.hasMoreTokens()) {
String delimeter = st.nextToken();
- appendToFile(debugLogFileName, fn +" Looking for an delimeter of:'"+delimeter+"'\n");
- appendToFile(debugLogFileName, fn +" receivedString='"+receivedString);
- if (aggregatedReceivedString.indexOf(delimeter) != -1)
- {
- debugLog.printRTAriDebug (fn, "Found our delimeter, which was: '"+delimeter +"'");
+ appendToFile(debugLogFileName, fn + " Looking for an delimeter of:'" + delimeter + "'\n");
+ appendToFile(debugLogFileName, fn + " receivedString='" + receivedString);
+ if (aggregatedReceivedString.indexOf(delimeter) != -1) {
+ debugLog.printRTAriDebug(fn, "Found our delimeter, which was: '" + delimeter + "'");
aggregatedReceivedString = "";
return (true);
}
return (false);
}
- public boolean checkIfReceivedStringMatchesDelimeter(int len, String delimeter)
- {
+ public boolean checkIfReceivedStringMatchesDelimeter(int len, String delimeter) {
String fnName = "SshJcraftWrapper.checkIfReceivedStringMatchesDelimeter:::";
int x;
int c;
String str = null;
- if (jcraftReadSwConfigFileFromDisk())
- {
+ if (jcraftReadSwConfigFileFromDisk()) {
DebugLog.printAriDebug(fnName, "jcraftReadSwConfigFileFromDisk block");
File fileName = new File(routerFileName);
- appendToFile(debugLogFileName, fnName +" jcraftReadSwConfigFileFromDisk::: Will read the tail end of the file from the disk");
- try
- {
+ appendToFile(debugLogFileName,
+ fnName + " jcraftReadSwConfigFileFromDisk::: Will read the tail end of the file from the disk");
+ try {
str = getLastFewLinesOfFile(fileName, 3);
- }
- catch (IOException e)
- {
- DebugLog.printAriDebug(fnName, "Caught an Exception, e="+e);
- dbLog.outputStackTrace(e);
+ } catch (IOException e) {
+ DebugLog.printAriDebug(fnName, "Caught an Exception, e=" + e);
+ dbLog.outputStackTrace(e);
e.printStackTrace();
}
- }
- else
- {
+ } else {
// DebugLog.printAriDebug(fnName, "TRACE 1: ******************************");
// When looking at the end of the charBuffer, don't include any linefeeds or spaces. We only want to make the smallest string possible.
- for(x=len-1; x>=0; x--)
- {
+ for (x = len - 1; x >= 0; x--) {
c = charBuffer[x];
- if (extraDebugFile.exists())
- appendToFile(debugLogFileName, fnName +" x="+x +" c="+c +"\n");
+ if (extraDebugFile.exists()) {
+ appendToFile(debugLogFileName, fnName + " x=" + x + " c=" + c + "\n");
+ }
if ((c != 10) && (c != 32)) // Not a line feed nor a space.
+ {
break;
+ }
}
- if ((x+1 - 13) >= 0)
- {
- str = new String (charBuffer, (x+1-13), 13);
- appendToFile(debugLogFileName, fnName +" str:'"+str +"'\n");
- }
- else
- {
+ if ((x + 1 - 13) >= 0) {
+ str = new String(charBuffer, (x + 1 - 13), 13);
+ appendToFile(debugLogFileName, fnName + " str:'" + str + "'\n");
+ } else {
File fileName = new File(routerFileName);
- appendToFile(debugLogFileName, fnName +" Will read the tail end of the file from the disk, x="+x +" len="+len +" str::'"+str +"' routerFileName='" +routerFileName +"'\n");
- DebugLog.printAriDebug(fnName, "Will read the tail end of the file from the disk, x="+x +" len="+len +" str::'"+str +"' routerFileName='" +routerFileName +"'");
- try
- {
+ appendToFile(debugLogFileName,
+ fnName + " Will read the tail end of the file from the disk, x=" + x + " len=" + len + " str::'"
+ + str + "' routerFileName='" + routerFileName + "'\n");
+ DebugLog.printAriDebug(fnName,
+ "Will read the tail end of the file from the disk, x=" + x + " len=" + len + " str::'" + str
+ + "' routerFileName='" + routerFileName + "'");
+ try {
str = getLastFewLinesOfFile(fileName, 3);
- }
- catch (IOException e)
- {
- DebugLog.printAriDebug(fnName, "Caught an Exception, e="+e);
- dbLog.outputStackTrace(e);
+ } catch (IOException e) {
+ DebugLog.printAriDebug(fnName, "Caught an Exception, e=" + e);
+ dbLog.outputStackTrace(e);
e.printStackTrace();
}
}
}
- if (str.indexOf(delimeter) != -1)
- {
- DebugLog.printAriDebug(fnName, "str in break is:'"+str +"'" +" delimeter='" +delimeter +"'");
- appendToFile(debugLogFileName, fnName +" str in break is:'"+str +" delimeter='" +delimeter +"'" +"'\n");
- return(true);
- }
- else
- {
- appendToFile(debugLogFileName, fnName +" Returning false");
- return(false);
+ if (str.indexOf(delimeter) != -1) {
+ DebugLog.printAriDebug(fnName, "str in break is:'" + str + "'" + " delimeter='" + delimeter + "'");
+ appendToFile(debugLogFileName,
+ fnName + " str in break is:'" + str + " delimeter='" + delimeter + "'" + "'\n");
+ return (true);
+ } else {
+ appendToFile(debugLogFileName, fnName + " Returning false");
+ return (false);
}
}
- public void closeConnection()
- {
+ public void closeConnection() {
String fn = "SshJcraftWrapper.closeConnection";
- debugLog.printRTAriDebug (fn, "Executing the closeConnection....");
+ debugLog.printRTAriDebug(fn, "Executing the closeConnection....");
inputStream = null;
outputStream = null;
dis = null;
charBuffer = null;
session.disconnect();
- session = null;
+ session = null;
}
- public void send (String cmd) throws IOException
- {
+ public void send(String cmd) throws IOException {
String fn = "SshJcraftWrapper.send";
OutputStream out = channel.getOutputStream();
DataOutputStream dos = new DataOutputStream(out);
- if ((cmd.charAt(cmd.length() - 1) != '\n') && (cmd.charAt(cmd.length() - 1) != '\r'))
+ if ((cmd.charAt(cmd.length() - 1) != '\n') && (cmd.charAt(cmd.length() - 1) != '\r')) {
cmd += "\n";
- int length = cmd.length();
- int i = -1;
- int nchars = 300000;
- int ncharsTotalSent = 0;
- int ncharsSent = 0;
+ }
+ int length = cmd.length();
+ int i = -1;
+ int nchars = 300000;
+ int ncharsTotalSent = 0;
+ int ncharsSent = 0;
- appendToFile(debugLogFileName, fn+": Sending: '"+cmd );
+ appendToFile(debugLogFileName, fn + ": Sending: '" + cmd);
// debugLog.printRTAriDebug (fn, "cmd = "+cmd);
- debugLog.printRTAriDebug (fn, "Length of cmd is:" +length); // 2,937,706
- try
- {
- if (length > 600000)
- {
- int timeout = 9000;
- for (i=0; i<length; i+=nchars)
- {
- String Cmd = cmd.substring(i, Math.min(length, i + nchars));
- ncharsSent = Cmd.length();
- ncharsTotalSent = ncharsTotalSent + Cmd.length();
- debugLog.printRTAriDebug (fn, "i="+i +" Sending Cmd: ncharsSent="+ncharsSent);
- dos.writeBytes(Cmd);
- dos.flush();
- try
- {
- debugLog.printRTAriDebug (fn, ":::i="+i +" length="+length);
- if (ncharsSent < length)
- receiveUntilBufferFlush (ncharsSent, timeout, "buffer flush i="+i);
- else
- {
- debugLog.printRTAriDebug (fn, "i="+i +" No Waiting this time....");
+ debugLog.printRTAriDebug(fn, "Length of cmd is:" + length); // 2,937,706
+ try {
+ if (length > 600000) {
+ int timeout = 9000;
+ for (i = 0; i < length; i += nchars) {
+ String Cmd = cmd.substring(i, Math.min(length, i + nchars));
+ ncharsSent = Cmd.length();
+ ncharsTotalSent = ncharsTotalSent + Cmd.length();
+ debugLog.printRTAriDebug(fn, "i=" + i + " Sending Cmd: ncharsSent=" + ncharsSent);
+ dos.writeBytes(Cmd);
dos.flush();
+ try {
+ debugLog.printRTAriDebug(fn, ":::i=" + i + " length=" + length);
+ if (ncharsSent < length) {
+ receiveUntilBufferFlush(ncharsSent, timeout, "buffer flush i=" + i);
+ } else {
+ debugLog.printRTAriDebug(fn, "i=" + i + " No Waiting this time....");
+ dos.flush();
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception: Nothing to flush out.");
+ }
+ }
+ } else {
+ debugLog.printRTAriDebug(fn, "Before executing the dos.writeBytes");
+ dos.writeBytes(cmd);
}
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception: Nothing to flush out.");
- }
- }
- }
- else
- {
- debugLog.printRTAriDebug (fn, "Before executing the dos.writeBytes");
- dos.writeBytes(cmd);
- }
- dos.flush();
- debugLog.printRTAriDebug (fn, "Leaving method");
- appendToFile(debugLogFileName, fn+": Leaving method\n");
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException. e="+e);
- dbLog.outputStackTrace(e);
+ dos.flush();
+ debugLog.printRTAriDebug(fn, "Leaving method");
+ appendToFile(debugLogFileName, fn + ": Leaving method\n");
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException. e=" + e);
+ dbLog.outputStackTrace(e);
throw new IOException(e.toString());
}
}
- public void sendChar (int v) throws IOException
- {
+ public void sendChar(int v) throws IOException {
String fn = "SshJcraftWrapper.sendChar";
OutputStream out = channel.getOutputStream();
DataOutputStream dos = new DataOutputStream(out);
- try
- {
- debugLog.printRTAriDebug (fn, "Sending: '" +v +"'");
- dos.writeChar (v);
+ try {
+ debugLog.printRTAriDebug(fn, "Sending: '" + v + "'");
+ dos.writeChar(v);
dos.flush();
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException. e="+e);
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException. e=" + e);
throw new IOException(e.toString());
}
}
- public void send (byte[] b, int off, int len) throws IOException
- {
+ public void send(byte[] b, int off, int len) throws IOException {
String fn = "SshJcraftWrapper.send:byte[]";
OutputStream out = channel.getOutputStream();
DataOutputStream dos = new DataOutputStream(out);
- try
- {
- dos.write (b, off, len);
+ try {
+ dos.write(b, off, len);
dos.flush();
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException. e="+e);
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException. e=" + e);
throw new IOException(e.toString());
}
}
- public static class MyUserInfo implements UserInfo, UIKeyboardInteractive
- {
- public String getPassword()
- {
+ public static class MyUserInfo implements UserInfo, UIKeyboardInteractive {
+
+ public String getPassword() {
return null;
}
- public boolean promptYesNo(String str)
- {
+
+ public boolean promptYesNo(String str) {
return false;
}
- public String getPassphrase()
- {
+
+ public String getPassphrase() {
return null;
}
- public boolean promptPassphrase(String message)
- {
+
+ public boolean promptPassphrase(String message) {
return false;
}
- public boolean promptPassword(String message)
- {
+
+ public boolean promptPassword(String message) {
return false;
}
- public void showMessage(String message)
- { }
+
+ public void showMessage(String message) {
+ }
+
public String[] promptKeyboardInteractive(String destination,
- String name,
- String instruction,
- String[] prompt,
- boolean[] echo)
- {
+ String name,
+ String instruction,
+ String[] prompt,
+ boolean[] echo) {
return null;
}
}
- public void addListener(TelnetListener listener)
- {
+ public void addListener(TelnetListener listener) {
this.listener = listener;
}
- public void appendToFile (String fileName, String dataToWrite)
- {
+ public void appendToFile(String fileName, String dataToWrite) {
String fn = "SshJcraftWrapper.appendToFile";
- try
- {
+ try {
// First check to see if a file 'fileName' exist, if it does
// write to it. If it does not exist, don't write to it.
File tmpFile = new File(fileName);
- if (tmpFile.exists())
- {
+ if (tmpFile.exists()) {
BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true));
// out.write(dataToWrite);
// out.write(getTheDate() +": " +Thread.currentThread().getName() +": "+dataToWrite);
- out.write(getTheDate() +": " +tId +": "+dataToWrite);
+ out.write(getTheDate() + ": " + tId + ": " + dataToWrite);
out.close();
}
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException: e="+e);
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception: e="+e);
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException: e=" + e);
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception: e=" + e);
}
}
- public void _appendToFile (String fileName, String dataToWrite)
- {
+ public void _appendToFile(String fileName, String dataToWrite) {
String fn = "SshJcraftWrapper.appendToFile";
- try
- {
+ try {
// First check to see if a file 'fileName' exist, if it does
// write to it. If it does not exist, don't write to it.
File tmpFile = new File(fileName);
- if (tmpFile.exists())
- {
+ if (tmpFile.exists()) {
BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true));
out.write(dataToWrite);
out.close();
}
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException: e="+e);
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception: e="+e);
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException: e=" + e);
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception: e=" + e);
}
}
- public String getTheDate()
- {
+ public String getTheDate() {
Calendar cal = Calendar.getInstance();
java.util.Date today = cal.getTime();
DateFormat df1 = DateFormat.getDateInstance();
}
- public void appendToRouterFile (String fileName, StringBuffer dataToWrite)
- {
+ public void appendToRouterFile(String fileName, StringBuffer dataToWrite) {
String fnName = "SshJcraftWrapper.appendToRouterFile";
- debugLog.printRTAriDebug (fnName, "Entered.... ");
- try
- {
+ debugLog.printRTAriDebug(fnName, "Entered.... ");
+ try {
// First check to see if a file 'fileName' exist, if it does
// write to it. If it does not exist, don't write to it.
File tmpFile = new File(fileName);
{
// if ((tmpFile.exists()) && (tmpFile.setWritable(true, true)))
- if (tmpFile.exists())
- {
+ if (tmpFile.exists()) {
BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true));
- // out.write("<!-- "+getTheDate() +": " +tId +" -->\n");
+ // out.write("<!-- "+getTheDate() +": " +tId +" -->\n");
out.write(dataToWrite.toString());
out.close();
}
}
- }
- catch (IOException e)
- {
+ } catch (IOException e) {
System.err.println("writeToFile() exception: " + e);
e.printStackTrace();
}
}
- public void appendToRouterFile (String fileName, int len)
- {
+ public void appendToRouterFile(String fileName, int len) {
String fnName = "SshJcraftWrapper.appendToFile";
// debugLog.printRTAriDebug (fnName, "Entered.... len="+len);
- try
- {
+ try {
// First check to see if a file 'fileName' exist, if it does
// write to it. If it does not exist, don't write to it.
File tmpFile = new File(fileName);
- // if ((tmpFile.exists()) && (tmpFile.setWritable(true, true)))
- if (tmpFile.exists())
- {
- BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true));
- // out.write("<!-- "+getTheDate() +": " +tId +" -->\n");
- out.write(charBuffer, 0, len);
- out.close();
- }
- }
- catch (IOException e)
- {
+ // if ((tmpFile.exists()) && (tmpFile.setWritable(true, true)))
+ if (tmpFile.exists()) {
+ BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true));
+ // out.write("<!-- "+getTheDate() +": " +tId +" -->\n");
+ out.write(charBuffer, 0, len);
+ out.close();
+ }
+ } catch (IOException e) {
System.err.println("writeToFile() exception: " + e);
e.printStackTrace();
}
}
- public String removeWhiteSpaceAndNewLineCharactersAroundString(String str)
- {
- if (str != null)
- {
+ public String removeWhiteSpaceAndNewLineCharactersAroundString(String str) {
+ if (str != null) {
StringTokenizer strTok = new StringTokenizer(str, "\n");
StringBuffer sb = new StringBuffer();
- while (strTok.hasMoreTokens())
- {
+ while (strTok.hasMoreTokens()) {
String line = strTok.nextToken();
sb.append(line);
}
return (sb.toString().trim());
+ } else {
+ return (str);
}
- else
- return(str);
}
- public String stripOffCmdFromRouterResponse(String routerResponse)
- {
+ public String stripOffCmdFromRouterResponse(String routerResponse) {
String fn = "SshJcraftWrapper.stripOffCmdFromRouterResponse";
// appendToFile(debugLogFileName, fn+": routerResponse='"+routerResponse +"'\n");
int numTokens = rr.countTokens();
// debugLog.printRTAriDebug (fn, "Number of lines in the response from the router is:" +numTokens);
- if (numTokens > 1)
- {
+ if (numTokens > 1) {
rr.nextToken(); //Skip the first line.
- while (rr.hasMoreTokens())
- {
- sb.append(rr.nextToken()+'\n');
+ while (rr.hasMoreTokens()) {
+ sb.append(rr.nextToken() + '\n');
}
}
return (sb.toString());
}
- public void setRouterCommandType(String type)
- {
+ public void setRouterCommandType(String type) {
String fn = "SshJcraftWrapper.setRouterCommandType";
this.routerCmdType = type;
- debugLog.printRTAriDebug (fn, "Setting routerCmdType to a value of '"+type +"'");
+ debugLog.printRTAriDebug(fn, "Setting routerCmdType to a value of '" + type + "'");
}
- public String getLastFewLinesOfFile(File file, int linesToRead) throws FileNotFoundException, IOException
- {
+ public String getLastFewLinesOfFile(File file, int linesToRead) throws FileNotFoundException, IOException {
String fn = "SshJcraftWrapper.getLastFewLinesOfFile";
RandomAccessFile randomAccessFile = new RandomAccessFile(file, "r");
int lines = 0;
long length = file.length();
length--;
randomAccessFile.seek(length);
- for(long seek = length; seek >= 0; --seek)
- {
+ for (long seek = length; seek >= 0; --seek) {
randomAccessFile.seek(seek);
- char c = (char)randomAccessFile.read();
+ char c = (char) randomAccessFile.read();
builder.append(c);
- if(c == '\n')
- {
+ if (c == '\n') {
builder = builder.reverse();
// System.out.println(builder.toString());
tail = builder.toString() + tail;
lines++;
builder.setLength(0);
- if (lines == linesToRead)
- {
+ if (lines == linesToRead) {
break;
}
}
}
randomAccessFile.close();
- if(!jcraftReadSwConfigFileFromDisk())
- debugLog.printRTAriDebug (fn, "tail='"+tail +"'");
- appendToFile(debugLogFileName, "tail='"+tail +"'\n");
+ if (!jcraftReadSwConfigFileFromDisk()) {
+ debugLog.printRTAriDebug(fn, "tail='" + tail + "'");
+ }
+ appendToFile(debugLogFileName, "tail='" + tail + "'\n");
return tail;
}
- public boolean jcraftReadSwConfigFileFromDisk()
- {
- if (jcraftReadSwConfigFileFromDisk.exists())
- return(true);
- else
- return(false);
+ public boolean jcraftReadSwConfigFileFromDisk() {
+ if (jcraftReadSwConfigFileFromDisk.exists()) {
+ return (true);
+ } else {
+ return (false);
+ }
}
- public String getEquipNameCode()
- {
- return (equipNameCode);
+ public String getEquipNameCode() {
+ return (equipNameCode);
- }
+ }
- public void setEquipNameCode(String equipNameCode)
- {
- this.equipNameCode = equipNameCode;
- }
+ public void setEquipNameCode(String equipNameCode) {
+ this.equipNameCode = equipNameCode;
+ }
- public String getRouterName()
- {
- return(RouterName);
- }
+ public String getRouterName() {
+ return (RouterName);
+ }
- // Routine does reads until it has read 'nchars' or times out.
- public void receiveUntilBufferFlush (int ncharsSent, int timeout, String message) throws TimedOutException, IOException
- {
+ // Routine does reads until it has read 'nchars' or times out.
+ public void receiveUntilBufferFlush(int ncharsSent, int timeout, String message)
+ throws TimedOutException, IOException {
String fn = "SshJcraftWrapper.receiveUntilBufferFlush";
StringBuffer sb2 = new StringBuffer();
StringBuffer sbReceive = new StringBuffer();
- debugLog.printRTAriDebug (fn, "ncharsSent="+ncharsSent+" timeout="+timeout +" "+message);
- int ncharsTotalReceived = 0;
- int ncharsRead = 0;
- boolean flag = false;
- charactersFromBufferFlush.setLength(0);
-
- long deadline = new Date().getTime() + timeout;
- logMemoryUsage();
- try
- {
+ debugLog.printRTAriDebug(fn, "ncharsSent=" + ncharsSent + " timeout=" + timeout + " " + message);
+ int ncharsTotalReceived = 0;
+ int ncharsRead = 0;
+ boolean flag = false;
+ charactersFromBufferFlush.setLength(0);
+
+ long deadline = new Date().getTime() + timeout;
+ logMemoryUsage();
+ try {
session.setTimeout(timeout); // This is the socket timeout value.
- while (true)
- {
- if(new Date().getTime() > deadline)
- {
- debugLog.printRTAriDebug (fn, "Throwing a TimedOutException: time in routine has exceed our deadline: ncharsSent="+ncharsSent+" ncharsTotalReceived="+ncharsTotalReceived);
- flag = true;
+ while (true) {
+ if (new Date().getTime() > deadline) {
+ debugLog.printRTAriDebug(fn,
+ "Throwing a TimedOutException: time in routine has exceed our deadline: ncharsSent="
+ + ncharsSent + " ncharsTotalReceived=" + ncharsTotalReceived);
+ flag = true;
throw new TimedOutException("Timeout: time in routine has exceed our deadline");
}
- ncharsRead = reader.read(charBuffer, 0, BUFFER_SIZE);
- if (listener != null)
- listener.receivedString(String.copyValueOf(charBuffer,0,ncharsRead));
- appendToRouterFile("/tmp/"+RouterName, ncharsRead);
- ncharsTotalReceived = ncharsTotalReceived + ncharsRead;
- // debugLog.printRTAriDebug (fn, "::ncharsSent="+ncharsSent+" ncharsTotalReceived="+ncharsTotalReceived +" ncharsRead="+ncharsRead);
- if (ncharsTotalReceived >= ncharsSent)
- {
- debugLog.printRTAriDebug (fn, "Received the correct number of characters, ncharsSent="+ncharsSent +" ncharsTotalReceived="+ncharsTotalReceived);
- logMemoryUsage();
- return;
- }
+ ncharsRead = reader.read(charBuffer, 0, BUFFER_SIZE);
+ if (listener != null) {
+ listener.receivedString(String.copyValueOf(charBuffer, 0, ncharsRead));
+ }
+ appendToRouterFile("/tmp/" + RouterName, ncharsRead);
+ ncharsTotalReceived = ncharsTotalReceived + ncharsRead;
+ // debugLog.printRTAriDebug (fn, "::ncharsSent="+ncharsSent+" ncharsTotalReceived="+ncharsTotalReceived +" ncharsRead="+ncharsRead);
+ if (ncharsTotalReceived >= ncharsSent) {
+ debugLog.printRTAriDebug(fn,
+ "Received the correct number of characters, ncharsSent=" + ncharsSent + " ncharsTotalReceived="
+ + ncharsTotalReceived);
+ logMemoryUsage();
+ return;
+ }
}
- }
- catch (JSchException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an JSchException e="+e.toString());
- debugLog.printRTAriDebug (fn, "ncharsSent="+ncharsSent+" ncharsTotalReceived="+ncharsTotalReceived +" ncharsRead="+ncharsRead);
- throw new TimedOutException (e.toString());
+ } catch (JSchException e) {
+ debugLog.printRTAriDebug(fn, "Caught an JSchException e=" + e.toString());
+ debugLog.printRTAriDebug(fn,
+ "ncharsSent=" + ncharsSent + " ncharsTotalReceived=" + ncharsTotalReceived + " ncharsRead="
+ + ncharsRead);
+ throw new TimedOutException(e.toString());
}
}
- public String getHostName()
- {
- return(hostName);
- }
-
- public String getUserName()
- {
- return(userName);
- }
-
- public String getPassWord()
- {
- return(passWord);
- }
-
- public void sftpPut(String sourcePath, String destDirectory) throws IOException
- {
- String fn = "SshJcraftWrapper.sftp";
- try
- {
- Session sftpSession = jsch.getSession(userName, hostName, 22);
+ public String getHostName() {
+ return (hostName);
+ }
+
+ public String getUserName() {
+ return (userName);
+ }
+
+ public String getPassWord() {
+ return (passWord);
+ }
+
+ public void sftpPut(String sourcePath, String destDirectory) throws IOException {
+ String fn = "SshJcraftWrapper.sftp";
+ try {
+ Session sftpSession = jsch.getSession(userName, hostName, 22);
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- debugLog.printRTAriDebug (fn, "Sending "+sourcePath +" --> "+destDirectory);
- sftp.put(sourcePath, destDirectory, ChannelSftp.OVERWRITE);
- debugLog.printRTAriDebug (fn, "Sent successfully");
- sftpSession.disconnect();
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ debugLog.printRTAriDebug(fn, "Sending " + sourcePath + " --> " + destDirectory);
+ sftp.put(sourcePath, destDirectory, ChannelSftp.OVERWRITE);
+ debugLog.printRTAriDebug(fn, "Sent successfully");
+ sftpSession.disconnect();
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
-
- public void SftpPut(String stringOfData, String fullPathDest) throws IOException
- {
- String fn = "SshJcraftWrapper.Sftp";
- try
- {
- Session sftpSession = jsch.getSession(userName, hostName, 22);
+ public void SftpPut(String stringOfData, String fullPathDest) throws IOException {
+ String fn = "SshJcraftWrapper.Sftp";
+ try {
+ Session sftpSession = jsch.getSession(userName, hostName, 22);
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- InputStream is = new ByteArrayInputStream(stringOfData.getBytes());
- debugLog.printRTAriDebug (fn, "Sending stringOfData --> "+fullPathDest);
- sftp.put(is, fullPathDest, ChannelSftp.OVERWRITE);
- debugLog.printRTAriDebug (fn, "Sent successfully");
- sftpSession.disconnect();
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ InputStream is = new ByteArrayInputStream(stringOfData.getBytes());
+ debugLog.printRTAriDebug(fn, "Sending stringOfData --> " + fullPathDest);
+ sftp.put(is, fullPathDest, ChannelSftp.OVERWRITE);
+ debugLog.printRTAriDebug(fn, "Sent successfully");
+ sftpSession.disconnect();
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
-
- public String sftpGet(String fullFilePathName) throws IOException
- {
- String fn = "SshJcraftWrapper.Sftp";
- try
- {
- Session sftpSession = jsch.getSession(userName, hostName, 22);
+
+ public String sftpGet(String fullFilePathName) throws IOException {
+ String fn = "SshJcraftWrapper.Sftp";
+ try {
+ Session sftpSession = jsch.getSession(userName, hostName, 22);
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- InputStream in = null;
- in = sftp.get(fullFilePathName);
- String sftpFileString = readInputStreamAsString(in);
- debugLog.printRTAriDebug (fn, "Retreived successfully");
- // debugLog.printRTAriDebug (fn, "sftpFileString="+sftpFileString);
- sftpSession.disconnect();
- return(sftpFileString);
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ InputStream in = null;
+ in = sftp.get(fullFilePathName);
+ String sftpFileString = readInputStreamAsString(in);
+ debugLog.printRTAriDebug(fn, "Retreived successfully");
+ // debugLog.printRTAriDebug (fn, "sftpFileString="+sftpFileString);
+ sftpSession.disconnect();
+ return (sftpFileString);
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
-
- public static String readInputStreamAsString(InputStream in) throws IOException
- {
- BufferedInputStream bis = new BufferedInputStream(in);
- ByteArrayOutputStream buf = new ByteArrayOutputStream();
- int result = bis.read();
- while(result != -1)
- {
- byte b = (byte)result;
- buf.write(b);
- result = bis.read();
+
+ public static String readInputStreamAsString(InputStream in) throws IOException {
+ BufferedInputStream bis = new BufferedInputStream(in);
+ ByteArrayOutputStream buf = new ByteArrayOutputStream();
+ int result = bis.read();
+ while (result != -1) {
+ byte b = (byte) result;
+ buf.write(b);
+ result = bis.read();
+ }
+ return buf.toString();
}
- return buf.toString();
- }
- public void logMemoryUsage()
- {
- String fn = "SshJcraftWrapper.logMemoryUsage";
- int mb = 1024*1024;
+ public void logMemoryUsage() {
+ String fn = "SshJcraftWrapper.logMemoryUsage";
+ int mb = 1024 * 1024;
long usedMemory;
long maxMemoryAdvailable;
- long memoryLetfOnHeap;
+ long memoryLetfOnHeap;
maxMemoryAdvailable = (runtime.maxMemory() / mb);
- usedMemory = ((runtime.totalMemory()/mb) - (runtime.freeMemory()/mb));
- memoryLetfOnHeap = maxMemoryAdvailable - usedMemory;
- DebugLog.printAriDebug(fn, "maxMemoryAdvailable="+maxMemoryAdvailable +" usedMemory="+usedMemory +" memoryLetfOnHeap="+memoryLetfOnHeap);
- }
+ usedMemory = ((runtime.totalMemory() / mb) - (runtime.freeMemory() / mb));
+ memoryLetfOnHeap = maxMemoryAdvailable - usedMemory;
+ DebugLog.printAriDebug(fn,
+ "maxMemoryAdvailable=" + maxMemoryAdvailable + " usedMemory=" + usedMemory + " memoryLetfOnHeap="
+ + memoryLetfOnHeap);
+ }
- // ----------------------------------------------------------------------------
- // ----------------------------------------------------------------------------
- // ----------------------------------------------------------------------------
- // ----------------------------------------------------------------------------
+ // ----------------------------------------------------------------------------
+ // ----------------------------------------------------------------------------
+ // ----------------------------------------------------------------------------
+ // ----------------------------------------------------------------------------
- // User specifies the port number, and the subsystem
- public void connect (String hostname, String username, String password, String prompt, int timeOut, int portNum, String subsystem) throws IOException
- {
+ // User specifies the port number, and the subsystem
+ public void connect(String hostname, String username, String password, String prompt, int timeOut, int portNum,
+ String subsystem) throws IOException {
String fn = "SshJcraftWrapper.connect";
- debugLog.printRTAriDebug (fn, ":::Attempting to connect to "+hostname +" username="+username +" password="+password + " prompt='"+prompt +"' timeOut="+timeOut +" portNum="+portNum +" subsystem="+subsystem);
+ debugLog.printRTAriDebug(fn,
+ ":::Attempting to connect to " + hostname + " username=" + username + " password=" + password + " prompt='"
+ + prompt + "' timeOut=" + timeOut + " portNum=" + portNum + " subsystem=" + subsystem);
RouterName = hostname;
jsch = new JSch();
- try
- {
+ try {
session = jsch.getSession(username, hostname, portNum);
UserInfo ui = new MyUserInfo();
session.setPassword(password);
session.setUserInfo(ui);
- session.setConfig("StrictHostKeyChecking", "no");
+ session.setConfig("StrictHostKeyChecking", "no");
session.connect(timeOut);
- session.setServerAliveCountMax(0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
+ session.setServerAliveCountMax(
+ 0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
channel = session.openChannel("subsystem");
- ((ChannelSubsystem)channel).setSubsystem(subsystem);
- // ((ChannelSubsystem)channel).setPtyType("vt102");
- ((ChannelSubsystem)channel).setPty(true);
+ ((ChannelSubsystem) channel).setSubsystem(subsystem);
+ // ((ChannelSubsystem)channel).setPtyType("vt102");
+ ((ChannelSubsystem) channel).setPty(true);
inputStream = channel.getInputStream();
dis = new DataInputStream(inputStream);
reader = new BufferedReader(new InputStreamReader(dis), BUFFER_SIZE);
channel.connect();
- debugLog.printRTAriDebug (fn, "Successfully connected.");
- debugLog.printRTAriDebug (fn, "Five second sleep....");
- try { Thread.sleep(5000); } catch (java.lang.InterruptedException ee) { boolean ignore = true; }
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception. e="+e);
+ debugLog.printRTAriDebug(fn, "Successfully connected.");
+ debugLog.printRTAriDebug(fn, "Five second sleep....");
+ try {
+ Thread.sleep(5000);
+ } catch (java.lang.InterruptedException ee) {
+ boolean ignore = true;
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception. e=" + e);
throw new IOException(e.toString());
}
}
- public void connect (String hostName, String username, String password, int portNumber) throws IOException
- {
+ public void connect(String hostName, String username, String password, int portNumber) throws IOException {
String fn = "SshJcraftWrapper.connect";
jsch = new JSch();
- debugLog.printRTAriDebug (fn, "::Attempting to connect to "+hostName +" username="+username +" password="+password +" portNumber="+portNumber);
- debugLog.printRTAriDebug (fn, "Trace C");
+ debugLog.printRTAriDebug(fn,
+ "::Attempting to connect to " + hostName + " username=" + username + " password=" + password
+ + " portNumber=" + portNumber);
+ debugLog.printRTAriDebug(fn, "Trace C");
RouterName = hostName;
- this.hostName = hostName;
- userName = username;
- passWord = password;
- try
- {
- java.util.Properties config = new java.util.Properties();
- config.put("StrictHostKeyChecking", "no");
+ this.hostName = hostName;
+ userName = username;
+ passWord = password;
+ try {
+ java.util.Properties config = new java.util.Properties();
+ config.put("StrictHostKeyChecking", "no");
session = jsch.getSession(username, hostName, 22);
// session = jsch.getSession(username, hostName, portNumber);
UserInfo ui = new MyUserInfo();
- session.setConfig(config);
+ session.setConfig(config);
session.setPassword(password);
session.setUserInfo(ui);
session.connect(30000);
channel = session.openChannel("shell");
- session.setServerAliveCountMax(0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
- ((ChannelShell)channel).setPtyType("vt102");
+ session.setServerAliveCountMax(
+ 0); // If this is not set to '0', then socket timeout on all reads will not work!!!!
+ ((ChannelShell) channel).setPtyType("vt102");
inputStream = channel.getInputStream();
dis = new DataInputStream(inputStream);
reader = new BufferedReader(new InputStreamReader(dis), BUFFER_SIZE);
channel.connect();
- debugLog.printRTAriDebug (fn, "::Successfully connected.");
- debugLog.printRTAriDebug (fn, "::Flushing input buffer");
- try
- {
- receiveUntil(":~#", 9000, "No cmd was sent, just waiting, but we can stop on a '~#'");
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception::: Nothing to flush out.");
- }
+ debugLog.printRTAriDebug(fn, "::Successfully connected.");
+ debugLog.printRTAriDebug(fn, "::Flushing input buffer");
+ try {
+ receiveUntil(":~#", 9000, "No cmd was sent, just waiting, but we can stop on a '~#'");
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception::: Nothing to flush out.");
+ }
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception. e="+e);
- // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostName +" "+e);
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception. e=" + e);
+ // dbLog.storeData("ErrorMsg= Exception trying to connect to "+hostName +" "+e);
throw new IOException(e.toString());
}
}
- public void put(String sourcePath, String destDirectory) throws IOException
- {
- String fn = "SshJcraftWrapper.sftp";
- try
- {
- Session sftpSession = jsch.getSession(userName, hostName, 22);
+ public void put(String sourcePath, String destDirectory) throws IOException {
+ String fn = "SshJcraftWrapper.sftp";
+ try {
+ Session sftpSession = jsch.getSession(userName, hostName, 22);
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- debugLog.printRTAriDebug (fn, "Sending "+sourcePath +" --> "+destDirectory);
- sftp.put(sourcePath, destDirectory, ChannelSftp.OVERWRITE);
- debugLog.printRTAriDebug (fn, "Sent successfully");
- sftpSession.disconnect();
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ debugLog.printRTAriDebug(fn, "Sending " + sourcePath + " --> " + destDirectory);
+ sftp.put(sourcePath, destDirectory, ChannelSftp.OVERWRITE);
+ debugLog.printRTAriDebug(fn, "Sent successfully");
+ sftpSession.disconnect();
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
-
- public void put(InputStream is, String fullPathDest, String hostName, String userName, String passWord) throws IOException
- {
- String fn = "SshJcraftWrapper.put";
- Session sftpSession = null;
- try
- {
- debugLog.printRTAriDebug (fn, "userName="+userName +" hostName="+hostName +" passWord="+passWord);
- jsch = new JSch();
- java.util.Properties config = new java.util.Properties();
- config.put("StrictHostKeyChecking", "no");
- sftpSession = jsch.getSession(userName, hostName, 22);
+
+ public void put(InputStream is, String fullPathDest, String hostName, String userName, String passWord)
+ throws IOException {
+ String fn = "SshJcraftWrapper.put";
+ Session sftpSession = null;
+ try {
+ debugLog.printRTAriDebug(fn, "userName=" + userName + " hostName=" + hostName + " passWord=" + passWord);
+ jsch = new JSch();
+ java.util.Properties config = new java.util.Properties();
+ config.put("StrictHostKeyChecking", "no");
+ sftpSession = jsch.getSession(userName, hostName, 22);
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.setConfig(config);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- String oldFiles = fullPathDest +"*";
- debugLog.printRTAriDebug (fn, "Deleting old files --> "+oldFiles);
- try{
- sftp.rm(oldFiles);
- debugLog.printRTAriDebug (fn, "Sending stringOfData --> "+fullPathDest);
- }
- catch(SftpException sft){
- String exp = "No such file";
- if(sft.getMessage()!=null && sft.getMessage().contains(exp))
- debugLog.printRTAriDebug (fn, "No files found -- Continue");
- else{
- debugLog.printRTAriDebug (fn, "Exception while sftp.rm " + sft.getMessage());
- sft.printStackTrace();
- throw sft;
- }
- }
- sftp.put(is, fullPathDest, ChannelSftp.OVERWRITE);
- debugLog.printRTAriDebug (fn, "Sent successfully");
- sftpSession.disconnect();
- sftpSession = null;
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- sftpSession.disconnect();
- sftpSession = null;
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.setConfig(config);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ String oldFiles = fullPathDest + "*";
+ debugLog.printRTAriDebug(fn, "Deleting old files --> " + oldFiles);
+ try {
+ sftp.rm(oldFiles);
+ debugLog.printRTAriDebug(fn, "Sending stringOfData --> " + fullPathDest);
+ } catch (SftpException sft) {
+ String exp = "No such file";
+ if (sft.getMessage() != null && sft.getMessage().contains(exp)) {
+ debugLog.printRTAriDebug(fn, "No files found -- Continue");
+ } else {
+ debugLog.printRTAriDebug(fn, "Exception while sftp.rm " + sft.getMessage());
+ sft.printStackTrace();
+ throw sft;
+ }
+ }
+ sftp.put(is, fullPathDest, ChannelSftp.OVERWRITE);
+ debugLog.printRTAriDebug(fn, "Sent successfully");
+ sftpSession.disconnect();
+ sftpSession = null;
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ sftpSession.disconnect();
+ sftpSession = null;
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
-
-
- public String get(String fullFilePathName, String hostName, String userName, String passWord) throws IOException
- {
- String fn = "SshJcraftWrapper.get";
- Session sftpSession = null;
- try
- {
- debugLog.printRTAriDebug (fn, "userName="+userName +" hostName="+hostName +" passWord="+passWord);
- jsch = new JSch();
- sftpSession = jsch.getSession(userName, hostName, 22);
- java.util.Properties config = new java.util.Properties();
- config.put("StrictHostKeyChecking", "no");
+
+
+ public String get(String fullFilePathName, String hostName, String userName, String passWord) throws IOException {
+ String fn = "SshJcraftWrapper.get";
+ Session sftpSession = null;
+ try {
+ debugLog.printRTAriDebug(fn, "userName=" + userName + " hostName=" + hostName + " passWord=" + passWord);
+ jsch = new JSch();
+ sftpSession = jsch.getSession(userName, hostName, 22);
+ java.util.Properties config = new java.util.Properties();
+ config.put("StrictHostKeyChecking", "no");
UserInfo ui = new MyUserInfo();
sftpSession.setPassword(passWord);
sftpSession.setUserInfo(ui);
- sftpSession.setConfig(config);
- sftpSession.connect(30*1000);
- debugLog.printRTAriDebug (fn, "Opening up an sftp channel....");
- ChannelSftp sftp=(ChannelSftp)sftpSession.openChannel("sftp");
- debugLog.printRTAriDebug (fn, "Connecting....");
- sftp.connect();
- InputStream in = null;
- in = sftp.get(fullFilePathName);
- String sftpFileString = readInputStreamAsString(in);
- debugLog.printRTAriDebug (fn, "Retreived successfully");
- // debugLog.printRTAriDebug (fn, "sftpFileString="+sftpFileString);
- sftpSession.disconnect();
- sftpSession = null;
- return(sftpFileString);
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception, e="+e);
- sftpSession.disconnect();
- sftpSession = null;
- // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
+ sftpSession.setConfig(config);
+ sftpSession.connect(30 * 1000);
+ debugLog.printRTAriDebug(fn, "Opening up an sftp channel....");
+ ChannelSftp sftp = (ChannelSftp) sftpSession.openChannel("sftp");
+ debugLog.printRTAriDebug(fn, "Connecting....");
+ sftp.connect();
+ InputStream in = null;
+ in = sftp.get(fullFilePathName);
+ String sftpFileString = readInputStreamAsString(in);
+ debugLog.printRTAriDebug(fn, "Retreived successfully");
+ // debugLog.printRTAriDebug (fn, "sftpFileString="+sftpFileString);
+ sftpSession.disconnect();
+ sftpSession = null;
+ return (sftpFileString);
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception, e=" + e);
+ sftpSession.disconnect();
+ sftpSession = null;
+ // dbLog.storeData("ErrorMsg= sftp threw an Exception. error is:"+e);
throw new IOException(e.toString());
+ }
}
- }
- public String send(String cmd, String delimiter) throws IOException
- {
+ public String send(String cmd, String delimiter) throws IOException {
String fn = "SshJcraftWrapper.send";
OutputStream out = channel.getOutputStream();
DataOutputStream dos = new DataOutputStream(out);
- if ((cmd.charAt(cmd.length() - 1) != '\n') && (cmd.charAt(cmd.length() - 1) != '\r'))
+ if ((cmd.charAt(cmd.length() - 1) != '\n') && (cmd.charAt(cmd.length() - 1) != '\r')) {
cmd += "\n";
- int length = cmd.length();
- int i = -1;
- int nchars = 300000;
- int ncharsTotalSent = 0;
- int ncharsSent = 0;
-
- debugLog.printRTAriDebug (fn, "Length of cmd is:" +length); // 2,937,706
- debugLog.printRTAriDebug (fn, "Length of cmd is:" +length); // 2,937,706
- try
- {
- if (length > 600000)
- {
- int timeout = 9000;
- for (i=0; i<length; i+=nchars)
- {
- String Cmd = cmd.substring(i, Math.min(length, i + nchars));
- ncharsSent = Cmd.length();
- ncharsTotalSent = ncharsTotalSent + Cmd.length();
- debugLog.printRTAriDebug (fn, "i="+i +" Sending Cmd: ncharsSent="+ncharsSent);
- dos.writeBytes(Cmd);
- dos.flush();
- try
- {
- debugLog.printRTAriDebug (fn, ":::i="+i +" length="+length);
- if (ncharsSent < length)
- receiveUntilBufferFlush (ncharsSent, timeout, "buffer flush i="+i);
- else
- {
- debugLog.printRTAriDebug (fn, "i="+i +" No Waiting this time....");
+ }
+ int length = cmd.length();
+ int i = -1;
+ int nchars = 300000;
+ int ncharsTotalSent = 0;
+ int ncharsSent = 0;
+
+ debugLog.printRTAriDebug(fn, "Length of cmd is:" + length); // 2,937,706
+ debugLog.printRTAriDebug(fn, "Length of cmd is:" + length); // 2,937,706
+ try {
+ if (length > 600000) {
+ int timeout = 9000;
+ for (i = 0; i < length; i += nchars) {
+ String Cmd = cmd.substring(i, Math.min(length, i + nchars));
+ ncharsSent = Cmd.length();
+ ncharsTotalSent = ncharsTotalSent + Cmd.length();
+ debugLog.printRTAriDebug(fn, "i=" + i + " Sending Cmd: ncharsSent=" + ncharsSent);
+ dos.writeBytes(Cmd);
dos.flush();
+ try {
+ debugLog.printRTAriDebug(fn, ":::i=" + i + " length=" + length);
+ if (ncharsSent < length) {
+ receiveUntilBufferFlush(ncharsSent, timeout, "buffer flush i=" + i);
+ } else {
+ debugLog.printRTAriDebug(fn, "i=" + i + " No Waiting this time....");
+ dos.flush();
+ }
+ } catch (Exception e) {
+ debugLog.printRTAriDebug(fn, "Caught an Exception: Nothing to flush out.");
+ }
+ }
+ } else {
+ debugLog.printRTAriDebug(fn, "Before executing the dos.writeBytes");
+ dos.writeBytes(cmd);
}
- }
- catch (Exception e)
- {
- debugLog.printRTAriDebug (fn, "Caught an Exception: Nothing to flush out.");
- }
- }
- }
- else
- {
- debugLog.printRTAriDebug (fn, "Before executing the dos.writeBytes");
- dos.writeBytes(cmd);
- }
- dos.flush();
- // Now lets get the response.
- String response = receiveUntil (delimiter, 300000, cmd);
- debugLog.printRTAriDebug (fn, "Leaving method");
- return(response);
- }
- catch (IOException e)
- {
- debugLog.printRTAriDebug (fn, "Caught an IOException. e="+e);
+ dos.flush();
+ // Now lets get the response.
+ String response = receiveUntil(delimiter, 300000, cmd);
+ debugLog.printRTAriDebug(fn, "Leaving method");
+ return (response);
+ } catch (IOException e) {
+ debugLog.printRTAriDebug(fn, "Caught an IOException. e=" + e);
throw new IOException(e.toString());
}
}
Code Review / appc.git / commitdiff