mirror of
https://github.com/eclipse/upm.git
synced 2025-07-02 01:41:12 +03:00
WFS: Added water flow sensor without grove dependency
Signed-off-by: Sisinty Sasmita Patra <sisinty.s.patra@intel.com>
This commit is contained in:

committed by
Noel Eck

parent
81e4eb07bf
commit
b65908ea24
5
src/wfs/CMakeLists.txt
Normal file
5
src/wfs/CMakeLists.txt
Normal file
@ -0,0 +1,5 @@
|
||||
upm_mixed_module_init (NAME wfs
|
||||
DESCRIPTION "UPM WFS Module"
|
||||
CPP_HDR wfs.hpp
|
||||
CPP_SRC wfs.cxx
|
||||
REQUIRES mraa)
|
21
src/wfs/javaupm_wfs.i
Normal file
21
src/wfs/javaupm_wfs.i
Normal file
@ -0,0 +1,21 @@
|
||||
%module javaupm_wfs
|
||||
%include "../upm.i"
|
||||
|
||||
%ignore flowISR;
|
||||
|
||||
%{
|
||||
#include "wfs.hpp"
|
||||
%}
|
||||
|
||||
%include "wfs.hpp"
|
||||
|
||||
%pragma(java) jniclasscode=%{
|
||||
static {
|
||||
try {
|
||||
System.loadLibrary("javaupm_wfs");
|
||||
} catch (UnsatisfiedLinkError e) {
|
||||
System.err.println("Native code library failed to load. \n" + e);
|
||||
System.exit(1);
|
||||
}
|
||||
}
|
||||
%}
|
8
src/wfs/jsupm_wfs.i
Normal file
8
src/wfs/jsupm_wfs.i
Normal file
@ -0,0 +1,8 @@
|
||||
%module jsupm_wfs
|
||||
%include "../upm.i"
|
||||
|
||||
%{
|
||||
#include "wfs.hpp"
|
||||
%}
|
||||
|
||||
%include "wfs.hpp"
|
11
src/wfs/pyupm_wfs.i
Normal file
11
src/wfs/pyupm_wfs.i
Normal file
@ -0,0 +1,11 @@
|
||||
// Include doxygen-generated documentation
|
||||
%include "pyupm_doxy2swig.i"
|
||||
%module pyupm_wfs
|
||||
%include "../upm.i"
|
||||
|
||||
%feature("autodoc", "3");
|
||||
|
||||
%include "wfs.hpp"
|
||||
%{
|
||||
#include "wfs.hpp"
|
||||
%}
|
124
src/wfs/wfs.cxx
Normal file
124
src/wfs/wfs.cxx
Normal file
@ -0,0 +1,124 @@
|
||||
/*
|
||||
* Author: Jon Trulson <jtrulson@ics.com>
|
||||
* Copyright (c) 2015 Intel Corporation.
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining
|
||||
* a copy of this software and associated documentation files (the
|
||||
* "Software"), to deal in the Software without restriction, including
|
||||
* without limitation the rights to use, copy, modify, merge, publish,
|
||||
* distribute, sublicense, and/or sell copies of the Software, and to
|
||||
* permit persons to whom the Software is furnished to do so, subject to
|
||||
* the following conditions:
|
||||
*
|
||||
* The above copyright notice and this permission notice shall be
|
||||
* included in all copies or substantial portions of the Software.
|
||||
*
|
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
||||
* LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
|
||||
#include <iostream>
|
||||
#include <string>
|
||||
#include <stdexcept>
|
||||
|
||||
#include "wfs.hpp"
|
||||
|
||||
using namespace upm;
|
||||
using namespace std;
|
||||
|
||||
WFS::WFS(int pin)
|
||||
{
|
||||
if ( !(m_gpio = mraa_gpio_init(pin)) )
|
||||
{
|
||||
throw std::invalid_argument(std::string(__FUNCTION__) +
|
||||
": mraa_gpio_init() failed, invalid pin?");
|
||||
return;
|
||||
}
|
||||
|
||||
mraa_gpio_dir(m_gpio, MRAA_GPIO_IN);
|
||||
|
||||
initClock();
|
||||
m_flowCounter = 0;
|
||||
m_isrInstalled = false;
|
||||
}
|
||||
|
||||
WFS::~WFS()
|
||||
{
|
||||
if (m_isrInstalled)
|
||||
stopFlowCounter();
|
||||
|
||||
mraa_gpio_close(m_gpio);
|
||||
}
|
||||
|
||||
void WFS::initClock()
|
||||
{
|
||||
gettimeofday(&m_startTime, NULL);
|
||||
}
|
||||
|
||||
uint32_t WFS::getMillis()
|
||||
{
|
||||
struct timeval elapsed, now;
|
||||
uint32_t elapse;
|
||||
|
||||
// get current time
|
||||
gettimeofday(&now, NULL);
|
||||
|
||||
// compute the delta since m_startTime
|
||||
if( (elapsed.tv_usec = now.tv_usec - m_startTime.tv_usec) < 0 )
|
||||
{
|
||||
elapsed.tv_usec += 1000000;
|
||||
elapsed.tv_sec = now.tv_sec - m_startTime.tv_sec - 1;
|
||||
}
|
||||
else
|
||||
{
|
||||
elapsed.tv_sec = now.tv_sec - m_startTime.tv_sec;
|
||||
}
|
||||
|
||||
elapse = (uint32_t)((elapsed.tv_sec * 1000) + (elapsed.tv_usec / 1000));
|
||||
|
||||
// never return 0
|
||||
if (elapse == 0)
|
||||
elapse = 1;
|
||||
|
||||
return elapse;
|
||||
}
|
||||
|
||||
void WFS::startFlowCounter()
|
||||
{
|
||||
initClock();
|
||||
// install our interrupt handler
|
||||
mraa_gpio_isr(m_gpio, MRAA_GPIO_EDGE_RISING,
|
||||
&flowISR, this);
|
||||
|
||||
m_isrInstalled = true;
|
||||
}
|
||||
|
||||
void WFS::stopFlowCounter()
|
||||
{
|
||||
// remove the interrupt handler
|
||||
mraa_gpio_isr_exit(m_gpio);
|
||||
|
||||
m_isrInstalled = false;
|
||||
}
|
||||
|
||||
void WFS::flowISR(void *ctx)
|
||||
{
|
||||
upm::WFS *This = (upm::WFS *)ctx;
|
||||
This->m_flowCounter++;
|
||||
}
|
||||
|
||||
float WFS::flowRate()
|
||||
{
|
||||
uint32_t millis = getMillis();
|
||||
uint32_t flow = flowCounter();
|
||||
|
||||
// 7.5 comes from the seeedstudio page, see the confusing datasheet :)
|
||||
float flowRate = (float(flow) * 7.5) / ((float(millis) / 1000.0) * 60.0);
|
||||
|
||||
return flowRate;
|
||||
}
|
140
src/wfs/wfs.hpp
Normal file
140
src/wfs/wfs.hpp
Normal file
@ -0,0 +1,140 @@
|
||||
/*
|
||||
* Author: Jon Trulson <jtrulson@ics.com>
|
||||
* Copyright (c) 2015 Intel Corporation.
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining
|
||||
* a copy of this software and associated documentation files (the
|
||||
* "Software"), to deal in the Software without restriction, including
|
||||
* without limitation the rights to use, copy, modify, merge, publish,
|
||||
* distribute, sublicense, and/or sell copies of the Software, and to
|
||||
* permit persons to whom the Software is furnished to do so, subject to
|
||||
* the following conditions:
|
||||
*
|
||||
* The above copyright notice and this permission notice shall be
|
||||
* included in all copies or substantial portions of the Software.
|
||||
*
|
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
||||
* LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
#pragma once
|
||||
|
||||
#include <string>
|
||||
#include <stdint.h>
|
||||
#include <sys/time.h>
|
||||
#include <mraa/gpio.h>
|
||||
|
||||
namespace upm {
|
||||
|
||||
/**
|
||||
* @brief Grove Water Flow Sensor library
|
||||
* @defgroup wfs libupm-wfs
|
||||
* @ingroup seeed gpio liquid eak
|
||||
*/
|
||||
|
||||
/**
|
||||
* @library wfs
|
||||
* @sensor wfs
|
||||
* @comname Grove Water Flow Sensor
|
||||
* @type liquid
|
||||
* @man seeed
|
||||
* @web http://www.seeedstudio.com/wiki/index.php?title=G1/2_Water_Flow_sensor
|
||||
* @con gpio
|
||||
* @kit eak
|
||||
|
||||
* @brief API for the Grove Water Flow Sensor
|
||||
*
|
||||
* This sensor is used to measure water flow in liters per
|
||||
* minute (LPM). It incorporates a Hall Effect sensor. The UPM module
|
||||
* defines an interrupt routine to be triggered on each low pulse,
|
||||
* keeping count. This device requires a 10K pull-up resistor for
|
||||
* the signal line (yellow wire). There is a schematic diagram on
|
||||
* the SeeedStudio site (3/2015):
|
||||
* http://www.seeedstudio.com/wiki/index.php?title=G1/2_Water_Flow_sensor
|
||||
*
|
||||
* However, be careful when wiring this up - the schematic appears to
|
||||
* have a bug in it: the lower left connection of the signal line
|
||||
* (yellow) to Vcc (red) should not be there. The sensor can work
|
||||
* with this connection, but probably not for very long.
|
||||
*
|
||||
* @image html wfs.jpg
|
||||
* @snippet wfs.cxx Interesting
|
||||
*/
|
||||
class WFS {
|
||||
public:
|
||||
/**
|
||||
* Grove Water Flow sensor constructor
|
||||
*
|
||||
* @param pin Digital pin to use
|
||||
*/
|
||||
WFS(int pin);
|
||||
/**
|
||||
* WFS destructor
|
||||
*/
|
||||
~WFS();
|
||||
/**
|
||||
* Returns the number of milliseconds elapsed since initClock()
|
||||
* was last called.
|
||||
*
|
||||
* @return Elapsed milliseconds
|
||||
*/
|
||||
uint32_t getMillis();
|
||||
|
||||
/**
|
||||
* Resets the clock
|
||||
*
|
||||
*/
|
||||
void initClock();
|
||||
|
||||
/**
|
||||
* Resets the flow counter to 0. The flow counter should be
|
||||
* stopped via stopFlowCounter() prior to calling this function.
|
||||
*
|
||||
*/
|
||||
void clearFlowCounter() { m_flowCounter = 0; };
|
||||
|
||||
/**
|
||||
* Starts the flow counter
|
||||
*
|
||||
*/
|
||||
void startFlowCounter();
|
||||
|
||||
/**
|
||||
* Stops the flow counter
|
||||
*
|
||||
*/
|
||||
void stopFlowCounter();
|
||||
|
||||
/**
|
||||
* Gets the flow counter
|
||||
*
|
||||
* @return Flow counter
|
||||
*/
|
||||
uint32_t flowCounter() { return m_flowCounter; };
|
||||
|
||||
/**
|
||||
* Computes the flow rate in liters per minute (LPM)
|
||||
*
|
||||
* @return Computed flow rate
|
||||
*/
|
||||
float flowRate();
|
||||
|
||||
private:
|
||||
/**
|
||||
* Flow interrupt service routine (ISR)
|
||||
*
|
||||
*/
|
||||
static void flowISR(void *ctx);
|
||||
|
||||
volatile uint32_t m_flowCounter;
|
||||
struct timeval m_startTime;
|
||||
mraa_gpio_context m_gpio;
|
||||
bool m_isrInstalled;
|
||||
};
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user