WebSVN – f9daq – Blame – //cvi/instr/DRS/drs4.c

Rev	Author	Line No.	Line
203	f9daq	1	#include <formatio.h>
195	f9daq	2	#include <utility.h>
		3	#include <ansi_c.h>
203	f9daq	4	#include <cvirte.h>
195	f9daq	5	#include <userint.h>
		6	#include "drs4.h"
203	f9daq	7	#include "drsread.h"
195	f9daq	8
203	f9daq	9	#define MIKRO
		10
		11	#ifdef MIKRO
		12	#include "MIKRO.h"
		13	#endif
		14
195	f9daq	15	static int daq_on;
203	f9daq	16	static int ph, p2,plothandle[4]= {0,0,0,0};
195	f9daq	17	static int tfID;
		18	static int controlID;
		19
203	f9daq	20	#define MAX_THREADS 10
195	f9daq	21
203	f9daq	22	static CmtThreadPoolHandle poolHandle = 0;
195	f9daq	23
		24	int main (int argc, char *argv[]) {
203	f9daq	25	short port;
		26	if (InitCVIRTE (0, argv, 0) == 0)
		27	return -1; /* out of memory */
		28	if ((ph = LoadPanel (0, "drs4.uir", PANEL)) < 0)
		29	return -1;
		30	if ((p2 = LoadPanel (0, "drs4.uir", SCAN)) < 0)
		31	return -1;
		32	SetStdioPort (CVI_STDIO_WINDOW);
		33	SetSleepPolicy(VAL_SLEEP_MORE);
		34	CmtNewThreadPool (MAX_THREADS, &poolHandle);
		35
		36	DisplayPanel (ph);
		37	DisplayPanel (p2);
		38
		39	#ifdef MIKRO
		40	GetCtrlVal(p2, SCAN_PORT, &port);
		41	if (MIKRO_Open (port)) MessagePopup ("Error", "Mikro Port Not found !\n Change in the GUI") ;
		42	MIKRO_Init(1,0);
		43	MIKRO_Init(2,0);
		44	#endif
		45
		46	RunUserInterface ();
		47	DiscardPanel (ph);
		48	DiscardPanel (p2);
		49	CmtDiscardThreadPool (poolHandle);
		50	MIKRO_Close ();
		51	return 0;
195	f9daq	52	}
		53
		54
		55
		56
		57
		58	static void start_timer (double tout) {
203	f9daq	59	SetCtrlAttribute (ph, PANEL_TIMER, ATTR_INTERVAL, tout);
		60	SetCtrlAttribute (ph, PANEL_TIMER, ATTR_ENABLED, 1);
195	f9daq	61	}
		62
		63	static void stop_timer ( void ) {
203	f9daq	64	SetCtrlAttribute (ph, PANEL_TIMER, ATTR_ENABLED, 0);
		65	DRSSetTimeout();
195	f9daq	66	}
		67
		68
		69
		70
		71	void CVICALLBACK EndOfThread ( CmtThreadPoolHandle poolhandle,
203	f9daq	72	CmtThreadFunctionID functionID, unsigned int event,
		73	int value, void *callbackData ) {
195	f9daq	74
203	f9daq	75	daq_on=0;
		76	//SetDimming(0);
		77	printf("End of Thread \n");
		78	return ;
195	f9daq	79
		80	}
		81
		82
