| Index: third_party/pexpect/examples/monitor.py
 | 
| diff --git a/third_party/pexpect/examples/monitor.py b/third_party/pexpect/examples/monitor.py
 | 
| new file mode 100644
 | 
| index 0000000000000000000000000000000000000000..9cb0eaf1db66d4e5a4a7f51e9c15f6ed2005d4b2
 | 
| --- /dev/null
 | 
| +++ b/third_party/pexpect/examples/monitor.py
 | 
| @@ -0,0 +1,229 @@
 | 
| +#!/usr/bin/env python
 | 
| +
 | 
| +''' This runs a sequence of commands on a remote host using SSH. It runs a
 | 
| +simple system checks such as uptime and free to monitor the state of the remote
 | 
| +host.
 | 
| +
 | 
| +./monitor.py [-s server_hostname] [-u username] [-p password]
 | 
| +    -s : hostname of the remote server to login to.
 | 
| +    -u : username to user for login.
 | 
| +    -p : Password to user for login.
 | 
| +
 | 
| +Example:
 | 
| +    This will print information about the given host:
 | 
| +        ./monitor.py -s www.example.com -u mylogin -p mypassword
 | 
| +
 | 
| +It works like this:
 | 
| +    Login via SSH (This is the hardest part).
 | 
| +    Run and parse 'uptime'.
 | 
| +    Run 'iostat'.
 | 
| +    Run 'vmstat'.
 | 
| +    Run 'netstat'
 | 
| +    Run 'free'.
 | 
| +    Exit the remote host.
 | 
| +
 | 
| +PEXPECT LICENSE
 | 
| +
 | 
| +    This license is approved by the OSI and FSF as GPL-compatible.
 | 
| +        http://opensource.org/licenses/isc-license.txt
 | 
| +
 | 
| +    Copyright (c) 2012, Noah Spurrier <noah@noah.org>
 | 
| +    PERMISSION TO USE, COPY, MODIFY, AND/OR DISTRIBUTE THIS SOFTWARE FOR ANY
 | 
| +    PURPOSE WITH OR WITHOUT FEE IS HEREBY GRANTED, PROVIDED THAT THE ABOVE
 | 
| +    COPYRIGHT NOTICE AND THIS PERMISSION NOTICE APPEAR IN ALL COPIES.
 | 
| +    THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 | 
| +    WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 | 
| +    MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 | 
| +    ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 | 
| +    WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 | 
| +    ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 | 
| +    OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 | 
| +
 | 
| +'''
 | 
| +
 | 
| +from __future__ import print_function
 | 
| +
 | 
| +from __future__ import absolute_import
 | 
| +
 | 
| +import os, sys, re, getopt, getpass
 | 
| +import pexpect
 | 
| +
 | 
| +
 | 
| +try:
 | 
| +    raw_input
 | 
| +except NameError:
 | 
| +    raw_input = input
 | 
| +
 | 
| +
 | 
| +#
 | 
| +# Some constants.
 | 
| +#
 | 
| +COMMAND_PROMPT = '[#$] ' ### This is way too simple for industrial use -- we will change is ASAP.
 | 
| +TERMINAL_PROMPT = '(?i)terminal type\?'
 | 
| +TERMINAL_TYPE = 'vt100'
 | 
| +# This is the prompt we get if SSH does not have the remote host's public key stored in the cache.
 | 
| +SSH_NEWKEY = '(?i)are you sure you want to continue connecting'
 | 
| +
 | 
| +def exit_with_usage():
 | 
| +
 | 
| +    print(globals()['__doc__'])
 | 
| +    os._exit(1)
 | 
| +
 | 
| +def main():
 | 
| +
 | 
| +    global COMMAND_PROMPT, TERMINAL_PROMPT, TERMINAL_TYPE, SSH_NEWKEY
 | 
| +    ######################################################################
 | 
| +    ## Parse the options, arguments, get ready, etc.
 | 
| +    ######################################################################
 | 
| +    try:
 | 
| +        optlist, args = getopt.getopt(sys.argv[1:], 'h?s:u:p:', ['help','h','?'])
 | 
| +    except Exception as e:
 | 
| +        print(str(e))
 | 
| +        exit_with_usage()
 | 
| +    options = dict(optlist)
 | 
| +    if len(args) > 1:
 | 
| +        exit_with_usage()
 | 
| +
 | 
| +    if [elem for elem in options if elem in ['-h','--h','-?','--?','--help']]:
 | 
| +        print("Help:")
 | 
| +        exit_with_usage()
 | 
| +
 | 
| +    if '-s' in options:
 | 
| +        host = options['-s']
 | 
| +    else:
 | 
| +        host = raw_input('hostname: ')
 | 
| +    if '-u' in options:
 | 
| +        user = options['-u']
 | 
| +    else:
 | 
| +        user = raw_input('username: ')
 | 
| +    if '-p' in options:
 | 
| +        password = options['-p']
 | 
| +    else:
 | 
| +        password = getpass.getpass('password: ')
 | 
| +
 | 
| +    #
 | 
| +    # Login via SSH
 | 
| +    #
 | 
| +    child = pexpect.spawn('ssh -l %s %s'%(user, host))
 | 
| +    i = child.expect([pexpect.TIMEOUT, SSH_NEWKEY, COMMAND_PROMPT, '(?i)password'])
 | 
| +    if i == 0: # Timeout
 | 
| +        print('ERROR! could not login with SSH. Here is what SSH said:')
 | 
| +        print(child.before, child.after)
 | 
| +        print(str(child))
 | 
| +        sys.exit (1)
 | 
