MbsAPIbase/f_his_hist.c
Go to the documentation of this file.
00001 // $Id: f_his_hist.c 478 2009-10-29 12:26:09Z linev $ 00002 //----------------------------------------------------------------------- 00003 // The GSI Online Offline Object Oriented (Go4) Project 00004 // Experiment Data Processing at EE department, GSI 00005 //----------------------------------------------------------------------- 00006 // Copyright (C) 2000- GSI Helmholtzzentrum für Schwerionenforschung GmbH 00007 // Planckstr. 1, 64291 Darmstadt, Germany 00008 // Contact: http://go4.gsi.de 00009 //----------------------------------------------------------------------- 00010 // This software can be used under the license agreements as stated 00011 // in Go4License.txt file which is part of the distribution. 00012 //----------------------------------------------------------------------- 00013 00014 #include "typedefs.h" 00015 #include "f_his_hist.h" 00016 #include "f_his_toupper.h" 00017 #include "f_his_swpbas.h" 00018 #include "f_stccomm.h" 00019 #include "f_swaplw.h" 00020 #include "f_ut_compress.h" 00021 #include "portnum_def.h" 00022 #include <stdio.h> 00023 #include <errno.h> 00024 #include <ctype.h> 00025 #include <string.h> 00026 #include <stdlib.h> 00027 static CHARS c_gl_serv_access[64]; 00028 static CHARS c_gl_serv_base[32]; 00029 static INTS4 l_gl_serv_port; 00030 static INTS4 l_gl_serv_chan; 00031 static INTS4 l_gl_serv_verb; 00032 struct s_tcpcomm *ps_tcpserv; 00033 s_his_comm s_his_comm_serv; 00034 /*****************+***********+****************************************/ 00035 /* */ 00036 /* GSI, Gesellschaft fuer Schwerionenforschung mbH */ 00037 /* Postfach 11 05 41 */ 00038 /* D-6100 Darmstadt 11 */ 00039 /* */ 00040 /*1+ C Procedure ***********+******************************************/ 00041 /* */ 00042 /*+ Module : f_his_getbas */ 00043 /* */ 00044 /*--------------------------------------------------------------------*/ 00045 /*+ CALLING : l=f_his_getbas(char server, int port, char base, char password, int **p_buf)*/ 00046 /*--------------------------------------------------------------------*/ 00047 /* */ 00048 /*+ PURPOSE : Returns list of histogram available from server */ 00049 /* */ 00050 /*+ ARGUMENTS : */ 00051 /* */ 00052 /*+ c_server : Node of server. */ 00053 /*+ l_port : Port number (must be known from server) */ 00054 /*+ c_base : Histogram base name */ 00055 /*+ c_password : Password if required from server */ 00056 /*+ p_buf : Address of buffer pointer. */ 00057 /* Data base is allocated and address returned. */ 00058 /* */ 00059 /*+ Return type : int. */ 00060 /*- COMM__SUCCESS : OK */ 00061 /*- COMM__ERROR : Error */ 00062 /*- COMM__NOACCESS: Password wrong */ 00063 /*- COMM__NOBASE : Base wrong */ 00064 /*- COMM__NOSERVER: Cannot connect (Port?) */ 00065 /*- COMM__NOHIST : Histogram not there */ 00066 /* */ 00067 /*2+DESCRIPTION***+***********+****************************************/ 00068 /* */ 00069 /*+ FUNCTION : Connects to histogram server. */ 00070 /* Allocates and returns LEA data base */ 00071 /* Bse must be compressed by server. */ 00072 /* */ 00073 /*2+IMPLEMENTATION************+****************************************/ 00074 /* */ 00075 /*+ File name : f_his_hist.c */ 00076 /*+ Version : 1.01 */ 00077 /*+ Author : Hans Essel */ 00078 /*+ Created : 21-May-2000 */ 00079 /*+ Updates : Date Purpose */ 00080 /* */ 00081 /*1- C Main ****************+******************************************/ 00082 INTS4 f_his_getbas(CHARS *pc_server, INTS4 l_port, CHARS *pc_base, CHARS *pc_access,INTS4 **p_buffer) 00083 { 00084 s_his_comm s_his_comm_cli; 00085 s_his_head *ps_his_head; 00086 INTS4 i_j,i_l,l_status,l_chan,l_swap,l_buffer,l_histos,l_size; 00087 INTS4 *pl_all,*pl_l; 00088 s_compress *ps_compress; 00089 struct s_tcpcomm *ps_tcpcli; 00090 00091 ps_tcpcli = (struct s_tcpcomm *) malloc (sizeof( struct s_tcpcomm)); 00092 00093 /* get base ***************************************************/ 00094 s_his_comm_cli.lu_endian=1; 00095 s_his_comm_cli.lu_size=0; 00096 s_his_comm_cli.lu_histos=0; 00097 s_his_comm_cli.lu_action=COMM__GETBASE; 00098 s_his_comm_cli.l_status=COMM__SUCCESS; 00099 strcpy(s_his_comm_cli.c_histo,"*"); 00100 strcpy(s_his_comm_cli.c_access,pc_access); 00101 strcpy(s_his_comm_cli.c_base,pc_base); 00102 l_status = f_stc_connectserver (pc_server,l_port, &l_chan, ps_tcpcli); 00103 if(l_status != STC__SUCCESS) {l_status=COMM__NOSERVER;goto g_return;} 00104 l_status = f_stc_write(&s_his_comm_cli,sizeof(s_his_comm),l_chan); 00105 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00106 l_status = f_stc_read (&s_his_comm_cli,sizeof(s_his_comm),l_chan,-1); 00107 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00108 l_swap = (s_his_comm_cli.lu_endian > 1); 00109 if(l_swap) l_status = f_swaplw((INTS4 *)&s_his_comm_cli,5,NULL); 00110 if(s_his_comm_cli.l_status != COMM__SUCCESS) {l_status=s_his_comm_cli.l_status;goto g_return;} 00111 00112 /* allocate buffer for comporessed base */ 00113 pl_all = (INTS4 *)malloc(s_his_comm_cli.lu_size); 00114 l_buffer = s_his_comm_cli.lu_size; 00115 /* break total buffer in TCP buffers */ 00116 pl_l=pl_all; 00117 i_l=l_buffer/16384; 00118 l_buffer=l_buffer%16384; 00119 for(i_j=0;i_j<i_l;i_j++){l_status = f_stc_read (pl_l,16384,l_chan,-1);pl_l+=4096;} 00120 if(l_buffer > 0) l_status = f_stc_read (pl_l,l_buffer,l_chan,-1); 00121 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00122 /* uncompress base */ 00123 ps_compress = (s_compress *) pl_all; 00124 if(l_swap == 1) 00125 { 00126 f_swaplw((INTS4 *)pl_all,sizeof(s_compress)/4,NULL); 00127 pl_l=pl_all+(sizeof(s_compress)/4); 00128 f_swaplw((INTS4 *)pl_l,ps_compress->l_masks,NULL); 00129 } 00130 *p_buffer = (INTS4 *)malloc(ps_compress->l_full_bytes); 00131 f_ut_compr_unpack((INTU1 *)pl_all,(INTU1 *) *p_buffer,ps_compress->l_full_bytes); 00132 if(l_swap == 1) l_status = f_his_swpbas((s_head*) *p_buffer); 00133 00134 l_status=COMM__SUCCESS; 00135 g_return: 00136 f_stc_discclient (l_chan); 00137 f_stc_close (ps_tcpcli); 00138 free(pl_all); 00139 free(ps_tcpcli); 00140 return(l_status); 00141 } 00142 /*1+ C Procedure ***********+******************************************/ 00143 /* */ 00144 /*+ Module : f_his_getdir */ 00145 /* */ 00146 /*--------------------------------------------------------------------*/ 00147 /*+ CALLING : l=f_his_getdir(char server, int port, char base, char password,*/ 00148 /* char histo, int **p_buf, int **l_histos)*/ 00149 /* */ 00150 /*--------------------------------------------------------------------*/ 00151 /* */ 00152 /*+ PURPOSE : Returns list of histogram available from server */ 00153 /* */ 00154 /*+ ARGUMENTS : */ 00155 /* */ 00156 /*+ c_server : Node of server. */ 00157 /*+ l_port : Port number (must be known from server) */ 00158 /*+ c_base : Histogram base name */ 00159 /*+ c_password : Password if required from server */ 00160 /*+ c_histo : Histogram wildcard */ 00161 /*+ p_buf : Address of buffer pointer. */ 00162 /* If NULL, buffer is allocated, if not l_histos gives */ 00163 /* size of buffer in sizeof(s_his_head). */ 00164 /*+ l_histos : Size in sizeof(s_his_head) of buffer, */ 00165 /* returns number of histograms */ 00166 /* */ 00167 /*+ Return type : int. */ 00168 /*- COMM__SUCCESS : OK */ 00169 /*- COMM__ERROR : Error */ 00170 /*- COMM__NOACCESS: Password wrong */ 00171 /*- COMM__NOBASE : Base wrong */ 00172 /*- COMM__NOSERVER: Cannot connect (Port?) */ 00173 /*- COMM__NOHIST : Histogram not there */ 00174 /* */ 00175 /*2+DESCRIPTION***+***********+****************************************/ 00176 /* */ 00177 /*+ FUNCTION : Connects to histogram server. */ 00178 /* Returns buffer with s_his_head slots */ 00179 /* */ 00180 /*2+IMPLEMENTATION************+****************************************/ 00181 /* */ 00182 /*+ File name : f_his_hist.c */ 00183 /*+ Version : 1.01 */ 00184 /*+ Author : Hans Essel */ 00185 /*+ Created : 21-May-2000 */ 00186 /*+ Updates : Date Purpose */ 00187 /* */ 00188 /*1- C Main ****************+******************************************/ 00189 INTS4 f_his_getdir(CHARS *pc_server, INTS4 l_port, CHARS *pc_base, CHARS *pc_access, CHARS *pc_histo 00190 ,INTS4 **p_buffer, INTS4 *pl_histos) 00191 { 00192 s_his_comm s_his_comm_cli; 00193 s_his_head *ps_his_head; 00194 INTS4 i_j,i_l,l_status,l_chan,l_swap,l_buffer,l_histos,l_size; 00195 INTS4 *pl_all,*pl_l; 00196 struct s_tcpcomm *ps_tcpcli; 00197 00198 ps_tcpcli = (struct s_tcpcomm *) malloc (sizeof( struct s_tcpcomm)); 00199 00200 /* get directory ***************************************************/ 00201 s_his_comm_cli.lu_endian=1; 00202 s_his_comm_cli.lu_size=0; 00203 s_his_comm_cli.lu_histos=0; 00204 s_his_comm_cli.lu_action=COMM__GETDIR; 00205 s_his_comm_cli.l_status=COMM__SUCCESS; 00206 strcpy(s_his_comm_cli.c_histo,pc_histo); 00207 strcpy(s_his_comm_cli.c_access,pc_access); 00208 strcpy(s_his_comm_cli.c_base,pc_base); 00209 l_status = f_stc_connectserver (pc_server,l_port, &l_chan, ps_tcpcli); 00210 if(l_status != STC__SUCCESS) {l_status=COMM__NOSERVER;goto g_return;} 00211 l_status = f_stc_write(&s_his_comm_cli,sizeof(s_his_comm),l_chan); 00212 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00213 l_status = f_stc_read (&s_his_comm_cli,sizeof(s_his_comm),l_chan,-1); 00214 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00215 l_swap = (s_his_comm_cli.lu_endian > 1); 00216 if(l_swap) l_status = f_swaplw((INTS4 *)&s_his_comm_cli,5,NULL); 00217 if(s_his_comm_cli.l_status != COMM__SUCCESS) {l_status=s_his_comm_cli.l_status;goto g_return;} 00218 00219 l_histos=s_his_comm_cli.lu_histos; 00220 l_size=sizeof(s_his_head)*l_histos; 00221 /* allocate buffer */ 00222 if(*p_buffer == 0) 00223 { 00224 pl_all = (INTS4 *)malloc(l_size); 00225 *p_buffer = pl_all; 00226 } 00227 else 00228 { 00229 if(*pl_histos < l_histos) {l_status=COMM__ERROR;goto g_return;} 00230 pl_all = *p_buffer; 00231 } 00232 *pl_histos = l_histos; 00233 l_buffer = s_his_comm_cli.lu_size; 00234 /* break total buffer in TCP buffers */ 00235 pl_l=pl_all; 00236 i_l=l_buffer/16384; 00237 l_buffer=l_buffer%16384; 00238 for(i_j=0;i_j<i_l;i_j++){l_status = f_stc_read (pl_l,16384,l_chan,-1);pl_l+=4096;} 00239 if(l_buffer > 0) l_status = f_stc_read (pl_l,l_buffer,l_chan,-1); 00240 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00241 00242 ps_his_head = (s_his_head *)pl_all; 00243 for(i_j=0;i_j<s_his_comm_cli.lu_histos;i_j++) 00244 { 00245 if(l_swap) l_status = f_swaplw((INTS4 *)ps_his_head,16,NULL); 00246 ps_his_head++; 00247 00248 } 00249 l_status=COMM__SUCCESS; 00250 g_return: 00251 f_stc_discclient (l_chan); 00252 f_stc_close (ps_tcpcli); 00253 free(ps_tcpcli); 00254 return(l_status); 00255 } 00256 /*****************+***********+****************************************/ 00257 /* */ 00258 /* GSI, Gesellschaft fuer Schwerionenforschung mbH */ 00259 /* Postfach 11 05 41 */ 00260 /* D-6100 Darmstadt 11 */ 00261 /* */ 00262 /*1+ C Procedure ***********+******************************************/ 00263 /* */ 00264 /*+ Module : f_his_gethis */ 00265 /* */ 00266 /*--------------------------------------------------------------------*/ 00267 /*+ CALLING : l=f_his_gethis(char server, int port, char base, char password,*/ 00268 /* char histo, s_his_head **p_head, int **p_buf, int **l_size)*/ 00269 /* */ 00270 /*--------------------------------------------------------------------*/ 00271 /* */ 00272 /*+ PURPOSE : Returns histogram from server */ 00273 /* */ 00274 /*+ ARGUMENTS : */ 00275 /* */ 00276 /*+ c_server : Node of server. */ 00277 /*+ l_port : Port number (must be known from server) */ 00278 /*+ c_base : Histogram base name */ 00279 /*+ c_password : Password if required from server */ 00280 /*+ c_histo : Histogram */ 00281 /*+ p_head : Address of header pointer (s_his_head) */ 00282 /* If NULL, s_his_head will be allocated */ 00283 /*+ p_buf : Address of buffer pointer */ 00284 /* If NULL, buffer for data will be allocated */ 00285 /*+ l_size : Size in bytes of buffer, returns size */ 00286 /* */ 00287 /*+ Return type : int. */ 00288 /*- COMM__SUCCESS : OK */ 00289 /*- COMM__ERROR : Error */ 00290 /*- COMM__NOACCESS: Password wrong */ 00291 /*- COMM__NOBASE : Base wrong */ 00292 /*- COMM__NOSERVER: Cannot connect (Port?) */ 00293 /*- COMM__NOHIST : Histogram not there */ 00294 /* */ 00295 /*2+DESCRIPTION***+***********+****************************************/ 00296 /* */ 00297 /*+ FUNCTION : Connects to histogram server. */ 00298 /* Returns buffer with s_his_head and data buffer */ 00299 /* Required buffer size can be obtained from */ 00300 /* s_his_head after calling f_his_getdir. */ 00301 /* */ 00302 /*2+IMPLEMENTATION************+****************************************/ 00303 /* */ 00304 /*+ File name : f_his_hist.c */ 00305 /*+ Version : 1.01 */ 00306 /*+ Author : Hans Essel */ 00307 /*+ Created : 21-May-2000 */ 00308 /*+ Updates : Date Purpose */ 00309 /* */ 00310 /*1- C Main ****************+******************************************/ 00311 INTS4 f_his_gethis(CHARS *pc_server, INTS4 l_port, CHARS *pc_base, CHARS *pc_access, CHARS *pc_histo 00312 , s_his_head **p_head, INTS4 **p_buffer, INTS4 *pl_size) 00313 { 00314 s_his_comm s_his_comm_cli; 00315 s_his_head *ps_his_head; 00316 INTS4 i_j,i_l,l_status,l_chan,l_swap,l_buffer,l_histos,l_size; 00317 INTS4 *pl_all,*pl_head,*pl_l; 00318 struct s_tcpcomm *ps_tcpcli; 00319 00320 ps_tcpcli = (struct s_tcpcomm *) malloc (sizeof( struct s_tcpcomm)); 00321 00322 /* get histogram ******************************************************/ 00323 s_his_comm_cli.lu_endian=1; 00324 s_his_comm_cli.lu_size=0; 00325 s_his_comm_cli.lu_histos=0; 00326 s_his_comm_cli.lu_action=COMM__GETHIST; 00327 s_his_comm_cli.l_status=COMM__SUCCESS; 00328 strcpy(s_his_comm_cli.c_histo,pc_histo); 00329 strcpy(s_his_comm_cli.c_access,pc_access); 00330 strcpy(s_his_comm_cli.c_base,pc_base); 00331 l_status = f_stc_connectserver (pc_server,l_port, &l_chan, ps_tcpcli); 00332 if(l_status != STC__SUCCESS) {l_status=COMM__NOSERVER;goto g_return;} 00333 l_status = f_stc_write(&s_his_comm_cli,sizeof(s_his_comm),l_chan); 00334 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00335 l_status = f_stc_read (&s_his_comm_cli,sizeof(s_his_comm),l_chan,-1); 00336 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00337 l_swap = (s_his_comm_cli.lu_endian > 1); 00338 if(l_swap) l_status = f_swaplw((INTS4 *)&s_his_comm_cli,5,NULL); 00339 if(s_his_comm_cli.l_status != COMM__SUCCESS) {l_status=s_his_comm_cli.l_status;goto g_return;} 00340 00341 l_size=s_his_comm_cli.lu_size-sizeof(s_his_head); 00342 /* allocate buffer */ 00343 if(*p_buffer == 0) 00344 { 00345 pl_all = (INTS4 *)malloc(l_size); 00346 *p_buffer = pl_all; 00347 } 00348 else 00349 { 00350 if(*pl_size < l_size) {l_status=COMM__ERROR;goto g_return;} 00351 pl_all = *p_buffer; 00352 } 00353 /* allocate header buffer */ 00354 if(*p_head == 0) 00355 { 00356 ps_his_head = (s_his_head *)malloc(sizeof(s_his_head)); 00357 *p_head = ps_his_head; 00358 } 00359 else ps_his_head = *p_head; 00360 00361 l_status = f_stc_read (ps_his_head,sizeof(s_his_head),l_chan,-1); 00362 if(l_swap) l_status = f_swaplw((INTS4 *)ps_his_head,16,NULL); 00363 00364 *pl_size = l_size; 00365 l_buffer = l_size; 00366 00367 /* break total buffer in TCP buffers */ 00368 pl_l=pl_all; 00369 i_l=l_buffer/16384; 00370 l_buffer=l_buffer%16384; 00371 for(i_j=0;i_j<i_l;i_j++){l_status = f_stc_read (pl_l,16384,l_chan,-1);pl_l+=4096;} 00372 if(l_buffer > 0) l_status = f_stc_read (pl_l,l_buffer,l_chan,-1); 00373 if(l_status != STC__SUCCESS) {l_status=COMM__ERROR;goto g_return;} 00374 00375 if(l_swap) l_status = f_swaplw((INTS4 *)pl_all,l_size/4,NULL); 00376 00377 l_status=COMM__SUCCESS; 00378 g_return: 00379 f_stc_discclient (l_chan); 00380 f_stc_close (ps_tcpcli); 00381 free(ps_tcpcli); 00382 return(l_status); 00383 } 00384 /*1+ C Procedure ***********+******************************************/ 00385 /* */ 00386 /*+ Module : f_his_server */ 00387 /* */ 00388 /*--------------------------------------------------------------------*/ 00389 /*+ CALLING : l=f_his_server(int *pl_port, char base, char accesss)*/ 00390 /*--------------------------------------------------------------------*/ 00391 /* */ 00392 /*+ PURPOSE : Start histogram server */ 00393 /* */ 00394 /*+ ARGUMENTS : */ 00395 /* */ 00396 /*+ pl_port : Address to receive port number used. */ 00397 /*+ base : Base name */ 00398 /*+ access : Password */ 00399 /* */ 00400 /*+ Return type : int. */ 00401 /*- COMM__SUCCESS : OK */ 00402 /*- COMM__ERROR : Error */ 00403 /* */ 00404 /*2+DESCRIPTION***+***********+****************************************/ 00405 /* */ 00406 /*+ FUNCTION : Creates histogram server. */ 00407 /* Returns port number */ 00408 /* */ 00409 /*2+IMPLEMENTATION************+****************************************/ 00410 /* */ 00411 /*+ File name : f_his_hist.c */ 00412 /*+ Version : 1.01 */ 00413 /*+ Author : Hans Essel */ 00414 /*+ Created : 21-May-2000 */ 00415 /*+ Updates : Date Purpose */ 00416 /* */ 00417 /*1- C Main ****************+******************************************/ 00418 INTS4 f_his_server(CHARS *pc_base, CHARS *pc_access, INTS4 *pl_port) 00419 { 00420 INTS4 *pl_l,i_j,i_l,ll,l_buffer,l_status; 00421 00422 ps_tcpserv = (struct s_tcpcomm *) malloc (sizeof( struct s_tcpcomm)); 00423 l_gl_serv_port=PORT__HIST_SERV; 00424 strcpy(c_gl_serv_access,pc_access); 00425 strcpy(c_gl_serv_base,pc_base); 00426 f_his_toupper(c_gl_serv_access,sizeof(c_gl_serv_access)); 00427 f_his_toupper(c_gl_serv_base,sizeof(c_gl_serv_base)); 00428 00429 while((l_status = f_stc_createserver (&l_gl_serv_port, ps_tcpserv)) != STC__SUCCESS) 00430 { 00431 l_gl_serv_port++; 00432 if(l_gl_serv_port > PORT__HIST_SERV + 20) 00433 { 00434 printf("Error creating histogram server\n"); 00435 return(COMM__ERROR); 00436 } 00437 } 00438 *pl_port=l_gl_serv_port; 00439 return(0); 00440 } 00441 00442 /*1+ C Procedure ***********+******************************************/ 00443 /* */ 00444 /*+ Module : f_his_wait */ 00445 /* */ 00446 /*--------------------------------------------------------------------*/ 00447 /*+ CALLING : l=f_his_wait(int *pl_action, char histogram) */ 00448 /*--------------------------------------------------------------------*/ 00449 /* */ 00450 /*+ PURPOSE : Wait for client */ 00451 /* */ 00452 /*+ ARGUMENTS : */ 00453 /* */ 00454 /*+ pl_action : Address to receive required action. */ 00455 /*+ histogram : Histogram sepc. */ 00456 /* */ 00457 /*+ Return type : int. */ 00458 /*- COMM__SUCCESS : OK */ 00459 /*- COMM__ERROR : Error */ 00460 /*- COMM__NOACCESS: Password wrong */ 00461 /*- COMM__NOBASE : Base wrong */ 00462 /* */ 00463 /*2+DESCRIPTION***+***********+****************************************/ 00464 /* */ 00465 /*+ FUNCTION : Waits for client to connect. */ 00466 /* Returns action required. */ 00467 /* Checks for correct base and password */ 00468 /* */ 00469 /*2+IMPLEMENTATION************+****************************************/ 00470 /* */ 00471 /*+ File name : f_his_hist.c */ 00472 /*+ Version : 1.01 */ 00473 /*+ Author : Hans Essel */ 00474 /*+ Created : 21-May-2000 */ 00475 /*+ Updates : Date Purpose */ 00476 /* */ 00477 /*1- C Main ****************+******************************************/ 00478 INTS4 f_his_wait(INTS4 *pl_action, CHARS *pc_histo) 00479 { 00480 INTS4 *pl_l,i_j,i_l,ll,l_buffer,l_status; 00481 /* Wait for client to connect */ 00482 if(l_gl_serv_verb == 1) {printf("Waiting for client on port %d [%s] \n",l_gl_serv_port,c_gl_serv_access);} 00483 l_status = f_stc_acceptclient (ps_tcpserv, &l_gl_serv_chan); 00484 if(l_status != STC__SUCCESS) { printf("error accepting client\n"); return(COMM__ERROR);} 00485 if(l_gl_serv_verb == 1) {printf("Client connected. \n");} 00486 l_status = f_stc_read (&s_his_comm_serv,sizeof(s_his_comm),l_gl_serv_chan,-1); 00487 if(l_status != STC__SUCCESS) { printf("error reading client\n"); f_stc_discclient(l_gl_serv_chan);return(COMM__ERROR); } 00488 /* check access */ 00489 f_his_toupper(s_his_comm_serv.c_access,sizeof(s_his_comm_serv.c_access)); 00490 f_his_toupper(s_his_comm_serv.c_base,sizeof(s_his_comm_serv.c_base)); 00491 if((strlen(c_gl_serv_access) != 0) & 00492 (strcmp(s_his_comm_serv.c_access,c_gl_serv_access) != 0)) 00493 { 00494 printf("Client connected with wrong password [%s]. \n",s_his_comm_serv.c_access); 00495 s_his_comm_serv.lu_endian=1; 00496 s_his_comm_serv.lu_size=0; 00497 s_his_comm_serv.lu_histos=0; 00498 s_his_comm_serv.l_status=COMM__NOACCESS; 00499 l_status = f_stc_write (&s_his_comm_serv,sizeof(s_his_comm), l_gl_serv_chan); 00500 f_stc_discclient (l_gl_serv_chan); 00501 return(COMM__NOACCESS); 00502 } 00503 /* check base name */ 00504 if(strcmp(s_his_comm_serv.c_base,c_gl_serv_base) != 0) 00505 { 00506 printf("Client connected for wrong base [%s]. \n",s_his_comm_serv.c_base); 00507 s_his_comm_serv.lu_endian=1; 00508 s_his_comm_serv.lu_size=0; 00509 s_his_comm_serv.lu_histos=0; 00510 s_his_comm_serv.l_status=COMM__NOBASE; 00511 l_status = f_stc_write (&s_his_comm_serv,sizeof(s_his_comm), l_gl_serv_chan); 00512 f_stc_discclient (l_gl_serv_chan); 00513 return(COMM__NOBASE); 00514 } 00515 if(s_his_comm_serv.lu_endian > 100) l_status = f_swaplw((INTS4 *)&s_his_comm_serv,5,NULL); 00516 if(l_gl_serv_verb == 1) {printf("%d: %d %d %d %d %d \"%s\" \"%s\" \"%s\"\n",l_status 00517 ,s_his_comm_serv.lu_endian 00518 ,s_his_comm_serv.lu_action 00519 ,s_his_comm_serv.lu_histos 00520 ,s_his_comm_serv.lu_size 00521 ,s_his_comm_serv.l_status 00522 ,s_his_comm_serv.c_access 00523 ,s_his_comm_serv.c_base 00524 ,s_his_comm_serv.c_histo);} 00525 *pl_action=s_his_comm_serv.lu_action; 00526 strcpy(pc_histo,s_his_comm_serv.c_histo); 00527 return(COMM__SUCCESS); 00528 } 00529 00530 /*1+ C Procedure ***********+******************************************/ 00531 /* */ 00532 /*+ Module : f_his_senddir */ 00533 /* */ 00534 /*--------------------------------------------------------------------*/ 00535 /*+ CALLING : l=f_his_senddir(s_his_head *ps_head, int l_histos) */ 00536 /*--------------------------------------------------------------------*/ 00537 /* */ 00538 /*+ PURPOSE : Send list of available histogram */ 00539 /* */ 00540 /*+ ARGUMENTS : */ 00541 /* */ 00542 /*+ ps_head : Address of header list. */ 00543 /*+ l_histos : Number of histograms */ 00544 /* */ 00545 /*+ Return type : int. */ 00546 /*- COMM__SUCCESS : OK */ 00547 /*- COMM__ERROR : Error */ 00548 /*- COMM__NOHIST : Histogram not there */ 00549 /* */ 00550 /*2+DESCRIPTION***+***********+****************************************/ 00551 /* */ 00552 /*+ FUNCTION : Send list of s_his_head to client. */ 00553 /* */ 00554 /*2+IMPLEMENTATION************+****************************************/ 00555 /* */ 00556 /*+ File name : f_his_hist.c */ 00557 /*+ Version : 1.01 */ 00558 /*+ Author : Hans Essel */ 00559 /*+ Created : 21-May-2000 */ 00560 /*+ Updates : Date Purpose */ 00561 /* */ 00562 /*1- C Main ****************+******************************************/ 00563 INTS4 f_his_senddir(s_his_head *ps_head, INTS4 l_histos) 00564 { 00565 INTS4 *pl_l,i_j,i_l,ll,l_buffer,l_status; 00566 00567 if(l_gl_serv_verb == 1) {printf("Send directory %s. \n",s_his_comm_serv.c_histo);} 00568 s_his_comm_serv.lu_histos=l_histos; 00569 s_his_comm_serv.lu_endian=1; 00570 s_his_comm_serv.lu_action=COMM__PUTDIR; 00571 s_his_comm_serv.lu_size=sizeof(s_his_head)*s_his_comm_serv.lu_histos; 00572 s_his_comm_serv.l_status=COMM__SUCCESS; 00573 l_status = f_stc_write (&s_his_comm_serv,sizeof(s_his_comm), l_gl_serv_chan); 00574 if(l_status != STC__SUCCESS) 00575 { printf("error writing comm to client\n"); f_stc_discclient(l_gl_serv_chan);return(COMM__ERROR);} 00576 00577 /* break total buffer in TCP buffers */ 00578 pl_l=(INTS4 *)ps_head; 00579 l_buffer = s_his_comm_serv.lu_size; 00580 i_l=l_buffer/16384; 00581 l_buffer=l_buffer%16384; 00582 for(i_j=0;i_j<i_l;i_j++){l_status = f_stc_write (pl_l,16384,l_gl_serv_chan);pl_l+=4096;} 00583 if(l_buffer > 0) l_status = f_stc_write (pl_l,l_buffer,l_gl_serv_chan); 00584 00585 if(l_status != STC__SUCCESS) 00586 { printf("error writing directory to client\n"); f_stc_discclient(l_gl_serv_chan);return(COMM__ERROR);} 00587 f_stc_discclient (l_gl_serv_chan); 00588 return(COMM__SUCCESS); 00589 } 00590 /*1+ C Procedure ***********+******************************************/ 00591 /* */ 00592 /*+ Module : f_his_sendhis */ 00593 /* */ 00594 /*--------------------------------------------------------------------*/ 00595 /*+ CALLING : l=f_his_sendhis(s_his_head *ps_head, int histos, char *histo, int *data)*/ 00596 /*--------------------------------------------------------------------*/ 00597 /* */ 00598 /*+ PURPOSE : Send histogram */ 00599 /* */ 00600 /*+ ARGUMENTS : */ 00601 /* */ 00602 /*+ ps_head : Address of header list. */ 00603 /*+ histos : Number of histograms */ 00604 /*+ histo : Name of requested histograms */ 00605 /*+ data : Pointer array to histogram data */ 00606 /* */ 00607 /*+ Return type : int. */ 00608 /*- COMM__SUCCESS : OK */ 00609 /*- COMM__ERROR : Error */ 00610 /*- COMM__NOHIST : Histogram not there */ 00611 /* */ 00612 /*2+DESCRIPTION***+***********+****************************************/ 00613 /* */ 00614 /*+ FUNCTION : Send one s_his_head and data to client. */ 00615 /* Histogram is searched by name. */ 00616 /* */ 00617 /*2+IMPLEMENTATION************+****************************************/ 00618 /* */ 00619 /*+ File name : f_his_hist.c */ 00620 /*+ Version : 1.01 */ 00621 /*+ Author : Hans Essel */ 00622 /*+ Created : 21-May-2000 */ 00623 /*+ Updates : Date Purpose */ 00624 /* */ 00625 /*1- C Main ****************+******************************************/ 00626 INTS4 f_his_sendhis(s_his_head *ps_head, INTS4 l_histos, CHARS *pc_histo, INTS4 *pl_data) 00627 { 00628 s_his_head *ps_his_head; 00629 INTS4 *pl_l,i_j,i_l,ll,l_buffer,l_status; 00630 00631 s_his_comm_serv.lu_endian=1; 00632 s_his_comm_serv.lu_histos=0; 00633 s_his_comm_serv.lu_action=COMM__PUTHIST; 00634 ps_his_head = ps_head; 00635 for(ll=0;ll<l_histos;ll++) 00636 { 00637 pl_l = pl_data; 00638 if(strcmp(ps_his_head->c_name,pc_histo) == 0) 00639 { 00640 s_his_comm_serv.lu_histos=1; 00641 s_his_comm_serv.l_status=COMM__SUCCESS; 00642 s_his_comm_serv.lu_size=sizeof(s_his_head)+ps_his_head->l_bins_1 * ps_his_head->l_bins_2 * 4; 00643 l_status = f_stc_write (&s_his_comm_serv,sizeof(s_his_comm), l_gl_serv_chan); 00644 if(l_status != STC__SUCCESS) 00645 { printf("error writing comm to client\n"); f_stc_discclient(l_gl_serv_chan); return(COMM__ERROR);} 00646 if(l_gl_serv_verb == 1) {printf("%-32s %8d\n",ps_his_head->c_name,s_his_comm_serv.lu_size-sizeof(s_his_head));} 00647 l_status = f_stc_write (ps_his_head,sizeof(s_his_head), l_gl_serv_chan); 00648 if(l_status != STC__SUCCESS) 00649 { printf("error writing header to client\n"); f_stc_discclient(l_gl_serv_chan); return(COMM__ERROR); } 00650 00651 /* break total buffer in TCP buffers */ 00652 l_buffer = s_his_comm_serv.lu_size-sizeof(s_his_head); 00653 i_l=l_buffer/16384; 00654 l_buffer=l_buffer%16384; 00655 for(i_j=0;i_j<i_l;i_j++){l_status = f_stc_write (pl_l,16384,l_gl_serv_chan);pl_l+=4096;} 00656 if(l_buffer > 0) l_status = f_stc_write (pl_l,l_buffer,l_gl_serv_chan); 00657 if(l_status != STC__SUCCESS) 00658 { printf("error writing data to client\n"); f_stc_discclient(l_gl_serv_chan); return(COMM__ERROR); } 00659 break; 00660 } /* found */ 00661 ps_his_head++; 00662 } /* loop */ 00663 if(s_his_comm_serv.lu_histos == 0) 00664 { 00665 if(l_gl_serv_verb == 1) {printf("Histogram %s not found\n",pc_histo);} 00666 s_his_comm_serv.l_status=COMM__NOHIST; 00667 s_his_comm_serv.lu_size=0; 00668 l_status = f_stc_write (&s_his_comm_serv,sizeof(s_his_comm), l_gl_serv_chan); 00669 if(l_status != STC__SUCCESS) 00670 { printf("error writing comm to client\n"); f_stc_discclient(l_gl_serv_chan); return(COMM__ERROR); } 00671 f_stc_discclient (l_gl_serv_chan); 00672 return(COMM__NOHIST); 00673 } 00674 f_stc_discclient (l_gl_serv_chan); 00675 return(COMM__SUCCESS); 00676 } 00677 /*1+ C Procedure ***********+******************************************/ 00678 /* */ 00679 /*+ Module : f_his_close */ 00680 /* */ 00681 /*--------------------------------------------------------------------*/ 00682 /*+ CALLING : l=f_his_close() */ 00683 /*--------------------------------------------------------------------*/ 00684 /* */ 00685 /*+ PURPOSE : Stop server, close sockets */ 00686 /* */ 00687 /*+ ARGUMENTS : */ 00688 /* */ 00689 /*+ Return type : int. */ 00690 /*- COMM__SUCCESS : OK */ 00691 /*- COMM__ERROR : Error */ 00692 /* */ 00693 /*2+DESCRIPTION***+***********+****************************************/ 00694 /* */ 00695 /*+ FUNCTION : Stop server, close sockets . */ 00696 /* */ 00697 /*2+IMPLEMENTATION************+****************************************/ 00698 /* */ 00699 /*+ File name : f_his_hist.c */ 00700 /*+ Version : 1.01 */ 00701 /*+ Author : Hans Essel */ 00702 /*+ Created : 21-May-2000 */ 00703 /*+ Updates : Date Purpose */ 00704 /* */ 00705 /*1- C Main ****************+******************************************/ 00706 INTS4 f_his_close() 00707 { 00708 printf("Exit histogram server\n"); 00709 f_stc_close (ps_tcpserv); 00710 free(ps_tcpserv); 00711 return(COMM__SUCCESS); 00712 }
