tikv
/
client-rust
mirror of https://github.com/tikv/client-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into correct-transaction-api

This commit is contained in:
Yilin Chen 2019-08-06 04:48:11 +00:00
parent 67f741acb0 2733e28ece
commit 60dc6a5af2
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/rpc/pd/timestamp.rs
View File

@ -6,10 +6,10 @@
//! Once a `TimestampOracle` is created, there will be two futures running in a background working //! Once a `TimestampOracle` is created, there will be two futures running in a background working
//! thread created automatically. The `get_timestamp` method creates a oneshot channel whose //! thread created automatically. The `get_timestamp` method creates a oneshot channel whose
//! transmitter is served as a `TimestampRequest`. `TimestampRequest`s are sent to the working //! transmitter is served as a `TimestampRequest`. `TimestampRequest`s are sent to the working
//! thread through a bounded multi-producer, single-consumer channel. The first future tries to //! thread through a bounded multi-producer, single-consumer channel. Every time the first future
//! exhaust the channel to get as many requests as possible and sends a single `TsoRequest` to the //! is polled, it tries to exhaust the channel to get as many requests as possible and sends a
//! PD server. The other future receives `TsoResponse`s from the PD server and allocates timestamps //! single `TsoRequest` to the PD server. The other future receives `TsoResponse`s from the PD
//! for the requests. //! server and allocates timestamps for the requests.
use super::Timestamp; use super::Timestamp;
use crate::{Error, Result}; use crate::{Error, Result};
@ -23,7 +23,7 @@ use futures::{
task::{AtomicWaker, Context, Poll}, task::{AtomicWaker, Context, Poll},
}; };
use grpcio::WriteFlags; use grpcio::WriteFlags;
use kvproto::pdpb::{PdClient, *}; use kvproto::pdpb::*;
use std::{cell::RefCell, collections::VecDeque, pin::Pin, rc::Rc, thread}; use std::{cell::RefCell, collections::VecDeque, pin::Pin, rc::Rc, thread};
/// It is an empirical value. /// It is an empirical value.