hcaltb::HcalTBSourcePositionDataUnpacker Class Reference

#include <HcalTBSourcePositionDataUnpacker.h>

Public Member Functions
	HcalTBSourcePositionDataUnpacker (void)
void	unpack (const FEDRawData &raw, HcalSourcePositionData &hspd) const

Detailed Description

Definition at line 9 of file HcalTBSourcePositionDataUnpacker.h.

Constructor & Destructor Documentation

hcaltb::HcalTBSourcePositionDataUnpacker::HcalTBSourcePositionDataUnpacker ( void  )

inline

Definition at line 11 of file HcalTBSourcePositionDataUnpacker.h.

References unpack().

{}

Member Function Documentation

void hcaltb::HcalTBSourcePositionDataUnpacker::unpack	(	const FEDRawData &	raw,
		HcalSourcePositionData &	hspd
	)		const

Definition at line 27 of file HcalTBSourcePositionDataUnpacker.cc.

References gather_cfg::cout, FEDRawData::data(), Exception, mps_fire::i, xdaqSourcePositionDataFormat::key_length, xdaqSourcePositionDataFormat::n_doubles, xdaqSourcePositionDataFormat::n_strings, HcalSourcePositionData::set(), FEDRawData::size(), xdaqSourcePositionDataFormat::start_of_data, and xdaqSourcePositionDataFormat::string_value_length.

Referenced by HcalTBSourcePositionDataUnpacker(), and HcalTBObjectUnpacker::produce().

                                                                                                         {
    if (raw.size() < 3 * 8) {
      throw cms::Exception("Missing Data") << "No data in the source position data block";
    }

    const struct xdaqSourcePositionDataFormat *sp = (const struct xdaqSourcePositionDataFormat *)(raw.data());

    if (raw.size() < sizeof(xdaqSourcePositionDataFormat)) {
      throw cms::Exception("DataFormatError", "Fragment too small");
    }

    map<string, double> sp_dblmap;
    map<string, string> sp_strmap;

#ifdef DEBUG
    cout << "#doubles = " << sp->n_doubles << endl;
    ;
    cout << "#strings = " << sp->n_strings << endl;
    cout << "key_length = " << sp->key_length << endl;
    cout << "string_value_length = " << sp->string_value_length << endl;
#endif

    // List of doubles:
    const char *keyptr = &sp->start_of_data;
    const double *valptr = (const double *)(&sp->start_of_data + sp->n_doubles * sp->key_length);

    for (int i = 0; i < sp->n_doubles; i++) {
#ifdef DEBUG
      cout << keyptr << " = " << *valptr << endl;
#endif
      sp_dblmap[keyptr] = *valptr;
      keyptr += sp->key_length;
      valptr++;
    }

    // List of strings:
    keyptr = (const char *)valptr;
    const char *strptr = (keyptr + sp->n_strings * sp->key_length);

    for (int i = 0; i < sp->n_strings; i++) {
#ifdef DEBUG
      cout << keyptr << " = " << strptr << endl;
#endif
      sp_strmap[keyptr] = strptr;
      keyptr += sp->key_length;
      strptr += sp->string_value_length;
    }

    // Now fill the input objects:
    hspd.set(sp_dblmap["MESSAGE"],        //double message_counter
             sp_dblmap["TIME_STAMP1"],    //double timestamp1_sec
             sp_dblmap["TIME_STAMP2"],    //double timestamp1_usec
             -1,                          //double timestamp2_sec
             -1,                          //double timestamp2_usec
             sp_dblmap["STATUS"],         //double status
             sp_dblmap["INDEX"],          //double index_counter
             sp_dblmap["REEL"],           //double reel_counter
             sp_dblmap["MOTOR_CURRENT"],  //double motor_current
             sp_dblmap["MOTOR_VOLTAGE"],  //double motor_voltage
             -1,                          //double driver_id
             -1,                          //double source_id
             sp_strmap["CURRENT_TUBENAME_FROM_COORD"],
             sp_strmap["INDEX_DESCRIPTION"],
             sp_strmap["LAST_COMMAND"],
             sp_strmap["MESSAGE"]);
  }