Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Class Members | Related Pages

Freiburg::Msgque Class Reference

wrapper for libFreiburg 2.0 More...

Inheritance diagram for Freiburg::Msgque:

TestFbg Perf Test List of all members.

Public Types

enum  ErrorE { OK = 'O', ERROR = 'E', WARNING = 'W', CONTINUE }
 collection for the different states of an error More...
enum  AllocE { DYNAMIC, STATIC }
 allocation style used for the data-segment in BufferS. More...
enum  TypeE {
  BIN = 'B', STR = 'C', INT2 = '2', INT4 = '4',
  INT8 = '8', FLT4 = 'F', FLT8 = 'D', PTR = 'P',
  LST = 'L', RET = 'R', STA = 'S'
}
 a enum for all data types supported by BufferS. More...

Public Member Functions

 Msgque (Msgque parent, string name, string server, string[] argv)
string MqErrorGetString (IntPtr error)
Stat StatCreate (string name, int count, short level)
Timer TimerCreate ()

Protected Types

enum  RetCodeE { OK = 'O', WARNING = 'W', ERROR = 'E' }

Protected Member Functions

delegate int HdlF (CsS *msgque, IntPtr data)
void MqErrorReset (IntPtr error)
ErrorE MqErrorGetStatus (IntPtr error)
void ErrorCheck (ErrorE err)
ErrorE MqServiceCreate (IntPtr msgque, string token, HdlF handle, IntPtr data)
Object readO (IntPtr read)
Object[] ReadLR (IntPtr read)
Object[] ReadL (IntPtr read)
Object[] CallService (string token, int timeout, params Object[] argv)
void CallService (string token, params Object[] argv)
void SendReturnAndWait (RetCodeE retcode, int retnum, string rettext, params Object[] argv)

Protected Attributes

CsS * msgque
 CsS.

Private Types

enum  CsE { CLIENT, SERVER }
 the private CsS type member More...

Private Member Functions

IntPtr MqBufferLCreate (IntPtr error, int num)
void MqBufferLAppendHC (IntPtr lbuf, string option, string value)
void MqBufferLAppendH2 (IntPtr lbuf, string option, short value)
void MqBufferLAppendHP (IntPtr lbuf, string option, IntPtr value)
void MqBufferLAppend (IntPtr lbuf, IntPtr value)
IntPtr MqBufferCreateC (IntPtr error, string value)
ErrorE MqCreate (IntPtr context, IntPtr argv, CsS **msgqueP)
void MqDelete (CsS **msgqueP)
void MqBufferLLog (IntPtr lbuf, string name)
 ~Msgque ()
ErrorE MqServiceDelete (IntPtr msgque, string token)
void MqSendSTART (IntPtr send)
void MqSendC (IntPtr send, string val)
void MqSend2 (IntPtr send, short val)
void MqSend4 (IntPtr send, int val)
void MqSend8 (IntPtr send, long val)
void MqSendF (IntPtr send, float val)
void MqSendD (IntPtr send, double val)
void MqSendB (IntPtr send, byte[] val, int size)
void MqSend_LST_START (IntPtr send)
void MqSend_LST_END (IntPtr send)
void sendO (Object oObj)
void sendL (Object[] oList)
ErrorE MqReadU (IntPtr read, BufferS **buf)
void MqReadCreate_LST_Ref (IntPtr read, BufferS *buf, IntPtr *readRef)
void MqReadDelete_LST_Ref (IntPtr *read)
void MqReadRET (IntPtr read, BufferS *buf)
int MqReadGetNumItems (IntPtr read)
ErrorE MqSendEND_AND_WAIT (IntPtr send, string token, int timeout)
char MqReadGetReturnCode (IntPtr read)
short MqReadGetReturnNum (IntPtr read)
void MqReadCreate_RET_Ref (IntPtr read, IntPtr *readRef)
void MqReadDelete_RET_Ref (IntPtr *readRef)
ErrorE MqSendEND (IntPtr send, string token, IntPtr trans)
void MqSend_RET_OK (IntPtr send)
void MqSend_RET_START (IntPtr send, RetCodeE retcode, int retnum)
ErrorE MqSendEND_RETR (IntPtr send, IntPtr trans)

Private Attributes

const string MSGQUE_DLL = "libFreiburg20"

Static Private Attributes

Mutex createMutex = new Mutex()
Mutex deleteMutex = new Mutex()

Detailed Description

wrapper for libFreiburg 2.0

