// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------

#ifndef MbsLmdStruct_H
#define MbsLmdStruct_H

#include <stdio.h>

#include "sMbs.h"

#ifndef FILEONLY
#include "f_stccomm.h"
#endif

#define LMD__SUCCESS        0
#define LMD__FAILURE        1
#define LMD__CLOSE_ERR      3
#define GETLMD__NOFILE      2
#define GETLMD__NOLMDFILE   4
#define GETLMD__EOFILE      5
#define GETLMD__NOMORE      6
#define GETLMD__NOBUFFER    7
#define GETLMD__TOOBIG      8
#define GETLMD__OUTOF_RANGE 9
#define GETLMD__SIZE_ERROR 10
#define LMD__TIMEOUT        50
#define PUTLMD__FILE_EXIST  101
#define PUTLMD__TOOBIG      102
#define PUTLMD__OPEN_ERR    103
#define PUTLMD__EXCEED      104
#define PORT__TRANS         6000
#define PORT__STREAM        6002

typedef struct
{
  FILE    *fFile;         /* file descripter or server No.    */
  int16_t *pBuffer;       /* pointer to internal buffer  */
  uint32_t iBufferWords;  /* internal buffer size      */
  uint32_t iLeftWords;    /* left words in buffer */
  uint32_t iInternHeader; /* has intern allocated header buffer */
  uint32_t iInternBuffer; /* has intern allocated buffer */
  uint32_t iElements;     /* events since open     */
  uint64_t iBytes;        /* bytes since open  */
  char     cFile[512];    /* channel name */
  uint32_t iSwap;
  uint32_t iVerbose;
  char     *cHeader;      /* header data buffer */
  uint32_t *pOffset4;     /* offset table */
  lmdoff_t *pOffset8;     /* long offset table */
  lmdoff_t oTableOffset;  /* greater zero when Long offset in file */
  uint32_t iOffsetSize;   /* Offset size, 4 or 8 [bytes] */
  uint32_t iOffsetEntries;/* offset table length */
  sMbsFileHeader *pMbsFileHeader;
  sMbsHeader     *pMbsHeader;
  struct s_tcpcomm  *pTCP;
  uint32_t iTCP;
  uint32_t iPort;
  uint32_t iTcpTimeout;
  uint32_t iTCPowner;
} sLmdControl;

sLmdControl * fLmdAllocateControl(void);
uint32_t   fLmdPutOpen(sLmdControl*,char*,sMbsFileHeader*,uint32_t,uint32_t,uint32_t,uint32_t);
uint32_t   fLmdPutElement(sLmdControl*,sMbsHeader*);
uint32_t   fLmdPutBuffer(sLmdControl*, sMbsHeader*,uint32_t);
uint32_t   fLmdPutClose(sLmdControl*);
#ifndef FILEONLY
uint32_t   fLmdInitMbs(sLmdControl*,char*,uint32_t,uint32_t,uint32_t,uint32_t,uint32_t);
uint32_t   fLmdGetMbsBuffer(sLmdControl*,sMbsBufferHeader*,uint32_t,uint32_t*,uint32_t*);
uint32_t   fLmdGetMbsEvent(sLmdControl*,sMbsHeader**);
uint32_t   fLmdCloseMbs(sLmdControl*);
#endif
uint32_t   fLmdGetOpen(sLmdControl*,char*,sMbsFileHeader*,uint32_t,uint32_t);
uint32_t   fLmdGetBuffer(sLmdControl*,sMbsHeader*,uint32_t,uint32_t*,uint32_t*);
int32_t    fLmdReadBuffer(sLmdControl*,char*,uint32_t);
uint32_t   fLmdGetElement(sLmdControl*,uint32_t,sMbsHeader**);
uint32_t   fLmdGetClose(sLmdControl*);
void       fLmdPrintBufferHeader(uint32_t,sMbsBufferHeader*);
void       fLmdPrintFileHeader(uint32_t,sMbsFileHeader*);
void       fLmdPrintHeader(uint32_t,sMbsHeader*);
void       fLmdPrintEvent(uint32_t,sMbsEventHeader*);
void       fLmdPrintControl(uint32_t,sLmdControl*);
void       fLmdVerbose(sLmdControl*,uint32_t);
void       fLmdSwap4(uint32_t*,uint32_t);
void       fLmdSwap8(uint64_t*,uint32_t);
void       fLmdSetWrittenEndian(sLmdControl *,uint32_t);
uint32_t   fLmdGetWrittenEndian(sLmdControl *);
uint32_t   fLmdGetSwap(sLmdControl *);
uint64_t   fLmdGetBytesWritten(sLmdControl *);

#endif