Padraig | b21b676 | 2016-09-21 14:59:02 +0100 | [diff] [blame^] | 1 | #!/usr/bin/python |
| 2 | ''' |
| 3 | Copyright 2016 Intel Corporation |
Ed Warnicke | 33007f5 | 2016-04-04 14:37:21 -0700 | [diff] [blame] | 4 | |
Padraig | b21b676 | 2016-09-21 14:59:02 +0100 | [diff] [blame^] | 5 | Licensed under the Apache License, Version 2.0 (the "License"); |
| 6 | you may not use this file except in compliance with the License. |
| 7 | You may obtain a copy of the License at |
| 8 | |
| 9 | http://www.apache.org/licenses/LICENSE-2.0 |
| 10 | |
| 11 | Unless required by applicable law or agreed to in writing, software |
| 12 | distributed under the License is distributed on an "AS IS" BASIS, |
| 13 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 14 | See the License for the specific language governing permissions and |
| 15 | limitations under the License. |
| 16 | ''' |
| 17 | |
| 18 | from cmd import Cmd |
| 19 | import os |
| 20 | import subprocess |
| 21 | import re |
| 22 | import sys |
| 23 | try: |
| 24 | import readline |
| 25 | except ImportError: |
| 26 | readline = None |
| 27 | |
| 28 | persishist = os.path.expanduser('~/.vpphistory') |
| 29 | persishist_size = 1000 |
| 30 | if not persishist: |
| 31 | os.mknod(persishist, stat.S_IFREG) |
| 32 | |
| 33 | class Vppctl(Cmd): |
| 34 | |
| 35 | def historyWrite(self): |
| 36 | if readline: |
| 37 | readline.set_history_length(persishist_size) |
| 38 | readline.write_history_file(persishist) |
| 39 | |
| 40 | def runVat(self, line): |
| 41 | input_prefix = "exec " |
| 42 | input_command = input_prefix + line |
| 43 | line_remove = '^load_one_plugin:' |
| 44 | s = '\n' |
| 45 | |
| 46 | vpp_process = subprocess.Popen(['sudo', 'vpp_api_test'], |
| 47 | stderr=subprocess.PIPE, |
| 48 | stdin=subprocess.PIPE, |
| 49 | stdout=subprocess.PIPE) |
| 50 | stdout_value = vpp_process.communicate(input_command)[0] |
| 51 | |
| 52 | buffer_stdout = stdout_value.splitlines() |
| 53 | |
| 54 | buffer_stdout[:] = [b for b in buffer_stdout |
| 55 | if line_remove not in b] |
| 56 | |
| 57 | for i, num in enumerate(buffer_stdout): |
| 58 | buffer_stdout[i] = num.replace('vat# ','') |
| 59 | |
| 60 | stdout_value = s.join(buffer_stdout) |
| 61 | print stdout_value |
| 62 | |
| 63 | def do_help(self, line): |
| 64 | self.runVat("help") |
| 65 | |
| 66 | def default(self, line): |
| 67 | self.runVat(line) |
| 68 | |
| 69 | def do_exit(self, line): |
| 70 | self.historyWrite() |
| 71 | |
| 72 | raise SystemExit |
| 73 | |
| 74 | def emptyline(self): |
| 75 | pass |
| 76 | |
| 77 | def preloop(self): |
| 78 | if readline and os.path.exists(persishist): |
| 79 | readline.read_history_file(persishist) |
| 80 | |
| 81 | def postcmd(self, stop, line): |
| 82 | self.historyWrite() |
| 83 | |
| 84 | if __name__ == '__main__': |
| 85 | command_args = sys.argv |
| 86 | |
| 87 | if not len(command_args) > 1: |
| 88 | prompt = Vppctl() |
| 89 | prompt.prompt = 'vpp# ' |
| 90 | prompt.cmdloop("Starting Vppctl...") |
| 91 | else: |
| 92 | del command_args[0] |
| 93 | stdout_value = " ".join(command_args) |
| 94 | VatAddress = Vppctl() |
| 95 | VatAddress.runVat(stdout_value) |
| 96 | |