main.cpp

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#include "data_all.h" 
#include "OptionParser.h"
#include "phoenix_protocol_buffer.h"
 


OptionParser createOptionParser(){
        OptionParser parser(true, __PROGRAM_VERSION__);
        parser.setExampleLongOption("phoenix_protocol_buffer_print --input=stream.pzmq --nbmessage=100");
        parser.setExampleShortOption("phoenix_protocol_buffer_print -i stream.pzmq -n 100");
        
        parser.addOption("input", "i", OptionType::FILENAME, true, false, "input stream recorded with phoenix_debug_zmq which contains protocol buffer data to be printed");
        parser.addOption("nbmessage", "n", "1", OptionType::UINT, "Number of messages to be printed");
        parser.addOption("firstmessage", "f", "0", OptionType::UINT, "Index of the first message to be printed");
        parser.addOption("offset", "o", "0", OptionType::UINT, "offset of sub-field to be printed");
        return parser;
}


bool printProtocolBufferMessage(const PPath & inputFile, size_t nbMessage, size_t firstMessageIndex, size_t offset){
        std::vector<std::vector<char> > vecMessage;
        if(!data_load(inputFile, vecMessage)){
                std::cerr << "printProtocolBufferMessage : cannot load file '"<<inputFile<<"'" << std::endl;
                return false;
        }
        std::cout << "Nb Messages loaded = " << vecMessage.size() << std::endl;
        size_t nbMessageToPrint(std::min(vecMessage.size(), firstMessageIndex + nbMessage));
        for(size_t i(firstMessageIndex); i < nbMessageToPrint; ++i){
                std::vector<char> & message = vecMessage[i];
                std::cout << "["<<i<<", size = "<<message.size()<<"] ";
                phoenix_printFieldMessage(message.data(), message.size(), offset);
        }
        return true;
}
 
int main(int argc, char** argv){
        OptionParser parser = createOptionParser();
        parser.parseArgument(argc, argv);
        const OptionMode & defaultMode = parser.getDefaultMode();
        
        PPath fileName("");
        defaultMode.getValue(fileName, "input");
        size_t nbMessage(1lu), firstMessageIndex(0lu);
        defaultMode.getValue(nbMessage, "nbmessage");
        defaultMode.getValue(firstMessageIndex, "firstmessage");
        size_t offset(0lu);
        defaultMode.getValue(offset, "offset");
        
        bool b(printProtocolBufferMessage(fileName, nbMessage, firstMessageIndex, offset));
        return b - 1;
}