diff --git a/slsDetectorSoftware/slsReceiver/Makefile b/slsDetectorSoftware/slsReceiver/Makefile
index d603db3f1..75f47fe90 100644
--- a/slsDetectorSoftware/slsReceiver/Makefile
+++ b/slsDetectorSoftware/slsReceiver/Makefile
@@ -1,5 +1,5 @@
 CC			=	g++ 
-CLAGS		+=  -DSLS_RECEIVER_FUNCTION_LIST 
+CLAGS		+=  -DSLS_RECEIVER_FUNCTION_LIST
 LDFLAG=   -L/usr/lib64/ -lpthread -lm  -lstdc++ 
 
 
diff --git a/slsDetectorSoftware/slsReceiver/circularFifo.h b/slsDetectorSoftware/slsReceiver/circularFifo.h
index 3c4c05670..e57a59192 100644
--- a/slsDetectorSoftware/slsReceiver/circularFifo.h
+++ b/slsDetectorSoftware/slsReceiver/circularFifo.h
@@ -15,11 +15,17 @@
 #ifndef CIRCULARFIFO_H_
 #define CIRCULARFIFO_H_
 
-#include "sls_detector_defs.h"
+//#include "sls_detector_defs.h"
 
 #include <vector>
 using namespace std;
 
+typedef  double double32_t;
+typedef  float float32_t;
+typedef  int int32_t;
+
+
+
 /** Circular Fifo (a.k.a. Circular Buffer)
 * Thread safe for one reader, and one writer */
 template<typename Element>
diff --git a/slsDetectorSoftware/slsReceiver/receiver_defs.h b/slsDetectorSoftware/slsReceiver/receiver_defs.h
index 90ac83c19..ebe3f7a62 100755
--- a/slsDetectorSoftware/slsReceiver/receiver_defs.h
+++ b/slsDetectorSoftware/slsReceiver/receiver_defs.h
@@ -16,7 +16,7 @@
 //all max frames defined in sls_detector_defs.h.  20000 gotthard, 100000 for short gotthard, 1000 for moench
 
 
-#define GOTTHARD_FIFO_SIZE					25000
+#define GOTTHARD_FIFO_SIZE					25000//11
 #define GOTTHARD_ALIGNED_FRAME_SIZE			4096
 #define GOTTHARD_PACKETS_PER_FRAME			2
 #define GOTTHARD_ONE_PACKET_SIZE			1286
@@ -35,7 +35,9 @@
 #define GOTTHARD_PACKET_INDEX_MASK			0x1
 
 
-
+#define GOTTHARD_NUM_JOBS_P_THREAD			5000//20000//3 with 25 frames
+#define GOTTHARD_SHORT_NUM_JOBS_P_THREAD 	2500//40000
+#define MOENCH_NUM_JOBS_P_THREAD			1000//10000
 
 #define MOENCH_FIFO_SIZE					2500
 #define MOENCH_ALIGNED_FRAME_SIZE			65536
diff --git a/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.cpp b/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.cpp
index 7260fa77e..a56c46a4c 100644
--- a/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.cpp
+++ b/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.cpp
@@ -16,6 +16,7 @@
 #include <sys/mman.h>		//munmap
 
 
+
 #include <string.h>
 #include <iostream>
 using namespace std;
@@ -60,6 +61,8 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 														frameIndexMask(GOTTHARD_FRAME_INDEX_MASK),
 														frameIndexOffset(GOTTHARD_FRAME_INDEX_OFFSET),
 														dataCompression(false),
+														numJobsPerThread(GOTTHARD_NUM_JOBS_P_THREAD),
+														userDefinedNumJobsPerThread(0),
 														startAcquisitionCallBack(NULL),
 														pStartAcquisition(NULL),
 														acquisitionFinishedCallBack(NULL),
@@ -80,7 +83,13 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 		packetsPerFrame = MOENCH_PACKETS_PER_FRAME;
 		frameIndexMask = MOENCH_FRAME_INDEX_MASK;
 		frameIndexOffset = MOENCH_FRAME_INDEX_OFFSET;
+		numJobsPerThread = MOENCH_NUM_JOBS_P_THREAD;
 	}
+
+	if(userDefinedNumJobsPerThread)
+		numJobsPerThread = userDefinedNumJobsPerThread;
+
+
 	oneBufferSize = bufferSize/packetsPerFrame;
 
 	strcpy(savefilename,"");
@@ -108,10 +117,10 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 	}
 
 
-	vector <vector<int16_t> > map;
-	vector <vector<int16_t> > mask;
-	int initial_offset = 4;
-	int later_offset = 2;
+	int16_t* map;
+	int16_t* mask;
+	int initial_offset = 2;
+	int later_offset = 1;
 
 	int mask_y_offset = 120;
 	int mask_adc = 0x7fff;
@@ -131,21 +140,17 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 	case MOENCH:
 		x = MOENCH_PIXELS_IN_ONE_ROW;
 		y = MOENCH_PIXELS_IN_ONE_ROW;
-		mask.resize(x);
-		for(i=0;i<x; i++)
-			mask[i].resize(y);
-		map.resize(x);
-		for(i=0;i<x; i++)
-			map[i].resize(y);
 
+		mask = new int16_t[x*y];
+		map = new int16_t[x*y];
 
 		//set up mask for moench
 		for(i=0;i<x; i++)
 			for(j=0;j<y; j++){
 				if (j<mask_y_offset)
-					mask[i][j] = mask_adc;
+					mask[i*y+j] = mask_adc;
 				else
-					mask[i][j] = 0;
+					mask[i*y+j] = 0;
 			}
 
 		//set up mapping for moench
@@ -157,7 +162,7 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 						ipacket = (ipx + 1) + (ipy * num_packets_in_row);
 						if (ipacket == MOENCH_PACKETS_PER_FRAME)
 							ipacket = 0;
-						map[ ipx * num_pixels_per_packet_in_col + ix][ ipy * num_pixels_per_packet_in_row + iy] =
+						map[ (ipx * num_pixels_per_packet_in_col + ix) * y + (ipy * num_pixels_per_packet_in_row + iy) ] =
 								ipacket * MOENCH_ONE_PACKET_SIZE + offset;
 						offset += later_offset;
 					}
@@ -166,41 +171,44 @@ slsReceiverFunctionList::slsReceiverFunctionList(detectorType det):
 			}
 
 
