Read many data packets

Author: echelon

etherdream.py

@@ -54,6 +54,7 @@ def respond_begin(self):
 		p = ResponsePacket('b')
 		respPacket = p.getStruct()
 		self.socket.send(respPacket)
+		print 'sent begin'
 
 	def respond_data(self):
 		p = ResponsePacket('d')
@@ -68,7 +69,7 @@ def handle_packet(self, packet):
 		t = packet.getType()
 
 		if t == PacketTypes.DATA:
-			self._queue.put_nowait(buf)
+			#self._queue.put_nowait(buf)
 			#print 'data packet'
 			self.respond_data()
 			return
@@ -85,6 +86,7 @@ def handle_packet(self, packet):
 
 	def main(self):
 		while 1:
+			print 'read()'
 			buf = self._reader.read()
 			packet = ReceivedCommandPacket(buf)
 

main.py

@@ -65,9 +65,11 @@ def etherdream_thread(queue):
 
 def main():
 
-	p3 = RepeaterProcess(DEVICE_MAC)
-	queue = p3.getQueue()
-	p3.start()
+	#p3 = RepeaterProcess(DEVICE_MAC)
+	#queue = p3.getQueue()
+	#p3.start()
+
+	queue = None
 
 	p2 = Process(target=etherdream_process, args=(queue,))
 	p2.start()

oldlib/dac2.py

@@ -136,6 +136,7 @@ def __init__(self, host, port = 7765):
 		first_status.dump()
 
 	def begin(self, lwm, rate):
+		print 'begin()'
 		cmd = struct.pack("<cHI", "b", lwm, rate)
 		self.conn.sendall(cmd)
 		return self.readresp("b")
@@ -154,22 +155,24 @@ def encode_point(self, point):
 			raise e
 
 	def write(self, points):
+		print 'write()'
 		epoints = map(self.encode_point, points)
 		cmd = struct.pack("<cH", "d", len(epoints))
 		data = cmd + "".join(epoints)
 		npoints = len(points)
 		ldata = len(data)
 		avg = ldata/npoints
 
-		print 'write() length: %d, num points: %d' % (len(data), len(points))
-		print 'Length per point: %d' % avg
-		print 'Length encoded points: %d' % len(epoints[0])
-		print 'Length command: %d' % len(cmd)
+		#print 'write() length: %d, num points: %d' % (len(data), len(points))
+		#print 'Length per point: %d' % avg
+		#print 'Length encoded points: %d' % len(epoints[0])
+		#print 'Length command: %d' % len(cmd)
 
 		self.conn.sendall(data)
 		return self.readresp("d")
 
 	def prepare(self):
+		print 'prepare()'
 		self.conn.sendall("p")
 		return self.readresp("p")
 
@@ -216,6 +219,7 @@ def play_stream(self, stream):
 			if not started:
 				self.begin(0, 30000)
 				started = 1
+				print 'started now'
 
 
 def find_dac():

reader.py

@@ -31,9 +31,6 @@ def _doRead(self):
 	def read(self):
 		self.count += 1
 
-		if self.count > 3:
-			sys.exit()
-
 		buf = ''
 		lengthRead = len(self._buf)
 		lengthExpect = 1024