Definition at line 129 of file csLibFbg.cs.

Member Enumeration Documentation

enum Freiburg::Msgque::AllocE
 

allocation style used for the data-segment in BufferS.

Shadow libFreiburg Object:
MqAllocE
Enumeration values:
DYNAMIC  dynamic allocation (e.g. MqSysMalloc, ...)
STATIC  static allocation (e.g. fixed size string)

Definition at line 269 of file csLibFbg.cs.

enum Freiburg::Msgque::CsE [private]
 

the private CsS type member

Shadow libFreiburg Object:
MqE
Enumeration values:
CLIENT 
SERVER 

Definition at line 145 of file csLibFbg.cs.

Referenced by Msgque().

enum Freiburg::Msgque::ErrorE
 

collection for the different states of an error

Shadow libFreiburg Object:
MqErrorE
Enumeration values:
OK 
ERROR 
WARNING 
CONTINUE 

Definition at line 141 of file csLibFbg.cs.

Referenced by ErrorCheck(), and Msgque().

enum Freiburg::Msgque::RetCodeE [protected]
 

Enumeration values:
OK 
WARNING 
ERROR 

Definition at line 536 of file csLibFbg.cs.

Referenced by SendReturnAndWait().

enum Freiburg::Msgque::TypeE
 

a enum for all data types supported by BufferS.

Shadow libFreiburg Object:
MqTypeE
Enumeration values:
BIN  'B' = binary type
STR  'C' = string type (e.g. with a \0 at the end)
INT2  '2' = 2 byte integer type
INT4  '4' = 4 byte integer type
INT8  '8' = 8 byte integer type
FLT4  'F' = 4 byte float type
FLT8  'D' = 8 byte float type
PTR  'P' = 4 byte pointer type
LST  'L' = list object type
RET  'R' = return object type
STA  'S' = statistical object type

Definition at line 276 of file csLibFbg.cs.

Referenced by readO().

Constructor & Destructor Documentation

Freiburg::Msgque::Msgque (  Msgque  parent,
string  name,
string  server,
string[]  argv
)  [inline]
 

Definition at line 195 of file csLibFbg.cs.

References createMutex, CsE, ErrorCheck(), ErrorE, MqBufferCreateC(), MqBufferLAppend(), MqBufferLAppendH2(), MqBufferLAppendHC(), MqBufferLAppendHP(), MqBufferLCreate(), MqCreate(), and msgque.

Freiburg::Msgque::~Msgque (   )  [inline, private]
 

Definition at line 223 of file csLibFbg.cs.

References deleteMutex, MqDelete(), and msgque.

Member Function Documentation

void Freiburg::Msgque::CallService (  string  token,
params Object[]  argv
)  [inline, protected]
 

Definition at line 525 of file csLibFbg.cs.

References ErrorCheck(), MqSendEND(), MqSendSTART(), msgque, Freiburg::Msgque::CsS::send, and sendL().

Object [] Freiburg::Msgque::CallService (  string  token,
int  timeout,
params Object[]  argv
)  [inline, protected]
 

Definition at line 486 of file csLibFbg.cs.

References Freiburg::Msgque::BufferS::data, ErrorCheck(), MqReadCreate_RET_Ref(), MqReadDelete_RET_Ref(), MqReadGetReturnCode(), MqReadGetReturnNum(), MqSendEND_AND_WAIT(), MqSendSTART(), msgque, Freiburg::Msgque::CsS::name, Freiburg::Msgque::CsS::read, ReadL(), ReadLR(), Freiburg::Msgque::CsS::send, and sendL().

Referenced by TestFbg::Echo2(), TestFbg::Echo4(), TestFbg::Echo8(), TestFbg::EchoD(), TestFbg::EchoF(), TestFbg::EchoL(), TestFbg::EchoP(), TestFbg::EchoS(), TestFbg::EchoSleep(), TestFbg::EchoU(), TestFbg::EchoUSleep(), TestFbg::Err1(), TestFbg::Err2(), TestFbg::Option(), TestFbg::Param(), TestFbg::Test(), and TestFbg::War2().

void Freiburg::Msgque::ErrorCheck (  ErrorE  err  )  [inline, protected]
 

Definition at line 244 of file csLibFbg.cs.

References Freiburg::Msgque::CsS::error, ErrorE, MqErrorGetString(), and msgque.

Referenced by CallService(), Msgque(), readO(), sendO(), and SendReturnAndWait().

