Lines Matching refs:vblob

392 rc_t VPhysicalCreateStatic ( VPhysical *self, const VBlob *vblob )  in VPhysicalCreateStatic()  argument
423 rc = KDataBufferSub ( & vblob -> data, & self -> srow, 0, UINT64_MAX ); in VPhysicalCreateStatic()
427 uint64_t row_bits = KDataBufferBits ( & vblob -> data ); in VPhysicalCreateStatic()
438 rc = KDataBufferSub ( & vblob -> data, & data, 0, UINT64_MAX ); in VPhysicalCreateStatic()
448 rc = KDataBufferSub ( & vblob -> data, & data, 0, UINT64_MAX ); in VPhysicalCreateStatic()
452 … rc = KDataBufferMake ( & data, vblob -> data . elem_bits, vblob -> data . elem_count ); in VPhysicalCreateStatic()
456vblob -> data . base, ( uint32_t ) ( row_bits / dt -> size ) ); in VPhysicalCreateStatic()
497 self -> sstart_id = vblob -> start_id; in VPhysicalCreateStatic()
498 self -> sstop_id = vblob -> stop_id; in VPhysicalCreateStatic()
499 self -> fixed_len = PageMapGetIdxRowInfo ( vblob -> pm, 0, NULL, NULL ); in VPhysicalCreateStatic()
608 rc_t VPhysicalWriteKColumn ( VPhysical *self, const VBlob *vblob ) in VPhysicalWriteKColumn() argument
615 uint32_t count = (uint32_t)(vblob -> stop_id - vblob -> start_id + 1); in VPhysicalWriteKColumn()
616 rc = KColumnBlobAssignRange ( kblob, vblob -> start_id, count ); in VPhysicalWriteKColumn()
619 … rc = KColumnBlobAppend ( kblob, vblob -> data . base, KDataBufferBytes ( & vblob -> data ) ); in VPhysicalWriteKColumn()
626 uint32_t blob_fixed = VBlobFixedRowLength ( vblob ); in VPhysicalWriteKColumn()
635 if ( vblob -> start_id < self -> kstart_id ) in VPhysicalWriteKColumn()
636 self -> kstart_id = vblob -> start_id; in VPhysicalWriteKColumn()
637 if ( vblob -> stop_id > self -> kstop_id ) in VPhysicalWriteKColumn()
638 self -> kstop_id = vblob -> stop_id; in VPhysicalWriteKColumn()
689 VBlob *vblob; in VPhysicalConvertStatic()
691 rc = VProductionReadBlob ( self -> b2s, & vblob, & rowId, 1,NULL ); in VPhysicalConvertStatic()
695 rc = VPhysicalWriteKColumn ( self, vblob ); in VPhysicalConvertStatic()
698 TRACK_BLOB ( VBlobRelease, vblob ); in VPhysicalConvertStatic()
699 ( void ) VBlobRelease ( vblob ); in VPhysicalConvertStatic()
804 VBlob *vblob; in VPhysicalWrite() local
805 rc_t rc = VProductionReadBlob ( self -> in, & vblob, & id , cnt,NULL); in VPhysicalWrite()
809 assert ( vblob != NULL ); in VPhysicalWrite()
810 if ( VBlobIsSingleRow ( vblob ) ) in VPhysicalWrite()
815 rc = VPhysicalCreateStatic ( self, vblob ); in VPhysicalWrite()
816 TRACK_BLOB ( VBlobRelease, vblob ); in VPhysicalWrite()
817 ( void ) VBlobRelease ( vblob ); in VPhysicalWrite()
830 assert ( vblob -> start_id <= vblob -> stop_id ); in VPhysicalWrite()
831 if ( vblob -> stop_id + 1 >= self -> sstart_id && in VPhysicalWrite()
832 vblob -> start_id <= self -> sstop_id + 1 ) in VPhysicalWrite()
835 if ( self -> fixed_len == PageMapGetIdxRowInfo ( vblob -> pm, 0, NULL, NULL ) ) in VPhysicalWrite()
838 … assert ( KDataBufferBits ( & self -> srow ) == KDataBufferBits ( & vblob -> data ) ); in VPhysicalWrite()
840 vblob -> data . base, vblob -> data . bit_offset, in VPhysicalWrite()
844 if ( vblob -> start_id < self -> sstart_id ) in VPhysicalWrite()
845 self -> sstart_id = vblob -> start_id; in VPhysicalWrite()
846 if ( vblob -> stop_id > self -> sstop_id ) in VPhysicalWrite()
847 self -> sstop_id = vblob -> stop_id; in VPhysicalWrite()
849 TRACK_BLOB ( VBlobRelease, vblob ); in VPhysicalWrite()
850 ( void ) VBlobRelease ( vblob ); in VPhysicalWrite()
878 TRACK_BLOB ( VBlobRelease, vblob ); in VPhysicalWrite()
879 ( void ) VBlobRelease ( vblob ); in VPhysicalWrite()
880 rc = VProductionReadBlob ( self -> b2s, & vblob, & id, cnt,NULL ); in VPhysicalWrite()
884 rc = VPhysicalWriteKColumn ( self, vblob ); in VPhysicalWrite()
889 TRACK_BLOB ( VBlobRelease, vblob ); in VPhysicalWrite()
890 ( void ) VBlobRelease ( vblob ); in VPhysicalWrite()
899 rc_t VPhysicalRead ( VPhysical *self, VBlob **vblob, int64_t id, uint32_t cnt, uint32_t elem_bits ) in VPhysicalRead() argument
907 * vblob = NULL; in VPhysicalRead()
913 return VPhysicalReadBlob ( self, vblob, id, elem_bits ); in VPhysicalRead()