- Timestamp:
- Jan 19, 2016, 8:48:44 AM (10 years ago)
- File:
-
- 1 edited
-
trunk/Ohana/src/libdvo/src/dvo_catalog_split.c (modified) (25 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Ohana/src/libdvo/src/dvo_catalog_split.c
r39312 r39320 101 101 } 102 102 103 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);103 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 104 104 105 105 // write PHU header … … 129 129 # endif 130 130 131 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);131 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 132 132 133 133 FTable *outtable = ftable; … … 310 310 int gfits_fread_uncompressed (Catalog *catalog, FTable *ftable, char *nativeOrder, char VERBOSE) { 311 311 312 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 313 312 314 // fread_ftable_data requires the header 313 315 … … 317 319 return FALSE; 318 320 } 321 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 319 322 // NOTE: fread_ftable returns an unswapped table; uncompress swaps the bytes into native order 320 323 … … 331 334 return FALSE; 332 335 } 336 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 337 333 338 if (!gfits_uncompress_table (ftable, &rawtable)) { 334 339 if (VERBOSE) fprintf (stderr, "failed to uncompress table\n"); … … 336 341 return FALSE; 337 342 } 343 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 338 344 339 345 char compressMode[256]; … … 346 352 gfits_free_header (ftable->header); 347 353 gfits_free_table (ftable); 354 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 348 355 349 356 // copies values but does not allocate new memory … … 866 873 } 867 874 868 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);875 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 869 876 870 877 Nmeasure_disk_new = MAX (catalog[0].Nmeasure_disk, catalog[0].Nmeasure + catalog[0].Nmeasure_off); … … 891 898 /* in split mode, we can save only part of the data */ 892 899 893 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);900 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 894 901 895 902 /*** Average Table ***/ … … 918 925 } 919 926 920 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);927 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 921 928 922 929 if (!dvo_catalog_save_subcat (catalog, &ftable, start, Nrows, catalog[0].Naverage_disk, Naverage_disk_new)) { … … 925 932 } 926 933 927 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);934 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 928 935 929 936 gfits_free_header (&header); … … 954 961 assert (catalog[0].Nmeasure_disk >= catalog[0].Nmeasure_off); 955 962 956 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);963 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 957 964 958 965 // if we are going to compress, we need to receive unswapped data -- … … 965 972 } 966 973 967 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);974 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 968 975 969 976 // write out Measure table … … 973 980 goto failure; 974 981 } 975 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);982 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 976 983 977 984 gfits_free_header (&header); … … 1023 1030 int swapFromNative = !output_is_compressed (start, Nrows, Nsecfilt_disk_new, catalog->catcompress); 1024 1031 1025 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1032 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1026 1033 1027 1034 // convert to external table format … … 1031 1038 } 1032 1039 1033 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1040 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1034 1041 1035 1042 // write out SecFilt table … … 1562 1569 } 1563 1570 1564 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1571 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1565 1572 1566 1573 Nmeasure_disk_new = catalog[0].Nmeasure; … … 1587 1594 /* in split mode, we can save only part of the data, but not using this function (use e.g., dvo_catalog_update_split) */ 1588 1595 1589 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1596 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1590 1597 1591 1598 /*** Average Table ***/ … … 1614 1621 } 1615 1622 1616 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1623 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1617 1624 1618 1625 if (!dvo_catalog_save_subcat (catalog, &ftable, start, Nrows, catalog[0].Naverage_disk, Naverage_disk_new)) { … … 1621 1628 } 1622 1629 1623 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1630 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1624 1631 1625 1632 gfits_free_header (&header); … … 1650 1657 assert (catalog[0].Nmeasure_disk >= catalog[0].Nmeasure_off); 1651 1658 1652 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1659 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1653 1660 1654 1661 // if we are going to compress, we need to receive unswapped data -- … … 1662 1669 } 1663 1670 1664 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1671 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1665 1672 1666 1673 // write out Measure table … … 1670 1677 goto failure; 1671 1678 } 1672 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1679 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1673 1680 1674 1681 gfits_free_header (&header); … … 1723 1730 int swapFromNative = !output_is_compressed (start, Nrows, Nsecfilt_disk_new, catalog->catcompress); 1724 1731 1725 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1732 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1726 1733 1727 1734 // convert to external table format … … 1731 1738 } 1732 1739 1733 if (OHANA_MEMCHECK) ohana_memcheck _func(TRUE);1740 if (OHANA_MEMCHECK) ohana_memcheck (TRUE); 1734 1741 1735 1742 // write out SecFilt table
Note:
See TracChangeset
for help on using the changeset viewer.
