{"header":{"message":"Rewrote server part to be more flexible/stable","description":null,"timestamp":"2020-10-14T10:55:17Z","authors":[{"email":"alexander.thaller@trivago.com","name":"Alexander Thaller"}]},"hash":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC","authors":[],"deps":{"hashes":[["XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC","Rewrote server part to be more flexible/stable"],["AA",null],["VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC","Reimplementing server"],["T4BZASPWFKHE74WO42QDVPKKWBCK64E73EI45VVZNIUX7BVMRVMAC","Implemented histfile import"],["FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC","Nicer logging"],["4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC","Added subcommand to disable/enable recording for a session"],["CK2R6STAMMOQCX3HD676VNU6LCNG4BSIV2ZSEEFWVUWW4TPFW73AC","Refactoring of table display and filters"],["T2HK3ZSDLLLGHROM77MND4UZF663WSHT5J2CT7ZMXDH6MMIZFOAQC","Initial commit."],["FTI67CGF4MMPDFA6YJN6UKOADQLFAECKGYPTWSPSALVQK76BJMJAC","Remove global args"],["TUBVSWW3OQX2OJKF2F5ACCPL3G6U6SNJQ3EWOSPBCV6EIZPM2LMAC","More documentation for subcommands and flags"],["WOYAD3FWIOSSZLM76DX6ZCRG6YILONICJ25UYMOJ52BGRLRPGRGAC","Got rid of unwraps in import code"],["AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC","Move run functions to sepperate module"],["VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC","Implemented adding of command to store"],["AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC","Fix parent directory not created for socket"],["ITAJ6L444PCEX6QTW6FDC7OU4NDM5IHY2GYSM2SMVAB3JYSDOYJQC","Better error handling for project dir defaults"],["42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC","Got rid of all unwraps"],["S4ZGOQWXROCH5YEQSTPDBHBZINIBIYSEIXD2YOB2N3QORQUD746AC","Start implementing histfile import"],["5JXDREUOXZRCIBYRD6225USUZRFYR2JDBTBTQUTRDMQTFEMSXZQQC","Add init subcommand to print initialize zsh code"],["K7M77GF5ILC4KKKYPTLZRZ2OND7DOQDQNRYKM3N6XV2DMJURYA3QC","Added changes from thaller-desktop-linux"],["4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC","Clippy"],["F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC","Switched to structopt for arg parsing"],["B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC","Basic client/server model"],["I5WVRUHGAQGWFZGX7YBKCGQKLHXZHZTCBWFIUCXVGY2WVFB77VQQC","Some cleanup of opt args and arg for entries count to display"],["B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC","Added state restoration on restart"],["IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC","More clippy"]],"deps":["VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC"],"known":["T2HK3ZSDLLLGHROM77MND4UZF663WSHT5J2CT7ZMXDH6MMIZFOAQC","B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC","VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC","K7M77GF5ILC4KKKYPTLZRZ2OND7DOQDQNRYKM3N6XV2DMJURYA3QC","B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC","F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC","42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC","FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC","FTI67CGF4MMPDFA6YJN6UKOADQLFAECKGYPTWSPSALVQK76BJMJAC","TUBVSWW3OQX2OJKF2F5ACCPL3G6U6SNJQ3EWOSPBCV6EIZPM2LMAC","I5WVRUHGAQGWFZGX7YBKCGQKLHXZHZTCBWFIUCXVGY2WVFB77VQQC","AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC","AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC","4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC","IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC","ITAJ6L444PCEX6QTW6FDC7OU4NDM5IHY2GYSM2SMVAB3JYSDOYJQC","S4ZGOQWXROCH5YEQSTPDBHBZINIBIYSEIXD2YOB2N3QORQUD746AC","T4BZASPWFKHE74WO42QDVPKKWBCK64E73EI45VVZNIUX7BVMRVMAC","WOYAD3FWIOSSZLM76DX6ZCRG6YILONICJ25UYMOJ52BGRLRPGRGAC","4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC","CK2R6STAMMOQCX3HD676VNU6LCNG4BSIV2ZSEEFWVUWW4TPFW73AC","5JXDREUOXZRCIBYRD6225USUZRFYR2JDBTBTQUTRDMQTFEMSXZQQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":4653},"path":"src/message.rs","line":27,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4965},"to":{"change":3,"start":1129,"end":1143},"introduced_by":3}],"inode":{"change":3,"pos":4653}}},"contents":[{"Del":{"text":"","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1129"}},{"Del":{"text":" Running,","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1142"}}]}},{"Edit":{"inode":{"change":3,"pos":5920},"path":"src/opt.rs","line":103,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7289},"to":{"change":3,"start":0,"end":49},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":49},"to":{"change":3,"start":190,"end":191},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":190},"to":{"change":3,"start":190,"end":191},"introduced_by":3}],"inode":{"change":3,"pos":5920}}},"contents":[{"Del":{"text":" #[structopt(flatten)]","pos":"I5WVRUHGAQGWFZGX7YBKCGQKLHXZHZTCBWFIUCXVGY2WVFB77VQQC:25"}},{"Del":{"text":" data_dir: DataDir,","pos":"I5WVRUHGAQGWFZGX7YBKCGQKLHXZHZTCBWFIUCXVGY2WVFB77VQQC:48"}},{"Del":{"text":"","pos":"FTI67CGF4MMPDFA6YJN6UKOADQLFAECKGYPTWSPSALVQK76BJMJAC:190"}}]}},{"Edit":{"inode":{"change":3,"pos":5920},"path":"src/opt.rs","line":267,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7964},"to":{"change":3,"start":7964,"end":7965},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7965},"to":{"change":3,"start":809,"end":864},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":864},"to":{"change":3,"start":7965,"end":8000},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7965},"to":{"change":3,"start":7965,"end":8000},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8000},"to":{"change":3,"start":1237,"end":1258},"introduced_by":3}],"inode":{"change":3,"pos":5920}}},"contents":[{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:7964"}},{"Del":{"text":" /// Tell server to print currently running command","pos":"TUBVSWW3OQX2OJKF2F5ACCPL3G6U6SNJQ3EWOSPBCV6EIZPM2LMAC:863"}},{"Del":{"text":" #[structopt(name = \"running\")]","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:7999"}},{"Del":{"text":" Running(Socket),","pos":"FTI67CGF4MMPDFA6YJN6UKOADQLFAECKGYPTWSPSALVQK76BJMJAC:1257"}}]}},{"Edit":{"inode":{"change":3,"pos":5920},"path":"src/opt.rs","line":343,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1998},"to":{"change":3,"start":1998,"end":2069},"introduced_by":3}],"inode":{"change":3,"pos":5920}}},"contents":[{"Del":{"text":" SubCommand::Running(o) => run::running(o.socket_path),","pos":"IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC:2068"}}]}},{"Replacement":{"inode":{"change":3,"pos":1890},"path":"src/run/mod.rs","line":287,"ins":{"up_context":[{"change":2,"pos":6011}],"down_context":[{"change":2,"pos":6073}],"flag":"BLOCK","start":0,"end":49,"inode":{"change":3,"pos":1890}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":6011},"to":{"change":2,"start":6011,"end":6073},"introduced_by":2}],"inode":{"change":3,"pos":1890}},"ins_contents":[{"Add":{"text":" server::builder(cache_dir, data_dir, socket)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:48"}}],"del_contents":[{"Del":{"text":" let server = server::builder(cache_dir, data_dir, socket)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:6072"}}]}},{"Edit":{"inode":{"change":3,"pos":1890},"path":"src/run/mod.rs","line":324,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6567},"to":{"change":3,"start":6567,"end":6642},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6642},"to":{"change":3,"start":2976,"end":3031},"introduced_by":3}],"inode":{"change":3,"pos":1890}}},"contents":[{"Del":{"text":"","pos":"AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC:6567"}},{"Del":{"text":" Ok(())","pos":"AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC:6578"}},{"Del":{"text":"}","pos":"AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC:6580"}},{"Del":{"text":"","pos":"AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC:6581"}},{"Del":{"text":"pub fn running(socket_path: PathBuf) -> Result<(), Error> {","pos":"AIF5IVL7B5S2X3N4RLS6GNKUCASQZPOH6NCVGECUFHQ5ZUJVDU6QC:6641"}},{"Del":{"text":" client::new(socket_path).send(&Message::Running)?;","pos":"IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC:3030"}}]}},{"FileDel":{"deleted_names":[{"basename":"server.rs","metadata":0}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":6110},"to":{"change":2,"start":12281,"end":12314},"introduced_by":2},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":12314},"to":{"change":2,"start":7866,"end":7866},"introduced_by":2}],"inode":{"change":2,"pos":7866}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":7866},"to":{"change":2,"start":7867,"end":12280},"introduced_by":2}],"inode":{"change":2,"pos":7866}},"content":[{"Del":{"text":"use super::Builder;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7886"}},{"Del":{"text":"use crate::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7899"}},{"Del":{"text":" client,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7911"}},{"Del":{"text":" message::Message,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7933"}},{"Del":{"text":" store::Store,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7951"}},{"Del":{"text":"};","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7954"}},{"Del":{"text":"use crossbeam_utils::sync::WaitGroup;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7992"}},{"Del":{"text":"use flume::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8005"}},{"Del":{"text":" Receiver,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8019"}},{"Del":{"text":" Sender,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8031"}},{"Del":{"text":"};","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8034"}},{"Del":{"text":"use log::warn;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8049"}},{"Del":{"text":"use std::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8060"}},{"Del":{"text":" os::unix::net::UnixDatagram,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8093"}},{"Del":{"text":" path::PathBuf,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8112"}},{"Del":{"text":" sync::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8124"}},{"Del":{"text":" atomic::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8142"}},{"Del":{"text":" AtomicBool,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8166"}},{"Del":{"text":" Ordering,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8188"}},{"Del":{"text":" },","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8199"}},{"Del":{"text":" Arc,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8212"}},{"Del":{"text":" },","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8219"}},{"Del":{"text":" thread,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8231"}},{"Del":{"text":"};","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8234"}},{"Del":{"text":"use thiserror::Error;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8256"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8257"}},{"Del":{"text":"const BUFFER_SIZE: usize = 65_527;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8292"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8293"}},{"Del":{"text":"#[derive(Error, Debug)]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8317"}},{"Del":{"text":"pub enum Error {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8334"}},{"Del":{"text":" #[error(\"can not receive message from socket: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8391"}},{"Del":{"text":" ReceiveFromSocket(std::io::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8430"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8431"}},{"Del":{"text":" #[error(\"can not send received data to processing: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8493"}},{"Del":{"text":" SendBuffer(flume::SendError>),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8536"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8537"}},{"Del":{"text":" #[error(\"can not deserialize message: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8586"}},{"Del":{"text":" DeserializeMessage(bincode::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8626"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8627"}},{"Del":{"text":" #[error(\"can not receive data from channel: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8682"}},{"Del":{"text":" ReceiveData(flume::RecvError),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8717"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8718"}},{"Del":{"text":" #[error(\"can not remove socket: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8761"}},{"Del":{"text":" RemoveSocket(std::io::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8795"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8796"}},{"Del":{"text":" #[error(\"can not setup ctrlc handler: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8845"}},{"Del":{"text":" SetupCtrlHandler(ctrlc::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8881"}},{"Del":{"text":"}","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8883"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8884"}},{"Del":{"text":"pub struct Server {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8904"}},{"Del":{"text":" pub(super) entries: sled::Db,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8938"}},{"Del":{"text":" pub(super) socket: UnixDatagram,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:8975"}},{"Del":{"text":" pub(super) socket_path: PathBuf,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9012"}},{"Del":{"text":" pub(super) store: Store,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9041"}},{"Del":{"text":" pub(super) stopping: Arc,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9083"}},{"Del":{"text":" pub(super) wait_group: WaitGroup,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9121"}},{"Del":{"text":"}","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9123"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9124"}},{"Del":{"text":"pub fn builder(cache_dir: PathBuf, data_dir: PathBuf, socket: PathBuf) -> Builder {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9208"}},{"Del":{"text":" Builder {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9222"}},{"Del":{"text":" cache_dir,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9241"}},{"Del":{"text":" data_dir,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9259"}},{"Del":{"text":" socket,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9275"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9281"}},{"Del":{"text":"}","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9283"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9284"}},{"Del":{"text":"impl Server {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9298"}},{"Del":{"text":" pub fn run(self) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9342"}},{"Del":{"text":" let data_sender =","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9368"}},{"Del":{"text":" Self::start_processor(Arc::clone(&self.stopping), self.wait_group.clone())?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9457"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9458"}},{"Del":{"text":" Self::start_receiver(","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9488"}},{"Del":{"text":" Arc::clone(&self.stopping),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9528"}},{"Del":{"text":" self.wait_group.clone(),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9565"}},{"Del":{"text":" self.socket,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9590"}},{"Del":{"text":" data_sender,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9615"}},{"Del":{"text":" )?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9627"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9628"}},{"Del":{"text":" Self::ctrl_c_watcher(self.stopping, self.socket_path.clone())?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9700"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9701"}},{"Del":{"text":" self.wait_group.wait();","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9733"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9734"}},{"Del":{"text":" std::fs::remove_file(&self.socket_path).map_err(Error::RemoveSocket)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9813"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9814"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9829"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9835"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9836"}},{"Del":{"text":" fn ctrl_c_watcher(stopping: Arc, socket_path: PathBuf) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9930"}},{"Del":{"text":" ctrlc::set_handler(move || {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:9967"}},{"Del":{"text":" stopping.store(true, Ordering::SeqCst);","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10019"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10020"}},{"Del":{"text":" let client = client::new(socket_path.clone());","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10079"}},{"Del":{"text":" if let Err(err) = client.send(&Message::Stop) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10139"}},{"Del":{"text":" warn!(\"{}\", err);","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10173"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10187"}},{"Del":{"text":" })","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10198"}},{"Del":{"text":" .map_err(Error::SetupCtrlHandler)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10242"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10243"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10258"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10264"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10265"}},{"Del":{"text":" fn start_receiver(","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10288"}},{"Del":{"text":" stopping: Arc,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10323"}},{"Del":{"text":" wait_group: WaitGroup,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10354"}},{"Del":{"text":" socket: UnixDatagram,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10384"}},{"Del":{"text":" data_sender: Sender>,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10422"}},{"Del":{"text":" ) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10451"}},{"Del":{"text":" thread::spawn(move || {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10483"}},{"Del":{"text":" loop {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10502"}},{"Del":{"text":" if dbg!(stopping.load(Ordering::SeqCst)) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10561"}},{"Del":{"text":" dbg!(\"break loop\");","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10601"}},{"Del":{"text":" break;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10628"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10646"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10647"}},{"Del":{"text":" if let Err(err) = Self::receive(&socket, &data_sender) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10720"}},{"Del":{"text":" warn!(\"{}\", err)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10757"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10775"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10789"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10790"}},{"Del":{"text":" drop(wait_group)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10819"}},{"Del":{"text":" });","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10831"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10832"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10847"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10853"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10854"}},{"Del":{"text":" fn receive(socket: &UnixDatagram, data_sender: &Sender>) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10946"}},{"Del":{"text":" dbg!(\"receive\");","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10971"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:10972"}},{"Del":{"text":" let mut buffer = [0_u8; BUFFER_SIZE];","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11018"}},{"Del":{"text":" let (written, _) = socket","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11052"}},{"Del":{"text":" .recv_from(&mut buffer)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11088"}},{"Del":{"text":" .map_err(Error::ReceiveFromSocket)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11137"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11138"}},{"Del":{"text":" data_sender","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11158"}},{"Del":{"text":" .send(buffer[0..written].to_vec())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11205"}},{"Del":{"text":" .map_err(Error::SendBuffer)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11247"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11248"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11263"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11269"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11270"}},{"Del":{"text":" fn start_processor(","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11294"}},{"Del":{"text":" stopping: Arc,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11329"}},{"Del":{"text":" wait_group: WaitGroup,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11360"}},{"Del":{"text":" ) -> Result>, Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11402"}},{"Del":{"text":" let (data_sender, data_receiver) = flume::unbounded();","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11465"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11466"}},{"Del":{"text":" thread::spawn(move || {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11498"}},{"Del":{"text":" loop {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11517"}},{"Del":{"text":" if dbg!(stopping.load(Ordering::SeqCst)) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11576"}},{"Del":{"text":" break;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11603"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11621"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11622"}},{"Del":{"text":" if let Err(err) = Self::process(&stopping, &data_receiver) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11699"}},{"Del":{"text":" warn!(\"{}\", err)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11736"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11754"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11768"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11769"}},{"Del":{"text":" drop(wait_group)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11798"}},{"Del":{"text":" });","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11810"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11811"}},{"Del":{"text":" Ok(data_sender)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11835"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11841"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11842"}},{"Del":{"text":" fn process(stopping: &Arc, data_receiver: &Receiver>) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:11943"}},{"Del":{"text":" let data = data_receiver.recv().map_err(Error::ReceiveData)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12013"}},{"Del":{"text":" let message = bincode::deserialize(&data).map_err(Error::DeserializeMessage)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12100"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12101"}},{"Del":{"text":" dbg!(&message);","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12125"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12126"}},{"Del":{"text":" match message {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12150"}},{"Del":{"text":" Message::Stop => stopping.store(true, Ordering::SeqCst),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12219"}},{"Del":{"text":" _ => todo!(),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12245"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12255"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12256"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12271"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12277"}},{"Del":{"text":"}","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12279"}}]}},{"FileDel":{"deleted_names":[{"basename":"server.rs","metadata":0},{"basename":"server_.rs","metadata":0}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":634},"to":{"change":3,"start":11464,"end":11497},"introduced_by":2},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":11497},"to":{"change":3,"start":10542,"end":10542},"introduced_by":2},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":6110},"to":{"change":2,"start":12315,"end":12349},"introduced_by":2},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":12349},"to":{"change":3,"start":10542,"end":10542},"introduced_by":2}],"inode":{"change":3,"pos":10542}}},"content_edges":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":7693},"to":{"change":3,"start":10581,"end":10603},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10581},"to":{"change":3,"start":10581,"end":10603},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":7710},"to":{"change":3,"start":10603,"end":10639},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10603},"to":{"change":3,"start":10603,"end":10639},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10639},"to":{"change":3,"start":7711,"end":7922},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":8255},"to":{"change":3,"start":10661,"end":10662},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10661},"to":{"change":3,"start":10661,"end":10662},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":8335},"to":{"change":3,"start":10704,"end":10705},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10704},"to":{"change":3,"start":10704,"end":10705},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17911},"to":{"change":3,"start":10944,"end":10945},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10944},"to":{"change":3,"start":10944,"end":10945},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10945},"to":{"change":3,"start":17912,"end":17926},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2699},"to":{"change":3,"start":11009,"end":11010},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11009},"to":{"change":3,"start":11009,"end":11010},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11010},"to":{"change":2,"start":12705,"end":13056},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":13056},"to":{"change":3,"start":11010,"end":11025},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11010},"to":{"change":3,"start":11010,"end":11025},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1709},"to":{"change":3,"start":11117,"end":11142},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":8784},"to":{"change":3,"start":11117,"end":11142},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":13246},"to":{"change":3,"start":11117,"end":11142},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11117},"to":{"change":3,"start":11117,"end":11142},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2774},"to":{"change":3,"start":18001,"end":18002},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8838},"to":{"change":3,"start":18001,"end":18002},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2868},"to":{"change":3,"start":18071,"end":18124},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18071},"to":{"change":3,"start":18071,"end":18124},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1958},"to":{"change":3,"start":8838,"end":8839},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2962},"to":{"change":3,"start":8838,"end":8839},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":18187},"to":{"change":3,"start":8838,"end":8839},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8838},"to":{"change":3,"start":8838,"end":8839},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8839},"to":{"change":3,"start":1710,"end":1727},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1727},"to":{"change":2,"start":13247,"end":13688},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18124},"to":{"change":3,"start":1874,"end":1958},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18002},"to":{"change":3,"start":2775,"end":2868},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1727},"to":{"change":3,"start":11198,"end":11205},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":8854},"to":{"change":3,"start":11198,"end":11205},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":13688},"to":{"change":3,"start":11198,"end":11205},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11198},"to":{"change":3,"start":11198,"end":11205},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1801},"to":{"change":3,"start":8922,"end":8946},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8922},"to":{"change":3,"start":8922,"end":8946},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1851},"to":{"change":3,"start":8993,"end":9062},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8993},"to":{"change":3,"start":8993,"end":9062},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3640},"to":{"change":3,"start":1852,"end":1908},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9137},"to":{"change":3,"start":1852,"end":1908},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1908},"to":{"change":3,"start":1959,"end":2089},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1908},"to":{"change":3,"start":9137,"end":9154},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2089},"to":{"change":3,"start":9137,"end":9154},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9137},"to":{"change":3,"start":9137,"end":9154},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3082},"to":{"change":3,"start":11378,"end":11379},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":14200},"to":{"change":3,"start":11378,"end":11379},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11378},"to":{"change":3,"start":11378,"end":11379},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":10010},"to":{"change":3,"start":11439,"end":11440},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11439},"to":{"change":3,"start":11439,"end":11440},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":471},"to":{"change":3,"start":2114,"end":2152},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":18245},"to":{"change":3,"start":2114,"end":2152},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10070},"to":{"change":3,"start":2114,"end":2152},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2152},"to":{"change":3,"start":10070,"end":10071},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10070},"to":{"change":3,"start":10070,"end":10071},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2496},"to":{"change":3,"start":11455,"end":11461},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11455},"to":{"change":3,"start":11455,"end":11461},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3139},"to":{"change":3,"start":11461,"end":11463},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11461},"to":{"change":3,"start":11461,"end":11463},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11461},"to":{"change":3,"start":2665,"end":3139},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10071},"to":{"change":3,"start":2153,"end":2212},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2664},"to":{"change":3,"start":2918,"end":2937},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2273},"to":{"change":3,"start":2918,"end":2937},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2937},"to":{"change":3,"start":2295,"end":2496},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2295},"to":{"change":3,"start":2295,"end":2496},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2212},"to":{"change":3,"start":2597,"end":2664},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11440},"to":{"change":3,"start":413,"end":471},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3196},"to":{"change":3,"start":9295,"end":9296},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":14222},"to":{"change":3,"start":9295,"end":9296},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9295},"to":{"change":3,"start":9295,"end":9296},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":14635},"to":{"change":3,"start":9316,"end":9323},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9316},"to":{"change":3,"start":9316,"end":9323},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2154},"to":{"change":3,"start":9457,"end":9529},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9457},"to":{"change":3,"start":9457,"end":9529},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2361},"to":{"change":3,"start":9583,"end":9584},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9583},"to":{"change":3,"start":9583,"end":9584},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2023},"to":{"change":3,"start":9599,"end":9606},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9599},"to":{"change":3,"start":9599,"end":9606},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2576},"to":{"change":3,"start":9749,"end":9842},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9749},"to":{"change":3,"start":9749,"end":9842},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2596},"to":{"change":3,"start":9842,"end":10010},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9842},"to":{"change":3,"start":9842,"end":10010},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9842},"to":{"change":3,"start":2577,"end":2596},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9606},"to":{"change":3,"start":3688,"end":3778},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3778},"to":{"change":3,"start":2362,"end":2576},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9584},"to":{"change":3,"start":1992,"end":2023},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9529},"to":{"change":3,"start":2155,"end":2361},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9323},"to":{"change":3,"start":1909,"end":1991},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1991},"to":{"change":3,"start":2090,"end":2154},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9296},"to":{"change":2,"start":14223,"end":14635},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11379},"to":{"change":2,"start":14201,"end":14222},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":14089},"to":{"change":3,"start":3641,"end":3687},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9220},"to":{"change":3,"start":3641,"end":3687},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9154},"to":{"change":2,"start":13997,"end":14089},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9062},"to":{"change":3,"start":3564,"end":3640},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8946},"to":{"change":3,"start":1802,"end":1851},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3687},"to":{"change":3,"start":2963,"end":3082},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11311},"to":{"change":3,"start":2963,"end":3082},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3082},"to":{"change":2,"start":14090,"end":14200},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11205},"to":{"change":2,"start":13689,"end":13996},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":13996},"to":{"change":3,"start":1728,"end":1801},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11205},"to":{"change":3,"start":1728,"end":1801},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11142},"to":{"change":3,"start":2700,"end":2774},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":13143},"to":{"change":3,"start":1616,"end":1617},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8766},"to":{"change":3,"start":1616,"end":1617},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1617},"to":{"change":2,"start":13144,"end":13246},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":11025},"to":{"change":2,"start":13057,"end":13143},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":412},"to":{"change":3,"start":183,"end":366},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18000},"to":{"change":3,"start":183,"end":366},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":366},"to":{"change":3,"start":2730,"end":2800},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18000},"to":{"change":3,"start":2730,"end":2800},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2800},"to":{"change":3,"start":2616,"end":2699},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18000},"to":{"change":3,"start":2616,"end":2699},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17926},"to":{"change":3,"start":337,"end":412},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10705},"to":{"change":3,"start":17542,"end":17627},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2522},"to":{"change":3,"start":17685,"end":17734},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17685},"to":{"change":3,"start":17685,"end":17734},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1857},"to":{"change":3,"start":17794,"end":17850},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2615},"to":{"change":3,"start":17794,"end":17850},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17794},"to":{"change":3,"start":17794,"end":17850},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1873},"to":{"change":3,"start":17867,"end":17911},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17867},"to":{"change":3,"start":17867,"end":17911},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17850},"to":{"change":3,"start":1858,"end":1873},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17734},"to":{"change":3,"start":1774,"end":1857},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17627},"to":{"change":3,"start":2442,"end":2522},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17541},"to":{"change":3,"start":8327,"end":8335},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8327},"to":{"change":3,"start":8327,"end":8335},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1735},"to":{"change":3,"start":17243,"end":17428},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10662},"to":{"change":3,"start":17243,"end":17428},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1773},"to":{"change":3,"start":17465,"end":17541},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17465},"to":{"change":3,"start":17465,"end":17541},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17428},"to":{"change":3,"start":1736,"end":1773},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10662},"to":{"change":3,"start":1588,"end":1735},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7968},"to":{"change":3,"start":7968,"end":8047},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":182},"to":{"change":3,"start":8047,"end":8050},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1568},"to":{"change":3,"start":8047,"end":8050},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2441},"to":{"change":3,"start":8047,"end":8050},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":12704},"to":{"change":3,"start":8047,"end":8050},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8047},"to":{"change":3,"start":8047,"end":8050},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":266},"to":{"change":3,"start":1270,"end":1291},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8095},"to":{"change":3,"start":1270,"end":1291},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":336},"to":{"change":3,"start":1368,"end":1378},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1368},"to":{"change":3,"start":1368,"end":1378},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1228},"to":{"change":3,"start":8182,"end":8191},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1378},"to":{"change":3,"start":8182,"end":8191},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8182},"to":{"change":3,"start":8182,"end":8191},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8191},"to":{"change":3,"start":17181,"end":17198},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1420},"to":{"change":3,"start":8191,"end":8211},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17198},"to":{"change":3,"start":8191,"end":8211},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8191},"to":{"change":3,"start":8191,"end":8211},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1587},"to":{"change":3,"start":17199,"end":17242},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8253},"to":{"change":3,"start":17199,"end":17242},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17242},"to":{"change":3,"start":8253,"end":8255},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8253},"to":{"change":3,"start":8253,"end":8255},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8211},"to":{"change":3,"start":1569,"end":1587},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1291},"to":{"change":3,"start":267,"end":336},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8050},"to":{"change":3,"start":1193,"end":1269},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1269},"to":{"change":3,"start":228,"end":266},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8047},"to":{"change":3,"start":1729,"end":1866},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1437},"to":{"change":3,"start":1914,"end":2208},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1914},"to":{"change":3,"start":1914,"end":2208},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1477},"to":{"change":3,"start":2254,"end":2352},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2254},"to":{"change":3,"start":2254,"end":2352},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1},"to":{"change":3,"start":1,"end":182},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":182},"to":{"change":3,"start":1478,"end":1568},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1568},"to":{"change":2,"start":12512,"end":12704},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2208},"to":{"change":3,"start":1438,"end":1477},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1866},"to":{"change":3,"start":1396,"end":1437},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10603},"to":{"change":3,"start":7694,"end":7710},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":10542},"to":{"change":3,"start":7489,"end":7617},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1334},"to":{"change":3,"start":7620,"end":7631},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7620},"to":{"change":3,"start":7620,"end":7631},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1395},"to":{"change":3,"start":7657,"end":7690},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7657},"to":{"change":3,"start":7657,"end":7690},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7690},"to":{"change":3,"start":17161,"end":17180},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17180},"to":{"change":2,"start":12392,"end":12511},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":12511},"to":{"change":3,"start":7690,"end":7693},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17180},"to":{"change":3,"start":7690,"end":7693},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7690},"to":{"change":3,"start":7690,"end":7693},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7631},"to":{"change":3,"start":1335,"end":1395},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7617},"to":{"change":3,"start":17142,"end":17160},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17160},"to":{"change":2,"start":12349,"end":12391},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":12391},"to":{"change":3,"start":2695,"end":2729},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17160},"to":{"change":3,"start":2695,"end":2729},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2729},"to":{"change":3,"start":1144,"end":1147},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17160},"to":{"change":3,"start":1144,"end":1147},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7617},"to":{"change":3,"start":1144,"end":1147},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1147},"to":{"change":3,"start":1286,"end":1334},"introduced_by":3}],"inode":{"change":3,"pos":10542}},"content":[{"Del":{"text":"use thiserror::Error;","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10602"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10603"}},{"Del":{"text":"const BUFFER_SIZE: usize = 65_527;","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10638"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7711"}},{"Del":{"text":"#[derive(Error, Debug)]","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7735"}},{"Del":{"text":"pub enum Error {","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7752"}},{"Del":{"text":" #[error(\"command for session already started\")]","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7804"}},{"Del":{"text":" SessionCommandAlreadyStarted,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7838"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7839"}},{"Del":{"text":" #[error(\"command for session not started yet\")]","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7891"}},{"Del":{"text":" SessionCommandNotStarted,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7921"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10661"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10704"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:10944"}},{"Del":{"text":"impl Server {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17925"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11009"}},{"Del":{"text":" let (data_sender, data_receiver) = flume::unbounded();","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12767"}},{"Del":{"text":" let (signal_sender, signal_receiver) = flume::unbounded();","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12834"}},{"Del":{"text":" let stopping = Arc::new(AtomicBool::new(false));","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12891"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12892"}},{"Del":{"text":" Self::ctrl_c_watcher(signal_sender)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12938"}},{"Del":{"text":" Self::signal_watcher(signal_receiver, Arc::clone(&stopping));","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13008"}},{"Del":{"text":" Self::start_processor(data_receiver);","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13054"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13055"}},{"Del":{"text":" loop {","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11024"}},{"Del":{"text":" }","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11130"}},{"Del":{"text":" }","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11140"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11141"}},{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:18001"}},{"Del":{"text":" let writer = std::io::BufWriter::new(file);","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:18122"}},{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:18123"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8838"}},{"Del":{"text":" Ok(self)","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1726"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13252"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13253"}},{"Del":{"text":" fn signal_watcher(signal_receiver: Receiver, stopping: Arc) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13341"}},{"Del":{"text":" thread::spawn(move || loop {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13378"}},{"Del":{"text":" match signal_receiver.recv() {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13421"}},{"Del":{"text":" Ok(signal) => match signal {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13466"}},{"Del":{"text":" RunState::Stop => stopping.store(true, Ordering::SeqCst),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13544"}},{"Del":{"text":" RunState::Continue => continue,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13596"}},{"Del":{"text":" },","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13615"}},{"Del":{"text":" Err(err) => warn!(\"{}\", err),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13661"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13675"}},{"Del":{"text":" });","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13687"}},{"Del":{"text":" serde_json::to_writer(writer, &self.state).map_err(Error::SerializeState)?;","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1957"}},{"Del":{"text":" let file = std::fs::File::create(&self.cache_path).map_err(Error::CreateCacheFile)?;","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2867"}},{"Del":{"text":" }","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11203"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11204"}},{"Del":{"text":" match message {","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8945"}},{"Del":{"text":" Message::CommandStart(data) => self.command_start(data),","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9061"}},{"Del":{"text":" Message::Running => self.command_running(),","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1907"}},{"Del":{"text":" Message::Disable(uuid) => self.disable_session(uuid),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2024"}},{"Del":{"text":" Message::Enable(uuid) => self.enable_session(uuid),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2088"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9146"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9152"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9153"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11378"}},{"Del":{"text":"","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11439"}},{"Del":{"text":"","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2114"}},{"Del":{"text":" Ok(RunState::Continue)","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2145"}},{"Del":{"text":" }","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2151"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:10070"}},{"Del":{"text":" }","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11460"}},{"Del":{"text":"}","pos":"B2MSSEJB4GIBFA6F2HRMK7FXUHJBZIZFK6NOHY7YZUSHRB53URGQC:11462"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2665"}},{"Del":{"text":" fn disable_session(&mut self, session_id: Uuid) -> Result {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2746"}},{"Del":{"text":" self.state","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2765"}},{"Del":{"text":" .entries","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2786"}},{"Del":{"text":" .remove(&session_id)","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2819"}},{"Del":{"text":" .expect(\"already tested if exists\");","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2868"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2869"}},{"Del":{"text":" self.state.disabled_session.insert(session_id);","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2925"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2926"}},{"Del":{"text":" Ok(RunState::Continue)","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2957"}},{"Del":{"text":" }","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2963"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2964"}},{"Del":{"text":" fn enable_session(&mut self, session_id: Uuid) -> Result {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:3044"}},{"Del":{"text":" self.state.disabled_session.remove(&session_id);","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:3101"}},{"Del":{"text":" Ok(RunState::Continue)","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:3132"}},{"Del":{"text":" }","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:3138"}},{"Del":{"text":" fn command_running(&self) -> Result {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2211"}},{"Del":{"text":" info!(","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2936"}},{"Del":{"text":" \"session_id={session_id}, command={command}\",","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2356"}},{"Del":{"text":" session_id = session_id,","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2397"}},{"Del":{"text":" command = entry.command","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2437"}},{"Del":{"text":" )","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2451"}},{"Del":{"text":" });","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2463"}},{"Del":{"text":"","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2464"}},{"Del":{"text":" Ok(RunState::Continue)","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2495"}},{"Del":{"text":" self.state.entries.iter().for_each(|(session_id, entry)| {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2663"}},{"Del":{"text":" self.store.add(&entry).map_err(Error::AddStore)?;","pos":"4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC:470"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9295"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9321"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9322"}},{"Del":{"text":" return Err(Error::SessionCommandAlreadyStarted);","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9517"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9527"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9528"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9583"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9604"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9605"}},{"Del":{"text":" return Err(Error::SessionCommandNotStarted);","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9805"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9815"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9816"}},{"Del":{"text":" let start = self","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9841"}},{"Del":{"text":" .entries","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9862"}},{"Del":{"text":" .remove(&finish.session_id)","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9902"}},{"Del":{"text":" .expect(\"already tested if exists\");","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9951"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:9952"}},{"Del":{"text":" let entry = Entry::from_messages(start, finish);","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:10009"}},{"Del":{"text":" .state","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2595"}},{"Del":{"text":" fn command_finished(&mut self, finish: &CommandFinished) -> Result {","pos":"IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC:3777"}},{"Del":{"text":" if self.state.disabled_session.contains(&finish.session_id) {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2431"}},{"Del":{"text":" return Err(Error::DisabledSession(finish.session_id));","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2498"}},{"Del":{"text":" }","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2508"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2509"}},{"Del":{"text":" if !self.state.entries.contains_key(&finish.session_id) {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2575"}},{"Del":{"text":" Ok(RunState::Continue)","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:2022"}},{"Del":{"text":" if self.state.disabled_session.contains(&start.session_id) {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2223"}},{"Del":{"text":" return Err(Error::DisabledSession(start.session_id));","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2289"}},{"Del":{"text":" }","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2299"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2300"}},{"Del":{"text":" self.state.entries.insert(start.session_id, start);","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2360"}},{"Del":{"text":" fn command_start(&mut self, start: CommandStart) -> Result {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1990"}},{"Del":{"text":" if self.state.entries.contains_key(&start.session_id) {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:2153"}},{"Del":{"text":" fn start_processor(data_receiver: Receiver>) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14302"}},{"Del":{"text":" loop {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14317"}},{"Del":{"text":" let buffer = match data_receiver.recv() {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14371"}},{"Del":{"text":" Ok(b) => b,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14399"}},{"Del":{"text":" Err(err) => {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14429"}},{"Del":{"text":" warn!(\"{}\", err);","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14467"}},{"Del":{"text":" continue;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14497"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14515"}},{"Del":{"text":" };","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14530"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14531"}},{"Del":{"text":" let message = bincode::deserialize(&buffer).map_err(Error::DeserializeMessage)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14624"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14634"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14215"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14221"}},{"Del":{"text":" let mut buffer = [0_u8; BUFFER_SIZE];","pos":"IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC:3686"}},{"Del":{"text":" fn receive(socket: &UnixDatagram, data_sender: &Sender>) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14088"}},{"Del":{"text":" Message::CommandFinished(data) => self.command_finished(&data),","pos":"IA2CJ4HDSST6MPDLX2FVE2ZZR7EP5O6AIAUFGZIMWJ6NODVMKOKAC:3639"}},{"Del":{"text":" Message::Stop => Ok(RunState::Stop),","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1850"}},{"Del":{"text":" let (written, _) = socket","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2996"}},{"Del":{"text":" .recv_from(&mut buffer)","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:3032"}},{"Del":{"text":" .map_err(Error::ReceiveFromSocket)?;","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:3081"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14090"}},{"Del":{"text":" data_sender","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14110"}},{"Del":{"text":" .send(buffer[0..written].to_vec())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14157"}},{"Del":{"text":" .map_err(Error::SendBuffer)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:14199"}},{"Del":{"text":" fn ctrl_c_watcher(signal_sender: Sender) -> Result<(), Error> {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13766"}},{"Del":{"text":" ctrlc::set_handler(move || {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13803"}},{"Del":{"text":" if let Err(err) = signal_sender.send(RunState::Stop) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13870"}},{"Del":{"text":" warn!(\"{}\", err)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13903"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13917"}},{"Del":{"text":" })","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13928"}},{"Del":{"text":" .map_err(Error::SetupCtrlHandler)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13972"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13973"}},{"Del":{"text":" Ok(())","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13988"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13994"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13995"}},{"Del":{"text":" fn process(&mut self, message: Message) -> Result {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1800"}},{"Del":{"text":" std::fs::remove_file(&socket_path).map_err(Error::RemoveSocket)?;","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2773"}},{"Del":{"text":"","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1616"}},{"Del":{"text":" if let Err(err) = Self::receive(&socket, &data_sender) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13212"}},{"Del":{"text":" warn!(\"{}\", err)","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13245"}},{"Del":{"text":" if stopping.load(Ordering::SeqCst) {","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13105"}},{"Del":{"text":" break;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13128"}},{"Del":{"text":" }","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:13142"}},{"Del":{"text":" let socket_path_parent = socket_path.parent().ok_or(Error::NoSocketPathParent)?;","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:271"}},{"Del":{"text":" std::fs::create_dir_all(socket_path_parent).map_err(Error::CreateSocketPathParent)?;","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:364"}},{"Del":{"text":"","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:365"}},{"Del":{"text":" info!(\"starting server listening on path {:?}\", socket_path);","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2799"}},{"Del":{"text":" let socket = UnixDatagram::bind(&socket_path).map_err(Error::BindSocket)?;","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2698"}},{"Del":{"text":" pub fn start(mut self, socket_path: &PathBuf) -> Result {","pos":"4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC:411"}},{"Del":{"text":"fn from_cachefile(cache_path: PathBuf, data_dir: PathBuf) -> Result {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17626"}},{"Del":{"text":" let reader = std::io::BufReader::new(file);","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17732"}},{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17733"}},{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17794"}},{"Del":{"text":" let store = store::new(data_dir);","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17832"}},{"Del":{"text":"","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17833"}},{"Del":{"text":" Ok(Server {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17849"}},{"Del":{"text":" store,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17881"}},{"Del":{"text":" cache_path,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17901"}},{"Del":{"text":" })","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17908"}},{"Del":{"text":"}","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17910"}},{"Del":{"text":" state,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1872"}},{"Del":{"text":" let state = serde_json::from_reader(reader).map_err(Error::DeserializeState)?;","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1856"}},{"Del":{"text":" let file = std::fs::File::open(&cache_path).map_err(Error::OpenCacheFile)?;","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2521"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8332"}},{"Del":{"text":"}","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8334"}},{"Del":{"text":"pub fn new(cache_path: PathBuf, data_dir: PathBuf) -> Result {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17320"}},{"Del":{"text":" if cache_path.exists() {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17349"}},{"Del":{"text":" from_cachefile(cache_path, data_dir)","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17394"}},{"Del":{"text":" } else {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17407"}},{"Del":{"text":" Ok(Server {","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17427"}},{"Del":{"text":" store: store::new(data_dir),","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17505"}},{"Del":{"text":" cache_path,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17529"}},{"Del":{"text":" })","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17540"}},{"Del":{"text":" state: State::default(),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1772"}},{"Del":{"text":"#[derive(Debug, Default, Serialize, Deserialize)]","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1637"}},{"Del":{"text":"struct State {","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1652"}},{"Del":{"text":" entries: HashMap,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1694"}},{"Del":{"text":" disabled_session: HashSet,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1731"}},{"Del":{"text":"}","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1733"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1734"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7968"}},{"Del":{"text":" #[error(\"can not add to storeo: {0}\")]","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8011"}},{"Del":{"text":" AddStore(crate::store::Error),","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8046"}},{"Del":{"text":"}","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8048"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8049"}},{"Del":{"text":" match self {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1290"}},{"Del":{"text":" }","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1377"}},{"Del":{"text":" }","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8187"}},{"Del":{"text":"}","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8189"}},{"Del":{"text":"","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8190"}},{"Del":{"text":"#[derive(Debug)]","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17197"}},{"Del":{"text":"pub struct Server {","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8210"}},{"Del":{"text":" store: Store,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17216"}},{"Del":{"text":" cache_path: PathBuf,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17241"}},{"Del":{"text":"}","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:8254"}},{"Del":{"text":" state: State,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1586"}},{"Del":{"text":" Self::Stop => true,","pos":"4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC:298"}},{"Del":{"text":" Self::Continue => false,","pos":"4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC:335"}},{"Del":{"text":"#[derive(Debug)]","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1209"}},{"Del":{"text":"enum RunState {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1225"}},{"Del":{"text":" Stop,","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1235"}},{"Del":{"text":" Continue,","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1249"}},{"Del":{"text":"}","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1251"}},{"Del":{"text":"","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1252"}},{"Del":{"text":"impl RunState {","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1268"}},{"Del":{"text":" const fn is_stop(&self) -> bool {","pos":"4LR5AJ4AX277G4G3SRDHNCIJIOCRZ6I4TUNTSZOAVUX4MW5GYFTQC:265"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1729"}},{"Del":{"text":" #[error(\"can not open cache file: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1774"}},{"Del":{"text":" OpenCacheFile(std::io::Error),","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1809"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1810"}},{"Del":{"text":" #[error(\"can not deserialize cache entries: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1865"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1914"}},{"Del":{"text":" #[error(\"can not bind to socket: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1958"}},{"Del":{"text":" BindSocket(std::io::Error),","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1990"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:1991"}},{"Del":{"text":" #[error(\"can not remove socket: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2034"}},{"Del":{"text":" RemoveSocket(std::io::Error),","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2068"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2069"}},{"Del":{"text":" #[error(\"can not create cache file: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2116"}},{"Del":{"text":" CreateCacheFile(std::io::Error),","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2153"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2154"}},{"Del":{"text":" #[error(\"can not serialize cache entries: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2207"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2254"}},{"Del":{"text":" #[error(\"can not receive message from socket: {0}\")]","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2311"}},{"Del":{"text":" ReceiveFromSocket(std::io::Error),","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2350"}},{"Del":{"text":"","pos":"42MNZNAH4QWQPYFUEMXD2OCDH5PRANP4IXEIK3SBYEOMJXTOKQ7QC:2351"}},{"Del":{"text":" #[error(\"no parent directory for socket path\")]","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:52"}},{"Del":{"text":" NoSocketPathParent,","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:76"}},{"Del":{"text":"","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:77"}},{"Del":{"text":" #[error(\"can not create socket parent directory: {0}\")]","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:137"}},{"Del":{"text":" CreateSocketPathParent(std::io::Error),","pos":"AMFKSNF2C3Y4Z5UNFMUFRSZUOWKQCBMCRFFYW44ZJLSPGVI3VFOAC:181"}},{"Del":{"text":"","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1478"}},{"Del":{"text":" #[error(\"not recording because session {0} is disabled\")]","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1540"}},{"Del":{"text":" DisabledSession(Uuid),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1567"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12512"}},{"Del":{"text":" #[error(\"can not send received data to processing: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12574"}},{"Del":{"text":" SendBuffer(flume::SendError>),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12617"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12618"}},{"Del":{"text":" #[error(\"can not setup ctrlc handler: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12667"}},{"Del":{"text":" SetupCtrlHandler(ctrlc::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12703"}},{"Del":{"text":" SerializeState(serde_json::Error),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1476"}},{"Del":{"text":" DeserializeState(serde_json::Error),","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1436"}},{"Del":{"text":"use uuid::Uuid;","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7709"}},{"Del":{"text":"use crate::{","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7501"}},{"Del":{"text":" entry::Entry,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7519"}},{"Del":{"text":" message::{","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7534"}},{"Del":{"text":" CommandFinished,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7559"}},{"Del":{"text":" CommandStart,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7581"}},{"Del":{"text":" Message,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7598"}},{"Del":{"text":" },","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7605"}},{"Del":{"text":" store,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7616"}},{"Del":{"text":"use std::{","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7630"}},{"Del":{"text":" os::unix::net::UnixDatagram,","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7689"}},{"Del":{"text":" path::PathBuf,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17179"}},{"Del":{"text":" sync::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12403"}},{"Del":{"text":" atomic::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12421"}},{"Del":{"text":" AtomicBool,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12445"}},{"Del":{"text":" Ordering,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12467"}},{"Del":{"text":" },","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12478"}},{"Del":{"text":" Arc,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12491"}},{"Del":{"text":" },","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12498"}},{"Del":{"text":" thread,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12510"}},{"Del":{"text":"};","pos":"VEN5WJYRT23IT77JAAZ5CJRSW3GUTTNMAECT3WVTHQA34HI4646AC:7692"}},{"Del":{"text":" collections::{","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1353"}},{"Del":{"text":" HashMap,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1370"}},{"Del":{"text":" HashSet,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1387"}},{"Del":{"text":" },","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1394"}},{"Del":{"text":" store::Store,","pos":"F2QYIRKBFYFWSTB7Z5CNGSZVYI6XQO3MHPUHJLBHPGLIOG7UNVNQC:17159"}},{"Del":{"text":"};","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12351"}},{"Del":{"text":"use flume::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12364"}},{"Del":{"text":" Receiver,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12378"}},{"Del":{"text":" Sender,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:12390"}},{"Del":{"text":"};","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2697"}},{"Del":{"text":"use log::{","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2708"}},{"Del":{"text":" info,","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2718"}},{"Del":{"text":" warn,","pos":"FKTISISENWXRFIQHUBCSWQAAN7OWUWIOD6R64YEQOBZ6VENZUWYQC:2728"}},{"Del":{"text":"};","pos":"B2BZZXWMRR2FYPBMSSQ6WBCOWX5R3JOXSESX4LFUAQF3FOS4APBQC:1146"}},{"Del":{"text":"use serde::{","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1298"}},{"Del":{"text":" Deserialize,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1315"}},{"Del":{"text":" Serialize,","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1330"}},{"Del":{"text":"};","pos":"4KBRNRLMAVPUVMU2EYNRJTTOZPQRGV2YHZNMLNGBA4Z3QAXKWNKAC:1333"}}]}},{"Replacement":{"inode":{"change":2,"pos":6130},"path":"src/server/builder.rs","line":1,"ins":{"up_context":[{"change":2,"pos":6130}],"down_context":[{"change":2,"pos":6150}],"flag":"BLOCK","start":50,"end":86,"inode":{"change":2,"pos":6130}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":6130},"to":{"change":2,"start":6131,"end":6150},"introduced_by":2}],"inode":{"change":2,"pos":6130}},"ins_contents":[{"Add":{"text":"use super::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:62"}},{"Add":{"text":" db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:70"}},{"Add":{"text":" Server,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:82"}},{"Add":{"text":"};","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:85"}}],"del_contents":[{"Del":{"text":"use super::Server;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:6149"}}]}},{"Edit":{"inode":{"change":2,"pos":6130},"path":"src/server/builder.rs","line":19,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":6396},"to":{"change":2,"start":6396,"end":6480},"introduced_by":2}],"inode":{"change":2,"pos":6130}}},"contents":[{"Del":{"text":" #[error(\"can not open entries database: {0}\")]","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:6446"}},{"Del":{"text":" OpenEntriesDb(sled::Error),","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:6478"}},{"Del":{"text":"","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:6479"}}]}},{"Edit":{"inode":{"change":2,"pos":6130},"path":"src/server/builder.rs","line":27,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":6738}],"down_context":[{"change":2,"pos":6738}],"flag":"BLOCK","start":87,"end":135,"inode":{"change":2,"pos":6130}}},"contents":[{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:87"}},{"Add":{"text":" #[error(\"{0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:107"}},{"Add":{"text":" Db(#[from] db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:134"}}]}},{"Replacement":{"inode":{"change":2,"pos":6130},"path":"src/server/builder.rs","line":40,"ins":{"up_context":[{"change":2,"pos":6931}],"down_context":[{"change":2,"pos":7028}],"flag":"BLOCK","start":136,"end":179,"inode":{"change":2,"pos":6130}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":6931},"to":{"change":2,"start":6931,"end":7028},"introduced_by":2}],"inode":{"change":2,"pos":6130}},"ins_contents":[{"Add":{"text":" let db = db::new(self.cache_dir)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:178"}}],"del_contents":[{"Del":{"text":" let entries = sled::open(self.cache_dir.join(\"entries\")).map_err(Error::OpenEntriesDb)?;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7027"}}]}},{"Replacement":{"inode":{"change":2,"pos":6130},"path":"src/server/builder.rs","line":52,"ins":{"up_context":[{"change":2,"pos":7464}],"down_context":[{"change":2,"pos":7485}],"flag":"BLOCK","start":180,"end":196,"inode":{"change":2,"pos":6130}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":7464},"to":{"change":2,"start":7464,"end":7485},"introduced_by":2}],"inode":{"change":2,"pos":6130}},"ins_contents":[{"Add":{"text":" db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:195"}}],"del_contents":[{"Del":{"text":" entries,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7484"}}]}},{"FileAdd":{"meta":{"basename":"db.rs","metadata":0},"context":[{"change":2,"pos":6110}],"contents":[{"Add":{"text":"use crate::message::CommandStart;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:232"}},{"Add":{"text":"use serde::Serialize;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:254"}},{"Add":{"text":"use std::path::Path;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:275"}},{"Add":{"text":"use thiserror::Error;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:297"}},{"Add":{"text":"use uuid::Uuid;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:313"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:314"}},{"Add":{"text":"#[derive(Error, Debug)]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:338"}},{"Add":{"text":"pub enum Error {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:355"}},{"Add":{"text":" #[error(\"can not open entries database: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:406"}},{"Add":{"text":" OpenEntriesDatabase(sled::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:444"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:445"}},{"Add":{"text":" #[error(\"can not open disabled_sessions database: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:506"}},{"Add":{"text":" OpenDisabledSessionsDatabase(sled::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:553"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:554"}},{"Add":{"text":" #[error(\"can not serialize data: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:598"}},{"Add":{"text":" SerializeData(bincode::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:633"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:634"}},{"Add":{"text":" #[error(\"can not deserialize entry: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:681"}},{"Add":{"text":" DeserializeEntry(bincode::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:719"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:720"}},{"Add":{"text":" #[error(\"{0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:740"}},{"Add":{"text":" Sled(#[from] sled::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:771"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:772"}},{"Add":{"text":" #[error(\"entry does not exist in db\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:815"}},{"Add":{"text":" EntryNotExist,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:834"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:836"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:837"}},{"Add":{"text":"pub fn new(path: impl AsRef) -> Result {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:895"}},{"Add":{"text":" let entries = sled::open(path.as_ref().join(\"entries\")).map_err(Error::OpenEntriesDatabase)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:993"}},{"Add":{"text":" let disabled_sessions = sled::open(path.as_ref().join(\"disabled_sessions\"))","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1073"}},{"Add":{"text":" .map_err(Error::OpenDisabledSessionsDatabase)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1129"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1130"}},{"Add":{"text":" Ok(Db {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1142"}},{"Add":{"text":" entries,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1159"}},{"Add":{"text":" disabled_sessions,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1186"}},{"Add":{"text":" })","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1193"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1195"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1196"}},{"Add":{"text":"pub struct Db {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1212"}},{"Add":{"text":" entries: sled::Db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1235"}},{"Add":{"text":" disabled_sessions: sled::Db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1268"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1270"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1271"}},{"Add":{"text":"impl Db {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1281"}},{"Add":{"text":" pub fn contains_entry(&self, uuid: &Uuid) -> Result {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1352"}},{"Add":{"text":" let key = Self::serialize(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1394"}},{"Add":{"text":" let contains = self.entries.contains_key(key)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1450"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1451"}},{"Add":{"text":" Ok(contains)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1472"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1478"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1479"}},{"Add":{"text":" pub fn is_session_disabled(&self, uuid: &Uuid) -> Result {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1555"}},{"Add":{"text":" let key = Self::serialize(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1597"}},{"Add":{"text":" let contains = self.disabled_sessions.contains_key(key)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1663"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1664"}},{"Add":{"text":" Ok(contains)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1685"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1691"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1692"}},{"Add":{"text":" pub fn add_entry(&self, entry: &CommandStart) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1765"}},{"Add":{"text":" let key = Self::serialize(&entry.session_id)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1820"}},{"Add":{"text":" let value = Self::serialize(&entry)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1866"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1867"}},{"Add":{"text":" self.entries.insert(key, value)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1909"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1910"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1925"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1931"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:1932"}},{"Add":{"text":" pub fn remove_entry(&self, uuid: &Uuid) -> Result {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2009"}},{"Add":{"text":" let key = Self::serialize(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2051"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2052"}},{"Add":{"text":" let data = self.entries.remove(key)?.ok_or(Error::EntryNotExist)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2127"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2128"}},{"Add":{"text":" let entry = Self::deserialize_entry(&data)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2181"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2182"}},{"Add":{"text":" Ok(entry)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2200"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2206"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2207"}},{"Add":{"text":" pub fn disable_session(&self, uuid: &Uuid) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2277"}},{"Add":{"text":" let key = Self::serialize(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2319"}},{"Add":{"text":" let value = Self::serialize(true)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2363"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2364"}},{"Add":{"text":" self.disabled_sessions.insert(key, value)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2416"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2417"}},{"Add":{"text":" self.remove_entry(&uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2452"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2453"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2468"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2474"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2475"}},{"Add":{"text":" pub fn enable_session(&self, uuid: &Uuid) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2544"}},{"Add":{"text":" let key = Self::serialize(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2586"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2587"}},{"Add":{"text":" self.disabled_sessions.remove(&key)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2633"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2634"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2649"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2655"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2656"}},{"Add":{"text":" fn serialize(data: impl Serialize) -> Result, Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2723"}},{"Add":{"text":" let bytes = bincode::serialize(&data).map_err(Error::SerializeData)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2801"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2802"}},{"Add":{"text":" Ok(bytes)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2820"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2826"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2827"}},{"Add":{"text":" fn deserialize_entry(data: &sled::IVec) -> Result {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2904"}},{"Add":{"text":" let entry = bincode::deserialize(&data).map_err(Error::DeserializeEntry)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2987"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:2988"}},{"Add":{"text":" Ok(entry)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3006"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3012"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3014"}}]}},{"Replacement":{"inode":{"change":2,"pos":7664},"path":"src/server/mod.rs","line":2,"ins":{"up_context":[{"change":2,"pos":7682}],"down_context":[{"change":2,"pos":7698}],"flag":"BLOCK","start":3046,"end":3058,"inode":{"change":2,"pos":7664}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":7682},"to":{"change":2,"start":7682,"end":7698},"introduced_by":2}],"inode":{"change":2,"pos":7664}},"ins_contents":[{"Add":{"text":"pub mod db;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3057"}}],"del_contents":[{"Del":{"text":"pub mod server;","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7697"}}]}},{"Replacement":{"inode":{"change":2,"pos":7664},"path":"src/server/mod.rs","line":8,"ins":{"up_context":[{"change":2,"pos":7761}],"down_context":[{"change":2,"pos":7830}],"flag":"BLOCK","start":3059,"end":3560,"inode":{"change":2,"pos":7664}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":7761},"to":{"change":2,"start":7761,"end":7830},"introduced_by":2}],"inode":{"change":2,"pos":7664}},"ins_contents":[{"Add":{"text":"pub use Error as ServerError;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3088"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3089"}},{"Add":{"text":"use crate::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3102"}},{"Add":{"text":" client,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3114"}},{"Add":{"text":" entry::Entry,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3132"}},{"Add":{"text":" message::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3147"}},{"Add":{"text":" CommandFinished,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3172"}},{"Add":{"text":" CommandStart,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3194"}},{"Add":{"text":" Message,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3211"}},{"Add":{"text":" },","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3218"}},{"Add":{"text":" store::Store,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3236"}},{"Add":{"text":"};","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3239"}},{"Add":{"text":"use crossbeam_utils::sync::WaitGroup;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3277"}},{"Add":{"text":"use db::Db;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3289"}},{"Add":{"text":"use flume::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3302"}},{"Add":{"text":" Receiver,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3316"}},{"Add":{"text":" Sender,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3328"}},{"Add":{"text":"};","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3331"}},{"Add":{"text":"use log::warn;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3346"}},{"Add":{"text":"use std::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3357"}},{"Add":{"text":" os::unix::net::UnixDatagram,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3390"}},{"Add":{"text":" path::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3402"}},{"Add":{"text":" Path,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3416"}},{"Add":{"text":" PathBuf,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3433"}},{"Add":{"text":" },","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3440"}},{"Add":{"text":" sync::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3452"}},{"Add":{"text":" atomic::{","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3470"}},{"Add":{"text":" AtomicBool,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3494"}},{"Add":{"text":" Ordering,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3516"}},{"Add":{"text":" },","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3527"}},{"Add":{"text":" Arc,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3540"}},{"Add":{"text":" },","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3547"}},{"Add":{"text":" thread,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3559"}}],"del_contents":[{"Del":{"text":"pub use server::{","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7778"}},{"Del":{"text":" builder,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7791"}},{"Del":{"text":" Error as ServerError,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7817"}},{"Del":{"text":" Server,","pos":"VCTIMI5CEMFTOMDWYI7S2ZKSFN5XYUXH4GBAIKSEZ2N3SBLSH26QC:7829"}}]}},{"Edit":{"inode":{"change":2,"pos":7664},"path":"src/server/mod.rs","line":42,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":7833}],"down_context":[],"flag":"BLOCK","start":3561,"end":10660,"inode":{"change":2,"pos":7664}}},"contents":[{"Add":{"text":"use thiserror::Error;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3582"}},{"Add":{"text":"use uuid::Uuid;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3598"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3599"}},{"Add":{"text":"const BUFFER_SIZE: usize = 65_527;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3634"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3635"}},{"Add":{"text":"#[derive(Error, Debug)]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3659"}},{"Add":{"text":"pub enum Error {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3676"}},{"Add":{"text":" #[error(\"can not receive message from socket: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3733"}},{"Add":{"text":" ReceiveFromSocket(std::io::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3772"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3773"}},{"Add":{"text":" #[error(\"can not send received data to processing: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3835"}},{"Add":{"text":" SendBuffer(flume::SendError>),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3878"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3879"}},{"Add":{"text":" #[error(\"can not deserialize message: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3928"}},{"Add":{"text":" DeserializeMessage(bincode::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3968"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:3969"}},{"Add":{"text":" #[error(\"can not receive data from channel: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4024"}},{"Add":{"text":" ReceiveData(flume::RecvError),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4059"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4060"}},{"Add":{"text":" #[error(\"can not remove socket: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4103"}},{"Add":{"text":" RemoveSocket(std::io::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4137"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4138"}},{"Add":{"text":" #[error(\"can not setup ctrlc handler: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4187"}},{"Add":{"text":" SetupCtrlHandler(ctrlc::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4223"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4224"}},{"Add":{"text":" #[error(\"command for session already started\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4276"}},{"Add":{"text":" SessionCommandAlreadyStarted,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4310"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4311"}},{"Add":{"text":" #[error(\"command for session not started yet\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4363"}},{"Add":{"text":" SessionCommandNotStarted,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4393"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4394"}},{"Add":{"text":" #[error(\"can not check if key exists in db: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4449"}},{"Add":{"text":" CheckContainsEntry(db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4484"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4485"}},{"Add":{"text":" #[error(\"can not check if session is disabled in db: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4549"}},{"Add":{"text":" CheckDisabledSession(db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4586"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4587"}},{"Add":{"text":" #[error(\"not recording because session {0} is disabled\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4649"}},{"Add":{"text":" DisabledSession(Uuid),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4676"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4677"}},{"Add":{"text":" #[error(\"can not add entry to db: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4722"}},{"Add":{"text":" AddDbEntry(db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4749"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4750"}},{"Add":{"text":" #[error(\"can not remove entry from db: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4800"}},{"Add":{"text":" RemoveDbEntry(db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4830"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4831"}},{"Add":{"text":" #[error(\"can not add to storeo: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4874"}},{"Add":{"text":" AddStore(crate::store::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4909"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4910"}},{"Add":{"text":" #[error(\"db error: {0}\")]","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4940"}},{"Add":{"text":" Db(#[from] db::Error),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4967"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4969"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4970"}},{"Add":{"text":"pub struct Server {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:4990"}},{"Add":{"text":" pub(super) db: Db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5013"}},{"Add":{"text":" pub(super) socket: UnixDatagram,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5050"}},{"Add":{"text":" pub(super) socket_path: PathBuf,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5087"}},{"Add":{"text":" pub(super) store: Store,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5116"}},{"Add":{"text":" pub(super) stopping: Arc,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5158"}},{"Add":{"text":" pub(super) wait_group: WaitGroup,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5196"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5198"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5199"}},{"Add":{"text":"pub fn builder(cache_dir: PathBuf, data_dir: PathBuf, socket: PathBuf) -> Builder {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5283"}},{"Add":{"text":" Builder {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5297"}},{"Add":{"text":" cache_dir,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5316"}},{"Add":{"text":" data_dir,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5334"}},{"Add":{"text":" socket,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5350"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5356"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5358"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5359"}},{"Add":{"text":"impl Server {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5373"}},{"Add":{"text":" pub fn run(self) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5417"}},{"Add":{"text":" let data_sender = Self::start_processor(","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5466"}},{"Add":{"text":" Arc::clone(&self.stopping),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5506"}},{"Add":{"text":" self.wait_group.clone(),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5543"}},{"Add":{"text":" self.db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5564"}},{"Add":{"text":" self.store,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5588"}},{"Add":{"text":" self.socket_path.clone(),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5626"}},{"Add":{"text":" )?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5638"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5639"}},{"Add":{"text":" Self::start_receiver(","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5669"}},{"Add":{"text":" Arc::clone(&self.stopping),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5709"}},{"Add":{"text":" self.wait_group.clone(),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5746"}},{"Add":{"text":" self.socket,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5771"}},{"Add":{"text":" data_sender,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5796"}},{"Add":{"text":" )?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5808"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5809"}},{"Add":{"text":" Self::ctrl_c_watcher(self.stopping, self.socket_path.clone())?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5881"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5882"}},{"Add":{"text":" self.wait_group.wait();","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5914"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5915"}},{"Add":{"text":" std::fs::remove_file(&self.socket_path).map_err(Error::RemoveSocket)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5994"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:5995"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6010"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6016"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6017"}},{"Add":{"text":" fn ctrl_c_watcher(stopping: Arc, socket_path: PathBuf) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6111"}},{"Add":{"text":" ctrlc::set_handler(move || {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6148"}},{"Add":{"text":" stopping.store(true, Ordering::SeqCst);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6200"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6201"}},{"Add":{"text":" let client = client::new(socket_path.clone());","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6260"}},{"Add":{"text":" if let Err(err) = client.send(&Message::Stop) {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6320"}},{"Add":{"text":" warn!(\"{}\", err);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6354"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6368"}},{"Add":{"text":" })","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6379"}},{"Add":{"text":" .map_err(Error::SetupCtrlHandler)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6423"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6424"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6439"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6445"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6446"}},{"Add":{"text":" fn start_receiver(","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6469"}},{"Add":{"text":" stopping: Arc,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6504"}},{"Add":{"text":" wait_group: WaitGroup,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6535"}},{"Add":{"text":" socket: UnixDatagram,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6565"}},{"Add":{"text":" data_sender: Sender>,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6603"}},{"Add":{"text":" ) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6632"}},{"Add":{"text":" thread::spawn(move || {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6664"}},{"Add":{"text":" loop {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6683"}},{"Add":{"text":" if stopping.load(Ordering::SeqCst) {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6736"}},{"Add":{"text":" break;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6763"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6781"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6782"}},{"Add":{"text":" if let Err(err) = Self::receive(&socket, &data_sender) {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6855"}},{"Add":{"text":" warn!(\"{}\", err)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6892"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6910"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6924"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6925"}},{"Add":{"text":" drop(wait_group)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6954"}},{"Add":{"text":" });","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6966"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6967"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6982"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6988"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:6989"}},{"Add":{"text":" fn receive(socket: &UnixDatagram, data_sender: &Sender>) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7081"}},{"Add":{"text":" let mut buffer = [0_u8; BUFFER_SIZE];","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7127"}},{"Add":{"text":" let (written, _) = socket","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7161"}},{"Add":{"text":" .recv_from(&mut buffer)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7197"}},{"Add":{"text":" .map_err(Error::ReceiveFromSocket)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7246"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7247"}},{"Add":{"text":" data_sender","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7267"}},{"Add":{"text":" .send(buffer[0..written].to_vec())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7314"}},{"Add":{"text":" .map_err(Error::SendBuffer)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7356"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7357"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7372"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7378"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7379"}},{"Add":{"text":" fn start_processor(","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7403"}},{"Add":{"text":" stopping: Arc,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7438"}},{"Add":{"text":" wait_group: WaitGroup,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7469"}},{"Add":{"text":" db: Db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7485"}},{"Add":{"text":" store: Store,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7507"}},{"Add":{"text":" socket_path: PathBuf,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7537"}},{"Add":{"text":" ) -> Result>, Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7579"}},{"Add":{"text":" let (data_sender, data_receiver) = flume::unbounded();","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7642"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7643"}},{"Add":{"text":" thread::spawn(move || {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7675"}},{"Add":{"text":" loop {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7694"}},{"Add":{"text":" if stopping.load(Ordering::SeqCst) {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7747"}},{"Add":{"text":" break;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7774"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7792"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7793"}},{"Add":{"text":" if let Err(err) =","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7827"}},{"Add":{"text":" Self::process(&stopping, &data_receiver, &db, &store, &socket_path)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7915"}},{"Add":{"text":" {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7933"}},{"Add":{"text":" warn!(\"{}\", err)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7970"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:7988"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8002"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8003"}},{"Add":{"text":" drop(wait_group)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8032"}},{"Add":{"text":" });","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8044"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8045"}},{"Add":{"text":" Ok(data_sender)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8069"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8075"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8076"}},{"Add":{"text":" fn process(","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8092"}},{"Add":{"text":" stopping: &Arc,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8128"}},{"Add":{"text":" data_receiver: &Receiver>,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8171"}},{"Add":{"text":" db: &Db,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8188"}},{"Add":{"text":" store: &Store,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8211"}},{"Add":{"text":" socket_path: impl AsRef,","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8250"}},{"Add":{"text":" ) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8279"}},{"Add":{"text":" let data = data_receiver.recv().map_err(Error::ReceiveData)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8349"}},{"Add":{"text":" let message = bincode::deserialize(&data).map_err(Error::DeserializeMessage)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8436"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8437"}},{"Add":{"text":" dbg!(&message);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8461"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8462"}},{"Add":{"text":" match message {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8486"}},{"Add":{"text":" Message::Stop => {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8517"}},{"Add":{"text":" stopping.store(true, Ordering::SeqCst);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8573"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8574"}},{"Add":{"text":" let client = client::new(socket_path.as_ref().to_path_buf());","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8652"}},{"Add":{"text":" if let Err(err) = client.send(&Message::Stop) {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8716"}},{"Add":{"text":" warn!(\"{}\", err);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8754"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8772"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8773"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8796"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8810"}},{"Add":{"text":" Message::CommandStart(data) => Self::command_start(db, &data),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8885"}},{"Add":{"text":" Message::CommandFinished(data) => Self::command_finished(db, store, &data),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:8973"}},{"Add":{"text":" Message::Disable(uuid) => Self::disable_session(db, &uuid),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9045"}},{"Add":{"text":" Message::Enable(uuid) => Self::enable_session(db, &uuid),","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9115"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9125"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9131"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9132"}},{"Add":{"text":" fn command_start(db: &Db, data: &CommandStart) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9206"}},{"Add":{"text":" if db","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9220"}},{"Add":{"text":" .contains_entry(&data.session_id)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9266"}},{"Add":{"text":" .map_err(Error::CheckContainsEntry)?","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9315"}},{"Add":{"text":" {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9325"}},{"Add":{"text":" return Err(Error::SessionCommandAlreadyStarted);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9386"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9396"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9397"}},{"Add":{"text":" if db","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9411"}},{"Add":{"text":" .is_session_disabled(&data.session_id)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9462"}},{"Add":{"text":" .map_err(Error::CheckDisabledSession)?","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9513"}},{"Add":{"text":" {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9523"}},{"Add":{"text":" return Err(Error::DisabledSession(data.session_id));","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9588"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9598"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9599"}},{"Add":{"text":" db.add_entry(data).map_err(Error::AddDbEntry)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9655"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9656"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9671"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9677"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9678"}},{"Add":{"text":" fn command_finished(db: &Db, store: &Store, data: &CommandFinished) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9773"}},{"Add":{"text":" if db","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9787"}},{"Add":{"text":" .is_session_disabled(&data.session_id)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9838"}},{"Add":{"text":" .map_err(Error::CheckDisabledSession)?","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9889"}},{"Add":{"text":" {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9899"}},{"Add":{"text":" return Err(Error::DisabledSession(data.session_id));","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9964"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9974"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9975"}},{"Add":{"text":" if !db","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:9990"}},{"Add":{"text":" .contains_entry(&data.session_id)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10036"}},{"Add":{"text":" .map_err(Error::CheckContainsEntry)?","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10085"}},{"Add":{"text":" {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10095"}},{"Add":{"text":" return Err(Error::SessionCommandNotStarted);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10152"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10162"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10163"}},{"Add":{"text":" let start = db","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10186"}},{"Add":{"text":" .remove_entry(&data.session_id)","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10230"}},{"Add":{"text":" .map_err(Error::RemoveDbEntry)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10275"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10276"}},{"Add":{"text":" let entry = Entry::from_messages(start, data);","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10331"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10332"}},{"Add":{"text":" store.add(&entry).map_err(Error::AddStore)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10385"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10386"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10401"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10407"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10408"}},{"Add":{"text":" fn disable_session(db: &Db, uuid: &Uuid) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10476"}},{"Add":{"text":" db.disable_session(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10511"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10512"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10527"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10533"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10534"}},{"Add":{"text":" fn enable_session(db: &Db, uuid: &Uuid) -> Result<(), Error> {","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10601"}},{"Add":{"text":" db.enable_session(uuid)?;","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10635"}},{"Add":{"text":"","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10636"}},{"Add":{"text":" Ok(())","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10651"}},{"Add":{"text":" }","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10657"}},{"Add":{"text":"}","pos":"XJJ6HCY4AYXPWPAGUQEKY2XNPEDV36H6OJKYRPKXC2BIASCLCSMAC:10659"}}]}}],"owner":"athaller","repo":"hstdb","token":"VOl/2kU3UXpF0bf4KSIRV1epnoH6zxM67d23FC6Q5f8=","login":null}

…

Dependencies

Change contents

Review