first factory-based version compiling, still very very preliminary

slsReceiverSoftware/Makefile

@@ -14,8 +14,10 @@ DFLAGS= -g -DDACS_INT  -DSLS_RECEIVER_UDP_FUNCTIONS
 INCLUDES?= -I. -Iincludes -IMySocketTCP -IslsReceiver -IslsDetectorCalibration -IslsReceiver/eigerReceiver -I$(ASM) 
 #-IslsReceiverInterface
 
-SRC_CLNT= MySocketTCP/MySocketTCP.cpp slsReceiver/slsReceiver.cpp slsReceiver/slsReceiverUDPFunctions.cpp  slsReceiver/slsReceiverTCPIPInterface.cpp   slsReceiver/slsReceiverUsers.cpp 
+SRC_CLNT= MySocketTCP/MySocketTCP.cpp  slsReceiver/slsReceiver.cpp slsReceiver/UDPInterface.cpp  slsReceiver/UDPBaseImplementation.cpp slsReceiver/slsReceiverTCPIPInterface.cpp   slsReceiver/slsReceiverUsers.cpp 
+
 #slsReceiverInterface/receiverInterface.cpp
+#slsReceiver/slsReceiverUDPFunctions.cpp
 
 OBJS = $(SRC_CLNT:.cpp=.o) 
 OBJS +=  slsReceiver/eigerReceiver.o  

slsReceiverSoftware/slsReceiver/Makefile

@@ -13,7 +13,7 @@ LDFLAGRXR 		?=	-L$(LIBDIR) -lSlsReceiver -L/usr/lib64/ -lpthread
 LDFLAGRXR 		+=	-lm  -lstdc++ 
 
 
-INCLUDES	?= 	-I ../MySocketTCP  -I ../slsDetectorCalibration -I ../includes -I eigerReceiver -I . 
+INCLUDES	?= 	-I ../MySocketTCP  -I ../slsDetectorCalibration -I ../includes/ -I eigerReceiver -I . 
 SRC_CLNT	= 	main.cpp 
 
 
@@ -40,19 +40,21 @@ $(DESTDIR)/sslsReceiver: lib
 
 
 $(DESTDIR)/slsReceiver: eigerReceiver	lib
+	echo "AAAAAAAAAAAA" $(CXX)   -o $@  $(SRC_CLNT)  $(FLAGS)  $(INCLUDES) $(CLAGS) $(LIBS) $(LDFLAGRXR) -fPIC 
 	$(CXX)   -o $@  $(SRC_CLNT)  $(FLAGS)  $(INCLUDES) $(CLAGS) $(LIBS) $(LDFLAGRXR) -fPIC 
 #$(EIGERFLAGS) 	
 
 
 ifeq ($(EIGERSLS), yes)
 eigerReceiver: 
-	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiverTest.o eigerReceiver/eigerReceiverTest.cpp $(EIGERFLAGS)
-	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiver.o eigerReceiver/eigerReceiver.cpp $(EIGERFLAGS)
-	$(CXX)  eigerReceiverTest.o eigerReceiver.o   -o eigerReceiver/eigerReceiverTest $(EIGERFLAGS)
+#	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiverTest.o 	eigerReceiver/eigerReceiverTest.cpp $(EIGERFLAGS)
+#	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiver.o eigerReceiver/eigerReceiver.cpp $(EIGERFLAGS)
+#	$(CXX)  eigerReceiverTest.o eigerReceiver.o   -o eigerReceiver/eigerReceiverTest $(EIGERFLAGS)	
+	$(CXX) $(FLAGS) $(CFLAGS) $(INCLUDES) -fPIC -c -o eigerReceiver.o eigerReceiverImplementation.cpp $(EIGERFLAGS)
 else ifeq ($(ROOTSLS), yes)
 eigerReceiver: eigerReceiver/eigerReceiverDummy.cpp 
 	echo "Compiling with root"
-	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiver.o eigerReceiver/eeigerReceiverDummy.cpp $(ROOTFLAGS)
+	$(CXX) $(FLAGS) $(CFLAGS) -fPIC -c -o eigerReceiver.o eigerReceiver/eigerReceiverDummy.cpp $(ROOTFLAGS)
 else
 eigerReceiver: eigerReceiver/eigerReceiverDummy.cpp
 	$(CXX) $(FLAGS) $(CFLAGS) $(INCLUDES) -fPIC -c -o eigerReceiver.o eigerReceiver/eigerReceiverDummy.cpp 	

slsReceiverSoftware/slsReceiver/UDPBaseImplementation.h

