selmeci / dgraph-tonic / 147

pending completion

Build # 147

Build Type

Pull #32

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/selmeci/dgraph-tonic/commit/<a class=hub.com/selmeci/dgraph-tonic/commit/<a class="double-link" href="https://git"><a class=hub.com/selmeci/dgraph-tonic/commit/<a class="double-link" href="https://git"><a class=hub.com/selmeci/dgraph-tonic/commit/<a class="double-link" href="https://git"><a class=hub.com/selmeci/dgraph-tonic/commit/dfc66f6bfeb3db86fe867caa1a00a50901eca208">dfc66f6bf">&lt;a href=&quot;https://github.com/selmeci/dgraph-tonic/commit/</a><a class="double-link" href="https://github.com/selmeci/dgraph-tonic/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/selmeci/dgraph-tonic/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/selmeci/dgraph-tonic/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/selmeci/dgraph-tonic/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/selmeci/dgraph-tonic/commit/dfc66f6bfeb3db86fe867caa1a00a50901eca208">dfc66f6bf</a><a href="https://github.com/selmeci/dgraph-tonic/commit/dfc66f6bfeb3db86fe867caa1a00a50901eca208">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/selmeci/dgraph-tonic/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/selmeci/dgraph-tonic/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/selmeci/dgraph-tonic/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/selmeci/dgraph-tonic/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/selmeci/dgraph-tonic/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/selmeci/dgraph-tonic/commit/dfc66f6bfeb3db86fe867caa1a00a50901eca208&quot;&gt;dfc66f6bf&lt;/a&gt;&lt;a href=&quot;https://github.com/selmeci/dgraph-tonic/commit/dfc66f6bfeb3db86fe867caa1a00a50901eca208&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/selmeci/dgraph-tonic/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://gi... (continued)

Pull Request Pull Request #32: Update dependencies - specifically, tokio, prost, and tonic

Run Details

18 of 18 new or added lines in 5 files covered. (100.0%)

765 of 1100 relevant lines covered (69.55%)

1.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

61.11

/src/sync/txn/read_only.rs

use std::collections::hash_map::RandomState;
use std::collections::HashMap;
use std::fmt::Debug;
use std::hash::Hash;
use std::sync::{Arc, Mutex};

use anyhow::Result;
use async_trait::async_trait;
use tokio::runtime::Runtime;

use crate::client::ILazyClient;
use crate::sync::txn::{IState, TxnType, TxnVariant};
use crate::txn::TxnReadOnlyType as AsyncReadOnlyTxn;
use crate::{Query, Response};

///
/// Inner state for read only transaction
///
#[derive(Clone, Debug)]
pub struct ReadOnly<C: ILazyClient> {
    pub(crate) rt: Arc<Mutex<Runtime>>,
    pub(crate) async_txn: Arc<Mutex<AsyncReadOnlyTxn<C>>>,
}

#[async_trait]
impl<C: ILazyClient> IState for ReadOnly<C> {
    fn query_with_vars<Q, K, V>(
        &mut self,
        query: Q,
        vars: HashMap<K, V, RandomState>,
    ) -> Result<Response>
    where
        Q: Into<String> + Send + Sync,
        K: Into<String> + Send + Sync + Eq + Hash,
        V: Into<String> + Send + Sync,
    {
        let rt = self.rt.lock().expect("Tokio Runtime");
        let async_txn = Arc::clone(&self.async_txn);
        rt.block_on(async move {
            let mut async_txn = async_txn.lock().expect("Async Txn");
            async_txn.query_with_vars(query, vars).await
        })
    }

    #[cfg(feature = "dgraph-1-1")]
    fn query_rdf_with_vars<Q, K, V>(&mut self, query: Q, vars: HashMap<K, V>) -> Result<Response>
    where
        Q: Into<String> + Send + Sync,
        K: Into<String> + Send + Sync + Eq + Hash,
        V: Into<String> + Send + Sync,
    {
        let rt = self.rt.lock().expect("Tokio Runtime");
        let async_txn = Arc::clone(&self.async_txn);
        rt.block_on(async move {
            let mut async_txn = async_txn.lock().expect("Async Txn");
            async_txn.query_rdf_with_vars(query, vars).await
        })
    }
}

