+++ /dev/null
-#ifndef INCLUDE_RTL_433_H_
-#define INCLUDE_RTL_433_H_
-
-#include <errno.h>
-#include <signal.h>
-#include <string.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <time.h>
-#include <stdint.h>
-
-#ifndef _WIN32
-#include <unistd.h>
-#else
-#include <Windows.h>
-#include <io.h>
-#include <fcntl.h>
-#include "getopt/getopt.h"
-#endif
-
-#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 15
-#define SIGNAL_GRABBER_BUFFER (12 * DEFAULT_BUF_LENGTH)
-#define BITBUF_COLS 34
-#define BITBUF_ROWS 50
-
-/* 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 */
-#define OOK_MANCHESTER 3 /* Manchester code */
-
-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],int16_t bits_per_row[BITBUF_ROWS]) ;
-} r_device;
-
-extern int debug_output;
-int debug_callback(uint8_t buffer[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]);
-
-#endif /* INCLUDE_RTL_433_H_ */
+++ /dev/null
-#ifndef INCLUDE_RTL_433_DEVICES_H_
-#define INCLUDE_RTL_433_DEVICES_H_
-
-extern r_device silvercrest;
-extern r_device rubicson;
-extern r_device prologue;
-extern r_device waveman;
-extern r_device steffen;
-extern r_device elv_em1000;
-extern r_device elv_ws2000;
-extern r_device lacrossetx;
-extern r_device acurite5n1;
-extern r_device acurite_rain_gauge;
-extern r_device acurite_th;
-extern r_device oregon_scientific;
-extern r_device mebus433;
-extern r_device intertechno;
-extern r_device newkaku;
-extern r_device alectov1;
-extern r_device wh2;
-
-#endif /* INCLUDE_RTL_433_DEVICES_H_ */
+++ /dev/null
-INCLUDES = $(all_includes) -I$(top_srcdir)/include
-AM_CFLAGS = ${CFLAGS} -fPIC ${SYMBOL_VISIBILITY}
-
-bin_PROGRAMS = rtl_433
-
-rtl_433_SOURCES = rtl_433.c \
- devices/acurite.c \
- devices/intertechno.c \
- devices/newkaku.c \
- devices/rubicson.c \
- devices/waveman.c \
- devices/alecto.c \
- devices/lacrosse.c \
- devices/oregon_scientific.c \
- devices/silvercrest.c \
- devices/elv.c \
- devices/mebus.c \
- devices/prologue.c \
- devices/steffen.c
-
-rtl_433_LDADD = $(LIBRTLSDR) $(LIBM)
+++ /dev/null
-# Makefile.in generated by automake 1.14.1 from Makefile.am.
-# src/Makefile. Generated from Makefile.in by configure.
-
-# Copyright (C) 1994-2013 Free Software Foundation, Inc.
-
-# This Makefile.in is free software; the Free Software Foundation
-# gives unlimited permission to copy and/or distribute it,
-# with or without modifications, as long as this notice is preserved.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY, to the extent permitted by law; without
-# even the implied warranty of MERCHANTABILITY or FITNESS FOR A
-# PARTICULAR PURPOSE.
-
-
-
-
-am__is_gnu_make = test -n '$(MAKEFILE_LIST)' && test -n '$(MAKELEVEL)'
-am__make_running_with_option = \
- case $${target_option-} in \
- ?) ;; \
- *) echo "am__make_running_with_option: internal error: invalid" \
- "target option '$${target_option-}' specified" >&2; \
- exit 1;; \
- esac; \
- has_opt=no; \
- sane_makeflags=$$MAKEFLAGS; \
- if $(am__is_gnu_make); then \
- sane_makeflags=$$MFLAGS; \
- else \
- case $$MAKEFLAGS in \
- *\\[\ \ ]*) \
- bs=\\; \
- sane_makeflags=`printf '%s\n' "$$MAKEFLAGS" \
- | sed "s/$$bs$$bs[$$bs $$bs ]*//g"`;; \
- esac; \
- fi; \
- skip_next=no; \
- strip_trailopt () \
- { \
- flg=`printf '%s\n' "$$flg" | sed "s/$$1.*$$//"`; \
- }; \
- for flg in $$sane_makeflags; do \
- test $$skip_next = yes && { skip_next=no; continue; }; \
- case $$flg in \
- *=*|--*) continue;; \
- -*I) strip_trailopt 'I'; skip_next=yes;; \
- -*I?*) strip_trailopt 'I';; \
- -*O) strip_trailopt 'O'; skip_next=yes;; \
- -*O?*) strip_trailopt 'O';; \
- -*l) strip_trailopt 'l'; skip_next=yes;; \
- -*l?*) strip_trailopt 'l';; \
- -[dEDm]) skip_next=yes;; \
- -[JT]) skip_next=yes;; \
- esac; \
- case $$flg in \
- *$$target_option*) has_opt=yes; break;; \
- esac; \
- done; \
- test $$has_opt = yes
-am__make_dryrun = (target_option=n; $(am__make_running_with_option))
-am__make_keepgoing = (target_option=k; $(am__make_running_with_option))
-pkgdatadir = $(datadir)/rtl433
-pkgincludedir = $(includedir)/rtl433
-pkglibdir = $(libdir)/rtl433
-pkglibexecdir = $(libexecdir)/rtl433
-am__cd = CDPATH="$${ZSH_VERSION+.}$(PATH_SEPARATOR)" && cd
-install_sh_DATA = $(install_sh) -c -m 644
-install_sh_PROGRAM = $(install_sh) -c
-install_sh_SCRIPT = $(install_sh) -c
-INSTALL_HEADER = $(INSTALL_DATA)
-transform = $(program_transform_name)
-NORMAL_INSTALL = :
-PRE_INSTALL = :
-POST_INSTALL = :
-NORMAL_UNINSTALL = :
-PRE_UNINSTALL = :
-POST_UNINSTALL = :
-build_triplet = x86_64-unknown-linux-gnu
-host_triplet = x86_64-unknown-linux-gnu
-bin_PROGRAMS = rtl_433$(EXEEXT)
-subdir = src
-DIST_COMMON = $(srcdir)/Makefile.in $(srcdir)/Makefile.am \
- $(top_srcdir)/depcomp
-ACLOCAL_M4 = $(top_srcdir)/aclocal.m4
-am__aclocal_m4_deps = $(top_srcdir)/m4/libtool.m4 \
- $(top_srcdir)/m4/ltoptions.m4 $(top_srcdir)/m4/ltsugar.m4 \
- $(top_srcdir)/m4/ltversion.m4 $(top_srcdir)/m4/lt~obsolete.m4 \
- $(top_srcdir)/configure.ac
-am__configure_deps = $(am__aclocal_m4_deps) $(CONFIGURE_DEPENDENCIES) \
- $(ACLOCAL_M4)
-mkinstalldirs = $(install_sh) -d
-CONFIG_HEADER = $(top_builddir)/config.h
-CONFIG_CLEAN_FILES =
-CONFIG_CLEAN_VPATH_FILES =
-am__installdirs = "$(DESTDIR)$(bindir)"
-PROGRAMS = $(bin_PROGRAMS)
-am__dirstamp = $(am__leading_dot)dirstamp
-am_rtl_433_OBJECTS = rtl_433.$(OBJEXT) devices/acurite.$(OBJEXT) \
- devices/intertechno.$(OBJEXT) devices/newkaku.$(OBJEXT) \
- devices/rubicson.$(OBJEXT) devices/waveman.$(OBJEXT) \
- devices/alecto.$(OBJEXT) devices/lacrosse.$(OBJEXT) \
- devices/oregon_scientific.$(OBJEXT) \
- devices/silvercrest.$(OBJEXT) devices/elv.$(OBJEXT) \
- devices/mebus.$(OBJEXT) devices/prologue.$(OBJEXT) \
- devices/steffen.$(OBJEXT) devices/wh2.$(OBJEXT) \
- devices/leak.$(OBJEXT)
-rtl_433_OBJECTS = $(am_rtl_433_OBJECTS)
-rtl_433_DEPENDENCIES =
-AM_V_lt = $(am__v_lt_$(V))
-am__v_lt_ = $(am__v_lt_$(AM_DEFAULT_VERBOSITY))
-am__v_lt_0 = --silent
-am__v_lt_1 =
-AM_V_P = $(am__v_P_$(V))
-am__v_P_ = $(am__v_P_$(AM_DEFAULT_VERBOSITY))
-am__v_P_0 = false
-am__v_P_1 = :
-AM_V_GEN = $(am__v_GEN_$(V))
-am__v_GEN_ = $(am__v_GEN_$(AM_DEFAULT_VERBOSITY))
-am__v_GEN_0 = @echo " GEN " $@;
-am__v_GEN_1 =
-AM_V_at = $(am__v_at_$(V))
-am__v_at_ = $(am__v_at_$(AM_DEFAULT_VERBOSITY))
-am__v_at_0 = @
-am__v_at_1 =
-DEFAULT_INCLUDES = -I. -I$(top_builddir)
-depcomp = $(SHELL) $(top_srcdir)/depcomp
-am__depfiles_maybe = depfiles
-am__mv = mv -f
-COMPILE = $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) \
- $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS)
-LTCOMPILE = $(LIBTOOL) $(AM_V_lt) --tag=CC $(AM_LIBTOOLFLAGS) \
- $(LIBTOOLFLAGS) --mode=compile $(CC) $(DEFS) \
- $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) \
- $(AM_CFLAGS) $(CFLAGS)
-AM_V_CC = $(am__v_CC_$(V))
-am__v_CC_ = $(am__v_CC_$(AM_DEFAULT_VERBOSITY))
-am__v_CC_0 = @echo " CC " $@;
-am__v_CC_1 =
-CCLD = $(CC)
-LINK = $(LIBTOOL) $(AM_V_lt) --tag=CC $(AM_LIBTOOLFLAGS) \
- $(LIBTOOLFLAGS) --mode=link $(CCLD) $(AM_CFLAGS) $(CFLAGS) \
- $(AM_LDFLAGS) $(LDFLAGS) -o $@
-AM_V_CCLD = $(am__v_CCLD_$(V))
-am__v_CCLD_ = $(am__v_CCLD_$(AM_DEFAULT_VERBOSITY))
-am__v_CCLD_0 = @echo " CCLD " $@;
-am__v_CCLD_1 =
-SOURCES = $(rtl_433_SOURCES)
-DIST_SOURCES = $(rtl_433_SOURCES)
-am__can_run_installinfo = \
- case $$AM_UPDATE_INFO_DIR in \
- n|no|NO) false;; \
- *) (install-info --version) >/dev/null 2>&1;; \
- esac
-am__tagged_files = $(HEADERS) $(SOURCES) $(TAGS_FILES) $(LISP)
-# Read a list of newline-separated strings from the standard input,
-# and print each of them once, without duplicates. Input order is
-# *not* preserved.
-am__uniquify_input = $(AWK) '\
- BEGIN { nonempty = 0; } \
- { items[$$0] = 1; nonempty = 1; } \
- END { if (nonempty) { for (i in items) print i; }; } \
-'
-# Make sure the list of sources is unique. This is necessary because,
-# e.g., the same source file might be shared among _SOURCES variables
-# for different programs/libraries.
-am__define_uniq_tagged_files = \
- list='$(am__tagged_files)'; \
- unique=`for i in $$list; do \
- if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \
- done | $(am__uniquify_input)`
-ETAGS = etags
-CTAGS = ctags
-DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST)
-ACLOCAL = ${SHELL} /home/rvb/git/rtl_433/missing aclocal-1.14
-AMTAR = $${TAR-tar}
-AM_DEFAULT_VERBOSITY = 0
-AR = ar
-AUTOCONF = ${SHELL} /home/rvb/git/rtl_433/missing autoconf
-AUTOHEADER = ${SHELL} /home/rvb/git/rtl_433/missing autoheader
-AUTOMAKE = ${SHELL} /home/rvb/git/rtl_433/missing automake-1.14
-AWK = gawk
-CC = gcc
-CCDEPMODE = depmode=gcc3
-CFLAGS = -g -O2 -I/usr/include/ -I/usr/include/libusb-1.0 -Wall -Wextra -Wno-unused -Wsign-compare
-CPP = gcc -E
-CPPFLAGS =
-CYGPATH_W = echo
-DEFS = -DHAVE_CONFIG_H
-DEPDIR = .deps
-DLLTOOL = false
-DOXYGEN = false
-DSYMUTIL =
-DUMPBIN =
-ECHO_C =
-ECHO_N = -n
-ECHO_T =
-EGREP = /bin/grep -E
-EXEEXT =
-FGREP = /bin/grep -F
-GREP = /bin/grep
-INSTALL = /usr/bin/install -c
-INSTALL_DATA = ${INSTALL} -m 644
-INSTALL_PROGRAM = ${INSTALL}
-INSTALL_SCRIPT = ${INSTALL}
-INSTALL_STRIP_PROGRAM = $(install_sh) -c -s
-LD = /usr/bin/ld -m elf_x86_64
-LDFLAGS =
-LIBOBJS =
-LIBRTLSDR_CFLAGS = -I/usr/include/ -I/usr/include/libusb-1.0
-LIBRTLSDR_LIBS = -lrtlsdr -lusb-1.0
-LIBS = -lrtlsdr -lusb-1.0
-LIBTOOL = $(SHELL) $(top_builddir)/libtool
-LIPO =
-LN_S = ln -s
-LTLIBOBJS =
-MAKEINFO = ${SHELL} /home/rvb/git/rtl_433/missing makeinfo
-MANIFEST_TOOL = :
-MKDIR_P = /bin/mkdir -p
-NM = /usr/bin/nm -B
-NMEDIT =
-OBJDUMP = objdump
-OBJEXT = o
-OTOOL =
-OTOOL64 =
-PACKAGE = rtl433
-PACKAGE_BUGREPORT = rtl_433@googlegroups.com
-PACKAGE_NAME = rtl433
-PACKAGE_STRING = rtl433 UNKNOWN-dirty
-PACKAGE_TARNAME = rtl433
-PACKAGE_URL =
-PACKAGE_VERSION = UNKNOWN-dirty
-PATH_SEPARATOR = :
-PKG_CONFIG = /usr/bin/pkg-config
-PKG_CONFIG_LIBDIR =
-PKG_CONFIG_PATH =
-RANLIB = ranlib
-RTLSDR_PC_CFLAGS = -g -O2 -I/usr/include/ -I/usr/include/libusb-1.0
-RTLSDR_PC_LIBS = -lrtlsdr -lusb-1.0
-SED = /bin/sed
-SET_MAKE =
-SHELL = /bin/bash
-STRIP = strip
-SYMBOL_VISIBILITY = -fvisibility=hidden
-VERSION = UNKNOWN-dirty
-abs_builddir = /home/rvb/git/rtl_433/src
-abs_srcdir = /home/rvb/git/rtl_433/src
-abs_top_builddir = /home/rvb/git/rtl_433
-abs_top_srcdir = /home/rvb/git/rtl_433
-ac_ct_AR = ar
-ac_ct_CC = gcc
-ac_ct_DUMPBIN =
-am__include = include
-am__leading_dot = .
-am__quote =
-am__tar = $${TAR-tar} chof - "$$tardir"
-am__untar = $${TAR-tar} xf -
-bindir = ${exec_prefix}/bin
-build = x86_64-unknown-linux-gnu
-build_alias =
-build_cpu = x86_64
-build_os = linux-gnu
-build_vendor = unknown
-builddir = .
-datadir = ${datarootdir}
-datarootdir = ${prefix}/share
-docdir = ${datarootdir}/doc/${PACKAGE_TARNAME}
-dvidir = ${docdir}
-exec_prefix = ${prefix}
-host = x86_64-unknown-linux-gnu
-host_alias =
-host_cpu = x86_64
-host_os = linux-gnu
-host_vendor = unknown
-htmldir = ${docdir}
-includedir = ${prefix}/include
-infodir = ${datarootdir}/info
-install_sh = ${SHELL} /home/rvb/git/rtl_433/install-sh
-libdir = ${exec_prefix}/lib
-libexecdir = ${exec_prefix}/libexec
-localedir = ${datarootdir}/locale
-localstatedir = ${prefix}/var
-mandir = ${datarootdir}/man
-mkdir_p = $(MKDIR_P)
-oldincludedir = /usr/include
-pdfdir = ${docdir}
-prefix = /usr/local
-program_transform_name = s,x,x,
-psdir = ${docdir}
-sbindir = ${exec_prefix}/sbin
-sharedstatedir = ${prefix}/com
-srcdir = .
-sysconfdir = ${prefix}/etc
-target_alias =
-top_build_prefix = ../
-top_builddir = ..
-top_srcdir = ..
-INCLUDES = $(all_includes) -I$(top_srcdir)/include
-AM_CFLAGS = ${CFLAGS} -fPIC ${SYMBOL_VISIBILITY}
-rtl_433_SOURCES = rtl_433.c \
- devices/acurite.c \
- devices/intertechno.c \
- devices/newkaku.c \
- devices/rubicson.c \
- devices/waveman.c \
- devices/alecto.c \
- devices/lacrosse.c \
- devices/oregon_scientific.c \
- devices/silvercrest.c \
- devices/elv.c \
- devices/mebus.c \
- devices/prologue.c \
- devices/steffen.c \
- devices/wh2.c \
- devices/leak.c
-
-rtl_433_LDADD = $(LIBRTLSDR) $(LIBM)
-all: all-am
-
-.SUFFIXES:
-.SUFFIXES: .c .lo .o .obj
-$(srcdir)/Makefile.in: $(srcdir)/Makefile.am $(am__configure_deps)
- @for dep in $?; do \
- case '$(am__configure_deps)' in \
- *$$dep*) \
- ( cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh ) \
- && { if test -f $@; then exit 0; else break; fi; }; \
- exit 1;; \
- esac; \
- done; \
- echo ' cd $(top_srcdir) && $(AUTOMAKE) --gnu src/Makefile'; \
- $(am__cd) $(top_srcdir) && \
- $(AUTOMAKE) --gnu src/Makefile
-.PRECIOUS: Makefile
-Makefile: $(srcdir)/Makefile.in $(top_builddir)/config.status
- @case '$?' in \
- *config.status*) \
- cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh;; \
- *) \
- echo ' cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__depfiles_maybe)'; \
- cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__depfiles_maybe);; \
- esac;
-
-$(top_builddir)/config.status: $(top_srcdir)/configure $(CONFIG_STATUS_DEPENDENCIES)
- cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh
-
-$(top_srcdir)/configure: $(am__configure_deps)
- cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh
-$(ACLOCAL_M4): $(am__aclocal_m4_deps)
- cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh
-$(am__aclocal_m4_deps):
-install-binPROGRAMS: $(bin_PROGRAMS)
- @$(NORMAL_INSTALL)
- @list='$(bin_PROGRAMS)'; test -n "$(bindir)" || list=; \
- if test -n "$$list"; then \
- echo " $(MKDIR_P) '$(DESTDIR)$(bindir)'"; \
- $(MKDIR_P) "$(DESTDIR)$(bindir)" || exit 1; \
- fi; \
- for p in $$list; do echo "$$p $$p"; done | \
- sed 's/$(EXEEXT)$$//' | \
- while read p p1; do if test -f $$p \
- || test -f $$p1 \
- ; then echo "$$p"; echo "$$p"; else :; fi; \
- done | \
- sed -e 'p;s,.*/,,;n;h' \
- -e 's|.*|.|' \
- -e 'p;x;s,.*/,,;s/$(EXEEXT)$$//;$(transform);s/$$/$(EXEEXT)/' | \
- sed 'N;N;N;s,\n, ,g' | \
- $(AWK) 'BEGIN { files["."] = ""; dirs["."] = 1 } \
- { d=$$3; if (dirs[d] != 1) { print "d", d; dirs[d] = 1 } \
- if ($$2 == $$4) files[d] = files[d] " " $$1; \
- else { print "f", $$3 "/" $$4, $$1; } } \
- END { for (d in files) print "f", d, files[d] }' | \
- while read type dir files; do \
- if test "$$dir" = .; then dir=; else dir=/$$dir; fi; \
- test -z "$$files" || { \
- echo " $(INSTALL_PROGRAM_ENV) $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL_PROGRAM) $$files '$(DESTDIR)$(bindir)$$dir'"; \
- $(INSTALL_PROGRAM_ENV) $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL_PROGRAM) $$files "$(DESTDIR)$(bindir)$$dir" || exit $$?; \
- } \
- ; done
-
-uninstall-binPROGRAMS:
- @$(NORMAL_UNINSTALL)
- @list='$(bin_PROGRAMS)'; test -n "$(bindir)" || list=; \
- files=`for p in $$list; do echo "$$p"; done | \
- sed -e 'h;s,^.*/,,;s/$(EXEEXT)$$//;$(transform)' \
- -e 's/$$/$(EXEEXT)/' \
- `; \
- test -n "$$list" || exit 0; \
- echo " ( cd '$(DESTDIR)$(bindir)' && rm -f" $$files ")"; \
- cd "$(DESTDIR)$(bindir)" && rm -f $$files
-
-clean-binPROGRAMS:
- @list='$(bin_PROGRAMS)'; test -n "$$list" || exit 0; \
- echo " rm -f" $$list; \
- rm -f $$list || exit $$?; \
- test -n "$(EXEEXT)" || exit 0; \
- list=`for p in $$list; do echo "$$p"; done | sed 's/$(EXEEXT)$$//'`; \
- echo " rm -f" $$list; \
- rm -f $$list
-devices/$(am__dirstamp):
- @$(MKDIR_P) devices
- @: > devices/$(am__dirstamp)
-devices/$(DEPDIR)/$(am__dirstamp):
- @$(MKDIR_P) devices/$(DEPDIR)
- @: > devices/$(DEPDIR)/$(am__dirstamp)
-devices/acurite.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/intertechno.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/newkaku.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/rubicson.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/waveman.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/alecto.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/lacrosse.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/oregon_scientific.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/silvercrest.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/elv.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/mebus.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/prologue.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/steffen.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/wh2.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-devices/leak.$(OBJEXT): devices/$(am__dirstamp) \
- devices/$(DEPDIR)/$(am__dirstamp)
-
-rtl_433$(EXEEXT): $(rtl_433_OBJECTS) $(rtl_433_DEPENDENCIES) $(EXTRA_rtl_433_DEPENDENCIES)
- @rm -f rtl_433$(EXEEXT)
- $(AM_V_CCLD)$(LINK) $(rtl_433_OBJECTS) $(rtl_433_LDADD) $(LIBS)
-
-mostlyclean-compile:
- -rm -f *.$(OBJEXT)
- -rm -f devices/*.$(OBJEXT)
-
-distclean-compile:
- -rm -f *.tab.c
-
-include ./$(DEPDIR)/rtl_433.Po
-include devices/$(DEPDIR)/acurite.Po
-include devices/$(DEPDIR)/alecto.Po
-include devices/$(DEPDIR)/elv.Po
-include devices/$(DEPDIR)/intertechno.Po
-include devices/$(DEPDIR)/lacrosse.Po
-include devices/$(DEPDIR)/mebus.Po
-include devices/$(DEPDIR)/newkaku.Po
-include devices/$(DEPDIR)/oregon_scientific.Po
-include devices/$(DEPDIR)/prologue.Po
-include devices/$(DEPDIR)/rubicson.Po
-include devices/$(DEPDIR)/silvercrest.Po
-include devices/$(DEPDIR)/steffen.Po
-include devices/$(DEPDIR)/waveman.Po
-include devices/$(DEPDIR)/wh2.Po
-include devices/$(DEPDIR)/leak.Po
-
-.c.o:
- $(AM_V_CC)depbase=`echo $@ | sed 's|[^/]*$$|$(DEPDIR)/&|;s|\.o$$||'`;\
- $(COMPILE) -MT $@ -MD -MP -MF $$depbase.Tpo -c -o $@ $< &&\
- $(am__mv) $$depbase.Tpo $$depbase.Po
-# $(AM_V_CC)source='$<' object='$@' libtool=no \
-# DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) \
-# $(AM_V_CC_no)$(COMPILE) -c -o $@ $<
-
-.c.obj:
- $(AM_V_CC)depbase=`echo $@ | sed 's|[^/]*$$|$(DEPDIR)/&|;s|\.obj$$||'`;\
- $(COMPILE) -MT $@ -MD -MP -MF $$depbase.Tpo -c -o $@ `$(CYGPATH_W) '$<'` &&\
- $(am__mv) $$depbase.Tpo $$depbase.Po
-# $(AM_V_CC)source='$<' object='$@' libtool=no \
-# DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) \
-# $(AM_V_CC_no)$(COMPILE) -c -o $@ `$(CYGPATH_W) '$<'`
-
-.c.lo:
- $(AM_V_CC)depbase=`echo $@ | sed 's|[^/]*$$|$(DEPDIR)/&|;s|\.lo$$||'`;\
- $(LTCOMPILE) -MT $@ -MD -MP -MF $$depbase.Tpo -c -o $@ $< &&\
- $(am__mv) $$depbase.Tpo $$depbase.Plo
-# $(AM_V_CC)source='$<' object='$@' libtool=yes \
-# DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) \
-# $(AM_V_CC_no)$(LTCOMPILE) -c -o $@ $<
-
-mostlyclean-libtool:
- -rm -f *.lo
-
-clean-libtool:
- -rm -rf .libs _libs
-
-ID: $(am__tagged_files)
- $(am__define_uniq_tagged_files); mkid -fID $$unique
-tags: tags-am
-TAGS: tags
-
-tags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files)
- set x; \
- here=`pwd`; \
- $(am__define_uniq_tagged_files); \
- shift; \
- if test -z "$(ETAGS_ARGS)$$*$$unique"; then :; else \
- test -n "$$unique" || unique=$$empty_fix; \
- if test $$# -gt 0; then \
- $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \
- "$$@" $$unique; \
- else \
- $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \
- $$unique; \
- fi; \
- fi
-ctags: ctags-am
-
-CTAGS: ctags
-ctags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files)
- $(am__define_uniq_tagged_files); \
- test -z "$(CTAGS_ARGS)$$unique" \
- || $(CTAGS) $(CTAGSFLAGS) $(AM_CTAGSFLAGS) $(CTAGS_ARGS) \
- $$unique
-
-GTAGS:
- here=`$(am__cd) $(top_builddir) && pwd` \
- && $(am__cd) $(top_srcdir) \
- && gtags -i $(GTAGS_ARGS) "$$here"
-cscopelist: cscopelist-am
-
-cscopelist-am: $(am__tagged_files)
- list='$(am__tagged_files)'; \
- case "$(srcdir)" in \
- [\\/]* | ?:[\\/]*) sdir="$(srcdir)" ;; \
- *) sdir=$(subdir)/$(srcdir) ;; \
- esac; \
- for i in $$list; do \
- if test -f "$$i"; then \
- echo "$(subdir)/$$i"; \
- else \
- echo "$$sdir/$$i"; \
- fi; \
- done >> $(top_builddir)/cscope.files
-
-distclean-tags:
- -rm -f TAGS ID GTAGS GRTAGS GSYMS GPATH tags
-
-distdir: $(DISTFILES)
- @srcdirstrip=`echo "$(srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \
- topsrcdirstrip=`echo "$(top_srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \
- list='$(DISTFILES)'; \
- dist_files=`for file in $$list; do echo $$file; done | \
- sed -e "s|^$$srcdirstrip/||;t" \
- -e "s|^$$topsrcdirstrip/|$(top_builddir)/|;t"`; \
- case $$dist_files in \
- */*) $(MKDIR_P) `echo "$$dist_files" | \
- sed '/\//!d;s|^|$(distdir)/|;s,/[^/]*$$,,' | \
- sort -u` ;; \
- esac; \
- for file in $$dist_files; do \
- if test -f $$file || test -d $$file; then d=.; else d=$(srcdir); fi; \
- if test -d $$d/$$file; then \
- dir=`echo "/$$file" | sed -e 's,/[^/]*$$,,'`; \
- if test -d "$(distdir)/$$file"; then \
- find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \
- fi; \
- if test -d $(srcdir)/$$file && test $$d != $(srcdir); then \
- cp -fpR $(srcdir)/$$file "$(distdir)$$dir" || exit 1; \
- find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \
- fi; \
- cp -fpR $$d/$$file "$(distdir)$$dir" || exit 1; \
- else \
- test -f "$(distdir)/$$file" \
- || cp -p $$d/$$file "$(distdir)/$$file" \
- || exit 1; \
- fi; \
- done
-check-am: all-am
-check: check-am
-all-am: Makefile $(PROGRAMS)
-installdirs:
- for dir in "$(DESTDIR)$(bindir)"; do \
- test -z "$$dir" || $(MKDIR_P) "$$dir"; \
- done
-install: install-am
-install-exec: install-exec-am
-install-data: install-data-am
-uninstall: uninstall-am
-
-install-am: all-am
- @$(MAKE) $(AM_MAKEFLAGS) install-exec-am install-data-am
-
-installcheck: installcheck-am
-install-strip:
- if test -z '$(STRIP)'; then \
- $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \
- install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \
- install; \
- else \
- $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \
- install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \
- "INSTALL_PROGRAM_ENV=STRIPPROG='$(STRIP)'" install; \
- fi
-mostlyclean-generic:
-
-clean-generic:
-
-distclean-generic:
- -test -z "$(CONFIG_CLEAN_FILES)" || rm -f $(CONFIG_CLEAN_FILES)
- -test . = "$(srcdir)" || test -z "$(CONFIG_CLEAN_VPATH_FILES)" || rm -f $(CONFIG_CLEAN_VPATH_FILES)
- -rm -f devices/$(DEPDIR)/$(am__dirstamp)
- -rm -f devices/$(am__dirstamp)
-
-maintainer-clean-generic:
- @echo "This command is intended for maintainers to use"
- @echo "it deletes files that may require special tools to rebuild."
-clean: clean-am
-
-clean-am: clean-binPROGRAMS clean-generic clean-libtool mostlyclean-am
-
-distclean: distclean-am
- -rm -rf ./$(DEPDIR) devices/$(DEPDIR)
- -rm -f Makefile
-distclean-am: clean-am distclean-compile distclean-generic \
- distclean-tags
-
-dvi: dvi-am
-
-dvi-am:
-
-html: html-am
-
-html-am:
-
-info: info-am
-
-info-am:
-
-install-data-am:
-
-install-dvi: install-dvi-am
-
-install-dvi-am:
-
-install-exec-am: install-binPROGRAMS
-
-install-html: install-html-am
-
-install-html-am:
-
-install-info: install-info-am
-
-install-info-am:
-
-install-man:
-
-install-pdf: install-pdf-am
-
-install-pdf-am:
-
-install-ps: install-ps-am
-
-install-ps-am:
-
-installcheck-am:
-
-maintainer-clean: maintainer-clean-am
- -rm -rf ./$(DEPDIR) devices/$(DEPDIR)
- -rm -f Makefile
-maintainer-clean-am: distclean-am maintainer-clean-generic
-
-mostlyclean: mostlyclean-am
-
-mostlyclean-am: mostlyclean-compile mostlyclean-generic \
- mostlyclean-libtool
-
-pdf: pdf-am
-
-pdf-am:
-
-ps: ps-am
-
-ps-am:
-
-uninstall-am: uninstall-binPROGRAMS
-
-.MAKE: install-am install-strip
-
-.PHONY: CTAGS GTAGS TAGS all all-am check check-am clean \
- clean-binPROGRAMS clean-generic clean-libtool cscopelist-am \
- ctags ctags-am distclean distclean-compile distclean-generic \
- distclean-libtool distclean-tags distdir dvi dvi-am html \
- html-am info info-am install install-am install-binPROGRAMS \
- install-data install-data-am install-dvi install-dvi-am \
- install-exec install-exec-am install-html install-html-am \
- install-info install-info-am install-man install-pdf \
- install-pdf-am install-ps install-ps-am install-strip \
- installcheck installcheck-am installdirs maintainer-clean \
- maintainer-clean-generic mostlyclean mostlyclean-compile \
- mostlyclean-generic mostlyclean-libtool pdf pdf-am ps ps-am \
- tags tags-am uninstall uninstall-am uninstall-binPROGRAMS
-
-
-# Tell versions [3.59,3.63) of GNU make to not export all variables.
-# Otherwise a system limit (for SysV at least) may be exceeded.
-.NOEXPORT:
+++ /dev/null
-#include "rtl_433.h"
-
-// ** 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
- // TODO: sensor does not seem to be in kph, e.g.,
- // a value of 49 here was registered as 41 kph on base unit
- // value could be rpm, etc which may need (polynomial) scaling factor??
- 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 hibyte, uint8_t lobyte) {
- // range: 0 to 99.99 in, 0.01 in incr., rolling counter?
- int raincounter = ((hibyte & 0x7f) << 7) | (lobyte & 0x7F);
- return raincounter;
-}
-
-static int acurite5n1_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- // 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_5IN1,");
- 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 = acurite_getRainfallCounter(buf[5], buf[6]);
- if (acurite_raincounter > 0) {
- // track rainfall difference after first run
- 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, "TEMP=%2.1f,",
- acurite_getTemp(buf[4], buf[5]));
- fprintf(stdout, "HUMIDITY=%d\n",
- acurite_getHumidity(buf[6]));
- }
- } else {
- return 0;
- }
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
-}
-
-static int acurite_rain_gauge_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- // This needs more validation to positively identify correct sensor type, but it basically works if message is really from acurite raingauge and it doesn't have any errors
- if ((bb[0][0] != 0) && (bb[0][1] != 0) && (bb[0][2]!=0) && (bb[0][3] == 0) && (bb[0][4] == 0)) {
- float total_rain = ((bb[0][1]&0xf)<<8)+ bb[0][2];
- total_rain /= 2; // Sensor reports number of bucket tips. Each bucket tip is .5mm
- fprintf(stdout, "SENSOR:TYPE=ACURITE_RAIN_GAUGE,RAIN=%2.1f\n", total_rain);
- fprintf(stderr, "Raw Message: %02x %02x %02x %02x %02x\n",bb[0][0],bb[0][1],bb[0][2],bb[0][3],bb[0][4]);
- return 1;
- }
- return 0;
-}
-
-static int acurite_th_detect(uint8_t *buf){
- if(buf[5] != 0) return 0;
- uint8_t sum = (buf[0] + buf[1] + buf[2] + buf[3]) & 0xff;
- if(sum == 0) return 0;
- return sum == buf[4];
-}
-static float acurite_th_temperature(uint8_t *s){
- uint16_t shifted = (((s[1] & 0x0f) << 8) | s[2]) << 4; // Logical left shift
- return (((int16_t)shifted) >> 4) / 10.0; // Arithmetic right shift
-}
-static int acurite_th_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- uint8_t *buf = NULL;
- int i;
- for(i = 0; i < BITBUF_ROWS; i++){
- if(acurite_th_detect(bb[i])){
- buf = bb[i];
- break;
- }
- }
- if(buf){
- fprintf(stdout, "SENSOR:TYPE=ACURITE_TEMP,");
- fprintf(stdout, "TEMP=%.1f,", acurite_th_temperature(buf));
- fprintf(stderr, "HUMIDITY=%d\n", buf[3]);
- return 1;
- }
-
- return 0;
-}
-
-r_device acurite5n1 = {
- /* .id = */ 10,
- /* .name = */ "Acurite 5n1 Weather Station",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 70,
- /* .long_limit = */ 240,
- /* .reset_limit = */ 21000,
- /* .json_callback = */ &acurite5n1_callback,
-};
-
-r_device acurite_rain_gauge = {
- /* .id = */ 11,
- /* .name = */ "Acurite 896 Rain Gauge",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 1744/4,
- /* .long_limit = */ 3500/4,
- /* .reset_limit = */ 5000/4,
- /* .json_callback = */ &acurite_rain_gauge_callback,
-};
-
-r_device acurite_th = {
- /* .id = */ 12,
- /* .name = */ "Acurite Temperature and Humidity Sensor",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 300,
- /* .long_limit = */ 550,
- /* .reset_limit = */ 2500,
- /* .json_callback = */ &acurite_th_callback,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-/* Documentation also at http://www.tfd.hu/tfdhu/files/wsprotocol/auriol_protocol_v20.pdf
- * Message Format: (9 nibbles, 36 bits):
- * Please note that bytes need to be reversed before processing!
- *
- * Format for Temperature Humidity
- * AAAAAAAA BBBB CCCC CCCC CCCC DDDDDDDD EEEE
- * RC Type Temperature___ Humidity Checksum
- * A = Rolling Code / Device ID
- * Device ID: AAAABBAA BB is used for channel, base channel is 01
- * When channel selector is used, channel can be 10 (2) and 11 (3)
- * B = Message type (xyyz = temp/humidity if yy <> '11') else wind/rain sensor
- * x indicates battery status (0 normal, 1 voltage is below ~2.6 V)
- * z 0 indicates regular transmission, 1 indicates requested by pushbutton
- * C = Temperature (two's complement)
- * D = Humidity BCD format
- * E = Checksum
- *
- * Format for Rain
- * AAAAAAAA BBBB CCCC DDDD DDDD DDDD DDDD EEEE
- * RC Type Rain Checksum
- * A = Rolling Code /Device ID
- * B = Message type (xyyx = NON temp/humidity data if yy = '11')
- * C = fixed to 1100
- * D = Rain (bitvalue * 0.25 mm)
- * E = Checksum
- *
- * Format for Windspeed
- * AAAAAAAA BBBB CCCC CCCC CCCC DDDDDDDD EEEE
- * RC Type Windspd Checksum
- * A = Rolling Code
- * B = Message type (xyyx = NON temp/humidity data if yy = '11')
- * C = Fixed to 1000 0000 0000
- * D = Windspeed (bitvalue * 0.2 m/s, correction for webapp = 3600/1000 * 0.2 * 100 = 72)
- * E = Checksum
- *
- * Format for Winddirection & Windgust
- * AAAAAAAA BBBB CCCD DDDD DDDD EEEEEEEE FFFF
- * RC Type Winddir Windgust Checksum
- * A = Rolling Code
- * B = Message type (xyyx = NON temp/humidity data if yy = '11')
- * C = Fixed to 111
- * D = Wind direction
- * E = Windgust (bitvalue * 0.2 m/s, correction for webapp = 3600/1000 * 0.2 * 100 = 72)
- * F = Checksum
- *********************************************************************************************
- */
-uint8_t reverse8(uint8_t x) {
- x = (x & 0xF0) >> 4 | (x & 0x0F) << 4;
- x = (x & 0xCC) >> 2 | (x & 0x33) << 2;
- x = (x & 0xAA) >> 1 | (x & 0x55) << 1;
- return x;
-}
-
-uint8_t bcd_decode8(uint8_t x) {
- return ((x & 0xF0) >> 4) * 10 + (x & 0x0F);
-}
-
-static int alectov1_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- int temperature_before_dec;
- int temperature_after_dec;
- int16_t temp;
- uint8_t humidity, csum = 0, csum2 = 0;
- int i;
- if (bb[1][0] == bb[5][0] && bb[2][0] == bb[6][0] && (bb[1][4] & 0xf) == 0 && (bb[5][4] & 0xf) == 0
- && (bb[5][0] != 0 && bb[5][1] != 0)) {
-
- for (i = 0; i < 4; i++) {
- uint8_t tmp = reverse8(bb[1][i]);
- csum += (tmp & 0xf) + ((tmp & 0xf0) >> 4);
-
- tmp = reverse8(bb[5][i]);
- csum2 += (tmp & 0xf) + ((tmp & 0xf0) >> 4);
- }
-
- csum = ((bb[1][1] & 0x7f) == 0x6c) ? (csum + 0x7) : (0xf - csum);
- csum2 = ((bb[5][1] & 0x7f) == 0x6c) ? (csum2 + 0x7) : (0xf - csum2);
-
- csum = reverse8((csum & 0xf) << 4);
- csum2 = reverse8((csum2 & 0xf) << 4);
- /* Quit if checksup does not work out */
- if (csum != (bb[1][4] >> 4) || csum2 != (bb[5][4] >> 4)) {
- fprintf(stderr, "\nAlectoV1 CRC error");
- return 0;
- } //Invalid checksum
-
-
- uint8_t wind = 0;
-
- if ((bb[1][1] & 0xe0) == 0x60) {
- wind = ((bb[1][1] & 0xf) == 0xc) ? 0 : 1;
-
- fprintf(stdout, "SENSOR:TYPE=ALECTO_%s,", wind ? "WIND" : "RAIN_GAUGE");
- fprintf(stdout, "ID=%d,", reverse8(bb[1][0]));
- fprintf(stdout, "BUTTON=%d,", bb[1][1]&0x10 ? 1 : 0);
- fprintf(stdout, "BATTERY=%s,", bb[1][1]&0x80 ? "LOW" : "OK");
- if (wind) {
- int skip = -1;
- /* Untested code written according to the specification, may not decode correctly */
- if ((bb[1][1]&0xe) == 0x8 && bb[1][2] == 0) {
- skip = 0;
- } else if ((bb[1][1]&0xe) == 0xe) {
- skip = 4;
- } //According to supplied data!
- if (skip >= 0) {
- double speed = reverse8(bb[1 + skip][3]);
- double gust = reverse8(bb[5 + skip][3]);
- int direction = (reverse8(bb[5 + skip][2]) << 1) | (bb[5 + skip][1] & 0x1);
- fprintf(stdout, "WINDSPEED=%.0f,", speed);
- fprintf(stdout, "WINDGUST=%.0f,", gust);
- fprintf(stdout, "WINDDIRECTION=%.2i\n", direction);
- }
- } else {
- /* Untested code written according to the specification, may not decode correctly */
- double rain_mm = (reverse8(bb[1][2]) + (reverse8(bb[1][3] << 8))) * 0.25;
- fprintf(stdout, "RAINFALL=%f\n", rain_mm);
- }
- } else if (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[3][4] & 0xf) == 0 && (bb[5][4] & 0xf) == 0) {
- //static char * temp_states[4] = {"stable", "increasing", "decreasing", "invalid"};
- temp = (int16_t) ((uint16_t) (reverse8(bb[1][1]) >> 4) | (reverse8(bb[1][2]) << 4));
- if ((temp & 0x800) != 0) {
- temp |= 0xf000;
- }
- temperature_before_dec = abs(temp / 10);
- temperature_after_dec = abs(temp % 10);
- humidity = bcd_decode8(reverse8(bb[1][3]));
- fprintf(stdout, "SENSOR:TYPE=ALECTO_TEMP,");
- fprintf(stdout, "ID=%d,", reverse8(bb[1][0]));
- fprintf(stdout, "CHANNEL== %d,", (bb[1][0] & 0xc) >> 2);
- fprintf(stdout, "BUTTON=%d,", bb[1][1]&0x10 ? 1 : 0);
- fprintf(stdout, "BATTERY=%s,", bb[1][1]&0x80 ? "Low" : "OK");
- fprintf(stdout, "TEMP=%s%d.%d,", temp < 0 ? "-" : "", temperature_before_dec, temperature_after_dec);
- fprintf(stdout, "HUMIDITY=%d\n", humidity);
- }
- fprintf(stderr, "Checksum = %01x (calculated %01x)\n", bb[1][4] >> 4, csum);
-
- fprintf(stderr, "Received Data = %02x %02x %02x %02x %02x\n", bb[1][0], bb[1][1], bb[1][2], bb[1][3], bb[1][4]);
- if (wind) fprintf(stderr, "Rcvd Data 2 = %02x %02x %02x %02x %02x\n", bb[5][0], bb[5][1], bb[5][2], bb[5][3], bb[5][4]);
- /*
- * fprintf(stderr, "L2M: %02x %02x %02x %02x %02x\n",reverse8(bb[1][0]),reverse8(bb[1][1]),reverse8(bb[1][2]),reverse8(bb[1][3]),reverse8(bb[1][4]));
- */
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-//Timing based on 250000
-r_device alectov1 = {
- /* .id = */ 13,
- /* .name = */ "AlectoV1 Weather Sensor",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 3500 / 4, //875
- /* .long_limit = */ 7000 / 4, //1750
- /* .reset_limit = */ 15000 / 4, //3750
- /* .json_callback = */ &alectov1_callback,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-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],int16_t bits_per_row[BITBUF_ROWS]) {
- // 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_ENERGY,");
- fprintf(stdout, "MODEL=EM1000-%s,",dec[0]>=1&&dec[0]<=3?types[dec[0]-1]:"?");
- fprintf(stdout, "ID=%d,",dec[1]);
- fprintf(stdout, "SEQNO=%d,",dec[2]);
- fprintf(stdout, "TOTAL=%d,",dec[3]|dec[4]<<8);
- fprintf(stdout, "CURRENT=%d,",dec[5]|dec[6]<<8);
- fprintf(stdout, "PEAK=%d\n",dec[7]|dec[8]<<8);
-
- return 1;
-}
-
-static int ws2000_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- // 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_WEATHER,");
- fprintf(stdout, "TYPE=%s,", dec[0]<=7?types[dec[0]]:"?");
- fprintf(stdout, "ID= %d,", dec[1]&7);
- if(dec[0]==4) {
- fprintf(stdout, "PRESSURE=%d,", 200+dec[10]*100+dec[9]*10+dec[8]);
- }
- fprintf(stdout, "TEMP=%s%d.%d,", dec[1]&8?"-":"", dec[4]*10+dec[3], dec[2]);
- fprintf(stdout, "HUMIDITY=%d.%d\n", dec[7]*10+dec[6], dec[5]);
-
- return 1;
-}
-
-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,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-static int intertechno_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
-
- //if (bb[1][1] == 0 && bb[1][0] != 0 && bb[1][3]==bb[2][3]){
- if(bb[0][0]==0 && bb[0][0] == 0 && bb[1][0] == 0x56){
- fprintf(stderr, "Switch event:\n");
- fprintf(stderr, "protocol = Intertechno\n");
- fprintf(stderr, "rid = %x\n",bb[1][0]);
- fprintf(stderr, "rid = %x\n",bb[1][1]);
- fprintf(stderr, "rid = %x\n",bb[1][2]);
- fprintf(stderr, "rid = %x\n",bb[1][3]);
- fprintf(stderr, "rid = %x\n",bb[1][4]);
- fprintf(stderr, "rid = %x\n",bb[1][5]);
- fprintf(stderr, "rid = %x\n",bb[1][6]);
- fprintf(stderr, "rid = %x\n",bb[1][7]);
- fprintf(stderr, "ADDR Slave = %i\n",bb[1][7] & 0b00001111);
- fprintf(stderr, "ADDR Master = %i\n",(bb[1][7] & 0b11110000) >> 4);
- fprintf(stderr, "command = %i\n",(bb[1][6] & 0b00000111));
- fprintf(stderr, "%02x %02x %02x %02x %02x\n",bb[1][0],bb[1][1],bb[1][2],bb[1][3],bb[1][4]);
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-r_device intertechno = {
- /* .id = */ 14,
- /* .name = */ "Intertechno 433",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 100,
- /* .long_limit = */ 350,
- /* .reset_limit = */ 3000,
- /* .json_callback = */ &intertechno_callback,
- /* .json_callback = */ //&debug_callback,
-};
+++ /dev/null
-/* LaCrosse TX Temperature and Humidity Sensors
- * Tested: TX-7U and TX-6U (Temperature only)
- *
- * Not Tested but should work: TX-3, TX-4
- *
- * Protocol Documentation: http://www.f6fbb.org/domo/sensors/tx3_th.php
- *
- * Message is 44 bits, 11 x 4 bit nybbles:
- *
- * [00] [cnt = 10] [type] [addr] [addr + parity] [v1] [v2] [v3] [iv1] [iv2] [check]
- *
- * Notes:
- * - Zero Pulses are longer (1,400 uS High, 1,000 uS Low) = 2,400 uS
- * - One Pulses are shorter ( 550 uS High, 1,000 uS Low) = 1,600 uS
- * - Sensor id changes when the battery is changed
- * - Values are BCD with one decimal place: vvv = 12.3
- * - Value is repeated integer only iv = 12
- * - Temperature is in Celsius with 50.0 added (to handle negative values)
- * - There is a 4 bit checksum and a parity bit covering the three digit value
- * - Parity check for TX-3 and TX-4 might be different.
- * - Msg sent with one repeat after 30 mS
- * - Temperature and humidity are sent as separate messages
- * - Frequency for each sensor may be could be off by as much as 50-75 khz
- */
-
-#include "rtl_433.h"
-
-// buffer to hold localized timestamp YYYY-MM-DD HH:MM:SS
-#define LOCAL_TIME_BUFLEN 32
-
-void local_time_str(time_t time_secs, char *buf) {
- time_t etime;
- struct tm *tm_info;
-
- if (time_secs == 0) {
- time(&etime);
- } else {
- etime = time_secs;
- }
-
- tm_info = localtime(&etime);
-
- strftime(buf, LOCAL_TIME_BUFLEN, "%Y-%m-%d %H:%M:%S", tm_info);
-}
-
-// Check for a valid LaCrosse Packet
-//
-// written for the version of pwm_p_decode() (OOK_PWM_P)
-// pulse width detector with two anomalys:
-// 1. bits are inverted
-// 2. The first bit is discarded as a start bit
-//
-// If a fixed pulse width decoder is used this
-// routine will need to be changed.
-static int lacrossetx_detect(uint8_t *pRow, uint8_t *msg_nybbles) {
- int i;
- uint8_t rbyte_no, rbit_no, mnybble_no, mbit_no;
- uint8_t bit, checksum, parity_bit, parity = 0;
-
- // Actual Packet should start with 0x0A and be 6 bytes
- // actual message is 44 bit, 11 x 4 bit nybbles.
- if ((pRow[0] & 0xFE) == 0x14 && pRow[6] == 0 && pRow[7] == 0) {
-
- for (i = 0; i < 11; i++) {
- msg_nybbles[i] = 0;
- }
-
- // Move nybbles into a byte array
- // shifted by one to compensate for loss of first bit.
- for (i = 0; i < 43; i++) {
- rbyte_no = i / 8;
- rbit_no = 7 - (i % 8);
- mnybble_no = (i + 1) / 4;
- mbit_no = 3 - ((i + 1) % 4);
- bit = (pRow[rbyte_no] & (1 << rbit_no)) ? 1 : 0;
- msg_nybbles[mnybble_no] |= (bit << mbit_no);
-
- // Check parity on three bytes of data value
- // TX3U might calculate parity on all data including
- // sensor id and redundant integer data
- if (mnybble_no > 4 && mnybble_no < 8) {
- parity += bit;
- }
-
- // fprintf(stderr, "recv: [%d/%d] %d -> msg [%d/%d] %02x, Parity: %d %s\n", rbyte_no, rbit_no,
- // bit, mnybble_no, mbit_no, msg_nybbles[mnybble_no], parity,
- // ( mbit_no == 0 ) ? "\n" : "" );
- }
-
- parity_bit = msg_nybbles[4] & 0x01;
- parity += parity_bit;
-
- // Validate Checksum (4 bits in last nybble)
- checksum = 0;
- for (i = 0; i < 10; i++) {
- checksum = (checksum + msg_nybbles[i]) & 0x0F;
- }
-
- // fprintf(stderr,"Parity: %d, parity bit %d, Good %d\n", parity, parity_bit, parity % 2);
-
- if (checksum == msg_nybbles[10] && (parity % 2 == 0)) {
- return 1;
- } else {
- fprintf(stderr,
- "LaCrosse Checksum/Parity error: %d != %d, Parity %d\n",
- checksum, msg_nybbles[10], parity);
- return 0;
- }
- }
-
- return 0;
-}
-
-// LaCrosse TX-6u, TX-7u, Temperature and Humidity Sensors
-// Temperature and Humidity are sent in different messages bursts.
-static int lacrossetx_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],
- int16_t bits_per_row[BITBUF_ROWS]) {
-
- int i, m, valid = 0;
- uint8_t *buf;
- uint8_t msg_nybbles[11];
- uint8_t sensor_id, msg_type, msg_len, msg_parity, msg_checksum;
- int msg_value_int;
- float msg_value = 0, temp_c = 0, temp_f = 0;
- time_t time_now;
- char time_str[25];
-
- static float last_msg_value = 0.0;
- static uint8_t last_sensor_id = 0;
- static uint8_t last_msg_type = 0;
- static time_t last_msg_time = 0;
-
- for (m = 0; m < BITBUF_ROWS; m++) {
- valid = 0;
- if (lacrossetx_detect(bb[m], msg_nybbles)) {
-
- msg_len = msg_nybbles[1];
- msg_type = msg_nybbles[2];
- sensor_id = (msg_nybbles[3] << 3) + (msg_nybbles[4] >> 1);
- msg_parity = msg_nybbles[4] & 0x01;
- msg_value = msg_nybbles[5] * 10 + msg_nybbles[6]
- + msg_nybbles[7] / 10.0;
- msg_value_int = msg_nybbles[8] * 10 + msg_nybbles[9];
- msg_checksum = msg_nybbles[10];
-
- time(&time_now);
-
- // suppress duplicates
- if (sensor_id == last_sensor_id && msg_type == last_msg_type
- && last_msg_value == msg_value
- && time_now - last_msg_time < 50) {
- continue;
- }
-
- local_time_str(time_now, time_str);
-
- switch (msg_type) {
- case 0x00:
- temp_c = msg_value - 50.0;
- temp_f = temp_c * 1.8 + 32;
- printf("SENSOR:TYPE=LACROSSE_TX,TIME=%s,ID=%02x,TEMP=%3.1f\n",
- time_str, sensor_id, temp_c);
- break;
-
- case 0x0E:
- printf("SENSOR:TYPE=LACROSSE_TX,TIME=%s,ID=%02x,HUMIDITY=%3.1f\n",
- time_str, sensor_id, msg_value);
- break;
-
- default:
- fprintf(stderr,
- "%s LaCrosse Sensor %02x: Unknown Reading % 3.1f (%d)\n",
- time_str, sensor_id, msg_value, msg_value_int);
- }
-
- time(&last_msg_time);
- last_msg_value = msg_value;
- last_msg_type = msg_type;
- last_sensor_id = sensor_id;
-
- } else {
- return 0;
- }
- }
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
- return 1;
-}
-
-r_device lacrossetx = {
-/* .id = */15,
-/* .name = */"LaCrosse TX Temperature / Humidity Sensor",
-/* .modulation = */OOK_PWM_P,
-/* .short_limit = */238,
-/* .long_limit = */750,
-/* .reset_limit = */8000,
-/* .json_callback = */&lacrossetx_callback, };
+++ /dev/null
-#include "rtl_433.h"
-
-int leak_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- int i,j,k;
- int rows_used[BITBUF_ROWS];
- int col_max = 0;
- int row_cnt = 0;
-
- // determine what part of bb[][] has non-zero data to avoid
- // outputting lots of empty rows
- for (i=0 ; i<BITBUF_ROWS ; i++) {
- for (j=BITBUF_COLS - 1 ; j > 0 ; j--) {
- if (bb[i][j] != 0)
- break;
- }
- if (j != 0) {
- rows_used[i] = 1;
- row_cnt++;
- if (j > col_max)
- col_max = j;
- } else {
- rows_used[i] = 0;
- }
- }
-
- fprintf(stderr,"Rows=%d,Cols=%d",row_cnt,col_max);
-
- if (row_cnt != 1) {
- return 0;
- }
-
- if (col_max !=4) {
- return 0;
- }
-
- if ((bb[0][0] == 0x76) || (bb[0][0] == 0x77)) {
-
- fprintf(stdout,"ALARM:TYPE=LEAK,ID=%2X%2X%2X%2X\n",bb[0][0],bb[0][1],bb[0][2],bb[0][3]);
-
- }
-
- return 1;
-
-}
-
-r_device leak = {
- /* .id = */ 20,
- /* .name = */ "Leak sensor",
- /* .modulation = */ OOK_MANCHESTER,
- /* .short_limit = */ 150,
- /* .long_limit = */ 0,
- /* .reset_limit = */ 1000,
- /* .json_callback = */ &leak_callback,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-static int mebus433_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- int temperature_before_dec;
- int temperature_after_dec;
- int16_t temp;
- int8_t hum;
-
- if (bb[0][0] == 0 && bb[1][4] !=0 && (bb[1][0] & 0b01100000) && bb[1][3]==bb[5][3] && bb[1][4] == bb[12][4]){
- // Upper 4 bits are stored in nibble 1, lower 8 bits are stored in nibble 2
- // upper 4 bits of nibble 1 are reserved for other usages.
- temp = (int16_t)((uint16_t)(bb[1][1] << 12 ) | bb[1][2]<< 4);
- temp = temp >> 4;
- // lower 4 bits of nibble 3 and upper 4 bits of nibble 4 contains
- // humidity as decimal value
- hum = (bb[1][3] << 4 | bb[1][4] >> 4);
-
- temperature_before_dec = abs(temp / 10);
- temperature_after_dec = abs(temp % 10);
-
- fprintf(stdout, "SENSOR:TYPE=MEBUS,");
- fprintf(stdout, "ID=%i,", bb[1][0] & 0b00011111);
- fprintf(stdout, "CHANNEL=%i,",((bb[1][1] & 0b00110000) >> 4)+1);
- fprintf(stdout, "BATTERY=%s,", bb[1][1] & 0b10000000?"OK":"LOW");
- fprintf(stdout, "TEMP=%s%d.%d,",temp<0?"-":"",temperature_before_dec, temperature_after_dec);
- fprintf(stdout, "HUMIDITY=%i\n", hum);
- fprintf(stderr, "%02x %02x %02x %02x %02x\n",bb[1][0],bb[1][1],bb[1][2],bb[1][3],bb[1][4]);
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-r_device mebus433 = {
- /* .id = */ 16,
- /* .name = */ "Mebus 433",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 300,
- /* .long_limit = */ 600,
- /* .reset_limit = */ 1500,
- /* .json_callback = */ &mebus433_callback,
- /* .json_callback = */ //&debug_callback,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-static int newkaku_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- /* Two bits map to 2 states, 0 1 -> 0 and 1 1 -> 1 */
- /* Status bit can be 1 1 -> 1 which indicates DIM value. 4 extra bits are present with value */
- /*start pulse: 1T high, 10.44T low */
- /*- 26 bit: Address */
- /*- 1 bit: group bit*/
- /*- 1 bit: Status bit on/off/[dim]*/
- /*- 4 bit: unit*/
- /*- [4 bit: dim level. Present if [dim] is used, but might be present anyway...]*/
- /*- stop pulse: 1T high, 40T low */
- int i;
- uint8_t tmp = 0;
- uint8_t unit = 0;
- uint8_t packet = 0;
- uint8_t bitcount = 0;
- uint32_t kakuid = 0;
-
- if (bb[0][0] == 0xac) {//allways starts with ac
- // first bit is from startbit sequence, not part of payload!
- // check protocol if value is 10 or 01, else stop processing as it is no vallid KAKU packet!
- //get id=24bits, remember 1st 1 bit = startbit, no payload!
- for (packet = 0; packet < 6; packet++) {//get first part kakuid
- tmp = bb[0][packet] << 1;
- if ((bb[0][packet + 1]&(1 << 7)) != 0) {// if set add bit to current
- tmp++;
- }
-
- for (bitcount = 0; bitcount < 8; bitcount += 2) {//process bitstream, check protocol!
-
- if (((tmp << bitcount & (0x80)) == 0x80)&((tmp << bitcount & (0x40)) == 0)) {
- //add 1
- kakuid = kakuid << 1;
- kakuid++;
- } else
- if (((tmp << bitcount & (0x80)) == 0)&((tmp << bitcount & (0x40)) == 0x40)) {
- kakuid = kakuid << 1;
- //add 0
- } else {
- return 0; //00 and 11 indicates packet error. Do exit, no valid packet
- }
- }
- }
- tmp = bb[0][6] << 1; //Get last part ID
- for (bitcount = 0; bitcount < 4; bitcount += 2) {
- if (((tmp << bitcount & (0x80)) == 0x80)&((tmp << bitcount & (0x40)) == 0)) {
- //add 1
- kakuid = kakuid << 1;
- kakuid++;
- } else
- if (((tmp << bitcount & (0x80)) == 0)&((tmp << bitcount & (0x40)) == 0x40)) {
- //= add bit on kakuid
- kakuid = kakuid << 1;
- //add 0
- } else {
- //fprintf(stderr, " Packet error, no newkaku!!\n", tmp << bitcount);
- return 0; //00 and 11 indicates packet error. no valid packet! do exit
- }
- }
- //Get unit ID
- tmp = bb[0][7] << 1;
- if ((bb[0][8]&(1 << 7)) != 0) {// if set add bit to current
- tmp++;
- }
- for (bitcount = 0; bitcount < 8; bitcount += 2) {//process bitstream, check protocol!
- if (((tmp << bitcount & (0x80)) == 0x80)&((tmp << bitcount & (0x40)) == 0)) {
- //add 1
- unit = unit << 1;
- unit++;
- } else
- if (((tmp << bitcount & (0x80)) == 0)&((tmp << bitcount & (0x40)) == 0x40)) {
- unit = unit << 1;
- //add 0
- } else {
- return 0; //00 and 11 indicates packet error. Do exit, no valid packet
- }
- }
- fprintf(stderr, "NewKaku event:\n");
- fprintf(stderr, "Model = NewKaKu on/off/dimmer switch\n");
- fprintf(stderr, "KakuId = %d (H%.2X)\n", kakuid, kakuid);
- fprintf(stderr, "Unit = %d (H%.2X)\n", unit, unit);
- fprintf(stderr, "Group Call = %s\n", (((bb[0][6] & (0x04)) == 0x04)&((bb[0][6] & (0x02)) == 0)) ? "Yes" : "No");
- fprintf(stderr, "Command = %s\n", (((bb[0][6] & (0x01)) == 0x01)&((bb[0][7] & (0x80)) == 0)) ? "On" : "Off");
- if (((bb[0][6] & (0x01)) == 0x01)&((bb[0][7] & (0x80)) == 0x80)) {//11 indicates DIM command, 4 extra bits indicate DIM value
- fprintf(stderr, "Dim = Yes\n");
- tmp = bb[0][8] << 1; // get packet, loose first bit
- uint8_t dv = 0;
- if ((bb[0][9]&(1 << 7)) != 0) {// if bit is set Add to current packet
- tmp++;
- for (bitcount = 0; bitcount < 8; bitcount += 2) {//process last bit outside
- if (((tmp << bitcount & (0x80)) == 0x80)&((tmp << bitcount & (0x40)) == 0)) {
- //add 1
- dv = dv << 1;
- dv++;
- } else
- if (((tmp << bitcount & (0x80)) == 0)&((tmp << bitcount & (0x40)) == 0x40)) {
- dv = dv << 1;
- //add 0
- } else {
- return 0; //00 and 11 indicates packet error. Do exit, no valid packet
- }
- }
- }
- fprintf(stderr, "Dim Value = %d\n", dv);
- } else {
- fprintf(stderr, "Dim = No\n");
- fprintf(stderr, "Dim Value = 0\n");
- }
- fprintf(stderr, "%02x %02x %02x %02x %02x %02x %02x %02x %02x\n",
- bb[0][0], bb[0][1], bb[0][2], bb[0][3], bb[0][4], bb[0][5], bb[0][6], bb[0][7], bb[0][8]);
- if (debug_output)
- debug_callback(bb, bits_per_row);
- return 1;
- }
- return 0;
-}
-
-r_device newkaku = {
- /* .id = */ 17,
- /* .name = */ "KlikAanKlikUit Wireless Switch",
- /* .modulation = */ OOK_PWM_D,
- /* .short_limit = */ 200,
- /* .long_limit = */ 800,
- /* .reset_limit = */ 4000,
- /* .json_callback = */ &newkaku_callback,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-float get_os_temperature(unsigned char *message, unsigned int sensor_id) {
- // sensor ID included to support sensors with temp in different position
- float temp_c = 0;
- temp_c = (((message[5]>>4)*100)+((message[4]&0x0f)*10) + ((message[4]>>4)&0x0f)) /10.0F;
- if (message[5] & 0x0f)
- temp_c = -temp_c;
- return temp_c;
-}
-unsigned int get_os_humidity(unsigned char *message, unsigned int sensor_id) {
- // sensor ID included to support sensors with temp in different position
- int humidity = 0;
- humidity = ((message[6]&0x0f)*10)+(message[6]>>4);
- return humidity;
-}
-
-static int validate_os_checksum(unsigned char *msg, int checksum_nibble_idx) {
- // Oregon Scientific v2.1 and v3 checksum is a 1 byte 'sum of nibbles' checksum.
- // with the 2 nibbles of the checksum byte swapped.
- int i;
- unsigned int checksum, sum_of_nibbles=0;
- for (i=0; i<(checksum_nibble_idx-1);i+=2) {
- unsigned char val=msg[i>>1];
- sum_of_nibbles += ((val>>4) + (val &0x0f));
- }
- if (checksum_nibble_idx & 1) {
- sum_of_nibbles += (msg[checksum_nibble_idx>>1]>>4);
- checksum = (msg[checksum_nibble_idx>>1] & 0x0f) | (msg[(checksum_nibble_idx+1)>>1]&0xf0);
- } else
- checksum = (msg[checksum_nibble_idx>>1]>>4) | ((msg[checksum_nibble_idx>>1]&0x0f)<<4);
- sum_of_nibbles &= 0xff;
-
- if (sum_of_nibbles == checksum)
- return 0;
- else {
- fprintf(stderr, "Checksum error in Oregon Scientific message. Expected: %02x Calculated: %02x\n", checksum, sum_of_nibbles);
- fprintf(stderr, "Message: "); int i; for (i=0 ;i<((checksum_nibble_idx+4)>>1) ; i++) fprintf(stderr, "%02x ", msg[i]); fprintf(stderr, "\n\n");
- return 1;
- }
-}
-
-static int validate_os_v2_message(unsigned char * msg, int bits_expected, int valid_v2_bits_received,
- int nibbles_in_checksum) {
- // Oregon scientific v2.1 protocol sends each bit using the complement of the bit, then the bit for better error checking. Compare number of valid bits processed vs number expected
- if (bits_expected == valid_v2_bits_received) {
- return (validate_os_checksum(msg, nibbles_in_checksum));
- } else {
- fprintf(stderr, "Bit validation error on Oregon Scientific message. Expected %d bits, received error after bit %d \n", bits_expected, valid_v2_bits_received);
- fprintf(stderr, "Message: "); int i; for (i=0 ;i<(bits_expected+7)/8 ; i++) fprintf(stderr, "%02x ", msg[i]); fprintf(stderr, "\n\n");
- }
- return 1;
-}
-
-static int oregon_scientific_v2_1_parser(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- // Check 2nd and 3rd bytes of stream for possible Oregon Scientific v2.1 sensor data (skip first byte to get past sync/startup bit errors)
- if ( ((bb[0][1] == 0x55) && (bb[0][2] == 0x55)) ||
- ((bb[0][1] == 0xAA) && (bb[0][2] == 0xAA))) {
- int i,j;
- unsigned char msg[BITBUF_COLS] = {0};
-
- // Possible v2.1 Protocol message
- int num_valid_v2_bits = 0;
-
- unsigned int sync_test_val = (bb[0][3]<<24) | (bb[0][4]<<16) | (bb[0][5]<<8) | (bb[0][6]);
- int dest_bit = 0;
- int pattern_index;
- // Could be extra/dropped bits in stream. Look for sync byte at expected position +/- some bits in either direction
- for(pattern_index=0; pattern_index<8; pattern_index++) {
- unsigned int mask = (unsigned int) (0xffff0000>>pattern_index);
- unsigned int pattern = (unsigned int)(0x55990000>>pattern_index);
- unsigned int pattern2 = (unsigned int)(0xaa990000>>pattern_index);
-
- //fprintf(stderr, "OS v2.1 sync byte search - test_val=%08x pattern=%08x mask=%08x\n", sync_test_val, pattern, mask);
-
- if (((sync_test_val & mask) == pattern) ||
- ((sync_test_val & mask) == pattern2)) {
- // Found sync byte - start working on decoding the stream data.
- // pattern_index indicates where sync nibble starts, so now we can find the start of the payload
- int start_byte = 5 + (pattern_index>>3);
- int start_bit = pattern_index & 0x07;
- //fprintf(stderr, "OS v2.1 Sync test val %08x found, starting decode at byte index %d bit %d\n", sync_test_val, start_byte, start_bit);
- int bits_processed = 0;
- unsigned char last_bit_val = 0;
- j=start_bit;
- for (i=start_byte;i<BITBUF_COLS;i++) {
- while (j<8) {
- if (bits_processed & 0x01) {
- unsigned char bit_val = ((bb[0][i] & (0x80 >> j)) >> (7-j));
-
- // check if last bit received was the complement of the current bit
- if ((num_valid_v2_bits == 0) && (last_bit_val == bit_val))
- num_valid_v2_bits = bits_processed; // record position of first bit in stream that doesn't verify correctly
- last_bit_val = bit_val;
-
- // copy every other bit from source stream to dest packet
- msg[dest_bit>>3] |= (((bb[0][i] & (0x80 >> j)) >> (7-j)) << (7-(dest_bit & 0x07)));
-
- //fprintf(stderr,"i=%d j=%d dest_bit=%02x bb=%02x msg=%02x\n",i, j, dest_bit, bb[0][i], msg[dest_bit>>3]);
- if ((dest_bit & 0x07) == 0x07) {
- // after assembling each dest byte, flip bits in each nibble to convert from lsb to msb bit ordering
- int k = (dest_bit>>3);
- unsigned char indata = msg[k];
- // flip the 4 bits in the upper and lower nibbles
- msg[k] = ((indata & 0x11) << 3) | ((indata & 0x22) << 1) |
- ((indata & 0x44) >> 1) | ((indata & 0x88) >> 3);
- }
- dest_bit++;
- }
- else
- last_bit_val = ((bb[0][i] & (0x80 >> j)) >> (7-j)); // used for v2.1 bit error detection
- bits_processed++;
- j++;
- }
- j=0;
- }
- break;
- } //if (sync_test_val...
- } // for (pattern...
-
-
- int sensor_id = (msg[0] << 8) | msg[1];
- if ((sensor_id == 0x1d20) || (sensor_id == 0x1d30)) {
- if (validate_os_v2_message(msg, 153, num_valid_v2_bits, 15) == 0) {
- int channel = ((msg[2] >> 4)&0x0f);
- if (channel == 4)
- channel = 3; // sensor 3 channel number is 0x04
- float temp_c = get_os_temperature(msg, sensor_id);
- if (sensor_id == 0x1d20) fprintf(stderr, "Weather Sensor THGR122N Channel %d ", channel);
- else fprintf(stderr, "Weather Sensor THGR968 Outdoor ");
- fprintf(stderr, "Temp: %3.1f°C %3.1f°F Humidity: %d%%\n", temp_c, ((temp_c*9)/5)+32,get_os_humidity(msg, sensor_id));
- }
- return 1;
- } else if (sensor_id == 0x5d60) {
- if (validate_os_v2_message(msg, 185, num_valid_v2_bits, 19) == 0) {
- unsigned int comfort = msg[7] >>4;
- char *comfort_str="Normal";
- if (comfort == 4) comfort_str = "Comfortable";
- else if (comfort == 8) comfort_str = "Dry";
- else if (comfort == 0xc) comfort_str = "Humid";
- unsigned int forecast = msg[9]>>4;
- char *forecast_str="Cloudy";
- if (forecast == 3) forecast_str = "Rainy";
- else if (forecast == 6) forecast_str = "Partly Cloudy";
- else if (forecast == 0xc) forecast_str = "Sunny";
- float temp_c = get_os_temperature(msg, 0x5d60);
- fprintf(stderr,"Weather Sensor BHTR968 Indoor Temp: %3.1f°C %3.1f°F Humidity: %d%%", temp_c, ((temp_c*9)/5)+32, get_os_humidity(msg, 0x5d60));
- fprintf(stderr, " (%s) Pressure: %dmbar (%s)\n", comfort_str, ((msg[7] & 0x0f) | (msg[8] & 0xf0))+856, forecast_str);
- }
- return 1;
- } else if (sensor_id == 0x2d10) {
- if (validate_os_v2_message(msg, 161, num_valid_v2_bits, 16) == 0) {
- float rain_rate = (((msg[4] &0x0f)*100)+((msg[4]>>4)*10) + ((msg[5]>>4)&0x0f)) /10.0F;
- float total_rain = (((msg[7]&0xf)*10000)+((msg[7]>>4)*1000) + ((msg[6]&0xf)*100)+((msg[6]>>4)*10) + (msg[5]&0xf))/10.0F;
- fprintf(stderr, "Weather Sensor RGR968 Rain Gauge Rain Rate: %2.0fmm/hr Total Rain %3.0fmm\n", rain_rate, total_rain);
- }
- return 1;
- } else if (sensor_id == 0xec40 && num_valid_v2_bits==153) {
- if ( validate_os_v2_message(msg, 153, num_valid_v2_bits, 12) == 0) {
- int channel = ((msg[2] >> 4)&0x0f);
- if (channel == 4)
- channel = 3; // sensor 3 channel number is 0x04
- float temp_c = get_os_temperature(msg, sensor_id);
- if (sensor_id == 0xec40) fprintf(stderr, "Thermo Sensor THR228N Channel %d ", channel);
- fprintf(stderr, "Temp: %3.1f°C %3.1f°F\n", temp_c, ((temp_c*9)/5)+32);
- }
- return 1;
- } else if (sensor_id == 0xec40 && num_valid_v2_bits==129) {
- if ( validate_os_v2_message(msg, 129, num_valid_v2_bits, 12) == 0) {
- int channel = ((msg[2] >> 4)&0x0f);
- if (channel == 4)
- channel = 3; // sensor 3 channel number is 0x04
- int battery_low = (msg[3] >> 2 & 0x01);
- unsigned char rolling_code = ((msg[2] << 4)&0xF0) | ((msg[3] >> 4)&0x0F);
- float temp_c = get_os_temperature(msg, sensor_id);
- if (sensor_id == 0xec40) fprintf(stderr, "Thermo Sensor THN132N, Channel %d, Battery: %s, Rolling-code 0x%0X, ", channel, battery_low?"Low":"Ok", rolling_code);
- fprintf(stderr, "Temp: %3.1f°C %3.1f°F\n", temp_c, ((temp_c*9)/5)+32);
- }
- return 1;
- } else if (num_valid_v2_bits > 16) {
-fprintf(stderr, "%d bit message received from unrecognized Oregon Scientific v2.1 sensor with device ID %x.\n", num_valid_v2_bits, sensor_id);
-fprintf(stderr, "Message: "); for (i=0 ; i<20 ; i++) fprintf(stderr, "%02x ", msg[i]); fprintf(stderr,"\n\n");
- } else {
-//fprintf(stderr, "\nPossible Oregon Scientific v2.1 message, but sync nibble wasn't found\n"); fprintf(stderr, "Raw Data: "); for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", bb[0][i]); fprintf(stderr,"\n\n");
- }
- } else {
-//if (bb[0][3] != 0) int i; fprintf(stderr, "\nBadly formatted OS v2.1 message encountered."); for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", bb[0][i]); fprintf(stderr,"\n\n");}
- }
- return 0;
-}
-
-static int oregon_scientific_v3_parser(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
-
- // Check stream for possible Oregon Scientific v3 protocol data (skip part of first and last bytes to get past sync/startup bit errors)
- if ((((bb[0][0]&0xf) == 0x0f) && (bb[0][1] == 0xff) && ((bb[0][2]&0xc0) == 0xc0)) ||
- (((bb[0][0]&0xf) == 0x00) && (bb[0][1] == 0x00) && ((bb[0][2]&0xc0) == 0x00))) {
- int i,j;
- unsigned char msg[BITBUF_COLS] = {0};
- unsigned int sync_test_val = (bb[0][2]<<24) | (bb[0][3]<<16) | (bb[0][4]<<8);
- int dest_bit = 0;
- int pattern_index;
- // Could be extra/dropped bits in stream. Look for sync byte at expected position +/- some bits in either direction
- for(pattern_index=0; pattern_index<16; pattern_index++) {
- unsigned int mask = (unsigned int)(0xfff00000>>pattern_index);
- unsigned int pattern = (unsigned int)(0xffa00000>>pattern_index);
- unsigned int pattern2 = (unsigned int)(0xff500000>>pattern_index);
- unsigned int pattern3 = (unsigned int)(0x00500000>>pattern_index);
-//fprintf(stderr, "OS v3 Sync nibble search - test_val=%08x pattern=%08x mask=%08x\n", sync_test_val, pattern, mask);
- if (((sync_test_val & mask) == pattern) ||
- ((sync_test_val & mask) == pattern2) ||
- ((sync_test_val & mask) == pattern3)) {
- // Found sync byte - start working on decoding the stream data.
- // pattern_index indicates where sync nibble starts, so now we can find the start of the payload
- int start_byte = 3 + (pattern_index>>3);
- int start_bit = (pattern_index+4) & 0x07;
-//fprintf(stderr, "Oregon Scientific v3 Sync test val %08x ok, starting decode at byte index %d bit %d\n", sync_test_val, start_byte, start_bit);
- j = start_bit;
- for (i=start_byte;i<BITBUF_COLS;i++) {
- while (j<8) {
- unsigned char bit_val = ((bb[0][i] & (0x80 >> j)) >> (7-j));
-
- // copy every bit from source stream to dest packet
- msg[dest_bit>>3] |= (((bb[0][i] & (0x80 >> j)) >> (7-j)) << (7-(dest_bit & 0x07)));
-
-//fprintf(stderr,"i=%d j=%d dest_bit=%02x bb=%02x msg=%02x\n",i, j, dest_bit, bb[0][i], msg[dest_bit>>3]);
- if ((dest_bit & 0x07) == 0x07) {
- // after assembling each dest byte, flip bits in each nibble to convert from lsb to msb bit ordering
- int k = (dest_bit>>3);
- unsigned char indata = msg[k];
- // flip the 4 bits in the upper and lower nibbles
- msg[k] = ((indata & 0x11) << 3) | ((indata & 0x22) << 1) |
- ((indata & 0x44) >> 1) | ((indata & 0x88) >> 3);
- }
- dest_bit++;
- j++;
- }
- j=0;
- }
- break;
- }
- }
-
- if ((msg[0] == 0xf8) && (msg[1] == 0x24)) {
- if (validate_os_checksum(msg, 15) == 0) {
- int channel = ((msg[2] >> 4)&0x0f);
- float temp_c = get_os_temperature(msg, 0xf824);
- int humidity = get_os_humidity(msg, 0xf824);
- fprintf(stderr,"Weather Sensor THGR810 Channel %d Temp: %3.1f°C %3.1f°F Humidity: %d%%\n", channel, temp_c, ((temp_c*9)/5)+32, humidity);
- }
- return 1;
- } else if ((msg[0] == 0x19) && (msg[1] == 0x84)) {
- if (validate_os_checksum(msg, 17) == 0) {
- float gustWindspeed = (msg[11]+msg[10])/100;
- float quadrant = msg[8]*22.5;
- fprintf(stderr, "Weather Sensor WGR800 Wind Gauge Gust Wind Speed : %2.0f m/s Wind direction %3.0f dgrs\n", gustWindspeed, quadrant);
- }
- return 1;
- } else if ((msg[0] != 0) && (msg[1]!= 0)) { // sync nibble was found and some data is present...
-fprintf(stderr, "Message received from unrecognized Oregon Scientific v3 sensor.\n");
-fprintf(stderr, "Message: "); for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", msg[i]); fprintf(stderr, "\n");
-fprintf(stderr, " Raw: "); for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", bb[0][i]); fprintf(stderr,"\n\n");
- } else if (bb[0][3] != 0) {
-//fprintf(stderr, "\nPossible Oregon Scientific v3 message, but sync nibble wasn't found\n"); fprintf(stderr, "Raw Data: "); for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", bb[0][i]); fprintf(stderr,"\n\n");
- }
- }
- else { // Based on first couple of bytes, either corrupt message or something other than an Oregon Scientific v3 message
-//if (bb[0][3] != 0) { fprintf(stderr, "\nUnrecognized Msg in v3: "); int i; for (i=0 ; i<BITBUF_COLS ; i++) fprintf(stderr, "%02x ", bb[0][i]); fprintf(stderr,"\n\n"); }
- }
- return 0;
-}
-
-static int oregon_scientific_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- int ret = oregon_scientific_v2_1_parser(bb, bits_per_row);
- if (ret == 0)
- ret = oregon_scientific_v3_parser(bb, bits_per_row);
- return ret;
-}
-
-r_device oregon_scientific = {
- /* .id = */ 18,
- /* .name = */ "Oregon Scientific Weather Sensor",
- /* .modulation = */ OOK_MANCHESTER,
- /* .short_limit = */ 125,
- /* .long_limit = */ 0, // not used
- /* .reset_limit = */ 600,
- /* .json_callback = */ &oregon_scientific_callback,
-};
+++ /dev/null
-/* 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 "rtl_433.h"
-
-static int prologue_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- int rid;
-
- int16_t temp2;
-
- /* 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) &&
- (bb[1][3] == bb[2][3]) && (bb[1][4] == bb[2][4])) {
-
- /* Prologue sensor */
- temp2 = (int16_t)((uint16_t)(bb[1][2] << 8) | (bb[1][3]&0xF0));
- temp2 = temp2 >> 4;
- fprintf(stderr, "Sensor temperature event:\n");
- fprintf(stderr, "protocol = Prologue, %d bits\n",bits_per_row[1]);
- fprintf(stderr, "button = %d\n",bb[1][1]&0x04?1:0);
- fprintf(stderr, "battery = %s\n",bb[1][1]&0x08?"Ok":"Low");
- fprintf(stderr, "temp = %s%d.%d\n",temp2<0?"-":"",abs((int16_t)temp2/10),abs((int16_t)temp2%10));
- fprintf(stderr, "humidity = %d\n", ((bb[1][3]&0x0F)<<4)|(bb[1][4]>>4));
- fprintf(stderr, "channel = %d\n",(bb[1][1]&0x03)+1);
- fprintf(stderr, "id = %d\n",(bb[1][0]&0xF0)>>4);
- rid = ((bb[1][0]&0x0F)<<4)|(bb[1][1]&0xF0)>>4;
- fprintf(stderr, "rid = %d\n", rid);
- fprintf(stderr, "hrid = %02x\n", rid);
-
- fprintf(stderr, "%02x %02x %02x %02x %02x\n",bb[1][0],bb[1][1],bb[1][2],bb[1][3],bb[1][4]);
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-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,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-/* 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
- */
-
-static int rubicson_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- int temperature_before_dec;
- int temperature_after_dec;
- int16_t temp;
-
- /* 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 temerature is signed and scaled by 10 */
- temp = (int16_t)((uint16_t)(bb[0][1] << 12) | (bb[0][2] << 4));
- temp = temp >> 4;
-
- temperature_before_dec = abs(temp / 10);
- temperature_after_dec = abs(temp % 10);
-
- fprintf(stderr, "Sensor temperature event:\n");
- fprintf(stderr, "protocol = Rubicson/Auriol, %d bits\n",bits_per_row[1]);
- fprintf(stderr, "rid = %x\n",bb[0][0]);
- fprintf(stderr, "temp = %s%d.%d\n",temp<0?"-":"",temperature_before_dec, temperature_after_dec);
- fprintf(stderr, "%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, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-// 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,
-};
-
+++ /dev/null
-#include "rtl_433.h"
-
-static int silvercrest_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- /* 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(stderr, "Remote button event:\n");
- fprintf(stderr, "model = Silvercrest, %d bits\n",bits_per_row[1]);
- fprintf(stderr, "%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, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-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,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-static int steffen_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
-
- if (bb[0][0]==0x00 && ((bb[1][0]&0x07)==0x07) && bb[1][0]==bb[2][0] && bb[2][0]==bb[3][0]) {
-
- fprintf(stderr, "Remote button event:\n");
- fprintf(stderr, "model = Steffan Switch Transmitter, %d bits\n",bits_per_row[1]);
- fprintf(stderr, "code = %d%d%d%d%d\n", (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(stderr, "button = A\n");
- else if ((bb[1][2]&0x0f)==0x0d)
- fprintf(stderr, "button = B\n");
- else if ((bb[1][2]&0x0f)==0x0b)
- fprintf(stderr, "button = C\n");
- else if ((bb[1][2]&0x0f)==0x07)
- fprintf(stderr, "button = D\n");
- else if ((bb[1][2]&0x0f)==0x0f)
- fprintf(stderr, "button = ALL\n");
- else
- fprintf(stderr, "button = unknown\n");
-
- if ((bb[1][2]&0xf0)==0xf0) {
- fprintf(stderr, "state = OFF\n");
- } else {
- fprintf(stderr, "state = ON\n");
- }
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-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,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-static int waveman_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- /* 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(stderr, "Remote button event:\n");
- fprintf(stderr, "model = Waveman Switch Transmitter, %d bits\n",bits_per_row[1]);
- fprintf(stderr, "id = %c\n", 'A'+nb[0]);
- fprintf(stderr, "channel = %d\n", (nb[1]>>2)+1);
- fprintf(stderr, "button = %d\n", (nb[1]&3)+1);
- fprintf(stderr, "state = %s\n", (nb[2]==0xe) ? "on" : "off");
- fprintf(stderr, "%02x %02x %02x\n",nb[0],nb[1],nb[2]);
-
- if (debug_output)
- debug_callback(bb, bits_per_row);
-
- return 1;
- }
- return 0;
-}
-
-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,
-};
+++ /dev/null
-#include "rtl_433.h"
-
-// ** WH2 Temperature and Humidity Outdoor Sensor **
-
-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;
-}
-
-static int wh2_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS],int16_t bits_per_row[BITBUF_ROWS]) {
- 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);
- fprintf(stderr, "SENSOR:TYPE=WH2,ID=%X,HUMIDITY=%g,TEMPERATURE=%g\n",wh2_id,wh2_humidity,wh2_temp);
-
- return 1;
-
-}
-
-r_device wh2 = {
- /* .id = */ 19,
- /* .name = */ "WH2 Weather Station",
- /* .modulation = */ OOK_PWM_P,
- /* .short_limit = */ 150,
- /* .long_limit = */ 400,
- /* .reset_limit = */ 20000,
- /* .json_callback = */ &wh2_callback,
-};
+++ /dev/null
-/*
- * rtl_433, turns your Realtek RTL2832 based DVB dongle into a 433.92MHz generic data receiver
- * Copyright (C) 2012 by Benjamin Larsson <benjamin@southpole.se>
- *
- * Based on rtl_sdr
- *
- * Copyright (C) 2012 by Steve Markgraf <steve@steve-m.de>
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#include "rtl-sdr.h"
-#include "rtl_433.h"
-#include "rtl_433_devices.h"
-
-static int do_exit = 0;
-static int do_exit_async = 0, frequencies = 0, events = 0;
-uint32_t frequency[MAX_PROTOCOLS];
-time_t rawtime_old;
-int flag;
-uint32_t samp_rate = DEFAULT_SAMPLE_RATE;
-static uint32_t bytes_to_read = 0;
-static rtlsdr_dev_t *dev = NULL;
-static uint16_t scaled_squares[256];
-static int override_short = 0;
-static int override_long = 0;
-int debug_output = 0;
-
-int debug_callback(uint8_t bb[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]) {
- int i,j,k;
- int rows_used[BITBUF_ROWS];
- int col_max = 0;
- int row_cnt = 0;
-
- // determine what part of bb[][] has non-zero data to avoid
- // outputting lots of empty rows
- for (i=0 ; i<BITBUF_ROWS ; i++) {
- for (j=BITBUF_COLS - 1 ; j > 0 ; j--) {
- if (bb[i][j] != 0)
- break;
- }
- if (j != 0) {
- rows_used[i] = 1;
- row_cnt++;
- if (j > col_max)
- col_max = j;
- } else {
- rows_used[i] = 0;
- }
- }
-
- if (!row_cnt) {
- fprintf(stderr, "debug_callback: empty data array\n");
- return 0;
- }
-
- fprintf(stderr, "\n");
- for (i=0 ; i<BITBUF_ROWS ; i++) {
- if (!rows_used[i]) {
- continue;
- }
-
- fprintf(stderr, "[%02d] ",i);
- for (j=0 ; j<=col_max ; j++) {
- fprintf(stderr, "%02x ", bb[i][j]);
- }
- fprintf(stderr, ": ");
- for (j=0 ; j<=col_max ; 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;
-}
-
-struct protocol_state {
- int (*callback)(uint8_t bits_buffer[BITBUF_ROWS][BITBUF_COLS], int16_t bits_per_row[BITBUF_ROWS]);
-
- /* 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;
-
-
-};
-
-struct dm_state {
- FILE *file;
- int save_data;
- int32_t level_limit;
- int32_t decimation_level;
- int16_t filter_buffer[MAXIMAL_BUF_LENGTH + FILTER_ORDER];
- int16_t* f_buf;
- int analyze;
- int debug_mode;
-
- /* Signal grabber variables */
- int signal_grabber;
- int8_t* sg_buf;
- int sg_index;
- int sg_len;
-
-
- /* Protocol states */
- int r_dev_num;
- struct protocol_state *r_devs[MAX_PROTOCOLS];
-
-};
-
-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);
- exit(1);
-}
-
-#ifdef _WIN32
-BOOL WINAPI
-sighandler(int signum) {
- if (CTRL_C_EVENT == signum) {
- fprintf(stderr, "Signal caught, exiting!\n");
- do_exit = 1;
- rtlsdr_cancel_async(dev);
- return TRUE;
- }
- return FALSE;
-}
-#else
-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);
-
- 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 (demod->r_dev_num > MAX_PROTOCOLS)
- fprintf(stderr, "Max number of protocols reached %d\n", MAX_PROTOCOLS);
-}
-
-
-static unsigned int counter = 0;
-static unsigned int print = 1;
-static unsigned int print2 = 0;
-static unsigned int pulses_found = 0;
-static unsigned int prev_pulse_start = 0;
-static unsigned int pulse_start = 0;
-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_pulse_counter = 0;
-
-static void classify_signal() {
- 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};
- struct protocol_state p = {0};
- unsigned int signal_type;
-
- if (!signal_pulse_data[0][0])
- return;
-
- 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],
- //signal_pulse_data[i][2]);
- if (signal_pulse_data[i][2] > max)
- max = signal_pulse_data[i][2];
- if (signal_pulse_data[i][2] <= min)
- min = signal_pulse_data[i][2];
- }
- }
- t = (max + min) / 2;
- //fprintf(stderr, "\n\nMax: %d, Min: %d t:%d\n", max, min, t);
-
- 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++) {
- 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 {
- max_new = max_new + signal_pulse_data[i][2];
- 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;
-
- 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++) {
- if (signal_pulse_data[i][0] > 0) {
- //fprintf(stderr, "%d\n", signal_pulse_data[i][1]);
- }
- }
- /* 50% decision limit */
- 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);
- signal_type = 1;
- }
- p_limit = (max + min) / 2;
-
- /* Initial guesses */
- a[0] = 1000000;
- a[2] = 0;
- 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];
- }
- }
- 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;
- delta = 10000000;
- 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++) {
- 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]) {
- a_new[1] += signal_distance_data[i];
- a_cnt[1]++;
- } else if (signal_distance_data[i] >= b[1]) {
- a_new[2] += signal_distance_data[i];
- a_cnt[2]++;
- }
- }
- }
-
- // fprintf(stderr, "Iteration %d.", k);
- delta = 0;
- 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]);
- a[i] = a_new[i];
- }
- // fprintf(stderr, " delta %d\n", delta);
-
- if (a[0] < min) {
- a[0] = min;
- // fprintf(stderr, "Fixing a[0] = %d\n", min);
- }
- if (a[2] > max) {
- a[0] = 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]);
- }
- // fprintf(stderr, "\n");
- k++;
- }
-
- if (override_short) {
- p_limit = override_short;
- a[0] = override_short;
- }
-
- if (override_long) {
- a[1] = override_long;
- }
-
- if (a[1]<a[0]) {
- a[1]=a[0]+1;
- }
-
- 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);
- if (signal_type == 1) {
- 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);
- }
-
- }
-
- }
- demod_print_bits_packet(&p);
- }
- if (signal_type == 2) {
- 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);
- } else {
- // fprintf(stderr, "1 [%d] %d > %d\n",i, signal_pulse_data[i][2], p_limit);
- demod_add_bit(&p, 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);
- }
-
-
- }
- }
- demod_print_bits_packet(&p);
- }
-
- for (i = 0; i < 1000; i++) {
- signal_pulse_data[i][0] = 0;
- signal_pulse_data[i][1] = 0;
- signal_pulse_data[i][2] = 0;
- signal_distance_data[i] = 0;
- }
-
-};
-
-static void pwm_analyze(struct dm_state *demod, int16_t *buf, uint32_t len) {
- unsigned int i;
-
- for (i = 0; i < len; i++) {
- if (buf[i] > demod->level_limit) {
- if (!signal_start)
- signal_start = counter;
- if (print) {
- pulses_found++;
- pulse_start = counter;
- 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]);
- prev_pulse_start = pulse_start;
- print = 0;
- print2 = 1;
- }
- }
- counter++;
- if (buf[i] < demod->level_limit) {
- if (print2) {
- 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);
- 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_counter++;
- if (signal_pulse_counter >= 4000) {
- signal_pulse_counter = 0;
- goto err;
- }
- }
- 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);
- pulses_found = 0;
- classify_signal();
-
- signal_pulse_counter = 0;
- if (demod->sg_buf) {
- 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;
- if (sg_idx < 0)
- 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;
- fprintf(stderr, "restart_pos = %d\n", start_pos);
- }
-
- 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_bszie;
- if (start_pos + signal_bszie > SIGNAL_GRABBER_BUFFER) {
- wlen = SIGNAL_GRABBER_BUFFER - start_pos;
- wrest = signal_bszie - 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);
- }
-
- fclose(sgfp);
- }
- signal_start = 0;
- }
- }
-
-
- }
- return;
-
-err:
- fprintf(stderr, "To many pulses detected, probably bad input data or input parameters\n");
- 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, p->bits_per_row);
- else
- demod_print_bits_packet(p);
-
- demod_reset_bits_packet(p);
- }
- }
-}
-
-/* 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;
- // 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;
- p->sample_counter = 0;
- // 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;
- // 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;
- // 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) {
- demod_add_bit(p, 1);
- } else if (p->pulse_length > p->short_limit) {
- demod_add_bit(p, 0);
- }
- p->sample_counter = 0;
- p->pulse_start = 0;
- }
-
- if (p->real_bits && (p->pulse_length > p->long_limit)) {
- 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;
- //demod_print_bits_packet(p);
- if (p->callback)
- events += p->callback(p->bits_buffer, p->bits_per_row);
- else
- demod_print_bits_packet(p);
- demod_reset_bits_packet(p);
-
- p->start_bit = 0;
- p->real_bits = 0;
- }
- }
-}
-
-/* Machester Decode for Oregon Scientific Weather Sensors
- Decode data streams sent by Oregon Scientific v2.1, and v3 weather sensors.
- With manchester encoding, both the pulse width and pulse distance vary. Clock sync
- is recovered from the data stream based on pulse widths and distances exceeding a
- minimum threashold (short limit* 1.5).
- */
-static void manchester_decode(struct dm_state *demod, struct protocol_state* p, int16_t *buf, uint32_t len) {
- unsigned int i;
-
- if (p->sample_counter == 0)
- p->sample_counter = p->short_limit*2;
-
- for (i=0 ; i<len ; i++) {
-
- if (p->start_c)
- p->sample_counter++; /* For this decode type, sample counter is count since last data bit recorded */
-
- if (!p->pulse_count && (buf[i] > demod->level_limit)) { /* Pulse start (rising edge) */
- p->pulse_count = 1;
- if (p->sample_counter > (p->short_limit + (p->short_limit>>1))) {
- /* Last bit was recorded more than short_limit*1.5 samples ago */
- /* so this pulse start must be a data edge (rising data edge means bit = 0) */
- demod_add_bit(p, 0);
- p->sample_counter=1;
- p->start_c++; // start_c counts number of bits received
- }
- }
- if (p->pulse_count && (buf[i] <= demod->level_limit)) { /* Pulse end (falling edge) */
- if (p->sample_counter > (p->short_limit + (p->short_limit>>1))) {
- /* Last bit was recorded more than "short_limit*1.5" samples ago */
- /* so this pulse end is a data edge (falling data edge means bit = 1) */
- demod_add_bit(p, 1);
- p->sample_counter=1;
- p->start_c++;
- }
- p->pulse_count = 0;
- }
-
- if (p->sample_counter > p->reset_limit) {
- //fprintf(stderr, "manchester_decode number of bits received=%d\n",p->start_c);
- if (p->callback)
- events+=p->callback(p->bits_buffer, p->bits_per_row);
- else
- demod_print_bits_packet(p);
- demod_reset_bits_packet(p);
- p->sample_counter = p->short_limit*2;
- p->start_c = 0;
- }
- }
-}
-
-/** 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) {
- 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);
- }
-
- /* 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]);
-}
-
-static void rtlsdr_callback(unsigned char *buf, uint32_t len, void *ctx) {
- 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);
- } else {
- 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;
- case OOK_MANCHESTER:
- manchester_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);
- }
- }
- }
-}
-
-int main(int argc, char **argv) {
-#ifndef _WIN32
- struct sigaction sigact;
-#endif
- char *filename = NULL;
- char *test_mode_file = NULL;
- FILE *test_mode;
- int n_read;
- int r, 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;
- uint32_t out_block_size = DEFAULT_BUF_LENGTH;
- int device_count;
- char vendor[256], product[256], serial[256];
-
- demod = malloc(sizeof (struct dm_state));
- memset(demod, 0, sizeof (struct dm_state));
-
- /* initialize tables */
- calc_squares();
-
- demod->f_buf = &demod->filter_buffer[FILTER_ORDER];
- demod->decimation_level = DEFAULT_DECIMATION_LEVEL;
- 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) {
- 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;
- }
- }
-
- /* 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, &acurite_th);
- register_protocol(demod, &acurite_rain_gauge);
- register_protocol(demod, &lacrossetx);
- register_protocol(demod, &oregon_scientific);
- register_protocol(demod, &newkaku);
- register_protocol(demod, &alectov1);
- register_protocol(demod, &intertechno);
- register_protocol(demod, &mebus433);
- register_protocol(demod, &wh2);
-
- if (argc <= optind - 1) {
- usage();
- } else {
- filename = argv[optind];
- }
-
- 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");
- fprintf(stderr,
- "Minimal length: %u\n", MINIMAL_BUF_LENGTH);
- fprintf(stderr,
- "Maximal length: %u\n", MAXIMAL_BUF_LENGTH);
- out_block_size = DEFAULT_BUF_LENGTH;
- }
-
- buffer = malloc(out_block_size * sizeof (uint8_t));
-
- device_count = rtlsdr_get_device_count();
- if (!device_count) {
- fprintf(stderr, "No supported devices found.\n");
- if (!test_mode_file)
- exit(1);
- }
-
- 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);
- 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);
-
- demod->save_data = 1;
- if (!filename) {
- demod->save_data = 0;
- } else if (strcmp(filename, "-") == 0) { /* Write samples to stdout */
- demod->file = stdout;
-#ifdef _WIN32
- _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;
- }
- }
-
- if (demod->signal_grabber)
- demod->sg_buf = malloc(SIGNAL_GRABBER_BUFFER);
-
- if (test_mode_file) {
- 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);
- i++;
- }
- //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]);
- exit(0);
- }
-
- /* Reset endpoint before we start reading from it (mandatory) */
- r = rtlsdr_reset_buffer(dev);
- if (r < 0)
- fprintf(stderr, "WARNING: Failed to reset buffers.\n");
-
- if (sync_mode) {
- fprintf(stderr, "Reading samples in sync mode...\n");
- while (!do_exit) {
- r = rtlsdr_read_sync(dev, buffer, out_block_size, &n_read);
- if (r < 0) {
- fprintf(stderr, "WARNING: sync read failed.\n");
- break;
- }
-
- 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) {
- fprintf(stderr, "Short write, samples lost, exiting!\n");
- break;
- }
-
- if ((uint32_t) n_read < out_block_size) {
- fprintf(stderr, "Short read, samples lost, exiting!\n");
- break;
- }
-
- if (bytes_to_read > 0)
- bytes_to_read -= n_read;
- }
- } else {
- if (frequencies == 0) {
- frequency[0] = DEFAULT_FREQUENCY;
- frequencies = 1;
- } else {
- time(&rawtime_old);
- }
- 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;
- frequency_current++;
- if (frequency_current > frequencies - 1) frequency_current = 0;
- }
- }
-
- if (do_exit)
- fprintf(stderr, "\nUser cancel, exiting...\n");
- else
- fprintf(stderr, "\nLibrary error %d, exiting...\n", r);
-
- if (demod->file && (demod->file != stdout))
- fclose(demod->file);
-
- 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);
-
- rtlsdr_close(dev);
- free(buffer);
-out:
- return r >= 0 ? r : -r;
-}
projects / rtl-433.git / commitdiff