@@ -0,0 +1,811 @@
+//#ifdef UDP_BASE_IMPLEMENTATION
+#ifndef UDP_BASE_IMPLEMENTATION_H
+#define UDP_BASE_IMPLEMENTATION_H
+/********************************************//**
+ * @file UDPBaseImplementation.h
+ * @short does all the functions for a receiver, set/get parameters, start/stop etc.
+ ***********************************************/
+
+
+#include "sls_receiver_defs.h"
+#include "receiver_defs.h"
+#include "genericSocket.h"
+#include "circularFifo.h"
+#include "singlePhotonDetector.h"
+#include "slsReceiverData.h"
+#include "moenchCommonMode.h"
+
+#include "UDPInterface.h"
+
+#ifdef MYROOT1
+#include <TTree.h>
+#include <TFile.h>
+#endif
+
+
+#include <string.h>
+#include <pthread.h>
+#include <stdio.h>
+#include <semaphore.h>
+
+
+/**
+ * @short does all the functions for a receiver, set/get parameters, start/stop etc.
+ */
+
+class UDPBaseImplementation : private virtual slsReceiverDefs, public UDPInterface {
+	
+ public:
+	/**
+	 * Constructor
+	 */
+	UDPBaseImplementation();
+
+	/**
+	 * Destructor
+	 */
+	virtual ~UDPBaseImplementation();
+
+	
+
+	/**
+	 * delete and free member parameters
+	 */
+	void deleteMembers();
+
+	/**
+	 * initialize member parameters
+	 */
+	void initializeMembers();
+
+	/**
+	 * Set receiver type
+	 * @param det detector type
+	 * Returns success or FAIL
+	 */
+	int setDetectorType(detectorType det);
+
+
+	//Frame indices and numbers caught
+	/**
+	 * Returns current Frame Index Caught for an entire  acquisition (including all scans)
+	 */
+	uint32_t getAcquisitionIndex();
+
+	/**
+	 * Returns if acquisition started
+	 */
+	bool getAcquistionStarted();
+
+	/**
+	 * Returns Frames Caught for each real time acquisition (eg. for each scan)
+	 */
+	int getFramesCaught();
+
+	/**
+	 * Returns Total Frames Caught for an entire acquisition (including all scans)
+	 */
+	int getTotalFramesCaught();
+
+	/**
+	 * Returns the frame index at start of each real time acquisition (eg. for each scan)
+	 */
+	uint32_t getStartFrameIndex();
+
+	/**
+	 * Returns current Frame Index for each real time acquisition (eg. for each scan)
+	 */
+	uint32_t getFrameIndex();
+
+	/**
+	 * Returns if measurement started
+	 */
+	bool getMeasurementStarted();
+
+	/**
+	 * Resets the Total Frames Caught
+	 * This is how the receiver differentiates between entire acquisitions
+	 * Returns 0
+	 */
+	void resetTotalFramesCaught();
+
+
+
+
+	//file parameters
+	/**
+	 * Returns File Path
+	 */
+	char* getFilePath() const;
+
+	/**
+	 * Set File Path
+	 * @param c file path
+	 */
+	char* setFilePath(const char c[]);
+
+	/**
+	 * Returns File Name
+	 */
+	char* getFileName() const;
+
+	/**
+	 * Set File Name (without frame index, file index and extension)
+	 * @param c file name
+	 */
+	char* setFileName(const char c[]);
+
+	/**
+	 * Returns File Index
+	 */
+	int getFileIndex();
+
+	/**
+	 * Set File Index
+	 * @param i file index
+	 */
+	int setFileIndex(int i);
+
+	/**
+	 * Set Frame Index Needed
+	 * @param i frame index needed
+	 */
+	int setFrameIndexNeeded(int i);
+
+	/**
+	 * Set enable file write
+	 * @param i file write enable
+	 * Returns file write enable
+	 */
+	int setEnableFileWrite(int i);
+
+	/**
+	 * Enable/disable overwrite
+	 * @param i enable
+	 * Returns enable over write
+	 */
+	int setEnableOverwrite(int i);
+
+	/**
+	* Returns file write enable
+	* 1: YES 0: NO
+	*/
+	int getEnableFileWrite() const;
+
+	/**
+	* Returns file over write enable
+	* 1: YES 0: NO
+	*/
+	int getEnableOverwrite() const;
+
+//other parameters
+
+	/**
+	 * abort acquisition with minimum damage: close open files, cleanup.
+	 * does nothing if state already is 'idle'
+	 */
+	void abort() {};
+
+	/**
+	 * Returns status of receiver: idle, running or error
+	 */
+	runStatus getStatus() const;
+
+	/**
+	 * Set detector hostname
+	 * @param c hostname
+	 */
+	void initialize(const char *detectorHostName);
+
+	 /* Returns detector hostname
+	 /returns hostname
+	  * caller needs to deallocate the returned char array.
+	  * if uninitialized, it must return NULL
+	 */
+	char *getDetectorHostname() const;
+
+	/**
+	 * Set Ethernet Interface or IP to listen to
+	 */
+	void setEthernetInterface(char* c);
+
+	/**
+	 * Set UDP Port Number
+	 */
+	void setUDPPortNo(int p);
+
+	/*
+	 * Returns number of frames to receive
+	 * This is the number of frames to expect to receiver from the detector.
+	 * The data receiver will change from running to idle when it got this number of frames
+	 */
+	int getNumberOfFrames() const;
+
+	/**
+	 * set frame number if a positive number
+	 */
+	int32_t setNumberOfFrames(int32_t fnum);
+
+	/**
+	 * Returns scan tag
+	 */
+	int getScanTag() const;
+
+	/**
+	 * set scan tag if its is a positive number
+	 */
+	int32_t setScanTag(int32_t stag);
+
+	/**
+	 * Returns the number of bits per pixel
+	 */
+	int getDynamicRange() const;
+
+	/**
+	 * set dynamic range if its is a positive number
+	 */
+	int32_t setDynamicRange(int32_t dr);
+
+	/**
+	 * Set short frame
+	 * @param i if shortframe i=1
+	 */
+	int setShortFrame(int i);
+
+	/**
+	 * Set the variable to send every nth frame to gui
+	 * or if 0,send frame only upon gui request
+	 */
+	int setNFrameToGui(int i);
+
+	/** set acquisition period if a positive number
+	 */
+	int64_t setAcquisitionPeriod(int64_t index);
+
+	/** get data compression, by saving only hits
+	 */
+	bool getDataCompression();
+
+	/** enabl data compression, by saving only hits
+	 /returns if failed
+	 */
+	int enableDataCompression(bool enable);
+
+	/**
+	 * enable 10Gbe
+	 @param enable 1 for 10Gbe or 0 for 1 Gbe, -1 to read out
+	 \returns enable for 10Gbe
+	 */
+	int enableTenGiga(int enable = -1);
+
+
+
+//other functions
+
+	/**
+	 * Returns the buffer-current frame read by receiver
+	 * @param c pointer to current file name
+	 * @param raw address of pointer, pointing to current frame to send to gui
+	 * @param fnum frame number for eiger as it is not in the packet
+	 */
+	void readFrame(char* c,char** raw, uint32_t &fnum);
+
+	/**
+	 * Closes all files
+	 * @param ithr thread index
+	 */
+	void closeFile(int ithr = -1);
+
+	/**
+	 * Starts Receiver - starts to listen for packets
+	 * @param message is the error message if there is an error
+	 * Returns success
+	 */
+	int startReceiver(char message[]);
+
+	/**
+	 * Stops Receiver - stops listening for packets
+	 * Returns success
+	 */
+	int stopReceiver();
+
+	/** set status to transmitting and
+	 * when fifo is empty later, sets status to run_finished
+	 */
+	void startReadout();
+
+	/**
+	 * shuts down the  udp sockets
+	 * \returns if success or fail
+	 */
+	int shutDownUDPSockets();
+
+private:
+	
+	/*
+	void not_implemented(string method_name){
+		std::cout << "[WARNING] Method " << method_name << " not implemented!" << std::endl;
+	};
+	*/
+	/**
+	 * Deletes all the filter objects for single photon data
+	 */
+	void deleteFilter();
+
+	/**
+	 * Constructs the filter for single photon data
+	 */
+	void setupFilter();
+
+	/**
+	 * set up fifo according to the new numjobsperthread
+	 */
+	void setupFifoStructure ();
+
+	/**
+	 * Copy frames to gui
+	 * uses semaphore for nth frame mode
+	 */
+	void copyFrameToGui(char* startbuf[], uint32_t fnum=-1, char* buf=NULL);
+
+	/**
+	 * creates udp sockets
+	 * \returns if success or fail
+	 */
+	int createUDPSockets();
+
+	/**
+	 * create listening thread
+	 * @param destroy is true to kill all threads and start again
+	 */
+	int createListeningThreads(bool destroy = false);
+
+	/**
+	 * create writer threads
+	 * @param destroy is true to kill all threads and start again
+	 */
+	int createWriterThreads(bool destroy = false);
+
+	/**
+	 * set thread priorities
+	 */
+	void setThreadPriorities();
+
+	/**
+	 * initializes variables and creates the first file
+	 * also does the startAcquisitionCallBack
+	 * \returns FAIL or OK
+	 */
+	int setupWriter();
+
+	/**
+	 * Creates new tree and file for compression
+	 * @param ithr thread number
+	 * @param iframe frame number
+	 *\returns OK for succces or FAIL for failure
+	 */
+	int createCompressionFile(int ithr, int iframe);
+
+	/**
+	 * Creates new file
+	 *\returns OK for succces or FAIL for failure
+	 */
+	int createNewFile();
+
+	/**
+	 * Static function - Thread started which listens to packets.
+	 * Called by startReceiver()
+	 * @param this_pointer pointer to this object
+	 */
+	static void* startListeningThread(void *this_pointer);
+
+	/**
+	 * Static function - Thread started which writes packets to file.
+	 * Called by startReceiver()
+	 * @param this_pointer pointer to this object
+	 */
+	static void* startWritingThread(void *this_pointer);
+
+	/**
+	 * Thread started which listens to packets.
+	 * Called by startReceiver()
+	 *
+	 */
+	int startListening();
+
+	/**
+	 * Thread started which writes packets to file.
+	 * Called by startReceiver()
+	 *
+	 */
+	int startWriting();
+
+	/**
+	 * Writing to file without compression
+	 * @param buf is the address of buffer popped out of fifo
+	 * @param numpackets is the number of packets
+	 * @param framenum current frame number
+	 */
+	void writeToFile_withoutCompression(char* buf,int numpackets, uint32_t framenum);
+
+	/**
+	 * Its called for the first packet of a scan or acquistion
+	 * Sets the startframeindices and the variables to know if acquisition started
+	 * @param ithread listening thread number
+	 */
+	void startFrameIndices(int ithread);
+
+	/**
+	 * This is called when udp socket is shut down
+	 * It pops ffff instead of packet number into fifo
+	 * to inform writers about the end of listening session
+	 * @param ithread listening thread number
+	 * @param rc number of bytes received
+	 * @param pc packet count
+	 * @param t total packets listened to
+	 */
+	void stopListening(int ithread, int rc, int &pc, int &t);
+
+	/**
+	 * When acquisition is over, this is called
+	 * @param ithread listening thread number
+	 * @param wbuffer writer buffer
+	 */
+	void stopWriting(int ithread, char* wbuffer[]);
+
+
+	/**
+	 * data compression for each fifo output
+	 * @param ithread listening thread number
+	 * @param wbuffer writer buffer
+	 * @param npackets number of packets from the fifo
+	 * @param data pointer to the next packet start
+	 * @param xmax max pixels in x direction
+	 * @param ymax max pixels in y direction
+	 * @param nf nf
+	 */
+	void handleDataCompression(int ithread, char* wbuffer[], int &npackets, char* data, int xmax, int ymax, int &nf);
+
+
+	/** structure of an eiger image header*/
+	typedef struct
+	{
+		unsigned char header_before[20];
+		unsigned char  fnum[4];
+		unsigned char  header_after[24];
+	} eiger_image_header;
+
+
+	/** structure of an eiger image header*/
+	typedef struct
+	{
+		unsigned char num1[4];
+		unsigned char num2[4];
+	} eiger_packet_header;
+
+	/** max number of listening threads */
+	const static int MAX_NUM_LISTENING_THREADS = EIGER_MAX_PORTS;
+
+	/** max number of writer threads */
+	const static int MAX_NUM_WRITER_THREADS = 15;
+
+	/** detector type */
+	detectorType myDetectorType;
+
+	/** detector hostname */
+	char detHostname[MAX_STR_LENGTH];
+
+	/** status of receiver */
+	runStatus status;
+
+	/** UDP Socket between Receiver and Detector */
+	genericSocket* udpSocket[MAX_NUM_LISTENING_THREADS];
+
+	/** Server UDP Port*/
+	int server_port[MAX_NUM_LISTENING_THREADS];
+
+	/** ethernet interface or IP to listen to */
+	char *eth;
+
+	/** max packets per file **/
+	int maxPacketsPerFile;
+
+	/** File write enable */
+	int enableFileWrite;
+
+	/** File over write enable */
+	int overwrite;
+
+	/** Complete File name */
+	char savefilename[MAX_STR_LENGTH];
+
+	/** File Name without frame index, file index and extension*/
+	char fileName[MAX_STR_LENGTH];
+
+	/** File Path */
+	char filePath[MAX_STR_LENGTH];
+
+	/** File Index */
+	int fileIndex;
+
+	/** scan tag */
+	int scanTag;
+
+	/** if frame index required in file name */
+	int frameIndexNeeded;
+
+	/* Acquisition started */
+	bool acqStarted;
+
+	/* Measurement started */
+	bool measurementStarted;
+
+	/** Frame index at start of each real time acquisition (eg. for each scan) */
+	uint32_t startFrameIndex;
+
+	/** Actual current frame index of each time acquisition (eg. for each scan) */
+	uint32_t frameIndex;
+
+	/** Frames Caught for each real time acquisition (eg. for each scan) */
+	int packetsCaught;
+
+	/** Total packets caught for an entire acquisition (including all scans) */
+	int totalPacketsCaught;
+
+	/** Pckets currently in current file, starts new file when it reaches max */
+	int packetsInFile;
+
+	/** Frame index at start of an entire acquisition (including all scans) */
+	uint32_t startAcquisitionIndex;
+
+	/** Actual current frame index of an entire acquisition (including all scans) */
+	uint32_t acquisitionIndex;
+
+	/** number of packets per frame*/
+	int packetsPerFrame;
+
+	/** frame index mask */
+	uint32_t frameIndexMask;
+
+	/** packet index mask */
+	uint32_t packetIndexMask;
+
+	/** frame index offset */
+	int frameIndexOffset;
+
+	/** acquisition period */
+	int64_t acquisitionPeriod;
+
+	/** frame number */
+	int32_t numberOfFrames;
+
+	/** dynamic range */
+	int dynamicRange;
+
+	/** short frames */
+	int shortFrame;
+
+	/** current frame number */
+	uint32_t currframenum;
+
+	/** Previous Frame number from buffer */
+	uint32_t prevframenum;
+
+	/** size of one frame */
+	int frameSize;
+
+	/** buffer size. different from framesize as we wait for one packet instead of frame for eiger */
+	int bufferSize;
+
+	/** oen buffer size */
+	int onePacketSize;
+
+	/** latest data */
+	char* latestData;
+
+	/** gui data ready */
+	int guiDataReady;
+
+	/** points to the data to send to gui */
+	char* guiData;
+
+	/** points to the filename to send to gui */
+	char* guiFileName;
+
+	/** temporary number for eiger frame number as its not included in the packet */
+	uint32_t guiFrameNumber;
+
+	/** send every nth frame to gui or only upon gui request*/
+	int nFrameToGui;
+
+	/** fifo size */
+	unsigned int fifosize;
+
+	/** number of jobs per thread for data compression */
+	int numJobsPerThread;
+
+	/** datacompression - save only hits */
+	bool dataCompression;
+
+	/** memory allocated for the buffer */
+	char *mem0[MAX_NUM_LISTENING_THREADS];
+
+	/** circular fifo to store addresses of data read */
+	CircularFifo<char>* fifo[MAX_NUM_LISTENING_THREADS];
+
+	/** circular fifo to store addresses of data already written and ready to be resued*/
+	CircularFifo<char>* fifoFree[MAX_NUM_LISTENING_THREADS];
+
+	/** Receiver buffer */
+	char *buffer[MAX_NUM_LISTENING_THREADS];
+
+	/** number of writer threads */
+	int numListeningThreads;
+
+	/** number of writer threads */
+	int numWriterThreads;
+
+	/** to know if listening and writer threads created properly */
+	int thread_started;
+
+	/** current listening thread index*/
+	int currentListeningThreadIndex;
+
+	/** current writer thread index*/
+	int currentWriterThreadIndex;
+
+	/** thread listening to packets */
+	pthread_t   listening_thread[MAX_NUM_LISTENING_THREADS];
+
+	/** thread writing packets */
+	pthread_t   writing_thread[MAX_NUM_WRITER_THREADS];
+
+	/** total frame count the listening thread has listened to */
+	int totalListeningFrameCount[MAX_NUM_LISTENING_THREADS];
+
+	/** mask showing which listening threads are running */
+	volatile uint32_t listeningthreads_mask;
+
+	/** mask showing which writer threads are running */
+	volatile uint32_t writerthreads_mask;
+
+	/** mask showing which threads  have created files*/
+	volatile uint32_t createfile_mask;
+
+	/** OK if file created was successful */
+	int ret_createfile;
+
+	/** variable used to self terminate threads waiting for semaphores */
+	int killAllListeningThreads;
+
+	/** variable used to self terminate threads waiting for semaphores */
+	int killAllWritingThreads;
+
+	/** 10Gbe enable*/
+	int tengigaEnable;
+
+
+
+
+//semaphores
+	/** semaphore to synchronize  writer and guireader threads */
+	sem_t smp;
+	/** semaphore to synchronize  listener threads */
+	sem_t listensmp[MAX_NUM_LISTENING_THREADS];
+	/** semaphore to synchronize  writer threads */
+	sem_t writersmp[MAX_NUM_WRITER_THREADS];
+
+
+//mutex
+	/** guiDataReady mutex */
+	pthread_mutex_t  dataReadyMutex;
+
+	/** mutex for status */
+	pthread_mutex_t status_mutex;
+
+	/** mutex for progress variable currframenum */
+	pthread_mutex_t progress_mutex;
+
+	/** mutex for writing data to file */
+	pthread_mutex_t write_mutex;
+
+	/** File Descriptor */
+	FILE *sfilefd;
+
+	//filter
+	singlePhotonDetector<uint16_t> *singlePhotonDet[MAX_NUM_WRITER_THREADS];
+	slsReceiverData<uint16_t>  *receiverdata[MAX_NUM_WRITER_THREADS];
+	moenchCommonMode *cmSub;
+	bool commonModeSubtractionEnable;
+
+#ifdef MYROOT1
+	/** Tree where the hits are stored */
+	TTree *myTree[MAX_NUM_WRITER_THREADS];
+
+	/** File where the tree is saved */
+	TFile *myFile[MAX_NUM_WRITER_THREADS];
+#endif
+
+
+
+	/**
+	   callback arguments are
+	   filepath
+	   filename
+	   fileindex
+	   data size
+	   
+	   return value is 
+	   0 callback takes care of open,close,write file
+	   1 callback writes file, we have to open, close it
+	   2 we open, close, write file, callback does not do anything
+
+	*/
+	int (*startAcquisitionCallBack)(char*, char*,int, int, void*);
+	void *pStartAcquisition;
+
+	/**
+	   args to acquisition finished callback
+	   total frames caught
+	   
+	*/
+	void (*acquisitionFinishedCallBack)(int, void*);
+	void *pAcquisitionFinished;
+
+
+	/**
+	  args to raw data ready callback are
+	  framenum
+	  datapointer
+	  datasize in bytes
+	  file descriptor
+	  guidatapointer (NULL, no data required)
+	*/
+	void (*rawDataReadyCallBack)(int, char*, int, FILE*, char*, void*);
+	void *pRawDataReady;
+
+	/** The action which decides what the user and default responsibilites to save data are
+	 * 0 raw data ready callback takes care of open,close,write file
+	 * 1 callback writes file, we have to open, close it
+	 * 2 we open, close, write file, callback does not do anything */
+	int cbAction;
+
+
+public:
+
+
+	/**
+	   callback arguments are
+	   filepath
+	   filename
+	   fileindex
+	   datasize
+	   
+	   return value is 
+	   0 callback takes care of open,close,wrie file
+	   1 callback writes file, we have to open, close it
+	   2 we open, close, write file, callback does not do anything
+	*/
+	void registerCallBackStartAcquisition(int (*func)(char*, char*,int, int, void*),void *arg){startAcquisitionCallBack=func; pStartAcquisition=arg;};
+
+	/**
+	   callback argument is
+	   toatal frames caught
+	*/
+	void registerCallBackAcquisitionFinished(void (*func)(int, void*),void *arg){acquisitionFinishedCallBack=func; pAcquisitionFinished=arg;};
+	
+	/**
+	  args to raw data ready callback are
+	  framenum
+	  datapointer
+	  datasize in bytes
+	  file descriptor
+	  guidatapointer (NULL, no data required)
+	*/
+	void registerCallBackRawDataReady(void (*func)(int, char*, int, FILE*, char*, void*),void *arg){rawDataReadyCallBack=func; pRawDataReady=arg;};
+};
+
+
+#endif
+
+//#endif

