From ecd5ee5a36f9d1b5e0ded62bde3952dff52c157a Mon Sep 17 00:00:00 2001
From: finga <finga@onders.org>
Date: Fri, 9 Jul 2021 00:31:51 +0200
Subject: [PATCH] Add functions to print information about SysV mqs

Not needed yet but maybe useful..
---
 sysvmq/src/lib.rs | 62 ++++++++++++++++++++++++++++++++++++++++-------
 1 file changed, 53 insertions(+), 9 deletions(-)

diff --git a/sysvmq/src/lib.rs b/sysvmq/src/lib.rs
index b9de136..298a48e 100644
--- a/sysvmq/src/lib.rs
+++ b/sysvmq/src/lib.rs
@@ -1,21 +1,15 @@
 use libc::{
-    msgctl, msgget, msqid_ds, IPC_CREAT, IPC_EXCL, IPC_INFO, IPC_NOWAIT, IPC_PRIVATE, IPC_RMID,
-    IPC_SET, IPC_STAT, MSG_COPY, MSG_EXCEPT, MSG_INFO, MSG_NOERROR, MSG_STAT,
+    msgctl, msgget, msginfo, msqid_ds, IPC_CREAT, IPC_EXCL, IPC_INFO, IPC_NOWAIT, IPC_PRIVATE,
+    IPC_RMID, IPC_SET, IPC_STAT, MSG_COPY, MSG_EXCEPT, MSG_INFO, MSG_NOERROR, MSG_STAT,
 };
 use nix::errno::{errno, Errno};
-use std::{marker::PhantomData, num::ParseIntError, ptr};
+use std::{marker::PhantomData, mem::MaybeUninit, ptr};
 use thiserror::Error;
 
 #[derive(Debug, Error)]
 pub enum SysvMqError {
     #[error("SysV message queue: {0}")]
     ErrnoError(&'static str),
-    #[error("No message queue found with key {0}")]
-    KeyNotFound(i32),
-    #[error("IO Error: {0}")]
-    IoError(#[from] std::io::Error),
-    #[error("Parse Error: {0}")]
-    ParserError(#[from] ParseIntError),
 }
 
 /// IPC bit flags
@@ -78,6 +72,56 @@ pub fn id_from_key(key: i32) -> Result<i32, SysvMqError> {
     }
 }
 
+pub fn ipc_info(id: i32) -> Result<(), SysvMqError> {
+    let mut msginfo = MaybeUninit::<msginfo>::uninit();
+
+    unsafe {
+        msgctl(
+            id,
+            ControlCommands::IpcInfo as i32,
+            msginfo.as_mut_ptr() as *mut msqid_ds,
+        );
+    }
+
+    let msginfo = unsafe { msginfo.assume_init() };
+
+    println!("info: {:?}", msginfo);
+
+    Ok(())
+}
+
+pub fn stat_info(id: i32) -> Result<(), SysvMqError> {
+    let mut msginfo = MaybeUninit::<msqid_ds>::uninit();
+
+    unsafe {
+        msgctl(id, ControlCommands::Stat as i32, msginfo.as_mut_ptr());
+    }
+
+    let msginfo = unsafe { msginfo.assume_init() };
+
+    println!("info: {:?}", msginfo);
+
+    Ok(())
+}
+
+pub fn msg_info(id: i32) -> Result<(), SysvMqError> {
+    let mut msginfo = MaybeUninit::<msginfo>::uninit();
+
+    unsafe {
+        msgctl(
+            id,
+            ControlCommands::MsgInfo as i32,
+            msginfo.as_mut_ptr() as *mut msqid_ds,
+        );
+    }
+
+    let msginfo = unsafe { msginfo.assume_init() };
+
+    println!("info: {:?}", msginfo);
+
+    Ok(())
+}
+
 pub struct SysvMq<T> {
     pub id: i32,
     pub key: i32,