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
60
61
|
#!/usr/bin/env python
#
# Copyright 2012 Free Software Foundation, Inc.
#
# This file is part of GNU Radio
#
# SPDX-License-Identifier: GPL-3.0-or-later
#
#
import sys
import subprocess
import re
import signal
import time
import atexit
import os
from gnuradio import gr
class monitor(object):
def __init__(self, tool="gr-ctrlport-monitor"):
print("ControlPort Monitor running.")
self.started = False
self.tool = tool
atexit.register(self.shutdown)
# setup export prefs
gr.prefs().singleton().set_bool("ControlPort", "on", True)
gr.prefs().singleton().set_bool("PerfCounters", "on", True)
gr.prefs().singleton().set_bool("PerfCounters", "export", True)
if(tool == "gr-perf-monitorx"):
gr.prefs().singleton().set_bool("ControlPort", "edges_list", True)
def start(self):
try:
print("monitor::endpoints() = %s" %
(gr.rpcmanager_get().endpoints()))
ep = gr.rpcmanager_get().endpoints()[0]
cmd = [self.tool, re.search(
r"-h (\S+|\d+\.\d+\.\d+\.\d+)", ep).group(1), re.search(r"-p (\d+)", ep).group(1)]
print("running: %s" % (str(cmd)))
self.proc = subprocess.Popen(cmd)
self.started = True
except:
self.proc = None
print("Failed to to connect to ControlPort. Please make sure that you have Thrift installed and check your firewall rules.")
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()
|
