QMP/qemu-ga-client scripts/qmp/qemu-ga-client

QMP/qmp scripts/qmp/qmp

-286

QMP/qmp-shell

··· 1 1 - #!/usr/bin/python 2 2 - # 3 3 - # Low-level QEMU shell on top of QMP. 4 4 - # 5 5 - # Copyright (C) 2009, 2010 Red Hat Inc. 6 6 - # 7 7 - # Authors: 8 8 - # Luiz Capitulino <lcapitulino@redhat.com> 9 9 - # 10 10 - # This work is licensed under the terms of the GNU GPL, version 2. See 11 11 - # the COPYING file in the top-level directory. 12 12 - # 13 13 - # Usage: 14 14 - # 15 15 - # Start QEMU with: 16 16 - # 17 17 - # # qemu [...] -qmp unix:./qmp-sock,server 18 18 - # 19 19 - # Run the shell: 20 20 - # 21 21 - # $ qmp-shell ./qmp-sock 22 22 - # 23 23 - # Commands have the following format: 24 24 - # 25 25 - # < command-name > [ arg-name1=arg1 ] ... [ arg-nameN=argN ] 26 26 - # 27 27 - # For example: 28 28 - # 29 29 - # (QEMU) device_add driver=e1000 id=net1 30 30 - # {u'return': {}} 31 31 - # (QEMU) 32 32 - 33 33 - import qmp 34 34 - import readline 35 35 - import sys 36 36 - import pprint 37 37 - 38 38 - class QMPCompleter(list): 39 39 - def complete(self, text, state): 40 40 - for cmd in self: 41 41 - if cmd.startswith(text): 42 42 - if not state: 43 43 - return cmd 44 44 - else: 45 45 - state -= 1 46 46 - 47 47 - class QMPShellError(Exception): 48 48 - pass 49 49 - 50 50 - class QMPShellBadPort(QMPShellError): 51 51 - pass 52 52 - 53 53 - # TODO: QMPShell's interface is a bit ugly (eg. _fill_completion() and 54 54 - # _execute_cmd()). Let's design a better one. 55 55 - class QMPShell(qmp.QEMUMonitorProtocol): 56 56 - def __init__(self, address, pp=None): 57 57 - qmp.QEMUMonitorProtocol.__init__(self, self.__get_address(address)) 58 58 - self._greeting = None 59 59 - self._completer = None 60 60 - self._pp = pp 61 61 - 62 62 - def __get_address(self, arg): 63 63 - """ 64 64 - Figure out if the argument is in the port:host form, if it's not it's 65 65 - probably a file path. 66 66 - """ 67 67 - addr = arg.split(':') 68 68 - if len(addr) == 2: 69 69 - try: 70 70 - port = int(addr[1]) 71 71 - except ValueError: 72 72 - raise QMPShellBadPort 73 73 - return ( addr[0], port ) 74 74 - # socket path 75 75 - return arg 76 76 - 77 77 - def _fill_completion(self): 78 78 - for cmd in self.cmd('query-commands')['return']: 79 79 - self._completer.append(cmd['name']) 80 80 - 81 81 - def __completer_setup(self): 82 82 - self._completer = QMPCompleter() 83 83 - self._fill_completion() 84 84 - readline.set_completer(self._completer.complete) 85 85 - readline.parse_and_bind("tab: complete") 86 86 - # XXX: default delimiters conflict with some command names (eg. query-), 87 87 - # clearing everything as it doesn't seem to matter 88 88 - readline.set_completer_delims('') 89 89 - 90 90 - def __build_cmd(self, cmdline): 91 91 - """ 92 92 - Build a QMP input object from a user provided command-line in the 93 93 - following format: 94 94 - 95 95 - < command-name > [ arg-name1=arg1 ] ... [ arg-nameN=argN ] 96 96 - """ 97 97 - cmdargs = cmdline.split() 98 98 - qmpcmd = { 'execute': cmdargs[0], 'arguments': {} } 99 99 - for arg in cmdargs[1:]: 100 100 - opt = arg.split('=') 101 101 - try: 102 102 - if(len(opt) > 2): 103 103 - opt[1] = '='.join(opt[1:]) 104 104 - value = int(opt[1]) 105 105 - except ValueError: 106 106 - if opt[1] == 'true': 107 107 - value = True 108 108 - elif opt[1] == 'false': 109 109 - value = False 110 110 - else: 111 111 - value = opt[1] 112 112 - qmpcmd['arguments'][opt[0]] = value 113 113 - return qmpcmd 114 114 - 115 115 - def _execute_cmd(self, cmdline): 116 116 - try: 117 117 - qmpcmd = self.__build_cmd(cmdline) 118 118 - except: 119 119 - print 'command format: <command-name> ', 120 120 - print '[arg-name1=arg1] ... [arg-nameN=argN]' 121 121 - return True 122 122 - resp = self.cmd_obj(qmpcmd) 123 123 - if resp is None: 124 124 - print 'Disconnected' 125 125 - return False 126 126 - 127 127 - if self._pp is not None: 128 128 - self._pp.pprint(resp) 129 129 - else: 130 130 - print resp 131 131 - return True 132 132 - 133 133 - def connect(self): 134 134 - self._greeting = qmp.QEMUMonitorProtocol.connect(self) 135 135 - self.__completer_setup() 136 136 - 137 137 - def show_banner(self, msg='Welcome to the QMP low-level shell!'): 138 138 - print msg 139 139 - version = self._greeting['QMP']['version']['qemu'] 140 140 - print 'Connected to QEMU %d.%d.%d\n' % (version['major'],version['minor'],version['micro']) 141 141 - 142 142 - def read_exec_command(self, prompt): 143 143 - """ 144 144 - Read and execute a command. 145 145 - 146 146 - @return True if execution was ok, return False if disconnected. 147 147 - """ 148 148 - try: 149 149 - cmdline = raw_input(prompt) 150 150 - except EOFError: 151 151 - print 152 152 - return False 153 153 - if cmdline == '': 154 154 - for ev in self.get_events(): 155 155 - print ev 156 156 - self.clear_events() 157 157 - return True 158 158 - else: 159 159 - return self._execute_cmd(cmdline) 160 160 - 161 161 - class HMPShell(QMPShell): 162 162 - def __init__(self, address): 163 163 - QMPShell.__init__(self, address) 164 164 - self.__cpu_index = 0 165 165 - 166 166 - def __cmd_completion(self): 167 167 - for cmd in self.__cmd_passthrough('help')['return'].split('\r\n'): 168 168 - if cmd and cmd[0] != '[' and cmd[0] != '\t': 169 169 - name = cmd.split()[0] # drop help text 170 170 - if name == 'info': 171 171 - continue 172 172 - if name.find('|') != -1: 173 173 - # Command in the form 'foobar|f' or 'f|foobar', take the 174 174 - # full name 175 175 - opt = name.split('|') 176 176 - if len(opt[0]) == 1: 177 177 - name = opt[1] 178 178 - else: 179 179 - name = opt[0] 180 180 - self._completer.append(name) 181 181 - self._completer.append('help ' + name) # help completion 182 182 - 183 183 - def __info_completion(self): 184 184 - for cmd in self.__cmd_passthrough('info')['return'].split('\r\n'): 185 185 - if cmd: 186 186 - self._completer.append('info ' + cmd.split()[1]) 187 187 - 188 188 - def __other_completion(self): 189 189 - # special cases 190 190 - self._completer.append('help info') 191 191 - 192 192 - def _fill_completion(self): 193 193 - self.__cmd_completion() 194 194 - self.__info_completion() 195 195 - self.__other_completion() 196 196 - 197 197 - def __cmd_passthrough(self, cmdline, cpu_index = 0): 198 198 - return self.cmd_obj({ 'execute': 'human-monitor-command', 'arguments': 199 199 - { 'command-line': cmdline, 200 200 - 'cpu-index': cpu_index } }) 201 201 - 202 202 - def _execute_cmd(self, cmdline): 203 203 - if cmdline.split()[0] == "cpu": 204 204 - # trap the cpu command, it requires special setting 205 205 - try: 206 206 - idx = int(cmdline.split()[1]) 207 207 - if not 'return' in self.__cmd_passthrough('info version', idx): 208 208 - print 'bad CPU index' 209 209 - return True 210 210 - self.__cpu_index = idx 211 211 - except ValueError: 212 212 - print 'cpu command takes an integer argument' 213 213 - return True 214 214 - resp = self.__cmd_passthrough(cmdline, self.__cpu_index) 215 215 - if resp is None: 216 216 - print 'Disconnected' 217 217 - return False 218 218 - assert 'return' in resp or 'error' in resp 219 219 - if 'return' in resp: 220 220 - # Success 221 221 - if len(resp['return']) > 0: 222 222 - print resp['return'], 223 223 - else: 224 224 - # Error 225 225 - print '%s: %s' % (resp['error']['class'], resp['error']['desc']) 226 226 - return True 227 227 - 228 228 - def show_banner(self): 229 229 - QMPShell.show_banner(self, msg='Welcome to the HMP shell!') 230 230 - 231 231 - def die(msg): 232 232 - sys.stderr.write('ERROR: %s\n' % msg) 233 233 - sys.exit(1) 234 234 - 235 235 - def fail_cmdline(option=None): 236 236 - if option: 237 237 - sys.stderr.write('ERROR: bad command-line option \'%s\'\n' % option) 238 238 - sys.stderr.write('qemu-shell [ -p ] [ -H ] < UNIX socket path> | < TCP address:port >\n') 239 239 - sys.exit(1) 240 240 - 241 241 - def main(): 242 242 - addr = '' 243 243 - qemu = None 244 244 - hmp = False 245 245 - pp = None 246 246 - 247 247 - try: 248 248 - for arg in sys.argv[1:]: 249 249 - if arg == "-H": 250 250 - if qemu is not None: 251 251 - fail_cmdline(arg) 252 252 - hmp = True 253 253 - elif arg == "-p": 254 254 - if pp is not None: 255 255 - fail_cmdline(arg) 256 256 - pp = pprint.PrettyPrinter(indent=4) 257 257 - else: 258 258 - if qemu is not None: 259 259 - fail_cmdline(arg) 260 260 - if hmp: 261 261 - qemu = HMPShell(arg) 262 262 - else: 263 263 - qemu = QMPShell(arg, pp) 264 264 - addr = arg 265 265 - 266 266 - if qemu is None: 267 267 - fail_cmdline() 268 268 - except QMPShellBadPort: 269 269 - die('bad port number in command-line') 270 270 - 271 271 - try: 272 272 - qemu.connect() 273 273 - except qmp.QMPConnectError: 274 274 - die('Didn\'t get QMP greeting message') 275 275 - except qmp.QMPCapabilitiesError: 276 276 - die('Could not negotiate capabilities') 277 277 - except qemu.error: 278 278 - die('Could not connect to %s' % addr) 279 279 - 280 280 - qemu.show_banner() 281 281 - while qemu.read_exec_command('(QEMU) '): 282 282 - pass 283 283 - qemu.close() 284 284 - 285 285 - if __name__ == '__main__': 286 286 - main()

