************************************************/
float Cvt_time(long int time_in)
{
- double t;
- int hh,mm;
+ double t;
+ int hh,mm;
- t = time_in;
+ t = time_in;
t /= 1000.0;
hh = t/3600;
t -= hh*3600;
mm = t/60;
t -= mm*60;
-
- return hh*10000 + mm*100 + (float) t;
+
+ return hh*10000 + mm*100 + (float) t;
}
/**********************************************************************/
/* */
void print_packet_info(Wsr88d_packet *p)
{
fprintf(stderr,"%5hd %5hd %5hd %5hd %5hd %5hd %5hd %10.3f %6d\n",
- p->msg_type, p->id_seq, p->azm, p->ray_num, p->ray_status, p->elev, p->elev_num,
- Cvt_time((int)p->ray_time), Cvt_date((int)p->ray_date));
+ p->msg_type, p->id_seq, p->azm, p->ray_num, p->ray_status, p->elev, p->elev_num,
+ Cvt_time((int)p->ray_time), Cvt_date((int)p->ray_date));
}
*/
int i;
for (i=low; i<high; i++)
- if (s->ray[i] != NULL) {
- free(s->ray[i]);
- s->ray[i] = NULL;
- }
+ if (s->ray[i] != NULL) {
+ free(s->ray[i]);
+ s->ray[i] = NULL;
+ }
}
void clear_sweep(Wsr88d_sweep *s, int low, int high)
*/
int i;
for (i=low; i<high; i++)
- s->ray[i] = NULL;
+ s->ray[i] = NULL;
}
void wsr88d_print_sweep_info(Wsr88d_sweep *s)
fprintf(stderr,"----- ----- ----- ----- ----- ----- ----- ---------- ------\n");
for (i=0; i<MAX_RAYS_IN_SWEEP; i++) {
- if (s->ray[i] != NULL)
- print_packet_info((Wsr88d_packet *) s->ray[i]);
+ if (s->ray[i] != NULL)
+ print_packet_info((Wsr88d_packet *) s->ray[i]);
}
}
int save_fd;
if ( strcmp(filename, "stdin") == 0 ) {
- save_fd = dup(0);
- wf->fptr = fdopen(save_fd,"r");
+ save_fd = dup(0);
+ wf->fptr = fdopen(save_fd,"r");
} else {
- wf->fptr = fopen(filename, "r");
+ wf->fptr = fopen(filename, "r");
}
if (wf->fptr == NULL) return NULL;
/* */
/**********************************************************************/
int wsr88d_read_file_header(Wsr88d_file *wf,
- Wsr88d_file_header *wsr88d_file_header)
+ Wsr88d_file_header *wsr88d_file_header)
{
int n;
n = fread(&wsr88d_file_header->title,
- sizeof(wsr88d_file_header->title), 1, wf->fptr);
+ sizeof(wsr88d_file_header->title), 1, wf->fptr);
if (little_endian())
- wsr88d_swap_file_header(wsr88d_file_header);
+ wsr88d_swap_file_header(wsr88d_file_header);
return n;
}
/* */
/**********************************************************************/
int wsr88d_read_tape_header(char *first_file,
- Wsr88d_tape_header *wsr88d_tape_header)
+ Wsr88d_tape_header *wsr88d_tape_header)
{
FILE *fp;
int n;
char c;
if ((fp = fopen(first_file, "r")) == NULL) {
- perror(first_file);
- return 0;
+ perror(first_file);
+ return 0;
}
n = fread(wsr88d_tape_header, sizeof(Wsr88d_tape_header), 1, fp);
if (n == 0) {
- fprintf(stderr, "WARNING: %s is smaller than 31616 bytes. It is not a tape header file.\n", first_file);
- } else {
- /* Try to read one more character. If we can, then this is not a
- * tape header file. I suppose that we could look for '.' as the
- * 9-th character and if it were there, then too this is not a tape
- * header file.
- */
- if (fread(&c, sizeof(char), 1, fp) > 0) {
- fprintf(stderr, "WARNING: %s is larger than 31616 bytes. It is not a tape header file.\n", first_file);
- memset(wsr88d_tape_header, 0, sizeof(Wsr88d_tape_header));
- n = 0;
- } else { /* Ok so far. Now check the first 8 bytes for "ARCHIVE2" */
- if (strncmp(wsr88d_tape_header->archive2, "ARCHIVE2", 8) != 0) {
- fprintf(stderr, "WARNING: %s is 31616 bytes. However, the first 8 bytes are not 'ARCHIVE2'.\n", first_file);
- memset(wsr88d_tape_header, 0, sizeof(Wsr88d_tape_header));
- n = 0;
- }
- }
-
+ fprintf(stderr, "WARNING: %s is smaller than 31616 bytes. It is not a tape header file.\n", first_file);
+ } else {
+ /* Try to read one more character. If we can, then this is not a
+ * tape header file. I suppose that we could look for '.' as the
+ * 9-th character and if it were there, then too this is not a tape
+ * header file.
+ */
+ if (fread(&c, sizeof(char), 1, fp) > 0) {
+ fprintf(stderr, "WARNING: %s is larger than 31616 bytes. It is not a tape header file.\n", first_file);
+ memset(wsr88d_tape_header, 0, sizeof(Wsr88d_tape_header));
+ n = 0;
+ } else { /* Ok so far. Now check the first 8 bytes for "ARCHIVE2" */
+ if (strncmp(wsr88d_tape_header->archive2, "ARCHIVE2", 8) != 0) {
+ fprintf(stderr, "WARNING: %s is 31616 bytes. However, the first 8 bytes are not 'ARCHIVE2'.\n", first_file);
+ memset(wsr88d_tape_header, 0, sizeof(Wsr88d_tape_header));
+ n = 0;
+ }
+ }
+
}
fclose(fp);
return n;
/* Step 1. */
while ((wsr88d_ray.msg_type & 15) != 1 && n > 0) {
- /*
- fprintf(stderr,"SKIPPING packet: type %d, radial status %d\n",
- wsr88d_ray.msg_type, wsr88d_ray.ray_status);
- */
- n = wsr88d_read_ray(wf, &wsr88d_ray);
+ /*
+ fprintf(stderr,"SKIPPING packet: type %d, radial status %d\n",
+ wsr88d_ray.msg_type, wsr88d_ray.ray_status);
+ */
+ n = wsr88d_read_ray(wf, &wsr88d_ray);
}
if (n <= 0) return n; /* Read failure. */
end_of_volume = 0;
/* Step 2. */
while ( ! end_of_volume ) {
- if ((wsr88d_ray.msg_type & 15) != 1) {
- /*
- fprintf(stderr,"SKIPPING (amid a sweep) packet: type %d, "
- "radial status %d\n",
- wsr88d_ray.msg_type, wsr88d_ray.ray_status);
- */
-
- } else {
- /* Load this ray into the sweep. */
- ray_num = wsr88d_ray.ray_num;
- /* Double check against # records we've seen. */
- /* It is possible that a reset occurs and we begin to overwrite
- * previously loaded rays. I've seen this occur, rarely, in the
- * WSR88D data. I must trust 'ray_num'.
- */
- /*
- if (nrec+1 != ray_num) {
- fprintf(stderr, "Data says %d is ray_num, but, I've seen %d "
- "records.\n", ray_num, nrec+1);
- }
- */
- if (wsr88d_sweep->ray[ray_num] == NULL) {
- wsr88d_sweep->ray[ray_num] = (Wsr88d_ray *) malloc (sizeof(Wsr88d_ray));
- }
- memcpy(wsr88d_sweep->ray[ray_num], &wsr88d_ray, sizeof(Wsr88d_ray));
- }
- n = wsr88d_read_ray(wf, &wsr88d_ray);
- if (n > 0) nrec++;
+ if ((wsr88d_ray.msg_type & 15) != 1) {
+ /*
+ fprintf(stderr,"SKIPPING (amid a sweep) packet: type %d, "
+ "radial status %d\n",
+ wsr88d_ray.msg_type, wsr88d_ray.ray_status);
+ */
+
+ } else {
+ /* Load this ray into the sweep. */
+ ray_num = wsr88d_ray.ray_num;
+ /* Double check against # records we've seen. */
+ /* It is possible that a reset occurs and we begin to overwrite
+ * previously loaded rays. I've seen this occur, rarely, in the
+ * WSR88D data. I must trust 'ray_num'.
+ */
+ /*
+ if (nrec+1 != ray_num) {
+ fprintf(stderr, "Data says %d is ray_num, but, I've seen %d "
+ "records.\n", ray_num, nrec+1);
+ }
+ */
+ if (wsr88d_sweep->ray[ray_num] == NULL) {
+ wsr88d_sweep->ray[ray_num] = (Wsr88d_ray *) malloc (sizeof(Wsr88d_ray));
+ }
+ memcpy(wsr88d_sweep->ray[ray_num], &wsr88d_ray, sizeof(Wsr88d_ray));
+ }
+ n = wsr88d_read_ray(wf, &wsr88d_ray);
+ if (n > 0) nrec++;
end_of_volume = wsr88d_ray.ray_status == 2 ||
- wsr88d_ray.ray_status == 4 ||
- n <= 0;
+ wsr88d_ray.ray_status == 4 ||
+ n <= 0;
}
/* Process the last packet of the input data. */
- if (wsr88d_ray.ray_status == 2 || wsr88d_ray.ray_status == 4) {
- /* Load this ray into the sweep. */
- ray_num = wsr88d_ray.ray_num;
- if (wsr88d_sweep->ray[ray_num] == NULL) {
- wsr88d_sweep->ray[ray_num] = (Wsr88d_ray *) malloc (sizeof(Wsr88d_ray));
- }
- memcpy(wsr88d_sweep->ray[ray_num], &wsr88d_ray, sizeof(Wsr88d_ray));
+ if ((wsr88d_ray.ray_status == 2 || wsr88d_ray.ray_status == 4) &&
+ (wsr88d_ray.msg_type & 15) == 1) {
+ /* Load this ray into the sweep. */
+ ray_num = wsr88d_ray.ray_num;
+ if (wsr88d_sweep->ray[ray_num] == NULL) {
+ wsr88d_sweep->ray[ray_num] = (Wsr88d_ray *) malloc (sizeof(Wsr88d_ray));
+ }
+ memcpy(wsr88d_sweep->ray[ray_num], &wsr88d_ray, sizeof(Wsr88d_ray));
}
/* Just to be safe, clear all ray pointers left in this sweep to
/*
fprintf(stderr,"Processed %d records for elevation number %d\n",
- nrec+1, wsr88d_ray.elev_num);
+ nrec+1, wsr88d_ray.elev_num);
wsr88d_print_sweep_info(wsr88d_sweep);
*/
return nrec;
short *half_word;
half_word = (short *)wsr88d_ray;
for (; half_word<(short *)&wsr88d_ray->msg_time; half_word++)
- swap_2_bytes(half_word);
+ swap_2_bytes(half_word);
swap_4_bytes(&wsr88d_ray->msg_time);
swap_2_bytes(&wsr88d_ray->num_seg);
half_word = (short *) &wsr88d_ray->ray_date;
for (; half_word<(short *)&wsr88d_ray->sys_cal; half_word++)
- swap_2_bytes(half_word);
+ swap_2_bytes(half_word);
swap_4_bytes(&wsr88d_ray->sys_cal);
half_word = (short *) &wsr88d_ray->refl_ptr;
for (; half_word<(short *)&wsr88d_ray->data[0]; half_word++)
- swap_2_bytes(half_word);
+ swap_2_bytes(half_word);
}
n = fread(wsr88d_ray, sizeof(Wsr88d_ray), 1, wf->fptr);
/* if (n > 0) print_packet_info(wsr88d_ray); */
if (little_endian())
- wsr88d_swap_ray(wsr88d_ray);
+ wsr88d_swap_ray(wsr88d_ray);
return n;
}
/* */
/**********************************************************************/
int wsr88d_read_ray_header(Wsr88d_file *wf,
- Wsr88d_ray_header *wsr88d_ray_header)
+ Wsr88d_ray_header *wsr88d_ray_header)
{
fprintf(stderr,"Stub routine: wsr88d_read_ray_header.\n");
return 0;
/* */
/**********************************************************************/
int wsr88d_ray_to_float(Wsr88d_ray *ray,
- int THE_DATA_WANTED, float v[], int *n)
+ int THE_DATA_WANTED, float v[], int *n)
{
/*
* Input: *ray - WSR-88D packet
/* Code from Dan Austin (cvt_pckt_data.c) was the template for this. */
- /* declarations */
+ /* declarations */
int num_ref_gates,num_vel_gates,num_spec_gates;
int refl_ptr, vel_ptr,spec_ptr,res_flag;
int ival;
*/
if (THE_DATA_WANTED == WSR88D_DZ) {
- /* do the reflectivity data (dbZ)*/
- if (refl_ptr+num_ref_gates > 2300)
- fprintf(stderr, "WARNING: # refl index (%d) exceeds maximum (2300)\n",
- refl_ptr+num_ref_gates);
- else {
- for(i=0; i<num_ref_gates; i++) {
- ival = ray->data[refl_ptr+i];
- if(ival > 1)
- v[i] = (((ival-2.0)/2.0)-32.0);
- else if (ival == 1)
- v[i] = WSR88D_RFVAL;
- else /* ival = 0 */
- v[i] = WSR88D_BADVAL;
- }
- *n = num_ref_gates;
- }
+ /* do the reflectivity data (dbZ)*/
+ if (refl_ptr+num_ref_gates > 2300)
+ fprintf(stderr, "WARNING: # refl index (%d) exceeds maximum (2300)\n",
+ refl_ptr+num_ref_gates);
+ else {
+ for(i=0; i<num_ref_gates; i++) {
+ ival = ray->data[refl_ptr+i];
+ if(ival > 1)
+ v[i] = (((ival-2.0)/2.0)-32.0);
+ else if (ival == 1)
+ v[i] = WSR88D_RFVAL;
+ else /* ival = 0 */
+ v[i] = WSR88D_BADVAL;
+ }
+ *n = num_ref_gates;
+ }
} else if (THE_DATA_WANTED == WSR88D_VR) {
- /* do the velocity data (M/S) */
- if (vel_ptr+num_vel_gates > 2300)
- fprintf(stderr, "WARNING: # vel index (%d) exceeds maximum (2300)\n",
- vel_ptr+num_vel_gates);
- else {
- for(i=0; i<num_vel_gates;i++) {
- ival = ray->data[vel_ptr+i];
- if(ival > 1)
- if (res_flag == 2) /* High resolution: 0.5 m/s */
- v[i] = (((ival-2.0)/2.0)-63.5);
- else
- v[i] = ((ival-2.0)-127.0);
- else if (ival == 1)
- v[i] = WSR88D_RFVAL;
- else /* ival = 0 */
- v[i] = WSR88D_BADVAL;
- }
- *n = num_vel_gates;
- }
-
+ /* do the velocity data (M/S) */
+ if (vel_ptr+num_vel_gates > 2300)
+ fprintf(stderr, "WARNING: # vel index (%d) exceeds maximum (2300)\n",
+ vel_ptr+num_vel_gates);
+ else {
+ for(i=0; i<num_vel_gates;i++) {
+ ival = ray->data[vel_ptr+i];
+ if(ival > 1)
+ if (res_flag == 2) /* High resolution: 0.5 m/s */
+ v[i] = (((ival-2.0)/2.0)-63.5);
+ else
+ v[i] = ((ival-2.0)-127.0);
+ else if (ival == 1)
+ v[i] = WSR88D_RFVAL;
+ else /* ival = 0 */
+ v[i] = WSR88D_BADVAL;
+ }
+ *n = num_vel_gates;
+ }
+
} else if (THE_DATA_WANTED == WSR88D_SW) {
- /* now do the spectrum width data (M/S)*/
- if (spec_ptr+num_spec_gates > 2300)
- fprintf(stderr, "WARNING: # spec index (%d) exceeds maximum (2300)\n",
- spec_ptr+num_spec_gates);
- else {
- for(i=0;i<num_spec_gates;i++) {
- ival = ray->data[spec_ptr+i];
- if(ival > 1)
- v[i] = (((ival-2)/2.0)-63.5);
- else if (ival == 1)
- v[i] = WSR88D_RFVAL;
- else /* ival = 0 */
- v[i] = WSR88D_BADVAL;
- }
- *n = num_spec_gates;
- }
+ /* now do the spectrum width data (M/S)*/
+ if (spec_ptr+num_spec_gates > 2300)
+ fprintf(stderr, "WARNING: # spec index (%d) exceeds maximum (2300)\n",
+ spec_ptr+num_spec_gates);
+ else {
+ for(i=0;i<num_spec_gates;i++) {
+ ival = ray->data[spec_ptr+i];
+ if(ival > 1)
+ v[i] = (((ival-2)/2.0)-63.5);
+ else if (ival == 1)
+ v[i] = WSR88D_RFVAL;
+ else /* ival = 0 */
+ v[i] = WSR88D_BADVAL;
+ }
+ *n = num_spec_gates;
+ }
}
return *n;
if (ray->vol_cpat == 31) return 31;
if (ray->vol_cpat == 32) return 32;
if (ray->vol_cpat == 121) return 121;
+ if (ray->vol_cpat == 211) return 211;
+ if (ray->vol_cpat == 212) return 212;
+ if (ray->vol_cpat == 221) return 221;
return 0;
}
/*
* This routine from Dan Austin. Program component of nex2uf.
*/
- static int vcp_info[4];
- int fix_angle;
- int pulse_cnt;
- int az_rate;
- int pulse_width;
-
- /* case statement to get vcp info */
- switch(vcp_num) {
- case 11:
- fix_angle = vcp11[(3*el_num)-1];
- pulse_cnt = vcp11[(3*el_num)];
- az_rate = vcp11[(3*el_num)+1];
- pulse_width = vcp11[1];
- break;
- case 12:
- fix_angle = vcp12[(3*el_num)-1];
- pulse_cnt = vcp12[(3*el_num)];
- az_rate = vcp12[(3*el_num)+1];
- pulse_width = vcp12[1];
- break;
- case 21:
- fix_angle = vcp21[(3*el_num)-1];
- pulse_cnt = vcp21[(3*el_num)];
- az_rate = vcp21[(3*el_num)+1];
- pulse_width = vcp21[1];
- break;
- case 31:
- fix_angle = vcp31[(3*el_num)-1];
- pulse_cnt = vcp31[(3*el_num)];
- az_rate = vcp31[(3*el_num)+1];
- pulse_width = vcp31[1];
- break;
- case 32:
- fix_angle = vcp32[(3*el_num)-1];
- pulse_cnt = vcp32[(3*el_num)];
- az_rate = vcp32[(3*el_num)+1];
- pulse_width = vcp32[1];
- break;
- case 300:
- fix_angle = vcp300[(3*el_num)-1];
- pulse_cnt = vcp300[(3*el_num)];
- az_rate = vcp300[(3*el_num)+1];
- pulse_width = vcp300[1];
- break;
- case 121:
- fix_angle = vcp121[(3*el_num)-1];
- pulse_cnt = vcp121[(3*el_num)];
- az_rate = vcp121[(3*el_num)+1];
- pulse_width = vcp121[1];
- break;
- case 211:
- fix_angle = vcp11[(3*el_num)-1];
- pulse_cnt = vcp11[(3*el_num)];
- az_rate = vcp11[(3*el_num)+1];
- pulse_width = vcp11[1];
- break;
- case 212:
- fix_angle = vcp12[(3*el_num)-1];
- pulse_cnt = vcp12[(3*el_num)];
- az_rate = vcp12[(3*el_num)+1];
- pulse_width = vcp12[1];
- break;
- case 221:
- fix_angle = vcp21[(3*el_num)-1];
- pulse_cnt = vcp21[(3*el_num)];
- az_rate = vcp21[(3*el_num)+1];
- pulse_width = vcp21[1];
- break;
- default:
- fix_angle = 0;
- pulse_cnt = 0;
- az_rate = 0;
- pulse_width= 0;
- break;
- }
-
- /* get array for output */
- vcp_info[0]=fix_angle;
- vcp_info[1]=pulse_cnt;
- vcp_info[2]=az_rate;
- vcp_info[3]=pulse_width;
-
-
- /* return the value array */
- return(vcp_info);
+ static int vcp_info[4];
+ int fix_angle;
+ int pulse_cnt;
+ int az_rate;
+ int pulse_width;
+
+ /* case statement to get vcp info */
+ switch(vcp_num) {
+ case 11:
+ fix_angle = vcp11[(3*el_num)-1];
+ pulse_cnt = vcp11[(3*el_num)];
+ az_rate = vcp11[(3*el_num)+1];
+ pulse_width = vcp11[1];
+ break;
+ case 12:
+ fix_angle = vcp12[(3*el_num)-1];
+ pulse_cnt = vcp12[(3*el_num)];
+ az_rate = vcp12[(3*el_num)+1];
+ pulse_width = vcp12[1];
+ break;
+ case 21:
+ fix_angle = vcp21[(3*el_num)-1];
+ pulse_cnt = vcp21[(3*el_num)];
+ az_rate = vcp21[(3*el_num)+1];
+ pulse_width = vcp21[1];
+ break;
+ case 31:
+ fix_angle = vcp31[(3*el_num)-1];
+ pulse_cnt = vcp31[(3*el_num)];
+ az_rate = vcp31[(3*el_num)+1];
+ pulse_width = vcp31[1];
+ break;
+ case 32:
+ fix_angle = vcp32[(3*el_num)-1];
+ pulse_cnt = vcp32[(3*el_num)];
+ az_rate = vcp32[(3*el_num)+1];
+ pulse_width = vcp32[1];
+ break;
+ case 300:
+ fix_angle = vcp300[(3*el_num)-1];
+ pulse_cnt = vcp300[(3*el_num)];
+ az_rate = vcp300[(3*el_num)+1];
+ pulse_width = vcp300[1];
+ break;
+ case 121:
+ fix_angle = vcp121[(3*el_num)-1];
+ pulse_cnt = vcp121[(3*el_num)];
+ az_rate = vcp121[(3*el_num)+1];
+ pulse_width = vcp121[1];
+ break;
+ case 211:
+ fix_angle = vcp11[(3*el_num)-1];
+ pulse_cnt = vcp11[(3*el_num)];
+ az_rate = vcp11[(3*el_num)+1];
+ pulse_width = vcp11[1];
+ break;
+ case 212:
+ fix_angle = vcp12[(3*el_num)-1];
+ pulse_cnt = vcp12[(3*el_num)];
+ az_rate = vcp12[(3*el_num)+1];
+ pulse_width = vcp12[1];
+ break;
+ case 221:
+ fix_angle = vcp21[(3*el_num)-1];
+ pulse_cnt = vcp21[(3*el_num)];
+ az_rate = vcp21[(3*el_num)+1];
+ pulse_width = vcp21[1];
+ break;
+ default:
+ fix_angle = 0;
+ pulse_cnt = 0;
+ az_rate = 0;
+ pulse_width= 0;
+ break;
+ }
+
+ /* get array for output */
+ vcp_info[0]=fix_angle;
+ vcp_info[1]=pulse_cnt;
+ vcp_info[2]=az_rate;
+ vcp_info[3]=pulse_width;
+
+
+ /* return the value array */
+ return(vcp_info);
}
prf = wsr88d_get_prf(ray);
nyquist = wsr88d_get_nyquist(ray);
- /* If required info to determine wavelength does not exist,
- just use 10 cm. All wsr88d radars are 10cm. MJK */
+ /* If required info to determine wavelength does not exist,
+ just use 10 cm. All wsr88d radars are 10cm. MJK */
if ((prf == 0) || (nyquist == 0.0)) wavelength = 0.10;
else wavelength = 4*nyquist/prf;
return wavelength;
float freq;
float c = 299792458.0;
- /* Carrier freq (GHz). Revised 12 Jun 97. MJK */
- freq = (c / wsr88d_get_wavelength(ray)) * 1.0e-9;
+ /* Carrier freq (GHz). Revised 12 Jun 97. MJK */
+ freq = (c / wsr88d_get_wavelength(ray)) * 1.0e-9;
return freq;
}
projects / ~andy / rsl / blobdiff