delegate int Freiburg::Msgque::HdlF (  CsS *  msgque,
IntPtr  data
)  [protected]
 

IntPtr Freiburg::Msgque::MqBufferCreateC (  IntPtr  error,
string  value
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqBufferLAppend (  IntPtr  lbuf,
IntPtr  value
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqBufferLAppendH2 (  IntPtr  lbuf,
string  option,
short  value
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqBufferLAppendHC (  IntPtr  lbuf,
string  option,
string  value
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqBufferLAppendHP (  IntPtr  lbuf,
string  option,
IntPtr  value
)  [private]
 

Referenced by Msgque().

IntPtr Freiburg::Msgque::MqBufferLCreate (  IntPtr  error,
int  num
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqBufferLLog (  IntPtr  lbuf,
string  name
)  [private]
 

ErrorE Freiburg::Msgque::MqCreate (  IntPtr  context,
IntPtr  argv,
CsS **  msgqueP
)  [private]
 

Referenced by Msgque().

void Freiburg::Msgque::MqDelete (  CsS **  msgqueP  )  [private]
 

Referenced by ~Msgque().

ErrorE Freiburg::Msgque::MqErrorGetStatus (  IntPtr  error  )  [protected]
 

Referenced by sendO().

string Freiburg::Msgque::MqErrorGetString (  IntPtr  error  ) 
 

Referenced by ErrorCheck().

void Freiburg::Msgque::MqErrorReset (  IntPtr  error  )  [protected]
 

Referenced by sendO().

void Freiburg::Msgque::MqReadCreate_LST_Ref (  IntPtr  read,
BufferS *  buf,
IntPtr *  readRef
)  [private]
 

Referenced by readO().

void Freiburg::Msgque::MqReadCreate_RET_Ref (  IntPtr  read,
IntPtr *  readRef
)  [private]
 

Referenced by CallService().

void Freiburg::Msgque::MqReadDelete_LST_Ref (  IntPtr *  read  )  [private]
 

Referenced by readO().

void Freiburg::Msgque::MqReadDelete_RET_Ref (  IntPtr *  readRef  )  [private]
 

Referenced by CallService().

int Freiburg::Msgque::MqReadGetNumItems (  IntPtr  read  )  [private]
 

Referenced by ReadL(), and ReadLR().

char Freiburg::Msgque::MqReadGetReturnCode (  IntPtr  read  )  [private]
 

Referenced by CallService().

short Freiburg::Msgque::MqReadGetReturnNum (  IntPtr  read  )  [private]
 

Referenced by CallService().

void Freiburg::Msgque::MqReadRET (  IntPtr  read,
BufferS *  buf
)  [private]
 

Referenced by readO().

ErrorE Freiburg::Msgque::MqReadU (  IntPtr  read,
BufferS **  buf
)  [private]
 

Referenced by readO().

void Freiburg::Msgque::MqSend2 (  IntPtr  send,
short  val
)  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSend4 (  IntPtr  send,
int  val
)  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSend8 (  IntPtr  send,
long  val
)  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSend_LST_END (  IntPtr  send  )  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSend_LST_START (  IntPtr  send  )  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSend_RET_OK (  IntPtr  send  )  [private]
 

Referenced by SendReturnAndWait().

void Freiburg::Msgque::MqSend_RET_START (  IntPtr  send,
RetCodeE  retcode,
int  retnum
)  [private]
 

Referenced by SendReturnAndWait().

void Freiburg::Msgque::MqSendB (  IntPtr  send,
byte[]  val,
int  size
)  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSendC (  IntPtr  send,
string  val
)  [private]
 

Referenced by sendO(), and SendReturnAndWait().

void Freiburg::Msgque::MqSendD (  IntPtr  send,
double  val
)  [private]
 

Referenced by sendO().

ErrorE Freiburg::Msgque::MqSendEND (  IntPtr  send,
string  token,
IntPtr  trans
)  [private]
 

Referenced by CallService().

ErrorE Freiburg::Msgque::MqSendEND_AND_WAIT (  IntPtr  send,
string  token,
int  timeout
)  [private]
 

Referenced by CallService().

ErrorE Freiburg::Msgque::MqSendEND_RETR (  IntPtr  send,
IntPtr  trans
)  [private]
 

Referenced by SendReturnAndWait().

void Freiburg::Msgque::MqSendF (  IntPtr  send,
float  val
)  [private]
 

Referenced by sendO().

void Freiburg::Msgque::MqSendSTART (  IntPtr  send  )  [private]
 

Referenced by CallService(), and SendReturnAndWait().

ErrorE Freiburg::Msgque::MqServiceCreate (  IntPtr  msgque,
string  token,
HdlF  handle,
IntPtr  data
)  [protected]
 

ErrorE Freiburg::Msgque::MqServiceDelete (  IntPtr  msgque,
string  token
)  [private]
 

Object [] Freiburg::Msgque::ReadL (  IntPtr  read  )  [inline, protected]
 

Definition at line 462 of file csLibFbg.cs.

References MqReadGetNumItems(), and readO().

Referenced by CallService(), and readO().

Object [] Freiburg::Msgque::ReadLR (  IntPtr  read  )  [inline, protected]
 

Definition at line 452 of file csLibFbg.cs.

References MqReadGetNumItems(), and readO().

Referenced by CallService().

Object Freiburg::Msgque::readO (  IntPtr  read  )  [inline, protected]
 

Definition at line 411 of file csLibFbg.cs.

References Freiburg::Msgque::BufferU::B, Freiburg::Msgque::BufferU::C, Freiburg::Msgque::BufferS::cur, Freiburg::Msgque::BufferS::cursize, Freiburg::Msgque::BufferU::D, ErrorCheck(), Freiburg::Msgque::BufferU::F, Freiburg::Msgque::BufferU::I2, Freiburg::Msgque::BufferU::I4, Freiburg::Msgque::BufferU::I8, MqReadCreate_LST_Ref(), MqReadDelete_LST_Ref(), MqReadRET(), MqReadU(), Freiburg::Msgque::BufferU::P, ReadL(), Freiburg::Msgque::BufferS::type, and TypeE.

Referenced by ReadL(), and ReadLR().

void Freiburg::Msgque::sendL (  Object[]  oList  )  [inline, private]
 

Definition at line 395 of file csLibFbg.cs.

References sendO().

Referenced by CallService(), sendO(), and SendReturnAndWait().

void Freiburg::Msgque::sendO (  Object  oObj  )  [inline, private]
 

Definition at line 358 of file csLibFbg.cs.

References Freiburg::Msgque::CsS::binary, Freiburg::Msgque::CsS::error, ErrorCheck(), MqErrorGetStatus(), MqErrorReset(), MqSend2(), MqSend4(), MqSend8(), MqSend_LST_END(), MqSend_LST_START(), MqSendB(), MqSendC(), MqSendD(), MqSendF(), msgque, Freiburg::Msgque::CsS::send, and sendL().

Referenced by sendL().

void Freiburg::Msgque::SendReturnAndWait (  RetCodeE  retcode,
int  retnum,
string  rettext,
params Object[]  argv
)  [inline, protected]
 

Definition at line 545 of file csLibFbg.cs.

References ErrorCheck(), MqSend_RET_OK(), MqSend_RET_START(), MqSendC(), MqSendEND_RETR(), MqSendSTART(), msgque, RetCodeE, Freiburg::Msgque::CsS::send, and sendL().

Stat Freiburg::Msgque::StatCreate (  string  name,
int  count,
short  level
)  [inline]
 

Definition at line 562 of file csLibFbg.cs.

References msgque.

Referenced by Perf::Main().

Timer Freiburg::Msgque::TimerCreate (   )  [inline]
 

Definition at line 567 of file csLibFbg.cs.

References msgque.

Referenced by Perf::Main().

Member Data Documentation

Mutex Freiburg::Msgque::createMutex = new Mutex() [static, private]
 

Definition at line 133 of file csLibFbg.cs.

Referenced by Msgque().

Mutex Freiburg::Msgque::deleteMutex = new Mutex() [static, private]
 

Definition at line 134 of file csLibFbg.cs.

Referenced by ~Msgque().

CsS* Freiburg::Msgque::msgque [protected]
 

CsS.

Definition at line 167 of file csLibFbg.cs.

Referenced by CallService(), ErrorCheck(), Msgque(), sendO(), SendReturnAndWait(), StatCreate(), TimerCreate(), and ~Msgque().

const string Freiburg::Msgque::MSGQUE_DLL = "libFreiburg20" [private]
 

Definition at line 131 of file csLibFbg.cs.

The documentation for this class was generated from the following file:
Generated on Tue Nov 23 16:15:59 2004 for csharpFreiburg by  doxygen 1.3.8-20040928