You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
131 lines
4.3 KiB
C
131 lines
4.3 KiB
C
1 year ago
|
/***************************************************************************
|
||
|
* Copyright (C) gempa GmbH *
|
||
|
* All rights reserved. *
|
||
|
* Contact: gempa GmbH (seiscomp-dev@gempa.de) *
|
||
|
* *
|
||
|
* GNU Affero General Public License Usage *
|
||
|
* This file may be used under the terms of the GNU Affero *
|
||
|
* Public License version 3.0 as published by the Free Software Foundation *
|
||
|
* and appearing in the file LICENSE included in the packaging of this *
|
||
|
* file. Please review the following information to ensure the GNU Affero *
|
||
|
* Public License version 3.0 requirements will be met: *
|
||
|
* https://www.gnu.org/licenses/agpl-3.0.html. *
|
||
|
* *
|
||
|
* Other Usage *
|
||
|
* Alternatively, this file may be used in accordance with the terms and *
|
||
|
* conditions contained in a signed written agreement between you and *
|
||
|
* gempa GmbH. *
|
||
|
***************************************************************************/
|
||
|
|
||
|
|
||
|
#ifndef SEISCOMP_PROCESSING_DETECTOR_H
|
||
|
#define SEISCOMP_PROCESSING_DETECTOR_H
|
||
|
|
||
|
|
||
|
#include <seiscomp/processing/waveformprocessor.h>
|
||
|
#include <boost/function.hpp>
|
||
|
#include <seiscomp/client.h>
|
||
|
|
||
|
|
||
|
namespace Seiscomp {
|
||
|
namespace Processing {
|
||
|
|
||
|
|
||
|
DEFINE_SMARTPOINTER(Detector);
|
||
|
|
||
|
class SC_SYSTEM_CLIENT_API Detector : public WaveformProcessor {
|
||
|
DECLARE_SC_CLASS(Detector)
|
||
|
|
||
|
public:
|
||
|
typedef boost::function<void (const Detector*, const Record*, const Core::Time&)> PublishFunc;
|
||
|
|
||
|
public:
|
||
|
Detector(double initTime);
|
||
|
|
||
|
public:
|
||
|
void setPublishFunction(const PublishFunc& func);
|
||
|
|
||
|
void setOffset(const Core::TimeSpan& ofs);
|
||
|
Core::TimeSpan offset() const;
|
||
|
|
||
|
void setDeadTimeAfterPick(const Core::TimeSpan &dt);
|
||
|
Core::TimeSpan deadTimeAfterPick() const;
|
||
|
|
||
|
virtual const std::string &methodID() const = 0;
|
||
|
|
||
|
virtual void reset() override;
|
||
|
|
||
|
protected:
|
||
|
virtual bool emitPick(const Record* rec, const Core::Time& t);
|
||
|
|
||
|
private:
|
||
|
PublishFunc _func;
|
||
|
Core::Time _lastPick;
|
||
|
Core::TimeSpan _offset;
|
||
|
Core::TimeSpan _deadTimeAfterPick;
|
||
|
};
|
||
|
|
||
|
|
||
|
|
||
|
DEFINE_SMARTPOINTER(SimpleDetector);
|
||
|
|
||
|
class SC_SYSTEM_CLIENT_API SimpleDetector : public Detector {
|
||
|
DECLARE_SC_CLASS(SimpleDetector)
|
||
|
|
||
|
public:
|
||
|
SimpleDetector(double deadTime = 0.0);
|
||
|
SimpleDetector(double on, double off, double deadTime);
|
||
|
|
||
|
public:
|
||
|
void setDeadTime(double deadTime) { _initTime = deadTime; }
|
||
|
void setThresholds(double on, double off);
|
||
|
|
||
|
//! Reimplemented method to analyse the filtered datastream.
|
||
|
//! It just checks whether a sample in filteredData exceeds the
|
||
|
//! 'on' threshold and calls validateOn or goes below the 'off'
|
||
|
//! threshold and calls validateOff.
|
||
|
void process(const Record *record, const DoubleArray &filteredData) override;
|
||
|
|
||
|
void reset() override;
|
||
|
|
||
|
protected:
|
||
|
bool isOn() const { return _triggered; }
|
||
|
bool isOff() const { return !_triggered; }
|
||
|
|
||
|
//! This methods returns whether a pick has been emitted after
|
||
|
//! setting the triggering state to 'on' or not
|
||
|
//! This value is only valid after the trigger state has
|
||
|
//! switched from 'off' to 'on'.
|
||
|
bool emittedPick() const { return _pickEmitted; }
|
||
|
|
||
|
//! This method gets called whenever the 'on' threshold is reached.
|
||
|
//! A derived class can return false for some reason to disable
|
||
|
//! setting the trigger state to true.
|
||
|
//!
|
||
|
//! When false is returned the processing of the current record
|
||
|
//! will be finished immediatly.
|
||
|
virtual bool validateOn(const Record *record, size_t &i, const DoubleArray &filteredData);
|
||
|
|
||
|
//! This method gets called whenever a filtered sample falls below
|
||
|
//! the 'off' threshold. A derived class can return false to disable
|
||
|
//! setting the trigger state to false. When false is returned the
|
||
|
//! processing of the current record will be finished immediatly.
|
||
|
virtual bool validateOff(const Record *record, size_t i, const DoubleArray &filteredData);
|
||
|
|
||
|
virtual const std::string &methodID() const override;
|
||
|
|
||
|
|
||
|
private:
|
||
|
bool _triggered;
|
||
|
bool _pickEmitted;
|
||
|
double _thresholdOn;
|
||
|
double _thresholdOff;
|
||
|
};
|
||
|
|
||
|
|
||
|
}
|
||
|
}
|
||
|
|
||
|
|
||
|
#endif
|