and (self._key != "pad_source") \

and (self._key != "pad_sink"))

if (len(sources) or len(sinks)) and is_not_virtual_or_pad:

self.get_params().append(self.get_parent().get_parent().Param(

block=self,

elif len(bussrcs) > 0:

self.bussify({'name':'bus','type':'bus'}, 'source')

self.bussify({'name':'bus','type':'bus'}, 'source')

ActionHandler constructor.

Create the main window, setup the message handler, import the preferences,

and connect all of the action handlers. Finally, enter the gtk main loop and block.

Args:

file_paths: a list of flow graph file passed from command line

platform: platform module

* some keys are ignored by the accelerators like the direction keys,

* some keys are not registered to any accelerators but are still used.

When not in focus, gtk and the accelerators handle the the key press.

Returns:

false to let gtk handle the key action

"""

Handle the delete event from the main window.

Generated by pressing X to close, alt+f4, or right click+close.

This method in turns calls the state handler to quit.

Returns:

true

"""

Actions.FLOW_GRAPH_SCREEN_CAPTURE, Actions.HELP_WINDOW_DISPLAY,

Actions.TYPES_WINDOW_DISPLAY, Actions.TOGGLE_BLOCKS_WINDOW,

Actions.TOGGLE_REPORTS_WINDOW, Actions.TOGGLE_HIDE_DISABLED_BLOCKS,

): action.set_sensitive(True)

if ParseXML.xml_failures:

Messages.send_xml_errors_if_any(ParseXML.xml_failures)

self.main_window.btwin.search_entry.hide()

Actions.TOGGLE_REPORTS_WINDOW.set_active(Preferences.reports_window_visibility())

Actions.TOGGLE_BLOCKS_WINDOW.set_active(Preferences.blocks_window_visibility())

elif action == Actions.APPLICATION_QUIT:

if self.main_window.close_pages():

gtk.main_quit()

self.get_page().get_state_cache().save_new_state(self.get_flow_graph().export_data())

self.get_page().set_saved(False)

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

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

elif action == Actions.BLOCK_CREATE_HIER:

# keeping track of coordinates for pasting later

coords = self.get_flow_graph().get_selected_blocks()[0].get_coordinate()

x,y = coords

y_min = y

pads = [];

# If a block parameter exists that is a parameter, create a parameter for it

if param.get_value() == flow_param.get_id():

params.append(param.get_value())

(x,y) = block.get_coordinate()

if x < x_min:

x_min = x

# Get id of connected blocks

source_id = connection.get_source().get_parent().get_id()

sink_id = connection.get_sink().get_parent().get_id()

if self.get_flow_graph().get_block(source_id) not in self.get_flow_graph().get_selected_blocks():

pads.append({'key': connection.get_sink().get_key(), 'coord': connection.get_source().get_coordinate(), 'block_id' : block.get_id(), 'direction': 'source'})

# Remove the default samp_rate variable block that is created

remove_me = self.get_flow_graph().get_block("samp_rate")

# Add the param blocks along the top of the window

# Connect the pad to the proper sinks

new_connection = self.get_flow_graph().connect(pad_source,sink)

self.get_flow_graph().update()

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

# Move/Rotate/Delete/Create

else:

self.main_window.btwin.hide()

Preferences.blocks_window_visibility(visible)

elif action == Actions.TOGGLE_HIDE_DISABLED_BLOCKS:

Actions.NOTHING_SELECT()

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

self.get_flow_graph()._old_selected_port = None

self.get_flow_graph()._new_selected_port = None

Actions.ELEMENT_CREATE()

elif action == Actions.BUSSIFY_SINKS:

n = {'name':'bus', 'type':'bus'}

for b in self.get_flow_graph().get_selected_blocks():

def __init__ (self, action_handler):

"""

ExecFlowGraphThread constructor.

Args:

action_handler: an instance of an ActionHandler

"""

"""

Call the action associated with the key press event.

Both the key value and the mask must have a match.

Args:

event: a gtk key press event

Returns:

true if handled

"""

tooltip='Toggle visibility of the block tree widget',

keypresses=(gtk.keysyms.b, gtk.gdk.CONTROL_MASK),

)

ABOUT_WINDOW_DISPLAY = Action(

label='_About',

tooltip='About this program',

keypresses=(gtk.keysyms.f, gtk.gdk.CONTROL_MASK,

gtk.keysyms.slash, NO_MODS_MASK),

)

