Changeset 38428
- Timestamp:
- Jun 8, 2015, 11:45:23 AM (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/ohana.20150429/src/libdvo/src/dvo_catalog_split.c
r38427 r38428 131 131 132 132 if (isCompressed) { 133 fprintf (stderr, "compress %s\n", catalog->filename);133 / fprintf (stderr, "compress %s\n", catalog->filename); 134 134 char *compressMode = dvo_catalog_compress_string (catalog->catcompress); 135 135 // I should test how Ntile affects fpack/funpack and speed … … 762 762 int dvo_catalog_save_split (Catalog *catalog, char VERBOSE) { 763 763 764 off_t Nitems;765 764 Header header; 766 765 FTable ftable; … … 768 767 int Nsecfilt; 769 768 off_t Naverage_disk_new, Nmeasure_disk_new, Nmissing_disk_new, Nsecfilt_disk_new, Nlensing_disk_new, Nlensobj_disk_new, Nstarpar_disk_new, Ngalphot_disk_new; 770 off_t first, start, Nrows;771 769 772 770 ftable.header = &header; … … 821 819 if ((catalog[0].catflags & DVO_LOAD_AVERAGE) && (catalog[0].average != NULL)) { 822 820 823 first = 0; // first row in memory to write824 start = catalog[0].Naverage_off; // first disk row to write825 Nrows = catalog[0].Naverage - first;821 off_t first = 0; // first row in memory to write 822 off_t start = catalog[0].Naverage_off; // first disk row to write 823 off_t Nrows = catalog[0].Naverage - first; 826 824 827 825 assert (Nrows >= 0); … … 865 863 if ((catalog[0].catflags & DVO_LOAD_MEASURE) && (catalog[0].measure != NULL)) { 866 864 867 first = 0; // first row in memory to write868 start = catalog[0].Nmeasure_off; // first disk row to write869 Nrows = catalog[0].Nmeasure - first;865 off_t first = 0; // first row in memory to write 866 off_t start = catalog[0].Nmeasure_off; // first disk row to write 867 off_t Nrows = catalog[0].Nmeasure - first; 870 868 871 869 assert (Nrows >= 0); … … 902 900 903 901 // if we are going to compress, we need to receive unswapped data -- 904 int swapFromNative = !output_is_compressed ( start, Nrows, Nmissing_disk_new, catalog->catcompress);902 int swapFromNative = !output_is_compressed (catalog[0].Nmissing_off, catalog[0].Nmissing, Nmissing_disk_new, catalog->catcompress); 905 903 906 904 // convert to external table format … … 923 921 if ((catalog[0].catflags & DVO_LOAD_SECFILT) && (catalog[0].secfilt != NULL)) { 924 922 925 first = 0; // first row in memory to write926 start = catalog[0].Nsecfilt_off; // first disk row to write927 Nitems = catalog[0].Naverage*Nsecfilt;928 Nrows = Nitems - first;923 off_t first = 0; // first row in memory to write 924 off_t start = catalog[0].Nsecfilt_off; // first disk row to write 925 off_t Nitems = catalog[0].Naverage*Nsecfilt; 926 off_t Nrows = Nitems - first; 929 927 930 928 assert (Nrows >= 0); … … 956 954 if ((catalog[0].catflags & DVO_LOAD_LENSING) && (catalog[0].lensing != NULL)) { 957 955 958 first = 0; // first row in memory to write959 start = catalog[0].Nlensing_off; // first disk row to write960 Nrows = catalog[0].Nlensing - first;956 off_t first = 0; // first row in memory to write 957 off_t start = catalog[0].Nlensing_off; // first disk row to write 958 off_t Nrows = catalog[0].Nlensing - first; 961 959 962 960 assert (Nrows >= 0); … … 987 985 if ((catalog[0].catflags & DVO_LOAD_LENSOBJ) && (catalog[0].lensobj != NULL)) { 988 986 989 first = 0; // first row in memory to write990 start = catalog[0].Nlensobj_off; // first disk row to write991 Nrows = catalog[0].Nlensobj - first;987 off_t first = 0; // first row in memory to write 988 off_t start = catalog[0].Nlensobj_off; // first disk row to write 989 off_t Nrows = catalog[0].Nlensobj - first; 992 990 993 991 assert (Nrows >= 0); … … 1018 1016 if ((catalog[0].catflags & DVO_LOAD_STARPAR) && (catalog[0].starpar != NULL)) { 1019 1017 1020 first = 0; // first row in memory to write1021 start = catalog[0].Nstarpar_off; // first disk row to write1022 Nrows = catalog[0].Nstarpar - first;1018 off_t first = 0; // first row in memory to write 1019 off_t start = catalog[0].Nstarpar_off; // first disk row to write 1020 off_t Nrows = catalog[0].Nstarpar - first; 1023 1021 1024 1022 assert (Nrows >= 0); … … 1049 1047 if ((catalog[0].catflags & DVO_LOAD_GALPHOT) && (catalog[0].galphot != NULL)) { 1050 1048 1051 first = 0; // first row in memory to write1052 start = catalog[0].Ngalphot_off; // first disk row to write1053 Nrows = catalog[0].Ngalphot - first;1049 off_t first = 0; // first row in memory to write 1050 off_t start = catalog[0].Ngalphot_off; // first disk row to write 1051 off_t Nrows = catalog[0].Ngalphot - first; 1054 1052 1055 1053 assert (Nrows >= 0);
Note:
See TracChangeset
for help on using the changeset viewer.