///
/// ReadOnly variant of transaction
///
pub type TxnReadOnlyType<C> = TxnVariant<ReadOnly<C>>;

impl<C: ILazyClient> TxnType<C> {
    ///
    /// Create new read only transaction from default transaction state
    ///
    pub fn read_only(self) -> TxnReadOnlyType<C> {
        let rt = self.extra.rt;
        let txn = self
            .extra
            .async_txn
            .lock()
            .expect("Txn")
            .to_owned()
            .read_only();
        TxnVariant {
            state: self.state,
            extra: ReadOnly {
                rt,
                async_txn: Arc::new(Mutex::new(txn)),
            },
        }
    }
}

1	use std::collections::hash_map::RandomState;
2	use std::collections::HashMap;
3	use std::fmt::Debug;
4	use std::hash::Hash;
5	use std::sync::{Arc, Mutex};
6
7	use anyhow::Result;
8	use async_trait::async_trait;
9	use tokio::runtime::Runtime;
10
11	use crate::client::ILazyClient;
12	use crate::sync::txn::{IState, TxnType, TxnVariant};
13	use crate::txn::TxnReadOnlyType as AsyncReadOnlyTxn;
14	use crate::{Query, Response};
15
16	///
17	/// Inner state for read only transaction
18	///
19	#[derive(Clone, Debug)]
20	pub struct ReadOnly<C: ILazyClient> {
21	pub(crate) rt: Arc<Mutex<Runtime>>,
22	pub(crate) async_txn: Arc<Mutex<AsyncReadOnlyTxn<C>>>,
23	}
24
25	#[async_trait]
26	impl<C: ILazyClient> IState for ReadOnly<C> {
27	fn query_with_vars<Q, K, V>(	2✔
28	&mut self,
29	query: Q,
30	vars: HashMap<K, V, RandomState>,
31	) -> Result<Response>
32	where
33	Q: Into<String> + Send + Sync,
34	K: Into<String> + Send + Sync + Eq + Hash,
35	V: Into<String> + Send + Sync,
36	{
37	let rt = self.rt.lock().expect("Tokio Runtime");	2✔
38	let async_txn = Arc::clone(&self.async_txn);	2✔
39	rt.block_on(async move {	6✔
40	let mut async_txn = async_txn.lock().expect("Async Txn");	2✔
41	async_txn.query_with_vars(query, vars).await	6✔
42	})
43	}
44
45	#[cfg(feature = "dgraph-1-1")]
46	fn query_rdf_with_vars<Q, K, V>(&mut self, query: Q, vars: HashMap<K, V>) -> Result<Response>
47	where
48	Q: Into<String> + Send + Sync,
49	K: Into<String> + Send + Sync + Eq + Hash,
50	V: Into<String> + Send + Sync,
51	{
52	let rt = self.rt.lock().expect("Tokio Runtime");	×
53	let async_txn = Arc::clone(&self.async_txn);	×
54	rt.block_on(async move {	×
55	let mut async_txn = async_txn.lock().expect("Async Txn");	×
56	async_txn.query_rdf_with_vars(query, vars).await	×
57	})
58	}
59	}
60
61	///
62	/// ReadOnly variant of transaction
63	///
64	pub type TxnReadOnlyType<C> = TxnVariant<ReadOnly<C>>;
65
66	impl<C: ILazyClient> TxnType<C> {
67	///
68	/// Create new read only transaction from default transaction state
69	///
70	pub fn read_only(self) -> TxnReadOnlyType<C> {	1✔
71	let rt = self.extra.rt;	1✔
72	let txn = self	1✔
73	.extra	×
74	.async_txn	×
75	.lock()
76	.expect("Txn")
77	.to_owned()
78	.read_only();
79	TxnVariant {
80	state: self.state,	1✔
81	extra: ReadOnly {	1✔
82	rt,
83	async_txn: Arc::new(Mutex::new(txn)),
84	},
85	}
86	}
87	}

selmeci / dgraph-tonic / 147

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous