MqContextC_ReadApi_Atom_RB_API

MqContextC - read a single-data-item outof a read-data-package … More...

Collaboration diagram for MqContextC_ReadApi_Atom_RB_API:

Functions
static OT_ProcRet	rbmqmsgque_MqContextC_ReadALL (MqContextC_ARGS)
	Ruby: MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?) → C-API get a temporary MkBufferListC from all data in the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadBFL (MqContextC_ARGS)
	Ruby: MkBufferListC ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadBUF (MqContextC_ARGS)
	Ruby: MkBufferC ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadBIN (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadBIN → C-API generic function to read an MK_BIN object from the read-data-package object …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadBOL (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadBinaryR (MqContextC_ARGS)
	Ruby: binary ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadDBL (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadFLT (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadHDL (MqContextC_ARGS)
	Ruby: MK_HDL ctx.ReadHDL() → C-API read the handle from the read-data-package
static OT_ProcRet	rbmqmsgque_MqContextC_ReadI16 (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadI32 (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadI64 (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadI8 (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadLONG (MqContextC_ARGS)
	Ruby: long ctx.ReadLONG() → C-API read the long native object from the read-data-package
static OT_ProcRet	rbmqmsgque_MqContextC_ReadSTR (MqContextC_ARGS)
	Ruby: doc_mq_rb_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
static OT_ProcRet	rbmqmsgque_MqContextC_ReadStringR (MqContextC_ARGS)
	Ruby: string ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
OT_ProcRet	rbmqmsgque_MqContextC_ReadLIST (MqContextC_ARGS)
	Ruby: [list...] ctx.ReadLIST() → C-API get all arguments as native list …
OT_ProcRet	rbmqmsgque_MqContextC_ReadNEXT (MqContextC_ARGS)
	Ruby: obj ctx.ReadNEXT() → C-API get the next argument as native object …

Detailed Description

MqContextC - read a single-data-item outof a read-data-package …

Function Documentation

rbmqmsgque_MqContextC_ReadALL()

static OT_ProcRet rbmqmsgque_MqContextC_ReadALL ( MqContextC_ARGS )

static

Ruby: MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?) → C-API
get a temporary MkBufferListC from all data in the read-data-package …

Definition at line 1625 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_VARARGS(0,1,ReadALL_doc);
  MkBufferListCreateTLS_T(val_inout,10);
  OT_CHECK_OPTIONAL(OT_CHECK_BFL (val_inout,MK_NULL_YES))
  OT_CHECK_NOARGS;
  MkErrorC_Check(hdl,MqReadALL (hdl, &val_inout));
  OT_retObj_SET_BFL(val_inout);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadBFL()

static OT_ProcRet rbmqmsgque_MqContextC_ReadBFL ( MqContextC_ARGS )

static

Ruby: MkBufferListC ctx.ReadBFL() → C-API
get a temporary MkBufferListC from next list-item in the read-data-package …

Definition at line 1640 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadBFL_doc);
  OT_CHECK_NOARGS;
  MK_BFL val_out;
  MkErrorC_Check(hdl,MqReadBFL (hdl, &val_out));
  OT_retObj_SET_BFL(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadBIN()

static OT_ProcRet rbmqmsgque_MqContextC_ReadBIN ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadBIN → C-API
generic function to read an MK_BIN object from the read-data-package object …

Definition at line 1666 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadBIN_doc);
  OT_CHECK_NOARGS;
  MkBinaryR val_out;
  MkErrorC_Check(hdl,MqReadBIN (hdl, &val_out));
  MkBinaryR retVal = val_out;
  OT_retObj_SET(OT_GET__ME_REF_MkBinaryR(retVal));
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadBinaryR()

static OT_ProcRet rbmqmsgque_MqContextC_ReadBinaryR ( MqContextC_ARGS )

static

Ruby: binary ctx.ReadBinaryR() → C-API
read a MkBinaryR from the read-data-package …

Definition at line 1691 of file MqContextC_rb.c.

                                                               {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadBinaryR_doc);
  OT_CHECK_NOARGS;
  MkBinaryR val_out;
  MkErrorC_Check(hdl,MqReadBinaryR (hdl, &val_out));
  MkBinaryR retVal = val_out;
  OT_retObj_SET(OT_GET__ME_REF_MkBinaryR(retVal));
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadBOL()

static OT_ProcRet rbmqmsgque_MqContextC_ReadBOL ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadBOL → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1679 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadBOL_doc);
  OT_CHECK_NOARGS;
  MK_BOL val_out;
  MkErrorC_Check(hdl,MqReadBOL (hdl, &val_out));
  OT_retObj_SET_BOL(val_out == 1);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadBUF()

static OT_ProcRet rbmqmsgque_MqContextC_ReadBUF ( MqContextC_ARGS )

static

Ruby: MkBufferC ctx.ReadBUF() → C-API
get a temporary MkBufferC from the read-data-package …

Definition at line 1652 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadBUF_doc);
  OT_CHECK_NOARGS;
  MK_BUF val_out;
  MkErrorC_Check(hdl,MqReadBUF (hdl, &val_out));
  OT_retObj_SET_BUF(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadDBL()

static OT_ProcRet rbmqmsgque_MqContextC_ReadDBL ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadDBL → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1704 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadDBL_doc);
  OT_CHECK_NOARGS;
  MK_DBL val_out;
  MkErrorC_Check(hdl,MqReadDBL (hdl, &val_out));
  OT_retObj_SET_DBL(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadFLT()

static OT_ProcRet rbmqmsgque_MqContextC_ReadFLT ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadFLT → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1716 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadFLT_doc);
  OT_CHECK_NOARGS;
  MK_FLT val_out;
  MkErrorC_Check(hdl,MqReadFLT (hdl, &val_out));
  OT_retObj_SET_FLT(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadHDL()

static OT_ProcRet rbmqmsgque_MqContextC_ReadHDL ( MqContextC_ARGS )

static

Ruby: MK_HDL ctx.ReadHDL() → C-API
read the handle from the read-data-package

Definition at line 1728 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadHDL_doc);
  OT_CHECK_NOARGS;
  MK_HDL val_out;
  MkErrorC_Check(hdl,MqReadHDL (hdl, &val_out));
  OT_retObj_SET_HDL(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadI16()

static OT_ProcRet rbmqmsgque_MqContextC_ReadI16 ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadI16 → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1740 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadI16_doc);
  OT_CHECK_NOARGS;
  MK_I16 val_out;
  MkErrorC_Check(hdl,MqReadI16 (hdl, &val_out));
  OT_retObj_SET_I16(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadI32()

static OT_ProcRet rbmqmsgque_MqContextC_ReadI32 ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadI32 → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1752 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadI32_doc);
  OT_CHECK_NOARGS;
  MK_I32 val_out;
  MkErrorC_Check(hdl,MqReadI32 (hdl, &val_out));
  OT_retObj_SET_I32(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadI64()

static OT_ProcRet rbmqmsgque_MqContextC_ReadI64 ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadI64 → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1764 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadI64_doc);
  OT_CHECK_NOARGS;
  MK_I64 val_out;
  MkErrorC_Check(hdl,MqReadI64 (hdl, &val_out));
  OT_retObj_SET_I64(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadI8()

static OT_ProcRet rbmqmsgque_MqContextC_ReadI8 ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadI8 → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1776 of file MqContextC_rb.c.

                                                          {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadI8_doc);
  OT_CHECK_NOARGS;
  MK_I8 val_out;
  MkErrorC_Check(hdl,MqReadI8 (hdl, &val_out));
  OT_retObj_SET_I8(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadLIST()

OT_ProcRet rbmqmsgque_MqContextC_ReadLIST

(

MqContextC_ARGS

)

Ruby: [list...] ctx.ReadLIST() → C-API
get all arguments as native list …

Definition at line 17 of file MqContextC_ReadLIST_lng.h.

                                                     {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadLIST_doc);
  OT_CHECK_NOARGS;
  OT_retObj_SET_List;
  OT_OBJ_T RET = OT_LNG_NULL;
  MK_BUF buf = NULL;
  while (MqReadItemExists(hdl)) {
    MqReadBUF (hdl, &buf);
    switch (buf->var.type) {
      case MK_I8T:  { RET = OT_TMP_I8_OBJ(MkBuf2I8(buf)); break; }
      case MK_BOLT: { RET = OT_TMP_BOL_OBJ(MkBuf2BOL(buf)); break; }
      case MK_I16T: { RET = OT_TMP_I16_OBJ(MkBuf2I16(buf)); break; }
      case MK_I32T: { RET = OT_TMP_I32_OBJ(MkBuf2I32(buf)); break; }
      case MK_FLTT: { RET = OT_TMP_FLT_OBJ(MkBuf2FLT(buf)); break; }
      case MK_I64T: { RET = OT_TMP_I64_OBJ(MkBuf2I64(buf)); break; }
      case MK_DBLT: { RET = OT_TMP_DBL_OBJ(MkBuf2DBL(buf)); break; }
      case MK_BINT: { RET = OT_TMP_BIN_OBJ(buf->storage.first.B,buf->var.cursize); break; }
      case MK_STRT: { RET = OT_TMP_STR_OBJ(buf->storage.first.C); break; }
      case MK_LSTT: {
        MK_BFL bfl = MkBufferListCreate(5);
        MkErrorC_Check(hdl,MkBufferGetBFL (buf, &bfl));
        OT_MK_CALL_0(bfl,MkBufferListC,ToList,RET);
        MkRefDecr_X(bfl);
        break;
      }
/*
      case MQ_ROUT:
      case MQ_LTRT: {
        OT_ERROR_TYPE("unable to convert an 'internal' object into a 'public' object");
        RET = OT_LNG_NULL;
      }
*/
    }
    if (RET == OT_LNG_NULL) goto error;
    OT_retObj_APPEND(RET);
  }
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadLONG()

static OT_ProcRet rbmqmsgque_MqContextC_ReadLONG ( MqContextC_ARGS )

static

Ruby: long ctx.ReadLONG() → C-API
read the long native object from the read-data-package

Definition at line 1791 of file MqContextC_rb.c.

                                                            {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadLONG_doc);
  OT_CHECK_NOARGS;
  MK_LONG val_out;
  MkErrorC_Check(hdl,MqReadLONG (hdl, &val_out));
  OT_retObj_SET_LONG(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadNEXT()

OT_ProcRet rbmqmsgque_MqContextC_ReadNEXT

(

MqContextC_ARGS

)

Ruby: obj ctx.ReadNEXT() → C-API
get the next argument as native object …

Definition at line 18 of file MqContextC_ReadNEXT_lng.h.

                                                     {
  OT_SETUP_hdl
  OT_SETUP_NOARG(ReadNEXT_doc)
  OT_CHECK_NOARGS
  OT_OBJ_T RET = OT_LNG_NULL;
  MK_BUF buf = NULL;
  MqReadBUF_E(hdl, &buf);
  switch (buf->var.type) {
    case MK_I8T: { RET = OT_TMP_I8_OBJ(MkBuf2I8(buf)); break; }
    case MK_BOLT: { RET = OT_TMP_BOL_OBJ(MkBuf2BOL(buf)); break; }
    case MK_I16T: { RET = OT_TMP_I16_OBJ(MkBuf2I16(buf)); break; }
    case MK_I32T: { RET = OT_TMP_I32_OBJ(MkBuf2I32(buf)); break; }
    case MK_FLTT: { RET = OT_TMP_FLT_OBJ(MkBuf2FLT(buf)); break; }
    case MK_I64T: { RET = OT_TMP_I64_OBJ(MkBuf2I64(buf)); break; }
    case MK_DBLT: { RET = OT_TMP_DBL_OBJ(MkBuf2DBL(buf)); break; }
    case MK_BINT: { RET = OT_TMP_BIN_OBJ(buf->storage.first.B,buf->var.cursize); break; }
    case MK_STRT: { RET = OT_TMP_STR_OBJ(buf->storage.first.C); break; }
    case MK_LSTT: {
      MK_BFL bfl = MkBufferListCreate(5);
      MkErrorC_Check(hdl,MkBufferGetBFL (buf, &bfl));
      OT_MK_CALL_0(bfl,MkBufferListC,ToList,RET);
      MkRefDecr_X(bfl);
      break;
    }
/*
    case MQ_ROUT:
    case MQ_LTRT: {
      OT_ERROR_TYPE("unable to convert an 'internal' object into a 'public' object");
      RET = OT_LNG_NULL;
    }
*/
  }
  if (RET == OT_LNG_NULL) goto error;
  OT_retObj_SET(RET);
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadSTR()

static OT_ProcRet rbmqmsgque_MqContextC_ReadSTR ( MqContextC_ARGS )

static

Ruby: doc_mq_rb_ReadSTR → C-API
read a PRIMITIVE TYPE from the read-data-package …

Definition at line 1806 of file MqContextC_rb.c.

                                                           {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadSTR_doc);
  OT_CHECK_NOARGS;
  MK_STRN val_out;
  MkErrorC_Check(hdl,MqReadSTR (hdl, &val_out));
  OT_retObj_SET_STR(val_out);
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}

rbmqmsgque_MqContextC_ReadStringR()

static OT_ProcRet rbmqmsgque_MqContextC_ReadStringR ( MqContextC_ARGS )

static

Ruby: string ctx.ReadStringR() → C-API
read a MkStringR from the read-data-package …

Definition at line 1818 of file MqContextC_rb.c.

                                                               {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadStringR_doc);
  OT_CHECK_NOARGS;
  MkStringR val_out;
  MkErrorC_Check(hdl,MqReadStringR (hdl, &val_out));
  MkStringR retVal = val_out;
  OT_retObj_SET(OT_GET__ME_REF_MkStringR(retVal));
  end: MK_UNUSED  /* LONG JUMP on error */
  OT_retObj_RETURN;
}