########################################################################

include(GrPython)

install(

FILES

${CMAKE_CURRENT_SOURCE_DIR}/icon.png

COMPONENT "runtime_python"

)

GR_PYTHON_INSTALL(

FILES

${CMAKE_CURRENT_SOURCE_DIR}/__init__.py

${CMAKE_CURRENT_SOURCE_DIR}/GrDataPlotter.py

${CMAKE_CURRENT_SOURCE_DIR}/monitor.py

DESTINATION ${GR_PYTHON_DIR}/gnuradio/ctrlport/

COMPONENT "runtime_python"

)

GR_PYTHON_INSTALL(

FILES

${CMAKE_CURRENT_SOURCE_DIR}/gr-perf-monitorx

DESTINATION ${GR_RUNTIME_DIR}

PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE GROUP_READ GROUP_EXECUTE WORLD_READ WORLD_EXECUTE

COMPONENT "runtime_python"

)

GR_PYTHON_INSTALL(

FILES

${CMAKE_CURRENT_BINARY_DIR}/GNURadio/__init__.py

${CMAKE_CURRENT_BINARY_DIR}/GNURadio/constants.py

${CMAKE_CURRENT_BINARY_DIR}/GNURadio/ControlPort.py

DESTINATION ${GR_PYTHON_DIR}/gnuradio/ctrlport/GNURadio

COMPONENT "runtime_python"

)

host: hostname of the connection

"""

class RPCConnectionThrift(RPCConnection):

def __init__(self, host=None, port=None):

if port is None: port = 9090

result = {}

for key, knob in self.thriftclient.radio.getKnobs(*args).iteritems():

else:

raise exceptions.ValueError

return result

def getRe(self,*args):

def setKnobs(self,*args):

self.thriftclient.radio.setKnobs(*args)

units = str(knobprops[itemKey].units)

descr = str(knobprops[itemKey].description)

v = v.re + v.im*1j

# If it's a byte stream, Python thinks it's a string.

# Unpack and convert to floats for plotting.

for k in knobs.keys():

if k not in foundKeys:

v = knobs[k].value

v = v.re + v.im*1j

# If it's a byte stream, Python thinks it's a string.

# Unpack and convert to floats for plotting.

#

import random,math,operator

import matplotlib

matplotlib.use("Qt4Agg");

import matplotlib.pyplot as plt

from gnuradio.ctrlport.GrDataPlotter import *

#from gnuradio.ctrlport import GNURadio

class MAINWindow(QtGui.QMainWindow):

def minimumSizeHint(self):

return QtGui.QSize(800,600)

super(MAINWindow, self).__init__()

self.conns = []

self.plots = []

self.knobprops = []

self.mdiArea = QtGui.QMdiArea()

self.mdiArea.setHorizontalScrollBarPolicy(QtCore.Qt.ScrollBarAsNeeded)

self.setWindowTitle("GNU Radio Performance Monitor")

self.setUnifiedTitleAndToolBarOnMac(True)

icon = QtGui.QIcon(ctrlport.__path__[0] + "/icon.png" )

self.setWindowIcon(icon)

child.show();

self.mdiArea.currentSubWindow().showMaximized()

self.mdiArea.addSubWindow(child)

self.mdiArea.currentSubWindow().showMaximized()

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.\n

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.'''

class ConInfoDialog(QtGui.QDialog):

def update(self):

print "update"

QtGui.QWidget.__init__( self)

self.layout = QtGui.QVBoxLayout(self);

self.layout.addLayout(self.hlayout);

self.G = G;

self._keymap = None

self._sort = state > 0

class DataTableBuffers(DataTable):

self.perfTable.setHorizontalHeaderLabels( ["Block Name", "Percent Buffer Full"] );

def update(self):

kl = map(lambda x: "%s::%soutput %% full" % \

(x, self._statistics_table[self._statistic]),

nodes);

# strip values out of ctrlport response

buffer_fullness = dict(zip(

blockport_fullness = {}

for blk in buffer_fullness:

for port in range(0,len(bdata)):

blockport_fullness["%s:%d"%(blk,port)] = bdata[port];

self.canvas.show();

class DataTableRuntimes(DataTable):

#self.perfTable.setRowCount(len( self.G.nodes() ))

def update(self):

kl = map(lambda x: "%s::%swork time" % \

(x, self._statistics_table[self._statistic]),

nodes);

# strip values out of ctrlport response

if(total_work == 0):

total_work = 1

work_times = dict(zip(

map(lambda x: x.split("::")[0], wrk_knobs.keys()),

# update table view

self.table_update(work_times)

self.prevent_clock_change = True;

kl1 = None;

if(self.clockKey == None):

else:

self.clockKey = kl1.keys()[0]

self.clockSelIdx = self.clocks.values().index(self.currClock)

self.clockSel.setCurrentIndex(self.clockSelIdx)

self.prevent_clock_change = False

nodes_stream);

st = time.time()

td1 = time.time() - st;

# strip values out of ctrlport response

buf_vals = dict(zip(

map(lambda x: x.split("::")[0], buf_knobs.keys()),

# get work time for all blocks

kl = map(lambda x: "%s::%swork time" % \

(x, self._statistics_table[self._statistic]),

nodes_stream);

st = time.time()

td2 = time.time() - st;

# strip values out of ctrlport response

if(total_work == 0):

total_work = 1

work_times = dict(zip(

map(lambda x: x.split("::")[0], wrk_knobs.keys()),

work_times_padded = dict(zip(

self.G.nodes(),

[0.1]*len(self.G.nodes())))

# get the right output buffer/port weight for each edge

sourceport = e[2]["sourceport"];

if(e[2]["type"] == "stream"):

e[2]["weight"] = newweight;

for n in nodes_msg:

(latency*1000))

except Exception, e:

if(type(self.parent) is MAINWindow):

# Find window of connection

remove = []

return

def rtt(self):

def bpt(self):

def resetPCs(self):

knob = GNURadio.ttypes.KnobBase()

km = {}

for b in self.blocks_list:

km[b + "::reset_perf_counters"] = knob

def toggleFlowgraph(self):

if self.pauseFGAct.isChecked():

km = {}

km[self.top_block + "::lock"] = knob

km[self.top_block + "::stop"] = knob

def unpauseFlowgraph(self):

knob = GNURadio.ttypes.KnobBase()

knob.a_bool = False

km = {}

km[self.top_block + "::unlock"] = knob

def stat_changed(self, index):

self._statistic = str(self.stattype.currentText())

idx = self.clockSel.currentIndex();

clk = self.clocks.values()[idx]

# print "UPDATE CLOCK!!! %d -> %d"%(idx,clk);

k[self.clockKey].value = clk;

km = {};

km[self.clockKey] = k[self.clockKey];

super(MForm, self).__init__()

askinfo = ConInfoDialog(self);

if askinfo.exec_():

host = str(askinfo.host.text());

port = str(askinfo.port.text());

else:

return

self.uid = uid

self.parent = parent

# self.setLayout(self.layout);

self.knobprops = self.radio.properties([])

self.parent.knobprops.append(self.knobprops)

sys.exit(1)

self.blocks_list = tmplist

edgepairs_stream = [];

edgepairs_msg = [];

index = self.table.treeWidget.selectedIndexes()

item = self.table.treeWidget.itemFromIndex(index[0])

itemname = str(item.text(0))

def updateGraph(self):

self.canvas.draw();

self.canvas.show();