|
1409 | 1409 | staged_prev: 0, // entry limit of previous I/O request |
1410 | 1410 | staged_now: 0, // entry limit of current I/O request |
1411 | 1411 | progress_showtm: 0, // last time when progress was showed |
1412 | | - have_to_read_empty_stl_branch: false, // by default splitted container branch read version if empty container |
1413 | 1412 | GetBasketEntry : function(k) { |
1414 | 1413 | if (!this.branch || (k > this.branch.fMaxBaskets)) return 0; |
1415 | 1414 | var res = (k < this.branch.fMaxBaskets) ? this.branch.fBasketEntry[k] : 0; |
|
1654 | 1653 | } else |
1655 | 1654 | if (is_brelem && (nb_leaves <= 1)) { |
1656 | 1655 |
|
1657 | | - item.have_to_read_empty_stl_branch = (branch.fType === JSROOT.BranchType.kClonesMemberNode); |
1658 | | - |
1659 | 1656 | elem = JSROOT.IO.FindBrachStreamerElement(branch, handle.file); |
1660 | 1657 |
|
1661 | | - if (elem) |
1662 | | - console.log('ELEMENT', elem.fName, elem.fType, elem.fTypeName, 'READ_EMPTY', item.have_to_read_empty_stl_branch); |
1663 | | - |
1664 | 1658 | // this is basic type - can try to solve problem differently |
1665 | 1659 | if (!elem && branch.fStreamerType && (branch.fStreamerType < 20)) { |
1666 | 1660 | elem = JSROOT.IO.CreateStreamerElement(target_name, branch.fStreamerType); |
|
1775 | 1769 | if (member.objs_branch_func) { |
1776 | 1770 | // STL branch provides special function for the reading |
1777 | 1771 | member.func = member.objs_branch_func; |
1778 | | - |
1779 | | - member.read_empty_stl_version = item.have_to_read_empty_stl_branch; |
1780 | | - |
1781 | 1772 | } else { |
1782 | 1773 | member.func0 = member.func; |
1783 | 1774 |
|
|
1853 | 1844 | // function provided by normal I/O |
1854 | 1845 | member.func = member.branch_func; |
1855 | 1846 | member.stl_size = item_cnt.name; |
1856 | | - member.read_empty_stl_version = item.have_to_read_empty_stl_branch; |
1857 | | - |
1858 | 1847 | } else |
1859 | 1848 | if ((elem.fType === JSROOT.IO.kStreamLoop) || (elem.fType === JSROOT.IO.kOffsetL+JSROOT.IO.kStreamLoop)) { |
1860 | 1849 | if (item_cnt2) { |
1861 | 1850 | // special solution for kStreamLoop |
1862 | 1851 | member.stl_size = item_cnt.name; |
1863 | 1852 | member.cntname = item_cnt2.name; |
1864 | 1853 | member.func = member.branch_func; // this is special function, provided by base I/O |
1865 | | - member.read_empty_stl_version = item.have_to_read_empty_stl_branch; |
1866 | 1854 | } else { |
1867 | 1855 | member.cntname = item_cnt.name; |
1868 | 1856 | } |
|
2071 | 2059 | basket.fDisplacement = undefined; |
2072 | 2060 |
|
2073 | 2061 | // rollback buffer - not needed in the future |
2074 | | - buf.locate(buf.raw_shift); |
| 2062 | + // buf.locate(buf.raw_shift); |
2075 | 2063 | } |
2076 | 2064 |
|
2077 | 2065 | function ProcessBlobs(blobs) { |
|
2097 | 2085 |
|
2098 | 2086 | bitems[k].bskt_obj = basket; // only number of entries in the basket are relevant for the moment |
2099 | 2087 |
|
2100 | | - console.log('CHECK', basket.fKeylen, basket.fObjlen, basket.fNbytes); |
2101 | | - |
2102 | 2088 | if (basket.fKeylen + basket.fObjlen === basket.fNbytes) { |
2103 | 2089 | // use data from original blob |
2104 | 2090 | buf.raw_shift = 0; |
|
2117 | 2103 |
|
2118 | 2104 | bitems[k].raw = buf; // here already unpacket buffer |
2119 | 2105 |
|
2120 | | - console.log('BUFFER', buf.remain()); |
2121 | | - |
2122 | 2106 | ReadBasketEntryOffset(bitems[k].branch, basket, buf); |
2123 | | - |
2124 | | - console.log('Extract RAW ', buf.remain(), 'last', basket.fLast - basket.fKeylen, 'objlen', basket.fObjlen); |
2125 | 2107 | } |
2126 | 2108 |
|
2127 | 2109 | if (ExtractPlaces()) |
|
0 commit comments