gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Re-export rocksdb::DBRawIterator until it can be encapsulated

Browse Source
This commit is contained in:
Michael Vines
2018-12-20 10:05:07 -08:00
parent b36ceb5be4
commit 93fb61dc8f
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/db_ledger.rs
View File

@ -7,7 +7,7 @@ use crate::packet::{Blob, SharedBlob, BLOB_HEADER_SIZE};
use crate::result::{Error, Result}; use crate::result::{Error, Result};
use bincode::{deserialize, serialize}; use bincode::{deserialize, serialize};
use byteorder::{BigEndian, ByteOrder, ReadBytesExt}; use byteorder::{BigEndian, ByteOrder, ReadBytesExt};
use rocksdb::{ColumnFamily, ColumnFamilyDescriptor, DBRawIterator, Options, WriteBatch, DB}; use rocksdb::{ColumnFamily, ColumnFamilyDescriptor, Options, WriteBatch, DB};
use serde::de::DeserializeOwned; use serde::de::DeserializeOwned;
use serde::Serialize; use serde::Serialize;
use solana_sdk::signature::{Keypair, KeypairUtil}; use solana_sdk::signature::{Keypair, KeypairUtil};
@ -16,6 +16,9 @@ use std::cmp::max;
use std::io; use std::io;
use std::path::Path; use std::path::Path;
// Re-export rocksdb::DBRawIterator until it can be encapsulated
pub use rocksdb::DBRawIterator;
pub const DB_LEDGER_DIRECTORY: &str = "rocksdb"; pub const DB_LEDGER_DIRECTORY: &str = "rocksdb";
// A good value for this is the number of cores on the machine // A good value for this is the number of cores on the machine
pub const TOTAL_THREADS: i32 = 8; pub const TOTAL_THREADS: i32 = 8;

1
src/db_window.rs
View File

@ -10,7 +10,6 @@ use crate::packet::{SharedBlob, BLOB_HEADER_SIZE};
use crate::result::Result; use crate::result::Result;
use crate::streamer::BlobSender; use crate::streamer::BlobSender;
use log::Level; use log::Level;
use rocksdb::DBRawIterator;
use solana_metrics::{influxdb, submit}; use solana_metrics::{influxdb, submit};
use solana_sdk::pubkey::Pubkey; use solana_sdk::pubkey::Pubkey;
use std::cmp; use std::cmp;