mqi 0.3.0

Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

use libmqm_default as default;
use libmqm_sys as mq;
use libmqm_sys::Mqi;

use super::option;
use crate::{Connection, Library, constants, prelude::*, result::ResultComp, structs, types};

const DEFAULT_OBJECTSTRING_LENGTH: types::MQLONG = 4096;

impl<L: Library<MQ: Mqi>, H> Connection<L, H> {
    /// This function uses the [`MQSTAT`](libmqm_sys::MQSTAT) MQ API function.
    pub fn stat_put(&self) -> ResultComp<option::AsyncPutStat> {
        let mut sts = structs::MQSTS::new(mq::MQSTS {
            Version: mq::MQSTS_VERSION_2,
            ..default::MQSTS_DEFAULT
        });

        if sts.ObjectString.VSBufSize == 0 {
            sts.ObjectString.VSBufSize = DEFAULT_OBJECTSTRING_LENGTH;
        }
        let mut buffer = Vec::with_capacity(
            sts.ObjectString
                .VSBufSize
                .try_into()
                .expect("buffer length should convert to usize"),
        );
        sts.ObjectString.VSPtr = (&raw mut *buffer).cast();

        // SAFETY: MQSTS ObjectString MQCHARV constructed from buffer
        unsafe {
            self.mq
                .mqstat(self.handle, constants::MQSTAT_TYPE_ASYNC_ERROR, &mut sts)
                .map_completion(|()| option::AsyncPutStat::new(&sts, buffer))
        }
    }

    /// This function uses the [`MQSTAT`](libmqm_sys::MQSTAT) MQ API function.
    #[inline]
    pub fn stat_reconnection(&self) -> ResultComp<option::ReconnectionStat> {
        let mut sts = structs::MQSTS::new(default::MQSTS_DEFAULT);

        // SAFETY: MQSTS No pointers populated
        unsafe {
            self.mq
                .mqstat(self.handle, constants::MQSTAT_TYPE_RECONNECTION, &mut sts)
                .map_completion(|()| option::ReconnectionStat::new(&sts))
        }
    }

    /// This function uses the [`MQSTAT`](libmqm_sys::MQSTAT) MQ API function.
    #[inline]
    pub fn stat_reconnection_error(&self) -> ResultComp<option::ReconnectionErrorStat> {
        let mut sts = structs::MQSTS::new(mq::MQSTS {
            Version: mq::MQSTS_VERSION_2,
            ..default::MQSTS_DEFAULT
        });

        sts.ObjectString.VSBufSize = DEFAULT_OBJECTSTRING_LENGTH;
        let mut object_string_buffer = Vec::with_capacity(
            sts.ObjectString
                .VSBufSize
                .try_into()
                .expect("buffer length should convert to usize"),
        );
        sts.ObjectString.VSPtr = (&raw mut *object_string_buffer).cast();

        sts.SubName.VSBufSize = DEFAULT_OBJECTSTRING_LENGTH;
        let mut sub_name_buffer = Vec::with_capacity(
            sts.SubName
                .VSBufSize
                .try_into()
                .expect("buffer length should convert to usize"),
        );
        sts.SubName.VSPtr = (&raw mut *sub_name_buffer).cast();

        // SAFETY: MQSTS ObjectString and SubName MQCHARV constructed from buffers
        unsafe {
            self.mq
                .mqstat(self.handle, constants::MQSTAT_TYPE_RECONNECTION_ERROR, &mut sts)
                .map_completion(|()| option::ReconnectionErrorStat::new(&sts, object_string_buffer, sub_name_buffer))
        }
    }
}