liz/veilid
1
0
Fork 0
Code Pull Requests Packages Releases Activity

Fix warnings.

Browse Source
This commit is contained in:
Trent Waddington
2023-10-10 12:51:11 +10:00
parent 1fec1a5008
commit 72889b8f1a
3 changed files with 31 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
veilid-core/src/rpc_processor/coders/operations/operation_value_changed.rs
View File

@@ -10,6 +10,7 @@ pub struct RPCOperationValueChanged {
}
impl RPCOperationValueChanged {
#[allow(dead_code)]
pub fn new(
key: TypedKey,
subkeys: ValueSubkeyRangeSet,
@@ -29,18 +30,27 @@ impl RPCOperationValueChanged {
Ok(())
}
#[allow(dead_code)]
pub fn key(&self) -> &TypedKey {
&self.key
}
#[allow(dead_code)]
pub fn subkeys(&self) -> &ValueSubkeyRangeSet {
&self.subkeys
}
#[allow(dead_code)]
pub fn count(&self) -> u32 {
self.count
}
#[allow(dead_code)]
pub fn value(&self) -> &SignedValueData {
&self.value
}
#[allow(dead_code)]
pub fn destructure(self) -> (TypedKey, ValueSubkeyRangeSet, u32, SignedValueData) {
(self.key, self.subkeys, self.count, self.value)
}

17
veilid-core/src/rpc_processor/coders/operations/operation_watch_value.rs
View File

@@ -14,6 +14,7 @@ pub struct RPCOperationWatchValueQ {
}
impl RPCOperationWatchValueQ {
#[allow(dead_code)]
pub fn new(
key: TypedKey,
subkeys: ValueSubkeyRangeSet,
@@ -70,25 +71,37 @@ impl RPCOperationWatchValueQ {
Ok(())
}
#[allow(dead_code)]
pub fn key(&self) -> &TypedKey {
&self.key
}
#[allow(dead_code)]
pub fn subkeys(&self) -> &ValueSubkeyRangeSet {
&self.subkeys
}
#[allow(dead_code)]
pub fn expiration(&self) -> u64 {
self.expiration
}
#[allow(dead_code)]
pub fn count(&self) -> u32 {
self.count
}
#[allow(dead_code)]
pub fn watcher(&self) -> &PublicKey {
&self.watcher
}
#[allow(dead_code)]
pub fn signature(&self) -> &Signature {
&self.signature
}
#[allow(dead_code)]
pub fn destructure(
self,
) -> (
@@ -192,6 +205,7 @@ pub struct RPCOperationWatchValueA {
}
impl RPCOperationWatchValueA {
#[allow(dead_code)]
pub fn new(expiration: u64, peers: Vec<PeerInfo>) -> Result<Self, RPCError> {
if peers.len() > MAX_WATCH_VALUE_A_PEERS_LEN {
return Err(RPCError::protocol("WatchValueA peers length too long"));
@@ -204,12 +218,15 @@ impl RPCOperationWatchValueA {
Ok(())
}
#[allow(dead_code)]
pub fn expiration(&self) -> u64 {
self.expiration
}
#[allow(dead_code)]
pub fn peers(&self) -> &[PeerInfo] {
&self.peers
}
#[allow(dead_code)]
pub fn destructure(self) -> (u64, Vec<PeerInfo>) {
(self.expiration, self.peers)
}