+1 -1

QMP/qmp.py scripts/qmp/qmp.py

··· 1 1 # QEMU Monitor Protocol Python class 2 2 - # 2 2 + # 3 3 # Copyright (C) 2009, 2010 Red Hat Inc. 4 4 # 5 5 # Authors:

QMP/qom-fuse scripts/qmp/qom-fuse

QMP/qom-get scripts/qmp/qom-get

QMP/qom-list scripts/qmp/qom-list

QMP/qom-set scripts/qmp/qom-set

+286

scripts/qmp/qmp-shell

··· 1 1 + #!/usr/bin/python 2 2 + # 3 3 + # Low-level QEMU shell on top of QMP. 4 4 + # 5 5 + # Copyright (C) 2009, 2010 Red Hat Inc. 6 6 + # 7 7 + # Authors: 8 8 + # Luiz Capitulino <lcapitulino@redhat.com> 9 9 + # 10 10 + # This work is licensed under the terms of the GNU GPL, version 2. See 11 11 + # the COPYING file in the top-level directory. 12 12 + # 13 13 + # Usage: 14 14 + # 15 15 + # Start QEMU with: 16 16 + # 17 17 + # # qemu [...] -qmp unix:./qmp-sock,server 18 18 + # 19 19 + # Run the shell: 20 20 + # 21 21 + # $ qmp-shell ./qmp-sock 22 22 + # 23 23 + # Commands have the following format: 24 24 + # 25 25 + # < command-name > [ arg-name1=arg1 ] ... [ arg-nameN=argN ] 26 26 + # 27 27 + # For example: 28 28 + # 29 29 + # (QEMU) device_add driver=e1000 id=net1 30 30 + # {u'return': {}} 31 31 + # (QEMU) 32 32 + 33 33 + import qmp 34 34 + import readline 35 35 + import sys 36 36 + import pprint 37 37 + 38 38 + class QMPCompleter(list): 39 39 + def complete(self, text, state): 40 40 + for cmd in self: 41 41 + if cmd.startswith(text): 42 42 + if not state: 43 43 + return cmd 44 44 + else: 45 45 + state -= 1 46 46 + 47 47 + class QMPShellError(Exception): 48 48 + pass 49 49 + 50 50 + class QMPShellBadPort(QMPShellError): 51 51 + pass 52 52 + 53 53 + # TODO: QMPShell's interface is a bit ugly (eg. _fill_completion() and 54 54 + # _execute_cmd()). Let's design a better one. 55 55 + class QMPShell(qmp.QEMUMonitorProtocol): 56 56 + def __init__(self, address, pp=None): 57 57 + qmp.QEMUMonitorProtocol.__init__(self, self.__get_address(address)) 58 58 + self._greeting = None 59 59 + self._completer = None 60 60 + self._pp = pp 61 61 + 62 62 + def __get_address(self, arg): 63 63 + """ 64 64 + Figure out if the argument is in the port:host form, if it's not it's 65 65 + probably a file path. 66 66 + """ 67 67 + addr = arg.split(':') 68 68 + if len(addr) == 2: 69 69 + try: 70 70 + port = int(addr[1]) 71 71 + except ValueError: 72 72 + raise QMPShellBadPort 73 73 + return ( addr[0], port ) 74 74 + # socket path 75 75 + return arg 76 76 + 77 77 + def _fill_completion(self): 78 78 + for cmd in self.cmd('query-commands')['return']: 79 79 + self._completer.append(cmd['name']) 80 80 + 81 81 + def __completer_setup(self): 82 82 + self._completer = QMPCompleter() 83 83 + self._fill_completion() 84 84 + readline.set_completer(self._completer.complete) 85 85 + readline.parse_and_bind("tab: complete") 86 86 + # XXX: default delimiters conflict with some command names (eg. query-), 87 87 + # clearing everything as it doesn't seem to matter 88 88 + readline.set_completer_delims('') 89 89 + 90 90 + def __build_cmd(self, cmdline): 91 91 + """ 92 92 + Build a QMP input object from a user provided command-line in the 93 93 + following format: 94 94 + 95 95 + < command-name > [ arg-name1=arg1 ] ... [ arg-nameN=argN ] 96 96 + """ 97 97 + cmdargs = cmdline.split() 98 98 + qmpcmd = { 'execute': cmdargs[0], 'arguments': {} } 99 99 + for arg in cmdargs[1:]: 100 100 + opt = arg.split('=') 101 101 + try: 102 102 + if(len(opt) > 2): 103 103 + opt[1] = '='.join(opt[1:]) 104 104 + value = int(opt[1]) 105 105 + except ValueError: 106 106 + if opt[1] == 'true': 107 107 + value = True 108 108 + elif opt[1] == 'false': 109 109 + value = False 110 110 + else: 111 111 + value = opt[1] 112 112 + qmpcmd['arguments'][opt[0]] = value 113 113 + return qmpcmd 114 114 + 115 115 + def _execute_cmd(self, cmdline): 116 116 + try: 117 117 + qmpcmd = self.__build_cmd(cmdline) 118 118 + except: 119 119 + print 'command format: <command-name> ', 120 120 + print '[arg-name1=arg1] ... [arg-nameN=argN]' 121 121 + return True 122 122 + resp = self.cmd_obj(qmpcmd) 123 123 + if resp is None: 124 124 + print 'Disconnected' 125 125 + return False 126 126 + 127 127 + if self._pp is not None: 128 128 + self._pp.pprint(resp) 129 129 + else: 130 130 + print resp 131 131 + return True 132 132 + 133 133 + def connect(self): 134 134 + self._greeting = qmp.QEMUMonitorProtocol.connect(self) 135 135 + self.__completer_setup() 136 136 + 137 137 + def show_banner(self, msg='Welcome to the QMP low-level shell!'): 138 138 + print msg 139 139 + version = self._greeting['QMP']['version']['qemu'] 140 140 + print 'Connected to QEMU %d.%d.%d\n' % (version['major'],version['minor'],version['micro']) 141 141 + 142 142 + def read_exec_command(self, prompt): 143 143 + """ 144 144 + Read and execute a command. 145 145 + 146 146 + @return True if execution was ok, return False if disconnected. 147 147 + """ 148 148 + try: 149 149 + cmdline = raw_input(prompt) 150 150 + except EOFError: 151 151 + print 152 152 + return False 153 153 + if cmdline == '': 154 154 + for ev in self.get_events(): 155 155 + print ev 156 156 + self.clear_events() 157 157 + return True 158 158 + else: 159 159 + return self._execute_cmd(cmdline) 160 160 + 161 161 + class HMPShell(QMPShell): 162 162 + def __init__(self, address): 163 163 + QMPShell.__init__(self, address) 164 164 + self.__cpu_index = 0 165 165 + 166 166 + def __cmd_completion(self): 167 167 + for cmd in self.__cmd_passthrough('help')['return'].split('\r\n'): 168 168 + if cmd and cmd[0] != '[' and cmd[0] != '\t': 169 169 + name = cmd.split()[0] # drop help text 170 170 + if name == 'info': 171 171 + continue 172 172 + if name.find('|') != -1: 173 173 + # Command in the form 'foobar|f' or 'f|foobar', take the 174 174 + # full name 175 175 + opt = name.split('|') 176 176 + if len(opt[0]) == 1: 177 177 + name = opt[1] 178 178 + else: 179 179 + name = opt[0] 180 180 + self._completer.append(name) 181 181 + self._completer.append('help ' + name) # help completion 182 182 + 183 183 + def __info_completion(self): 184 184 + for cmd in self.__cmd_passthrough('info')['return'].split('\r\n'): 185 185 + if cmd: 186 186 + self._completer.append('info ' + cmd.split()[1]) 187 187 + 188 188 + def __other_completion(self): 189 189 + # special cases 190 190 + self._completer.append('help info') 191 191 + 192 192 + def _fill_completion(self): 193 193 + self.__cmd_completion() 194 194 + self.__info_completion() 195 195 + self.__other_completion() 196 196 + 197 197 + def __cmd_passthrough(self, cmdline, cpu_index = 0): 198 198 + return self.cmd_obj({ 'execute': 'human-monitor-command', 'arguments': 199 199 + { 'command-line': cmdline, 200 200 + 'cpu-index': cpu_index } }) 201 201 + 202 202 + def _execute_cmd(self, cmdline): 203 203 + if cmdline.split()[0] == "cpu": 204 204 + # trap the cpu command, it requires special setting 205 205 + try: 206 206 + idx = int(cmdline.split()[1]) 207 207 + if not 'return' in self.__cmd_passthrough('info version', idx): 208 208 + print 'bad CPU index' 209 209 + return True 210 210 + self.__cpu_index = idx 211 211 + except ValueError: 212 212 + print 'cpu command takes an integer argument' 213 213 + return True 214 214 + resp = self.__cmd_passthrough(cmdline, self.__cpu_index) 215 215 + if resp is None: 216 216 + print 'Disconnected' 217 217 + return False 218 218 + assert 'return' in resp or 'error' in resp 219 219 + if 'return' in resp: 220 220 + # Success 221 221 + if len(resp['return']) > 0: 222 222 + print resp['return'], 223 223 + else: 224 224 + # Error 225 225 + print '%s: %s' % (resp['error']['class'], resp['error']['desc']) 226 226 + return True 227 227 + 228 228 + def show_banner(self): 229 229 + QMPShell.show_banner(self, msg='Welcome to the HMP shell!') 230 230 + 231 231 + def die(msg): 232 232 + sys.stderr.write('ERROR: %s\n' % msg) 233 233 + sys.exit(1) 234 234 + 235 235 + def fail_cmdline(option=None): 236 236 + if option: 237 237 + sys.stderr.write('ERROR: bad command-line option \'%s\'\n' % option) 238 238 + sys.stderr.write('qemu-shell [ -p ] [ -H ] < UNIX socket path> | < TCP address:port >\n') 239 239 + sys.exit(1) 240 240 + 241 241 + def main(): 242 242 + addr = '' 243 243 + qemu = None 244 244 + hmp = False 245 245 + pp = None 246 246 + 247 247 + try: 248 248 + for arg in sys.argv[1:]: 249 249 + if arg == "-H": 250 250 + if qemu is not None: 251 251 + fail_cmdline(arg) 252 252 + hmp = True 253 253 + elif arg == "-p": 254 254 + if pp is not None: 255 255 + fail_cmdline(arg) 256 256 + pp = pprint.PrettyPrinter(indent=4) 257 257 + else: 258 258 + if qemu is not None: 259 259 + fail_cmdline(arg) 260 260 + if hmp: 261 261 + qemu = HMPShell(arg) 262 262 + else: 263 263 + qemu = QMPShell(arg, pp) 264 264 + addr = arg 265 265 + 266 266 + if qemu is None: 267 267 + fail_cmdline() 268 268 + except QMPShellBadPort: 269 269 + die('bad port number in command-line') 270 270 + 271 271 + try: 272 272 + qemu.connect() 273 273 + except qmp.QMPConnectError: 274 274 + die('Didn\'t get QMP greeting message') 275 275 + except qmp.QMPCapabilitiesError: 276 276 + die('Could not negotiate capabilities') 277 277 + except qemu.error: 278 278 + die('Could not connect to %s' % addr) 279 279 + 280 280 + qemu.show_banner() 281 281 + while qemu.read_exec_command('(QEMU) '): 282 282 + pass 283 283 + qemu.close() 284 284 + 285 285 + if __name__ == '__main__': 286 286 + main()