slsReceiverSoftware/slsReceiver/UDPInterface.cpp

@@ -0,0 +1,43 @@
+//#ifdef SLS_RECEIVER_UDP_FUNCTIONS
+/********************************************//**
+ * @file slsReceiverUDPFunctions.cpp
+ * @short does all the functions for a receiver, set/get parameters, start/stop etc.
+ ***********************************************/
+
+
+
+
+#include <signal.h>  		// SIGINT
+#include <sys/stat.h> 		// stat
+#include <sys/socket.h>		// socket(), bind(), listen(), accept(), shut down
+#include <arpa/inet.h>		// sock_addr_in, htonl, INADDR_ANY
+#include <stdlib.h>			// exit()
+#include <iomanip>			//set precision
+#include <sys/mman.h>		//munmap
+
+#include <string.h>
+#include <iostream>
+using namespace std;
+
+#include "UDPInterface.h"
+#include "UDPBaseImplementation.h"
+
+#include "moench02ModuleData.h"
+#include "gotthardModuleData.h"
+#include "gotthardShortModuleData.h"
+
+
+using namespace std;
+
+UDPInterface * UDPInterface::create(string receiver_type){
+	
+	if (receiver_type == "standard")
+		return new UDPBaseImplementation();
+	else{
+		cout << "[ERROR] UDP interface not supported, using standard implementation" << endl;
+		return new UDPBaseImplementation();
+	}
+}
+
+
+//#endif

