WireCell::Img::JsonBlobSetSink Class Reference

#include <JsonBlobSetSink.h>

Inheritance diagram for WireCell::Img::JsonBlobSetSink:

Public Member Functions
	JsonBlobSetSink ()
virtual	~JsonBlobSetSink ()
virtual void	configure (const WireCell::Configuration &cfg)
	Accept a configuration. More...
virtual WireCell::Configuration	default_configuration () const
	Optional, override to return a hard-coded default configuration. More...
virtual bool	operator() (const IBlobSet::pointer &bs)
	The calling signature: More...
Public Member Functions inherited from WireCell::IBlobSetSink
virtual	~IBlobSetSink ()
virtual std::string	signature ()
Public Member Functions inherited from WireCell::ISinkNode< IBlobSet >
virtual	~ISinkNode ()
virtual bool	operator() (const boost::any &anyin)
virtual std::vector< std::string >	input_types ()
Public Member Functions inherited from WireCell::ISinkNodeBase
virtual	~ISinkNodeBase ()
virtual NodeCategory	category ()
	Return the behavior category type. More...
Public Member Functions inherited from WireCell::INode
virtual	~INode ()
virtual int	concurrency ()
virtual std::vector< std::string >	output_types ()
virtual void	reset ()
Public Member Functions inherited from WireCell::IComponent< INode >
virtual	~IComponent ()
Public Member Functions inherited from WireCell::Interface
virtual	~Interface ()
Public Member Functions inherited from WireCell::IConfigurable
virtual	~IConfigurable ()
Public Member Functions inherited from WireCell::IComponent< IConfigurable >
virtual	~IComponent ()

Private Attributes
double	m_drift_speed
std::string	m_filename
int	m_face
Log::logptr_t	l

Additional Inherited Members
Public Types inherited from WireCell::ISinkNode< IBlobSet >
typedef IBlobSet	input_type
typedef std::shared_ptr< const IBlobSet >	input_pointer
Public Types inherited from WireCell::ISinkNodeBase
typedef std::shared_ptr< ISinkNodeBase >	pointer
Public Types inherited from WireCell::INode
enum	NodeCategory {   unknown, sourceNode, sinkNode, functionNode,   queuedoutNode, joinNode, splitNode, faninNode,   fanoutNode, multioutNode, hydraNode }
Public Types inherited from WireCell::IComponent< INode >
typedef std::shared_ptr< INode >	pointer
	Access subclass facet by pointer. More...
typedef std::vector< pointer >	vector
	Vector of shared pointers. More...
Public Types inherited from WireCell::Interface
typedef std::shared_ptr< Interface >	pointer
Public Types inherited from WireCell::IComponent< IConfigurable >
typedef std::shared_ptr< IConfigurable >	pointer
	Access subclass facet by pointer. More...
typedef std::vector< pointer >	vector
	Vector of shared pointers. More...

Detailed Description

Definition at line 13 of file JsonBlobSetSink.h.

Constructor & Destructor Documentation

Img::JsonBlobSetSink::JsonBlobSetSink

(

)

Definition at line 15 of file JsonBlobSetSink.cxx.

    : m_drift_speed(1.6*units::mm/units::us)
    , m_filename("blobs-%02d.json")
    , m_face(0)
    , l(Log::logger("io"))
{
}

Img::JsonBlobSetSink::~JsonBlobSetSink ( )

virtual

Definition at line 22 of file JsonBlobSetSink.cxx.

{
}

Member Function Documentation

void Img::JsonBlobSetSink::configure ( const WireCell::Configuration &  config )

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 27 of file JsonBlobSetSink.cxx.

{
    m_face = get(cfg, "face", m_face);
    m_drift_speed = get(cfg, "drift_speed", m_drift_speed);
    m_filename = get(cfg, "filename", m_filename);
}

WireCell::Configuration Img::JsonBlobSetSink::default_configuration ( ) const

virtual

Optional, override to return a hard-coded default configuration.

Reimplemented from WireCell::IConfigurable.

Definition at line 34 of file JsonBlobSetSink.cxx.

{
    Configuration cfg;

    // File name for output files.  A "%d" will be filled in with blob
    // set ident number.
    cfg["filename"] = m_filename;
    // Set to -1 to not apply any face filter, otherwise only consider matching face number
    cfg["face"] = m_face;
    cfg["drift_speed"] = m_drift_speed;
    return cfg;
}

bool Img::JsonBlobSetSink::operator() ( const IBlobSet::pointer &  in )

virtual

The calling signature:

Implements WireCell::ISinkNode< IBlobSet >.

Definition at line 47 of file JsonBlobSetSink.cxx.

{
    if (!bs) {
        l->debug("JsonBlobSetSink: eos");
        return true;
    }

    const auto& blobs = bs->blobs();
    if (blobs.empty()) {
        l->info("JsonBlobSetSink: no blobs");
        return true;
    }

    auto slice = blobs[0]->slice();
    auto frame = slice->frame();
    const double start = slice->start();
    const double time = frame->time();
    const double x = (start-time)*m_drift_speed;

    l->debug("JsonBlobSetSink: frame:{}, slice:{} set:{} time:{} ms, start={} ms x:{} nblobs:{}",
             frame->ident(), slice->ident(), bs->ident(),
             time/units::ms, start/units::ms,
             x,  blobs.size());

    Json::Value jblobs = Json::arrayValue;


    for (const auto& iblob: blobs) {
        if (m_face >= 0 and m_face != iblob->face()->ident()) {
            continue;           // filter
        }
        const auto& coords = iblob->face()->raygrid();
        const auto& blob = iblob->shape();
        Json::Value jcorners = Json::arrayValue;        
        for (const auto& corner : blob.corners()) {
            Json::Value jcorner = Json::arrayValue;
            auto pt = coords.ray_crossing(corner.first, corner.second);
            jcorner.append(x);
            jcorner.append(pt.y());
            jcorner.append(pt.z());
            jcorners.append(jcorner);
        }
        Json::Value jblob;
        jblob["points"] = jcorners;
        jblob["values"]["charge"] = iblob->value();
        jblob["values"]["uncert"] = iblob->uncertainty();
        jblob["values"]["ident"] = iblob->ident();
        jblob["values"]["inset"] = jblobs.size();

        jblobs.append(jblob);
    }


    Json::Value top;

    top["blobs"] = jblobs;

    std::string fname = m_filename;
    if (m_filename.find("%") != std::string::npos) {
        fname = String::format(m_filename, bs->ident());
    }
    std::ofstream fstr(fname);
    if (!fstr) {
        l->error("Failed to open for writing: %s", fname);
        return false;
    }
    fstr << top;


    return true;    
}

Member Data Documentation

Log::logptr_t WireCell::Img::JsonBlobSetSink::l

private

Definition at line 29 of file JsonBlobSetSink.h.

double WireCell::Img::JsonBlobSetSink::m_drift_speed

private

Definition at line 26 of file JsonBlobSetSink.h.

int WireCell::Img::JsonBlobSetSink::m_face

private

Definition at line 28 of file JsonBlobSetSink.h.

std::string WireCell::Img::JsonBlobSetSink::m_filename

private

Definition at line 27 of file JsonBlobSetSink.h.

---

The documentation for this class was generated from the following files:

• wire-cell-build/img/inc/WireCellImg/JsonBlobSetSink.h
• wire-cell-build/img/src/JsonBlobSetSink.cxx