Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class dataCapture(gr.sync_block):
- """
- docstring for block dataCapture
- """
- def __init__(self,IP="192.168.122.3",DataKind="RawTimeSamples",DataSource=0,Channel=0,size=1024,port=0):
- gr.sync_block.__init__(self,name="dataCapture",in_sig=None,out_sig=[numpy.float32])
- kind = 2
- if (DataKind=="RawTimeSamples"):
- kind = 1
- self.size = size
- elif(DataKind=="WindowingSamples"):
- kind = 2
- self.size = size/2
- self.position = 0
- ### Capture packet
- self.DataSelection = namedtuple('DataSelection',['DataKind','DataSource','Channel','SizePc'])
- self.DataSelectionArray = []
- self.newObject = self.DataSelection(kind,DataSource,Channel,5)
- self.DataSelectionArray.append(self.newObject)
- ### Crear socket
- self.socketServer = serverCommander.authenticate(IP)
- def work(self, input_items, output_items):
- for i in range(0, len(output_items[0])):
- # rellenar
- if (self.position == 0):
- self.CaptureArray = serverCommander.captureData(self.socketServer[0],self.DataSelectionArray)
- output_items[0][i] = (self.CaptureArray[0].Data[self.subkind])[self.position]
- self.position = self.position + 1
- ## reiniciar
- if (self.position == self.size):
- self.position = 0
- return len(output_items[0])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement