{"header":{"message":"Adding tag/txn.rs, now that the parser allows it","description":null,"timestamp":"2021-12-09T11:48:48.44112827Z","authors":[{}]},"hash":"N3X5YP7PV2XVQKRRWSRCGJG34HZPLV4BGBLZGJG55KGIB7ORJ77QC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["N3X5YP7PV2XVQKRRWSRCGJG34HZPLV4BGBLZGJG55KGIB7ORJ77QC","Adding tag/txn.rs, now that the parser allows it"],["AA",null],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."]],"deps":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"tag","metadata":576},"context":[{"change":2,"pos":198146}],"contents":[]}},{"FileAdd":{"meta":{"basename":"txn.rs","metadata":0},"context":[{"change":0,"pos":15}],"contents":[{"Add":"use super::*;"},{"Add":"use crate::small_string::SmallStr;"},{"Add":"use std::collections::{hash_map::Entry, HashMap};"},{"Add":"use std::sync::Mutex;"},{"Add":""},{"Add":"struct WithOffset {"},{"Add":" off: u64,"},{"Add":" r: R,"},{"Add":"}"},{"Add":""},{"Add":"use std::io::{Seek, SeekFrom};"},{"Add":""},{"Add":"impl Read for WithOffset {"},{"Add":" fn read(&mut self, b: &mut [u8]) -> Result {"},{"Add":" self.r.read(b)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl Seek for WithOffset {"},{"Add":" fn seek(&mut self, s: SeekFrom) -> Result {"},{"Add":" let s = match s {"},{"Add":" SeekFrom::Start(s) => SeekFrom::Start(s + self.off),"},{"Add":" x => x,"},{"Add":" };"},{"Add":" self.r.seek(s)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct TagTxn {"},{"Add":" pub(crate) header: FileHeader,"},{"Add":" s: Mutex>>,"},{"Add":" loaded: Mutex>>,"},{"Add":"}"},{"Add":""},{"Add":"impl std::convert::From> for BlockError {"},{"Add":" fn from(e: BlockError<::zstd_seekable::Error>) -> Self {"},{"Add":" match e {"},{"Add":" BlockError::Txn(t) => BlockError::Txn(t.into()),"},{"Add":" BlockError::Block { block } => BlockError::Block { block },"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl From for TxnErr {"},{"Add":" fn from(e: zstd_seekable::Error) -> Self {"},{"Add":" TxnErr(TagError::Zstd(e))"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl TagTxn {"},{"Add":" pub fn new>(p: P) -> Result {"},{"Add":" let mut file = std::fs::File::open(p)?;"},{"Add":" let mut off = [0u8; std::mem::size_of::() as usize];"},{"Add":" file.read_exact(&mut off)?;"},{"Add":" let header: crate::tag::FileHeader = bincode::deserialize(&off)?;"},{"Add":" let s = zstd_seekable::Seekable::init(Box::new(WithOffset {"},{"Add":" r: file,"},{"Add":" off: header.channel,"},{"Add":" }))?;"},{"Add":" Ok(TagTxn {"},{"Add":" header,"},{"Add":" loaded: Mutex::new(HashMap::new()),"},{"Add":" s: Mutex::new(s),"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" pub fn channel(&self) -> ChannelRef {"},{"Add":" ChannelRef::new(self.header.offsets.clone())"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl ::sanakirja::LoadPage for TagTxn {"},{"Add":" type Error = zstd_seekable::Error;"},{"Add":" fn load_page(&self, off: u64) -> Result<::sanakirja::CowPage, Self::Error> {"},{"Add":" use ::sanakirja::CowPage;"},{"Add":" let off_aligned = (off / crate::tag::BLOCK_SIZE as u64) * crate::tag::BLOCK_SIZE as u64;"},{"Add":" let p = match self.loaded.lock().unwrap().entry(off_aligned) {"},{"Add":" Entry::Occupied(mut e) => unsafe {"},{"Add":" e.get_mut().as_mut_ptr().add((off - off_aligned) as usize)"},{"Add":" },"},{"Add":" Entry::Vacant(e) => {"},{"Add":" let mut buf = Box::new([0; crate::tag::BLOCK_SIZE]);"},{"Add":" self.s"},{"Add":" .lock()"},{"Add":" .unwrap()"},{"Add":" .decompress(&mut buf[..], off_aligned)?;"},{"Add":" unsafe { e.insert(buf).as_mut_ptr().add((off - off_aligned) as usize) }"},{"Add":" }"},{"Add":" };"},{"Add":" Ok(CowPage {"},{"Add":" data: p,"},{"Add":" offset: off,"},{"Add":" })"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl GraphTxnT for TagTxn {"},{"Add":" type Graph = DbOffsets;"},{"Add":" type GraphError = TagError;"},{"Add":""},{"Add":" fn get_graph<'txn>("},{"Add":" &'txn self,"},{"Add":" db: &Self::Graph,"},{"Add":" key: &Vertex,"},{"Add":" value: Option<&SerializedEdge>,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let gr: Db, SerializedEdge> = Db::from_page(db.graph);"},{"Add":" Ok(::sanakirja::btree::get(self, &gr, key, value)?.map(|(_, v)| v))"},{"Add":" }"},{"Add":""},{"Add":" fn get_external<'txn>("},{"Add":" &'txn self,"},{"Add":" int: &ChangeId,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let gr: UDb = UDb::from_page(self.header.offsets.external);"},{"Add":" Ok(::sanakirja::btree::get(self, &gr, int, None)?.map(|(_, v)| v))"},{"Add":" }"},{"Add":""},{"Add":" fn get_internal<'txn>("},{"Add":" &'txn self,"},{"Add":" int: &SerializedHash,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let gr: UDb = UDb::from_page(self.header.offsets.internal);"},{"Add":" Ok(::sanakirja::btree::get(self, &gr, int, None)?.map(|(_, v)| v))"},{"Add":" }"},{"Add":""},{"Add":" type Adj = crate::pristine::sanakirja::Adj;"},{"Add":""},{"Add":" fn init_adj("},{"Add":" &self,"},{"Add":" g: &Self::Graph,"},{"Add":" key: Vertex,"},{"Add":" dest: Position,"},{"Add":" min_flag: EdgeFlags,"},{"Add":" max_flag: EdgeFlags,"},{"Add":" ) -> Result> {"},{"Add":" let edge = SerializedEdge::new(min_flag, dest.change, dest.pos, ChangeId::ROOT);"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let gr: Db, SerializedEdge> = Db::from_page(g.graph);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(self, &gr)?;"},{"Add":" cursor.set(self, &key, Some(&edge))?;"},{"Add":" Ok(Self::Adj {"},{"Add":" cursor,"},{"Add":" key,"},{"Add":" min_flag,"},{"Add":" max_flag,"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" fn next_adj<'a>("},{"Add":" &'a self,"},{"Add":" _: &Self::Graph,"},{"Add":" a: &mut Self::Adj,"},{"Add":" ) -> Option>> {"},{"Add":" crate::pristine::sanakirja::next_adj(self, a).map(|x| x.map_err(|e| TxnErr(e.into())))"},{"Add":" }"},{"Add":""},{"Add":" fn find_block("},{"Add":" &self,"},{"Add":" graph: &Self::Graph,"},{"Add":" p: Position,"},{"Add":" ) -> Result<&Vertex, BlockError> {"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let gr: Db, SerializedEdge> = Db::from_page(graph.graph);"},{"Add":" Ok(crate::pristine::sanakirja::find_block(self, &gr, p)?)"},{"Add":" }"},{"Add":""},{"Add":" fn find_block_end("},{"Add":" &self,"},{"Add":" graph: &Self::Graph,"},{"Add":" p: Position,"},{"Add":" ) -> Result<&Vertex, BlockError> {"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let gr: Db, SerializedEdge> = Db::from_page(graph.graph);"},{"Add":" Ok(crate::pristine::sanakirja::find_block_end(self, &gr, p)?)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl ChannelTxnT for TagTxn {"},{"Add":" type Channel = DbOffsets;"},{"Add":""},{"Add":" fn graph<'a>(&self, c: &'a Self::Channel) -> &'a Self::Graph {"},{"Add":" c"},{"Add":" }"},{"Add":" fn name<'a>(&self, _: &'a Self::Channel) -> &'a str {"},{"Add":" \"\""},{"Add":" }"},{"Add":" fn id<'a>(&self, _: &'a Self::Channel) -> Option<&'a RemoteId> {"},{"Add":" None"},{"Add":" }"},{"Add":" fn apply_counter(&self, channel: &Self::Channel) -> u64 {"},{"Add":" channel.apply_counter.into()"},{"Add":" }"},{"Add":" fn last_modified(&self, _: &Self::Channel) -> u64 {"},{"Add":" 0"},{"Add":" }"},{"Add":" fn changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Changeset {"},{"Add":" &channel.changes"},{"Add":" }"},{"Add":" fn rev_changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::RevChangeset {"},{"Add":" &channel.revchanges"},{"Add":" }"},{"Add":" fn tags<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Tags {"},{"Add":" &channel.tags"},{"Add":" }"},{"Add":""},{"Add":" type Changeset = u64; // Db;"},{"Add":" type RevChangeset = u64; // UDb>;"},{"Add":" type Tags = u64; // UDb;"},{"Add":""},{"Add":" type States = u64; // UDb;"},{"Add":" fn states<'a>(&self, channel: &'a Self::Channel) -> &'a Self::States {"},{"Add":" &channel.states"},{"Add":" }"},{"Add":""},{"Add":" fn get_changeset("},{"Add":" &self,"},{"Add":" channel: &Self::Changeset,"},{"Add":" c: &ChangeId,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let db: Db = Db::from_page(*channel);"},{"Add":" match ::sanakirja::btree::get(self, &db, c, None) {"},{"Add":" Ok(Some((k, x))) if k == c => Ok(Some(x)),"},{"Add":" Ok(x) => {"},{"Add":" debug!(\"get_changeset = {:?}\", x);"},{"Add":" Ok(None)"},{"Add":" }"},{"Add":" Err(e) => {"},{"Add":" error!(\"{:?}\", e);"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn get_revchangeset("},{"Add":" &self,"},{"Add":" revchanges: &Self::RevChangeset,"},{"Add":" c: &L64,"},{"Add":" ) -> Result>, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb> = UDb::from_page(*revchanges);"},{"Add":" match ::sanakirja::btree::get(self, &db, c, None) {"},{"Add":" Ok(Some((k, x))) if k == c => Ok(Some(x)),"},{"Add":" Ok(_) => Ok(None),"},{"Add":" Err(e) => {"},{"Add":" error!(\"{:?}\", e);"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" type ChangesetCursor = ::sanakirja::btree::cursor::Cursor>;"},{"Add":""},{"Add":" fn cursor_changeset<'a>("},{"Add":" &'a self,"},{"Add":" channel: &Self::Changeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result, TxnErr>"},{"Add":" {"},{"Add":" use crate::pristine::sanakirja::Db;"},{"Add":" let db: Db = Db::from_page(*channel);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(self, &db)?;"},{"Add":" if let Some(k) = pos {"},{"Add":" cursor.set(self, &k, None)?;"},{"Add":" }"},{"Add":" Ok(Cursor {"},{"Add":" cursor,"},{"Add":" txn: self,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" type RevchangesetCursor = ::sanakirja::btree::cursor::Cursor<"},{"Add":" L64,"},{"Add":" Pair,"},{"Add":" UP>,"},{"Add":" >;"},{"Add":""},{"Add":" fn cursor_revchangeset_ref<'a, RT: std::ops::Deref>("},{"Add":" txn: RT,"},{"Add":" channel: &Self::RevChangeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result<"},{"Add":" Cursor>,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb> = UDb::from_page(*channel);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(&*txn, &db)?;"},{"Add":" if let Some(k) = pos {"},{"Add":" cursor.set(&*txn, &k, None)?;"},{"Add":" }"},{"Add":" Ok(Cursor {"},{"Add":" cursor,"},{"Add":" txn,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" fn rev_cursor_revchangeset<'a>("},{"Add":" &'a self,"},{"Add":" channel: &Self::RevChangeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result<"},{"Add":" RevCursor>,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb> = UDb::from_page(*channel);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(self, &db)?;"},{"Add":" if let Some(ref pos) = pos {"},{"Add":" cursor.set(self, pos, None)?;"},{"Add":" } else {"},{"Add":" cursor.set_last(self)?;"},{"Add":" };"},{"Add":" Ok(RevCursor {"},{"Add":" cursor,"},{"Add":" txn: self,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_revchangeset_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::RevchangesetCursor,"},{"Add":" ) -> Result)>, TxnErr> {"},{"Add":" if let Ok(x) = cursor.next(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":" fn cursor_revchangeset_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::RevchangesetCursor,"},{"Add":" ) -> Result)>, TxnErr> {"},{"Add":" if let Ok(x) = cursor.prev(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_changeset_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::ChangesetCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" if let Ok(x) = cursor.next(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":" fn cursor_changeset_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::ChangesetCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" if let Ok(x) = cursor.prev(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn channel_has_state("},{"Add":" &self,"},{"Add":" channel: &Self::States,"},{"Add":" m: &SerializedMerkle,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb = UDb::from_page(*channel);"},{"Add":" match ::sanakirja::btree::get(self, &db, m, None)? {"},{"Add":" Some((k, v)) if k == m => Ok(Some(*v)),"},{"Add":" _ => Ok(None),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn get_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" c: &L64,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb = UDb::from_page(*channel);"},{"Add":" match ::sanakirja::btree::get(self, &db, c, None)? {"},{"Add":" Some((k, v)) if k == c => Ok(Some(v)),"},{"Add":" _ => Ok(None),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" type TagsCursor ="},{"Add":" ::sanakirja::btree::cursor::Cursor>;"},{"Add":" fn cursor_tags<'txn>("},{"Add":" &'txn self,"},{"Add":" channel: &Self::Tags,"},{"Add":" k: Option,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb = UDb::from_page(*channel);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(self, &db)?;"},{"Add":" if let Some(k) = k {"},{"Add":" cursor.set(self, &k, None)?;"},{"Add":" }"},{"Add":" Ok(Cursor {"},{"Add":" cursor,"},{"Add":" txn: self,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":" fn cursor_tags_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::TagsCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" if let Ok(x) = cursor.next(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_tags_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::TagsCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" if let Ok(x) = cursor.prev(self) {"},{"Add":" Ok(x)"},{"Add":" } else {"},{"Add":" Err(TxnErr(SanakirjaError::PristineCorrupt).into())"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn iter_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" from: u64,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" self.cursor_tags(channel, Some(from.into()))"},{"Add":" }"},{"Add":""},{"Add":" fn rev_iter_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" from: Option,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::RevCursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" use crate::pristine::sanakirja::UDb;"},{"Add":" let db: UDb = UDb::from_page(*channel);"},{"Add":" let mut cursor = ::sanakirja::btree::cursor::Cursor::new(self, &db)?;"},{"Add":" if let Some(from) = from {"},{"Add":" cursor.set(self, &from.into(), None)?;"},{"Add":" } else {"},{"Add":" cursor.set_last(self)?;"},{"Add":" };"},{"Add":" Ok(RevCursor {"},{"Add":" cursor,"},{"Add":" txn: self,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct WithTag {"},{"Add":" pub txn: T,"},{"Add":" pub tag: txn::TagTxn,"},{"Add":"}"},{"Add":""},{"Add":"impl std::ops::Deref for WithTag {"},{"Add":" type Target = T;"},{"Add":" fn deref(&self) -> &T {"},{"Add":" &self.txn"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"fn map_cursor<'txn, A, B, C: ?Sized, D: ?Sized, E>("},{"Add":" c: crate::pristine::Cursor,"},{"Add":" s: &'txn E,"},{"Add":") -> crate::pristine::Cursor {"},{"Add":" crate::pristine::Cursor {"},{"Add":" cursor: c.cursor,"},{"Add":" txn: s,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" k: c.k,"},{"Add":" v: c.v,"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"fn map_revcursor<'txn, A, B, C: ?Sized, D: ?Sized, E>("},{"Add":" c: crate::pristine::RevCursor,"},{"Add":" s: &'txn E,"},{"Add":") -> crate::pristine::RevCursor {"},{"Add":" crate::pristine::RevCursor {"},{"Add":" cursor: c.cursor,"},{"Add":" txn: s,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" k: c.k,"},{"Add":" v: c.v,"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl GraphTxnT for WithTag {"},{"Add":" type Graph = ::Graph;"},{"Add":" type GraphError = ::GraphError;"},{"Add":""},{"Add":" fn get_graph<'txn>("},{"Add":" &'txn self,"},{"Add":" db: &Self::Graph,"},{"Add":" key: &Vertex,"},{"Add":" value: Option<&SerializedEdge>,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.get_graph(db, key, value)"},{"Add":" }"},{"Add":""},{"Add":" fn get_external<'txn>("},{"Add":" &'txn self,"},{"Add":" int: &ChangeId,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.get_external(int)"},{"Add":" }"},{"Add":""},{"Add":" fn get_internal<'txn>("},{"Add":" &'txn self,"},{"Add":" int: &SerializedHash,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.get_internal(int)"},{"Add":" }"},{"Add":""},{"Add":" type Adj = ::Adj;"},{"Add":""},{"Add":" fn init_adj("},{"Add":" &self,"},{"Add":" g: &Self::Graph,"},{"Add":" key: Vertex,"},{"Add":" dest: Position,"},{"Add":" min_flag: EdgeFlags,"},{"Add":" max_flag: EdgeFlags,"},{"Add":" ) -> Result> {"},{"Add":" self.tag.init_adj(g, key, dest, min_flag, max_flag)"},{"Add":" }"},{"Add":""},{"Add":" fn next_adj<'a>("},{"Add":" &'a self,"},{"Add":" a: &Self::Graph,"},{"Add":" b: &mut Self::Adj,"},{"Add":" ) -> Option>> {"},{"Add":" self.tag.next_adj(a, b)"},{"Add":" }"},{"Add":""},{"Add":" fn find_block("},{"Add":" &self,"},{"Add":" graph: &Self::Graph,"},{"Add":" p: Position,"},{"Add":" ) -> Result<&Vertex, BlockError> {"},{"Add":" self.tag.find_block(graph, p)"},{"Add":" }"},{"Add":""},{"Add":" fn find_block_end("},{"Add":" &self,"},{"Add":" graph: &Self::Graph,"},{"Add":" p: Position,"},{"Add":" ) -> Result<&Vertex, BlockError> {"},{"Add":" self.tag.find_block_end(graph, p)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl WithTag {"},{"Add":" pub fn channel(&self) -> ChannelRef {"},{"Add":" ChannelRef::new(self.tag.header.offsets.clone())"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl ChannelTxnT for WithTag {"},{"Add":" type Channel = ::Channel;"},{"Add":""},{"Add":" fn graph<'a>(&self, c: &'a Self::Channel) -> &'a Self::Graph {"},{"Add":" self.tag.graph(c)"},{"Add":" }"},{"Add":" fn name<'a>(&self, c: &'a Self::Channel) -> &'a str {"},{"Add":" self.tag.name(c)"},{"Add":" }"},{"Add":" fn id<'a>(&self, c: &'a Self::Channel) -> Option<&'a RemoteId> {"},{"Add":" self.tag.id(c)"},{"Add":" }"},{"Add":" fn apply_counter(&self, channel: &Self::Channel) -> u64 {"},{"Add":" self.tag.apply_counter(channel)"},{"Add":" }"},{"Add":" fn last_modified(&self, c: &Self::Channel) -> u64 {"},{"Add":" self.tag.last_modified(c)"},{"Add":" }"},{"Add":" fn changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Changeset {"},{"Add":" self.tag.changes(channel)"},{"Add":" }"},{"Add":" fn rev_changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::RevChangeset {"},{"Add":" self.tag.rev_changes(channel)"},{"Add":" }"},{"Add":" fn tags<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Tags {"},{"Add":" self.tag.tags(channel)"},{"Add":" }"},{"Add":""},{"Add":" type Changeset = ::Changeset;"},{"Add":" type RevChangeset = ::RevChangeset;"},{"Add":" type Tags = ::Tags;"},{"Add":""},{"Add":" type States = ::States;"},{"Add":""},{"Add":" fn states<'a>(&self, channel: &'a Self::Channel) -> &'a Self::States {"},{"Add":" &channel.states"},{"Add":" }"},{"Add":""},{"Add":" fn get_changeset("},{"Add":" &self,"},{"Add":" channel: &Self::Changeset,"},{"Add":" c: &ChangeId,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.get_changeset(channel, c)"},{"Add":" }"},{"Add":""},{"Add":" fn get_revchangeset("},{"Add":" &self,"},{"Add":" revchanges: &Self::RevChangeset,"},{"Add":" c: &L64,"},{"Add":" ) -> Result>, TxnErr> {"},{"Add":" self.tag.get_revchangeset(revchanges, c)"},{"Add":" }"},{"Add":""},{"Add":" type ChangesetCursor = ::ChangesetCursor;"},{"Add":""},{"Add":" fn cursor_changeset<'a>("},{"Add":" &'a self,"},{"Add":" channel: &Self::Changeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result, TxnErr>"},{"Add":" {"},{"Add":" Ok(map_cursor(self.tag.cursor_changeset(channel, pos)?, self))"},{"Add":" }"},{"Add":""},{"Add":" type RevchangesetCursor = ::RevchangesetCursor;"},{"Add":""},{"Add":" fn cursor_revchangeset_ref<'a, RT: std::ops::Deref>("},{"Add":" txn: RT,"},{"Add":" channel: &Self::RevChangeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result<"},{"Add":" Cursor>,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" let cursor ="},{"Add":" ::cursor_revchangeset_ref(&txn.deref().tag, channel, pos)?;"},{"Add":" Ok(Cursor {"},{"Add":" cursor: cursor.cursor,"},{"Add":" txn,"},{"Add":" t: std::marker::PhantomData,"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" fn rev_cursor_revchangeset<'a>("},{"Add":" &'a self,"},{"Add":" channel: &Self::RevChangeset,"},{"Add":" pos: Option,"},{"Add":" ) -> Result<"},{"Add":" RevCursor>,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" Ok(map_revcursor("},{"Add":" self.tag.rev_cursor_revchangeset(channel, pos)?,"},{"Add":" self,"},{"Add":" ))"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_revchangeset_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::RevchangesetCursor,"},{"Add":" ) -> Result)>, TxnErr> {"},{"Add":" self.tag.cursor_revchangeset_next(cursor)"},{"Add":" }"},{"Add":" fn cursor_revchangeset_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::RevchangesetCursor,"},{"Add":" ) -> Result)>, TxnErr> {"},{"Add":" self.tag.cursor_revchangeset_prev(cursor)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_changeset_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::ChangesetCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.cursor_changeset_next(cursor)"},{"Add":" }"},{"Add":" fn cursor_changeset_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::ChangesetCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.cursor_changeset_prev(cursor)"},{"Add":" }"},{"Add":""},{"Add":" fn channel_has_state("},{"Add":" &self,"},{"Add":" channel: &Self::States,"},{"Add":" m: &SerializedMerkle,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.channel_has_state(channel, m)"},{"Add":" }"},{"Add":""},{"Add":" fn get_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" c: &L64,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.get_tags(channel, c)"},{"Add":" }"},{"Add":""},{"Add":" type TagsCursor = ::TagsCursor;"},{"Add":" fn cursor_tags<'txn>("},{"Add":" &'txn self,"},{"Add":" channel: &Self::Tags,"},{"Add":" k: Option,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.tag.cursor_tags(channel, k)?, self))"},{"Add":" }"},{"Add":" fn cursor_tags_next("},{"Add":" &self,"},{"Add":" cursor: &mut Self::TagsCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.cursor_tags_next(cursor)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_tags_prev("},{"Add":" &self,"},{"Add":" cursor: &mut Self::TagsCursor,"},{"Add":" ) -> Result, TxnErr> {"},{"Add":" self.tag.cursor_tags_prev(cursor)"},{"Add":" }"},{"Add":""},{"Add":" fn iter_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" from: u64,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.tag.iter_tags(channel, from)?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn rev_iter_tags("},{"Add":" &self,"},{"Add":" channel: &Self::Tags,"},{"Add":" from: Option,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::RevCursor,"},{"Add":" TxnErr,"},{"Add":" > {"},{"Add":" Ok(map_revcursor(self.tag.rev_iter_tags(channel, from)?, self))"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl TreeTxnT for WithTag {"},{"Add":" type TreeError = T::TreeError;"},{"Add":" type Tree = T::Tree;"},{"Add":" type TreeCursor = T::TreeCursor;"},{"Add":" fn get_tree("},{"Add":" &self,"},{"Add":" a: &PathId,"},{"Add":" b: Option<&Inode>,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.get_tree(a, b)"},{"Add":" }"},{"Add":" fn cursor_tree<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Self::Tree,"},{"Add":" b: Option<(&PathId, Option<&Inode>)>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.cursor_tree(a, b)?, self))"},{"Add":" }"},{"Add":" fn cursor_tree_next("},{"Add":" &self,"},{"Add":" m: &mut Self::TreeCursor,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.cursor_tree_next(m)"},{"Add":" }"},{"Add":" fn cursor_tree_prev("},{"Add":" &self,"},{"Add":" m: &mut Self::TreeCursor,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.cursor_tree_prev(m)"},{"Add":" }"},{"Add":" fn iter_tree<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &PathId,"},{"Add":" b: Option<&Inode>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.iter_tree(a, b)?, self))"},{"Add":" }"},{"Add":""},{"Add":" type Revtree = T::Revtree;"},{"Add":" type RevtreeCursor = T::RevtreeCursor;"},{"Add":""},{"Add":" fn get_revtree("},{"Add":" &self,"},{"Add":" a: &Inode,"},{"Add":" b: Option<&PathId>,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.get_revtree(a, b)"},{"Add":" }"},{"Add":" fn cursor_revtree<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Self::Revtree,"},{"Add":" b: Option<(&Inode, Option<&PathId>)>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.cursor_revtree(a, b)?, self))"},{"Add":" }"},{"Add":" fn cursor_revtree_next("},{"Add":" &self,"},{"Add":" m: &mut Self::RevtreeCursor,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.cursor_revtree_next(m)"},{"Add":" }"},{"Add":" fn cursor_revtree_prev("},{"Add":" &self,"},{"Add":" m: &mut Self::RevtreeCursor,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.cursor_revtree_prev(m)"},{"Add":" }"},{"Add":" fn iter_revtree<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Inode,"},{"Add":" b: Option<&PathId>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.iter_revtree(a, b)?, self))"},{"Add":" }"},{"Add":""},{"Add":" type Inodes = T::Inodes;"},{"Add":" type InodesCursor = T::InodesCursor;"},{"Add":" type Revinodes = T::Revinodes;"},{"Add":" type RevinodesCursor = T::RevinodesCursor;"},{"Add":""},{"Add":" fn get_inodes("},{"Add":" &self,"},{"Add":" a: &Inode,"},{"Add":" b: Option<&Position>,"},{"Add":" ) -> Result>, TreeErr> {"},{"Add":" self.txn.get_inodes(a, b)"},{"Add":" }"},{"Add":" fn get_revinodes("},{"Add":" &self,"},{"Add":" a: &Position,"},{"Add":" b: Option<&Inode>,"},{"Add":" ) -> Result, TreeErr> {"},{"Add":" self.txn.get_revinodes(a, b)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_inodes<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Self::Inodes,"},{"Add":" b: Option<(&Inode, Option<&Position>)>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor>,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.cursor_inodes(a, b)?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_revinodes<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Self::Revinodes,"},{"Add":" b: Option<(&Position, Option<&Inode>)>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor, Inode>,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.cursor_revinodes(a, b)?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_inodes_next("},{"Add":" &self,"},{"Add":" m: &mut Self::InodesCursor,"},{"Add":" ) -> Result)>, TreeErr> {"},{"Add":" self.txn.cursor_inodes_next(m)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_revinodes_next("},{"Add":" &self,"},{"Add":" m: &mut Self::RevinodesCursor,"},{"Add":" ) -> Result, &Inode)>, TreeErr> {"},{"Add":" self.txn.cursor_revinodes_next(m)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_inodes_prev("},{"Add":" &self,"},{"Add":" m: &mut Self::InodesCursor,"},{"Add":" ) -> Result)>, TreeErr> {"},{"Add":" self.txn.cursor_inodes_prev(m)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_revinodes_prev("},{"Add":" &self,"},{"Add":" m: &mut Self::RevinodesCursor,"},{"Add":" ) -> Result, &Inode)>, TreeErr> {"},{"Add":" self.txn.cursor_revinodes_prev(m)"},{"Add":" }"},{"Add":""},{"Add":" fn iter_inodes<'txn>("},{"Add":" &'txn self,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor>,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.iter_inodes()?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn iter_revinodes<'txn>("},{"Add":" &'txn self,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor, Inode>,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.iter_revinodes()?, self))"},{"Add":" }"},{"Add":""},{"Add":" type Partials = T::Partials;"},{"Add":" type PartialsCursor = T::PartialsCursor;"},{"Add":""},{"Add":" fn cursor_partials<'txn>("},{"Add":" &'txn self,"},{"Add":" a: &Self::Partials,"},{"Add":" b: Option<(&SmallStr, Option<&Position>)>,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor<"},{"Add":" Self,"},{"Add":" &'txn Self,"},{"Add":" Self::PartialsCursor,"},{"Add":" SmallStr,"},{"Add":" Position,"},{"Add":" >,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.cursor_partials(a, b)?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn iter_partials<'txn>("},{"Add":" &'txn self,"},{"Add":" channel: &str,"},{"Add":" ) -> Result<"},{"Add":" crate::pristine::Cursor<"},{"Add":" Self,"},{"Add":" &'txn Self,"},{"Add":" Self::PartialsCursor,"},{"Add":" SmallStr,"},{"Add":" Position,"},{"Add":" >,"},{"Add":" TreeErr,"},{"Add":" > {"},{"Add":" Ok(map_cursor(self.txn.iter_partials(channel)?, self))"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_partials_next("},{"Add":" &self,"},{"Add":" m: &mut Self::PartialsCursor,"},{"Add":" ) -> Result)>, TreeErr> {"},{"Add":" self.txn.cursor_partials_next(m)"},{"Add":" }"},{"Add":""},{"Add":" fn cursor_partials_prev("},{"Add":" &self,"},{"Add":" m: &mut Self::PartialsCursor,"},{"Add":" ) -> Result)>, TreeErr> {"},{"Add":" self.txn.cursor_partials_prev(m)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl TreeMutTxnT for WithTag {"},{"Add":" fn put_inodes("},{"Add":" &mut self,"},{"Add":" a: &Inode,"},{"Add":" b: &Position,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.put_inodes(a, b)"},{"Add":" }"},{"Add":" fn put_revinodes("},{"Add":" &mut self,"},{"Add":" a: &Position,"},{"Add":" b: &Inode,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.put_revinodes(a, b)"},{"Add":" }"},{"Add":" fn del_inodes("},{"Add":" &mut self,"},{"Add":" a: &Inode,"},{"Add":" b: Option<&Position>,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.del_inodes(a, b)"},{"Add":" }"},{"Add":" fn del_revinodes("},{"Add":" &mut self,"},{"Add":" a: &Position,"},{"Add":" b: Option<&Inode>,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.del_revinodes(a, b)"},{"Add":" }"},{"Add":" fn put_tree(&mut self, a: &PathId, b: &Inode) -> Result> {"},{"Add":" self.txn.put_tree(a, b)"},{"Add":" }"},{"Add":" fn put_revtree(&mut self, a: &Inode, b: &PathId) -> Result> {"},{"Add":" self.txn.put_revtree(a, b)"},{"Add":" }"},{"Add":" fn del_tree("},{"Add":" &mut self,"},{"Add":" a: &PathId,"},{"Add":" b: Option<&Inode>,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.del_tree(a, b)"},{"Add":" }"},{"Add":" fn del_revtree("},{"Add":" &mut self,"},{"Add":" a: &Inode,"},{"Add":" b: Option<&PathId>,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.del_revtree(a, b)"},{"Add":" }"},{"Add":" fn put_partials("},{"Add":" &mut self,"},{"Add":" a: &str,"},{"Add":" b: Position,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.put_partials(a, b)"},{"Add":" }"},{"Add":" fn del_partials("},{"Add":" &mut self,"},{"Add":" a: &str,"},{"Add":" b: Option>,"},{"Add":" ) -> Result> {"},{"Add":" self.txn.del_partials(a, b)"},{"Add":" }"},{"Add":"}"}]}}],"owner":"irevoire","repo":"pijul","token":"kCl64QYjs4TUIG3GMu57oHzry5lyKCNlt9ia+sZCIeA=","login":null}

…

Dependencies

Change contents