toolchain: bump to 1.79.0

lib/event/src/tags/key.rs

@@ -53,7 +53,7 @@ impl Key {
         if s.len() <= INLINE_CAP {
             Key::inline(&s)
         } else {
-            unsafe { transmute(s) }
+            unsafe { transmute::<String, Key>(s) }
         }
     }
 
@@ -169,7 +169,7 @@ impl From<&str> for Key {
             unsafe {
                 copy_nonoverlapping(v.as_ptr(), data.as_mut_ptr(), len);
                 data[KEY_SIZE - 1] = len as u8;
-                return transmute(data);
+                return transmute::<[u8; 24], Key>(data);
             }
         }
 
@@ -183,7 +183,7 @@ impl From<&String> for Key {
         if v.len() < INLINE_CAP {
             Key::inline(v)
         } else {
-            unsafe { transmute(v.to_string()) }
+            unsafe { transmute::<String, Key>(v.to_string()) }
         }
     }
 }
@@ -197,7 +197,7 @@ impl From<String> for Key {
 impl From<Key> for String {
     fn from(key: Key) -> Self {
         if key.last == 0 {
-            return unsafe { transmute(key) };
+            return unsafe { transmute::<Key, String>(key) };
         }
 
         key.as_str().to_string()
@@ -272,7 +272,7 @@ mod serde {
                     let key = if len <= INLINE_CAP {
                         Key::inline(v)
                     } else {
-                        unsafe { transmute(v.to_string()) }
+                        unsafe { transmute::<String, Key>(v.to_string()) }
                     };
 
                     Ok(key)

lib/framework/src/config/watcher.rs

@@ -123,6 +123,7 @@ mod inotify {
     ///
     /// A file system event that describes a change that the user previously
     /// registered interest in. To watch for events.
+    #[allow(dead_code)]
     pub struct Event<S> {
         /// Identifies the watch this event originates from.
         pub wd: i32,

lib/virt/src/client.rs

@@ -227,36 +227,10 @@ impl Client {
     }
 
     pub async fn storage_pools(&mut self) -> Result<Vec<StoragePoolInfo>, Error> {
-        /*        let req = self.make_request(
-            REMOTE_PROC_CONNECT_LIST_STORAGE_POOLS,
-            ListAllStoragePoolsRequest::new(2), // 2 for active pools
-        );
-        let resp: ListAllStoragePoolsResponse = self.do_request(req).await?;
-        let pools = resp.pools();
-        let mut infos = Vec::with_capacity(pools.len());
-
-        for pool in pools {
-            let name = pool.name.0.clone();
-            let req = self.make_request(
-                REMOTE_PROC_STORAGE_POOL_GET_INFO,
-                StoragePoolGetInfoRequest::new(pool),
-            );
-            let resp: StoragePoolGetInfoResponse = self.do_request(req).await?;
-            infos.push(StoragePoolInfo {
-                name,
-                state: resp.0.state as u32,
-                capacity: resp.0.capacity,
-                allocation: resp.0.allocation,
-                available: resp.0.available,
-            })
-        }
-
-        Ok(infos)*/
-
         let resp: ConnectListStoragePoolsResponse = self
             .send(ConnectListStoragePoolsRequest { maxnames: 2 })
             .await?;
-        let mut infos = Vec::with_capacity(resp.pools.len());
+        let mut infos = Vec::with_capacity(resp.ret as usize);
 
         for pool in resp.pools {
             let req = GetStoragePoolInfoRequest { pool: &pool };

lib/virt/src/protocol/get_all_domain_stats.rs

@@ -6,6 +6,7 @@ use super::{pack_flex, unpack_flex, unpack_string, Domain, Pack, Unpack};
 
 pub const REMOTE_CONNECT_GET_ALL_DOMAIN_STATS_MAX: usize = 4096;
 
+#[allow(dead_code)]
 pub enum RemoteTypedParamValue {
     Const1(i32),
     Const2(u32),

lib/virt/src/protocol/get_domain_vcpus.rs

@@ -49,6 +49,7 @@ impl<R: Read> Unpack<R> for VcpuInfo {
 
 pub struct GetDomainVcpusResponse {
     pub infos: Vec<VcpuInfo>,
+    #[allow(dead_code)]
     pub maps: Vec<u8>,
 }
 

lib/vtl/src/compiler/function_call.rs

@@ -13,7 +13,13 @@ pub struct FunctionCall {
 impl Expression for FunctionCall {
     #[inline]
     fn resolve(&self, cx: &mut Context) -> Result<Value, ExpressionError> {
-        self.function.resolve(cx)
+        self.function.resolve(cx).map_err(|err| match err {
+            ExpressionError::Error { message, .. } => ExpressionError::Error {
+                message,
+                span: self.span,
+            },
+            err => err,
+        })
     }
 
     #[inline]

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.78.0"
+channel = "1.79.0"

src/sinks/elasticsearch/mod.rs

@@ -1,3 +1,5 @@
+#![allow(dead_code)]
+
 mod common;
 mod config;
 mod encoder;

src/sources/bind/client/mod.rs

@@ -81,6 +81,7 @@ pub struct ZoneView {
 }
 
 /// ThreadModel contains task and worker information
+#[allow(dead_code)]
 #[derive(Default, Deserialize)]
 pub struct ThreadModel {
     #[serde(rename = "type")]

src/sources/bind/client/v3.rs

@@ -273,6 +273,7 @@ mod tests {
             DateTime::parse_from_rfc3339("2021-07-15T05:11:08.926Z").unwrap()
         );
         assert_eq!(stats.taskmgr.thread_model.worker_threads, 5);
+        assert_eq!(stats.taskmgr.thread_model.typ, "threaded");
         assert_eq!(stats.views.views.len(), 2)
     }
 

src/sources/libvirt.rs

@@ -792,6 +792,7 @@ async fn gather_v2(path: &str) -> Result<Vec<Metric>, Error> {
     Ok(metrics)
 }
 
+#[allow(dead_code)]
 mod schema {
     use serde::Deserialize;