MqCall_cc.cc

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME "MqCall_cc.cc"
 
/*****************************************************************************/
/*                                                                           */
/*                                context                                    */
/*                                                                           */
/*****************************************************************************/
 
#include <iostream>
#include <exception>
#include <typeinfo>
 
#include "private_cc.hh"
 
namespace ccmqmsgque {
 
  MK_CBP MqServiceCallbackC::Create (
    MK_RT_ARGS 
    MQ_CTX const context, 
    MqServiceCallbackC* const copy, 
    MqContextC *self
  ) {
    MqContextC * tgt = MqContextC::MqContextC_GetSelf(context);
    MK_CBP ret = NULL;
    switch (copy->type) {
      case PC_MqEventIF: {
        auto val = dynamic_cast<MqEventIF*const>(tgt);
        ret = new MqServiceCallbackC(PC_MqEventIF, val, self);
        if (!val) context->setup.Event.fCall = NULL;
        break;
      }
      case PC_MqBgErrorIF: {
        auto val = dynamic_cast<MqBgErrorIF*const>(tgt); 
        ret = new MqServiceCallbackC(PC_MqBgErrorIF, val, self);
        if (!val) context->setup.BgError.fCall = NULL;
        break;
      }
      case PC_MqServerSetupIF: {
        auto val = dynamic_cast<MqServerSetupIF*const>(tgt);
        ret = new MqServiceCallbackC(PC_MqBgErrorIF, val, self);
        if (!val) context->setup.ServerSetup.fCall = NULL;
        break;
      }
      case PC_MqServerCleanupIF: {
        auto val = dynamic_cast<MqServerCleanupIF*const>(tgt);
        ret = new MqServiceCallbackC(PC_MqBgErrorIF, val, self);
        if (!val) context->setup.ServerCleanup.fCall = NULL;
        break;
      }
      default:
        XE(context)
        break;
    }
    return ret;
  }
 
  void MqServiceCallbackC::Free ( MQ_SERVICE_FREE_ARGS )
  {
    delete static_cast<MqServiceCallbackC*>(*dataP);
    *dataP = NULL;
  }
 
  void MqServiceCallbackC::Copy ( MQ_SERVICE_COPY_ARGS )
  {
    *dataP = MqServiceCallbackC::Create(MK_RT_CALL mqctx, static_cast<struct MqServiceCallbackC *> (*dataP));
  }
 
  enum MkErrorE MqServiceCallbackC::Call ( MQ_SERVICE_CALL_ARGS )
  {
    MQ_SERVICE_CALL_CHECK;
 
    MqServiceCallbackC * const pdata = static_cast<struct MqServiceCallbackC * const> (__data__);
    MqContextC *self = MqContextC::MqContextC_GetSelf(mqctx);
    try {
 
      switch (pdata->type) {
        case PC_MqTokenICB:
          (self->*pdata->call.Callback)();
          break;
        case PC_MqTokenCCB:
          (*pdata->call.StaticCallback)(self);
          break;
        case PC_MqServiceIF:
          (pdata->call.Service->Service)(self);
          break;
        case PC_MqEventIF:
          (pdata->call.Event->Event)();
          break;
        case PC_MqBgErrorIF:
          (pdata->call.BgError->BgError)();
          break;
        case PC_MqServerSetupIF:
          (pdata->call.ServerSetup->ServerSetup)();
          break;
        case PC_MqServerCleanupIF:
          (pdata->call.ServerCleanup->ServerCleanup)();
          break;
      }
 
    } catch (const MkExceptionC& ex) {
      MkExceptionC::Catch(mqctx,ex);
    } catch (const std::exception& ex) {
      MkExceptionC::Catch(mqctx,ex);
    } catch (...) {
      // http://groups.google.com/group/comp.programming.threads/browse_thread/thread/652bcf186fbbf697/f63757846514e5e5
      throw;
    }
 
    // everything is OK
    return MkErrorStack_0E_Check();
  }
 
} // END - namespace "ccmqmsgque"