* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
-
-/* Currently this can decode the temperature and id from Rubicson sensors
- *
- * the sensor sends 36 bits 12 times pwm modulated
- * the data is grouped into 9 nibles
- * [id0] [id1], [unk0] [temp0], [temp1] [temp2], [unk1] [unk2], [unk3]
- *
- * The id changes when the battery is changed in the sensor.
- * unk0 is always 1 0 0 0, most likely 2 channel bits as the sensor can recevice 3 channels
- * unk1-3 changes and the meaning is unknown
- * temp is 12 bit signed scaled by 10
- *
- * The sensor can be bought at Kjell&Co
- */
-
-/* Prologue sensor protocol
- *
- * the sensor sends 36 bits 7 times, before the first packet there is a pulse sent
- * the packets are pwm modulated
- *
- * the data is grouped in 9 nibles
- * [id0] [rid0] [rid1] [data0] [temp0] [temp1] [temp2] [humi0] [humi1]
- *
- * id0 is always 1001,9
- * rid is a random id that is generated when the sensor starts, could include battery status
- * the same batteries often generate the same id
- * data(3) is 0 the battery status, 1 ok, 0 low, first reading always say low
- * data(2) is 1 when the sensor sends a reading when pressing the button on the sensor
- * data(1,0)+1 forms the channel number that can be set by the sensor (1-3)
- * temp is 12 bit signed scaled by 10
- * humi0 is always 1100,c if no humidity sensor is available
- * humi1 is always 1100,c if no humidity sensor is available
- *
- * The sensor can be bought at Clas Ohlson
- */
-
-#include <errno.h>
-#include <signal.h>
-#include <string.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <time.h>
-
-#ifndef _WIN32
-#include <unistd.h>
-#else
-#include <Windows.h>
-#include <io.h>
-#include <fcntl.h>
-#include "getopt/getopt.h"
-#endif
+#include <stdbool.h>
#include "rtl-sdr.h"
+#include "rtl_433.h"
+#include "baseband.h"
+#include "pulse_detect.h"
+#include "pulse_demod.h"
+#include "data.h"
+#include "util.h"
-#define DEFAULT_SAMPLE_RATE 250000
-#define DEFAULT_FREQUENCY 433920000
-#define DEFAULT_HOP_TIME (60*10)
-#define DEFAULT_HOP_EVENTS 2
-#define DEFAULT_ASYNC_BUF_NUMBER 32
-#define DEFAULT_BUF_LENGTH (16 * 16384)
-#define DEFAULT_LEVEL_LIMIT 10000
-#define DEFAULT_DECIMATION_LEVEL 0
-#define MINIMAL_BUF_LENGTH 512
-#define MAXIMAL_BUF_LENGTH (256 * 16384)
-#define FILTER_ORDER 1
-#define MAX_PROTOCOLS 10
-#define SIGNAL_GRABBER_BUFFER (12 * DEFAULT_BUF_LENGTH)
-#define BITBUF_COLS 34
-#define BITBUF_ROWS 50
static int do_exit = 0;
-static int do_exit_async=0, frequencies=0, events=0;
+static int do_exit_async = 0, frequencies = 0, events = 0;
uint32_t frequency[MAX_PROTOCOLS];
time_t rawtime_old;
+int duration = 0;
+time_t stop_time;
int flag;
-uint32_t samp_rate=DEFAULT_SAMPLE_RATE;
+uint32_t samp_rate = DEFAULT_SAMPLE_RATE;
+float sample_file_pos = -1;
static uint32_t bytes_to_read = 0;
static rtlsdr_dev_t *dev = NULL;
-static uint16_t scaled_squares[256];
-static int debug_output = 0;
static int override_short = 0;
static int override_long = 0;
+int include_only = 0; // Option -I
+int debug_output = 0;
+int quiet_mode = 0;
+int utc_mode = 0;
+int overwrite_mode = 0;
-/* Supported modulation types */
-#define OOK_PWM_D 1 /* Pulses are of the same length, the distance varies */
-#define OOK_PWM_P 2 /* The length of the pulses varies */
-
-
-typedef struct {
- unsigned int id;
- char name[256];
- unsigned int modulation;
- unsigned int short_limit;
- unsigned int long_limit;
- unsigned int reset_limit;
- int (*json_callback)(uint8_t bits_buffer[BITBUF_ROWS][BITBUF_COLS]) ;
-} r_device;
-
-static int debug_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- int i,j,k;
- fprintf(stderr, "\n");
- for (i=0 ; i<BITBUF_ROWS ; i++) {
- fprintf(stderr, "[%02d] ",i);
- for (j=0 ; j<BITBUF_COLS ; j++) {
- fprintf(stderr, "%02x ", bb[i][j]);
- }
- fprintf(stderr, ": ");
- for (j=0 ; j<BITBUF_COLS ; j++) {
- for (k=7 ; k>=0 ; k--) {
- if (bb[i][j] & 1<<k)
- fprintf(stderr, "1");
- else
- fprintf(stderr, "0");
- }
- fprintf(stderr, " ");
- }
- fprintf(stderr, "\n");
- }
- fprintf(stderr, "\n");
-
- return 0;
-}
-
-uint8_t crc8( uint8_t *addr, uint8_t len)
-{
- uint8_t crc = 0;
-
- // Indicated changes are from reference CRC-8 function in OneWire library
- while (len--) {
- uint8_t inbyte = *addr++;
- int i;
- for (i = 8; i; i--) {
- uint8_t mix = (crc ^ inbyte) & 0x80; // changed from & 0x01
- crc <<= 1; // changed from right shift
- if (mix) crc ^= 0x31;// changed from 0x8C;
- inbyte <<= 1; // changed from right shift
- }
- }
- return crc;
-}
-
-void printBits(size_t const size, void const * const ptr)
-{
- unsigned char *b = (unsigned char*) ptr;
- unsigned char byte;
- int i, j;
-
- for (i=0;i<size;i++) {
-
- fprintf(stderr,"%2x:",b[i]);
-
- for (j=0;j<7;j++) {
- byte = b[i] & (1<<j);
- byte >>= j;
- fprintf(stderr,"%u", byte);
- }
- fprintf(stderr," ");
- }
- fprintf(stderr,"\n");
-}
-
-static int wh2_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- int i,j,k;
-
- uint8_t payload[4];
- int received_crc8,payload_crc8;
-
- int wh2_id;
- float wh2_temp;
- float wh2_humidity;
-
- if (bb[0][0] != 0xFE) return 0;
-
- payload[0] = bb[0][1]>>1;
- payload[1] = bb[0][2]>>1 | ((bb[0][1]&1) << 7 );
- payload[2] = bb[0][3]>>1 | ((bb[0][2]&1) << 7 );
- payload[3] = bb[0][4]>>1 | ((bb[0][3]&1) << 7 );
-
- received_crc8 = (bb[0][5]>>1) | ((bb[0][4]&1) << 7 );
-
- payload_crc8 = crc8(payload,4);
-
- if (payload_crc8 != received_crc8) {
- fprintf(stderr,"Bad WH2 payload CRC, skipping...\n");
- return 0;
- }
-
- wh2_id = (payload[0] << 4) + (payload[1] >> 4);
- wh2_temp = ((payload[1] & 0x7) << 8) + payload[2];
- if (payload[1] & 0x8) {
- wh2_temp = -wh2_temp;
- }
- wh2_temp = wh2_temp/10;
-
- wh2_humidity = payload[3];
-
- fprintf(stdout, "SENSOR:TYPE=WH2,ID=%X,HUMIDITY=%g,TEMPERATURE=%g\n",wh2_id,wh2_humidity,wh2_temp);
-
- return 1;
-
-}
-
-static int silvercrest_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- /* FIXME validate the received message better */
- if (bb[1][0] == 0xF8 &&
- bb[2][0] == 0xF8 &&
- bb[3][0] == 0xF8 &&
- bb[4][0] == 0xF8 &&
- bb[1][1] == 0x4d &&
- bb[2][1] == 0x4d &&
- bb[3][1] == 0x4d &&
- bb[4][1] == 0x4d) {
- /* Pretty sure this is a Silvercrest remote */
- fprintf(stdout, "BUTTON:TYPE=SILVERCREST,CODE=%02x-%02x-%02x-%02x-%02x\n",bb[1][0],bb[0][1],bb[0][2],bb[0][3],bb[0][4]);
-
- if (debug_output)
- debug_callback(bb);
-
- return 1;
- }
- return 0;
-}
-
-static int rubicson_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- int temperature_before_dec;
- int temperature_after_dec;
- int16_t temp;
- float ftemp;
-
- /* FIXME validate the received message better, figure out crc */
- if (bb[1][0] == bb[2][0] && bb[2][0] == bb[3][0] && bb[3][0] == bb[4][0] &&
- bb[4][0] == bb[5][0] && bb[5][0] == bb[6][0] && bb[6][0] == bb[7][0] && bb[7][0] == bb[8][0] &&
- bb[8][0] == bb[9][0] && (bb[5][0] != 0 && bb[5][1] != 0 && bb[5][2] != 0)) {
-
- /* Nible 3,4,5 contains 12 bits of temperature
- * The temperature is signed and scaled by 10 */
- temp = (int16_t)((uint16_t)(bb[0][1] << 12) | (bb[0][2] << 4));
- temp = temp >> 4;
- ftemp = (float)temp/10;
-
- fprintf(stdout, "SENSOR:TYPE=RUBICSON,ID=%X,TEMPERATURE=%f\n",bb[0][0],ftemp);
-
- if (debug_output)
- debug_callback(bb);
-
- return 1;
- }
- return 0;
-}
-
-static int prologue_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- int rid;
-
- int16_t temp2;
- float ftemp;
-
- /* FIXME validate the received message better */
- if (((bb[1][0]&0xF0) == 0x90 && (bb[2][0]&0xF0) == 0x90 && (bb[3][0]&0xF0) == 0x90 && (bb[4][0]&0xF0) == 0x90 &&
- (bb[5][0]&0xF0) == 0x90 && (bb[6][0]&0xF0) == 0x90) ||
- ((bb[1][0]&0xF0) == 0x50 && (bb[2][0]&0xF0) == 0x50 && (bb[3][0]&0xF0) == 0x50 && (bb[4][0]&0xF0) == 0x50)) {
-
- /* Prologue sensor */
- temp2 = (int16_t)((uint16_t)(bb[1][2] << 8) | (bb[1][3]&0xF0));
- temp2 = temp2 >> 4;
- ftemp = (float)temp2/10;
- rid = ((bb[1][0]&0x0F)<<4)|(bb[1][1]&0xF0)>>4;
- fprintf(stdout,
- "SENSOR:TYPE=PROLOGUE,BUTTON=%d,BATTERY=%s,TEMPERATURE=%f,HUMIDITY=%d,CHANNEL=%d,ID=%d,RID=%02x\n",
- bb[1][1]&0x04?1:0,
- bb[1][1]&0x08?"Ok":"Low",
- ftemp,
- ((bb[1][3]&0x0F)<<4)|(bb[1][4]>>4),
- (int)((bb[1][1]&0x03)+1),
- (int)((bb[1][0]&0xF0)>>4),
- rid);
-
- if (debug_output)
- debug_callback(bb);
-
- return 1;
- }
- return 0;
-}
-
-static int waveman_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- /* Two bits map to 2 states, 0 1 -> 0 and 1 1 -> 1 */
- int i;
- uint8_t nb[3] = {0};
-
- if (((bb[0][0]&0x55)==0x55) && ((bb[0][1]&0x55)==0x55) && ((bb[0][2]&0x55)==0x55) && ((bb[0][3]&0x55)==0x00)) {
- for (i=0 ; i<3 ; i++) {
- nb[i] |= ((bb[0][i]&0xC0)==0xC0) ? 0x00 : 0x01;
- nb[i] |= ((bb[0][i]&0x30)==0x30) ? 0x00 : 0x02;
- nb[i] |= ((bb[0][i]&0x0C)==0x0C) ? 0x00 : 0x04;
- nb[i] |= ((bb[0][i]&0x03)==0x03) ? 0x00 : 0x08;
- }
-
- fprintf(stdout,
- "BUTTON:TYPE=WAVEMAN,ID=%c,CHANNEL=%d,BUTTON=%d,STATE=%s\n",
- 'A'+nb[0],
- (int)((nb[1]>>2)+1),
- (int)((nb[1]&3)+1),
- ((nb[2]==0xe) ? "on" : "off"));
-
- if (debug_output)
- debug_callback(bb);
-
- return 1;
- }
- return 0;
-}
-
-static int steffen_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
-
- if (bb[0][0]==0x00 && ((bb[1][0]&0x07)==0x07) && bb[1][0]==bb[2][0] && bb[2][0]==bb[3][0]) {
-
- fprintf(stdout, "BUTTON:TYPE=STEFFAN,CODE=%d%d%d%d%d,",(bb[1][0]&0x80)>>7, (bb[1][0]&0x40)>>6, (bb[1][0]&0x20)>>5, (bb[1][0]&0x10)>>4, (bb[1][0]&0x08)>>3);
-
- if ((bb[1][2]&0x0f)==0x0e)
- fprintf(stdout, "BUTTON=A,");
- else if ((bb[1][2]&0x0f)==0x0d)
- fprintf(stdout, "BUTTON=B,");
- else if ((bb[1][2]&0x0f)==0x0b)
- fprintf(stdout, "BUTTON=C,");
- else if ((bb[1][2]&0x0f)==0x07)
- fprintf(stdout, "BUTTON=D,");
- else if ((bb[1][2]&0x0f)==0x0f)
- fprintf(stdout, "BUTTON=ALL,");
- else
- fprintf(stdout, "BUTTON=UNKNOWN,");
-
- if ((bb[1][2]&0xf0)==0xf0) {
- fprintf(stdout, "STATE=OFF\n");
- } else {
- fprintf(stdout, "STATE=ON\n");
- }
-
- if (debug_output)
- debug_callback(bb);
-
- return 1;
- }
- return 0;
-}
-
-
-uint16_t AD_POP(uint8_t bb[BITBUF_COLS], uint8_t bits, uint8_t bit) {
- uint16_t val = 0;
- uint8_t i, byte_no, bit_no;
- for (i=0;i<bits;i++) {
- byte_no= (bit+i)/8 ;
- bit_no =7-((bit+i)%8);
- if (bb[byte_no]&(1<<bit_no)) val = val | (1<<i);
- }
- return val;
-}
-
-static int em1000_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- // based on fs20.c
- uint8_t dec[10];
- uint8_t bytes=0;
- uint8_t bit=18; // preamble
- uint8_t bb_p[14];
- char* types[] = {"S", "?", "GZ"};
- uint8_t checksum_calculated = 0;
- uint8_t i;
- uint8_t stopbit;
- uint8_t checksum_received;
-
- // check and combine the 3 repetitions
- for (i = 0; i < 14; i++) {
- if(bb[0][i]==bb[1][i] || bb[0][i]==bb[2][i]) bb_p[i]=bb[0][i];
- else if(bb[1][i]==bb[2][i]) bb_p[i]=bb[1][i];
- else return 0;
- }
-
- // read 9 bytes with stopbit ...
- for (i = 0; i < 9; i++) {
- dec[i] = AD_POP (bb_p, 8, bit); bit+=8;
- stopbit=AD_POP (bb_p, 1, bit); bit+=1;
- if (!stopbit) {
-// fprintf(stderr, "!stopbit: %i\n", i);
- return 0;
- }
- checksum_calculated ^= dec[i];
- bytes++;
- }
-
- // Read checksum
- checksum_received = AD_POP (bb_p, 8, bit); bit+=8;
- if (checksum_received != checksum_calculated) {
-// fprintf(stderr, "checksum_received != checksum_calculated: %d %d\n", checksum_received, checksum_calculated);
- return 0;
- }
-
-//for (i = 0; i < bytes; i++) fprintf(stderr, "%02X ", dec[i]); fprintf(stderr, "\n");
-
- // based on 15_CUL_EM.pm
- fprintf(stdout, "SENSOR:TYPE=ELV-EM-1000,MODEL=%s,CODE=%d,SEQNO=%d,TOTAL=%d,CURRENT=%d,PEAK=%d\n",dec[0]>=1&&dec[0]<=3?types[dec[0]-1]:"?",dec[1],dec[2],dec[3]|dec[4]<<8,dec[5]|dec[6]<<8,dec[7]|dec[8]<<8);
-
- return 1;
-}
-
-static int ws2000_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- // based on http://www.dc3yc.privat.t-online.de/protocol.htm
- uint8_t dec[13];
- uint8_t nibbles=0;
- uint8_t bit=11; // preamble
- char* types[]={"!AS3", "AS2000/ASH2000/S2000/S2001A/S2001IA/ASH2200/S300IA", "!S2000R", "!S2000W", "S2001I/S2001ID", "!S2500H", "!Pyrano", "!KS200/KS300"};
- uint8_t check_calculated=0, sum_calculated=0;
- uint8_t i;
- uint8_t stopbit;
- uint8_t sum_received;
-
- dec[0] = AD_POP (bb[0], 4, bit); bit+=4;
- stopbit= AD_POP (bb[0], 1, bit); bit+=1;
- if (!stopbit) {
-//fprintf(stderr, "!stopbit\n");
- return 0;
- }
- check_calculated ^= dec[0];
- sum_calculated += dec[0];
-
- // read nibbles with stopbit ...
- for (i = 1; i <= (dec[0]==4?12:8); i++) {
- dec[i] = AD_POP (bb[0], 4, bit); bit+=4;
- stopbit= AD_POP (bb[0], 1, bit); bit+=1;
- if (!stopbit) {
-//fprintf(stderr, "!stopbit %i\n", i);
- return 0;
- }
- check_calculated ^= dec[i];
- sum_calculated += dec[i];
- nibbles++;
- }
-
- if (check_calculated) {
-//fprintf(stderr, "check_calculated (%d) != 0\n", check_calculated);
- return 0;
- }
-
- // Read sum
- sum_received = AD_POP (bb[0], 4, bit); bit+=4;
- sum_calculated+=5;
- sum_calculated&=0xF;
- if (sum_received != sum_calculated) {
-//fprintf(stderr, "sum_received (%d) != sum_calculated (%d) ", sum_received, sum_calculated);
- return 0;
- }
-
-//for (i = 0; i < nibbles; i++) fprintf(stderr, "%02X ", dec[i]); fprintf(stderr, "\n");
-
- fprintf(stdout, "SENSOR:TYPE=ELV-WS-2000,MODEL=%s,CODE=%d,TEMPERATURE=%s%d.%d,HUMIDITY=%d.%d",dec[0]<=7?types[dec[0]]:"?",dec[1]&7,dec[1]&8?"-":"",dec[4]*10+dec[3],dec[2],dec[7]*10+dec[6], dec[5]);
- if(dec[0]==4) {
- fprintf(stdout, "PRESSURE=%d\n", 200+dec[10]*100+dec[9]*10+dec[8]);
- } else {
- fprintf(stdout, "\n");
- }
-
- return 1;
-}
-
-// ** Acurite 5n1 functions **
-
-const float acurite_winddirections[] =
- { 337.5, 315.0, 292.5, 270.0, 247.5, 225.0, 202.5, 180,
- 157.5, 135.0, 112.5, 90.0, 67.5, 45.0, 22.5, 0.0 };
-
-static int acurite_raincounter = 0;
-
-static int acurite_crc(uint8_t row[BITBUF_COLS], int cols) {
- // sum of first n-1 bytes modulo 256 should equal nth byte
- int i;
- int sum = 0;
- for ( i=0; i < cols; i++)
- sum += row[i];
- if ( sum % 256 == row[cols] )
- return 1;
- else
- return 0;
-}
-
-static int acurite_detect(uint8_t *pRow) {
- int i;
- if ( pRow[0] != 0x00 ) {
- // invert bits due to wierd issue
- for (i = 0; i < 8; i++)
- pRow[i] = ~pRow[i] & 0xFF;
- pRow[0] |= pRow[8]; // fix first byte that has mashed leading bit
-
- if (acurite_crc(pRow, 7))
- return 1; // passes crc check
- }
- return 0;
-}
-
-static float acurite_getTemp (uint8_t highbyte, uint8_t lowbyte) {
- // range -40 to 158 F
- int highbits = (highbyte & 0x0F) << 7 ;
- int lowbits = lowbyte & 0x7F;
- int rawtemp = highbits | lowbits;
- float temp = (rawtemp - 400) / 10.0;
- return temp;
-}
-
-static int acurite_getWindSpeed (uint8_t highbyte, uint8_t lowbyte) {
- // range: 0 to 159 kph
- int highbits = ( highbyte & 0x1F) << 3;
- int lowbits = ( lowbyte & 0x70 ) >> 4;
- int speed = highbits | lowbits;
- return speed;
-}
-
-static float acurite_getWindDirection (uint8_t byte) {
- // 16 compass points, ccw from (NNW) to 15 (N)
- int direction = byte & 0x0F;
- return acurite_winddirections[direction];
-}
-
-static int acurite_getHumidity (uint8_t byte) {
- // range: 1 to 99 %RH
- int humidity = byte & 0x7F;
- return humidity;
-}
-
-static int acurite_getRainfallCounter (uint8_t highbyte, uint8_t lowbyte) {
- // range: 0 to 99.99 in, 0.01 in incr., rolling counter?
- int highbits = (highbyte & 0x3F) << 7 ;
- int lowbits = lowbyte & 0x7F;
- int raincounter = highbits | lowbits;
- return raincounter;
-}
-
-static int acurite5n1_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS]) {
- // acurite 5n1 weather sensor decoding for rtl_433
- // Jens Jensen 2014
- int i;
- uint8_t *buf = NULL;
- // run through rows til we find one with good crc (brute force)
- for (i=0; i < BITBUF_ROWS; i++) {
- if (acurite_detect(bb[i])) {
- buf = bb[i];
- break; // done
- }
- }
-
- if (buf) {
- // decode packet here
- fprintf(stdout, "SENSOR:TYPE=ACURITE");
- if (debug_output) {
- for (i=0; i < 8; i++)
- fprintf(stderr, "%02X ", buf[i]);
- fprintf(stderr, "CRC OK\n");
- }
-
- if ((buf[2] & 0x0F) == 1) {
- // wind speed, wind direction, rainfall
-
- float rainfall = 0.00;
- int raincounter = 0;
- if (acurite_raincounter > 0) {
- // track rainfall difference after first run
- raincounter = acurite_getRainfallCounter(buf[5], buf[6]);
- rainfall = ( raincounter - acurite_raincounter ) * 0.01;
- } else {
- // capture starting counter
- acurite_raincounter = raincounter;
- }
-
- fprintf(stdout, ",WINDSPEED=%d",
- acurite_getWindSpeed(buf[3], buf[4]));
- fprintf(stdout, ",WINDDIRECTION=%0.1f",
- acurite_getWindDirection(buf[4]));
- fprintf(stdout, ",RAINGAUGE: %0.2f\n", rainfall);
-
- } else if ((buf[2] & 0x0F) == 8) {
- // wind speed, temp, RH
- fprintf(stdout, ",WINDSPEED=%d",
- acurite_getWindSpeed(buf[3], buf[4]));
- fprintf(stdout, ",TEMPERATURE=%2.1f",
- acurite_getTemp(buf[4], buf[5]));
- fprintf(stdout, ",HUMIDITY=%d\n",
- acurite_getHumidity(buf[6]));
- }
- }
- //if (debug_output)
- // debug_callback(bb);
- return 1;
-}
-
-
-// timings based on samp_rate=1024000
-r_device rubicson = {
- /* .id = */ 1,
- /* .name = */ "Rubicson Temperature Sensor",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 1744/4,
- /* .long_limit = */ 3500/4,
- /* .reset_limit = */ 5000/4,
- /* .json_callback = */ &rubicson_callback,
-};
-
-r_device prologue = {
- /* .id = */ 2,
- /* .name = */ "Prologue Temperature Sensor",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 3500/4,
- /* .long_limit = */ 7000/4,
- /* .reset_limit = */ 15000/4,
- /* .json_callback = */ &prologue_callback,
-};
-
-r_device silvercrest = {
- /* .id = */ 3,
- /* .name = */ "Silvercrest Remote Control",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 600/4,
- /* .long_limit = */ 5000/4,
- /* .reset_limit = */ 15000/4,
- /* .json_callback = */ &silvercrest_callback,
-};
-
-r_device tech_line_fws_500 = {
- /* .id = */ 4,
- /* .name = */ "Tech Line FWS-500 Sensor",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 3500/4,
- /* .long_limit = */ 7000/4,
- /* .reset_limit = */ 15000/4,
- /* .json_callback = */ &rubicson_callback,
-};
-
-r_device generic_hx2262 = {
- /* .id = */ 5,
- /* .name = */ "Window/Door sensor",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 1300/4,
- /* .long_limit = */ 10000/4,
- /* .reset_limit = */ 40000/4,
- /* .json_callback = */ &silvercrest_callback,
-};
-
-r_device technoline_ws9118 = {
- /* .id = */ 6,
- /* .name = */ "Technoline WS9118",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 1800/4,
- /* .long_limit = */ 3500/4,
- /* .reset_limit = */ 15000/4,
- /* .json_callback = */ &debug_callback,
-};
-
-
-r_device elv_em1000 = {
- /* .id = */ 7,
- /* .name = */ "ELV EM 1000",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 750/4,
- /* .long_limit = */ 7250/4,
- /* .reset_limit = */ 30000/4,
- /* .json_callback = */ &em1000_callback,
-};
-
-r_device elv_ws2000 = {
- /* .id = */ 8,
- /* .name = */ "ELV WS 2000",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ (602+(1155-602)/2)/4,
- /* .long_limit = */ ((1755635-1655517)/2)/4, // no repetitions
- /* .reset_limit = */ ((1755635-1655517)*2)/4,
- /* .json_callback = */ &ws2000_callback,
-};
-
-r_device waveman = {
- /* .id = */ 6,
- /* .name = */ "Waveman Switch Transmitter",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 1000/4,
- /* .long_limit = */ 8000/4,
- /* .reset_limit = */ 30000/4,
- /* .json_callback = */ &waveman_callback,
-};
-
-r_device steffen = {
- /* .id = */ 9,
- /* .name = */ "Steffen Switch Transmitter",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 140,
- /* .long_limit = */ 270,
- /* .reset_limit = */ 1500,
- /* .json_callback = */ &steffen_callback,
-};
-
-r_device acurite5n1 = {
- /* .id = */ 10,
- /* .name = */ "Acurite 5n1 Weather Station",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 75,
- /* .long_limit = */ 220,
- /* .reset_limit = */ 20000,
- /* .json_callback = */ &acurite5n1_callback,
-};
-
-r_device wh2 = {
- /* .id = */ 11,
- /* .name = */ "WH2 Weather Station",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 150,
- /* .long_limit = */ 400,
- /* .reset_limit = */ 20000,
- /* .json_callback = */ &wh2_callback,
-};
-
-struct protocol_state {
- int (*callback)(uint8_t bits_buffer[BITBUF_ROWS][BITBUF_COLS]);
-
- /* bits state */
- int bits_col_idx;
- int bits_row_idx;
- int bits_bit_col_idx;
- uint8_t bits_buffer[BITBUF_ROWS][BITBUF_COLS];
- int16_t bits_per_row[BITBUF_ROWS];
- int bit_rows;
- unsigned int modulation;
-
- /* demod state */
- int pulse_length;
- int pulse_count;
- int pulse_distance;
- int sample_counter;
- int start_c;
-
- int packet_present;
- int pulse_start;
- int real_bits;
- int start_bit;
- /* pwm limits */
- int short_limit;
- int long_limit;
- int reset_limit;
-
-
-};
+typedef enum {
+ CONVERT_NATIVE,
+ CONVERT_SI,
+ CONVERT_CUSTOMARY
+} conversion_mode_t;
+static conversion_mode_t conversion_mode = CONVERT_NATIVE;
+int num_r_devices = 0;
struct dm_state {
- FILE *file;
- int save_data;
+ FILE *out_file;
int32_t level_limit;
- int32_t decimation_level;
- int16_t filter_buffer[MAXIMAL_BUF_LENGTH+FILTER_ORDER];
- int16_t* f_buf;
+ int16_t am_buf[MAXIMAL_BUF_LENGTH]; // AM demodulated signal (for OOK decoding)
+ union {
+ // These buffers aren't used at the same time, so let's use a union to save some memory
+ int16_t fm_buf[MAXIMAL_BUF_LENGTH]; // FM demodulated signal (for FSK decoding)
+ uint16_t temp_buf[MAXIMAL_BUF_LENGTH]; // Temporary buffer (to be optimized out..)
+ };
+ FilterState lowpass_filter_state;
+ DemodFM_State demod_FM_state;
+ int enable_FM_demod;
int analyze;
+ int analyze_pulses;
int debug_mode;
/* Signal grabber variables */
int r_dev_num;
struct protocol_state *r_devs[MAX_PROTOCOLS];
+ pulse_data_t pulse_data;
+ pulse_data_t fsk_pulse_data;
};
-void usage(void)
-{
- fprintf(stderr,
- "rtl_433, an ISM band generic data receiver for RTL2832 based DVB-T receivers\n\n"
- "Usage:\t[-d device_index (default: 0)]\n"
- "\t[-g gain (default: 0 for auto)]\n"
- "\t[-a analyze mode, print a textual description of the signal]\n"
- "\t[-t signal auto save, use it together with analyze mode (-a -t)\n"
- "\t[-l change the detection level used to determine pulses (0-3200) default: %i]\n"
- "\t[-f [-f...] receive frequency[s], default: %i Hz]\n"
- "\t[-s samplerate (default: %i Hz)]\n"
- "\t[-S force sync output (default: async)]\n"
- "\t[-r read data from file instead of from a receiver]\n"
- "\t[-p ppm_error (default: 0)]\n"
- "\t[-r test file name (indata)]\n"
- "\t[-m test file mode (0 rtl_sdr data, 1 rtl_433 data)]\n"
- "\t[-D print debug info on event\n"
- "\t[-z override short value\n"
- "\t[-x override long value\n"
- "\tfilename (a '-' dumps samples to stdout)\n\n", DEFAULT_LEVEL_LIMIT, DEFAULT_FREQUENCY, DEFAULT_SAMPLE_RATE);
+void usage(r_device *devices) {
+ int i;
+ char disabledc;
+
+ fprintf(stderr,
+ "rtl_433, an ISM band generic data receiver for RTL2832 based DVB-T receivers\n\n"
+ "Usage:\t= Tuner options =\n"
+ "\t[-d <RTL-SDR USB device index>] (default: 0)\n"
+ "\t[-g <gain>] (default: 0 for auto)\n"
+ "\t[-f <frequency>] [-f...] Receive frequency(s) (default: %i Hz)\n"
+ "\t[-p <ppm_error] Correct rtl-sdr tuner frequency offset error (default: 0)\n"
+ "\t[-s <sample rate>] Set sample rate (default: %i Hz)\n"
+ "\t[-S] Force sync output (default: async)\n"
+ "\t= Demodulator options =\n"
+ "\t[-R <device>] Enable only the specified device decoding protocol (can be used multiple times)\n"
+ "\t[-G] Enable all device protocols, included those disabled by default\n"
+ "\t[-l <level>] Change detection level used to determine pulses [0-16384] (0 = auto) (default: %i)\n"
+ "\t[-z <value>] Override short value in data decoder\n"
+ "\t[-x <value>] Override long value in data decoder\n"
+ "\t[-n <value>] Specify number of samples to take (each sample is 2 bytes: 1 each of I & Q)\n"
+ "\t= Analyze/Debug options =\n"
+ "\t[-a] Analyze mode. Print a textual description of the signal. Disables decoding\n"
+ "\t[-A] Pulse Analyzer. Enable pulse analyzis and decode attempt\n"
+ "\t[-I] Include only: 0 = all (default), 1 = unknown devices, 2 = known devices\n"
+ "\t[-D] Print debug info on event (repeat for more info)\n"
+ "\t[-q] Quiet mode, suppress non-data messages\n"
+ "\t[-W] Overwrite mode, disable checks to prevent files from being overwritten\n"
+ "\t= File I/O options =\n"
+ "\t[-t] Test signal auto save. Use it together with analyze mode (-a -t). Creates one file per signal\n"
+ "\t\t Note: Saves raw I/Q samples (uint8 pcm, 2 channel). Preferred mode for generating test files\n"
+ "\t[-r <filename>] Read data from input file instead of a receiver\n"
+ "\t[-m <mode>] Data file mode for input / output file (default: 0)\n"
+ "\t\t 0 = Raw I/Q samples (uint8, 2 channel)\n"
+ "\t\t 1 = AM demodulated samples (int16 pcm, 1 channel)\n"
+ "\t\t 2 = FM demodulated samples (int16) (experimental)\n"
+ "\t\t 3 = Raw I/Q samples (cf32, 2 channel)\n"
+ "\t\t Note: If output file is specified, input will always be I/Q\n"
+ "\t[-F] kv|json|csv Produce decoded output in given format. Not yet supported by all drivers.\n"
+ "\t[-C] native|si|customary Convert units in decoded output.\n"
+ "\t[-T] specify number of seconds to run\n"
+ "\t[-U] Print timestamps in UTC (this may also be accomplished by invocation with TZ environment variable set).\n"
+ "\t[<filename>] Save data stream to output file (a '-' dumps samples to stdout)\n\n",
+ DEFAULT_FREQUENCY, DEFAULT_SAMPLE_RATE, DEFAULT_LEVEL_LIMIT);
+
+ fprintf(stderr, "Supported device protocols:\n");
+ for (i = 0; i < num_r_devices; i++) {
+ if (devices[i].disabled)
+ disabledc = '*';
+ else
+ disabledc = ' ';
+
+ fprintf(stderr, " [%02d]%c %s\n", i + 1, disabledc, devices[i].name);
+ }
+ fprintf(stderr, "\n* Disabled by default, use -R n or -G\n");
+
exit(1);
}
#ifdef _WIN32
BOOL WINAPI
-sighandler(int signum)
-{
+sighandler(int signum) {
if (CTRL_C_EVENT == signum) {
fprintf(stderr, "Signal caught, exiting!\n");
do_exit = 1;
return FALSE;
}
#else
-static void sighandler(int signum)
-{
- fprintf(stderr, "Signal caught, exiting!\n");
+static void sighandler(int signum) {
+ if (signum == SIGPIPE) {
+ signal(SIGPIPE,SIG_IGN);
+ } else {
+ fprintf(stderr, "Signal caught, exiting!\n");
+ }
do_exit = 1;
rtlsdr_cancel_async(dev);
}
#endif
-/* precalculate lookup table for envelope detection */
-static void calc_squares() {
- int i;
- for (i=0 ; i<256 ; i++)
- scaled_squares[i] = (128-i) * (128-i);
-}
-
-/** This will give a noisy envelope of OOK/ASK signals
- * Subtract the bias (-128) and get an envelope estimation
- * The output will be written in the input buffer
- * @returns pointer to the input buffer
- */
-
-static void envelope_detect(unsigned char *buf, uint32_t len, int decimate)
-{
- uint16_t* sample_buffer = (uint16_t*) buf;
- unsigned int i;
- unsigned op = 0;
- unsigned int stride = 1<<decimate;
-
- for (i=0 ; i<len/2 ; i+=stride) {
- sample_buffer[op++] = scaled_squares[buf[2*i ]]+scaled_squares[buf[2*i+1]];
- }
-}
-
-static void demod_reset_bits_packet(struct protocol_state* p) {
- memset(p->bits_buffer, 0 ,BITBUF_ROWS*BITBUF_COLS);
- memset(p->bits_per_row, 0 ,BITBUF_ROWS);
- p->bits_col_idx = 0;
- p->bits_bit_col_idx = 7;
- p->bits_row_idx = 0;
- p->bit_rows = 0;
-}
-
-static void demod_add_bit(struct protocol_state* p, int bit) {
- p->bits_buffer[p->bits_row_idx][p->bits_col_idx] |= bit<<p->bits_bit_col_idx;
- p->bits_bit_col_idx--;
- if (p->bits_bit_col_idx<0) {
- p->bits_bit_col_idx = 7;
- p->bits_col_idx++;
- if (p->bits_col_idx>BITBUF_COLS-1) {
- p->bits_col_idx = BITBUF_COLS-1;
-// fprintf(stderr, "p->bits_col_idx>%i!\n", BITBUF_COLS-1);
- }
- }
- p->bits_per_row[p->bit_rows]++;
-}
-
-static void demod_next_bits_packet(struct protocol_state* p) {
- p->bits_col_idx = 0;
- p->bits_row_idx++;
- p->bits_bit_col_idx = 7;
- if (p->bits_row_idx>BITBUF_ROWS-1) {
- p->bits_row_idx = BITBUF_ROWS-1;
- //fprintf(stderr, "p->bits_row_idx>%i!\n", BITBUF_ROWS-1);
- }
- p->bit_rows++;
- if (p->bit_rows > BITBUF_ROWS-1)
- p->bit_rows -=1;
-}
-
-static void demod_print_bits_packet(struct protocol_state* p) {
- int i,j,k;
-
- fprintf(stderr, "\n");
- for (i=0 ; i<p->bit_rows+1 ; i++) {
- fprintf(stderr, "[%02d] {%d} ",i, p->bits_per_row[i]);
- for (j=0 ; j<((p->bits_per_row[i]+8)/8) ; j++) {
- fprintf(stderr, "%02x ", p->bits_buffer[i][j]);
- }
- fprintf(stderr, ": ");
- for (j=0 ; j<((p->bits_per_row[i]+8)/8) ; j++) {
- for (k=7 ; k>=0 ; k--) {
- if (p->bits_buffer[i][j] & 1<<k)
- fprintf(stderr, "1");
- else
- fprintf(stderr, "0");
- }
-// fprintf(stderr, "=0x%x ",demod->bits_buffer[i][j]);
- fprintf(stderr, " ");
- }
- fprintf(stderr, "\n");
- }
- fprintf(stderr, "\n");
- return;
-}
static void register_protocol(struct dm_state *demod, r_device *t_dev) {
- struct protocol_state *p = calloc(1,sizeof(struct protocol_state));
- p->short_limit = (float)t_dev->short_limit/((float)DEFAULT_SAMPLE_RATE/(float)samp_rate);
- p->long_limit = (float)t_dev->long_limit /((float)DEFAULT_SAMPLE_RATE/(float)samp_rate);
- p->reset_limit = (float)t_dev->reset_limit/((float)DEFAULT_SAMPLE_RATE/(float)samp_rate);
- p->modulation = t_dev->modulation;
- p->callback = t_dev->json_callback;
- demod_reset_bits_packet(p);
+ struct protocol_state *p = calloc(1, sizeof (struct protocol_state));
+ p->short_limit = (float) t_dev->short_limit / ((float) 1000000 / (float) samp_rate);
+ p->long_limit = (float) t_dev->long_limit / ((float) 1000000 / (float) samp_rate);
+ p->reset_limit = (float) t_dev->reset_limit / ((float) 1000000 / (float) samp_rate);
+ p->modulation = t_dev->modulation;
+ p->callback = t_dev->json_callback;
+ p->name = t_dev->name;
+ p->demod_arg = t_dev->demod_arg;
+ bitbuffer_clear(&p->bits);
demod->r_devs[demod->r_dev_num] = p;
demod->r_dev_num++;
- fprintf(stderr, "Registering protocol[%02d] %s\n",demod->r_dev_num, t_dev->name);
+ if (!quiet_mode) {
+ fprintf(stderr, "Registering protocol [%d] \"%s\"\n", demod->r_dev_num, t_dev->name);
+ }
- if (demod->r_dev_num > MAX_PROTOCOLS)
- fprintf(stderr, "Max number of protocols reached %d\n",MAX_PROTOCOLS);
+ if (demod->r_dev_num > MAX_PROTOCOLS) {
+ fprintf(stderr, "\n\nMax number of protocols reached %d\n", MAX_PROTOCOLS);
+ fprintf(stderr, "Increase MAX_PROTOCOLS and recompile\n");
+ exit(-1);
+ }
}
static unsigned int pulse_end = 0;
static unsigned int pulse_avg = 0;
static unsigned int signal_start = 0;
-static unsigned int signal_end = 0;
-static unsigned int signal_pulse_data[4000][3] = {{0}};
+static unsigned int signal_end = 0;
+static unsigned int signal_pulse_data[4000][3] = {
+ {0}};
static unsigned int signal_pulse_counter = 0;
+typedef struct output_handler {
+ /*data_printer_t*/ void *printer;
+ void (*aux_free)(void *aux);
+ FILE *file;
+ void *aux;
+ struct output_handler *next;
+} output_handler_t;
+static output_handler_t *output_handler = NULL;
+static output_handler_t **next_output_handler = &output_handler;
+
+/* handles incoming structured data by dumping it */
+void data_acquired_handler(data_t *data)
+{
+ if (conversion_mode == CONVERT_SI) {
+ for (data_t *d = data; d; d = d->next) {
+ if ((d->type == DATA_DOUBLE) &&
+ !strcmp(d->key, "temperature_F")) {
+ *(double*)d->value = fahrenheit2celsius(*(double*)d->value);
+ free(d->key);
+ d->key = strdup("temperature_C");
+ char *pos;
+ if (d->format &&
+ (pos = strrchr(d->format, 'F'))) {
+ *pos = 'C';
+ }
+ }
+ }
+ }
+ if (conversion_mode == CONVERT_CUSTOMARY) {
+ for (data_t *d = data; d; d = d->next) {
+ if ((d->type == DATA_DOUBLE) &&
+ !strcmp(d->key, "temperature_C")) {
+ *(double*)d->value = celsius2fahrenheit(*(double*)d->value);
+ free(d->key);
+ d->key = strdup("temperature_F");
+ char *pos;
+ if (d->format &&
+ (pos = strrchr(d->format, 'C'))) {
+ *pos = 'F';
+ }
+ }
+ }
+ }
+
+ for (output_handler_t *output = output_handler; output; output = output->next) {
+ data_print(data, output->file, output->printer, output->aux);
+ }
+ data_free(data);
+}
static void classify_signal() {
- unsigned int i,k, max=0, min=1000000, t;
+ unsigned int i, k, max = 0, min = 1000000, t;
unsigned int delta, count_min, count_max, min_new, max_new, p_limit;
unsigned int a[3], b[2], a_cnt[3], a_new[3], b_new[2];
unsigned int signal_distance_data[4000] = {0};
if (!signal_pulse_data[0][0])
return;
- for (i=0 ; i<1000 ; i++) {
+ for (i = 0; i < 1000; i++) {
if (signal_pulse_data[i][0] > 0) {
//fprintf(stderr, "[%03d] s: %d\t e:\t %d\t l:%d\n",
//i, signal_pulse_data[i][0], signal_pulse_data[i][1],
min = signal_pulse_data[i][2];
}
}
- t=(max+min)/2;
+ t = (max + min) / 2;
//fprintf(stderr, "\n\nMax: %d, Min: %d t:%d\n", max, min, t);
- delta = (max - min)*(max-min);
+ delta = (max - min)*(max - min);
//TODO use Lloyd-Max quantizer instead
- k=1;
- while((k < 10) && (delta > 0)) {
- min_new = 0; count_min = 0;
- max_new = 0; count_max = 0;
-
- for (i=0 ; i < 1000 ; i++) {
+ k = 1;
+ while ((k < 10) && (delta > 0)) {
+ min_new = 0;
+ count_min = 0;
+ max_new = 0;
+ count_max = 0;
+
+ for (i = 0; i < 1000; i++) {
if (signal_pulse_data[i][0] > 0) {
if (signal_pulse_data[i][2] < t) {
min_new = min_new + signal_pulse_data[i][2];
count_min++;
- }
- else {
+ } else {
max_new = max_new + signal_pulse_data[i][2];
count_max++;
}
}
}
- min_new = min_new / count_min;
- max_new = max_new / count_max;
+ if (count_min != 0 && count_max != 0) {
+ min_new = min_new / count_min;
+ max_new = max_new / count_max;
+ }
delta = (min - min_new)*(min - min_new) + (max - max_new)*(max - max_new);
min = min_new;
max = max_new;
- t = (min + max)/2;
+ t = (min + max) / 2;
- fprintf(stderr, "Iteration %d. t: %d min: %d (%d) max: %d (%d) delta %d\n", k,t, min, count_min, max, count_max, delta);
+ fprintf(stderr, "Iteration %d. t: %d min: %d (%d) max: %d (%d) delta %d\n", k, t, min, count_min, max, count_max, delta);
k++;
}
- for (i=0 ; i<1000 ; i++) {
+ for (i = 0; i < 1000; i++) {
if (signal_pulse_data[i][0] > 0) {
//fprintf(stderr, "%d\n", signal_pulse_data[i][1]);
}
}
/* 50% decision limit */
- if (max/min > 1) {
+ if (min != 0 && max / min > 1) {
fprintf(stderr, "Pulse coding: Short pulse length %d - Long pulse length %d\n", min, max);
signal_type = 2;
} else {
- fprintf(stderr, "Distance coding: Pulse length %d\n", (min+max)/2);
+ fprintf(stderr, "Distance coding: Pulse length %d\n", (min + max) / 2);
signal_type = 1;
}
- p_limit = (max+min)/2;
+ p_limit = (max + min) / 2;
/* Initial guesses */
a[0] = 1000000;
a[2] = 0;
- for (i=1 ; i<1000 ; i++) {
+ for (i = 1; i < 1000; i++) {
if (signal_pulse_data[i][0] > 0) {
-// fprintf(stderr, "[%03d] s: %d\t e:\t %d\t l:%d\t d:%d\n",
-// i, signal_pulse_data[i][0], signal_pulse_data[i][1],
-// signal_pulse_data[i][2], signal_pulse_data[i][0]-signal_pulse_data[i-1][1]);
- signal_distance_data[i-1] = signal_pulse_data[i][0]-signal_pulse_data[i-1][1];
- if (signal_distance_data[i-1] > a[2])
- a[2] = signal_distance_data[i-1];
- if (signal_distance_data[i-1] <= a[0])
- a[0] = signal_distance_data[i-1];
+ // fprintf(stderr, "[%03d] s: %d\t e:\t %d\t l:%d\t d:%d\n",
+ // i, signal_pulse_data[i][0], signal_pulse_data[i][1],
+ // signal_pulse_data[i][2], signal_pulse_data[i][0]-signal_pulse_data[i-1][1]);
+ signal_distance_data[i - 1] = signal_pulse_data[i][0] - signal_pulse_data[i - 1][1];
+ if (signal_distance_data[i - 1] > a[2])
+ a[2] = signal_distance_data[i - 1];
+ if (signal_distance_data[i - 1] <= a[0])
+ a[0] = signal_distance_data[i - 1];
}
}
min = a[0];
max = a[2];
- a[1] = (a[0]+a[2])/2;
-// for (i=0 ; i<1 ; i++) {
-// b[i] = (a[i]+a[i+1])/2;
-// }
- b[0] = (a[0]+a[1])/2;
- b[1] = (a[1]+a[2])/2;
-// fprintf(stderr, "a[0]: %d\t a[1]: %d\t a[2]: %d\t\n",a[0],a[1],a[2]);
-// fprintf(stderr, "b[0]: %d\t b[1]: %d\n",b[0],b[1]);
-
- k=1;
+ a[1] = (a[0] + a[2]) / 2;
+ // for (i=0 ; i<1 ; i++) {
+ // b[i] = (a[i]+a[i+1])/2;
+ // }
+ b[0] = (a[0] + a[1]) / 2;
+ b[1] = (a[1] + a[2]) / 2;
+ // fprintf(stderr, "a[0]: %d\t a[1]: %d\t a[2]: %d\t\n",a[0],a[1],a[2]);
+ // fprintf(stderr, "b[0]: %d\t b[1]: %d\n",b[0],b[1]);
+
+ k = 1;
delta = 10000000;
- while((k < 10) && (delta > 0)) {
- for (i=0 ; i<3 ; i++) {
+ while ((k < 10) && (delta > 0)) {
+ for (i = 0; i < 3; i++) {
a_new[i] = 0;
a_cnt[i] = 0;
}
- for (i=0 ; i < 1000 ; i++) {
+ for (i = 0; i < 1000; i++) {
if (signal_distance_data[i] > 0) {
if (signal_distance_data[i] < b[0]) {
a_new[0] += signal_distance_data[i];
a_cnt[0]++;
- } else if (signal_distance_data[i] < b[1] && signal_distance_data[i] >= b[0]){
+ } else if (signal_distance_data[i] < b[1] && signal_distance_data[i] >= b[0]) {
a_new[1] += signal_distance_data[i];
a_cnt[1]++;
} else if (signal_distance_data[i] >= b[1]) {
}
}
-// fprintf(stderr, "Iteration %d.", k);
+ // fprintf(stderr, "Iteration %d.", k);
delta = 0;
- for (i=0 ; i<3 ; i++) {
+ for (i = 0; i < 3; i++) {
if (a_cnt[i])
a_new[i] /= a_cnt[i];
- delta += (a[i]-a_new[i])*(a[i]-a_new[i]);
-// fprintf(stderr, "\ta[%d]: %d (%d)", i, a_new[i], a[i]);
+ delta += (a[i] - a_new[i])*(a[i] - a_new[i]);
+ // fprintf(stderr, "\ta[%d]: %d (%d)", i, a_new[i], a[i]);
a[i] = a_new[i];
}
-// fprintf(stderr, " delta %d\n", delta);
+ // fprintf(stderr, " delta %d\n", delta);
if (a[0] < min) {
a[0] = min;
-// fprintf(stderr, "Fixing a[0] = %d\n", min);
+ // fprintf(stderr, "Fixing a[0] = %d\n", min);
}
if (a[2] > max) {
a[0] = max;
-// fprintf(stderr, "Fixing a[2] = %d\n", max);
+ // fprintf(stderr, "Fixing a[2] = %d\n", max);
}
-// if (a[1] == 0) {
-// a[1] = (a[2]+a[0])/2;
-// fprintf(stderr, "Fixing a[1] = %d\n", a[1]);
-// }
-
-// fprintf(stderr, "Iteration %d.", k);
- for (i=0 ; i<2 ; i++) {
-// fprintf(stderr, "\tb[%d]: (%d) ", i, b[i]);
- b[i] = (a[i]+a[i+1])/2;
-// fprintf(stderr, "%d ", b[i]);
+ // if (a[1] == 0) {
+ // a[1] = (a[2]+a[0])/2;
+ // fprintf(stderr, "Fixing a[1] = %d\n", a[1]);
+ // }
+
+ // fprintf(stderr, "Iteration %d.", k);
+ for (i = 0; i < 2; i++) {
+ // fprintf(stderr, "\tb[%d]: (%d) ", i, b[i]);
+ b[i] = (a[i] + a[i + 1]) / 2;
+ // fprintf(stderr, "%d ", b[i]);
}
-// fprintf(stderr, "\n");
+ // fprintf(stderr, "\n");
k++;
}
a[1] = override_long;
}
- if (a[1]<a[0]) {
- a[1]=a[0]+1;
- }
+ fprintf(stderr, "\nShort distance: %d, long distance: %d, packet distance: %d\n", a[0], a[1], a[2]);
+ fprintf(stderr, "\np_limit: %d\n", p_limit);
- if (a[2]<a[1]*2) {
- a[2] = a[1]*2;
- }
-
- fprintf(stderr, "\nShort distance: %d, long distance: %d, packet distance: %d\n",a[0],a[1],a[2]);
- fprintf(stderr, "\np_limit: %d\n",p_limit);
-
- demod_reset_bits_packet(&p);
+ bitbuffer_clear(&p.bits);
if (signal_type == 1) {
- for(i=0 ; i<1000 ; i++){
+ for (i = 0; i < 1000; i++) {
if (signal_distance_data[i] > 0) {
- if (signal_distance_data[i] < (a[0]+a[1])/2) {
-// fprintf(stderr, "0 [%d] %d < %d\n",i, signal_distance_data[i], (a[0]+a[1])/2);
- demod_add_bit(&p, 0);
- } else if ((signal_distance_data[i] > (a[0]+a[1])/2) && (signal_distance_data[i] < (a[1]+a[2])/2)) {
-// fprintf(stderr, "0 [%d] %d > %d\n",i, signal_distance_data[i], (a[0]+a[1])/2);
- demod_add_bit(&p, 1);
- } else if (signal_distance_data[i] > (a[1]+a[2])/2) {
-// fprintf(stderr, "0 [%d] %d > %d\n",i, signal_distance_data[i], (a[1]+a[2])/2);
- demod_next_bits_packet(&p);
+ if (signal_distance_data[i] < (a[0] + a[1]) / 2) {
+ // fprintf(stderr, "0 [%d] %d < %d\n",i, signal_distance_data[i], (a[0]+a[1])/2);
+ bitbuffer_add_bit(&p.bits, 0);
+ } else if ((signal_distance_data[i] > (a[0] + a[1]) / 2) && (signal_distance_data[i] < (a[1] + a[2]) / 2)) {
+ // fprintf(stderr, "0 [%d] %d > %d\n",i, signal_distance_data[i], (a[0]+a[1])/2);
+ bitbuffer_add_bit(&p.bits, 1);
+ } else if (signal_distance_data[i] > (a[1] + a[2]) / 2) {
+ // fprintf(stderr, "0 [%d] %d > %d\n",i, signal_distance_data[i], (a[1]+a[2])/2);
+ bitbuffer_add_row(&p.bits);
}
- }
+ }
}
- demod_print_bits_packet(&p);
+ bitbuffer_print(&p.bits);
}
if (signal_type == 2) {
- for(i=0 ; i<1000 ; i++){
- if(signal_pulse_data[i][2] > 0) {
+ for (i = 0; i < 1000; i++) {
+ if (signal_pulse_data[i][2] > 0) {
if (signal_pulse_data[i][2] < p_limit) {
-// fprintf(stderr, "0 [%d] %d < %d\n",i, signal_pulse_data[i][2], p_limit);
- demod_add_bit(&p, 0);
+ // fprintf(stderr, "0 [%d] %d < %d\n",i, signal_pulse_data[i][2], p_limit);
+ bitbuffer_add_bit(&p.bits, 0);
} else {
-// fprintf(stderr, "1 [%d] %d > %d\n",i, signal_pulse_data[i][2], p_limit);
- demod_add_bit(&p, 1);
+ // fprintf(stderr, "1 [%d] %d > %d\n",i, signal_pulse_data[i][2], p_limit);
+ bitbuffer_add_bit(&p.bits, 1);
}
- if ((signal_distance_data[i] >= (a[1]+a[2])/2)) {
-// fprintf(stderr, "\\n [%d] %d > %d\n",i, signal_distance_data[i], (a[1]+a[2])/2);
- demod_next_bits_packet(&p);
+ if ((signal_distance_data[i] >= (a[1] + a[2]) / 2)) {
+ // fprintf(stderr, "\\n [%d] %d > %d\n",i, signal_distance_data[i], (a[1]+a[2])/2);
+ bitbuffer_add_row(&p.bits);
}
}
}
- demod_print_bits_packet(&p);
+ bitbuffer_print(&p.bits);
}
- for (i=0 ; i<1000 ; i++) {
+ for (i = 0; i < 1000; i++) {
signal_pulse_data[i][0] = 0;
signal_pulse_data[i][1] = 0;
signal_pulse_data[i][2] = 0;
};
-
-static void pwm_analyze(struct dm_state *demod, int16_t *buf, uint32_t len)
-{
+static void pwm_analyze(struct dm_state *demod, int16_t *buf, uint32_t len) {
unsigned int i;
+ int32_t threshold = (demod->level_limit ? demod->level_limit : 8000); // Does not support auto level. Use old default instead.
- for (i=0 ; i<len ; i++) {
- if (buf[i] > demod->level_limit) {
+ for (i = 0; i < len; i++) {
+ if (buf[i] > threshold) {
if (!signal_start)
signal_start = counter;
if (print) {
signal_pulse_data[signal_pulse_counter][0] = counter;
signal_pulse_data[signal_pulse_counter][1] = -1;
signal_pulse_data[signal_pulse_counter][2] = -1;
- if (debug_output) fprintf(stderr, "pulse_distance %d\n",counter-pulse_end);
- if (debug_output) fprintf(stderr, "pulse_start distance %d\n",pulse_start-prev_pulse_start);
- if (debug_output) fprintf(stderr, "pulse_start[%d] found at sample %d, value = %d\n",pulses_found, counter, buf[i]);
+ if (debug_output) fprintf(stderr, "pulse_distance %d\n", counter - pulse_end);
+ if (debug_output) fprintf(stderr, "pulse_start distance %d\n", pulse_start - prev_pulse_start);
+ if (debug_output) fprintf(stderr, "pulse_start[%d] found at sample %d, value = %d\n", pulses_found, counter, buf[i]);
prev_pulse_start = pulse_start;
- print =0;
+ print = 0;
print2 = 1;
}
}
counter++;
- if (buf[i] < demod->level_limit) {
+ if (buf[i] < threshold) {
if (print2) {
- pulse_avg += counter-pulse_start;
+ pulse_avg += counter - pulse_start;
if (debug_output) fprintf(stderr, "pulse_end [%d] found at sample %d, pulse length = %d, pulse avg length = %d\n",
- pulses_found, counter, counter-pulse_start, pulse_avg/pulses_found);
+ pulses_found, counter, counter - pulse_start, pulse_avg / pulses_found);
pulse_end = counter;
print2 = 0;
signal_pulse_data[signal_pulse_counter][1] = counter;
- signal_pulse_data[signal_pulse_counter][2] = counter-pulse_start;
+ signal_pulse_data[signal_pulse_counter][2] = counter - pulse_start;
signal_pulse_counter++;
if (signal_pulse_counter >= 4000) {
signal_pulse_counter = 0;
print = 1;
if (signal_start && (pulse_end + 50000 < counter)) {
signal_end = counter - 40000;
- fprintf(stderr, "*** signal_start = %d, signal_end = %d\n",signal_start-10000, signal_end);
- fprintf(stderr, "signal_len = %d, pulses = %d\n", signal_end-(signal_start-10000), pulses_found);
+ fprintf(stderr, "*** signal_start = %d, signal_end = %d\n", signal_start - 10000, signal_end);
+ fprintf(stderr, "signal_len = %d, pulses = %d\n", signal_end - (signal_start - 10000), pulses_found);
pulses_found = 0;
classify_signal();
signal_pulse_counter = 0;
if (demod->sg_buf) {
- int start_pos, signal_bszie, wlen, wrest=0, sg_idx, idx;
+ int start_pos, signal_bszie, wlen, wrest = 0, sg_idx, idx;
char sgf_name[256] = {0};
FILE *sgfp;
- sprintf(sgf_name, "gfile%03d.data",demod->signal_grabber);
- demod->signal_grabber++;
- signal_bszie = 2*(signal_end-(signal_start-10000));
- signal_bszie = (131072-(signal_bszie%131072)) + signal_bszie;
- sg_idx = demod->sg_index-demod->sg_len;
+ while (1) {
+ sprintf(sgf_name, "gfile%03d.data", demod->signal_grabber);
+ demod->signal_grabber++;
+ if (access(sgf_name, F_OK) == -1 || overwrite_mode) {
+ break;
+ }
+ }
+
+ signal_bszie = 2 * (signal_end - (signal_start - 10000));
+ signal_bszie = (131072 - (signal_bszie % 131072)) + signal_bszie;
+ sg_idx = demod->sg_index - demod->sg_len;
if (sg_idx < 0)
- sg_idx = SIGNAL_GRABBER_BUFFER-demod->sg_len;
- idx = (i-40000)*2;
- start_pos = sg_idx+idx-signal_bszie;
+ sg_idx = SIGNAL_GRABBER_BUFFER - demod->sg_len;
+ idx = (i - 40000)*2;
+ start_pos = sg_idx + idx - signal_bszie;
fprintf(stderr, "signal_bszie = %d - sg_index = %d\n", signal_bszie, demod->sg_index);
fprintf(stderr, "start_pos = %d - buffer_size = %d\n", start_pos, SIGNAL_GRABBER_BUFFER);
if (signal_bszie > SIGNAL_GRABBER_BUFFER)
fprintf(stderr, "Signal bigger then buffer, signal = %d > buffer %d !!\n", signal_bszie, SIGNAL_GRABBER_BUFFER);
if (start_pos < 0) {
- start_pos = SIGNAL_GRABBER_BUFFER+start_pos;
+ start_pos = SIGNAL_GRABBER_BUFFER + start_pos;
fprintf(stderr, "restart_pos = %d\n", start_pos);
}
- fprintf(stderr, "*** Saving signal to file %s\n",sgf_name);
+ fprintf(stderr, "*** Saving signal to file %s\n", sgf_name);
sgfp = fopen(sgf_name, "wb");
if (!sgfp) {
fprintf(stderr, "Failed to open %s\n", sgf_name);
wlen = SIGNAL_GRABBER_BUFFER - start_pos;
wrest = signal_bszie - wlen;
}
- fprintf(stderr, "*** Writing data from %d, len %d\n",start_pos, wlen);
+ fprintf(stderr, "*** Writing data from %d, len %d\n", start_pos, wlen);
fwrite(&demod->sg_buf[start_pos], 1, wlen, sgfp);
if (wrest) {
- fprintf(stderr, "*** Writing data from %d, len %d\n",0, wrest);
- fwrite(&demod->sg_buf[0], 1, wrest, sgfp);
+ fprintf(stderr, "*** Writing data from %d, len %d\n", 0, wrest);
+ fwrite(&demod->sg_buf[0], 1, wrest, sgfp);
}
fclose(sgfp);
return;
}
-/* The distance between pulses decodes into bits */
-
-static void pwm_d_decode(struct dm_state *demod, struct protocol_state* p, int16_t *buf, uint32_t len) {
- unsigned int i;
-
- for (i=0 ; i<len ; i++) {
- if (buf[i] > demod->level_limit) {
- p->pulse_count = 1;
- p->start_c = 1;
- }
- if (p->pulse_count && (buf[i] < demod->level_limit)) {
- p->pulse_length = 0;
- p->pulse_distance = 1;
- p->sample_counter = 0;
- p->pulse_count = 0;
- }
- if (p->start_c) p->sample_counter++;
- if (p->pulse_distance && (buf[i] > demod->level_limit)) {
- if (p->sample_counter < p->short_limit) {
- demod_add_bit(p, 0);
- } else if (p->sample_counter < p->long_limit) {
- demod_add_bit(p, 1);
- } else {
- demod_next_bits_packet(p);
- p->pulse_count = 0;
- p->sample_counter = 0;
- }
- p->pulse_distance = 0;
- }
- if (p->sample_counter > p->reset_limit) {
- p->start_c = 0;
- p->sample_counter = 0;
- p->pulse_distance = 0;
- if (p->callback)
- events+=p->callback(p->bits_buffer);
- else
- demod_print_bits_packet(p);
- demod_reset_bits_packet(p);
- }
+static void rtlsdr_callback(unsigned char *iq_buf, uint32_t len, void *ctx) {
+ struct dm_state *demod = ctx;
+ int i;
+ char time_str[LOCAL_TIME_BUFLEN];
+
+ if (do_exit || do_exit_async)
+ return;
+
+ if ((bytes_to_read > 0) && (bytes_to_read < len)) {
+ len = bytes_to_read;
+ do_exit = 1;
+ rtlsdr_cancel_async(dev);
+ }
+
+ if (demod->signal_grabber) {
+ //fprintf(stderr, "[%d] sg_index - len %d\n", demod->sg_index, len );
+ memcpy(&demod->sg_buf[demod->sg_index], iq_buf, len);
+ demod->sg_len = len;
+ demod->sg_index += len;
+ if (demod->sg_index + len > SIGNAL_GRABBER_BUFFER)
+ demod->sg_index = 0;
+ }
+
+ // AM demodulation
+ envelope_detect(iq_buf, demod->temp_buf, len/2);
+ baseband_low_pass_filter(demod->temp_buf, demod->am_buf, len/2, &demod->lowpass_filter_state);
+
+ // FM demodulation
+ if (demod->enable_FM_demod) {
+ baseband_demod_FM(iq_buf, demod->fm_buf, len/2, &demod->demod_FM_state);
+ }
+
+ // Handle special input formats
+ if(!demod->out_file) { // If output file is specified we always assume I/Q input
+ if (demod->debug_mode == 1) { // The IQ buffer is really AM demodulated data
+ memcpy(demod->am_buf, iq_buf, len);
+ } else if (demod->debug_mode == 2) { // The IQ buffer is really FM demodulated data
+ fprintf(stderr, "Reading FM modulated data not implemented yet!\n");
+ }
+ }
+
+ if (demod->analyze || (demod->out_file == stdout)) { // We don't want to decode devices when outputting to stdout
+ pwm_analyze(demod, demod->am_buf, len / 2);
+ } else {
+ // Detect a package and loop through demodulators with pulse data
+ int package_type = 1; // Just to get us started
+ while(package_type) {
+ int p_events = 0; // Sensor events successfully detected per package
+ package_type = pulse_detect_package(demod->am_buf, demod->fm_buf, len/2, demod->level_limit, samp_rate, &demod->pulse_data, &demod->fsk_pulse_data);
+ if (package_type == 1) {
+ if(demod->analyze_pulses) fprintf(stderr, "Detected OOK package\t@ %s\n", local_time_str(0, time_str));
+ for (i = 0; i < demod->r_dev_num; i++) {
+ switch (demod->r_devs[i]->modulation) {
+ case OOK_PULSE_PCM_RZ:
+ p_events += pulse_demod_pcm(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_PPM_RAW:
+ p_events += pulse_demod_ppm(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_PWM_PRECISE:
+ p_events += pulse_demod_pwm_precise(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_PWM_RAW:
+ p_events += pulse_demod_pwm(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_PWM_TERNARY:
+ p_events += pulse_demod_pwm_ternary(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_MANCHESTER_ZEROBIT:
+ p_events += pulse_demod_manchester_zerobit(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_CLOCK_BITS:
+ p_events += pulse_demod_clock_bits(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ case OOK_PULSE_PWM_OSV1:
+ p_events += pulse_demod_osv1(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ // FSK decoders
+ case FSK_PULSE_PCM:
+ case FSK_PULSE_PWM_RAW:
+ break;
+ case FSK_PULSE_MANCHESTER_ZEROBIT:
+ p_events += pulse_demod_manchester_zerobit(&demod->pulse_data, demod->r_devs[i]);
+ break;
+ default:
+ fprintf(stderr, "Unknown modulation %d in protocol!\n", demod->r_devs[i]->modulation);
+ }
+ } // for demodulators
+ if(debug_output > 1) pulse_data_print(&demod->pulse_data);
+ if(demod->analyze_pulses && (include_only == 0 || (include_only == 1 && p_events == 0) || (include_only == 2 && p_events > 0)) ) {
+ pulse_analyzer(&demod->pulse_data, samp_rate);
+ }
+ } else if (package_type == 2) {
+ if(demod->analyze_pulses) fprintf(stderr, "Detected FSK package\t@ %s\n", local_time_str(0, time_str));
+ for (i = 0; i < demod->r_dev_num; i++) {
+ switch (demod->r_devs[i]->modulation) {
+ // OOK decoders
+ case OOK_PULSE_PCM_RZ:
+ case OOK_PULSE_PPM_RAW:
+ case OOK_PULSE_PWM_PRECISE:
+ case OOK_PULSE_PWM_RAW:
+ case OOK_PULSE_PWM_TERNARY:
+ case OOK_PULSE_MANCHESTER_ZEROBIT:
+ case OOK_PULSE_CLOCK_BITS:
+ case OOK_PULSE_PWM_OSV1:
+ break;
+ case FSK_PULSE_PCM:
+ p_events += pulse_demod_pcm(&demod->fsk_pulse_data, demod->r_devs[i]);
+ break;
+ case FSK_PULSE_PWM_RAW:
+ p_events += pulse_demod_pwm(&demod->fsk_pulse_data, demod->r_devs[i]);
+ break;
+ case FSK_PULSE_MANCHESTER_ZEROBIT:
+ p_events += pulse_demod_manchester_zerobit(&demod->fsk_pulse_data, demod->r_devs[i]);
+ break;
+ default:
+ fprintf(stderr, "Unknown modulation %d in protocol!\n", demod->r_devs[i]->modulation);
+ }
+ } // for demodulators
+ if(debug_output > 1) pulse_data_print(&demod->fsk_pulse_data);
+ if(demod->analyze_pulses && (include_only == 0 || (include_only == 1 && p_events == 0) || (include_only == 2 && p_events > 0)) ) {
+ pulse_analyzer(&demod->fsk_pulse_data, samp_rate);
+ }
+ } // if (package_type == ...
+ } // while(package_type)...
+ } // if (demod->analyze...
+
+ if (demod->out_file) {
+ uint8_t* out_buf = iq_buf; // Default is to dump IQ samples
+ if (demod->debug_mode == 1) { // AM data
+ out_buf = (uint8_t*)demod->am_buf;
+ } else if (demod->debug_mode == 2) { // FM data
+ out_buf = (uint8_t*)demod->fm_buf;
+ }
+ if (fwrite(out_buf, 1, len, demod->out_file) != len) {
+ fprintf(stderr, "Short write, samples lost, exiting!\n");
+ rtlsdr_cancel_async(dev);
+ }
+ }
+
+ if (bytes_to_read > 0)
+ bytes_to_read -= len;
+
+ time_t rawtime;
+ time(&rawtime);
+ if (frequencies > 1) {
+ if (difftime(rawtime, rawtime_old) > DEFAULT_HOP_TIME || events >= DEFAULT_HOP_EVENTS) {
+ rawtime_old = rawtime;
+ events = 0;
+ do_exit_async = 1;
+ rtlsdr_cancel_async(dev);
+ }
+ }
+ if (duration > 0 && rawtime >= stop_time) {
+ do_exit_async = do_exit = 1;
+ fprintf(stderr, "Time expired, exiting!\n");
+ rtlsdr_cancel_async(dev);
}
}
-/* The length of pulses decodes into bits */
-
-static void pwm_p_decode(struct dm_state *demod, struct protocol_state* p, int16_t *buf, uint32_t len) {
- unsigned int i;
-
- for (i=0 ; i<len ; i++) {
- if (buf[i] > demod->level_limit && !p->start_bit) {
- /* start bit detected */
- p->start_bit = 1;
- p->start_c = 1;
- p->sample_counter = 0;
- if (debug_output)
- fprintf(stderr, "start bit pulse start detected\n");
- }
-
- if (!p->real_bits && p->start_bit && (buf[i] < demod->level_limit)) {
- /* end of startbit */
- p->real_bits = 1;
- p->pulse_length = 0;
- if (debug_output)
- fprintf(stderr, "start bit pulse end detected\n");
- }
- if (p->start_c) p->sample_counter++;
-
-
- if (!p->pulse_start && p->real_bits && (buf[i] > demod->level_limit)) {
- /* save the pulse start, it will never be zero */
- p->pulse_start = p->sample_counter;
- if (debug_output)
- fprintf(stderr, "real bit pulse start detected\n");
-
- }
-
- if (p->real_bits && p->pulse_start && (buf[i] < demod->level_limit)) {
- /* end of pulse */
-
- p->pulse_length = p->sample_counter-p->pulse_start;
- if (debug_output) {
- fprintf(stderr, "real bit pulse end detected %d\n", p->pulse_length);
- fprintf(stderr, "space duration %d\n", p->sample_counter);
- }
-
- if (p->pulse_length <= p->short_limit) {
- if (debug_output)
- fprintf(stderr, "1 received\n");
- demod_add_bit(p, 1);
- } else {
- if (debug_output)
- fprintf(stderr, "0 received\n");
- demod_add_bit(p, 0);
+// find the fields output for CSV
+void *determine_csv_fields(r_device* devices, int num_devices)
+{
+ int i, j;
+ int cur_output_fields = 0;
+ int num_output_fields = 0;
+ void *csv_aux;
+ const char **output_fields = NULL;
+ for (i = 0; i < num_devices; i++)
+ if (!devices[i].disabled) {
+ if (devices[i].fields)
+ for (int c = 0; devices[i].fields[c]; ++c)
+ ++num_output_fields;
+ else
+ fprintf(stderr, "rtl_433: warning: %d \"%s\" does not support CSV output\n",
+ i, devices[i].name);
+ }
+ output_fields = calloc(num_output_fields + 1, sizeof(char*));
+ for (i = 0; i < num_devices; i++) {
+ if (!devices[i].disabled && devices[i].fields) {
+ for (int c = 0; devices[i].fields[c]; ++c) {
+ output_fields[cur_output_fields] = devices[i].fields[c];
+ ++cur_output_fields;
}
- p->sample_counter = 0;
- p->pulse_start = 0;
- }
-
- if (p->real_bits && (p->pulse_length > p->long_limit)) {
- if (debug_output)
- fprintf(stderr, "End of packet\n");
- demod_next_bits_packet(p);
-
- p->start_bit = 0;
- p->real_bits = 0;
}
+ }
- if (p->sample_counter > p->reset_limit) {
- p->start_c = 0;
- p->sample_counter = 0;
- if (p->callback)
- events+=p->callback(p->bits_buffer);
- else
- demod_print_bits_packet(p);
- demod_reset_bits_packet(p);
+ csv_aux = data_csv_init(output_fields, num_output_fields);
+ free(output_fields);
+ return csv_aux;
+}
- p->start_bit = 0;
- p->real_bits = 0;
- }
+void add_json_output()
+{
+ output_handler_t *output = calloc(1, sizeof(output_handler_t));
+ if (!output) {
+ fprintf(stderr, "rtl_433: failed to allocate memory for output handler\n");
+ exit(1);
}
+ output->printer = &data_json_printer;
+ output->file = stdout;
+ *next_output_handler = output;
+ next_output_handler = &output->next;
}
-
-
-/** Something that might look like a IIR lowpass filter
- *
- * [b,a] = butter(1, 0.01) -> quantizes nicely thus suitable for fixed point
- * Q1.15*Q15.0 = Q16.15
- * Q16.15>>1 = Q15.14
- * Q15.14 + Q15.14 + Q15.14 could possibly overflow to 17.14
- * but the b coeffs are small so it wont happen
- * Q15.14>>14 = Q15.0 \o/
- */
-
-static uint16_t lp_xmem[FILTER_ORDER] = {0};
-
-#define F_SCALE 15
-#define S_CONST (1<<F_SCALE)
-#define FIX(x) ((int)(x*S_CONST))
-
-int a[FILTER_ORDER+1] = {FIX(1.00000),FIX(0.96907)};
-int b[FILTER_ORDER+1] = {FIX(0.015466),FIX(0.015466)};
-
-static void low_pass_filter(uint16_t *x_buf, int16_t *y_buf, uint32_t len)
+void add_csv_output(void *aux_data)
{
- unsigned int i;
-
- /* Calculate first sample */
- y_buf[0] = ((a[1]*y_buf[-1]>>1) + (b[0]*x_buf[0]>>1) + (b[1]*lp_xmem[0]>>1)) >> (F_SCALE-1);
- for (i=1 ; i<len ; i++) {
- y_buf[i] = ((a[1]*y_buf[i-1]>>1) + (b[0]*x_buf[i]>>1) + (b[1]*x_buf[i-1]>>1)) >> (F_SCALE-1);
+ if (!aux_data) {
+ fprintf(stderr, "rtl_433: failed to allocate memory for CSV auxiliary data\n");
+ exit(1);
}
-
- /* Save last sample */
- memcpy(lp_xmem, &x_buf[len-1-FILTER_ORDER], FILTER_ORDER*sizeof(int16_t));
- memcpy(&y_buf[-FILTER_ORDER], &y_buf[len-1-FILTER_ORDER], FILTER_ORDER*sizeof(int16_t));
- //fprintf(stderr, "%d\n", y_buf[0]);
+ output_handler_t *output = calloc(1, sizeof(output_handler_t));
+ if (!output) {
+ fprintf(stderr, "rtl_433: failed to allocate memory for output handler\n");
+ exit(1);
+ }
+ output->printer = &data_csv_printer;
+ output->aux_free = &data_csv_free;
+ output->file = stdout;
+ output->aux = aux_data;
+ *next_output_handler = output;
+ next_output_handler = &output->next;
}
-
-static void rtlsdr_callback(unsigned char *buf, uint32_t len, void *ctx)
+void add_kv_output()
{
- struct dm_state *demod = ctx;
- uint16_t* sbuf = (uint16_t*) buf;
- int i;
- if (demod->file || !demod->save_data) {
- if (do_exit || do_exit_async)
- return;
-
- if ((bytes_to_read > 0) && (bytes_to_read < len)) {
- len = bytes_to_read;
- do_exit = 1;
- rtlsdr_cancel_async(dev);
- }
-
- if (demod->signal_grabber) {
- //fprintf(stderr, "[%d] sg_index - len %d\n", demod->sg_index, len );
- memcpy(&demod->sg_buf[demod->sg_index], buf, len);
- demod->sg_len =len;
- demod->sg_index +=len;
- if (demod->sg_index+len > SIGNAL_GRABBER_BUFFER)
- demod->sg_index = 0;
- }
-
-
- if (demod->debug_mode == 0) {
- envelope_detect(buf, len, demod->decimation_level);
- low_pass_filter(sbuf, demod->f_buf, len>>(demod->decimation_level+1));
- } else if (demod->debug_mode == 1){
- memcpy(demod->f_buf, buf, len);
- }
- if (demod->analyze) {
- pwm_analyze(demod, demod->f_buf, len/2);
- }
- {
- for (i=0 ; i<demod->r_dev_num ; i++) {
- switch (demod->r_devs[i]->modulation) {
- case OOK_PWM_D:
- pwm_d_decode(demod, demod->r_devs[i], demod->f_buf, len/2);
- break;
- case OOK_PWM_P:
- pwm_p_decode(demod, demod->r_devs[i], demod->f_buf, len/2);
- break;
- default:
- fprintf(stderr, "Unknown modulation %d in protocol!\n", demod->r_devs[i]->modulation);
- }
- }
- fflush(stdout);
- }
-
- if (demod->save_data) {
- if (fwrite(demod->f_buf, 1, len>>demod->decimation_level, demod->file) != len>>demod->decimation_level) {
- fprintf(stderr, "Short write, samples lost, exiting!\n");
- rtlsdr_cancel_async(dev);
- }
- }
-
- if (bytes_to_read > 0)
- bytes_to_read -= len;
-
- if(frequencies>1) {
- time_t rawtime;
- time(&rawtime);
- if(difftime(rawtime, rawtime_old)>DEFAULT_HOP_TIME || events>=DEFAULT_HOP_EVENTS) {
- rawtime_old=rawtime;
- events=0;
- do_exit_async=1;
- rtlsdr_cancel_async(dev);
- }
- }
+ output_handler_t *output = calloc(1, sizeof(output_handler_t));
+ if (!output) {
+ fprintf(stderr, "rtl_433: failed to allocate memory for output handler\n");
+ exit(1);
}
+ output->printer = &data_kv_printer;
+ output->file = stdout;
+ *next_output_handler = output;
+ next_output_handler = &output->next;
}
-int main(int argc, char **argv)
-{
+int main(int argc, char **argv) {
#ifndef _WIN32
struct sigaction sigact;
#endif
- char *filename = NULL;
- char *test_mode_file = NULL;
- FILE *test_mode;
+ char *out_filename = NULL;
+ char *in_filename = NULL;
+ FILE *in_file;
int n_read;
- int r, opt;
+ int r = 0, opt;
int i, gain = 0;
int sync_mode = 0;
int ppm_error = 0;
struct dm_state* demod;
- uint8_t *buffer;
uint32_t dev_index = 0;
- int frequency_current=0;
+ int frequency_current = 0;
uint32_t out_block_size = DEFAULT_BUF_LENGTH;
int device_count;
char vendor[256], product[256], serial[256];
+ int have_opt_R = 0;
+ int register_all = 0;
+
+ setbuf(stdout, NULL);
+ setbuf(stderr, NULL);
- demod = malloc(sizeof(struct dm_state));
- memset(demod,0,sizeof(struct dm_state));
+ demod = malloc(sizeof (struct dm_state));
+ memset(demod, 0, sizeof (struct dm_state));
/* initialize tables */
- calc_squares();
+ baseband_init();
+
+ r_device devices[] = {
+#define DECL(name) name,
+ DEVICES
+#undef DECL
+ };
- demod->f_buf = &demod->filter_buffer[FILTER_ORDER];
- demod->decimation_level = DEFAULT_DECIMATION_LEVEL;
- demod->level_limit = DEFAULT_LEVEL_LIMIT;
+ num_r_devices = sizeof(devices)/sizeof(*devices);
+ demod->level_limit = DEFAULT_LEVEL_LIMIT;
- while ((opt = getopt(argc, argv, "x:z:p:Dtam:r:c:l:d:f:g:s:b:n:S::")) != -1) {
+ while ((opt = getopt(argc, argv, "x:z:p:DtaAI:qm:r:l:d:f:g:s:b:n:SR:F:C:T:UWG")) != -1) {
switch (opt) {
- case 'd':
- dev_index = atoi(optarg);
- break;
- case 'f':
- if(frequencies<MAX_PROTOCOLS) frequency[frequencies++] = (uint32_t)atof(optarg);
- else fprintf(stderr, "Max number of frequencies reached %d\n",MAX_PROTOCOLS);
- break;
- case 'g':
- gain = (int)(atof(optarg) * 10); /* tenths of a dB */
- break;
- case 'p':
- ppm_error = atoi(optarg);
- break;
- case 's':
- samp_rate = (uint32_t)atof(optarg);
- break;
- case 'b':
- out_block_size = (uint32_t)atof(optarg);
- break;
- case 'l':
- demod->level_limit = (uint32_t)atof(optarg);
- break;
- case 'n':
- bytes_to_read = (uint32_t)atof(optarg) * 2;
- break;
- case 'c':
- demod->decimation_level = (uint32_t)atof(optarg);
- break;
- case 'a':
- demod->analyze = 1;
- break;
- case 'r':
- test_mode_file = optarg;
- break;
- case 't':
- demod->signal_grabber = 1;
- break;
- case 'm':
- demod->debug_mode = atoi(optarg);
- break;
- case 'S':
- sync_mode = 1;
- break;
- case 'D':
- debug_output = 1;
- break;
- case 'z':
- override_short = atoi(optarg);
- break;
- case 'x':
- override_long = atoi(optarg);
- break;
- default:
- usage();
- break;
+ case 'd':
+ dev_index = atoi(optarg);
+ break;
+ case 'f':
+ if (frequencies < MAX_PROTOCOLS) frequency[frequencies++] = (uint32_t) atof(optarg);
+ else fprintf(stderr, "Max number of frequencies reached %d\n", MAX_PROTOCOLS);
+ break;
+ case 'g':
+ gain = (int) (atof(optarg) * 10); /* tenths of a dB */
+ break;
+ case 'G':
+ register_all = 1;
+ break;
+ case 'p':
+ ppm_error = atoi(optarg);
+ break;
+ case 's':
+ samp_rate = (uint32_t) atof(optarg);
+ break;
+ case 'b':
+ out_block_size = (uint32_t) atof(optarg);
+ break;
+ case 'l':
+ demod->level_limit = (uint32_t) atof(optarg);
+ break;
+ case 'n':
+ bytes_to_read = (uint32_t) atof(optarg) * 2;
+ break;
+ case 'a':
+ demod->analyze = 1;
+ break;
+ case 'A':
+ demod->analyze_pulses = 1;
+ break;
+ case 'I':
+ include_only = atoi(optarg);
+ break;
+ case 'r':
+ in_filename = optarg;
+ break;
+ case 't':
+ demod->signal_grabber = 1;
+ break;
+ case 'm':
+ demod->debug_mode = atoi(optarg);
+ break;
+ case 'S':
+ sync_mode = 1;
+ break;
+ case 'D':
+ debug_output++;
+ break;
+ case 'z':
+ override_short = atoi(optarg);
+ break;
+ case 'x':
+ override_long = atoi(optarg);
+ break;
+ case 'R':
+ if (!have_opt_R) {
+ for (i = 0; i < num_r_devices; i++) {
+ devices[i].disabled = 1;
+ }
+ have_opt_R = 1;
+ }
+
+ i = atoi(optarg);
+ if (i > num_r_devices) {
+ fprintf(stderr, "Remote device number specified larger than number of devices\n\n");
+ usage(devices);
+ }
+
+ devices[i - 1].disabled = 0;
+ break;
+ case 'q':
+ quiet_mode = 1;
+ break;
+ case 'F':
+ if (strcmp(optarg, "json") == 0) {
+ add_json_output();
+ } else if (strcmp(optarg, "csv") == 0) {
+ add_csv_output(determine_csv_fields(devices, num_r_devices));
+ } else if (strcmp(optarg, "kv") == 0) {
+ add_kv_output();
+ } else {
+ fprintf(stderr, "Invalid output format %s\n", optarg);
+ usage(devices);
+ }
+ break;
+ case 'C':
+ if (strcmp(optarg, "native") == 0) {
+ conversion_mode = CONVERT_NATIVE;
+ } else if (strcmp(optarg, "si") == 0) {
+ conversion_mode = CONVERT_SI;
+ } else if (strcmp(optarg, "customary") == 0) {
+ conversion_mode = CONVERT_CUSTOMARY;
+ } else {
+ fprintf(stderr, "Invalid conversion mode %s\n", optarg);
+ usage(devices);
+ }
+ break;
+ case 'U':
+ #if !defined(__MINGW32__)
+ utc_mode = setenv("TZ", "UTC", 1);
+ if(utc_mode != 0) fprintf(stderr, "Unable to set TZ to UTC; error code: %d\n", utc_mode);
+ #endif
+ break;
+ case 'W':
+ overwrite_mode = 1;
+ break;
+ case 'T':
+ time(&stop_time);
+ duration = atoi(optarg);
+ if (duration < 1) {
+ fprintf(stderr, "Duration '%s' was not positive integer; will continue indefinitely\n", optarg);
+ } else {
+ stop_time += duration;
+ }
+ break;
+ default:
+ usage(devices);
+ break;
}
}
- /* init protocols somewhat ok */
- register_protocol(demod, &rubicson);
- register_protocol(demod, &prologue);
- register_protocol(demod, &silvercrest);
-// register_protocol(demod, &generic_hx2262);
-// register_protocol(demod, &technoline_ws9118);
- register_protocol(demod, &elv_em1000);
- register_protocol(demod, &elv_ws2000);
- register_protocol(demod, &waveman);
- register_protocol(demod, &steffen);
- register_protocol(demod, &acurite5n1);
- register_protocol(demod, &wh2);
-
- if (argc <= optind-1) {
- usage();
+ if (argc <= optind - 1) {
+ usage(devices);
} else {
- filename = argv[optind];
+ out_filename = argv[optind];
+ }
+
+ if (!output_handler) {
+ add_kv_output();
+ }
+
+ for (i = 0; i < num_r_devices; i++) {
+ if (!devices[i].disabled || register_all) {
+ register_protocol(demod, &devices[i]);
+ if(devices[i].modulation >= FSK_DEMOD_MIN_VAL) {
+ demod->enable_FM_demod = 1;
+ }
+ }
}
- if(out_block_size < MINIMAL_BUF_LENGTH ||
- out_block_size > MAXIMAL_BUF_LENGTH ){
+ if (!quiet_mode)
+ fprintf(stderr,"Registered %d out of %d device decoding protocols\n",
+ demod->r_dev_num, num_r_devices);
+
+ if (out_block_size < MINIMAL_BUF_LENGTH ||
+ out_block_size > MAXIMAL_BUF_LENGTH) {
fprintf(stderr,
- "Output block size wrong value, falling back to default\n");
+ "Output block size wrong value, falling back to default\n");
fprintf(stderr,
- "Minimal length: %u\n", MINIMAL_BUF_LENGTH);
+ "Minimal length: %u\n", MINIMAL_BUF_LENGTH);
fprintf(stderr,
- "Maximal length: %u\n", MAXIMAL_BUF_LENGTH);
+ "Maximal length: %u\n", MAXIMAL_BUF_LENGTH);
out_block_size = DEFAULT_BUF_LENGTH;
}
- buffer = malloc(out_block_size * sizeof(uint8_t));
+ if (!in_filename) {
+ device_count = rtlsdr_get_device_count();
+ if (!device_count) {
+ fprintf(stderr, "No supported devices found.\n");
+ if (!in_filename)
+ exit(1);
+ }
+
+ if (!quiet_mode) {
+ fprintf(stderr, "Found %d device(s):\n", device_count);
+ for (i = 0; i < device_count; i++) {
+ rtlsdr_get_device_usb_strings(i, vendor, product, serial);
+ fprintf(stderr, " %d: %s, %s, SN: %s\n", i, vendor, product, serial);
+ }
+ fprintf(stderr, "\n");
+
+ fprintf(stderr, "Using device %d: %s\n",
+ dev_index, rtlsdr_get_device_name(dev_index));
+ }
+
+ r = rtlsdr_open(&dev, dev_index);
+ if (r < 0) {
+ fprintf(stderr, "Failed to open rtlsdr device #%d.\n", dev_index);
+ exit(1);
+ }
+#ifndef _WIN32
+ sigact.sa_handler = sighandler;
+ sigemptyset(&sigact.sa_mask);
+ sigact.sa_flags = 0;
+ sigaction(SIGINT, &sigact, NULL);
+ sigaction(SIGTERM, &sigact, NULL);
+ sigaction(SIGQUIT, &sigact, NULL);
+ sigaction(SIGPIPE, &sigact, NULL);
+#else
+ SetConsoleCtrlHandler((PHANDLER_ROUTINE) sighandler, TRUE);
+#endif
+ /* Set the sample rate */
+ r = rtlsdr_set_sample_rate(dev, samp_rate);
+ if (r < 0)
+ fprintf(stderr, "WARNING: Failed to set sample rate.\n");
+ else
+ fprintf(stderr, "Sample rate set to %d.\n", rtlsdr_get_sample_rate(dev)); // Unfortunately, doesn't return real rate
- device_count = rtlsdr_get_device_count();
- if (!device_count) {
- fprintf(stderr, "No supported devices found.\n");
- if (!test_mode_file)
- exit(1);
- }
+ fprintf(stderr, "Bit detection level set to %d%s.\n", demod->level_limit, (demod->level_limit ? "" : " (Auto)"));
- fprintf(stderr, "Found %d device(s):\n", device_count);
- for (i = 0; i < device_count; i++) {
- rtlsdr_get_device_usb_strings(i, vendor, product, serial);
- fprintf(stderr, " %d: %s, %s, SN: %s\n", i, vendor, product, serial);
- }
- fprintf(stderr, "\n");
+ if (0 == gain) {
+ /* Enable automatic gain */
+ r = rtlsdr_set_tuner_gain_mode(dev, 0);
+ if (r < 0)
+ fprintf(stderr, "WARNING: Failed to enable automatic gain.\n");
+ else
+ fprintf(stderr, "Tuner gain set to Auto.\n");
+ } else {
+ /* Enable manual gain */
+ r = rtlsdr_set_tuner_gain_mode(dev, 1);
+ if (r < 0)
+ fprintf(stderr, "WARNING: Failed to enable manual gain.\n");
- fprintf(stderr, "Using device %d: %s\n",
- dev_index, rtlsdr_get_device_name(dev_index));
+ /* Set the tuner gain */
+ r = rtlsdr_set_tuner_gain(dev, gain);
+ if (r < 0)
+ fprintf(stderr, "WARNING: Failed to set tuner gain.\n");
+ else
+ fprintf(stderr, "Tuner gain set to %f dB.\n", gain / 10.0);
+ }
- r = rtlsdr_open(&dev, dev_index);
- if (r < 0) {
- fprintf(stderr, "Failed to open rtlsdr device #%d.\n", dev_index);
- if (!test_mode_file)
- exit(1);
- }
-#ifndef _WIN32
- sigact.sa_handler = sighandler;
- sigemptyset(&sigact.sa_mask);
- sigact.sa_flags = 0;
- sigaction(SIGINT, &sigact, NULL);
- sigaction(SIGTERM, &sigact, NULL);
- sigaction(SIGQUIT, &sigact, NULL);
- sigaction(SIGPIPE, &sigact, NULL);
-#else
- SetConsoleCtrlHandler( (PHANDLER_ROUTINE) sighandler, TRUE );
-#endif
- /* Set the sample rate */
- r = rtlsdr_set_sample_rate(dev, samp_rate);
- if (r < 0)
- fprintf(stderr, "WARNING: Failed to set sample rate.\n");
- else
- fprintf(stderr, "Sample rate set to %d.\n", rtlsdr_get_sample_rate(dev)); // Unfortunately, doesn't return real rate
-
- fprintf(stderr, "Sample rate decimation set to %d. %d->%d\n",demod->decimation_level, samp_rate, samp_rate>>demod->decimation_level);
- fprintf(stderr, "Bit detection level set to %d.\n", demod->level_limit);
-
- if (0 == gain) {
- /* Enable automatic gain */
- r = rtlsdr_set_tuner_gain_mode(dev, 0);
- if (r < 0)
- fprintf(stderr, "WARNING: Failed to enable automatic gain.\n");
- else
- fprintf(stderr, "Tuner gain set to Auto.\n");
- } else {
- /* Enable manual gain */
- r = rtlsdr_set_tuner_gain_mode(dev, 1);
- if (r < 0)
- fprintf(stderr, "WARNING: Failed to enable manual gain.\n");
-
- /* Set the tuner gain */
- r = rtlsdr_set_tuner_gain(dev, gain);
- if (r < 0)
- fprintf(stderr, "WARNING: Failed to set tuner gain.\n");
- else
- fprintf(stderr, "Tuner gain set to %f dB.\n", gain/10.0);
- }
+ r = rtlsdr_set_freq_correction(dev, ppm_error);
- r = rtlsdr_set_freq_correction(dev, ppm_error);
+ }
- demod->save_data = 1;
- if (!filename) {
- demod->save_data = 0;
- } else if(strcmp(filename, "-") == 0) { /* Write samples to stdout */
- demod->file = stdout;
+ if (out_filename) {
+ if (strcmp(out_filename, "-") == 0) { /* Write samples to stdout */
+ demod->out_file = stdout;
#ifdef _WIN32
- _setmode(_fileno(stdin), _O_BINARY);
+ _setmode(_fileno(stdin), _O_BINARY);
#endif
- } else {
- demod->file = fopen(filename, "wb");
- if (!demod->file) {
- fprintf(stderr, "Failed to open %s\n", filename);
- goto out;
- }
- }
+ } else {
+ if (access(out_filename, F_OK) == 0 && !overwrite_mode) {
+ fprintf(stderr, "Output file %s already exists, exiting\n", out_filename);
+ goto out;
+ }
+ demod->out_file = fopen(out_filename, "wb");
+ if (!demod->out_file) {
+ fprintf(stderr, "Failed to open %s\n", out_filename);
+ goto out;
+ }
+ }
+ }
if (demod->signal_grabber)
demod->sg_buf = malloc(SIGNAL_GRABBER_BUFFER);
- if (test_mode_file) {
+ if (in_filename) {
int i = 0;
unsigned char test_mode_buf[DEFAULT_BUF_LENGTH];
- fprintf(stderr, "Test mode active. Reading samples from file: %s\n",test_mode_file);
- test_mode = fopen(test_mode_file, "r");
- if (!test_mode) {
- fprintf(stderr, "Opening file: %s failed!\n",test_mode_file);
- goto out;
- }
- while(fread(test_mode_buf, 131072, 1, test_mode) != 0) {
- rtlsdr_callback(test_mode_buf, 131072, demod);
+ float test_mode_float_buf[DEFAULT_BUF_LENGTH];
+ if (strcmp(in_filename, "-") == 0) { /* read samples from stdin */
+ in_file = stdin;
+ in_filename = "<stdin>";
+ } else {
+ in_file = fopen(in_filename, "rb");
+ if (!in_file) {
+ fprintf(stderr, "Opening file: %s failed!\n", in_filename);
+ goto out;
+ }
+ }
+ fprintf(stderr, "Test mode active. Reading samples from file: %s\n", in_filename); // Essential information (not quiet)
+ if (!quiet_mode) {
+ fprintf(stderr, "Input format: %s\n", (demod->debug_mode == 3) ? "cf32" : "uint8");
+ }
+ sample_file_pos = 0.0;
+
+ int n_read, cf32_tmp;
+ do {
+ if (demod->debug_mode == 3) {
+ n_read = fread(test_mode_float_buf, sizeof(float), 131072, in_file);
+ for(int n = 0; n < n_read; n++) {
+ cf32_tmp = test_mode_float_buf[n]*127 + 127;
+ if (cf32_tmp < 0)
+ cf32_tmp = 0;
+ else if (cf32_tmp > 255)
+ cf32_tmp = 255;
+ test_mode_buf[n] = (uint8_t)cf32_tmp;
+ }
+ } else {
+ n_read = fread(test_mode_buf, 1, 131072, in_file);
+ }
+ if (n_read == 0) break; // rtlsdr_callback() will Segmentation Fault with len=0
+ rtlsdr_callback(test_mode_buf, n_read, demod);
i++;
- }
+ sample_file_pos = (float)i * n_read / samp_rate;
+ } while (n_read != 0);
+
+ // Call a last time with cleared samples to ensure EOP detection
+ memset(test_mode_buf, 128, DEFAULT_BUF_LENGTH); // 128 is 0 in unsigned data
+ rtlsdr_callback(test_mode_buf, 131072, demod); // Why the magic value 131072?
+
//Always classify a signal at the end of the file
classify_signal();
- fprintf(stderr, "Test mode file issued %d packets\n", i);
- fprintf(stderr, "Filter coeffs used:\n");
- fprintf(stderr, "a: %d %d\n", a[0], a[1]);
- fprintf(stderr, "b: %d %d\n", b[0], b[1]);
+ if (!quiet_mode) {
+ fprintf(stderr, "Test mode file issued %d packets\n", i);
+ }
exit(0);
}
fprintf(stderr, "WARNING: Failed to reset buffers.\n");
if (sync_mode) {
- fprintf(stderr, "Reading samples in sync mode...\n");
+ if (!demod->out_file) {
+ fprintf(stderr, "Specify an output file for sync mode.\n");
+ exit(0);
+ }
+
+ fprintf(stderr, "Reading samples in sync mode...\n");
+ uint8_t *buffer = malloc(out_block_size * sizeof (uint8_t));
+
+ time_t timestamp;
while (!do_exit) {
r = rtlsdr_read_sync(dev, buffer, out_block_size, &n_read);
if (r < 0) {
break;
}
- if ((bytes_to_read > 0) && (bytes_to_read < (uint32_t)n_read)) {
+ if ((bytes_to_read > 0) && (bytes_to_read < (uint32_t) n_read)) {
n_read = bytes_to_read;
do_exit = 1;
}
- if (fwrite(buffer, 1, n_read, demod->file) != (size_t)n_read) {
+ if (fwrite(buffer, 1, n_read, demod->out_file) != (size_t) n_read) {
fprintf(stderr, "Short write, samples lost, exiting!\n");
break;
}
- if ((uint32_t)n_read < out_block_size) {
+ if ((uint32_t) n_read < out_block_size) {
fprintf(stderr, "Short read, samples lost, exiting!\n");
break;
}
+ if (duration > 0) {
+ time(×tamp);
+ if (timestamp >= stop_time) {
+ do_exit = 1;
+ fprintf(stderr, "Time expired, exiting!\n");
+ }
+ }
+
if (bytes_to_read > 0)
bytes_to_read -= n_read;
}
+
+ free(buffer);
} else {
- if(frequencies==0) {
- frequency[0] = DEFAULT_FREQUENCY;
- frequencies=1;
+ if (frequencies == 0) {
+ frequency[0] = DEFAULT_FREQUENCY;
+ frequencies = 1;
} else {
- time(&rawtime_old);
+ time(&rawtime_old);
}
- fprintf(stderr, "Reading samples in async mode...\n");
- while(!do_exit) {
+ if (!quiet_mode) {
+ fprintf(stderr, "Reading samples in async mode...\n");
+ }
+ while (!do_exit) {
/* Set the frequency */
r = rtlsdr_set_center_freq(dev, frequency[frequency_current]);
if (r < 0)
fprintf(stderr, "WARNING: Failed to set center freq.\n");
else
fprintf(stderr, "Tuned to %u Hz.\n", rtlsdr_get_center_freq(dev));
- r = rtlsdr_read_async(dev, rtlsdr_callback, (void *)demod,
- DEFAULT_ASYNC_BUF_NUMBER, out_block_size);
- do_exit_async=0;
+ r = rtlsdr_read_async(dev, rtlsdr_callback, (void *) demod,
+ DEFAULT_ASYNC_BUF_NUMBER, out_block_size);
+ do_exit_async = 0;
frequency_current++;
- if(frequency_current>frequencies-1) frequency_current=0;
+ if (frequency_current > frequencies - 1) frequency_current = 0;
}
}
else
fprintf(stderr, "\nLibrary error %d, exiting...\n", r);
- if (demod->file && (demod->file != stdout))
- fclose(demod->file);
+ if (demod->out_file && (demod->out_file != stdout))
+ fclose(demod->out_file);
- for (i=0 ; i<demod->r_dev_num ; i++)
+ for (i = 0; i < demod->r_dev_num; i++)
free(demod->r_devs[i]);
if (demod->signal_grabber)
free(demod->sg_buf);
- if(demod)
- free(demod);
+ free(demod);
rtlsdr_close(dev);
- free (buffer);
out:
+ for (output_handler_t *output = output_handler; output; output = output->next) {
+ if (output->aux_free) {
+ output->aux_free(output->aux);
+ }
+ }
return r >= 0 ? r : -r;
}
projects / rtl-433.git / blobdiff