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
62
63
64
65
66
|
import gras
import numpy
class generic(gras.Block):
def __init__(self):
gras.Block.__init__(self,
name="generic",
in_sig=[numpy.float32],
out_sig=[numpy.float32])
def set_parameters(self,func_name,window):
self.n = window
self.func_name = func_name
# Check if value of window is integral of length of input source vector
# For cases like -> input = [3 , 4, 5 ,6] & window = 3
def isIntegralWin(self, input_item, window):
if (len(input_item) % window ):
raise Exception("Value of Window should be an integral value of length of input items")
def work(self, input_items, output_items):
# Limit output_items to just the size of window
output_items[0] = output_items[0][:self.n]
from scilab import Scilab
Sci = Scilab()
# Check number of input_instances
n_input_items = len(input_items)
# Create output string instance which will be evaluated
out_eval_string = 'eval("Sci.'+self.func_name+'('
# Iterate for n_input_items
for i in range(n_input_items):
# Check window condition
self.isIntegralWin(input_items[i][:], self.n)
# If the window is greater than 1, input_items[i][:self.n] looks like [1 2 3 4 5] which is err for python since it requires comma as delimiters
if self.n == 1:
out_eval_string = out_eval_string + str(input_items[i][:self.n]) + ","
else:
print 'IN',str(input_items[i][:self.n])
out_eval_string = out_eval_string + (str(input_items[i][:self.n].tolist())) + "," # Replace 10spaces with a singe comma
out_eval_string = out_eval_string.rstrip(",") + ')")'
print "STRING ",str(out_eval_string)
# for functions like sin
if n_input_items == 1 and self.n == 1:
output_items[0][:self.n] = eval(out_eval_string)
else:
output_items[0] = eval(out_eval_string)
print "OUT",output_items[0]
#print 'SIZE,', output_items[0].size
#Write a for loop for n_inputs
for i in range(n_input_items):
self.consume(i,self.n) # Consume from port 0 input_items
self.produce(0,self.n) # Produce from port 0 output_items
|
