]> Pileus Git - ~andy/rsl/blob - nsig_to_radar.c
6ce808183a7f0c14db53f6a04312a3039a244eb6
[~andy/rsl] / nsig_to_radar.c
1 /*
2     NASA/TRMM, Code 910.1.
3     This is the TRMM Office Radar Software Library.
4     Copyright (C) 1996  Paul A. Kucera of Applied Research Corporation,
5                         Landover, Maryland, a NASA/GSFC on-site contractor.
6
7     This library is free software; you can redistribute it and/or
8     modify it under the terms of the GNU Library General Public
9     License as published by the Free Software Foundation; either
10     version 2 of the License, or (at your option) any later version.
11
12     This library is distributed in the hope that it will be useful,
13     but WITHOUT ANY WARRANTY; without even the implied warranty of
14     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15     Library General Public License for more details.
16
17     You should have received a copy of the GNU Library General Public
18     License along with this library; if not, write to the Free
19     Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20         */
21 /*************************************************************/
22 /*                                                           */
23 /*    Function: nsig_to_radar.c                              */
24 /*                                                           */
25 /*    Paul A. Kucera                                         */
26 /*    Applied Research Corporation                           */
27 /*    NASA/GSFC                                              */
28 /*    TRMM/Code 910.1                                        */
29 /*                                                           */
30 /*    Modifications by:                                      */
31 /*    John H. Merritt                                        */
32 /*    Space Applications Corporation                         */
33 /*    NASA/GSFC                                              */
34 /*    TRMM/Code 910.1                                        */
35 /*                                                           */
36 /*    Started: 08 AUG 96                                     */
37 /*                                                           */
38 /*    Derived from Paul Kucera's nsig_to_radar.c             */
39 /*    Copyright 1996                                         */
40 /*************************************************************/
41
42 #include<stdio.h>
43 #include<unistd.h>
44 #include<sys/types.h>
45 #include<sys/stat.h>
46 #include<fcntl.h>
47 #include<stdlib.h>
48 #include<math.h>
49 #include<string.h>
50
51 #include"nsig.h"
52 #include"rsl.h"
53
54 extern int radar_verbose_flag;
55 extern int rsl_qfield[]; /* See RSL_select_fields */
56
57    /*  We need this entry for various things esp in Ray_header  */
58 #define MISSING_HEADER_DATA -9999
59    /*  The following is speed of light _in_ _air_ !  */
60 #define SPEED_OF_LIGHT 299702547
61 #define MIT_BEAMWIDTH      1.65
62 #define TOG_BEAMWIDTH      1.65
63 #define KWA_BEAMWIDTH      1.0
64 #define DEFAULT_BEAMWIDTH  1.0
65 #define NSIG_NO_DATA       -1
66 #define MAX_NSIG_SWEEPS    30
67 #define MAX_NSIG_RAYS      400
68 #define NSIG_NO_ECHO       -32.0
69 #define NSIG_NO_ECHO2     -999.0
70
71 static float (*f)(Range x);
72 static Range (*invf)(float x);
73
74 extern FILE *file;
75
76 void  get_extended_header_info(NSIG_Sweep **nsig_sweep, int xh_size, int iray,
77                                int nparams,
78                                int *msec, float *azm, float *elev,
79                                float *pitch, float *roll, float *heading,
80                                float *azm_rate, float *elev_rate,
81                                float *pitch_rate, float *roll_rate,
82                                float *heading_rate,
83                                float *lat, float *lon, int *alt, float *rvc,
84                                float *vel_east, float *vel_north, float *vel_up)
85 {
86   static NSIG_Ext_header_ver1 xh;
87   int data_type, itype;
88
89   *msec = *azm = *elev = *pitch = *roll = *heading =
90         *azm_rate = *elev_rate = *pitch_rate = *roll_rate = *heading_rate =
91         *lat = *lon = *alt = *rvc = 0;
92
93   /* Determine where 'itype' for extended header is. */
94   for (itype = 0; itype<nparams; itype++) {
95         data_type = NSIG_I2(nsig_sweep[itype]->idh.data_type);
96     if (data_type == NSIG_DTB_EXH) break;
97   }
98   /*  printf("...extended header itype=%d, nparams=%d\n", itype, nparams); */
99   if (itype == nparams) return;  /* No extended header. */
100
101   /* Version 1. */
102   if (nsig_sweep[itype]->ray[iray] == NULL) return;
103   if (nsig_sweep[itype]->ray[iray]->range == NULL) return;
104   memmove(&xh, nsig_sweep[itype]->ray[iray]->range, sizeof(xh));
105   *msec = NSIG_I4(xh.msec);
106   /*   printf("...extended header msec= %d\n", *msec); */
107   if (xh_size <= 20) /* Stop, only have version 0. */
108     return;
109
110   /* Version 1 processing. */
111   *azm = nsig_from_bang(xh.azm);
112   *elev = nsig_from_bang(xh.elev);
113   *pitch = nsig_from_bang(xh.pitch);
114   *roll   = nsig_from_bang(xh.roll);
115   *heading = nsig_from_bang(xh.heading);
116   *azm_rate = nsig_from_bang(xh.azm_rate);
117   *elev_rate = nsig_from_bang(xh.elev_rate);
118   *pitch_rate = nsig_from_bang(xh.pitch_rate);
119   *roll_rate   = nsig_from_bang(xh.roll_rate);
120 #ifdef NSIG_VER2
121
122 #else
123   *heading_rate = nsig_from_bang(xh.heading_rate);
124 #endif
125   *lat = nsig_from_fourb_ang(xh.lat);
126   *lon = nsig_from_fourb_ang(xh.lon);
127   if(*lat > 180.0) *lat -= 360.0;
128   if(*lon > 180.0) *lon -= 360.0;
129   *alt       = NSIG_I2(xh.alt);
130   *rvc       = NSIG_I2(xh.rad_vel_cor)/100.0; /* cm to m */
131   *vel_east  = NSIG_I2(xh.vel_e)/100.0; /* cm to m */
132   *vel_north = NSIG_I2(xh.vel_n)/100.0; /* cm to m */
133   *vel_up    = NSIG_I2(xh.vel_u)/100.0; /* cm to m */
134   return;
135 }
136
137 /** Main code **/
138 Radar *
139 #ifdef NSIG_VER2
140 RSL_nsig2_to_radar
141 #else
142 RSL_nsig_to_radar
143 #endif
144 (char *filename)
145 {
146   FILE *fp;
147   /* RSL structures */
148   Radar                    *radar;
149   Ray                      *ray;
150   
151   int i, j, k, n;
152   int year, month, day;
153   int hour, minute, sec;
154   int numbins, numsweep;
155   int num_rays, sea_lvl_hgt;
156   int radar_number, num_samples;
157   int latd, latm, lats, lond, lonm, lons;
158   int data_type;
159   int bin_num;
160   int sweep_year, sweep_day, sweep_month;
161   int sweep_hour, sweep_minute, sweep_second;
162   int sweep_sec;
163   int z_flag_unc, z_flag_cor, v_flag, w_flag, speckle;
164   int ant_scan_mode;
165   float second;
166   float pw;
167   float bin_space;
168   float prf, prf2, wave, beam_width;
169   int prf_mode;
170   float prf_modes[] = {1.0, 2.0/3.0, 3.0/4.0, 4.0/5.0};
171   float vert_half_bw, horz_half_bw;
172   float rng_last_bin;
173   float rng_first_bin, freq;
174   float max_vel, sweep_rate, azim_rate;
175   float ray_data;
176   float az1, az2;
177   double tmp;
178   float sqi, log, csr, sig, cal_dbz;
179   char radar_type[50], state[2], city[15];
180   char site_name[16];
181   NSIG_Product_file *prod_file;
182   short id;
183   int data_mask, nrays;
184   int masks[5];
185   int nparams, nsweeps;
186   NSIG_Sweep **nsig_sweep;
187   NSIG_Ray *ray_p;
188   int itype, ifield;
189   unsigned short nsig_2byte;   /* New for 2-byte data types, Aug 2009 */
190   twob nsig_twob;
191   Sweep *sweep;
192   int msec;
193   float azm, elev, pitch, roll, heading, azm_rate, elev_rate,
194     pitch_rate, roll_rate, heading_rate,
195     lat, lon;
196   int alt;  /* Altitude */
197   float rvc;  /* Radial correction velocity m/s */
198   float vel_east, vel_north, vel_up; /* Platform velocity vectors m/sec */
199   int xh_size;
200   float incr;
201   extern int *rsl_qsweep; /* See RSL_read_these_sweeps in volume.c */
202   extern int rsl_qsweep_max;
203   extern float rsl_kdp_wavelen;
204
205   radar = NULL;
206   if (radar_verbose_flag)
207     fprintf(stderr, "open file: %s\n", filename);
208   
209   /** Opening nsig file **/
210   if((fp = nsig_open(filename)) == NULL) return NULL;
211   
212 #ifdef NSIG_VER2
213   sprintf(radar_type, "nsig2");
214   radar_number = 22;  /** Arbitrary number given to nsig2 data **/
215 #else
216   sprintf(radar_type, "nsig");
217   radar_number = 21;  /* What are these suppose to be? */
218 #endif
219   sprintf(state,"NA");
220   sprintf(city,"NA");
221   
222   /* MAINLINE CODE */
223   
224   prod_file = (NSIG_Product_file *)calloc(1, sizeof(NSIG_Product_file));
225
226   n = nsig_read_record(fp, (char *)&prod_file->rec1);
227   nsig_endianess(&prod_file->rec1);
228   if (radar_verbose_flag)
229     fprintf(stderr, "Read %d bytes for rec1.\n", n);
230
231   id = NSIG_I2(prod_file->rec1.struct_head.id);
232   if (radar_verbose_flag)
233     fprintf(stderr, "ID = %d\n", (int)id);
234   if (id != 7 && id != 27) { /* testing: Use 27 for Version 2 data */
235     fprintf(stderr, "File is not a SIGMET version 1 nor version 2 raw product file.\n");
236     return NULL;
237   }
238
239   n = nsig_read_record(fp, (char *)&prod_file->rec2);
240   if (radar_verbose_flag)
241     fprintf(stderr, "Read %d bytes for rec2.\n", n);
242
243    /** Test for scan mode -- If scan is a RHI will return NULL  **/
244    /** because RSL can't handle RHI's.  In the future, replace  **/
245    /** NULL will a routine to convert RHI's to RSL Format       **/
246    ant_scan_mode =NSIG_I2(prod_file->rec2.task_config.scan_info.ant_scan_mode);
247    if(ant_scan_mode == 2)
248       {
249       if (radar_verbose_flag)
250       fprintf(stderr, "RHI scan detected. Unable to process, returning NULL.\n");
251       /*      return NULL; */
252       }
253   
254   /* Count the bits set in 'data_mask' to determine the number
255    * of parameters present.
256    */
257   xh_size = NSIG_I2(prod_file->rec2.ingest_head.size_ext_ray_headers);
258   nrays = NSIG_I2(prod_file->rec2.ingest_head.num_rays);
259   if (radar_verbose_flag)
260     fprintf(stderr, "Expecting %d rays in each sweep.\n", nrays);
261 #ifdef NSIG_VER2 
262   memmove(&masks[0], prod_file->rec2.task_config.dsp_info.data_mask_cur.mask_word_0,
263     sizeof(fourb));
264   memmove(&masks[1], &prod_file->rec2.task_config.dsp_info.data_mask_cur.mask_word_1,
265     4*sizeof(fourb));
266   nparams = 0;
267   for (j=0; j < 5; j++) {
268     data_mask = masks[j];
269     for (i=0; i<32; i++)
270       nparams += (data_mask >> i) & 0x1;
271   }
272 #else
273   memmove(&data_mask, prod_file->rec2.task_config.dsp_info.data_mask, sizeof(fourb));
274   for (nparams=i=0; i<32; i++)
275     nparams += (data_mask >> i) & 0x1;
276 #endif
277
278   /* Number of sweeps */
279   nsweeps = NSIG_I2(prod_file->rec2.task_config.scan_info.num_swp);
280   
281
282
283    memmove(site_name, prod_file->rec1.prod_end.site_name, sizeof(prod_file->rec1.prod_end.site_name));
284    site_name[sizeof(site_name)-1] = '\0';
285   if (radar_verbose_flag) {
286     fprintf(stderr, "nparams = %d, nsweeps = %d\n", nparams, nsweeps);
287     fprintf(stderr, "Site name = <%s>\n", site_name);
288   }
289
290     /* nsig_sweep = nsig_read_sweep(fp, prod_file)
291      *
292      * Use: nsig_sweep[i]->ray[j]->range
293      *
294      * where 'range' is [0..nbins-1]
295      */
296
297     /*
298      * All the information you need is in:
299      *    prod_file->rec1
300      *        .struct_head, .prod_config .prod_end
301      *    prod_file->rec2
302      *        .struct_head, .ingest_head, .task_config .device_stat,
303      *        .dsp1, .dsp2
304      *    nsig_sweep[0..nparams-1]  'nparams' is the true number
305      *                              of parameters present.  You
306      *                              must check the 'id' (or type)
307      *                              to determine the field type.
308      *                              So far seen, nparams <= 6.
309      *    nsig_sweep[i]->bhdr     <NSIG_Raw_prod_bhdr>
310      *    nsig_sweep[i]->idh      <NSIG_Ingest_data_header>
311      *    nsig_sweep[i]->ray[j]   <NSIG_Ray *>
312      *
313      * Note:
314      *    For extended header access, you'll typically use nsig_sweep[0]
315      *    (double check the id) and the ray data allocated (nsig_ray->range)
316      *    is a pointer to the extended header, either v0 or v1.
317      *    You can typecast the pointer to NSIG_Ext_header_ver0 or
318      *    NSIG_Ext_header_ver1, as you like.  To determine which
319      *    version of the extended headers you have use:
320      *      xh_size <= 20 for version 0, else version 1.
321      *    Access:
322      *      xh_size = NSIG_I2(prod_file->rec2.ingest_head.size_ext_ray_headers)
323      *    
324      * Functions:
325      *    NSIG_I2(nsig_sweep[i]->idh.num_rays_act);   -- # of rays. (j)
326      *    NSIG_I2(nsig_sweep[i]->ray[j]->h.num_bins); -- # of bins in a ray.
327      *
328      *    NSIG_I2(x), NSIG_I4(x)   - Convert data, x, to floating point.
329      *
330      *    IMPORTANT NOTE: It must be known whether or not to perform
331      *                    byte-swapping.  To determine this, call
332      *                    'nsig_endianess'.  It returns 0 for no-swapping
333      *                    and 1 for swapping.  Additionally, it transparently
334      *                    initializes the nsig library to automatically
335      *                    swap when using NSIG_I2 or NSIG_I4.
336      *                    The function 'nsig_read_sweep' automatically
337      *                    calls 'nsig_endianess', too.
338      */
339
340    sea_lvl_hgt = NSIG_I2(prod_file->rec1.prod_end.grnd_sea_ht);
341
342    if (radar_verbose_flag)
343      fprintf(stderr, "sea: %d\n", sea_lvl_hgt);
344    if (radar_verbose_flag)
345      fprintf(stderr, "site_name: %s", site_name);
346    
347    /** Determine beamwidth from input variables (not saved in nsig file) **/
348    if(strncmp(site_name,"mit",3) == 0 || strncmp(site_name,"MIT",3) == 0)
349      beam_width = MIT_BEAMWIDTH;
350    else if(strncmp(site_name,"tog",3) == 0 || strncmp(site_name,"TOG",3) == 0)
351      beam_width = TOG_BEAMWIDTH;
352    else if(strncmp(site_name,"kwa",3) == 0 || strncmp(site_name,"KWA",3) == 0)
353      beam_width = KWA_BEAMWIDTH;
354    else
355      beam_width = DEFAULT_BEAMWIDTH;
356
357    if (radar_verbose_flag)
358      fprintf(stderr, "beamwidth: %f\n", beam_width);
359    
360    vert_half_bw = beam_width/2.0;
361    horz_half_bw = beam_width/2.0;
362    
363    /** Reading date and time **/
364    month = NSIG_I2(prod_file->rec2.ingest_head.start_time.month);
365    year = NSIG_I2(prod_file->rec2.ingest_head.start_time.year);
366    day = NSIG_I2(prod_file->rec2.ingest_head.start_time.day);
367    sec = NSIG_I4(prod_file->rec2.ingest_head.start_time.sec);
368
369    /* converting seconds since mid to time of day */
370    tmp = sec/3600.0;
371    hour = (int)tmp;
372    tmp = (tmp - hour) * 60.0;
373    minute = (int)tmp;
374    second = (tmp - minute) * 60.0;
375
376    /** records of the nsig file.                             **/
377    num_rays = 0;
378    pw = (NSIG_I4(prod_file->rec1.prod_end.pulse_wd))/100.0; /* pulse width */
379    prf = NSIG_I4(prod_file->rec1.prod_end.prf);  /* pulse repetition frequency */
380    prf_mode = NSIG_I2(prod_file->rec2.task_config.dsp_info.prf_mode);
381    prf2 = prf * prf_modes[prf_mode];
382    wave = (NSIG_I4(prod_file->rec1.prod_end.wavelen))/100.0; /* wavelength (cm) */
383    rsl_kdp_wavelen = wave;  /* EXTERNAL (volume.c) This sets KD_F and KD_INVF
384                              * to operate with the proper wavelength.
385                              */
386    numbins = NSIG_I4(prod_file->rec1.prod_end.num_bin);   /* # bins in ray */
387    rng_first_bin = (float)NSIG_I4(prod_file->rec1.prod_end.rng_f_bin)/100.0;
388    rng_last_bin = (float)NSIG_I4(prod_file->rec1.prod_end.rng_l_bin)/100.0;
389    bin_space = ((rng_last_bin-rng_first_bin)/numbins); /*rng res (m)*/
390    
391    numsweep = NSIG_I2(prod_file->rec2.task_config.scan_info.num_swp); /* # sweeps in volume */
392    num_samples = NSIG_I2(prod_file->rec1.prod_end.num_samp);
393    sweep_rate = 3.0; /** Approximate value -- info not stored **/
394    azim_rate = sweep_rate*360.0/60.0;
395    if (prf_mode != 0)
396    {
397         float max_vel1 = wave*prf/(100.0*4.0);
398         float max_vel2 = wave*prf2/(100.0*4.0);
399
400         max_vel = (max_vel1 * max_vel2)/(max_vel1-max_vel2);
401    }
402    else 
403    {
404         max_vel = wave*prf/(100.0*4.0);
405    }
406
407    freq = (299793000.0/wave)*1.0e-4; /** freq in MHZ **/
408
409    sqi = NSIG_I2(prod_file->rec2.task_config.calib_info.sqi)/256.0;
410    log = NSIG_I2(prod_file->rec2.task_config.calib_info.noise)/16.0;
411    csr = NSIG_I2(prod_file->rec2.task_config.calib_info.clutr_corr)/(-16.0);
412    sig = NSIG_I2(prod_file->rec2.task_config.calib_info.power)/16.0;
413    cal_dbz = NSIG_I2(prod_file->rec2.task_config.calib_info.cal_ref)/16.0;
414    z_flag_unc = NSIG_I2(prod_file->rec2.task_config.calib_info.z_flag_unc);
415    z_flag_cor = NSIG_I2(prod_file->rec2.task_config.calib_info.z_flag_cor);
416    v_flag = NSIG_I2(prod_file->rec2.task_config.calib_info.v_flag);
417    w_flag = NSIG_I2(prod_file->rec2.task_config.calib_info.w_flag);
418    speckle = NSIG_I2(prod_file->rec2.task_config.calib_info.speckle);
419
420    /** Verbose calibration information **/
421    if (radar_verbose_flag)
422       {
423       fprintf(stderr, "LOG = %5.2f\n", log);
424       fprintf(stderr, "SQI = %5.2f\n", sqi);
425       fprintf(stderr, "CSR = %5.2f\n", csr);
426       fprintf(stderr, "SIG = %5.2f\n", sig);
427       fprintf(stderr, "Calibration reflectivity: %5.2f dBZ\n", cal_dbz);
428       fprintf(stderr, "ZT flags: %d\n", z_flag_unc);  /** can find these **/
429       fprintf(stderr, "DZ flags: %d\n", z_flag_cor);  /** defn in the    **/
430       fprintf(stderr, "VR flags: %d\n", v_flag);      /** SIGMET Doc     **/
431       fprintf(stderr, "SW flags: %d\n", w_flag);
432       fprintf(stderr, "Flags: -3856  = SQI thresholding\n");
433       fprintf(stderr, "       -21846 = LOG thresholding\n");
434       fprintf(stderr, "       -24416 = LOG & SQI thresholding\n");
435       fprintf(stderr, "       -24516 = LOG & SQI & SIG thresholding\n");
436       fprintf(stderr, "speckle remover: %d\n", speckle);
437       }
438    
439    if (radar_verbose_flag)
440      fprintf(stderr, "vel: %f prf: %f prf2: %f\n", max_vel, prf, prf2);
441    
442    /** Extracting Latitude and Longitude from nsig file **/
443    lat = nsig_from_fourb_ang(prod_file->rec2.ingest_head.lat_rad);
444    lon = nsig_from_fourb_ang(prod_file->rec2.ingest_head.lon_rad);
445    if(lat > 180.0) lat -= 360.0;
446    if(lon > 180.0) lon -= 360.0;
447    if (radar_verbose_flag)
448      fprintf(stderr, "nsig_to_radar: lat %f, lon %f\n", lat, lon);
449    /** Latitude deg, min, sec **/
450    latd = (int)lat;
451    tmp = (lat - latd) * 60.0;
452    latm = (int)tmp;
453    lats = (int)((tmp - latm) * 60.0);
454    /** Longitude deg, min, sec **/
455    lond = (int)lon;
456    tmp = (lon - lond) * 60.0;
457    lonm = (int)tmp;
458    lons = (int)((tmp - lonm) * 60.0);
459    
460    /** Allocating memory for radar structure **/
461    radar = RSL_new_radar(MAX_RADAR_VOLUMES);
462    if (radar == NULL) 
463       {
464       fprintf(stderr, "nsig_to_radar: radar is NULL\n");
465       return NULL;
466       }
467
468    /** Filling Radar Header **/
469    radar->h.month = month;
470    radar->h.day = day;
471    radar->h.year = year; /* Year 2000 compliant. */
472    radar->h.hour = hour;
473    radar->h.minute = minute;
474    radar->h.sec = second;
475    sprintf(radar->h.radar_type, "%s", radar_type);
476    radar->h.number = radar_number;
477    memmove(radar->h.name, site_name, sizeof(radar->h.name));
478    memmove(radar->h.radar_name, site_name, sizeof(radar->h.radar_name));
479    memmove(radar->h.city, city, sizeof(radar->h.city));
480    memmove(radar->h.state, state, sizeof(radar->h.state));
481    radar->h.latd = latd;
482    radar->h.latm = latm;
483    radar->h.lats = lats;
484    radar->h.lond = lond;
485    radar->h.lonm = lonm;
486    radar->h.lons = lons;
487    radar->h.height = (int)sea_lvl_hgt;
488    radar->h.spulse = (int)(pw*1000);
489    radar->h.lpulse = (int)(pw*1000);
490
491    if (radar_verbose_flag) {
492 #ifdef NSIG_VER2
493      fprintf(stderr, "\nSIGMET version 2 raw product file.\n");
494 #else
495      fprintf(stderr, "\nSIGMET version 1 raw product file.\n");
496 #endif
497      fprintf(stderr, "Date: %2.2d/%2.2d/%4.4d %2.2d:%2.2d:%f\n",
498              radar->h.month, radar->h.day, radar->h.year,
499              radar->h.hour, radar->h.minute, radar->h.sec);
500      fprintf(stderr, "Name: ");
501      for (i=0; i<sizeof(radar->h.name); i++)
502        fprintf(stderr, "%c", radar->h.name[i]);
503      fprintf(stderr, "\n");
504      fprintf(stderr, "Lat/lon (%d %d' %d'', %d %d' %d'')\n",
505              radar->h.latd, radar->h.latm, radar->h.lats,
506              radar->h.lond, radar->h.lonm, radar->h.lons);
507    }
508
509    /** Converting data **/
510    if (radar_verbose_flag) fprintf(stderr, "Expecting %d sweeps.\n", numsweep);
511    for(i = 0; i < numsweep; i++)
512       {
513         nsig_sweep = nsig_read_sweep(fp, prod_file);
514         if (nsig_sweep == NULL) { /* EOF possibility */
515           if (feof(fp)) break;
516           else continue;
517         }
518         if (rsl_qsweep != NULL) {
519           if (i > rsl_qsweep_max) break;
520           if (rsl_qsweep[i] == 0) continue;
521         }
522         if (radar_verbose_flag)
523           fprintf(stderr, "Read sweep # %d\n", i);
524     /* The whole sweep is 'nsig_sweep' ... pretty slick.
525          *
526          * nsig_sweep[itype]  -- [0..nparams], if non-null.
527          */
528     for (itype=0; itype<nparams; itype++) {
529       if (nsig_sweep[itype] == NULL) continue;
530           
531       /** Reading date and time **/
532       sweep_month = NSIG_I2(nsig_sweep[itype]->idh.time.month);
533       sweep_year = NSIG_I2(nsig_sweep[itype]->idh.time.year);
534       sweep_day = NSIG_I2(nsig_sweep[itype]->idh.time.day);
535       sweep_sec = NSIG_I4(nsig_sweep[itype]->idh.time.sec);
536 #ifdef NSIG_VER2
537       msec      = NSIG_I2(nsig_sweep[itype]->idh.time.msec);
538       /*      printf("....... msec == %d\n", msec); */
539 #endif
540       /* converting seconds since mid to time of day */
541       tmp = sweep_sec/3600.0;
542       sweep_hour = (int)tmp;
543       tmp = (tmp - sweep_hour) * 60.0;
544       sweep_minute = (int)tmp;
545       sweep_second = sweep_sec - (sweep_hour*3600 + sweep_minute*60);
546
547       num_rays = NSIG_I2(nsig_sweep[itype]->idh.num_rays_exp);
548
549       data_type = NSIG_I2(nsig_sweep[itype]->idh.data_type);
550
551       ifield = 0;
552       switch (data_type) {
553       case NSIG_DTB_EXH: 
554           ifield = -1; 
555           break;
556       case NSIG_DTB_UCR:
557       case NSIG_DTB_UCR2:
558         ifield = ZT_INDEX;
559         f      = ZT_F; 
560         invf   = ZT_INVF;
561         break;
562       case NSIG_DTB_CR:
563       case NSIG_DTB_CR2:
564         ifield = DZ_INDEX;
565         f      = DZ_F; 
566         invf   = DZ_INVF;
567         break;
568       case NSIG_DTB_VEL:
569       case NSIG_DTB_VEL2:
570         ifield = VR_INDEX;
571         f      = VR_F; 
572         invf   = VR_INVF;
573         break;
574       case NSIG_DTB_WID:
575       case NSIG_DTB_WID2:
576         ifield = SW_INDEX;
577         f      = SW_F; 
578         invf   = SW_INVF;
579         break;
580       case NSIG_DTB_ZDR:             
581       case NSIG_DTB_ZDR2:
582         ifield = DR_INDEX;
583         f      = DR_F; 
584         invf   = DR_INVF;
585         break;
586       case NSIG_DTB_KDP:
587         ifield = KD_INDEX;
588         f      = KD_F; 
589         invf   = KD_INVF;
590         break;
591       case NSIG_DTB_PHIDP:     /* SRB 990127 */
592         ifield = PH_INDEX;
593         f      = PH_F; 
594         invf   = PH_INVF;
595         break;
596       case NSIG_DTB_RHOHV:     /* SRB 000414 */
597         ifield = RH_INDEX;
598         f      = RH_F; 
599         invf   = RH_INVF;
600         break;
601       case NSIG_DTB_VELC:
602       case NSIG_DTB_VELC2:
603         ifield = VC_INDEX;
604         f      = VC_F; 
605         invf   = VC_INVF;
606         break;
607       case NSIG_DTB_KDP2:
608         ifield = KD_INDEX;
609         f      = KD_F; 
610         invf   = KD_INVF;
611         break;
612       case NSIG_DTB_PHIDP2:
613         ifield = PH_INDEX;
614         f      = PH_F; 
615         invf   = PH_INVF;
616         break;
617       case NSIG_DTB_RHOHV2:
618         ifield = RH_INDEX;
619         f      = RH_F; 
620         invf   = RH_INVF;
621         break;
622       case NSIG_DTB_SQI:
623       case NSIG_DTB_SQI2:
624         ifield = SQ_INDEX;
625         f      = SQ_F; 
626         invf   = SQ_INVF;
627         break;
628       case NSIG_DTB_HCLASS:
629       case NSIG_DTB_HCLASS2:
630         ifield = HC_INDEX;
631         f      = HC_F; 
632         invf   = HC_INVF;
633       case NSIG_DTB_DBZ2:
634         ifield = CZ_INDEX;
635         f      = CZ_F; 
636         invf   = CZ_INVF;
637       case NSIG_DTB_ZDRC2:
638         ifield = ZD_INDEX;
639         f      = ZD_F; 
640         invf   = ZD_INVF;
641         break;
642       default:
643         fprintf(stderr,"Unknown field type: %d  Skipping it.\n", data_type);
644         continue;
645       }
646
647       if (radar_verbose_flag)
648         fprintf(stderr, "     nsig_sweep[%d], data_type = %d, rays(expected) = %d, nrays(actual) = %d\n", itype, data_type, num_rays, NSIG_I2(nsig_sweep[itype]->idh.num_rays_act));
649
650       if (data_type != NSIG_DTB_EXH) {
651         if ((radar->v[ifield] == NULL)) {
652           if (rsl_qfield[ifield]) {
653              radar->v[ifield] = RSL_new_volume(numsweep);
654              radar->v[ifield]->h.f = f;
655              radar->v[ifield]->h.invf = invf;
656            } else {
657              /* Skip this field, because, the user does not want it. */
658              continue;
659            }
660         }
661          if (radar->v[ifield]->sweep[i] == NULL)
662            radar->v[ifield]->sweep[i] = RSL_new_sweep(num_rays);
663          } 
664       else
665       continue;    /* Skip the actual extended header processing.
666                     * This is different than getting it, so that
667                     * the information is available for the other
668                     * fields when filling the RSL ray headers.
669                     */
670
671       /** DATA conversion time **/
672       sweep = radar->v[ifield]->sweep[i];
673       sweep->h.f = f;
674       sweep->h.invf = invf;
675       sweep->h.sweep_num = i;
676       sweep->h.beam_width = beam_width;
677       sweep->h.vert_half_bw = vert_half_bw;
678       sweep->h.horz_half_bw = horz_half_bw;
679       elev = nsig_from_bang(nsig_sweep[itype]->idh.fix_ang);
680       sweep->h.elev = elev;
681       
682       for(j = 0; j < num_rays; j++)
683         {
684           ray_p = nsig_sweep[itype]->ray[j];
685           if (ray_p == NULL) continue;
686           bin_num = NSIG_I2(ray_p->h.num_bins);
687
688           /* Load extended header information, if available.
689            * We need to pass the entire nsig_sweep and search for
690            * the extended header field (it may not be data_type==0).
691            */
692           get_extended_header_info(nsig_sweep, xh_size, j, nparams,
693                        &msec, &azm, &elev,
694                        &pitch, &roll, &heading,
695                        &azm_rate, &elev_rate,
696                        &pitch_rate, &roll_rate, &heading_rate,
697                        &lat, &lon, &alt, &rvc,
698                        &vel_east, &vel_north, &vel_up);
699           
700
701           if (radar->v[ifield]->sweep[i]->ray[j] == NULL)
702             radar->v[ifield]->sweep[i]->ray[j] = RSL_new_ray(bin_num);
703           ray = radar->v[ifield]->sweep[i]->ray[j];
704           ray->h.f = f;
705           ray->h.invf = invf;
706           /** Ray is at nsig_sweep[itype].ray->... **/
707           /** Loading nsig data into data structure **/
708                   
709           ray->h.month  = sweep_month;
710           ray->h.day    = sweep_day;
711           ray->h.year   = sweep_year; /* Year 2000 compliant. */
712           ray->h.hour   = sweep_hour;
713           ray->h.minute = sweep_minute;
714           if (msec == 0) { /* No extended header */
715             ray->h.sec  = NSIG_I2(ray_p->h.sec) + sweep_second;
716             elev = sweep->h.elev;
717           } else
718             ray->h.sec  = sweep_second + msec/1000.0;
719
720           /* add time ... handles end of min,hour,month,year and century. */
721           if (ray->h.sec >= 60) /* Should I fix the time no matter what? */
722             RSL_fix_time(ray);  /* Repair second overflow. */
723
724           ray->h.ray_num    = j;
725           ray->h.elev_num   = i;
726           ray->h.range_bin1 = (int)rng_first_bin;
727           ray->h.gate_size  = (int)(bin_space+.5); /* Nearest int */
728           ray->h.vel_res    = bin_space;
729           ray->h.sweep_rate = sweep_rate;
730           ray->h.prf        = (int)prf;
731             if (prf != 0)
732               ray->h.unam_rng = 299793000.0 / (2.0 * prf * 1000.0);  /* km */
733             else
734               ray->h.unam_rng = 0.0;
735           ray->h.prf2 = (int) prf2;
736           ray->h.fix_angle = (float)sweep->h.elev;
737           ray->h.azim_rate  = azim_rate;
738           ray->h.pulse_count = num_samples;
739           ray->h.pulse_width = pw;
740           ray->h.beam_width  = beam_width;
741           ray->h.frequency   = freq / 1000.0;  /* GHz */
742           ray->h.wavelength  = wave/100.0;     /* meters */
743           ray->h.nyq_vel     = max_vel;        /* m/s */
744           if (elev == 0.) elev = sweep->h.elev;
745           ray->h.elev        = (nsig_from_bang(ray_p->h.end_elev)+nsig_from_bang(ray_p->h.beg_elev))/2.0;
746           /* Compute mean azimuth angle for ray. */
747           az1 = nsig_from_bang(ray_p->h.beg_azm);
748           az2 = nsig_from_bang(ray_p->h.end_azm);
749           /*          printf("az1, %f, az2 %f\n", az1, az2); */
750           if(az1 > az2)
751             if((az1 - az2) > 180.0) az2 += 360.0;
752             else
753               ;
754           else
755             if((az2 - az1) > 180.0) az1 += 360.0;
756
757           az1 = (az1 + az2) / 2.0;
758           if (az1 > 360) az1 -= 360;
759           ray->h.azimuth     = az1;
760
761           /* From the extended header information, we learn the following. */
762           ray->h.pitch        = pitch;
763           ray->h.roll         = roll;
764           ray->h.heading      = heading;
765           ray->h.pitch_rate   = pitch_rate;
766           ray->h.roll_rate    = roll_rate;
767           ray->h.heading_rate = heading_rate;
768           ray->h.lat          = lat;
769           ray->h.lon          = lon;
770           ray->h.alt          = alt;
771           ray->h.rvc          = rvc;
772           ray->h.vel_east     = vel_east;
773           ray->h.vel_north    = vel_north;
774           ray->h.vel_up       = vel_up;
775
776           /*          printf("Processing sweep[%d]->ray[%d]: %d %f %f %f %f %f %f %f %f %d nbins=%d, bin1=%d gate=%d\n",
777                  i, j, msec, ray->h.sec, ray->h.azimuth, ray->h.elev, ray->h.pitch, ray->h.roll, ray->h.heading, ray->h.lat, ray->h.lon, ray->h.alt, ray->h.nbins, ray->h.range_bin1, ray->h.gate_size);
778                  */
779           /* TODO: ingest data header contains a value for bits-per-bin.
780            * This might be of use to allocate an array for ray->range with
781            * either 1-byte or 2-byte elements.  Then there's no need for
782            * memmove() whenever we need 2 bytes.
783            */
784
785           if (data_type == NSIG_DTB_EXH) continue;
786           ray_data = 0;
787           for(k = 0; k < bin_num; k++) {
788             switch(data_type) {
789             case NSIG_DTB_UCR:
790             case NSIG_DTB_CR:
791               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
792               else ray_data = (float)((ray_p->range[k]-64.0)/2.0);
793               break;
794             /* Simplified the velocity conversion for NSIG_DTB_VEL, using
795              * formula from IRIS Programmer's Manual. BLK, Oct 9 2009.
796              */
797             case NSIG_DTB_VEL:
798               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
799               else ray_data = (float)((ray_p->range[k]-128.0)/127.0)*max_vel;
800               break;
801               
802             case NSIG_DTB_WID:
803               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
804               else ray_data =(float)((ray_p->range[k])/256.0)*max_vel;
805               break;
806               
807             case NSIG_DTB_ZDR:
808               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
809               else ray_data = (float)((ray_p->range[k]-128.0)/16.0);
810               break;
811
812             case NSIG_DTB_KDP:
813                 if (ray_p->range[k] == 0 || ray_p->range[k] == 255 ||
814                     rsl_kdp_wavelen == 0.0) {
815                   ray_data = NSIG_NO_ECHO;
816                   break;
817                 }
818                 if (ray_p->range[k] < 128)
819                   ray_data = (-0.25 *
820                     pow((double)600.0,(double)((127-ray_p->range[k])/126.0))) /
821                       rsl_kdp_wavelen;
822                 else if (ray_p->range[k] > 128)
823                   ray_data = (0.25 *
824                     pow((double)600.0,(double)((ray_p->range[k]-129)/126.0))) /
825                       rsl_kdp_wavelen;
826                 else
827                   ray_data = 0.0;
828                 break;
829
830             case NSIG_DTB_PHIDP:
831               if (ray_p->range[k] == 0 || ray_p->range[k] == 255) 
832                 ray_data = NSIG_NO_ECHO;
833               else
834                 ray_data = 180.0*((ray_p->range[k]-1.0)/254.0);
835               break;
836
837             case NSIG_DTB_RHOHV:
838               if (ray_p->range[k] == 0 || ray_p->range[k] == 255) 
839                 ray_data = NSIG_NO_ECHO;
840               else 
841                 ray_data = sqrt((double)((ray_p->range[k]-1.0)/253.0));
842               break;
843
844             case NSIG_DTB_HCLASS:
845               if (ray_p->range[k] == 0 || ray_p->range[k] == 255) 
846                 ray_data = NSIG_NO_ECHO;
847               else
848                 ray_data = ray_p->range[k];
849               break;
850
851             case NSIG_DTB_SQI:
852               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
853               else ray_data = (float)sqrt((ray_p->range[k]-1.0)/253.0);
854               break;
855
856             case NSIG_DTB_VELC:
857               if (ray_p->range[k] == 0) ray_data = NSIG_NO_ECHO;
858               else {
859                 incr=75./127.;  /*  (+|- 75m/s) / 254 values */
860                 ray_data = (float)(ray_p->range[k]-128)*incr;
861               }
862               break;
863
864             case NSIG_DTB_UCR2:
865             case NSIG_DTB_CR2:
866             case NSIG_DTB_VEL2:
867             case NSIG_DTB_VELC2:
868             case NSIG_DTB_ZDR2:
869             case NSIG_DTB_KDP2:
870               memmove(nsig_twob, &ray_p->range[2*k], 2);
871               nsig_2byte = NSIG_I2(nsig_twob);
872               if (nsig_2byte == 0 || nsig_2byte == 65535)
873                 ray_data = NSIG_NO_ECHO2;
874               else ray_data = (float)(nsig_2byte-32768)/100.;
875               break;
876
877             case NSIG_DTB_WID2:
878               memmove(nsig_twob, &ray_p->range[2*k], 2);
879               nsig_2byte = NSIG_I2(nsig_twob);
880               if (nsig_2byte == 0 || nsig_2byte == 65535)
881                 ray_data = NSIG_NO_ECHO2;
882               else ray_data = (float)nsig_2byte/100.;
883               break;
884
885             case NSIG_DTB_PHIDP2:
886               memmove(nsig_twob, &ray_p->range[2*k], 2);
887               nsig_2byte = NSIG_I2(nsig_twob);
888               if (nsig_2byte == 0 || nsig_2byte == 65535)
889                 ray_data = NSIG_NO_ECHO;
890               else
891                 ray_data = 360.*(nsig_2byte-1)/65534.;
892               break;
893
894             case NSIG_DTB_SQI2:
895             case NSIG_DTB_RHOHV2:
896               memmove(nsig_twob, &ray_p->range[2*k], 2);
897               nsig_2byte = NSIG_I2(nsig_twob);
898               if (nsig_2byte == 0 || nsig_2byte == 65535)
899                 ray_data = NSIG_NO_ECHO2;
900               else ray_data = (float)(nsig_2byte-1)/65533.;
901               break;
902
903             case NSIG_DTB_HCLASS2:
904               memmove(nsig_twob, &ray_p->range[2*k], 2);
905               nsig_2byte = NSIG_I2(nsig_twob);
906               if (nsig_2byte == 0 || nsig_2byte == 65535)
907                 ray_data = NSIG_NO_ECHO2;
908               else
909                 ray_data = nsig_2byte;
910             }
911
912             if (ray_data == NSIG_NO_ECHO || ray_data == NSIG_NO_ECHO2)
913               ray->range[k] = ray->h.invf(BADVAL);
914             else
915               ray->range[k] = ray->h.invf(ray_data);
916
917             /*
918             if (data_type == NSIG_DTB_KDP)
919             printf("v[%d]->sweep[%d]->ray[%d]->range[%d] = %f, %d, %f\n", 
920                    ifield, i, j, k, ray->h.f(ray->range[k]), 
921                    (int)ray_p->range[k], ray_data);
922             */
923           }
924         }
925         }
926         nsig_free_sweep(nsig_sweep);
927       }
928
929    /* Do not reset radar->h.nvolumes. It is already set properly. */
930    if (radar_verbose_flag)
931      fprintf(stderr, "Max index of radar->v[0..%d]\n", radar->h.nvolumes);
932    
933
934    /** close nsig file **/
935    nsig_close(fp);
936
937    radar = RSL_prune_radar(radar);
938    /** return radar pointer **/
939    return radar;
940 }