Process incoming Nexa bits as they arrive

jherland · jherland · commit ab0ca8103ba8 · 2013-03-29T01:21:42.000+01:00
Don't wait for an invalid waveform until we start parsing bits
diff --git a/libraries/nexa_node b/libraries/nexa_node
@@ -1 +1 @@
-Subproject commit 52093fa14b0b00ae5f9fbd9f8a7a41f6afd3996f
+Subproject commit 9a5f53cf3b72ea4c386fc9fdc9aaea77177de15c
diff --git a/nexa_decoder/nexa_decoder.ino b/nexa_decoder/nexa_decoder.ino
@@ -112,7 +112,7 @@ void parse_32bit_cmd(NexaCommand & cmd, const char buf[32])
 }
 
 /*
- * Parse data form ring buffer, and generate + print NexaCommands.
+ * Parse data from ring buffer, and generate + print NexaCommands.
  */
 void decode_bits(RingBuffer<char> & rx_bits)
 {
@@ -142,6 +142,9 @@ void decode_bits(RingBuffer<char> & rx_bits)
 				parse_12bit_cmd(cmd, buf);
 			else if (version == NexaCommand::NEXA_32BIT)
 				parse_32bit_cmd(cmd, buf);
+#if DEBUG
+			Serial.println();
+#endif
 			cmd.print(Serial);
 			Serial.flush();
 
@@ -154,13 +157,12 @@ void decode_bits(RingBuffer<char> & rx_bits)
 
 void loop()
 {
-	if (pulse_parser(rf_port.rx_get_pulse()) &&
-	    !rx_bits.r_empty()) {
+	pulse_parser(rf_port.rx_get_pulse());
+	if (!rx_bits.r_empty()) {
 		size_t len = rx_bits.r_buf_len();
 		do {
 #if DEBUG
 			Serial.write((const byte *) rx_bits.r_buf(), len);
-			Serial.println();
 #endif
 			decode_bits(rx_bits);
 		} while (len = rx_bits.r_buf_len());