203	f9daq	83	int CVICALLBACK daq(void *functionData) {
195	f9daq	84
		85
203	f9daq	86	int neve;
		87	char filename[0xff];
		88	int imask[4];
		89	unsigned long mask;
		90	int frequency;
		91	double trgdelay;
		92	double trglevel;
		93	int trgtype;
		94	int trgchannel;
		95	int trgpolarity;
		96	int verbose;
		97	double range;
		98	int pfreq;
		99	int enabledoutput;
		100	int neveold = 0;
		101	double rate;
		102	int args = (int ) functionData;
201	f9daq	103
203	f9daq	104	GetCtrlVal(ph, PANEL_FILENAME, filename );
		105	GetCtrlVal(ph, PANEL_CH0, &imask[0] );
		106	GetCtrlVal(ph, PANEL_CH1, &imask[1] );
		107	GetCtrlVal(ph, PANEL_CH2, &imask[2] );
		108	GetCtrlVal(ph, PANEL_CH3, &imask[3] );
		109	mask = 0;
		110	for (int i=0; i<4; i++) {
		111	if (imask[i]) mask \|= (1<<i);
201	f9daq	112	}
203	f9daq	113
		114	GetCtrlVal(ph,PANEL_NEVE, &neve);
		115	GetCtrlVal(ph,PANEL_DEBUG, &verbose);
		116	GetCtrlVal(ph,PANEL_PFREQ, &pfreq);
		117	GetCtrlVal(ph,PANEL_ENABLEDOUTPUT, &enabledoutput);
		118
		119	GetCtrlVal(ph,PANEL_FREQUENCY, &frequency);
		120	GetCtrlVal(ph,PANEL_TRGDELAY, &trgdelay);
		121	GetCtrlVal(ph,PANEL_TRGCHANNEL, &trgchannel);
		122
		123	GetCtrlVal(ph,PANEL_TRGTYPE, &trgtype);
		124	GetCtrlVal(ph,PANEL_TRGLEVEL, &trglevel);
		125	GetCtrlVal(ph,PANEL_TRGPOLARITY, &trgpolarity);
		126	GetCtrlVal(ph,PANEL_RANGE, &range);
		127
		128
		129	//printf("mask=0x%x\n",mask);
		130
		131	DRSSetMask( (unsigned char)( mask & 0xF ) );
		132
		133	DRSSetFrequency( frequency );
		134	DRSSetTriggerDelay(trgdelay );
		135	DRSSetTriggerChannel(trgchannel );
		136	DRSSetTriggerType( trgtype );
		137	DRSSetTriggerLevel(trglevel);
		138	DRSSetTriggerPolarity(trgpolarity);
		139
		140	DRSSetRange ( range );
		141
		142
		143
		144	FILE *fp= NULL;
		145
		146	if (enabledoutput) {
		147	if (args[0]) fp = fopen(filename,"wb");
		148	else fp = fopen(filename,"ab");
		149	}
		150
		151	static unsigned char *buffer;
		152
		153	int buffer_size = 0;
		154	const int nBoards=1;
		155	const int waveDepth=1024;
207	f9daq	156
203	f9daq	157	if (buffer_size == 0) {
207	f9daq	158	buffer_size = 8; // file header + time header
		159	buffer_size += nBoards * (4 + 4(4+waveDepth4)); // bin widths
		160	buffer_size += 24 + nBoards * (8 + 4(8+waveDepth2));
		161	buffer = (unsigned char *)malloc(buffer_size);
		162	}
		163
203	f9daq	164	time_t t=0,told=0, tstart=0;
		165
		166	if (!DRSInit()) {
		167	time(&tstart);
		168	told=tstart;
		169	int i=0;
		170	for (i=0; i<neve; i++) {
		171	start_timer(1);// 1 s timeout
		172	int retval = DRSRead(0);
		173	stop_timer();
		174	int nb = ( retval == 0 && fp ) ? DRSToBuffer( buffer , i ) : 0;
		175	SetCtrlVal(ph,PANEL_CEVE,i);
		176	if (retval) i--;
		177	if (!daq_on) break;
		178	time(&t);
		179	if (t!=told ) {
		180	rate = (i-neveold);
		181	printf("%d events in %2.2f min (%d s) Rate %f Hz %s ",i+1, (double)(t-tstart)/60.,(t-tstart), rate , ctime(&t));
		182	GetCtrlVal(ph,PANEL_PFREQ, &pfreq);
		183	neveold = i;
		184	}
		185	told=t;
		186	// Save data
		187	if (nb>0 && fp) fwrite(buffer, 1,nb ,fp);
		188	// Plot Data
		189	if (i % pfreq == 0) for (int k=0; k<4; k++) {
		190	if (! (mask & ( 0x1<<k )) ) continue;
		191	float *t=DRSGetTime(k);
		192	float *x=DRSGetWave(k);
		193
		194	const int col[4]= {VAL_WHITE,VAL_RED,VAL_GREEN,VAL_BLUE};
		195	if (plothandle[k]) DeleteGraphPlot (ph, PANEL_GRAPH, plothandle[k], VAL_IMMEDIATE_DRAW);
		196	plothandle[k] = PlotXY (ph, PANEL_GRAPH, t, x, 1024, VAL_FLOAT, VAL_FLOAT, VAL_THIN_LINE, VAL_NO_POINT, VAL_SOLID, 1, col[k]);
		197
		198	for (int i=0 ; i<1024 ; i++) {
		199	if (verbose) printf("[%d] %d. x= %3.2f y=%3.2f\n", k, i, t[i], x[i] );
		200	//h[k]->Fill( t[i], x[i]*1e-3);
		201	}
		202	}
		203
		204
		205	}
		206	time(&t);
		207	printf("%d events in %2.2f min (%d s) %s",i+1, (double)(t-tstart)/60.,t-tstart, ctime(&t));
		208	DRSEnd();
		209	}
		210
		211	if (fp) fclose(fp);
		212
		213	free(buffer);
		214
		215	return 0;
		216
195	f9daq	217	}
		218
		219
		220
