vpp - Vector Packet Processing

diff options

author	Keith Burns (alagalah) <alagalah@gmail.com>	2017-09-12 15:12:17 -0700
committer	Florin Coras <florin.coras@gmail.com>	2017-09-14 02:56:46 +0000
commit	831fb59f2eba1abbd1e49fc7dce58172f0842258 (patch)
tree	50950ca83e3d7e977790dcf317134531cf40ec9a /src/scripts/vnet/rewrite
parent	7c5c40db2a8d71a857ae63b6238cfac6e257da6d (diff)

Stats refactor

- added per-interface simple/combined counters - refactored fib/nbr API to use common registration scheme - refactored "want_stats" and "want_interface" to use per interface registration scheme - fixed issues with SEGV when client disconnects abruptly. Change-Id: Ib701bd8e4105d03548259217bfc809bd738b7c72 Signed-off-by: Keith Burns (alagalah) <alagalah@gmail.com>

Diffstat (limited to 'src/scripts/vnet/rewrite')

0 files changed, 0 insertions, 0 deletions

import errno import os import shlex import socket import signal import tempfile import types from subprocess import Popen from time import sleep import outer_packages import jsonrpclib # uses Unix sockets for determine running process. # (assumes used daemons will register proper socket) # all daemons should use -p argument as listening tcp port and check_connectivity RPC method class SingletonDaemon(object): # run_cmd can be function of how to run daemon or a str to run at subprocess def __init__(self, name, tag, port, run_cmd, dir = None): self.name = name self.tag = tag self.port = port self.run_cmd = run_cmd self.dir = dir self.stop = self.kill # alias if ' ' in tag: raise Exception('Error: tag should not include spaces') if dir and not os.path.exists(dir): print('Warning: path given for %s: %s, does not exist' % (name, dir)) # returns True if daemon is running def is_running(self): try: lock_socket = register_socket(self.tag) # the check is ~200000 faster and more reliable than checking via 'netstat' or 'ps' etc. lock_socket.shutdown(socket.SHUT_RDWR) lock_socket.close() except socket.error: # Unix socket in use return True sleep(0.5) # Unix socket is not used, but maybe it's old version of daemon not using socket return bool(self.get_pid_by_listening_port()) # get pid of running daemon by registered Unix socket (most robust way) def get_pid_by_unix_socket(self): ret_code, stdout, stderr = run_command('netstat -px') if ret_code: raise Exception('Error running netstat: %s' % [ret_code, stdout, stderr]) for line in stdout.splitlines(): line_arr = line.strip().split() if len(line_arr) == 8 and line_arr[0] == 'unix' and line_arr[4] == 'DGRAM' and line_arr[7] == '@%s' % self.tag: return int(line_arr[6].split('/', 1)[0]) # get pid of running daemon by listening tcp port (for backward compatibility) def get_pid_by_listening_port(self): ret_code, stdout, stderr = run_command('netstat -tlnp') if ret_code: raise Exception('Error running netstat: %s' % [ret_code, stdout, stderr]) for line in stdout.splitlines(): line_arr = line.strip().split() if len(line_arr) == 7 and line_arr[3] == '0.0.0.0:%s' % self.port: if '/' not in line_arr[6]: raise Exception('Expecting pid/program name in netstat line of using port %s, got: %s' % (self.port, line)) return int(line_arr[6].split('/')[0]) # get PID of running process, None if not found def get_pid(self): pid = self.get_pid_by_unix_socket() if pid: return pid pid = self.get_pid_by_listening_port() if pid: return pid def kill_by_signal(self, pid, signal_name, timeout): os.kill(pid, signal_name) poll_rate = 0.1 for i in range(int(timeout / poll_rate)): if not self.is_running(): return True sleep(poll_rate) # kill daemon, with verification def kill(self, timeout = 15): pid = self.get_pid() if not pid: raise Exception('%s is not running' % self.name) # try Ctrl+C, usual kill, kill -9 for signal_name in [signal.SIGINT, signal.SIGTERM, signal.SIGKILL]: if self.kill_by_signal(pid, signal_name, timeout): return True raise Exception('Could not kill %s, even with -9' % self.name) # try connection as RPC client, return True upon success, False if fail def check_connectivity(self, timeout = 15): daemon = jsonrpclib.Server('http://127.0.0.1:%s/' % self.port) poll_rate = 0.1 for i in range(int(timeout/poll_rate)): try: daemon.check_connectivity() return True except socket.error: # daemon is not up yet sleep(poll_rate) return False # start daemon # returns True if success, False if already running def start(self, timeout = 20): if self.is_running(): raise Exception('%s is already running' % self.name) if not self.run_cmd: raise Exception('No starting command registered for %s' % self.name) if type(self.run_cmd) is types.FunctionType: self.run_cmd() return with tempfile.TemporaryFile() as stdout_file, tempfile.TemporaryFile() as stderr_file: proc = Popen(shlex.split('%s -p %s' % (self.run_cmd, self.port)), cwd = self.dir, close_fds = True, stdout = stdout_file, stderr = stderr_file) if timeout > 0: poll_rate = 0.1 for i in range(int(timeout/poll_rate)): if self.is_running(): break sleep(poll_rate) if bool(proc.poll()): # process ended with error stdout_file.seek(0) stderr_file.seek(0) raise Exception('Run of %s ended unexpectfully: %s' % (self.name, [proc.returncode, stdout_file.read().decode(errors = 'replace'), stderr_file.read().decode(errors = 'replace')])) elif proc.poll() == 0: # process runs other process, and ended break if self.is_running(): if self.check_connectivity(): return True raise Exception('Daemon process is running, but no connectivity') raise Exception('%s failed to run.' % self.name) # restart the daemon def restart(self, timeout = 15): if self.is_running(): self.kill(timeout) sleep(0.5) return self.start(timeout) # provides unique way to determine running process, should be used inside daemon def register_socket(tag): global lock_socket # Without this our lock gets garbage collected lock_socket = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) try: lock_socket.bind('\0%s' % tag) return lock_socket except socket.error: raise socket.error('Error: process with tag %s is already running.' % tag) # runs command def run_command(command, timeout = 15, cwd = None): # pipes might stuck, even with timeout with tempfile.TemporaryFile() as stdout_file, tempfile.TemporaryFile() as stderr_file: proc = Popen(shlex.split(command), stdout = stdout_file, stderr = stderr_file, cwd = cwd, close_fds = True) if timeout > 0: poll_rate = 0.1 for i in range(int(timeout/poll_rate)): sleep(poll_rate) if proc.poll() is not None: # process stopped break if proc.poll() is None: proc.kill() # timeout return (errno.ETIME, '', 'Timeout on running: %s' % command) else: proc.wait() stdout_file.seek(0) stderr_file.seek(0) return (proc.returncode, stdout_file.read().decode(errors = 'replace'), stderr_file.read().decode(errors = 'replace'))


context:
space:
mode: