Filter4.cc

Go to the documentation of this file.

 
/* LABEL-START */
 
#include  "debug_mq.h"
#include  "LibMqMsgque_cc.hh"
 
/* LABEL-END */
 
#define META_CONTEXT_S hdl
 
#include <queue>
#include <stdexcept>
#include <stdlib.h>
#include <stdio.h>
 
using namespace std;
using namespace ccmqmsgque;
 
class Filter4 : public MqContextC, public MqServerSetupIF, public MqServerCleanupIF, public MqEventIF, public MqServiceIF {
  public:
    // Factory Constructor
    Filter4(MK_TYP const typ=NULL, MqContextC* tmpl=NULL) : MqContextC(typ, tmpl) {
      ConfigSetIgnoreExit(true);
    }
 
  private:
    queue<MqDumpC*> itms;
    FILE *FH = NULL;
    MK_I32 errCnt = 0;
 
    void ErrorWrite () {
      auto err = ErrorFORMAT();
      fprintf(FH, "ERROR: %s\n", err->GetText());
      fflush(FH);
      err->Reset ();
    }
 
    void Event () {
      // check if data is available
      if (itms.empty()) {
        // no data available, set error-code to CONTINUE
        ErrorFORMAT()->SetCONTINUE();
      } else {
        // extract the first (oldest) item from the store
        MqDumpC *dump = itms.front();
        // an item is available, try to send the data
        try {
          // get the filter-context
          MqContextC *ftr = SlaveGetFilter();
          // send BDY data to the link-target
          try {
            ProxyForward(ftr, dump);
          } catch (const MkExceptionC& ex) {
            if (++errCnt <= 3) {
              return;
            } else {
              throw;
            }
          } catch (...) {
            throw;
          }
        } catch (const exception& e) {
          ErrorCatch (e);
          // on error write the error-text and "forget" the data
          ErrorWrite ();
        }
        // delete the data, will contine with next item
        delete dump;
        itms.pop();
        errCnt = 0;
      }
    }
 
    void Service (MqContextC * ctx) {
      auto dump = MqDumpC::Export(ctx);
      itms.push (dump);
      SendRETURN();
    }
 
    void LOGF () {
      // get the "link-target"
      MqContextC *ftr = SlaveGetFilter();
      // check "Ident" from the "link-target"
      if (strcmp(ftr->ConfigGetPrefix(),"Filter4-1") == 0) {
        // if "Ident" is "transFilter" send the data to the "link-target"
        ProxyForward(ftr);
      } else {
        // if "Ident" is not "transFilter" use the data as file-name to open a file 
        FH = fopen (ReadSTR(), "a");
      }
      SendRETURN();
    }
 
    // [SlaveGetMaster_example]
    void WRIT () {
      Filter4 *ctx = static_cast<Filter4*>(SlaveGetMaster());
      fprintf (ctx->FH, "%s\n", ReadSTR());
      fflush (ctx->FH);
      SendRETURN();
    }
    // [SlaveGetMaster_example]
 
    void EXIT () {
      ErrorFORMAT()->SetEXIT();
    }
 
    void ServerCleanup() {
      while (!itms.empty()) {
        delete itms.front();
        itms.pop();
      }
      if (FH != NULL) fclose (FH);
    }
 
    void ServerSetup() {
      MqContextC *ftr = static_cast<MqContextC*>(SlaveGetFilter());
      // SERVER: listen on every token (+ALL)
      ServiceCreate ("LOGF", MqServiceICB(&Filter4::LOGF));
      ServiceCreate ("EXIT", MqServiceICB(&Filter4::EXIT));
      ServiceCreate ("+ALL", this);
      ftr->ServiceCreate ("WRIT", MqServiceICB(&Filter4::WRIT));
      FH = NULL;
    }
};
 
/*****************************************************************************/
/*                                                                           */
/*                               M A I N                                     */
/*                                                                           */
/*****************************************************************************/
 
// [initial_example]
int MK_CDECL main (int argc, MK_STRN argv[])
{
  MqMsgque::CcMqSetup();
  MqFactoryCT<Filter4>::Add("Filter4")->Initial();
 
  Filter4 filter;
  try {
    filter.Init();
    filter.LinkCreate (MkBufferListC {argc, argv});
    filter.ProcessEvent (MQ_WAIT_FOREVER);
  } catch (const exception& e) {
    filter.ErrorCatch(e);
  }
  return filter.Exit();
}
// [initial_example]