stop ignoring dead code and unused variables

This commit is contained in:
Dustin J. Mitchell 2020-11-23 14:29:51 -05:00
parent 779a331003
commit ba55d298ce
3 changed files with 0 additions and 11 deletions

View file

@ -4,7 +4,4 @@ use failure::Fail;
pub enum Error { pub enum Error {
#[fail(display = "Task Database Error: {}", _0)] #[fail(display = "Task Database Error: {}", _0)]
DBError(String), DBError(String),
#[fail(display = "Replica Error: {}", _0)]
ReplicaError(String),
} }

View file

@ -1,7 +1,3 @@
// TODO: remove this eventually when there's an API
#![allow(dead_code)]
#![allow(unused_variables)]
#[macro_use] #[macro_use]
extern crate failure; extern crate failure;

View file

@ -177,7 +177,6 @@ impl<'t> TaskStorageTxn for Txn<'t> {
fn all_tasks(&mut self) -> Fallible<Vec<(Uuid, TaskMap)>> { fn all_tasks(&mut self) -> Fallible<Vec<(Uuid, TaskMap)>> {
let bucket = self.tasks_bucket(); let bucket = self.tasks_bucket();
let kvtxn = self.kvtxn(); let kvtxn = self.kvtxn();
let curs = kvtxn.read_cursor(bucket)?;
let all_tasks: Result<Vec<(Uuid, TaskMap)>, Error> = kvtxn let all_tasks: Result<Vec<(Uuid, TaskMap)>, Error> = kvtxn
.read_cursor(bucket)? .read_cursor(bucket)?
.iter() .iter()
@ -189,7 +188,6 @@ impl<'t> TaskStorageTxn for Txn<'t> {
fn all_task_uuids(&mut self) -> Fallible<Vec<Uuid>> { fn all_task_uuids(&mut self) -> Fallible<Vec<Uuid>> {
let bucket = self.tasks_bucket(); let bucket = self.tasks_bucket();
let kvtxn = self.kvtxn(); let kvtxn = self.kvtxn();
let curs = kvtxn.read_cursor(bucket)?;
Ok(kvtxn Ok(kvtxn
.read_cursor(bucket)? .read_cursor(bucket)?
.iter() .iter()
@ -224,7 +222,6 @@ impl<'t> TaskStorageTxn for Txn<'t> {
fn operations(&mut self) -> Fallible<Vec<Operation>> { fn operations(&mut self) -> Fallible<Vec<Operation>> {
let bucket = self.operations_bucket(); let bucket = self.operations_bucket();
let kvtxn = self.kvtxn(); let kvtxn = self.kvtxn();
let curs = kvtxn.read_cursor(bucket)?;
let all_ops: Result<Vec<(u64, Operation)>, Error> = kvtxn let all_ops: Result<Vec<(u64, Operation)>, Error> = kvtxn
.read_cursor(bucket)? .read_cursor(bucket)?
.iter() .iter()
@ -299,7 +296,6 @@ impl<'t> TaskStorageTxn for Txn<'t> {
res.push(None) res.push(None)
} }
let curs = kvtxn.read_cursor(working_set_bucket)?;
for (i, u) in kvtxn.read_cursor(working_set_bucket)?.iter() { for (i, u) in kvtxn.read_cursor(working_set_bucket)?.iter() {
let i: u64 = i.into(); let i: u64 = i.into();
res[i as usize] = Some(u.inner()?.to_serde()); res[i as usize] = Some(u.inner()?.to_serde());