version 1.1, 2012/05/09 03:53:22
|
version 1.2, 2012/08/21 22:14:34
|
Line 287 int jretile_manytofew(void) |
|
Line 287 int jretile_manytofew(void) |
|
return 1; | return 1; |
} | } |
| |
|
/* |
irecout=0; | irecout=0; |
for (iset=0; iset < ntimechunks; iset++) | for (iset=0; iset < ntimechunks; iset++) |
{ | { |
Line 309 int jretile_manytofew(void) |
|
Line 310 int jretile_manytofew(void) |
|
drms_setkey_time(outrec, "T_STOP", tstopout); | drms_setkey_time(outrec, "T_STOP", tstopout); |
drms_setkey_time(outrec, "T_OBS", tstartout+chunksecs/2); | drms_setkey_time(outrec, "T_OBS", tstartout+chunksecs/2); |
drms_setkey_int(outrec, "NDT", ndt); | drms_setkey_int(outrec, "NDT", ndt); |
/* |
|
if (segoutflag) |
|
segout = drms_segment_lookup(outrec, segnameout); |
|
else |
|
segout = drms_segment_lookupnum(outrec, 0); |
|
segout->axis[0]=2*ndt; |
|
segout->axis[1]=lmaxout*(lmaxout+1)/2+lmaxout - lminout*(lminout+1)/2 + 1; |
|
*/ |
|
irecout++; | irecout++; |
} | } |
} | } |
|
*/ |
| |
|
int firsttimethrough=1; |
int *nskiparr=(int *)calloc(nrecsout,sizeof(int)); | int *nskiparr=(int *)calloc(nrecsout,sizeof(int)); |
for (irecin=0; irecin < nrecsin; irecin++) | for (irecin=0; irecin < nrecsin; irecin++) |
{ | { |
Line 382 int jretile_manytofew(void) |
|
Line 377 int jretile_manytofew(void) |
|
lmaxout = lminout + lchunksize - 1; | lmaxout = lminout + lchunksize - 1; |
lminout = MAXIMUM(lminout,lmin); | lminout = MAXIMUM(lminout,lmin); |
lmaxout = MINIMUM(lmaxout,lmax); | lmaxout = MINIMUM(lmaxout,lmax); |
|
outrec = outrecset->records[irecout]; |
|
|
|
if (firsttimethrough) |
|
{ |
|
if (histlink) |
|
drms_setlink_static(outrec, histlinkname, histrecnum); |
|
drms_copykeys(outrec, inrec, 0, kDRMS_KeyClass_Explicit); |
|
drms_setkey_int(outrec, "LMIN", lminout); |
|
drms_setkey_int(outrec, "LMAX", lmaxout); |
|
drms_setkey_time(outrec, "T_START", tstartout); |
|
drms_setkey_time(outrec, "T_STOP", tstopout); |
|
drms_setkey_time(outrec, "T_OBS", tstartout+chunksecs/2); |
|
drms_setkey_int(outrec, "NDT", ndt); |
|
} |
| |
if (tstartin >= tstopout || tstopin <= tstartout || lminin > lmaxout || lmaxin < lminout) | if (tstartin >= tstopout || tstopin <= tstartout || lminin > lmaxout || lmaxin < lminout) |
{ | { |
Line 389 int jretile_manytofew(void) |
|
Line 398 int jretile_manytofew(void) |
|
continue; | continue; |
} | } |
| |
outrec = outrecset->records[irecout]; |
|
if (segoutflag) | if (segoutflag) |
segout = drms_segment_lookup(outrec, segnameout); | segout = drms_segment_lookup(outrec, segnameout); |
else | else |
Line 422 int jretile_manytofew(void) |
|
Line 430 int jretile_manytofew(void) |
|
outarr = drms_array_create(usetype, 2, length, arrptr, &status); | outarr = drms_array_create(usetype, 2, length, arrptr, &status); |
if (status != DRMS_SUCCESS || outarr == NULL || arrptr == NULL) | if (status != DRMS_SUCCESS || outarr == NULL || arrptr == NULL) |
{ | { |
fprintf(stderr,"ERROR: problem creating output array: T_START = %s, LMIN = %d, LMAX = %d, length = [%d, %d], status = %d, histrecnum = %lld", |
fprintf(stderr,"ERROR: problem creating output array: T_START = %s, LMIN = %d, LMAX = %d, length = [%d, %d], status = %d, histrecnum = %lld\n", |
tstartstr, lminout, lmaxout, length[0], length[1], status, histrecnum); | tstartstr, lminout, lmaxout, length[0], length[1], status, histrecnum); |
drms_close_records(inrecset, DRMS_FREE_RECORD); | drms_close_records(inrecset, DRMS_FREE_RECORD); |
drms_close_records(outrecset, DRMS_FREE_RECORD); | drms_close_records(outrecset, DRMS_FREE_RECORD); |
Line 459 int jretile_manytofew(void) |
|
Line 467 int jretile_manytofew(void) |
|
} // end loop on lchunk | } // end loop on lchunk |
} // end loop on iset | } // end loop on iset |
| |
|
firsttimethrough=0; |
|
drms_free_array(inarr); |
continue_outer_loop: | continue_outer_loop: |
inrec = drms_recordset_fetchnext(drms_env, inrecset, &fetchstat, &chunkstat, NULL); | inrec = drms_recordset_fetchnext(drms_env, inrecset, &fetchstat, &chunkstat, NULL); |
} // end loop on irecin | } // end loop on irecin |