{"header":{"message":"have a basic index structure","description":null,"timestamp":"2021-09-24T13:31:56.75777Z","authors":[{}]},"hash":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC","authors":[{"key":"BCbPPm1DzTKCMDwRhA2WJN63Uswk1sQh9wdbcbpfnWPZ"}],"deps":{"hashes":[["DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC","have a basic index structure"],["AA",null],["KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC","Added allocations as setting"],["ANUA65XKNZZIOSRIHH7V5JOADUMCZUYOJ3ZE7DBLY4GTXLI7DFEQC","added new function"],["IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC","still trying to wrap my head around this"],["PL45Z6DWXYDTT7LZLTTFSOJBX6IOVPZT42F36Z6E7ABQJS7XY5PQC","Commenting out some stuff"],["UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC","apparently had to reset the whole pijul thing"],["SIHQ3OG5GIBQLSMOBKSD2IHFTGFXU4VDCX45BH2ABS42BV3N2UIQC","starting some basic module structure"],["G5C3RSELXRNXJFQQ6ZVCXLQE4AJNXYB32RULKHWLWF5SGEFXYTWQC","adding sql folder"],["LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC","hja;lp"]],"deps":["KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC"],"known":["LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC","ANUA65XKNZZIOSRIHH7V5JOADUMCZUYOJ3ZE7DBLY4GTXLI7DFEQC","PL45Z6DWXYDTT7LZLTTFSOJBX6IOVPZT42F36Z6E7ABQJS7XY5PQC","SIHQ3OG5GIBQLSMOBKSD2IHFTGFXU4VDCX45BH2ABS42BV3N2UIQC","UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC","IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC","G5C3RSELXRNXJFQQ6ZVCXLQE4AJNXYB32RULKHWLWF5SGEFXYTWQC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":60},"path":"src/vector_query/opclass.rs","line":91,"ins":{"up_context":[{"change":3,"pos":2191}],"down_context":[{"change":3,"pos":3352}],"flag":"BLOCK","start":0,"end":1137,"inode":{"change":3,"pos":60}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2191},"to":{"change":3,"start":2191,"end":3352},"introduced_by":3}],"inode":{"change":3,"pos":60}},"ins_contents":[{"Add":{"text":" // #[pg_test]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20"}},{"Add":{"text":" // fn test_hello_pgvector_rs() {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:60"}},{"Add":{"text":" // let arr0 = (0..32)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:93"}},{"Add":{"text":" // .map(|x| x as f32)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:130"}},{"Add":{"text":" // .map(|x| x.sin())","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:166"}},{"Add":{"text":" // .collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:206"}},{"Add":{"text":" // let mut arr = arr0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:239"}},{"Add":{"text":" // .iter()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:265"}},{"Add":{"text":" // .map(|x| x.into_datum())","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:308"}},{"Add":{"text":" // .map(|x| x.unwrap())","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:347"}},{"Add":{"text":" // .collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:399"}},{"Add":{"text":" // let mut nulls = arr.iter().map(|_| false).collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:479"}},{"Add":{"text":" // let mut arr_2 = arr.clone();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:522"}},{"Add":{"text":" // let mut nulls_2 = nulls.clone();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:569"}},{"Add":{"text":" // let vec1 = unsafe {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:603"}},{"Add":{"text":" // let size = arr.len();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:643"}},{"Add":{"text":" // let b = arr.as_mut_ptr();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:687"}},{"Add":{"text":" // Array::over(b, nulls.as_mut_ptr(), size)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:746"}},{"Add":{"text":" // };","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:763"}},{"Add":{"text":" // vec1.iter().for_each(|x| {});","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:807"}},{"Add":{"text":" // let vec2 = unsafe {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:841"}},{"Add":{"text":" // let size = arr_2.len();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:883"}},{"Add":{"text":" // Array::over(arr_2.as_mut_ptr(), nulls_2.as_mut_ptr(), size)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:961"}},{"Add":{"text":" // };","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:978"}},{"Add":{"text":" // vec2.iter().zip(arr0.iter()).for_each(|(x, y)| {});","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1044"}},{"Add":{"text":" // let d = l2_dist(vec1, vec2);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1087"}},{"Add":{"text":" //","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1094"}},{"Add":{"text":" // assert!(false);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1124"}},{"Add":{"text":" // }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1136"}}],"del_contents":[{"Del":{"text":" #[pg_test]","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2205"}},{"Del":{"text":" fn test_hello_pgvector_rs() {","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2239"}},{"Del":{"text":" let arr0 = (0..32)","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2266"}},{"Del":{"text":" .map(|x| x as f32)","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2297"}},{"Del":{"text":" .map(|x| x.sin())","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2327"}},{"Del":{"text":" .collect::>();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2361"}},{"Del":{"text":" let mut arr = arr0","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2388"}},{"Del":{"text":" .iter()","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2408"}},{"Del":{"text":" .map(|x| x.into_datum())","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2445"}},{"Del":{"text":" .map(|x| x.unwrap())","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2478"}},{"Del":{"text":" .collect::>();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2524"}},{"Del":{"text":" let mut nulls = arr.iter().map(|_| false).collect::>();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2598"}},{"Del":{"text":" let mut arr_2 = arr.clone();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2635"}},{"Del":{"text":" let mut nulls_2 = nulls.clone();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2676"}},{"Del":{"text":" println!(\"{:?}\", arr);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2707"}},{"Del":{"text":" let vec1 = unsafe {","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2735"}},{"Del":{"text":" let size = arr.len();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2769"}},{"Del":{"text":" let b = arr.as_mut_ptr();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2807"}},{"Del":{"text":" println!(\"{:?}\", b);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2840"}},{"Del":{"text":" Array::over(b, nulls.as_mut_ptr(), size)","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2893"}},{"Del":{"text":" };","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2904"}},{"Del":{"text":" vec1.iter().for_each(|x| {","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2939"}},{"Del":{"text":" println!(\"{:?}\", x);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2972"}},{"Del":{"text":" });","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:2984"}},{"Del":{"text":" let vec2 = unsafe {","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3012"}},{"Del":{"text":" let size = arr_2.len();","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3048"}},{"Del":{"text":" Array::over(arr_2.as_mut_ptr(), nulls_2.as_mut_ptr(), size)","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3120"}},{"Del":{"text":" };","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3131"}},{"Del":{"text":" vec2.iter().zip(arr0.iter()).for_each(|(x, y)| {","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3188"}},{"Del":{"text":" println!(\"{:?}\", x.unwrap() - y);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3234"}},{"Del":{"text":" });","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3246"}},{"Del":{"text":" let d = l2_dist(vec1, vec2);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3283"}},{"Del":{"text":" println!(\"distance: {}\", d);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3320"}},{"Del":{"text":"","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3321"}},{"Del":{"text":" assert!(false);","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3345"}},{"Del":{"text":" }","pos":"IFWHYAZTPKL7ZVOV3AFZNIUTRLMVSOACYACA3CI4DSEEZU77YQEQC:3351"}}]}},{"Edit":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":141,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2444}],"down_context":[{"change":3,"pos":2444}],"flag":"BLOCK","start":1138,"end":1146,"inode":{"change":3,"pos":28}}},"contents":[{"Add":{"text":" ///","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1145"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":232,"ins":{"up_context":[{"change":3,"pos":5530}],"down_context":[{"change":3,"pos":5615}],"flag":"BLOCK","start":1147,"end":1229,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5530},"to":{"change":3,"start":5530,"end":5615},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" let len = good_start * 4; // something less than BLOCK_SIZE - good_start;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1228"}}],"del_contents":[{"Del":{"text":" let len = good_start * 1024; // something less than BLOCK_SIZE - good_start;","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:5614"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":236,"ins":{"up_context":[{"change":3,"pos":5725}],"down_context":[{"change":3,"pos":5710}],"flag":"BLOCK","start":1230,"end":1286,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5725},"to":{"change":3,"start":5725,"end":5790},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" F32BlockError::overflow(good_start, len, 0)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1285"}}],"del_contents":[{"Del":{"text":" F32BlockError::overflow(good_start, len, BLOCK_SIZE)","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:5789"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":240,"ins":{"up_context":[{"change":3,"pos":5860}],"down_context":[{"change":3,"pos":5912}],"flag":"BLOCK","start":1287,"end":1448,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5860},"to":{"change":3,"start":5860,"end":5912},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" assert!(mem.free(good_start, len - good_start).is_ok());","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1351"}},{"Add":{"text":" mem.push_iter((0..(len - good_start)).map(|x| (x as f32).cos()))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1424"}},{"Add":{"text":" .unwrap();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1447"}}],"del_contents":[{"Del":{"text":" assert!(mem.free(good_start, len).is_ok());","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:5911"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":249,"ins":{"up_context":[{"change":3,"pos":5992}],"down_context":[{"change":3,"pos":6201}],"flag":"BLOCK","start":1449,"end":1506,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":47},"to":{"change":3,"start":6145,"end":6201},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5992},"to":{"change":3,"start":6145,"end":6201},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6145},"to":{"change":3,"start":6145,"end":6201},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":"pub struct FiniteDimAllocator {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1505"}}],"del_contents":[{"Del":{"text":"pub struct FiniteDimAllocator {","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:6200"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":251,"ins":{"up_context":[{"change":3,"pos":6221}],"down_context":[{"change":3,"pos":6290}],"flag":"BLOCK","start":1507,"end":1563,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6239},"to":{"change":3,"start":6239,"end":6255},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6255},"to":{"change":3,"start":48,"end":83},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" pub len: usize,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1526"}},{"Add":{"text":" f32_data: F32Block,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1562"}}],"del_contents":[{"Del":{"text":" len: usize,","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:6254"}},{"Del":{"text":" f32_data: F32Block,","pos":"SIHQ3OG5GIBQLSMOBKSD2IHFTGFXU4VDCX45BH2ABS42BV3N2UIQC:82"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":256,"ins":{"up_context":[{"change":3,"pos":6372}],"down_context":[{"change":3,"pos":6495}],"flag":"BLOCK","start":1564,"end":1690,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6372},"to":{"change":3,"start":6372,"end":6495},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":"impl FiniteDimAllocator {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1626"}},{"Add":{"text":" fn new(dimension: u16) -> FiniteDimAllocator {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1689"}}],"del_contents":[{"Del":{"text":"impl FiniteDimAllocator {","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:6432"}},{"Del":{"text":" fn new(dimension: u16) -> FiniteDimAllocator {","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:6494"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":261,"ins":{"up_context":[{"change":3,"pos":6589}],"down_context":[{"change":3,"pos":6645}],"flag":"BLOCK","start":1691,"end":1748,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6589},"to":{"change":3,"start":84,"end":140},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" f32_data: F32Block::::default(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1747"}}],"del_contents":[{"Del":{"text":" f32_data: F32Block::::default(),","pos":"SIHQ3OG5GIBQLSMOBKSD2IHFTGFXU4VDCX45BH2ABS42BV3N2UIQC:139"}}]}},{"Edit":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":266,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":6055}],"down_context":[{"change":3,"pos":6055}],"flag":"BLOCK","start":1749,"end":1844,"inode":{"change":3,"pos":28}}},"contents":[{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1754"}},{"Add":{"text":" pub fn clear(&mut self) {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1784"}},{"Add":{"text":" self.len = 0;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1806"}},{"Add":{"text":" self.f32_data.0.truncate(0);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1843"}}]}},{"Edit":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":273,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":6710}],"down_context":[{"change":3,"pos":6710}],"flag":"BLOCK","start":1845,"end":2035,"inode":{"change":3,"pos":28}}},"contents":[{"Add":{"text":" let data_len = self.f32_data.0.len();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1890"}},{"Add":{"text":" let remainder = data_len % (dimension as usize);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1947"}},{"Add":{"text":" let new_len = data_len - remainder;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:1991"}},{"Add":{"text":" self.f32_data.0.truncate(new_len);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2034"}}]}},{"Replacement":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":283,"ins":{"up_context":[{"change":3,"pos":6819}],"down_context":[{"change":3,"pos":6062}],"flag":"BLOCK","start":2036,"end":2152,"inode":{"change":3,"pos":28}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6819},"to":{"change":3,"start":6819,"end":6848},"introduced_by":3}],"inode":{"change":3,"pos":28}},"ins_contents":[{"Add":{"text":" pub fn get_max_entries(&self) -> usize {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2080"}},{"Add":{"text":" BLOCK_SIZE / self.dim()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2112"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2118"}},{"Add":{"text":" pub fn end(&self) -> usize {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2151"}}],"del_contents":[{"Del":{"text":" fn end(&self) -> usize {","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:6847"}}]}},{"Edit":{"inode":{"change":3,"pos":28},"path":"src/vec_block_alloc.rs","line":365,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8970},"to":{"change":3,"start":8970,"end":9186},"introduced_by":3}],"inode":{"change":3,"pos":28}}},"contents":[{"Del":{"text":" }","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:8975"}},{"Del":{"text":"","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:8976"}},{"Del":{"text":" #[test]","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:8988"}},{"Del":{"text":" fn print_size() {","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:9010"}},{"Del":{"text":" const SIZE: usize = 523934;","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:9046"}},{"Del":{"text":" let size = std::mem::size_of::>();","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:9114"}},{"Del":{"text":" print!(\"Size of allocator: {}\", size);","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:9161"}},{"Del":{"text":" assert!(false);","pos":"LECAQCCL2UKTMH3LQSGEFVBOF6CYCGJGJZM2I2T4R7QPTBVW4VYQC:9185"}}]}},{"Edit":{"inode":{"change":3,"pos":50512},"path":"src/shmem_blocks.rs","line":65,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":569}],"down_context":[{"change":3,"pos":51920}],"flag":"BLOCK","start":2153,"end":2206,"inode":{"change":3,"pos":50512}}},"contents":[{"Add":{"text":" println!(\"Setting stuff: {}\", size);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2205"}}]}},{"Edit":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":2,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":7199}],"down_context":[{"change":3,"pos":7199}],"flag":"BLOCK","start":2207,"end":2225,"inode":{"change":3,"pos":206}}},"contents":[{"Add":{"text":"pub mod handlers;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2224"}}]}},{"Edit":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":7228}],"down_context":[{"change":3,"pos":219}],"flag":"BLOCK","start":2226,"end":2295,"inode":{"change":3,"pos":206}}},"contents":[{"Add":{"text":"use crate::FiniteDimAllocator;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2256"}},{"Add":{"text":"use either::Either;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2276"}},{"Add":{"text":"use itertools::*;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2294"}}]}},{"Edit":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":231}],"down_context":[{"change":3,"pos":7229}],"flag":"BLOCK","start":2296,"end":2335,"inode":{"change":3,"pos":206}}},"contents":[{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2296"}},{"Add":{"text":"use crate::shmem_blocks::ShMemBlocks;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2334"}}]}},{"Edit":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":15,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":7317}],"down_context":[{"change":3,"pos":7317}],"flag":"BLOCK","start":2336,"end":8943,"inode":{"change":3,"pos":206}}},"contents":[{"Add":{"text":"pub const CREATE_STR: &str = r#\"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2368"}},{"Add":{"text":" CREATE TABLE IF NOT EXISTS index_has_allocation (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2422"}},{"Add":{"text":" id serial8 not null primary key,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2463"}},{"Add":{"text":" index_table_name text NOT NULL,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2503"}},{"Add":{"text":" table_name text NOT NULL,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2537"}},{"Add":{"text":" allocation integer UNIQUE NOT NULL,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2581"}},{"Add":{"text":" dim integer NOT NULL","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2610"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2617"}},{"Add":{"text":" \"#;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2625"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2626"}},{"Add":{"text":"pub fn init_index_alloc_table() {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2660"}},{"Add":{"text":" Spi::connect(|mut client| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2692"}},{"Add":{"text":" client.update(CREATE_STR, None, None);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2739"}},{"Add":{"text":" Ok(Some(()))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2760"}},{"Add":{"text":" });","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2768"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2770"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2771"}},{"Add":{"text":"fn get_ord_opt(heap_tup_data: &SpiHeapTupleData, ord: usize) -> Option {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2861"}},{"Add":{"text":" heap_tup_data","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2879"}},{"Add":{"text":" .by_ordinal(ord)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2904"}},{"Add":{"text":" .ok()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2918"}},{"Add":{"text":" .map(|datum| datum.value::())","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2959"}},{"Add":{"text":" .flatten()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2978"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2980"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:2981"}},{"Add":{"text":"/// This function clears allocation blocks that we've stored by can't use","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3055"}},{"Add":{"text":"pub fn clear_non_existent_allocs(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3108"}},{"Add":{"text":" shmem_blocks: &'static ShMemBlocks,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3154"}},{"Add":{"text":") -> Option<()> {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3172"}},{"Add":{"text":" let size = shmem_blocks.get_size();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3212"}},{"Add":{"text":" Spi::connect(|mut client| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3244"}},{"Add":{"text":" client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3267"}},{"Add":{"text":" \"DELETE FROM index_has_allocation WHERE allocation > $1;\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3338"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3356"}},{"Add":{"text":" Some(vec![(PgBuiltInOids::INT4OID.oid(), size.into_datum())]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3431"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3442"}},{"Add":{"text":" let bad_rows = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3472"}},{"Add":{"text":" .select(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3493"}},{"Add":{"text":" \"SELECT id, allocation, dim, index_table_name, table_name FROM index_has_allocation;\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3597"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3619"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3641"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3655"}},{"Add":{"text":" .filter_map(|spi_heap_tuple_data| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3703"}},{"Add":{"text":" let id_opt: Option = get_ord_opt(&spi_heap_tuple_data, 1);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3783"}},{"Add":{"text":" let alloc_opt: Option = get_ord_opt(&spi_heap_tuple_data, 2);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3866"}},{"Add":{"text":" let dim_opt: Option = get_ord_opt(&spi_heap_tuple_data, 3);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:3947"}},{"Add":{"text":" let index_table_opt: Option = get_ord_opt(&spi_heap_tuple_data, 4);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4039"}},{"Add":{"text":" let table_opt: Option = get_ord_opt(&spi_heap_tuple_data, 5);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4125"}},{"Add":{"text":" if let Some(id) = id_opt {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4168"}},{"Add":{"text":" if let (Some(allocation_index), Some(dim), Some(index_table_name), Some(table_name)) =","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4275"}},{"Add":{"text":" (alloc_opt, dim_opt, index_table_opt, table_opt)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4348"}},{"Add":{"text":" {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4370"}},{"Add":{"text":" if let Some(allocation_lock) =","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4425"}},{"Add":{"text":" shmem_blocks.get_block(allocation_index as usize)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4503"}},{"Add":{"text":" {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4529"}},{"Add":{"text":" let mut allocation = allocation_lock.exclusive();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4607"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4608"}},{"Add":{"text":" allocation.clear();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4656"}},{"Add":{"text":" allocation.set_dim(dim as u16);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4716"}},{"Add":{"text":" load_vecs_into_mem(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4764"}},{"Add":{"text":" &mut client,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4809"}},{"Add":{"text":" allocation_lock,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4858"}},{"Add":{"text":" allocation_index,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4908"}},{"Add":{"text":" dim as u16,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:4952"}},{"Add":{"text":" &index_table_name,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5003"}},{"Add":{"text":" &table_name,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5048"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5049"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5080"}},{"Add":{"text":" None","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5113"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5146"}},{"Add":{"text":" Some(id)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5183"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5209"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5238"}},{"Add":{"text":" Some(id)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5271"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5293"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5318"}},{"Add":{"text":" None","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5343"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5361"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5376"}},{"Add":{"text":" .collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5410"}},{"Add":{"text":" client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5433"}},{"Add":{"text":" \"DELETE FROM index_has_allocation WHERE id in $1;\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5497"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5515"}},{"Add":{"text":" Some(vec![(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5539"}},{"Add":{"text":" PgBuiltInOids::INT8ARRAYOID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5590"}},{"Add":{"text":" bad_rows.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5629"}},{"Add":{"text":" )]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5646"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5657"}},{"Add":{"text":" Ok(Some(()))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5678"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5685"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5687"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5688"}},{"Add":{"text":"#[derive(Clone, Copy)]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5711"}},{"Add":{"text":"struct ReIndex {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5728"}},{"Add":{"text":" idx_table_id: i64,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5751"}},{"Add":{"text":" lookup: i64,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5768"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5770"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5771"}},{"Add":{"text":"fn load_vecs_into_mem(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5813"}},{"Add":{"text":" client: &mut SpiClient,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5841"}},{"Add":{"text":" lock: &PgLwLock>,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5888"}},{"Add":{"text":" allocation_index: i32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5915"}},{"Add":{"text":" dim: u16,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5929"}},{"Add":{"text":" index_table_name: &str,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5957"}},{"Add":{"text":" table_name: &str,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5979"}},{"Add":{"text":") {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:5983"}},{"Add":{"text":" let tup_table = client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6018"}},{"Add":{"text":" \"SELECT","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6034"}},{"Add":{"text":" idx_table.id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6060"}},{"Add":{"text":" idx_table.lookup_index,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6096"}},{"Add":{"text":" data_table.vec_data","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6128"}},{"Add":{"text":" FROM $1 idx_table","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6154"}},{"Add":{"text":" JOIN $2 data_table","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6181"}},{"Add":{"text":" ON idx_table.vec_id = data_table.vec_id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6234"}},{"Add":{"text":" WHERE allocation_index = $2","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6270"}},{"Add":{"text":" ORDER BY lookup_index;\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6303"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6317"}},{"Add":{"text":" Some(vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6336"}},{"Add":{"text":" (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6350"}},{"Add":{"text":" PgBuiltInOids::REGCLASSOID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6400"}},{"Add":{"text":" index_table_name.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6447"}},{"Add":{"text":" ),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6462"}},{"Add":{"text":" (PgBuiltInOids::REGCLASSOID.oid(), table_name.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6535"}},{"Add":{"text":" (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6549"}},{"Add":{"text":" PgBuiltInOids::INT4OID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6595"}},{"Add":{"text":" (allocation_index as i32).into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6651"}},{"Add":{"text":" ),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6666"}},{"Add":{"text":" ]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6678"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6685"}},{"Add":{"text":" let mut allocation = lock.exclusive();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6728"}},{"Add":{"text":" let max_entries = allocation.get_max_entries();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6780"}},{"Add":{"text":" let mut current_lookup = 0;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6812"}},{"Add":{"text":" let (reindex, delete): (Vec<_>, Vec<_>) = tup_table","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6868"}},{"Add":{"text":" .filter_map(|tup_desc_data| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6906"}},{"Add":{"text":" let idx_table_id = get_ord_opt::(&tup_desc_data, 1)?;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:6977"}},{"Add":{"text":" if let Some(vec_data) = get_ord_opt::>(&tup_desc_data, 3) {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7058"}},{"Add":{"text":" allocation.add_vec(&vec_data);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7105"}},{"Add":{"text":" if let Some(lookup_idx) = get_ord_opt::(&tup_desc_data, 2) {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7187"}},{"Add":{"text":" if current_lookup == lookup_idx {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7241"}},{"Add":{"text":" None","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7270"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7299"}},{"Add":{"text":" let reindex = Some(Either::Left(ReIndex {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7365"}},{"Add":{"text":" idx_table_id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7407"}},{"Add":{"text":" lookup: current_lookup,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7459"}},{"Add":{"text":" }));","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7488"}},{"Add":{"text":" current_lookup += 1;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7533"}},{"Add":{"text":" reindex","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7565"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7587"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7612"}},{"Add":{"text":" let reindex = Some(Either::Left(ReIndex {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7674"}},{"Add":{"text":" idx_table_id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7712"}},{"Add":{"text":" lookup: current_lookup,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7760"}},{"Add":{"text":" }));","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7785"}},{"Add":{"text":" current_lookup += 1;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7826"}},{"Add":{"text":" reindex","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7854"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7872"}},{"Add":{"text":" } else {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7893"}},{"Add":{"text":" let delete = Some(Either::Right(idx_table_id));","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7957"}},{"Add":{"text":" current_lookup += 1;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:7994"}},{"Add":{"text":" delete","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8017"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8031"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8042"}},{"Add":{"text":" .partition_map(|x| x);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8073"}},{"Add":{"text":" for ReIndex {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8091"}},{"Add":{"text":" idx_table_id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8113"}},{"Add":{"text":" lookup,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8129"}},{"Add":{"text":" } in reindex.iter()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8153"}},{"Add":{"text":" {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8159"}},{"Add":{"text":" client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8182"}},{"Add":{"text":" \"UPDATE $1","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8205"}},{"Add":{"text":" SET lookup_index = $2,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8241"}},{"Add":{"text":" WHERE id = $3\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8270"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8288"}},{"Add":{"text":" Some(vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8311"}},{"Add":{"text":" (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8329"}},{"Add":{"text":" PgBuiltInOids::REGCLASSOID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8383"}},{"Add":{"text":" index_table_name.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8434"}},{"Add":{"text":" ),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8453"}},{"Add":{"text":" (PgBuiltInOids::INT4OID.oid(), lookup.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8522"}},{"Add":{"text":" (PgBuiltInOids::INT8OID.oid(), idx_table_id.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8597"}},{"Add":{"text":" ]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8613"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8624"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8630"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8631"}},{"Add":{"text":" client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8650"}},{"Add":{"text":" \"DELETE FROM $1 WHERE id in $2\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8691"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8705"}},{"Add":{"text":" Some(vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8724"}},{"Add":{"text":" (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8738"}},{"Add":{"text":" PgBuiltInOids::REGCLASSOID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8788"}},{"Add":{"text":" index_table_name.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8835"}},{"Add":{"text":" ),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8850"}},{"Add":{"text":" (PgBuiltInOids::INT8ARRAYOID.oid(), delete.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8920"}},{"Add":{"text":" ]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8932"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8939"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8941"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8942"}}]}},{"Replacement":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":241,"ins":{"up_context":[{"change":3,"pos":8246}],"down_context":[{"change":3,"pos":8577}],"flag":"BLOCK","start":8944,"end":9862,"inode":{"change":3,"pos":206}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8246},"to":{"change":3,"start":8246,"end":8577},"introduced_by":3}],"inode":{"change":3,"pos":206}},"ins_contents":[{"Add":{"text":"#[cfg(any(test, feature = \"pg_test\"))]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8982"}},{"Add":{"text":"mod tests {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:8994"}},{"Add":{"text":" use crate::init_index_alloc_table;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9033"}},{"Add":{"text":" use crate::mem_cache_index::handlers::AllocatorWithCount;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9095"}},{"Add":{"text":" use crate::mem_cache_index::handlers::MemCacheVectorsBuilder;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9161"}},{"Add":{"text":" use crate::mem_cache_index::handlers::SharedMemHandler;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9221"}},{"Add":{"text":" use crate::mem_cache_index::handlers::Vectors;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9272"}},{"Add":{"text":" use crate::mem_cache_index::handlers::VectorsBuilder;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9330"}},{"Add":{"text":" use std::ops::Deref;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9355"}},{"Add":{"text":" use std::ops::DerefMut;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9383"}},{"Add":{"text":" use std::sync::RwLock;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9410"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9411"}},{"Add":{"text":" use crate::MAX_SPACE;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9437"}},{"Add":{"text":" use crate::SHMEM_BLOCKS;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9466"}},{"Add":{"text":" use pgx::*;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9482"}},{"Add":{"text":" use rand::*;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9499"}},{"Add":{"text":" use rand_distr::{Distribution, Poisson, Uniform};","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9553"}},{"Add":{"text":" use serde::{Deserialize, Serialize};","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9594"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9595"}},{"Add":{"text":" pub fn postgresql_conf_options() -> Vec<&'static str> {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9655"}},{"Add":{"text":" // return any postgresql.conf settings that are required for your tests","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9735"}},{"Add":{"text":" vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9749"}},{"Add":{"text":" \"\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9765"}},{"Add":{"text":" \"shared_buffers = 512MB\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9803"}},{"Add":{"text":" \"pgvector.allocation_blocks = 128\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9851"}},{"Add":{"text":" ]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9861"}}],"del_contents":[{"Del":{"text":"#[cfg(test)]","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8258"}},{"Del":{"text":"mod test {","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8269"}},{"Del":{"text":" // We want to try out something like","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8310"}},{"Del":{"text":" // ```sql","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8324"}},{"Del":{"text":" // CREATE TABLE public.vecs_2","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8358"}},{"Del":{"text":" //(","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8366"}},{"Del":{"text":" // idx bigserial,","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8391"}},{"Del":{"text":" // vec real[] CONSTRAINT vecs_2_dim512 CHECK (cardinality(vec) = 512),","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8469"}},{"Del":{"text":" // PRIMARY KEY (idx)","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8497"}},{"Del":{"text":" //);","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8506"}},{"Del":{"text":" //","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8513"}},{"Del":{"text":" // ```","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8524"}},{"Del":{"text":" fn test_constraints() {","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8552"}},{"Del":{"text":" todo!() // YOLO","pos":"UV2RTMNSNI3AJFVVD66OT3CEF7WU7TLAPJKACGX7BBSSWAEBAAAAC:8576"}}]}},{"Edit":{"inode":{"change":3,"pos":206},"path":"src/mem_cache_index/mod.rs","line":268,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":8583}],"down_context":[{"change":3,"pos":8583}],"flag":"BLOCK","start":9863,"end":12211,"inode":{"change":3,"pos":206}}},"contents":[{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9863"}},{"Add":{"text":" #[pg_test]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9878"}},{"Add":{"text":" fn test_rebuild() {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9902"}},{"Add":{"text":" let mut rng = thread_rng();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9938"}},{"Add":{"text":" let poisson = Poisson::new(1024.0).unwrap();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:9991"}},{"Add":{"text":" let n_vecs = poisson.sample(&mut rng) as i32;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10045"}},{"Add":{"text":" let dim = 512u16;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10071"}},{"Add":{"text":" let mut shmem_handler = SharedMemHandler {};","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10124"}},{"Add":{"text":" init_index_alloc_table();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10158"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10159"}},{"Add":{"text":" println!(\"Building vectors\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10197"}},{"Add":{"text":" let vectors = VectorsBuilder::new().init(dim);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10252"}},{"Add":{"text":" for _ in 0..n_vecs {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10281"}},{"Add":{"text":" let unif = Uniform::new(-1.0, 1.0);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10329"}},{"Add":{"text":" let vec = (0..dim).map(|_| unif.sample(&mut rng)).collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10412"}},{"Add":{"text":" Spi::connect(|mut client| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10452"}},{"Add":{"text":" client.update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10483"}},{"Add":{"text":" \"INSERT INTO vectors (vec) VALUES ($1)\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10544"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10570"}},{"Add":{"text":" Some(vec![(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10602"}},{"Add":{"text":" PgBuiltInOids::FLOAT4ARRAYOID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10663"}},{"Add":{"text":" vec.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10705"}},{"Add":{"text":" )]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10730"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10749"}},{"Add":{"text":" Ok(Some(()))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10778"}},{"Add":{"text":" });","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10794"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10804"}},{"Add":{"text":" println!(\"DONE Building vectors\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10847"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10848"}},{"Add":{"text":" let mut mem_cache_vectors = MemCacheVectorsBuilder::new().init();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10922"}},{"Add":{"text":" mem_cache_vectors.push_batch(&mut shmem_handler, &vectors);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:10990"}},{"Add":{"text":" let AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11023"}},{"Add":{"text":" allocator_index,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11052"}},{"Add":{"text":" count,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11071"}},{"Add":{"text":" } = Spi::connect(|client| -> Result, SpiError> {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11155"}},{"Add":{"text":" let (allocator, count) = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11199"}},{"Add":{"text":" .select(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11224"}},{"Add":{"text":" \"SELECT ","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11253"}},{"Add":{"text":" allocator,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11284"}},{"Add":{"text":" COUNT(*) n_vecs","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11320"}},{"Add":{"text":" FROM memcache_index_vectors","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11365"}},{"Add":{"text":" GROUP BY allocator","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11401"}},{"Add":{"text":" ORDER BY n_vecs DESC\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11441"}},{"Add":{"text":" Some(1),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11470"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11496"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11514"}},{"Add":{"text":" .first()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11539"}},{"Add":{"text":" .get_two::();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11579"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11580"}},{"Add":{"text":" Ok(allocator.map(|allocator_index| AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11648"}},{"Add":{"text":" allocator_index: allocator_index as u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11705"}},{"Add":{"text":" count: count.expect(\"Missing count\") as u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11766"}},{"Add":{"text":" }))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11782"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11793"}},{"Add":{"text":" .expect(\"Failed to get vec count\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11837"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11838"}},{"Add":{"text":" let end = SHMEM_BLOCKS","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11869"}},{"Add":{"text":" .get_block(allocator_index as usize)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11918"}},{"Add":{"text":" .expect(\"Couldn't get allocator\")","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11964"}},{"Add":{"text":" .share()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:11985"}},{"Add":{"text":" .len;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12003"}},{"Add":{"text":" assert_eq!(end, count as usize);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12044"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12045"}},{"Add":{"text":" // let c = Spi::get_one::(\"SELECT sum(array_length(vec, 1)) FROM vectors\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12142"}},{"Add":{"text":" // assert_eq!(Some((dim as i32) * n_vecs), c);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12204"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12210"}}]}},{"FileAdd":{"meta":{"basename":"handlers.rs","metadata":0},"context":[{"change":3,"pos":196}],"contents":[{"Add":{"text":"use crate::MAX_SPACE;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12270"}},{"Add":{"text":"use crate::SHMEM_BLOCKS;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12295"}},{"Add":{"text":"use pgx::*;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12307"}},{"Add":{"text":"use serde::{Deserialize, Serialize};","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12344"}},{"Add":{"text":"use std::ops::Deref;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12365"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12366"}},{"Add":{"text":"pub struct VectorsBuilder {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12395"}},{"Add":{"text":"impl VectorsBuilder {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12417"}},{"Add":{"text":" pub(crate) fn new() -> Self {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12451"}},{"Add":{"text":" VectorsBuilder {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12477"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12483"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12484"}},{"Add":{"text":" pub(crate) fn init(self, dim: u16) -> Vectors {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12536"}},{"Add":{"text":" Spi::run(&format!(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12563"}},{"Add":{"text":" \"CREATE TABLE vectors (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12599"}},{"Add":{"text":" id serial8 not null primary key,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12653"}},{"Add":{"text":" vec real[{}]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12687"}},{"Add":{"text":" )\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12708"}},{"Add":{"text":" dim","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12724"}},{"Add":{"text":" ));","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12736"}},{"Add":{"text":" Vectors { dim }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12760"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12766"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12768"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12769"}},{"Add":{"text":"pub(crate) struct Vectors {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12797"}},{"Add":{"text":" dim: u16,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12811"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12813"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12814"}},{"Add":{"text":"impl Vectors {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12829"}},{"Add":{"text":" pub(crate) fn get_vecs_block<'a>(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12867"}},{"Add":{"text":" &'a self,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12885"}},{"Add":{"text":" client: &'a SpiClient,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12916"}},{"Add":{"text":" n_vectors: u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12940"}},{"Add":{"text":" ) -> impl Iterator + 'a {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:12988"}},{"Add":{"text":" let dim = self.dim as usize;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13025"}},{"Add":{"text":" client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13040"}},{"Add":{"text":" .select(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13061"}},{"Add":{"text":" \"SELECT","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13085"}},{"Add":{"text":" vectors.id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13121"}},{"Add":{"text":" vectors.vec","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13157"}},{"Add":{"text":" FROM vectors","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13190"}},{"Add":{"text":" LEFT JOIN memcache_index_vectors miv","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13247"}},{"Add":{"text":" ON miv.vector_id = vectors.id","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13301"}},{"Add":{"text":" WHERE allocator_index IS NULL\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13353"}},{"Add":{"text":" Some(n_vectors as i64),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13393"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13415"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13429"}},{"Add":{"text":" .map(move |tuple| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13461"}},{"Add":{"text":" let id = tuple","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13492"}},{"Add":{"text":" .by_ordinal(1)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13527"}},{"Add":{"text":" .expect(\"The table schema disallows null vector_ids. This shouldn't be NULL\")","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13625"}},{"Add":{"text":" .value::()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13661"}},{"Add":{"text":" .expect(\"The value should definitely not be null\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13733"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13734"}},{"Add":{"text":" let vec = tuple","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13766"}},{"Add":{"text":" .by_ordinal(2)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13801"}},{"Add":{"text":" .expect(\"The vector argument can't be null\")","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13866"}},{"Add":{"text":" .value::>()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13907"}},{"Add":{"text":" .expect(\"There should definitely be a vector here\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:13980"}},{"Add":{"text":" assert!(vec.len() <= dim);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14023"}},{"Add":{"text":" VecWithId { id, vec }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14061"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14076"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14082"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14084"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14085"}},{"Add":{"text":"pub(crate) struct SharedMemHandler {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14123"}},{"Add":{"text":"impl SharedMemHandler {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14147"}},{"Add":{"text":" pub fn get_new_block(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14173"}},{"Add":{"text":" &mut self,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14192"}},{"Add":{"text":" client: &mut SpiClient,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14224"}},{"Add":{"text":" vec_table: &Vectors,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14253"}},{"Add":{"text":" vec_table_name: &str,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14283"}},{"Add":{"text":" memcache_table: &str,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14313"}},{"Add":{"text":" ) -> Option {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14351"}},{"Add":{"text":" let size = (SHMEM_BLOCKS.get_size() as i32) - 1;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14408"}},{"Add":{"text":" client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14423"}},{"Add":{"text":" .select(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14444"}},{"Add":{"text":" \"SELECT ","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14469"}},{"Add":{"text":" i","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14507"}},{"Add":{"text":" FROM generate_series(0, $1) range(i)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14577"}},{"Add":{"text":" LEFT JOIN index_has_allocation iha","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14645"}},{"Add":{"text":" ON iha.allocation = range.i","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14709"}},{"Add":{"text":" WHERE iha.allocation IS NULL","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14771"}},{"Add":{"text":" ORDER BY i\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14817"}},{"Add":{"text":" Some(1),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14842"}},{"Add":{"text":" Some(vec![(PgBuiltInOids::INT4OID.oid(), size.into_datum())]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14921"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14935"}},{"Add":{"text":" .first()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14956"}},{"Add":{"text":" .get_one::()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:14986"}},{"Add":{"text":" .map(|index| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15013"}},{"Add":{"text":" let lock = SHMEM_BLOCKS","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15053"}},{"Add":{"text":" .get_block(index as usize)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15100"}},{"Add":{"text":" .expect(\"The lock must exist by passing size above\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15174"}},{"Add":{"text":" lock.exclusive().set_dim(vec_table.dim);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15231"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15232"}},{"Add":{"text":" let inserts = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15269"}},{"Add":{"text":" .update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15298"}},{"Add":{"text":" \"INSERT INTO index_has_allocation (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15358"}},{"Add":{"text":" index_table_name,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15416"}},{"Add":{"text":" table_name,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15468"}},{"Add":{"text":" allocation,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15520"}},{"Add":{"text":" dim","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15564"}},{"Add":{"text":" )VALUES (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15610"}},{"Add":{"text":" $1,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15654"}},{"Add":{"text":" $2,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15698"}},{"Add":{"text":" $3,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15742"}},{"Add":{"text":" $4","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15785"}},{"Add":{"text":" )\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15825"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15855"}},{"Add":{"text":" Some(vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15890"}},{"Add":{"text":" (PgBuiltInOids::TEXTOID.oid(), memcache_table.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:15979"}},{"Add":{"text":" (PgBuiltInOids::TEXTOID.oid(), vec_table_name.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16068"}},{"Add":{"text":" (PgBuiltInOids::INT4OID.oid(), index.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16148"}},{"Add":{"text":" (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16178"}},{"Add":{"text":" PgBuiltInOids::INT4OID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16240"}},{"Add":{"text":" (vec_table.dim as i32).into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16309"}},{"Add":{"text":" ),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16340"}},{"Add":{"text":" ]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16368"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16390"}},{"Add":{"text":" .count();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16420"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16421"}},{"Add":{"text":" let max_vecs_per_block = MAX_SPACE as u32 / vec_table.dim as u32;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16503"}},{"Add":{"text":" AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16540"}},{"Add":{"text":" allocator_index: index as u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16591"}},{"Add":{"text":" count: max_vecs_per_block,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16638"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16656"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16671"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16677"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16679"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16680"}},{"Add":{"text":"pub(crate) struct MemCacheVectorsBuilder {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16724"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16725"}},{"Add":{"text":"impl MemCacheVectorsBuilder {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16755"}},{"Add":{"text":" pub(crate) fn new() -> Self {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16789"}},{"Add":{"text":" MemCacheVectorsBuilder {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16823"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16829"}},{"Add":{"text":" pub(crate) fn init(self) -> MemCacheVectors {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16879"}},{"Add":{"text":" Spi::run(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16897"}},{"Add":{"text":" \"CREATE TABLE memcache_index_vectors (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:16948"}},{"Add":{"text":" id serial8 not null primary key,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17002"}},{"Add":{"text":" vector_id bigint UNIQUE NOT NULL REFERENCES vectors(id),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17080"}},{"Add":{"text":" allocator integer NOT NULL REFERENCES index_has_allocation(allocation),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17173"}},{"Add":{"text":" allocator_index integer NOT NULL,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17228"}},{"Add":{"text":" UNIQUE (allocator, allocator_index)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17285"}},{"Add":{"text":" )\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17306"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17317"}},{"Add":{"text":" MemCacheVectors {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17344"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17350"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17352"}},{"Add":{"text":"pub(crate) struct MemCacheVectors {}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17389"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17390"}},{"Add":{"text":"#[derive(Serialize, Deserialize, PostgresType, Debug)]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17445"}},{"Add":{"text":"pub struct AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17477"}},{"Add":{"text":" pub allocator_index: u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17507"}},{"Add":{"text":" pub count: u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17527"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17529"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17530"}},{"Add":{"text":"#[derive(Deserialize, Serialize, PostgresType, Debug)]","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17585"}},{"Add":{"text":"pub struct VecWithId {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17608"}},{"Add":{"text":" pub id: i64,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17625"}},{"Add":{"text":" pub vec: Vec,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17648"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17650"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17651"}},{"Add":{"text":"impl MemCacheVectors {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17674"}},{"Add":{"text":" pub(crate) fn push_batch(&mut self, shmem: &mut SharedMemHandler, vec: &Vectors) {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17761"}},{"Add":{"text":" Spi::connect(|mut client| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17797"}},{"Add":{"text":" let max_vecs_per_block = (MAX_SPACE / (vec.dim as usize)) as u32;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17875"}},{"Add":{"text":" let AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17912"}},{"Add":{"text":" allocator_index,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17945"}},{"Add":{"text":" count,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17968"}},{"Add":{"text":" } = self","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:17989"}},{"Add":{"text":" .get_smallest_existing_alloc(&client, max_vecs_per_block)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18063"}},{"Add":{"text":" .or_else(|| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18093"}},{"Add":{"text":" shmem.get_new_block(&mut client, vec, \"vectors\", \"memcache_index_vectors\")","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18188"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18207"}},{"Add":{"text":" .ok_or(SpiError::Transaction)?; // Probably unwrap is better","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18284"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18285"}},{"Add":{"text":" let entries = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18318"}},{"Add":{"text":" .select(\"SELECT COUNT(*) FROM memcache_index_vectors\", None, None)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18401"}},{"Add":{"text":" .first()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18426"}},{"Add":{"text":" .get_one::();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18461"}},{"Add":{"text":" let vecs_with_ids = vec.get_vecs_block(&mut client, count).collect::>();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18553"}},{"Add":{"text":" vecs_with_ids.iter().for_each(|vec_with_id| {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18611"}},{"Add":{"text":" self.push_vector(allocator_index as usize, &mut client, vec_with_id)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18696"}},{"Add":{"text":" .expect(\"Failed to push vec\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18747"}},{"Add":{"text":" }); // todo if one of these fails, there should be a recovery step.","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18827"}},{"Add":{"text":" Ok(Some(()))","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18852"}},{"Add":{"text":" });","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18864"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18870"}},{"Add":{"text":" fn push_vector(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18890"}},{"Add":{"text":" &mut self,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18909"}},{"Add":{"text":" allocator_number: usize,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18942"}},{"Add":{"text":" client: &mut SpiClient,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:18974"}},{"Add":{"text":" vec_with_id: &VecWithId,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19007"}},{"Add":{"text":" ) -> Result<(), String> {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19037"}},{"Add":{"text":" let lock = SHMEM_BLOCKS.get_block(allocator_number).ok_or(format!(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19112"}},{"Add":{"text":" \"How did we get an allocator_index {}, when we have { } allocators\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19193"}},{"Add":{"text":" allocator_number,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19223"}},{"Add":{"text":" SHMEM_BLOCKS.get_size()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19259"}},{"Add":{"text":" ))?;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19272"}},{"Add":{"text":" let mut allocator = lock.exclusive();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19318"}},{"Add":{"text":" let VecWithId { id, vec } = vec_with_id;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19367"}},{"Add":{"text":" let allocator_index = allocator.len as i32;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19419"}},{"Add":{"text":" println!(\"PUTTING VECTOR\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19455"}},{"Add":{"text":" allocator","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19473"}},{"Add":{"text":" .add_vec(vec)","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19499"}},{"Add":{"text":" .map_err(|err| format!(\"ERROR : {:?}\", err))?;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19558"}},{"Add":{"text":" let next_index = allocator.len as i32;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19605"}},{"Add":{"text":" println!(\"PUT VECTOR\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19637"}},{"Add":{"text":" println!(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19655"}},{"Add":{"text":" \"VEC_ID : {:?} ALLOCATOR: {:?}, ALLOCATOR_INDEX: {:?}, NEXT_INDEX: {:?}\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19741"}},{"Add":{"text":" id, allocator_number, allocator_index, next_index","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19803"}},{"Add":{"text":" );","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19814"}},{"Add":{"text":" let inserts = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19843"}},{"Add":{"text":" .update(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19864"}},{"Add":{"text":" \"INSERT INTO memcache_index_vectors (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19918"}},{"Add":{"text":" vector_id,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:19961"}},{"Add":{"text":" allocator,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20004"}},{"Add":{"text":" allocator_index","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20052"}},{"Add":{"text":" ) VALUES (","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20091"}},{"Add":{"text":" $1,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20127"}},{"Add":{"text":" $2,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20163"}},{"Add":{"text":" $3","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20198"}},{"Add":{"text":" );\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20231"}},{"Add":{"text":" Some(1),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20256"}},{"Add":{"text":" Some(vec![","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20283"}},{"Add":{"text":" (PgBuiltInOids::INT8OID.oid(), id.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20352"}},{"Add":{"text":" (PgBuiltInOids::INT4OID.oid(), allocator_number.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20435"}},{"Add":{"text":" (PgBuiltInOids::INT4OID.oid(), allocator_index.into_datum()),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20517"}},{"Add":{"text":" ]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20537"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20551"}},{"Add":{"text":" .count();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20573"}},{"Add":{"text":" assert!(inserts == 1);","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20604"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20605"}},{"Add":{"text":" println!(\"UPDATE VECTOR TABLE\");","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20646"}},{"Add":{"text":" Ok(())","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20661"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20667"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20668"}},{"Add":{"text":" fn get_smallest_existing_alloc>(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20734"}},{"Add":{"text":" &self,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20749"}},{"Add":{"text":" client: T,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20768"}},{"Add":{"text":" vecs_per_block: u32,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20797"}},{"Add":{"text":" ) -> Option {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20835"}},{"Add":{"text":" let (allocator_opt, count_opt) = client","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20883"}},{"Add":{"text":" .select(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20904"}},{"Add":{"text":" \"SELECT","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20928"}},{"Add":{"text":" allocator,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:20963"}},{"Add":{"text":" COUNT(vector_id) n_vecs","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21011"}},{"Add":{"text":" FROM memcache_index_vectors","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21059"}},{"Add":{"text":" GROUP BY allocator","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21098"}},{"Add":{"text":" HAVING 2 <= $1","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21133"}},{"Add":{"text":" ORDER BY n_vecs\",","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21171"}},{"Add":{"text":" None,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21193"}},{"Add":{"text":" Some(vec![(","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21221"}},{"Add":{"text":" PgBuiltInOids::INT4OID.oid(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21271"}},{"Add":{"text":" vecs_per_block.into_datum(),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21320"}},{"Add":{"text":" )]),","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21341"}},{"Add":{"text":" )","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21355"}},{"Add":{"text":" .first()","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21376"}},{"Add":{"text":" .get_two::();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21412"}},{"Add":{"text":" let count = count_opt?;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21444"}},{"Add":{"text":" allocator_opt.map(|allocator_index| AllocatorWithCount {","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21509"}},{"Add":{"text":" allocator_index,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21538"}},{"Add":{"text":" count,","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21557"}},{"Add":{"text":" })","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21568"}},{"Add":{"text":" }","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21574"}},{"Add":{"text":"}","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21576"}}]}},{"Edit":{"inode":{"change":3,"pos":9696},"path":"src/lib.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":15033}],"down_context":[{"change":3,"pos":9771}],"flag":"BLOCK","start":21578,"end":21623,"inode":{"change":3,"pos":9696}}},"contents":[{"Add":{"text":"use mem_cache_index::init_index_alloc_table;","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21622"}}]}},{"Replacement":{"inode":{"change":3,"pos":9696},"path":"src/lib.rs","line":43,"ins":{"up_context":[{"change":3,"pos":13059}],"down_context":[{"change":3,"pos":15854}],"flag":"BLOCK","start":21624,"end":21699,"inode":{"change":3,"pos":9696}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":13059},"to":{"change":2,"start":570,"end":604},"introduced_by":2}],"inode":{"change":3,"pos":9696}},"ins_contents":[{"Add":{"text":" //init_index_alloc_table();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21655"}},{"Add":{"text":"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21656"}},{"Add":{"text":" let r = shmem_blocks::init_setting();","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21698"}}],"del_contents":[{"Del":{"text":" shmem_blocks::init_setting();","pos":"KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC:603"}}]}},{"Replacement":{"inode":{"change":3,"pos":657},"path":"sql/mem_cache_index_mod.generated.sql","line":1,"ins":{"up_context":[{"change":3,"pos":657}],"down_context":[{"change":3,"pos":694}],"flag":"BLOCK","start":21700,"end":21738,"inode":{"change":3,"pos":657}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657},"to":{"change":3,"start":658,"end":694},"introduced_by":3}],"inode":{"change":3,"pos":657}},"ins_contents":[{"Add":{"text":"-- ./src/mem_cache_index/mod.rs:212:0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21737"}}],"del_contents":[{"Del":{"text":"-- ./src/mem_cache_index/mod.rs:9:0","pos":"G5C3RSELXRNXJFQQ6ZVCXLQE4AJNXYB32RULKHWLWF5SGEFXYTWQC:693"}}]}},{"Edit":{"inode":{"change":3,"pos":657},"path":"sql/mem_cache_index_mod.generated.sql","line":4,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":921}],"down_context":[],"flag":"BLOCK","start":21739,"end":21934,"inode":{"change":3,"pos":657}}},"contents":[{"Add":{"text":"CREATE SCHEMA IF NOT EXISTS \"tests\";","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21775"}},{"Add":{"text":"-- ./src/mem_cache_index/mod.rs:269:4","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21813"}},{"Add":{"text":"CREATE OR REPLACE FUNCTION tests.\"test_rebuild\"() RETURNS void LANGUAGE c AS 'MODULE_PATHNAME', 'test_rebuild_wrapper';","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21933"}}]}},{"Edit":{"inode":{"change":3,"pos":961},"path":"sql/load-order.txt","line":4,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1049}],"down_context":[],"flag":"BLOCK","start":21935,"end":21974,"inode":{"change":3,"pos":961}}},"contents":[{"Add":{"text":"mem_cache_index_handlers.generated.sql","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21973"}}]}},{"Replacement":{"inode":{"change":3,"pos":1092},"path":"sql/lib.generated.sql","line":10,"ins":{"up_context":[{"change":3,"pos":1673}],"down_context":[{"change":3,"pos":1847}],"flag":"BLOCK","start":21975,"end":21997,"inode":{"change":3,"pos":1092}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1673},"to":{"change":2,"start":605,"end":627},"introduced_by":2}],"inode":{"change":3,"pos":1092}},"ins_contents":[{"Add":{"text":"-- ./src/lib.rs:160:0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:21996"}}],"del_contents":[{"Del":{"text":"-- ./src/lib.rs:157:0","pos":"KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC:626"}}]}},{"Replacement":{"inode":{"change":3,"pos":1092},"path":"sql/lib.generated.sql","line":12,"ins":{"up_context":[{"change":3,"pos":2015}],"down_context":[{"change":3,"pos":2037}],"flag":"BLOCK","start":21998,"end":22020,"inode":{"change":3,"pos":1092}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2015},"to":{"change":2,"start":628,"end":650},"introduced_by":2}],"inode":{"change":3,"pos":1092}},"ins_contents":[{"Add":{"text":"-- ./src/lib.rs:167:0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22019"}}],"del_contents":[{"Del":{"text":"-- ./src/lib.rs:164:0","pos":"KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC:649"}}]}},{"Replacement":{"inode":{"change":3,"pos":1092},"path":"sql/lib.generated.sql","line":14,"ins":{"up_context":[{"change":3,"pos":2201}],"down_context":[{"change":3,"pos":2223}],"flag":"BLOCK","start":22021,"end":22043,"inode":{"change":3,"pos":1092}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2201},"to":{"change":2,"start":651,"end":673},"introduced_by":2}],"inode":{"change":3,"pos":1092}},"ins_contents":[{"Add":{"text":"-- ./src/lib.rs:182:0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22042"}}],"del_contents":[{"Del":{"text":"-- ./src/lib.rs:179:0","pos":"KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC:672"}}]}},{"Replacement":{"inode":{"change":3,"pos":1092},"path":"sql/lib.generated.sql","line":16,"ins":{"up_context":[{"change":3,"pos":2379}],"down_context":[{"change":3,"pos":2401}],"flag":"BLOCK","start":22044,"end":22066,"inode":{"change":3,"pos":1092}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2379},"to":{"change":2,"start":674,"end":696},"introduced_by":2}],"inode":{"change":3,"pos":1092}},"ins_contents":[{"Add":{"text":"-- ./src/lib.rs:195:0","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22065"}}],"del_contents":[{"Del":{"text":"-- ./src/lib.rs:192:0","pos":"KZX6RVSGAYRMCPKHROF3L2CHELFYLEAAN4Z7HN4MW2AAEIJJGBCQC:695"}}]}},{"Edit":{"inode":{"change":3,"pos":15618},"path":"Cargo.toml","line":21,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":16033}],"down_context":[{"change":3,"pos":21985}],"flag":"BLOCK","start":22067,"end":22088,"inode":{"change":3,"pos":15618}}},"contents":[{"Add":{"text":"rand_distr = \"0.4.1\"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22087"}}]}},{"Edit":{"inode":{"change":3,"pos":15618},"path":"Cargo.toml","line":27,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":22043}],"down_context":[{"change":3,"pos":16073}],"flag":"BLOCK","start":22089,"end":22127,"inode":{"change":3,"pos":15618}}},"contents":[{"Add":{"text":"either = \"1.6.1\"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22105"}},{"Add":{"text":"itertools = \"0.10.1\"","pos":"DH3RVE6JRQBOSRUBVIIMKSJYFS4CK5PI25KV2NAJ7EP4Q7NNKSJQC:22126"}}]}}],"owner":"gigapixel","repo":"pgvector_rs","token":"lHeCm/Koaho9XgRUMa6hO92pxMv6hlSnavf9xiwzD6Q=","login":null}

…

Dependencies

Change contents

Review