24 | #[derive(Debug, PartialEq, PartialOrd, Eq, Hash, Clone)] |
25 | #[allow(clippy::rc_buffer)] |
26 | pub struct Namespace(Arc<Vec<String>>); |
16 | #[derive(Debug, Clone)] |
17 | #[allow(clippy::rc_buffer)] |
18 | pub struct SqliteStatement { |
77 | /// Current content. |
78 | #[allow(clippy::rc_buffer)] // Rc::make_mut is what we want here. |
79 | content: Rc<String>, |
370 | /// Get the current text. |
371 | #[allow(clippy::rc_buffer)] |
372 | pub fn get_content(&self) -> Rc<String> { |
546 | /// The signature and state type must match the `Accumulator's implementation`. |
547 | #[allow(clippy::rc_buffer)] |
548 | pub fn create_udaf( |
1945 | #[derive(Debug, Clone, PartialEq, Eq)] |
1946 | #[allow(clippy::rc_buffer)] |
1947 | pub struct StringifiedPlan { |
48 | #[allow(clippy::rc_buffer)] |
49 | #[derive(Clone, Data, Lens)] |
43 | #[allow(clippy::rc_buffer)] |
44 | #[derive(Clone, Data, PartialEq)] |
35 | /// We don't use a Mutex around the Vec here because adding a middleware during execution should be an error. |
36 | #[allow(clippy::rc_buffer)] |
37 | middleware: Arc<Vec<Arc<dyn Middleware>>>, |
42 | /// Representation of a Multiaddr. |
43 | #[allow(clippy::rc_buffer)] |
44 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
953 | /// Builtin programs activated dynamically by feature |
954 | #[allow(clippy::rc_buffer)] |
955 | feature_builtins: Arc<Vec<(Builtin, Pubkey, ActivationType)>>, |
79 | /// Google Cloud Platform project JSON credentials (provided as String). |
80 | #[allow(clippy::rc_buffer)] |
81 | pub(crate) fn get_token(google_credentials: impl AsRef<str>) -> Result<Arc<String>> { |
192 | #[allow(clippy::rc_buffer)] |
193 | buffer: Rc<String>, |
61 | /// The data to sign. |
62 | #[allow(clippy::rc_buffer)] |
63 | pub data: Arc<Vec<u8>>, |
53 | /// We don't use a Mutex around the Vec here because adding a middleware during execution should be an error. |
54 | #[allow(clippy::rc_buffer)] |
55 | middleware: Arc<Vec<Arc<dyn Middleware>>>, |
41 | #[allow(clippy::rc_buffer)] |
42 | pub struct FloodSub { |
133 | // Tell new peer my subscribed topics. |
134 | #[allow(clippy::rc_buffer)] |
135 | fn get_hello_packet(&self) -> Arc<Vec<u8>> { |
449 | #[allow(clippy::rc_buffer)] |
450 | async fn handle_send_message(mut rx: UnboundedReceiver<Arc<Vec<u8>>>, mut writer: Substream) -> Result<()> { |
36 | /// Representation of a Multiaddr. |
37 | #[allow(clippy::rc_buffer)] |
38 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
56 | /// We don't use a Mutex around the Vec here because adding a middleware during execution should be an error. |
57 | #[allow(clippy::rc_buffer)] |
58 | middleware: Arc<Vec<Arc<dyn Middleware>>>, |
37 | /// Representation of a Multiaddr. |
38 | #[allow(clippy::rc_buffer)] |
39 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
42 | /// Representation of a Multiaddr. |
43 | #[allow(clippy::rc_buffer)] |
44 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
65 | pub struct Node<C: Codec> { |
66 | #[allow(clippy::rc_buffer)] |
67 | queues: Arc<Vec<Queue<Packet<C>>>>, |
13 | #[derive(Debug, Clone)] |
14 | #[allow(clippy::rc_buffer)] |
15 | pub struct SqliteStatement { |
91 | // NOTE seems falls positive. |
92 | #[allow(clippy::rc_buffer)] |
93 | thread_pools: Option<Arc<Vec<ThreadPool>>>, |
1309 | /// Dynamic feature transitions for builtin programs |
1310 | #[allow(clippy::rc_buffer)] |
1311 | builtin_feature_transitions: Arc<Vec<BuiltinFeatureTransition>>, |
1040 | /// Dynamic feature transitions for builtin programs |
1041 | #[allow(clippy::rc_buffer)] |
1042 | builtin_feature_transitions: Arc<Vec<BuiltinFeatureTransition>>, |
18 | #[derive(Debug, Clone)] |
19 | #[allow(clippy::rc_buffer)] |
20 | pub struct SqliteStatement<'q> { |
17 | #[derive(Debug, Clone)] |
18 | #[allow(clippy::rc_buffer)] |
19 | pub struct SqliteStatement<'q> { |
39 | /// 在这里不在Vec使用互斥体,因为在执行期间添加中间件应该是一个错误。 |
40 | #[allow(clippy::rc_buffer)] |
41 | middleware: Arc<Vec<Arc<dyn Middleware<State>>>>, |
53 | /// We don't use a Mutex around the Vec here because adding a middleware during execution should be an error. |
54 | #[allow(clippy::rc_buffer)] |
55 | middleware: Arc<Vec<Arc<dyn Middleware>>>, |
42 | /// Representation of a Multiaddr. |
43 | #[allow(clippy::rc_buffer)] |
44 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
42 | /// Representation of a Multiaddr. |
43 | #[allow(clippy::rc_buffer)] |
44 | #[derive(PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] |
38 | /// We don't use a Mutex around the Vec here because adding a middleware during execution should be an error. |
39 | #[allow(clippy::rc_buffer)] |
40 | middleware: Arc<Vec<Arc<dyn Middleware<State>>>>, |
84 | struct ReadableFile { |
85 | #[allow(clippy::rc_buffer)] // to allow accessing the same object as writable |
86 | content: Arc<Vec<u8>>, |
272 | file_type: VfsFileType, |
273 | #[allow(clippy::rc_buffer)] // to allow accessing the same object as writable |
274 | content: Arc<Vec<u8>>, |
1079 | /// Dynamic feature transitions for builtin programs |
1080 | #[allow(clippy::rc_buffer)] |
1081 | builtin_feature_transitions: Arc<Vec<BuiltinFeatureTransition>>, |
102 | /// concept's currently assigned runtime ID. |
103 | #[allow(clippy::rc_buffer)] |
104 | pub fn concept_id(&self) -> Option<Rc<usize>> { |
121 | /// implementation. |
122 | #[allow(clippy::rc_buffer)] |
123 | pub fn documentation(&self) -> Option<Rc<str>> { |
141 | /// concept's class. |
142 | #[allow(clippy::rc_buffer)] |
143 | pub fn dual_purpose_documentation(&self) -> Option<Rc<str>> { |
109 | /// Get the Rust code representation for the default value of this concept. |
110 | #[allow(clippy::rc_buffer)] |
111 | pub fn default_value(&self) -> Option<Rc<str>> { |
126 | /// Get the name of the Rust primitive that this concept represents. |
127 | #[allow(clippy::rc_buffer)] |
128 | pub fn rust_primitive(&self) -> Option<Rc<str>> { |
143 | /// Get the unboxed version of this primitive. |
144 | #[allow(clippy::rc_buffer)] |
145 | pub fn unboxed_representation(&self) -> Option<Rc<str>> { |
161 | /// concept. |
162 | #[allow(clippy::rc_buffer)] |
163 | pub fn dummy_value(&self) -> Option<Rc<str>> { |
93 | /// Get the version number for the crate. |
94 | #[allow(clippy::rc_buffer)] |
95 | pub fn version(&self) -> Option<Rc<str>> { |
105 | /// Retrieve usize-valued StrongValue. |
106 | #[allow(clippy::rc_buffer)] |
107 | pub fn value(&self) -> Option<Rc<usize>> { |
105 | /// Retrieve str-valued StrongValue. |
106 | #[allow(clippy::rc_buffer)] |
107 | pub fn value(&self) -> Option<Rc<str>> { |
1 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
2 | #![warn(clippy::all, rust_2018_idioms, rust_2018_compatibility)] |
3 | #![allow(clippy::rc_buffer)] // https://github.com/rust-lang/rust-clippy/issues/6170 |
209 | #![allow(clippy::rc_buffer)] |
210 | #![warn(missing_docs)] |
1 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
66 | //! |
67 | #![allow(clippy::rc_buffer)] |
68 | #![warn(clippy::complexity)] |
76 | //! |
77 | #![allow(clippy::rc_buffer)] |
78 | #![warn(clippy::complexity)] |
1 | #![allow(clippy::rc_buffer)] |
1 | //! A stage to broadcast data from a leader node to validators |
2 | #![allow(clippy::rc_buffer)] |
3 | use { |
1 | //! The `retransmit_stage` retransmits shreds between validators |
2 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
1 | #![allow(clippy::rc_buffer)] |
6 | #![allow(clippy::stable_sort_primitive)] |
7 | #![allow(clippy::rc_buffer)] |
8 | #![warn(clippy::needless_borrow, clippy::use_self)] |