summaryrefslogtreecommitdiff
path: root/gnuradio-runtime/python/gnuradio/ctrlport/monitor.py
blob: 53a571a698531512380f0f3f713ff10260fa2dca (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
#!/usr/bin/env python
#
# Copyright 2012 Free Software Foundation, Inc.
#
# This file is part of GNU Radio
#
# GNU Radio is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 3, or (at your option)
# any later version.
#
# GNU Radio is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with GNU Radio; see the file COPYING.  If not, write to
# the Free Software Foundation, Inc., 51 Franklin Street,
# Boston, MA 02110-1301, USA.
#

import sys, subprocess, re, signal, time, atexit, os
from gnuradio import gr

class monitor:
    def __init__(self):
        print "ControlPort Monitor running."
        self.started = False
        atexit.register(self.shutdown)

    def __del__(self):
        if(self.started):
            self.stop()

    def start(self):
        print "monitor::endpoints() = %s" % (gr.rpcmanager_get().endpoints())
        try:
            self.proc = subprocess.Popen(map(lambda a: ["gr-ctrlport-monitor",
                                                        re.search("\d+\.\d+\.\d+\.\d+",a).group(0),
                                                        re.search("-p (\d+)",a).group(1)],
                                             gr.rpcmanager_get().endpoints())[0])
            self.started = True
        except:
            self.proc = None
            print "failed to to start ControlPort Monitor on specified port"

    def stop(self):
        if(self.proc):
            if(self.proc.returncode == None):
                print "\tcalling stop on shutdown"
                self.proc.terminate()
        else:
            print "\tno proc to shut down, exiting"

    def shutdown(self):
        print "ctrlport.monitor received shutdown signal"
        if(self.started):
            self.stop()