Feature/usi OVS switch #521
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,169 @@ | ||
| package daq.usi; | ||
|
|
||
| import java.util.HashMap; | ||
| import java.util.regex.Matcher; | ||
| import java.util.regex.Pattern; | ||
|
|
||
|
|
||
| public abstract class BaseSwitchController implements SwitchController { | ||
| /** | ||
| * Terminal Prompt ends with '#' when enabled, '>' when not enabled. | ||
| */ | ||
| public static final String CONSOLE_PROMPT_ENDING_ENABLED = "#"; | ||
| public static final String CONSOLE_PROMPT_ENDING_LOGIN = ">"; | ||
| public static final int TELNET_PORT = 23; | ||
|
|
||
| // Define Common Variables Required for All Switch Interrogators | ||
| protected SwitchTelnetClientSocket telnetClientSocket; | ||
| protected Thread telnetClientSocketThread; | ||
| protected String remoteIpAddress; | ||
| protected boolean debug; | ||
| protected String username; | ||
| protected String password; | ||
| protected boolean userAuthorised = false; | ||
| protected boolean userEnabled = false; | ||
| protected String hostname = null; | ||
| protected boolean commandPending = false; | ||
|
|
||
| public BaseSwitchController(String remoteIpAddress, String username, | ||
| String password) { | ||
|
Collaborator
There was a problem hiding this comment. check your style settings -- this should be hanging indent 4. Did it pass stickler/lint?
Collaborator
Author
There was a problem hiding this comment. It passes stickler.mostly likely it means that rule is not configured.
Collaborator
Author
There was a problem hiding this comment. Actually intellij won't even let me move this line to a less indented position. Is this a java syntax issue? |
||
| this(remoteIpAddress, username, password, false); | ||
| } | ||
|
|
||
| /** | ||
| * Abstract Switch controller. Override this class for switch specific implementation | ||
| * | ||
| * @param remoteIpAddress switch ip address | ||
| * @param username switch username | ||
| * @param password switch password | ||
| * @param debug for verbose logging | ||
| */ | ||
| public BaseSwitchController( | ||
| String remoteIpAddress, String username, String password, boolean debug) { | ||
| this.remoteIpAddress = remoteIpAddress; | ||
| this.username = username; | ||
| this.password = password; | ||
| this.debug = debug; | ||
| telnetClientSocket = | ||
| new SwitchTelnetClientSocket(remoteIpAddress, TELNET_PORT, this, debug); | ||
| } | ||
|
|
||
| /** | ||
| * Map a simple table containing a header and 1 row of data to a hashmap | ||
| * This method will also attempt to correct for mis-aligned tabular data as well as empty | ||
| * columns values. | ||
| * | ||
| * @param rawPacket Raw table response from a switch command | ||
| * @param colNames Array containing the names of the columns in the response | ||
| * @param mapNames Array containing names key names to map values to | ||
| * @return A HashMap containing the values mapped to the key names provided in the mapNames array | ||
| */ | ||
| protected static HashMap<String, String> mapSimpleTable( | ||
| String rawPacket, String[] colNames, String[] mapNames) { | ||
| HashMap<String, String> colMap = new HashMap<>(); | ||
| String[] lines = rawPacket.split("\n"); | ||
| if (lines.length > 0) { | ||
| String header = lines[0].trim(); | ||
| String values = lines[1].trim(); | ||
| int lastSectionEnd = 0; | ||
| for (int i = 0; i < colNames.length; ++i) { | ||
| int secStart = lastSectionEnd; | ||
| int secEnd; | ||
| if ((i + 1) >= colNames.length) { | ||
| // Resolving last column | ||
| secEnd = values.length(); | ||
| } else { | ||
| // Tabular data is not always reported in perfectly alignment, we need to calculate the | ||
| // correct values based off of the sections in between white spaces | ||
| int firstWhiteSpace = | ||
| getFirstWhiteSpace(values.substring(lastSectionEnd)) + lastSectionEnd; | ||
| int lastWhiteSpace = | ||
| getIndexOfNonWhitespaceAfterWhitespace(values.substring(firstWhiteSpace)) | ||
| + firstWhiteSpace; | ||
| int nextHeaderStart = header.indexOf(colNames[i + 1]); | ||
| secEnd = Math.min(lastWhiteSpace, nextHeaderStart); | ||
| } | ||
| lastSectionEnd = secEnd; | ||
| String sectionRaw = values.substring(secStart, secEnd).trim(); | ||
| colMap.put(mapNames[i], sectionRaw); | ||
| } | ||
| } | ||
| return colMap; | ||
| } | ||
|
|
||
| private static int getFirstWhiteSpace(String string) { | ||
| char[] characters = string.toCharArray(); | ||
| for (int i = 0; i < string.length(); i++) { | ||
| if (Character.isWhitespace(characters[i])) { | ||
| return i; | ||
| } | ||
| } | ||
| return -1; | ||
| } | ||
|
|
||
| private static int getIndexOfNonWhitespaceAfterWhitespace(String string) { | ||
| char[] characters = string.toCharArray(); | ||
| boolean lastWhitespace = false; | ||
| for (int i = 0; i < string.length(); i++) { | ||
| if (Character.isWhitespace(characters[i])) { | ||
| lastWhitespace = true; | ||
| } else if (lastWhitespace) { | ||
| return i; | ||
| } | ||
| } | ||
| return -1; | ||
| } | ||
|
|
||
| protected boolean containsPrompt(String consoleData) { | ||
| // Prompts usually hostname# or hostname(config)# | ||
| Pattern r = Pattern.compile(hostname + "\\s*(\\(.+\\))?" + CONSOLE_PROMPT_ENDING_ENABLED, 'g'); | ||
| Matcher m = r.matcher(consoleData); | ||
| return m.find(); | ||
| } | ||
|
|
||
| protected boolean promptReady(String consoleData) { | ||
| // Prompts usually hostname# or hostname(config)# | ||
| Pattern r = Pattern.compile(hostname + "\\s*(\\(.+\\))?" + CONSOLE_PROMPT_ENDING_ENABLED + "$"); | ||
| Matcher m = r.matcher(consoleData); | ||
| return m.find(); | ||
| } | ||
|
|
||
| /** | ||
| * Receive the raw data packet from the telnet connection and process accordingly. | ||
| * | ||
| * @param consoleData Most recent data read from the telnet socket buffer | ||
| */ | ||
| public void receiveData(String consoleData) { | ||
| if (debug) { | ||
| System.out.println( | ||
| java.time.LocalTime.now() + " receivedData:\t" + consoleData); | ||
| } | ||
| if (consoleData != null) { | ||
| try { | ||
| consoleData = consoleData.trim(); | ||
| if (!userAuthorised) { | ||
| handleLoginMessage(consoleData); | ||
| } else if (!userEnabled) { | ||
| handleEnableMessage(consoleData); | ||
| } else { | ||
| parseData(consoleData); | ||
| } | ||
| } catch (Exception e) { | ||
| telnetClientSocket.disposeConnection(); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| protected abstract void parseData(String consoleData) throws Exception; | ||
|
|
||
| protected abstract void handleLoginMessage(String consoleData) throws Exception; | ||
|
|
||
| protected abstract void handleEnableMessage(String consoleData) throws Exception; | ||
|
|
||
| @Override | ||
| public void start() { | ||
| telnetClientSocketThread = new Thread(telnetClientSocket); | ||
| telnetClientSocketThread.start(); | ||
| } | ||
| } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,201 +1,21 @@ | ||
| package daq.usi; | ||
|
|
||
| import grpc.InterfaceResponse; | ||
| import grpc.PowerResponse; | ||
| import grpc.SwitchActionResponse; | ||
|
|
||
| public interface SwitchController { | ||
|
|
||
| void getPower(int devicePort, ResponseHandler<PowerResponse> handler) throws Exception; | ||
|
|
||
| void getInterface(int devicePort, ResponseHandler<InterfaceResponse> handler) | ||
| throws Exception; | ||
|
|
||
| void connect(int devicePort, ResponseHandler<SwitchActionResponse> handler) | ||
| throws Exception; | ||
|
|
||
| void disconnect(int devicePort, ResponseHandler<SwitchActionResponse> handler) | ||
| throws Exception; | ||
|
|
||
| void start(); | ||
| } |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.