| +    if i == 1: # In this case SSH does not have the public key cached.
 | 
| +        child.sendline ('yes')
 | 
| +        child.expect ('(?i)password')
 | 
| +    if i == 2:
 | 
| +        # This may happen if a public key was setup to automatically login.
 | 
| +        # But beware, the COMMAND_PROMPT at this point is very trivial and
 | 
| +        # could be fooled by some output in the MOTD or login message.
 | 
| +        pass
 | 
| +    if i == 3:
 | 
| +        child.sendline(password)
 | 
| +        # Now we are either at the command prompt or
 | 
| +        # the login process is asking for our terminal type.
 | 
| +        i = child.expect ([COMMAND_PROMPT, TERMINAL_PROMPT])
 | 
| +        if i == 1:
 | 
| +            child.sendline (TERMINAL_TYPE)
 | 
| +            child.expect (COMMAND_PROMPT)
 | 
| +    #
 | 
| +    # Set command prompt to something more unique.
 | 
| +    #
 | 
| +    COMMAND_PROMPT = "\[PEXPECT\]\$ "
 | 
| +    child.sendline ("PS1='[PEXPECT]\$ '") # In case of sh-style
 | 
| +    i = child.expect ([pexpect.TIMEOUT, COMMAND_PROMPT], timeout=10)
 | 
| +    if i == 0:
 | 
| +        print("# Couldn't set sh-style prompt -- trying csh-style.")
 | 
| +        child.sendline ("set prompt='[PEXPECT]\$ '")
 | 
| +        i = child.expect ([pexpect.TIMEOUT, COMMAND_PROMPT], timeout=10)
 | 
| +        if i == 0:
 | 
| +            print("Failed to set command prompt using sh or csh style.")
 | 
| +            print("Response was:")
 | 
| +            print(child.before)
 | 
| +            sys.exit (1)
 | 
| +
 | 
| +    # Now we should be at the command prompt and ready to run some commands.
 | 
| +    print('---------------------------------------')
 | 
| +    print('Report of commands run on remote host.')
 | 
| +    print('---------------------------------------')
 | 
| +
 | 
| +    # Run uname.
 | 
| +    child.sendline ('uname -a')
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +    print(child.before)
 | 
| +    if 'linux' in child.before.lower():
 | 
| +        LINUX_MODE = 1
 | 
| +    else:
 | 
| +        LINUX_MODE = 0
 | 
| +
 | 
| +    # Run and parse 'uptime'.
 | 
| +    child.sendline ('uptime')
 | 
| +    child.expect('up\s+(.*?),\s+([0-9]+) users?,\s+load averages?: ([0-9]+\.[0-9][0-9]),?\s+([0-9]+\.[0-9][0-9]),?\s+([0-9]+\.[0-9][0-9])')
 | 
| +    duration, users, av1, av5, av15 = child.match.groups()
 | 
| +    days = '0'
 | 
| +    hours = '0'
 | 
| +    mins = '0'
 | 
| +    if 'day' in duration:
 | 
| +        child.match = re.search('([0-9]+)\s+day',duration)
 | 
| +        days = str(int(child.match.group(1)))
 | 
| +    if ':' in duration:
 | 
| +        child.match = re.search('([0-9]+):([0-9]+)',duration)
 | 
| +        hours = str(int(child.match.group(1)))
 | 
| +        mins = str(int(child.match.group(2)))
 | 
| +    if 'min' in duration:
 | 
| +        child.match = re.search('([0-9]+)\s+min',duration)
 | 
| +        mins = str(int(child.match.group(1)))
 | 
| +    print()
 | 
| +    print('Uptime: %s days, %s users, %s (1 min), %s (5 min), %s (15 min)' % (
 | 
| +        duration, users, av1, av5, av15))
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +
 | 
| +    # Run iostat.
 | 
| +    child.sendline ('iostat')
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +    print(child.before)
 | 
| +
 | 
| +    # Run vmstat.
 | 
| +    child.sendline ('vmstat')
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +    print(child.before)
 | 
| +
 | 
| +    # Run free.
 | 
| +    if LINUX_MODE:
 | 
| +        child.sendline ('free') # Linux systems only.
 | 
| +        child.expect (COMMAND_PROMPT)
 | 
| +        print(child.before)
 | 
| +
 | 
| +    # Run df.
 | 
| +    child.sendline ('df')
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +    print(child.before)
 | 
| +
 | 
| +    # Run lsof.
 | 
| +    child.sendline ('lsof')
 | 
| +    child.expect (COMMAND_PROMPT)
 | 
| +    print(child.before)
 | 
| +
 | 
| +#    # Run netstat
 | 
| +#    child.sendline ('netstat')
 | 
| +#    child.expect (COMMAND_PROMPT)
 | 
| +#    print child.before
 | 
| +
 | 
| +#    # Run MySQL show status.
 | 
| +#    child.sendline ('mysql -p -e "SHOW STATUS;"')
 | 
| +#    child.expect (PASSWORD_PROMPT_MYSQL)
 | 
| +#    child.sendline (password_mysql)
 | 
| +#    child.expect (COMMAND_PROMPT)
 | 
| +#    print
 | 
| +#    print child.before
 | 
| +
 | 
| +    # Now exit the remote host.
 | 
| +    child.sendline ('exit')
 | 
| +    index = child.expect([pexpect.EOF, "(?i)there are stopped jobs"])
 | 
| +    if index==1:
 | 
| +        child.sendline("exit")
 | 
| +        child.expect(EOF)
 | 
| +
 | 
| +if __name__ == "__main__":
 | 
| +    main()
 | 
| 
 |