OPEN_HIER = Action(

label='Open H_ier',

tooltip='Open the source of the selected hierarchical block',

Actions.RELOAD_BLOCKS,

Actions.OPEN_HIER,

Actions.BUSSIFY_SOURCES,

)

##The list of actions and categories for the menu bar.

]),

(gtk.Action('View', '_View', None, None), [

Actions.TOGGLE_BLOCKS_WINDOW,

Actions.TOGGLE_REPORTS_WINDOW,

None,

Actions.ERRORS_WINDOW_DISPLAY,

Actions.FIND_BLOCKS,

pygtk.require('2.0')

import gtk

import Utils

class TextDisplay(gtk.TextView):

"""A non editable gtk text view."""

def __init__(self, text=''):

"""

TextDisplay constructor.

Args:

text: the text to display (string)

"""

self.set_cursor_visible(False)

self.set_wrap_mode(gtk.WRAP_WORD_CHAR)

def insert(self, line):

# make backspaces work

line = self._consume_backspaces(line)

# add the remaining text to buffer

self.get_buffer().insert(self.get_buffer().get_end_iter(), line)

def _consume_backspaces(self, line):

"""removes text from the buffer if line starts with \b*"""

# return remaining text

return line[back_count:]

def MessageDialogHelper(type, buttons, title=None, markup=None):

"""

Create a modal message dialog and run it.

Args:

type: the type of message: gtk.MESSAGE_INFO, gtk.MESSAGE_WARNING, gtk.MESSAGE_QUESTION or gtk.MESSAGE_ERROR

buttons: the predefined set of buttons to use:

gtk.BUTTONS_NONE, gtk.BUTTONS_OK, gtk.BUTTONS_CLOSE, gtk.BUTTONS_CANCEL, gtk.BUTTONS_YES_NO, gtk.BUTTONS_OK_CANCEL

Args:

tittle: the title of the window (string)

markup: the message text with pango markup

Returns:

the gtk response from run()

"""

Handle the delete event from the main window.

Generated by pressing X to close, alt+f4, or right click+close.

This method in turns calls the state handler to quit.

Returns:

true

"""

Handle a page change. When the user clicks on a new tab,

reload the flow graph to update the vars window and

call handle states (select nothing) to update the buttons.

Args:

notebook: the notebook

page: new page

def add_report_line(self, line):

"""

Place line at the end of the text buffer, then scroll its window all the way down.

Args:

line: the new text

"""

self.text_display.insert(line)

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

# Pages: create and close

"""

Create a new notebook page.

Set the tab to be selected.

Args:

file_path: optional file to load into the flow graph

show: true if the page should be shown after loading

def close_pages(self):

"""

Close all the pages in this notebook.

Returns:

true if all closed

"""

Close the current page.

If the notebook becomes empty, and ensure is true,

call new page upon exit to ensure that at least one page exists.

Args:

ensure: boolean

"""

Set the title of the main window.

Set the titles on the page tabs.

Show/hide the reports window.

Args:

title: the window title

"""

def get_page(self):

"""

Get the selected page.

Returns:

the selected page

"""

def get_flow_graph(self):

"""

Get the selected flow graph.

Returns:

the selected flow graph

"""

def _set_page(self, page):

"""

Set the current page.

Args:

page: the page widget

"""

def _save_changes(self):

"""

Save changes to flow graph?

Returns:

true if yes

"""

def _get_files(self):

"""

Get the file names for all the pages, in order.

Returns:

list of file paths

"""

def _get_pages(self):

"""

Get a list of all pages in the notebook.

Returns:

list of pages

"""

else:

try: return _config_parser.getboolean('main', 'blocks_window_visible')

except: return True

$indent($blk.get_make())

#else

self.$blk.get_id() = $indent($blk.get_make())

#if $blk.has_param('affinity') and $blk.get_param('affinity').get_evaluated()

(self.$blk.get_id()).set_processor_affinity($blk.get_param('affinity').get_evaluated())

#end if

tb.wait()

qapp.connect(qapp, Qt.SIGNAL("aboutToQuit()"), quitting)

#for $m in $monitors

#end for

qapp.exec_()

tb = None #to clean up Qt widgets

tb.wait()

#end if

#end if