slsReceiverSoftware/slsReceiver/UDPInterface.h

@@ -1,7 +1,7 @@
-#ifndef SLSRECEIVERBASE_H
-#define SLSRECEIVERBASE_H
+#ifndef UDPINTERFACE_H
+#define UDPINTERFACE_H
 /***********************************************
- * @file slsReceiverBase.h
+ * @file UDPInterface.h
  * @short base class with all the functions for a receiver, set/get parameters, start/stop etc.
  ***********************************************/
 /**
@@ -12,19 +12,35 @@
  * @short base class with all the functions for a receiver, set/get parameters, start/stop etc.
  */
 
-class slsReceiverBase {
+#include "sls_receiver_defs.h"
+#include "receiver_defs.h"
+#include "MySocketTCP.h"
 
-public:
+/*
+void print_not_implemented(string method_name){
+	std::cout << "[WARNING] Method " << method_name << " not implemented!" << std::endl; 
+}
+*/
+
+class UDPInterface {
+	
+ public:
 	
 	/**
 	 * constructor
 	 */
-  slsReceiverBase(){};
+	//UDPInterface(){};
 	
 	/**
 	 * Destructor
 	 */
-  virtual ~slsReceiverBase() {};
+	virtual ~UDPInterface() {};
+	
+	/**
+	 * Factory create method
+	 */
+	static UDPInterface *create(string receiver_type = "standard");
+	
 
 	/**
 	 * Initialize the Receiver

slsReceiverSoftware/slsReceiver/main.cpp

@@ -75,6 +75,7 @@ int main(int argc, char *argv[]) {
 
 	//start tcp server thread
 	if(user->start() == slsReceiverDefs::OK){
+		cout << "DONE!" << endl;
 		string str;
 		cin>>str;
 		//wait and look for an exit keyword

slsReceiverSoftware/slsReceiver/slsReceiver.cpp

@@ -10,24 +10,26 @@
 #include <stdlib.h>
 
 #include "slsReceiver.h"
-#include "slsReceiverUDPFunctions.h"
-#include "eigerReceiver.h"
+//#include "slsReceiverUDPFunctions.h"
+//#include "eigerReceiver.h"
+
+#include "UDPInterface.h"
+//#include "UDPBaseImplementation.h"
+
+
+#include "utilities.h"
 
 using namespace std;
 
 slsReceiver::slsReceiver(int argc, char *argv[], int &success){
+	
 	//creating base receiver
-	cout << "SLS Receiver" << endl;
-	receiverBase = new slsReceiverUDPFunctions();
 	int tcpip_port_no=-1;
 
-
-	
 	ifstream infile;
 	string sLine,sargname;
 	int iline = 0;
 
-
 	success=OK;
 
 	string fname = "";
@@ -38,34 +40,34 @@ slsReceiver::slsReceiver(int argc, char *argv[], int &success){
 			if(iarg+1==argc){
 				cout << "no config file name given. Exiting." << endl;
 				success=FAIL;
-			}else
+			}
+			else
 				fname.assign(argv[iarg+1]);
 		}
 	}
 	if((!fname.empty()) && (success == OK)){
-#ifdef VERBOSE
-		std::cout<< "config file name "<< fname << std::endl;
-#endif
+
+		VERBOSE_PRINT("config file name " + fname );
+		
 		infile.open(fname.c_str(), ios_base::in);
 		if (infile.is_open()) {
 			while(infile.good()){
 				getline(infile,sLine);
 				iline++;
-#ifdef VERBOSE
-				cout <<  sLine << endl;
-#endif
+
+				VERBOSE_PRINT(sLine);
+
 				if(sLine.find('#')!=string::npos){
-#ifdef VERBOSE
-					cout << "Line is a comment " << endl;
-#endif
+					VERBOSE_PRINT( "Line is a comment ");
 					continue;
-				}else if(sLine.length()<2){
-#ifdef VERBOSE
-					cout << "Empty line " << endl;
-#endif
+				}
+				else if(sLine.length()<2){
+					VERBOSE_PRINT("Empty line ");
 					continue;
-				}else{
+				}
+				else{
 					istringstream sstr(sLine);
+					
 					//parameter name
 					if(sstr.good())
 						sstr >> sargname;
@@ -85,14 +87,13 @@ slsReceiver::slsReceiver(int argc, char *argv[], int &success){
 				}
 			}
 			infile.close();
-		}else {
+		}
+		else {
 			cout << "Error opening configuration file " << fname << endl;
 			success = FAIL;
 		}
-#ifdef VERBOSE
-		cout << "Read configuration file of " << iline << " lines" << endl;
-#endif
 
+		VERBOSE_PRINT("Read configuration file of " + iline + " lines");
 	}
 
 
@@ -131,16 +132,16 @@ slsReceiver::slsReceiver(int argc, char *argv[], int &success){
 	}
 
 
-	if (success==OK)
-	  tcpipInterface = new slsReceiverTCPIPInterface(success,receiverBase, tcpip_port_no);
+	if (success==OK){
+		cout << "SLS Receiver" << endl;
+		udp_interface = UDPInterface::create("stasndard");
+		tcpipInterface = new slsReceiverTCPIPInterface(success, udp_interface, tcpip_port_no);
 		//tcp ip interface
-
-
-
+	}
 }
 
 
-slsReceiver::~slsReceiver() {if(receiverBase) delete receiverBase; if(tcpipInterface) delete tcpipInterface;}
+slsReceiver::~slsReceiver() {if(udp_interface) delete udp_interface; if(tcpipInterface) delete tcpipInterface;}
 
 
 int slsReceiver::start() {
@@ -158,7 +159,6 @@ void slsReceiver::closeFile(int p) {
 }
 
 
-
 int64_t slsReceiver::getReceiverVersion(){
 	tcpipInterface->getReceiverVersion();
 }
@@ -166,20 +166,20 @@ int64_t slsReceiver::getReceiverVersion(){
 
 void slsReceiver::registerCallBackStartAcquisition(int (*func)(char*, char*,int, int, void*),void *arg){
   //tcpipInterface
-	  receiverBase->registerCallBackStartAcquisition(func,arg);
+	udp_interface->registerCallBackStartAcquisition(func,arg);
 }
 
 
 
 void slsReceiver::registerCallBackAcquisitionFinished(void (*func)(int, void*),void *arg){
   //tcpipInterface
-	  receiverBase->registerCallBackAcquisitionFinished(func,arg);
+	udp_interface->registerCallBackAcquisitionFinished(func,arg);
 }
 
 
 void slsReceiver::registerCallBackRawDataReady(void (*func)(int, char*, int, FILE*, char*, void*),void *arg){
 	//tcpipInterface
-	  receiverBase->registerCallBackRawDataReady(func,arg);
+	udp_interface->registerCallBackRawDataReady(func,arg);
 }
 
 

slsReceiverSoftware/slsReceiver/slsReceiver.h

@@ -7,8 +7,12 @@
 
 
 #include "slsReceiverTCPIPInterface.h"
-#include "slsReceiverBase.h"
+#include "UDPInterface.h"
+#include "UDPBaseImplementation.h"
 
+#include "sls_receiver_defs.h"
+#include "receiver_defs.h"
+#include "MySocketTCP.h"
 
 
 
@@ -18,7 +22,7 @@
 
 class slsReceiver : private virtual slsReceiverDefs {
 	
-public:
+ public:
 	/**
 	 * Constructor
 	 * creates the tcp interface and the udp class
@@ -80,9 +84,9 @@ public:
 	void registerCallBackRawDataReady(void (*func)(int, char*, int, FILE*, char*, void*),void *arg);
 
 
-private:
+ private:
 	slsReceiverTCPIPInterface* tcpipInterface;
-	slsReceiverBase*			receiverBase;
+	UDPInterface* udp_interface;
 };
 
 

slsReceiverSoftware/slsReceiver/slsReceiverTCPIPInterface.cpp

@@ -4,7 +4,7 @@
  ***********************************************/
 
 #include "slsReceiverTCPIPInterface.h"
-#include "slsReceiverBase.h"
+#include "UDPInterface.h"
 #include "gitInfoReceiver.h"
 #include "slsReceiverUsers.h"
 #include "slsReceiver.h"
@@ -28,7 +28,7 @@ slsReceiverTCPIPInterface::~slsReceiverTCPIPInterface() {
 }
 
 
-slsReceiverTCPIPInterface::slsReceiverTCPIPInterface(int &success, slsReceiverBase* rbase, int pn):
+slsReceiverTCPIPInterface::slsReceiverTCPIPInterface(int &success, UDPInterface* rbase, int pn):
 		myDetectorType(GOTTHARD),
 		receiverBase(rbase),
 		ret(OK),
@@ -124,9 +124,9 @@ int slsReceiverTCPIPInterface::start(){
 		cout << "Could not create TCP Server thread" << endl;
 		return FAIL;
 	}
-#ifdef VERBOSE
+	//#ifdef VERBOSE
 	cout << "TCP Server thread created successfully." << endl;
-#endif
+	//#endif
 	return OK;
 }
 
@@ -503,7 +503,7 @@ int slsReceiverTCPIPInterface::set_file_dir() {
 
 
 
-
+// LEO: do we need it in the base class?
 int slsReceiverTCPIPInterface::set_file_index() {
 	ret=OK;
 	int retval=-1;
@@ -608,7 +608,7 @@ int slsReceiverTCPIPInterface::set_frame_index() {
 
 
 
-
+//LEO: is the client that commands the setup, or you just need the args?
 int slsReceiverTCPIPInterface::setup_udp(){
 	ret=OK;
 	strcpy(mess,"could not set up udp connection");
@@ -1773,7 +1773,7 @@ int slsReceiverTCPIPInterface::set_detector_hostname() {
 
 
 
-
+//LEO: why the receiver should set the dynamic range?
 int slsReceiverTCPIPInterface::set_dynamic_range() {
 	ret=OK;
 	int retval=-1;

slsReceiverSoftware/slsReceiver/slsReceiverTCPIPInterface.h

@@ -9,7 +9,7 @@
 #include "sls_receiver_defs.h"
 #include "receiver_defs.h"
 #include "MySocketTCP.h"
-#include "slsReceiverBase.h"
+#include "UDPInterface.h"
 
 
 
@@ -19,7 +19,7 @@
 
 class slsReceiverTCPIPInterface : private virtual slsReceiverDefs {
 	
-public:
+ public:
 	/**
 	 * Constructor
 	 * reads config file, creates socket, assigns function table
@@ -27,7 +27,7 @@ public:
 	 * @param rbase pointer to the receiver base
 	 * @param pn port number (defaults to default port number)
 	 */
-  slsReceiverTCPIPInterface(int &success, slsReceiverBase* rbase, int pn=-1);
+	slsReceiverTCPIPInterface(int &success, UDPInterface* rbase, int pn=-1);
 	
 	/**
 	 * Sets the port number to listen to. 
@@ -234,7 +234,7 @@ private:
 	detectorType myDetectorType;
 
 	/** slsReceiverBase object */
-	slsReceiverBase *receiverBase;
+	UDPInterface *receiverBase;
 
 	/** Number of functions */
 	static const int numberOfFunctions = 256;

slsReceiverSoftware/slsReceiver/slsReceiverUDPFunctions.cpp

@@ -6,6 +6,8 @@
 
 
 #include "slsReceiverUDPFunctions.h"
+#include "UDPBaseImplementation.h"
+
 
 #include "moench02ModuleData.h"
 #include "gotthardModuleData.h"
@@ -28,6 +30,9 @@ using namespace std;
 
 
 
+slsReceiverUDPFunctions * slsReceiverUDPFunctions::create(void){
+	return slsReceiverUDPFunctions();
+}
 
 slsReceiverUDPFunctions::slsReceiverUDPFunctions():
 		thread_started(0),
@@ -695,7 +700,7 @@ void slsReceiverUDPFunctions::setupFilter(){
 
 
 
-
+//LEO: it is not clear to me..
 void slsReceiverUDPFunctions::setupFifoStructure(){
 
 	int64_t i;

slsReceiverSoftware/slsReceiver/slsReceiverUDPFunctions.h

@@ -7,15 +7,17 @@
  ***********************************************/
 
 
-#include "sls_receiver_defs.h"
-#include "receiver_defs.h"
-#include "genericSocket.h"
+//#include "sls_receiver_defs.h"
+//#include "receiver_defs.h"
+//#include "genericSocket.h"
 #include "circularFifo.h"
 #include "singlePhotonDetector.h"
 #include "slsReceiverData.h"
 #include "moenchCommonMode.h"
 
-#include "slsReceiverBase.h"
+
+#include "UDPInterface.h"
+#include "UDPBaseImplementation.h"
 
 
 #ifdef MYROOT1
@@ -34,9 +36,10 @@
  * @short does all the functions for a receiver, set/get parameters, start/stop etc.
  */
 
-class slsReceiverUDPFunctions : private virtual slsReceiverDefs, public slsReceiverBase  {
 
-public:
+class slsReceiverUDPFunctions : private virtual slsReceiverDefs, public UDPInterface {
+	
+ public:
 	/**
 	 * Constructor
 	 */

slsReceiverSoftware/slsReceiver/slsReceiverUsers.h

@@ -1,4 +1,3 @@
-
 #ifndef SLS_RECEIVER_USERS_H
 #define SLS_RECEIVER_USERS_H