-		filter = new singlePhotonFilter(x,y, MOENCH_FRAME_INDEX_MASK, MOENCH_PACKET_INDEX_MASK, MOENCH_FRAME_INDEX_OFFSET, 0, MOENCH_PACKETS_PER_FRAME, 0,map, mask,MOENCH_BUFFER_SIZE);
+		filter = new singlePhotonFilter(x,y, MOENCH_FRAME_INDEX_MASK, MOENCH_PACKET_INDEX_MASK, MOENCH_FRAME_INDEX_OFFSET,
+				0, MOENCH_PACKETS_PER_FRAME, 0,map, mask,fifofree,MOENCH_BUFFER_SIZE);
 		break;
 	default:
 		x = 1;
 		y = (GOTTHARD_DATA_BYTES/GOTTHARD_PACKETS_PER_FRAME);/*bufferSize/sizeof(int16_t)*/
 		offset = initial_offset;
 
-		mask.resize(x);
-		for(int i=0;i<x; i++)
-			mask[i].resize(y);
-		map.resize(x);
-		for(int i=0;i<x; i++)
-			map[i].resize(y);
+		mask = new int16_t[x*y];
+		map = new int16_t[x*y];
 
-		//set up mask for moench
+		//set up mask for gotthard
 		for (i=0; i < x; i++)
 			for (j=0; j < y; j++){
-				mask[i][j] = 0;
+				mask[i*y+j] = 0;
 			}
 
 		//set up mapping for gotthard
 		for (i=0; i < x; i++)
 			for (j=0; j < y; j++){
 				//since there are 2 packets
-				if (y == y/2)
+				if (j == y/2){
 					offset += initial_offset;
-				map[i][j] = offset;
-				offset += 2;
+					offset += 1;
+				}
+				map[i*y+j] = offset;
+				/*cout<<"offset["<<i*y+j<<"]:"<<map[i*y+j]<<"\t";*/
+				offset += 1;
 			}
+cout<<endl;
 
-
-		filter = new singlePhotonFilter(x,y,GOTTHARD_FRAME_INDEX_MASK, GOTTHARD_PACKET_INDEX_MASK, GOTTHARD_FRAME_INDEX_OFFSET, 0, GOTTHARD_PACKETS_PER_FRAME, 1,map, mask,GOTTHARD_BUFFER_SIZE);
+		filter = new singlePhotonFilter(x,y,GOTTHARD_FRAME_INDEX_MASK, GOTTHARD_PACKET_INDEX_MASK, GOTTHARD_FRAME_INDEX_OFFSET,
+				0, GOTTHARD_PACKETS_PER_FRAME, 1,map, mask,fifofree,GOTTHARD_BUFFER_SIZE);
 		break;
 	}
 
+
+
 	pthread_mutex_init(&status_mutex,NULL);
 	pthread_mutex_init(&dataReadyMutex,NULL);
 
@@ -332,7 +340,13 @@ int slsReceiverFunctionList::startReceiver(char message[]){
 		}
 		//wait till udp socket created
 		while(!listening_thread_running);