203	f9daq	221	int CVICALLBACK scan(void *functionData) {
195	f9daq	222
207	f9daq	223	int dx[3]={0,0,0};
		224	int nx[3]={0,0,0};
		225	int x0[3]={0,0,0};
		226	int ix[3]={0,0,0};
		227	int idx[3]={0,0,0};
203	f9daq	228	int size;
207	f9daq	229	char posrec[4]="POSR";
		230	char runbuf[4]="PRUN";
203	f9daq	231
207	f9daq	232	int n[3];
203	f9daq	233	char filename[0xFF];
		234	int enabledoutput;
		235
		236	FILE *fp;
		237	GetCtrlVal(ph, PANEL_FILENAME, filename );
		238
		239	GetCtrlVal(ph,PANEL_ENABLEDOUTPUT, &enabledoutput);
		240
		241	if ( GetFileInfo(filename,&size) ) {
		242	MessagePopup ("Warning", "File exist. Remove it first or choose another file");
		243	return 0;
		244	}
		245	GetCtrlVal(p2, SCAN_STEPX, &dx[0]);
		246	GetCtrlVal(p2, SCAN_STEPY, &dx[1]);
		247	GetCtrlVal(p2, SCAN_NSTEPSX, &nx[0]);
		248	GetCtrlVal(p2, SCAN_NSTEPSY, &nx[1]);
		249	GetCtrlVal(p2, SCAN_STARTX, &x0[0]);
		250	GetCtrlVal(p2, SCAN_STARTY, &x0[1]);
207	f9daq	251
		252
		253	if (enabledoutput) {
		254	fp = fopen(filename,"ab");
		255	if (fp) {
		256	size=36;
		257	fwrite(runbuf, 1,4 ,fp);
		258	fwrite(&size , 1,4 ,fp);
		259	fwrite(x0 , 1,4*3 ,fp);
		260	fwrite(dx , 1,4*3 ,fp);
		261	fwrite(nx , 1,4*3 ,fp);
		262	fclose(fp);
		263	}
		264	}
		265
203	f9daq	266	for (int i=0; i<nx[0]; i++) {
		267
		268	ix[0]= x0[0]+i*dx[0];
		269	#ifdef MIKRO
		270	MIKRO_MoveTo(1,ix[0]);
		271	#endif
		272	SetCtrlVal (p2, SCAN_IX, i);
		273	for (int j=0; j<nx[1]; j++) {
		274
		275	SetCtrlVal (p2, SCAN_IY, j);
		276
		277	ix[1]= x0[1]+j*dx[1];
		278	#ifdef MIKRO
		279	MIKRO_MoveTo(2,ix[1]);
		280
		281	MIKRO_GetPosition(1,&n[0]);
		282	SetCtrlVal (p2, SCAN_XP, n[0]);
		283	MIKRO_GetPosition(2,&n[1]);
		284	SetCtrlVal (p2, SCAN_YP, n[1]);
207	f9daq	285
		286	if (enabledoutput) {
203	f9daq	287	fp = fopen(filename,"ab");
		288	if (fp) {
207	f9daq	289	idx[0]=i;
		290	idx[1]=j;
		291	size=24;
		292	fwrite(posrec, 1,4 ,fp);
		293	fwrite(&size , 1,4 ,fp);
		294	fwrite(n , 1,4*3 ,fp);
		295	fwrite(idx , 1,4*3 ,fp);
203	f9daq	296	fclose(fp);
		297	}
		298	}
		299
		300	#endif
		301	daq(functionData);
		302	if (!daq_on) break;
		303	}
		304	if (!daq_on) break;
		305	}
		306
		307	return 0;
195	f9daq	308	}
		309
