Changeset 9781

Show
Ignore:
Timestamp:
10/11/08 20:36:20
Author:
jblum
Message:

selector fix, issue with IO terminators

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • gnuradio/trunk/grc/src/grc_gnuradio/blks2/selector.py

    r9741 r9781  
    2626        def __init__(self, item_size, num_inputs, num_outputs, input_index, output_index): 
    2727                """ 
    28                 SelectorHelper constructor. 
     28                Selector constructor. 
    2929                @param item_size the size of the gr data stream in bytes 
    3030                @param num_inputs the number of inputs (integer) 
    …… 
    3939                ) 
    4040                #terminator blocks for unused inputs and outputs 
    41                 self.input_terminators = [gr.null_sink(item_size)] * num_inputs 
    42                 self.output_terminators = [gr.head(item_size, 0)] * num_outputs 
    43                 self.copy = None 
     41                self.input_terminators = [gr.null_sink(item_size) for i in range(num_inputs)] 
     42                self.output_terminators = [gr.head(item_size, 0) for i in range(num_outputs)] 
     43                self.copy = gr.kludge_copy(item_size) 
    4444                #connections 
    4545                for i in range(num_inputs): self.connect((self, i), self.input_terminators[i]) 
    …… 
    6666                        self.disconnect((self, self.input_index), self.input_terminators[self.input_index]) 
    6767                        self.disconnect(self.output_terminators[self.output_index], (self, self.output_index)) 
    68                         self.copy = gr.skiphead(self.item_size, 0) 
    6968                        self.connect((self, self.input_index), self.copy) 
    7069                        self.connect(self.copy, (self, self.output_index)) 
    …… 
    8079                        self.disconnect(self.copy, (self, self.output_index)) 
    8180                        self.disconnect(self.output_terminators[self.output_index], self.input_terminators[self.input_index]) 
    82                         del self.copy 
    83                         self.copy = None 
    8481                        self.connect((self, self.input_index), self.input_terminators[self.input_index]) 
    8582                        self.connect(self.output_terminators[self.output_index], (self, self.output_index))