-		if(listening_thread_running!=1){
+		if(listening_thread_running==-1){
+			//change status
+			pthread_mutex_lock(&status_mutex);
+			status = IDLE;
+			listening_thread_running = 0;
+			receiver_threads_running = 0;
+			pthread_mutex_unlock(&(status_mutex));
 			strcpy(message,"Could not create UDP Socket.\n");
 			return FAIL;
 		}
@@ -359,7 +373,15 @@ int slsReceiverFunctionList::startReceiver(char message[]){
 		}
 		//wait till file is created
 		while(!writing_thread_running);
-		if(writing_thread_running!=1){
+		if(writing_thread_running==-1){
+			//change status
+			pthread_mutex_lock(&status_mutex);
+			status = IDLE;
+			listening_thread_running = 0;
+			receiver_threads_running = 0;
+			pthread_mutex_unlock(&(status_mutex));
+			if(udpSocket) udpSocket->ShutDownSocket();
+			pthread_join(listening_thread,NULL);
 			sprintf(message,"Could not create file %s.\n",savefilename);
 			return FAIL;
 		}
@@ -401,7 +423,6 @@ int slsReceiverFunctionList::startReceiver(char message[]){
 	//initialize semaphore
 	sem_init(&smp,0,1);
 
-
 	return OK;
 }
 
@@ -410,14 +431,14 @@ int slsReceiverFunctionList::startReceiver(char message[]){
 
 
 int slsReceiverFunctionList::stopReceiver(){
-#ifdef VERBOSE
+//#ifdef VERBOSE
 	cout << "Stopping Receiver" << endl;
-#endif
+//#endif
 
 	if(receiver_threads_running){
-#ifdef VERBOSE
-		cout << "Stopping new acquisition threadddd ...." << endl;
-#endif
+//#ifdef VERBOSE
+		cout << "Stopping new acquisition thread" << endl;
+//#endif
 		//stop listening thread
 		pthread_mutex_lock(&status_mutex);
 		receiver_threads_running=0;
@@ -426,11 +447,13 @@ int slsReceiverFunctionList::stopReceiver(){
 		if(udpSocket) udpSocket->ShutDownSocket();
 		pthread_join(listening_thread,NULL);
 		pthread_join(writing_thread,NULL);
+		/*if(dataCompression)
+			filter->enableCompression(false);*/
 	}
 	//change status
 	pthread_mutex_lock(&status_mutex);
 	status = IDLE;
-	pthread_mutex_unlock(&(status_mutex));
+	pthread_mutex_unlock(&(status_mutex));;
 
 	//semaphore destroy
 	sem_post(&smp);
@@ -462,144 +485,155 @@ int slsReceiverFunctionList::startListening(){
 #ifdef VERYVERBOSE
 	cout << "In startListening()\n");
 #endif
-	int rc;
-
+	int rc=0;
 	measurementStarted = false;
 	startFrameIndex = 0;
-
 	int offset=0;
 	int ret=1;
 	int i=0;
-	uint32_t *framenum;
 	char *tempchar = new char[oneBufferSize];
 
 
-	// A do/while(FALSE) loop is used to make error cleanup easier.  The
-	//  close() of each of the socket descriptors is only done once at the
-	//  very end of the program.
-	do {
+	//to increase socket receiver buffer size and max length of input queue by changing kernel settings
+	if(system("echo $((100*1024*1024)) > /proc/sys/net/core/rmem_max"))
+		cout << "\nWARNING: Could not change socket receiver buffer size in file /proc/sys/net/core/rmem_max" << endl;
+	else if(system("echo 250000 > /proc/sys/net/core/netdev_max_backlog"))
+		cout << "\nWARNING: Could not change max length of input queue in file /proc/sys/net/core/netdev_max_backlog" << endl;
 
-		//to increase socket receiver buffer size and max length of input queue by changing kernel settings
-		if(system("echo $((100*1024*1024)) > /proc/sys/net/core/rmem_max"))
-			cout << "\nWARNING: Could not change socket receiver buffer size in file /proc/sys/net/core/rmem_max" << endl;
-		else if(system("echo 250000 > /proc/sys/net/core/netdev_max_backlog"))
-			cout << "\nWARNING: Could not change max length of input queue in file /proc/sys/net/core/netdev_max_backlog" << endl;
-
-		/** permanent setting heiner
+	/** permanent setting heiner
 		net.core.rmem_max = 104857600 # 100MiB
 		net.core.netdev_max_backlog = 250000
 		sysctl -p
 		// from the manual
 		sysctl -w net.core.rmem_max=16777216
 		sysctl -w net.core.netdev_max_backlog=250000
-		 */
+	 */
 
-		//creating udp socket
-		if (strchr(eth,'.')!=NULL) strcpy(eth,"");
-		if(!strlen(eth)){
-			cout<<"warning:eth is empty.listening to all"<<endl;
-			if(udpSocket){
-				delete udpSocket;
-				udpSocket = NULL;
-			}
-			udpSocket = new genericSocket(server_port,genericSocket::UDP,oneBufferSize,1);//packetsPerFrame);
-		}else{
-			cout<<"eth:"<<eth<<endl;
-			udpSocket = new genericSocket(server_port,genericSocket::UDP,oneBufferSize,1,eth);//packetsPerFrame,eth);
-		}
-		if (udpSocket->getErrorStatus()){
-#ifdef VERBOSE
-			std::cout<< "Could not create UDP socket "<< server_port  << std::endl;
-#endif
-			pthread_mutex_lock(&status_mutex);
-			listening_thread_running = -1;
-			pthread_mutex_unlock(&status_mutex);
-			break;
+	//creating udp socket
+	if (strchr(eth,'.')!=NULL) strcpy(eth,"");
+	if(!strlen(eth)){
+		cout<<"warning:eth is empty.listening to all"<<endl;
+		if(udpSocket){
+			delete udpSocket;
+			udpSocket = NULL;
 		}
+		udpSocket = new genericSocket(server_port,genericSocket::UDP,oneBufferSize,1);//packetsPerFrame);
+	}else{
+		cout<<"eth:"<<eth<<endl;
+		udpSocket = new genericSocket(server_port,genericSocket::UDP,oneBufferSize,1,eth);//packetsPerFrame,eth);
+	}
+	int iret = udpSocket->getErrorStatus();
+	if (iret){
+		//#ifdef VERBOSE
+		std::cout<< "Could not create UDP socket on port "<< server_port  << " error:"<<iret<<std::endl;
+		//#endif
+		pthread_mutex_lock(&status_mutex);
+		listening_thread_running = -1;
+		pthread_mutex_unlock(&status_mutex);
+		return 0;
+	}else{
+
+		/*filter->setupAcquisitionParameters();*/
 
-		filter->setupAcquisitionParameters();
 
 		while (receiver_threads_running) {
-			if(!listening_thread_running){
-				pthread_mutex_lock(&status_mutex);
-				listening_thread_running = 1;
-				pthread_mutex_unlock(&(status_mutex));
-			}
 
 			if (!fifofree->isEmpty()) {
 				if (ret!=0)
 					fifofree->pop(buffer);
 
-				if(ret == -2){
+
+				if(ret == -3){
 					memcpy(buffer,tempchar,oneBufferSize);
 					offset = oneBufferSize;
-				}
-
-				//receiver 2 half frames / 1 short frame / 40 moench frames
-				rc = udpSocket->ReceiveDataOnly(buffer+offset,oneBufferSize);
-				if( rc <= 0){
-#ifdef VERYVERBOSE
-					cerr << "recvfrom() failed" << endl;
-#endif
-					continue;
-				}
-				//cout<<"got index:"<<hex<<(((uint32_t)(*((uint32_t*)(buffer+offset))) & (frameIndexMask)) >> frameIndexOffset);
-
-
-				if ((myDetectorType == GOTTHARD) && (shortFrame == -1))
-					(*((uint32_t*)(buffer+offset)))++;
-
-
-				ret = filter->verifyFrame(buffer+offset);
-
-
-				//start for each scan
-				if(!measurementStarted){
-					startFrameIndex = ((((uint32_t)(*((uint32_t*)buffer))) & (frameIndexMask)) >> frameIndexOffset);
-					cout<<"startFrameIndex:"<<hex<<startFrameIndex<<endl;
-					prevframenum=startFrameIndex;
-					measurementStarted = true;
-				}
-
-				//start of acquisition
-				if(!acqStarted){
-					startAcquisitionIndex=startFrameIndex;
-					currframenum = startAcquisitionIndex;
-					acqStarted = true;
-					cout<<"startAcquisitionIndex:"<<hex<<startAcquisitionIndex<<endl;
-				}
-
-
-				/*
-				if(ret < 0){
-					offset = 0;
-					continue;
-				}
-				 */
-				//last packet, but not the full frame, must push previous frame
-				if(ret == -1){
-					//set reminaing headers invalid
-					for( i = offset+ oneBufferSize; i < bufferSize; i += oneBufferSize)
-						(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
-					offset = 0;
-				}
-
-				//first packet of new frame, must push previous frame
-				else if(ret == -2){
-					//copy the new frame to a temp
-					memcpy(tempchar, buffer+offset, oneBufferSize);
 					//set all the new frame header and remaining headers invalid
-					for(i = offset; i < bufferSize; i += oneBufferSize);
-					(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
-				}
-				//wait for new packets of same frame
-				else if (ret == 0){
-					offset += oneBufferSize;
-					continue;
-				}
-				//wait for next frame
-				else{
+					for(i = offset; i < bufferSize; i += oneBufferSize)
+						(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
+					//start from beginning
 					offset = 0;
+					ret = 0;
+				}
+				else{
+					if(ret == -2){/** for moench, in between nxt, means ots -1*/
+						memcpy(buffer,tempchar,oneBufferSize);
+						offset = oneBufferSize;
+						ret = 0;
+					}
+
+
+					if(!startFrameIndex){
+						if(!listening_thread_running){
+							pthread_mutex_lock(&status_mutex);
+							listening_thread_running = 1;
+							pthread_mutex_unlock(&(status_mutex));
+						}
+					}
+					//receiver 2 half frames / 1 short frame / 40 moench frames
+					rc = udpSocket->ReceiveDataOnly(buffer+offset,oneBufferSize);
+					if( rc <= 0){
+						//#ifdef VERYVERBOSE
+						cerr << "recvfrom() failed:"<<endl;;// << receiver_threads_running<<endl;
+						fifofree->push(buffer);
+						//#endif
+						continue;
+					}
+
+
+					//manipulate buffer number to inlude frame number and packet number for gotthard
+					if ((myDetectorType == GOTTHARD) && (shortFrame == -1))
+						(*((uint32_t*)(buffer+offset)))++;
+
+
+					ret = filter->verifyFrame(buffer+offset);
+
+					//start for each scan
+					if(!measurementStarted){
+						startFrameIndex = ((((uint32_t)(*((uint32_t*)buffer))) & (frameIndexMask)) >> frameIndexOffset);
+						cout<<"startFrameIndex:"<<startFrameIndex<<endl;
+						prevframenum=startFrameIndex;
+						measurementStarted = true;
+					}
+
+					//start of acquisition
+					if(!acqStarted){
+						startAcquisitionIndex=startFrameIndex;
+						currframenum = startAcquisitionIndex;
+						acqStarted = true;
+						cout<<"startAcquisitionIndex:"<<startAcquisitionIndex<<endl;
+					}
+
+					//last packet, but not the full frame, must push previous frame
+					if(ret == -1){
+						//set reminaing headers invalid
+						for( i = offset+ oneBufferSize; i < bufferSize; i += oneBufferSize)
+							(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
+						offset = 0;
+					}
+
+					else if(ret == -3){
+						//copy the new frame to a temp
+						memcpy(tempchar, buffer+offset, oneBufferSize);
+						//set all the new frame header and remaining headers invalid
+						for(i = offset; i < bufferSize; i += oneBufferSize)
+							(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
+					}
+					//first packet of new frame, must push previous frame
+					else if(ret == -2){
+						//copy the new frame to a temp
+						memcpy(tempchar, buffer+offset, oneBufferSize);
+						//set all the new frame header and remaining headers invalid
+						for(i = offset; i < bufferSize; i += oneBufferSize)
+							(*((uint32_t*)(buffer+i))) = 0xFFFFFFFF;
+					}
+					//wait for new packets of same frame
+					else if (ret == 0){
+						offset += oneBufferSize;
+						continue;
+					}
+					//wait for next frame
+					else
+						offset = 0;
+
 				}
 
 				//so that it doesnt write the last frame twice
@@ -609,21 +643,9 @@ int slsReceiverFunctionList::startListening(){
 
 			}
 		}
-	} while (receiver_threads_running);
-	pthread_mutex_lock(&status_mutex);
-	receiver_threads_running=0;
-	status = IDLE;
-	pthread_mutex_unlock(&status_mutex);
-
-
-	//Close down any open socket descriptors
-	udpSocket->Disconnect();
-	delete tempchar;
-
-#ifdef VERBOSE
-	cout << "receiver_threads_running:" << receiver_threads_running << endl;
-#endif
+	}
 
+	delete  tempchar;
 	return 0;
 }
 
@@ -634,7 +656,6 @@ int slsReceiverFunctionList::startListening(){
 
 void* slsReceiverFunctionList::startWritingThread(void* this_pointer){
 	((slsReceiverFunctionList*)this_pointer)->startWriting();
-
 	return this_pointer;
 }
 
@@ -649,7 +670,14 @@ int slsReceiverFunctionList::startWriting(){
 	char *wbuf;
 	int sleepnumber=0;
 	int frameFactor=0;
-	int i;
+	int i,p;
+
+/*	char* trialarr[GOTTHARD_COMPRESSION_FIFO_SIZE];*/
+	int iJob = -2;
+	char* startingmem = 0;
+	int header_of_last_packet = (packetsPerFrame-1)*oneBufferSize;
+	int pointinfifo=0;
+	int firsttime = 1;
 
 	packetsInFile=0;
 	framesCaught=0;
@@ -667,10 +695,11 @@ int slsReceiverFunctionList::startWriting(){
 	cout << "Max Frames Per File:" << maxFramesPerFile << endl;
 	if (rawDataReadyCallBack)
 		cout << "Note: Data Write has been defined exernally" << endl;
+	if (dataCompression)
+		cout << "Data Compression is enabled with " << numJobsPerThread << " number of jobs per thread" << endl;
 	if(nFrameToGui)
 		cout << "Sending every " << nFrameToGui << "th frame to gui" <<  endl;
 
-
 	//by default, we read/write everything
 	cbAction = DO_EVERYTHING;
 	//acquisition start call back returns enable write
@@ -685,68 +714,83 @@ int slsReceiverFunctionList::startWriting(){
 	cout << "Ready!" << endl;
 
 
-	if (dataCompression)
-		filter->enableFilter(true);
-
 	//will always run till acquisition over and then runs till fifo is empty
 	while(receiver_threads_running || (!fifo->isEmpty())){
 
 		//start a new file
-		if (((int)(packetsInFile/packetsPerFrame) >= maxFramesPerFile)  || (strlen(savefilename) == 0)){
+		if ((strlen(savefilename) == 0) || ((packetsInFile/packetsPerFrame) >= maxFramesPerFile)){
 
 			//create file name
-			if(frameIndexNeeded==-1)	sprintf(savefilename, "%s/%s_%d.raw", filePath,fileName,fileIndex);
-			else						sprintf(savefilename, "%s/%s_f%012d_%d.raw", filePath,fileName,framesCaught,fileIndex);
+			if(!dataCompression){
+				if(frameIndexNeeded==-1)
+					sprintf(savefilename, "%s/%s_%d.raw", filePath,fileName,fileIndex);
+				else
+					sprintf(savefilename, "%s/%s_f%012d_%d.raw", filePath,fileName,framesCaught,fileIndex);
+			}
+
+			//only for gui display
+			else if(strlen(savefilename) == 0){
+				sprintf(savefilename, "%s/%s_fxxx_%d.raw", filePath,fileName,fileIndex);
+				filter->setupAcquisitionParameters(filePath,fileName,fileIndex);
+			}
+
+
 
 			if(enableFileWrite && cbAction > DO_NOTHING){
-
-				//create tree and file
-				if(dataCompression){
-					if(enableFileWrite){
-						filter->writeToFile();
-						filter->initTree(savefilename);
+				if (dataCompression){
+					//only the first time
+					if ((!framesCaught) && (filter->initTree()== FAIL)){
+						cout << " Error: Could not create file " << savefilename << endl;
+						pthread_mutex_lock(&status_mutex);
+						writing_thread_running = -1;
+						pthread_mutex_unlock(&(status_mutex));
+						break;
 					}
 				}
-				/*else{*///the standard way
-				if(sfilefd){
-					fclose(sfilefd);
-					sfilefd = NULL;
-				}
 
-				if (NULL == (sfilefd = fopen((const char *) (savefilename), "w"))){
-					cout << "Error: Could not create file " << savefilename << endl;
-					pthread_mutex_lock(&status_mutex);
-					writing_thread_running = -1;
-					pthread_mutex_unlock(&(status_mutex));
-					break;
-				}
-				//setting buffer
-				setvbuf(sfilefd,NULL,_IOFBF,BUF_SIZE);
-				/*}*/
 
-				//printing packet losses and file names
-				//if(prevframenum != 0)
-				if(!framesCaught)
-					cout << savefilename << endl;
+				//standard way
 				else{
-					cout << savefilename
-							<< "\tpacket loss "
-							<< setw(4)<<fixed << setprecision(4)<< dec <<
-							(int)(((((currframenum-prevframenum)*packetsPerFrame)-(packetsInFile))/(double)((currframenum-prevframenum)*packetsPerFrame))*100.000)/*packetloss*/
-							<< "%\tframenum "
-							<< dec << currframenum //<< "\t\t p " << prevframenum
-							<< "\tindex " << dec << getFrameIndex()
-							<< "\tpackets lost " << dec << ((currframenum-prevframenum)*packetsPerFrame)-(packetsInFile) << endl;
+					//close and open file
+					if(sfilefd){
+						fclose(sfilefd);
+						sfilefd = NULL;
+					}
+					if (NULL == (sfilefd = fopen((const char *) (savefilename), "w"))){
+						cout << "Error: Could not create file " << savefilename << endl;
+						pthread_mutex_lock(&status_mutex);
+						writing_thread_running = -1;
+						pthread_mutex_unlock(&(status_mutex));
+						break;
+					}
+					//setting buffer
+					setvbuf(sfilefd,NULL,_IOFBF,BUF_SIZE);
+
+
+					//printing packet losses and file names
+					if(!framesCaught)
+						cout << savefilename << endl;
+					else{
+						cout << savefilename
+								<< "\tpacket loss "
+								<< setw(4)<<fixed << setprecision(4)<< dec <<
+								(int)(((((currframenum-prevframenum)*packetsPerFrame)-(packetsInFile))/(double)((currframenum-prevframenum)*packetsPerFrame))*100.000)/*packetloss*/
+								<< "%\tframenum "
+								<< dec << currframenum //<< "\t\t p " << prevframenum
+								<< "\tindex " << dec << getFrameIndex()
+								<< "\tpackets lost " << dec << ((currframenum-prevframenum)*packetsPerFrame)-(packetsInFile) << endl;
+
+					}
 				}
 			}
 
-			pthread_mutex_lock(&status_mutex);
-			writing_thread_running = 1;
-			pthread_mutex_unlock(&(status_mutex));
-
-
-			//if(prevframenum != 0){
-			if(framesCaught){
+			//only the first time - state the thread is rinning
+			if (!framesCaught){
+				pthread_mutex_lock(&status_mutex);
+				writing_thread_running = 1;
+				pthread_mutex_unlock(&(status_mutex));
+			}
+			else if (!dataCompression){
 				prevframenum = currframenum;
 				packetsInFile=0;
 			}
@@ -757,49 +801,108 @@ int slsReceiverFunctionList::startWriting(){
 		if(!fifo->isEmpty()){
 
 			if(fifo->pop(wbuf)){
-
 				currframenum = ((uint32_t)(*((uint32_t*)wbuf))& frameIndexMask) >>frameIndexOffset;
-				//cout<<"currframenum: "<<hex<<currframenum<<endl;
-				//cout<<"currframenum2:"<<hex<<((((uint32_t)(*((uint32_t*)((char*)(wbuf+oneBufferSize)))))& frameIndexMask) >> frameIndexOffset)<<endl;;
-
-				for(i=0; i < packetsPerFrame; i++){
-					if(((uint32_t)(*((uint32_t*)((char*)(wbuf+oneBufferSize))))) == 0xFFFFFFFF){
-						//cout<<"found one: currframenum:"<<currframenum<<" currframe2:"<<((((uint32_t)(*((uint32_t*)((char*)(wbuf+oneBufferSize)))))& frameIndexMask) >> frameIndexOffset)<<endl;
-						break;
-					}
-				}
-
-				packetsInFile += i;
-				totalPacketsCaught += i;
-				//count only if you get full frames
-				if(i == packetsPerFrame){
-					framesCaught++;
-					totalFramesCaught++;
-				}
+				//cout<<"currframenum2:"<<((((uint32_t)(*((uint32_t*)((char*)(wbuf+oneBufferSize)))))& frameIndexMask) >> frameIndexOffset)<<endl;;
 
 				//write data call back
 				if (cbAction < DO_EVERYTHING) {
-					rawDataReadyCallBack(currframenum, wbuf, i*oneBufferSize, sfilefd, guiData,pRawDataReady);
+					rawDataReadyCallBack(currframenum, wbuf, bufferSize, sfilefd, guiData,pRawDataReady);
 				}
+
 				//default writing to file
 				else if(enableFileWrite){
-					/*if(!dataCompression){*/
-					if(sfilefd)
-						fwrite(wbuf, 1, i*oneBufferSize, sfilefd);
-					else{
-						cout << "You do not have permissions to overwrite: " << savefilename << endl;
-						usleep(50000);
+
+					if(dataCompression){
+
+						//if whole frame received
+						if(((uint32_t)(*((uint32_t*)(wbuf+header_of_last_packet)))) != 0xFFFFFFFF){
+							framesCaught++;
+							totalFramesCaught++;
+							packetsInFile += packetsPerFrame;
+							totalPacketsCaught += packetsPerFrame;
+							p = packetsPerFrame;
+						}
+						//to skip incompleete frames
+						else  {
+							/*cout<<"***not whole frame currframenum:"<<currframenum<<endl;*/
+							(*((uint32_t*)(wbuf))) = 0xFFFFFFFF;
+							p=0;
+						}
+
+
+						/*cout<<"wbuf:"<<(void*)wbuf<<endl;*/
+						//filter and write
+						if(iJob==-2){
+							/*cout<<"startingmem changed"<<endl;*/
+							startingmem = wbuf;
+							/*cout<<"***************startingmem:"<<(void*)startingmem<<endl;
+							cout<<"mem0:"<<(void*)mem0<<endl;*/
+							iJob=0;
+							if(firsttime){
+								pointinfifo = (startingmem-mem0)/4096;
+								firsttime = 0;
+								/*cout<<"fist time pointinfifo :"<<pointinfifo+1<< " iJob:"<<iJob+1<<endl;*/
+							}
+						}
+						++pointinfifo;
+						++iJob;
+
+						if(pointinfifo >= (fifosize-1)){
+							/*cout<<"*** sending not normally  "<<iJob<<endl;
+							cout<<"value:"<<((startingmem-mem0)/4096)+1<<endl;
+							 cout<<"pointfifo:"<<pointinfifo<<endl;
+							cout<<"iJob:"<<iJob<<endl;*/
+							filter->assignJobsForThread(startingmem,iJob);
+							startingmem = mem0;
+							iJob = 0;
+							pointinfifo = 0;
+							/*cout<<"***************1trialmem:"<<(void*)startingmem<<endl;
+							cout<<"1mem0:"<<(void*)mem0<<endl;
+							cout<<"1fist time pointinfifo :"<<pointinfifo+1<< " iJob:"<<iJob+1<<endl;*/
+
+						}
+						else if(iJob>=(numJobsPerThread)){
+							/*cout<<"*** sending normally "<<numJobsPerThread<<endl;
+							cout<<"value:"<<((startingmem-mem0)/4096)+1<<endl;
+							 cout<<"pointfifo:"<<pointinfifo<<endl;
+							cout<<"iJob:"<<iJob<<endl;*/
+							filter->assignJobsForThread(startingmem,numJobsPerThread);
+							iJob = -2;
+						}
+					}
+
+
+					//standard way
+					else{
+						//find number of packets received
+						for(i=0,p=0; i < bufferSize; i+=oneBufferSize,++p){
+							if(((uint32_t)(*((uint32_t*)((wbuf+i))))) == 0xFFFFFFFF){
+								break;
+							}
+						}
+						//increment counters
+						totalPacketsCaught += p;
+						packetsInFile += p;
+						if(p == packetsPerFrame){
+							framesCaught++;
+							totalFramesCaught++;
+						}
+						//write to file
+						if(sfilefd)
+							fwrite(wbuf, 1, p*oneBufferSize, sfilefd);
+						else{
+							cout << "You do not have permissions to overwrite: " << savefilename << endl;
+							usleep(50000);
+						}
 					}
-					/*}*/
 				}
 
 
 
-
-
 				//does not read every frame
 				if(!nFrameToGui){
-					if((guiData) && (i == packetsPerFrame)){
+					if((guiData) && (p == packetsPerFrame)){/*change it in funcs*/
+				/*	if(guiData){*/
 						pthread_mutex_lock(&dataReadyMutex);
 						guiDataReady=0;
 						pthread_mutex_unlock(&dataReadyMutex);
@@ -816,7 +919,7 @@ int slsReceiverFunctionList::startWriting(){
 				}
 				//reads every nth frame
 				else{
-					if (i != packetsPerFrame)//so no 1 packet frame writing over previous 2 packet frame
+					if (p != packetsPerFrame)//so no 1 packet frame writing over previous 2 packet frame
 						;
 					else if(frameFactor){
 						frameFactor--;
@@ -837,33 +940,60 @@ int slsReceiverFunctionList::startWriting(){
 					}
 				}
 
-				fifofree->push(wbuf);
+
+				if(!dataCompression)
+					fifofree->push(wbuf);
 			}
 		}
 		else{//cout<<"************************fifo empty**********************************"<<endl;
-			//change status to idle if the fifo is empty and status is transmitting
-			if(status == TRANSMITTING){
-				pthread_mutex_lock(&status_mutex);
-				status = RUN_FINISHED;
-				pthread_mutex_unlock(&(status_mutex));
-				cout << "Status: Run Finished" << endl;
-			}else{
+
+			//acquisition in the detector is done
+			if(status==TRANSMITTING){
+
+				//compression
+				if(dataCompression){
+					//popped data
+					if(iJob>0){
+						cout<<"sending at the end  "<<iJob<<endl;
+						filter->assignJobsForThread(startingmem,iJob);
+						iJob = -2;
+					}
+					//no more popped data
+					else{
+						//all jobs done
+						if(filter->checkIfJobsDone()){
+							//its all done
+							pthread_mutex_lock(&status_mutex);
+							status = RUN_FINISHED;
+							pthread_mutex_unlock(&(status_mutex));
+							cout << "Status: Run Finished" << endl;
+						}
+					}
+				}
+
+				//standard way
+				else{
+					pthread_mutex_lock(&status_mutex);
+					status = RUN_FINISHED;
+					pthread_mutex_unlock(&(status_mutex));
+					cout << "Status: Run Finished" << endl;
+				}
+			}
+			//acquisition not done in detector
+			else{
 				sleepnumber++;
 				usleep(50000);
 			}
 		}
 	}
 
-	pthread_mutex_lock(&status_mutex);
-	receiver_threads_running=0;
-	pthread_mutex_unlock(&status_mutex);
 
 	cout << "Total Packets Caught:" << dec << totalPacketsCaught << endl;
 	//cout << "RealTime Full Frames Caught:" << dec << framesCaught << endl;
 	cout << "Total Full Frames Caught:"<< dec << totalFramesCaught << endl;
 
 
-	if(sfilefd){
+	if((!dataCompression)&&(sfilefd)){
 #ifdef VERBOSE
 		cout << "sfield:" << (int)sfilefd << endl;
 #endif
@@ -921,6 +1051,7 @@ int slsReceiverFunctionList::setShortFrame(int i){
 		packetsPerFrame = GOTTHARD_SHORT_PACKETS_PER_FRAME;
 		frameIndexMask = GOTTHARD_SHORT_FRAME_INDEX_MASK;
 		frameIndexOffset = GOTTHARD_SHORT_FRAME_INDEX_OFFSET;
+		numJobsPerThread = GOTTHARD_SHORT_NUM_JOBS_P_THREAD;
 
 	}else{
 		bufferSize = GOTTHARD_BUFFER_SIZE;
@@ -928,77 +1059,80 @@ int slsReceiverFunctionList::setShortFrame(int i){
 		packetsPerFrame = GOTTHARD_PACKETS_PER_FRAME;
 		frameIndexMask = GOTTHARD_FRAME_INDEX_MASK;
 		frameIndexOffset = GOTTHARD_FRAME_INDEX_OFFSET;
+		numJobsPerThread = GOTTHARD_NUM_JOBS_P_THREAD;
 	}
 
+	if(userDefinedNumJobsPerThread)
+		numJobsPerThread = userDefinedNumJobsPerThread;
+
 	oneBufferSize = bufferSize/packetsPerFrame;
 
 	//if the filter is inititalized with the wrong readout
 	if(filter->getPacketsPerFrame() != packetsPerFrame){
 
-		vector <vector<int16_t> > map;
-		vector <vector<int16_t> > mask;
-		int initial_offset = 4;
-		int later_offset = 2;
+		int16_t* map;
+		int16_t* mask;
+
+		int initial_offset = 2;
+		int later_offset = 1;
 		int x,y,i,j,offset = 0;
 
 		switch(packetsPerFrame){
 		case GOTTHARD_SHORT_PACKETS_PER_FRAME://roi readout for gotthard
 			x = 1;
-			y = (GOTTHARD_DATA_BYTES/GOTTHARD_PACKETS_PER_FRAME)/2;
+			y = (GOTTHARD_SHORT_DATABYTES/sizeof(int16_t));
 			offset = initial_offset;
 
-			mask.resize(x);
-			for(int i=0;i<x; i++)
-				mask[i].resize(y);
-			map.resize(x);
-			for(int i=0;i<x; i++)
-				map[i].resize(y);
-			//set up mask for moench
+
+			mask = new int16_t[x*y];
+			map = new int16_t[x*y];
+
+			//set up mask for gotthard short
 			for (int i=0; i < x; i++)
 				for (int j=0; j < y; j++){
-					mask[i][j] = 0;
+					mask[i*y+j] = 0;
 				}
-			//set up mapping for gotthard
+			//set up mapping for gotthard short
 			for (int i=0; i < x; i++)
 				for (int j=0; j < y; j++){
-					map[i][j] = offset;
+					map[i*y+j] = offset;
 					offset += 2;
 				}
 
 			delete filter;
-			filter = new singlePhotonFilter(x,y,frameIndexMask, GOTTHARD_PACKET_INDEX_MASK, frameIndexOffset, 0, GOTTHARD_SHORT_PACKETS_PER_FRAME, 0,map, mask,GOTTHARD_SHORT_BUFFER_SIZE);
+			filter = new singlePhotonFilter(x,y,frameIndexMask, GOTTHARD_PACKET_INDEX_MASK, frameIndexOffset,
+					0, GOTTHARD_SHORT_PACKETS_PER_FRAME, 0,map, mask,fifofree,GOTTHARD_SHORT_BUFFER_SIZE);
 			break;
 
 		default: //normal readout for gotthard
 			x = 1;
-			y = (GOTTHARD_DATA_BYTES/GOTTHARD_PACKETS_PER_FRAME);
+			y = (GOTTHARD_DATA_BYTES/sizeof(int16_t));
 			offset = initial_offset;
 
-			mask.resize(x);
-			for(int i=0;i<x; i++)
-				mask[i].resize(y);
-			map.resize(x);
-			for(int i=0;i<x; i++)
-				map[i].resize(y);
+			mask = new int16_t[x*y];
+			map = new int16_t[x*y];
 
-			//set up mask for moench
+			//set up mask for gotthard
 			for (int i=0; i < x; i++)
 				for (int j=0; j < y; j++){
-					mask[i][j] = 0;
+					mask[i*y+j] = 0;
 				}
 
 			//set up mapping for gotthard
 			for (int i=0; i < x; i++)
 				for (int j=0; j < y; j++){
 					//since there are 2 packets
-					if (y == y/2)
+					if (j == y/2){
 						offset += initial_offset;
-					map[i][j] = offset;
-					offset += 2;
+						offset += 1;
+					}
+					map[i*y+j] = offset;
+					offset += 1;
 				}
 
 			delete filter;
-			filter = new singlePhotonFilter(x,y,frameIndexMask, GOTTHARD_PACKET_INDEX_MASK, frameIndexOffset, 0, GOTTHARD_PACKETS_PER_FRAME, 1,map, mask,GOTTHARD_BUFFER_SIZE);
+			filter = new singlePhotonFilter(x,y,frameIndexMask, GOTTHARD_PACKET_INDEX_MASK, frameIndexOffset,
+					0, GOTTHARD_PACKETS_PER_FRAME, 1,map, mask,fifofree,GOTTHARD_BUFFER_SIZE);
 			break;
 		}
 
diff --git a/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.h b/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.h
index b3d474987..09aea5ef5 100644
--- a/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.h
+++ b/slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.h
@@ -51,7 +51,7 @@ public:
 	/**
 	 * Returns status of receiver: idle, running or error
 	 */
-	runStatus getStatus(){return status;};
+	runStatus getStatus(){ return status;};
 
 	/**
 	 * Returns File Name
@@ -71,12 +71,12 @@ public:
 	/**
 	 * Returns Frames Caught for each real time acquisition (eg. for each scan)
 	 */
-	uint32_t getFramesCaught(){return framesCaught;};
+	int getFramesCaught(){return framesCaught;};
 
 	/**
 	 * Returns Total Frames Caught for an entire acquisition (including all scans)
 	 */
-	uint32_t getTotalFramesCaught(){return totalFramesCaught;};
+	int getTotalFramesCaught(){return totalFramesCaught;};
 
 	/**
 	 * Returns the frame index at start of each real time acquisition (eg. for each scan)
@@ -209,18 +209,21 @@ public:
 	void startReadout();
 
 	/** enabl data compression, by saving only hits */
-	void enableDataCompression(bool enable){dataCompression = enable;};
+	void enableDataCompression(bool enable){dataCompression = enable;filter->enableCompression(enable);};
 
 	/** get data compression, by saving only hits */
 	bool getDataCompression(){ return dataCompression;};
 
+	/** Set Number of Jobs Per Thread */
+	void setNumberOfJobsPerThread(int i){userDefinedNumJobsPerThread = i; numJobsPerThread = i;};
+
 private:
 
 	/** detector type */
 	detectorType myDetectorType;
 
 	/** max frames per file **/
-	uint32_t maxFramesPerFile;
+	int maxFramesPerFile;
 
 	/** File write enable */
 	int enableFileWrite;
@@ -241,7 +244,7 @@ private:
 	int frameIndexNeeded;
 
 	/** Frames Caught for each real time acquisition (eg. for each scan) */
-	uint32_t framesCaught;
+	int framesCaught;
 
 	/* Acquisition started */
 	bool acqStarted;
@@ -268,7 +271,7 @@ private:
 	uint32_t acquisitionIndex;
 
 	/** Packets currently in current file, starts new file when it reaches max */
-	uint32_t packetsInFile;
+	int packetsInFile;
 
 	/** Previous Frame number from buffer */
 	uint32_t prevframenum;
@@ -328,10 +331,10 @@ private:
 	int shortFrame;
 
 	/** buffer size can be 1286*2 or 518 or 1286*40 */
-	uint32_t bufferSize;
+	int bufferSize;
 
 	/** number of packets per frame*/
-	uint32_t packetsPerFrame;
+	int packetsPerFrame;
 	
 	/** gui data ready */
 	int guiDataReady;
@@ -369,6 +372,12 @@ private:
 	/** guiDataReady mutex */
 	pthread_mutex_t  dataReadyMutex;
 
+	/** Number of jobs per thread for data compression */
+	int numJobsPerThread;
+
+	/** user defined number of jobs per thread for data compression */
+	int userDefinedNumJobsPerThread;
+
 	/**
 	   callback arguments are
 	   filepath
@@ -412,6 +421,7 @@ private:
 	int cbAction;
 
 
+
 public:
 	/** File Descriptor */
 	static FILE *sfilefd;
diff --git a/slsDetectorSoftware/slsReceiver/slsReceiver_funcs.cpp b/slsDetectorSoftware/slsReceiver/slsReceiver_funcs.cpp
index 85a4e927a..d34038a13 100644
--- a/slsDetectorSoftware/slsReceiver/slsReceiver_funcs.cpp
+++ b/slsDetectorSoftware/slsReceiver/slsReceiver_funcs.cpp
@@ -40,6 +40,8 @@ slsReceiverFuncs::slsReceiverFuncs(int argc, char *argv[], int &success):
 	ifstream infile;
 	string sLine,sargname;
 	int iline = 0;
+	bool dcompr = false;
+	int jobthread = -1;
 
 
 	success=OK;
@@ -130,17 +132,20 @@ slsReceiverFuncs::slsReceiverFuncs(int argc, char *argv[], int &success):
 	//parse command line for type etc.. more priority
 	if(success == OK){
 		for(int iarg=1;iarg<argc;iarg++){
+
 			//type
 			if(!strcasecmp(argv[iarg],"-type")){
 				if(iarg+1==argc){
 					cout << "no detector type given after -type in command line. Exiting." << endl;
 					success=FAIL;
 				}else{
-					if(!strcasecmp(argv[iarg+1],"gotthard"))
+					if(!strcasecmp(argv[iarg+1],"gotthard")){
 						slsReceiverFuncs::myDetectorType = GOTTHARD;
-					else if(!strcasecmp(argv[iarg+1],"moench"))
+						iarg++;
+					}else if(!strcasecmp(argv[iarg+1],"moench")){
 						slsReceiverFuncs::myDetectorType = MOENCH;
-					else{
+						iarg++;
+					}else{
 						cout << "could not decode detector type in command line. \nOptions are:\ngotthard\nmoench.\n\nExiting." << endl;
 						success=FAIL;
 					}
@@ -152,20 +157,57 @@ slsReceiverFuncs::slsReceiverFuncs(int argc, char *argv[], int &success):
 					cout << "no port given after -rx_tcpport in command line. Exiting." << endl;
 					success=FAIL;
 				}else{
-					if(sscanf(argv[iarg+1],"%d",&port_no))
+					if(sscanf(argv[iarg+1],"%d",&port_no)){
 						cout<<"dataport:"<<port_no<<endl;
-					else{
+						iarg++;
+					}else{
 						cout << "could not decode port in command line. \n\nExiting." << endl;
 						success=FAIL;
 					}
 				}
 			}
+			//compression
+			else if(!strcasecmp(argv[iarg],"-compression")){
+				if(iarg+1==argc){
+					cout << "no value given after -compression in command line. Exiting." << endl;
+					success=FAIL;
+				}else {
+					if(!strcasecmp(argv[iarg+1],"yes")){
+						dcompr = true;
+						iarg++;
+				}else if(!strcasecmp(argv[iarg+1],"no")){
+						dcompr = true;
+						iarg++;
+					}else{
+						cout << "could not decode value for compression in command line. \n\nExiting." << endl;
+						success=FAIL;
+					}
+				}
+			}
+			//jobstothread
+			else if(!strcasecmp(argv[iarg],"-jobthread")){
+				if(iarg+1==argc){
+					cout << "no value given after -jobthread in command line. Exiting." << endl;
+					success=FAIL;
+				}else {
+					if(sscanf(argv[iarg+1],"%d",&jobthread)){
+						iarg++;
+					}else{
+						cout << "could not decode value for jobthread in command line. \n\nExiting." << endl;
+						success=FAIL;
+					}
+				}
+			}
+			else{
+				cout << "Unknown argument:" << argv[iarg] << endl;
+				success=FAIL;
+			}
 		}
 	}
 
 
-	if(success == OK){
 
+	if(success == OK){
 		//display detector message
 		switch(myDetectorType){
 		case GOTTHARD:
@@ -180,6 +222,16 @@ slsReceiverFuncs::slsReceiverFuncs(int argc, char *argv[], int &success):
 			break;
 		}
 	}
+	//help
+	else{
+		cout << "Help Commands " << endl;
+		cout << "type:\t\t Type of receiver. Default: Gotthard. Options: Moench" << endl;
+		cout << "rx_tcpport:\t TCP Communication Port with the client. Default:1954. " << endl;
+		cout << "compression:\t Data Compression. Saving only hits. Option:yes, no" << endl;
+		cout << "jobthread:\t Number of jobs given to a thread for compression." << endl << endl;
+	}
+
+
 
 	//create socket
 	if(success == OK){
@@ -197,6 +249,9 @@ slsReceiverFuncs::slsReceiverFuncs(int argc, char *argv[], int &success):
 			function_table();
 			slsReceiverList =  new slsReceiverFunctionList(myDetectorType);
 
+			if(dcompr)	slsReceiverList->enableDataCompression(dcompr);
+			if(jobthread!=-1) slsReceiverList->setNumberOfJobsPerThread(jobthread);
+
 #ifdef VERBOSE
 			cout << "Function table assigned." << endl;
 #endif
@@ -1146,8 +1201,10 @@ int	slsReceiverFuncs::gotthard_read_frame(){
 			if(shortFrame!=-1){
 				if(bindex != 0xFFFFFFFF)
 					memcpy((((char*)retval)+(GOTTHARD_SHORT_DATABYTES*shortFrame)),((char*) origVal)+4, GOTTHARD_SHORT_DATABYTES);
-				else
+				else{
 					index = startIndex - 1;
+					cout << "Missing Packet,Not sending to gui" << endl;
+				}
 			}
 			//all adc
 			else{
@@ -1170,8 +1227,10 @@ int	slsReceiverFuncs::gotthard_read_frame(){
 					}else
 						cout << "different frames caught. frame1:"<< hex << index << ":"<<pindex<<" frame2:" << hex << index2 << ":"<<pindex2<<endl;
 				}
-				else
+				else{
 					index = startIndex - 1;
+					cout << "Missing Packet,Not sending to gui" << endl;
+				}
 			}
 
 			arg = (index - startIndex);