203	f9daq	310
195	f9daq	311	int CVICALLBACK StartCB (int panel, int control, int event,
203	f9daq	312	void *callbackData, int eventData1, int eventData2) {
		313	ThreadFunctionPtr mythread = NULL;
		314	switch (event) {
		315
		316	case EVENT_COMMIT:
		317
		318	controlID=0;
		319	if (panel == ph && control == PANEL_START) {
		320	mythread = daq;
		321	controlID= control;
		322	}
		323	if (panel == p2 && control == SCAN_SCAN) mythread = scan;
		324	if (mythread!=NULL) {
		325	printf("New Thread panel=%d button=%d\n", panel, control);
		326
		327	// SetDimming(1);
		328
		329	daq_on=1;
		330	CmtScheduleThreadPoolFunctionAdv (poolHandle, mythread, &controlID,
		331	DEFAULT_THREAD_PRIORITY,
		332	EndOfThread,
		333	EVENT_TP_THREAD_FUNCTION_END,
		334	NULL, RUN_IN_SCHEDULED_THREAD,
		335	&tfID);
		336	}
		337	break;
		338	}
		339	return 0;
195	f9daq	340	}
		341
		342	int CVICALLBACK StopCB (int panel, int control, int event,
203	f9daq	343	void *callbackData, int eventData1, int eventData2) {
		344	switch (event) {
		345	case EVENT_COMMIT:
		346	daq_on=0;
		347	break;
		348	}
		349	return 0;
195	f9daq	350	}
		351
		352	int CVICALLBACK ExitCB (int panel, int control, int event,
203	f9daq	353	void *callbackData, int eventData1, int eventData2) {
		354	switch (event) {
		355	case EVENT_COMMIT:
		356	QuitUserInterface (0);
		357	break;
		358	}
		359	return 0;
195	f9daq	360	}
203	f9daq	361
		362	int CVICALLBACK MoveStageCB (int panel, int control, int event,
		363	void *callbackData, int eventData1, int eventData2) {
		364	int axis=0, step=1000, direction=1, n;
		365	switch (event) {
		366	case EVENT_COMMIT:
		367
		368	if (panel == p2) {
		369	switch (control) {
		370	case SCAN_BR :
		371	axis = 1;
		372	direction = 1;
		373	GetCtrlVal(p2, SCAN_STEPX, &step);
		374	break;
		375	case SCAN_BL :
		376	axis = 1;
		377	direction = -1;
		378	GetCtrlVal(p2, SCAN_STEPX, &step);
		379	break;
		380	case SCAN_BU :
		381	axis = 2;
		382	direction = 1;
		383	GetCtrlVal(p2, SCAN_STEPY, &step);
		384	break;
		385	case SCAN_BD :
		386	axis = 2;
		387	direction = -1;
		388	GetCtrlVal(p2, SCAN_STEPY, &step);
		389	break;
		390	}
		391	#ifdef MIKRO
		392	MIKRO_MoveFor(axis, direction*step );
		393	MIKRO_GetPosition(axis,&n);
		394	if (axis == 1) SetCtrlVal (p2, SCAN_XP, n);
		395	if (axis == 2) SetCtrlVal (p2, SCAN_YP, n);
		396	#endif // MIKRO
		397	}
		398
		399	break;
		400	}
		401	return 0;
		402	}
		403
		404
		405
		406
		407
		408	int CVICALLBACK GoXCB (int panel, int control, int event,
		409	void *callbackData, int eventData1, int eventData2) {
		410	int n2;
		411	switch (event) {
		412	case EVENT_COMMIT:
		413	GetCtrlVal (p2, SCAN_XG, &n2);
		414	#ifdef MIKRO
		415	MIKRO_MoveTo(1,n2);
		416	MIKRO_GetPosition(1,&n2);
		417
		418	#endif
		419	SetCtrlVal (p2, SCAN_XP, n2);
		420	break;
		421	}
		422	return 0;
		423	}
		424
		425	int CVICALLBACK GoYCB (int panel, int control, int event,
		426	void *callbackData, int eventData1, int eventData2) {
		427	int n2;
		428	switch (event) {
		429	case EVENT_COMMIT:
		430	GetCtrlVal (p2, SCAN_YG, &n2);
		431	#ifdef MIKRO
		432	MIKRO_MoveTo(2,n2);
		433	MIKRO_GetPosition(2,&n2);
		434
		435	#endif
		436	SetCtrlVal (p2, SCAN_YP, n2);
		437	break;
		438	}
		439	return 0;
		440	}
		441
		442	int CVICALLBACK GetCurrentPositionCB (int panel, int control, int event,
		443	void *callbackData, int eventData1, int eventData2) {
		444
		445	int n[2];
		446	switch (event) {
		447	case EVENT_COMMIT:
		448	#ifdef MIKRO
		449	MIKRO_GetPosition(1,&n[0]);
		450	SetCtrlVal (p2, SCAN_XP, n[0]);
		451	MIKRO_GetPosition(2,&n[1]);
		452	SetCtrlVal (p2, SCAN_YP, n[1]);
		453	#endif
		454	break;
		455	}
		456	return 0;
		457	}
		458
		459	int CVICALLBACK HomeCB (int panel, int control, int event,
		460	void *callbackData, int eventData1, int eventData2) {
		461	switch (event) {
		462	case EVENT_COMMIT:
		463	#ifdef MIKRO
		464	MIKRO_ReferenceMove(1);
		465	MIKRO_ReferenceMove(2);
		466	GetCurrentPositionCB(panel, control, event, NULL, 0, 0);
		467	#endif
		468	break;
		469	}
		470	return 0;
		471	}

Subversion Repositories f9daq

(root)//cvi/instr/DRS/drs4.c – Rev 207