syslog_rs/sync/

syslog.rs

/*-
 * syslog-rs - a syslog client translated from libc to rust
 * 
 * Copyright 2025 Aleksandr Morozov
 * 
 * Licensed under the EUPL, Version 1.2 or - as soon they will be approved by
 * the European Commission - subsequent versions of the EUPL (the "Licence").
 * 
 * You may not use this work except in compliance with the Licence.
 * 
 * You may obtain a copy of the Licence at:
 * 
 *    https://joinup.ec.europa.eu/software/page/eupl
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the Licence is distributed on an "AS IS" basis, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * Licence for the specific language governing permissions and limitations
 * under the Licence.
 */

use std::{fmt::{self, Arguments, Write}, marker::PhantomData};

use crate::{error::SyRes, formatters::{DefaultSyslogFormatter, SyslogFormatter}, sy_sync_queue::SyslogQueueAdapter, syslog_provider::*, LogFacility, LogStat, Priority};

#[cfg(feature = "use_sync_queue")]
use crate::sy_sync_queue::SyslogQueue;


use super::syslog_sync_shared::SyslogShared;
use super::{syslog_stream::SyslogStream, syslog_trait::SyslogApi};


/// A main instance of the Syslog client.
/// 
/// * `D` - a [SyslogDestination] instance which is either:
///     [SyslogLocal], [SyslogFile], [SyslogNet], [SyslogTls]. By
///     default a `SyslogLocal` is set.
/// 
/// * `F` - a [SyslogFormatter] a message formatter for the destination
///     server. See `formatters` i.e `FormatRfc3146`, `FormatRfc5424`, `FormatFile`. Or
///     `DefaultSyslogFormatter`, `DefaultSyslogFormatterFile`.
/// 
/// * `S` - a [SyslogApi] sybsystem. It is either [SyslogShared] or [SyslogQueue] with 
///     the same 'F' - formatter type. By default a [SyslogShared] is set.
#[derive(Debug)]
pub struct Syslog<D = SyslogLocal, F = DefaultSyslogFormatter, S = SyslogShared<F>>
    (S, PhantomData<F>, PhantomData<D>)
where D: SyslogDestination, F: SyslogFormatter, S: SyslogApi;

impl Syslog
{
    /// Opens a default connection to the local syslog server with default formatter.
    /// 
    /// # Arguments
    /// 
    /// * `ident` - A program name which will appear on the logs. If none, will be determined
    ///     automatically.
    /// 
    /// * `logstat` - [LogStat] an instance config.
    /// 
    /// * `facility` - [LogFacility] a syslog facility.
    /// 
    /// * `dest` - a destination server. Allows to connect to the different local syslog server or
    ///     will be determined automatically.
    /// 
    /// # Returns
    /// 
    /// A [SyRes] is returned ([Result]) with: 
    /// 
    /// * [Result::Ok] - with instance
    /// 
    /// * [Result::Err] - with error description.
    pub 
    fn openlog(ident: Option<&str>, logstat: LogStat, facility: LogFacility, dest: SyslogLocal) -> SyRes<Self>
    {
        let net_tap = dest.init()?;
        
        let syslog = SyslogShared::<DefaultSyslogFormatter>::openlog(ident, logstat, facility, net_tap)?;

        return Ok(Self(syslog, PhantomData::<DefaultSyslogFormatter>, PhantomData::<SyslogLocal>));
    }
}

#[cfg(feature = "use_sync")]
impl<D: SyslogDestination, F: SyslogFormatter> Syslog<D, F, SyslogShared<F>>
{
    /// Opens a special connection to the destination syslog server with specific formatter.
    /// 
    /// All struct generic should be specified before calling this function.
    /// 
    /// # Arguments
    /// 
    /// * `ident` - A program name which will appear on the logs. If none, will be determined
    ///     automatically.
    /// 
    /// * `logstat` - [LogStat] an instance config.
    /// 
    /// * `facility` - [LogFacility] a syslog facility.
    /// 
    /// * `dest` - a destination server. Allows to connect to the different local syslog server or
    ///     will be determined automatically.
    /// 
    /// # Returns
    /// 
    /// A [SyRes] is returned ([Result]) with: 
    /// 
    /// * [Result::Ok] - with instance
    /// 
    /// * [Result::Err] - with error description.
    pub 
    fn openlog_with(ident: Option<&str>, logstat: LogStat, facility: LogFacility, dest: D) -> SyRes<Syslog<D, F, SyslogShared<F>>>
    {
        let net_tap = dest.init()?;
        
        let syslog = SyslogShared::<F>::openlog(ident, logstat, facility, net_tap)?;

        return Ok(Self(syslog, PhantomData::<F>, PhantomData::<D>));
    }

    /// Sets the logmask to filter out the syslog calls. This function behaves 
    /// differently as it behaves in syslog_sync.rs or syslog_async.rs.
    /// It may return an error if: syslog thread had exit and some thread calls
    /// this function. Or something happened with channel. 
    /// This function blocks until the previous mask is received.
    /// 
    /// See macroses [LOG_MASK] and [LOG_UPTO] to generate mask
    ///
    /// # Example
    ///
    /// LOG_MASK!(Priority::LOG_EMERG) | LOG_MASK!(Priority::LOG_ERROR)
    ///
    /// or
    ///
    /// ~(LOG_MASK!(Priority::LOG_INFO))
    /// LOG_UPTO!(Priority::LOG_ERROR) 
    pub 
    fn setlogmask(&self, logmask: i32) -> SyRes<i32>
    {
        return self.0.setlogmask(logmask);
    }

    /// Changes the identity i.e program name which will appear on the logs.
    /// 
    /// Can return error if mutex is poisoned.
    pub 
    fn change_identity(&self, ident: &str) -> SyRes<()>
    {
        return self.0.change_identity(ident);
    }

    /// Closes connection to the syslog server
    pub 
    fn closelog(&self) -> SyRes<()>
    {
        return self.0.closelog();
    }

    /// Similar to libc, syslog() sends data to syslog server.
    /// 
    /// # Arguments
    ///
    /// * `pri` - a priority [Priority]
    ///
    /// * `fmt` - a program's message to be sent as payload.
    #[inline]
    pub 
    fn syslog(&self, pri: Priority, fmt: String)
    {
        self.0.syslog(pri, fmt);
    }

    /// Sends message to syslog (same as `syslog`).
    #[inline]
    pub 
    fn vsyslog<M: AsRef<str>>(&self, pri: Priority, fmt: M)
    {
        self.0.vsyslog(pri, fmt);
    }

    /// Performs the reconnection to the syslog server or file re-open.
    /// 
    /// # Returns
    /// 
    /// A [Result] is retured as [SyRes].
    /// 
    /// * [Result::Ok] - with empty inner type.
    /// 
    /// * [Result::Err] - an error code and description
    pub  
    fn reconnect(&self) -> SyRes<()>
    {
        return self.0.reconnect();
    }

    /// Updates the inner instance destionation i.e path to file
    /// or server address. The type of destination can not be changed.
    /// 
    /// This function disconnects from syslog server if previously was 
    /// connected (and reconnects if was connected previously).
    /// 
    /// # Arguments 
    /// 
    /// * `new_tap` - a consumed instance of type `D` [SyslogDestination]
    /// 
    /// # Returns 
    /// 
    /// A [SyRes] is returned. An error may be returned if:
    /// 
    /// * connection to server was failed
    /// 
    /// * incorrect type
    /// 
    /// * disconnect frm server failed
    pub 
    fn update_tap(&self, new_tap: D) -> SyRes<()>
    {
        return self.0.update_tap_data(new_tap.init()?);
    }
    
    /// Derives from active syslog intance an [fmt::Write] instance.
    /// 
    /// A boxed `dyn` instance of [SyslogStream] is returned.
    pub 
    fn make_stream(&self, pri: Priority) -> Box<dyn SyslogStream>
    {
        let inst = 
            StreamableSyslog
            {
                inner: self.0.clone(),
                pri: pri,
                _p: PhantomData::<F>,
            };

        return Box::new(inst);
    }
}

#[cfg(feature = "use_sync_queue")]
impl<D: SyslogDestination, F: SyslogFormatter> Syslog<D, F, SyslogQueue<F>>
{
    /// Opens a special connection to the destination syslog server with specific formatter.
    /// 
    /// All struct generic should be specified before calling this function.
    /// 
    /// # Arguments
    /// 
    /// * `ident` - A program name which will appear on the logs. If none, will be determined
    ///     automatically.
    /// 
    /// * `logstat` - [LogStat] an instance config.
    /// 
    /// * `facility` - [LogFacility] a syslog facility.
    /// 
    /// * `dest` - a destination server. Allows to connect to the different local syslog server or
    ///     will be determined automatically.
    /// 
    /// # Returns
    /// 
    /// A [SyRes] is returned ([Result]) with: 
    /// 
    /// * [Result::Ok] - with instance
    /// 
    /// * [Result::Err] - with error description.
    pub 
    fn openlog_with(ident: Option<&str>, logstat: LogStat, facility: LogFacility, dest: D) -> SyRes<Syslog<D, F, SyslogQueue<F>>>
    {
        let net_tap = dest.init()?;
        
        let syslog = SyslogQueue::<F>::openlog(ident, logstat, facility, net_tap)?;
    
        return Ok(Self(syslog, PhantomData::<F>, PhantomData::<D>));
    }

    /// Sets the logmask to filter out the syslog calls. This function behaves 
    /// differently as it behaves in syslog_sync.rs or syslog_async.rs.
    /// It may return an error if: syslog thread had exit and some thread calls
    /// this function. Or something happened with channel. 
    /// This function blocks until the previous mask is received.
    /// 
    /// See macroses [LOG_MASK] and [LOG_UPTO] to generate mask
    ///
    /// # Example
    ///
    /// LOG_MASK!(Priority::LOG_EMERG) | LOG_MASK!(Priority::LOG_ERROR)
    ///
    /// or
    ///
    /// ~(LOG_MASK!(Priority::LOG_INFO))
    /// LOG_UPTO!(Priority::LOG_ERROR) 
    pub 
    fn setlogmask(&self, logmask: i32) -> SyRes<i32>
    {
        return self.0.setlogmask(logmask);
    }

    /// Closes connection to the syslog server
    pub 
    fn closelog(&self) -> SyRes<()>
    {
        return self.0.closelog();
    }

    /// Similar to libc, syslog() sends data to syslog server.
    /// 
    /// # Arguments
    ///
    /// * `pri` - a priority [Priority]
    ///
    /// * `fmt` - a program's message to be sent as payload.
    #[inline]
    pub 
    fn syslog(&self, pri: Priority, fmt: String)
    {
        self.0.syslog(pri, fmt);
    }

    /// Sends message to syslog (same as `syslog`).
    #[inline]
    pub 
    fn vsyslog<M: AsRef<str>>(&self, pri: Priority, fmt: M)
    {
        self.0.vsyslog(pri, fmt);
    }

    /// Performs the reconnection to the syslog server or file re-open.
    /// 
    /// # Returns
    /// 
    /// A [Result] is retured as [SyRes].
    /// 
    /// * [Result::Ok] - with empty inner type.
    /// 
    /// * [Result::Err] - an error code and description
    pub  
    fn reconnect(&self) -> SyRes<()>
    {
        return self.0.reconnect();
    }

    /// Updates the inner instance destionation i.e path to file
    /// or server address. The type of destination can not be changed.
    /// 
    /// This function disconnects from syslog server if previously was 
    /// connected (and reconnects if was connected previously).
    /// 
    /// # Arguments 
    /// 
    /// * `new_tap` - a consumed instance of type `D` [SyslogDestination]
    /// 
    /// # Returns 
    /// 
    /// A [SyRes] is returned. An error may be returned if:
    /// 
    /// * connection to server was failed
    /// 
    /// * incorrect type
    /// 
    /// * disconnect frm server failed
    pub 
    fn update_tap(&self, new_tap: D) -> SyRes<()>
    {
        return self.0.update_tap_data(new_tap.init()?);
    }
    
    /// Derives from active syslog intance an [fmt::Write] instance.
    /// 
    /// A boxed `dyn` instance of [SyslogStream] is returned.
    pub 
    fn make_stream(&self, pri: Priority) -> Box<dyn SyslogStream>
    {
        let inst = 
            StreamableSyslog
            {
                inner: self.0.clone(),
                pri: pri,
                _p: PhantomData::<F>,
            };

        return Box::new(inst);
    }
}

#[cfg(all(feature = "use_sync_queue", feature = "use_async"))]
impl<D: SyslogDestination, F: SyslogFormatter> Syslog<D, F, SyslogQueue<F>>
{
    pub 
    fn make_adapter(&self) -> SyslogQueueAdapter
    {
        return self.0.make_adapter();
    }
}

#[cfg(feature = "build_with_net")]
impl<F: SyslogFormatter, S: SyslogApi> Syslog<SyslogNet, F, S>
{

}

#[cfg(feature = "build_with_file")]
impl<F: SyslogFormatter, S: SyslogApi> Syslog<SyslogFile, F, S>
{

}

impl<F: SyslogFormatter, S: SyslogApi> Syslog<SyslogLocal, F, S>
{

}

#[cfg(feature = "build_with_tls")]
impl<F: SyslogFormatter, S: SyslogApi> Syslog<SyslogTls, F, S>
{

}


/// An implementation which allows to [write!] to syslog.
/// 
/// Will block awaiting while inner mutex is locked.
/// You need to make sure that [SyslogStream] is stored as
/// mutable instance.
struct StreamableSyslog<F: SyslogFormatter, S: SyslogApi>
{
    /// Syslog instance
    inner: S,

    /// Priority
    pri: Priority,

    _p: PhantomData<F>
}

impl<F: SyslogFormatter, S: SyslogApi> SyslogStream for StreamableSyslog<F, S>
{
    /// Updates the pri [Priority] 
    fn update_pri(&mut self, new_pri: Priority) -> Priority
    {
        let prev = self.pri;
        self.pri = new_pri;

        return prev;
    }
}

impl<F: SyslogFormatter, S: SyslogApi> Write for StreamableSyslog<F, S>
{
    fn write_str(&mut self, s: &str) -> fmt::Result 
    {
        self.inner.vsyslog(self.pri, s);

        return Ok(());
    }

    fn write_fmt(self: &mut Self, args: Arguments<'_>) -> fmt::Result
    {
        if let Some(s) = args.as_str() 
        {
            return self.write_str(s);
        } 
        else 
        {
            return self.write_str(&args.to_string());
        }
    }
}

/*
#[test]
fn test1()
{
    let sy = 
        Syslog
            ::<SyslogNet, DefaultSyslogFormatter, SyslogShared<DefaultSyslogFormatter>>
            ::openlog_with(None, LogStat::empty(), LogFacility::empty(), SyslogNet::new())
                .unwrap();

    //sy.change_net();
}
    */
#[cfg(feature = "use_sync")]
#[cfg(test)]
mod tests_shared
{
    use super::*;

    #[test]
    fn test_single_message()
    {


        let log = 
                Syslog::openlog(
                    Some("test1"), 
                    LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID, 
                    LogFacility::LOG_DAEMON,
                SyslogLocal::new());

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = log.unwrap();

        let now = std::time::Instant::now();

        log.syslog(Priority::LOG_DEBUG, format!("test UTF-8 проверка BOM UTF-8"));

        let dur = now.elapsed();
        println!("{:?}", dur);

        let now = std::time::Instant::now();

        log.syslog(Priority::LOG_DEBUG, format!("test UTF-8  きるさお命泉ぶねりよ日子金れっ"));

        let dur = now.elapsed();
        println!("{:?}", dur);

        let _ = log.closelog();

        return;
    }

    #[test]
    fn test_single_message_perror()
    {
        /*use std::sync::Arc;
        use std::thread;
        use std::time::Duration;
        use super::{LOG_MASK};*/

        let log = 
            Syslog::openlog(
                    Some("test1"), 
                    LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID | LogStat::LOG_PERROR, 
                    LogFacility::LOG_DAEMON,
                    SyslogLocal::new()
                );

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = log.unwrap();

        log.syslog(Priority::LOG_DEBUG, format!("test UTF-8 きるさお命泉ぶねりよ日子金れっ проверка BOM"));

        let _ = log.closelog();

        return;
    }

    #[test]
    fn test_multithreading()
    {
        use std::sync::Arc;
        use std::thread;
        use std::time::{Instant, Duration};

        let log = 
                Syslog::openlog(
                    Some("test1"), 
                    LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID, 
                    LogFacility::LOG_DAEMON,
                SyslogLocal::new()
            );

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = Arc::new(log.unwrap());
        let c1_log = log.clone();
        let c2_log = log.clone();

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(200));
                let now = Instant::now();
                c1_log.syslog(Priority::LOG_DEBUG, format!("a message from thread 1 #{}[]", i));
                let elapsed = now.elapsed();
                println!("t1: {:?}", elapsed);
            }
        });

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(201));
                let now = Instant::now();
                c2_log.syslog(Priority::LOG_DEBUG, format!("きるさお命泉ぶねりよ日子金れっ {}", i));
                let elapsed = now.elapsed();
                println!("t2: {:?}", elapsed);
            }
        });

        let now = Instant::now();
        log.syslog(Priority::LOG_DEBUG, format!("A message from main, きるさお命泉ぶねりよ日子金れっ"));
        let elapsed = now.elapsed();
        println!("main: {:?}", elapsed);

        thread::sleep(Duration::from_secs(2));

        let _ = log.closelog();

        return;
    }

    #[test]
    fn long_msg_test()
    {
        // 40 EMSGSIZE
        let msg = 
    "7赤ざクぽな載覧な改申ほふ取容う主坊酸ヱ司戦ヒソオ力端めゃ間真ル実記キ団需くスルて学回県仁京ぴ熱完かあもく。上ょぜ催5強変却ソヲキ転入ク記事購シリ断衝ぽ玲面たぽつへ様態の善無かー勢加ヨマナキ趣会撮さはこ違42器のレうゆ。稿エスタ己報照アイネル岩撲ムニ半者サアキツ画47込死請誌8策ノ再然ださそ禁断しにた高否リ続最ユケ山芸ロ去群づへ索芭あン掲佳怖斎澤クね。
    書キマコヒ上広ざばてわ会佐のにりリ学総点フわすか頼野ぜイよば株約ネキヱメ必軽チヲ録使ラ下能ナウコ紀捜れ霊別イ摯療じらどト相3聞めびら情拳ユフエ確経板植えーぜあ。無ど曲注程クタル系新どばくい都面村リと計安ワヱ月見モヌエノ完臨健85定テサコミ貸容ミテタカ写載とかえげ詐訃だみそな。代け設養テヨナ乱54服料ニ止画ら不暮ッ強治ぱンやし供方広づじもあ般判ごくドラ示刊ヱサトキ速事取さふぞ授共西れッ。
    陸オク康59面くこ惑7伊エノモ候余ロソウ政投ナク転文だけス香両4誕よ数真ひぞぴざ空加ユラ勢隣ゃびよ移72士シヌ図際想カマテ覧費活輸権因ん。東がイ価変や濃恒ヒメネエ学見ょ理供カオムヱ針中わば文63転ヨリホミ礼民ネトマツ速果還ばが転世晴げでんが。犯レト同岸サケ写新ゆぐぱひ人捕けほゅえ的人第いぜ転連ぎど京分株ニムトヒ家及ユフケヌ記定み歩死質をゃいイ都末ワ革量んつ覧打百レいん。
    下ゃとぞら川株以東ぴそぱ費更ウマヨメ覧論ウスレモ八度ずんとイ発平う果構つ小各ぼス夢国フラ連石はちい雪飲聴ゅいと。門ぱし続消上ト文影投設テユチ設川ルラシケ引押ヤマセメ権書ハテ例発リロソイ環載ぴ企実カマリト店鉄ワソロフ逆子先チルマ楽法どゆね声東女携抜爆んけみ。14報ふラめて怒止に開謙こさ促大ヘチツ遺飯ケ営長コキ価空少ろッひぱ読信ケテウ者育ヒミク代57柱浪フ。
    ";

    println!("{}", msg.len());

        let log = 
                Syslog::openlog(
                    Some("test1"), 
                    LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID, 
                    LogFacility::LOG_DAEMON,
                    SyslogLocal::new()
                );

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = log.unwrap();

        log.syslog(Priority::LOG_DEBUG, format!("{}", msg));
                    
        let _ = log.closelog();

        return;
    }
}
    
#[cfg(feature = "use_sync_queue")]
#[cfg(test)]
mod tests_queue
{
    use crate::{formatters::DefaultSyslogFormatter, sy_sync::Syslog, LogFacility, LogStat, Priority, SyslogLocal, SyslogQueue};


    #[test]
    fn test_multithreading()
    {
        use std::sync::Arc;
        use std::thread;
        use std::time::{Instant, Duration};
        use crate::LOG_MASK;

        let log = 
            Syslog
                ::<SyslogLocal, DefaultSyslogFormatter, SyslogQueue<_>>
                ::openlog_with(
                Some("test1"), 
                LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID, 
                LogFacility::LOG_DAEMON, SyslogLocal::new()
            );

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = Arc::new(log.unwrap());
        let c1_log = log.clone();
        let c2_log = log.clone();

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(200));
                let now = Instant::now();
                c1_log.syslog(Priority::LOG_DEBUG, format!("a message from thread 1 #{}[]", i));
                let elapsed = now.elapsed();
                println!("t1: {:?}", elapsed);
            }
        });

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(201));
                let now = Instant::now();
                c2_log.syslog(Priority::LOG_DEBUG, format!("きるさお命泉ぶねりよ日子金れっ {}", i));
                let elapsed = now.elapsed();
                println!("t2: {:?}", elapsed);
            }
        });

        let res = log.setlogmask(!LOG_MASK!(Priority::LOG_ERR));

        assert_eq!(res.is_ok(), true, "{}", res.err().unwrap());
        assert_eq!(res.unwrap(), 0xff, "should be 0xff");

        let now = Instant::now();
        log.syslog(Priority::LOG_DEBUG, format!("A message from main, сообщение от главнюка"));
        let elapsed = now.elapsed();
        println!("main: {:?}", elapsed);

        thread::sleep(Duration::from_secs(2));

        let _ = log.closelog();

        thread::sleep(Duration::from_millis(500));

        let res = log.setlogmask(!LOG_MASK!(Priority::LOG_ERR));

        assert_eq!(res.is_ok(), true);

        return;
    }

    #[cfg(feature = "build_with_file")]
    #[test]
    fn test_file_multithreading()
    {
        use std::sync::Arc;
        use std::thread;
        use std::time::{Instant, Duration};
        use crate::formatters::DefaultSyslogFormatterFile;
        use crate::{SyslogFile, SyslogQueue, LOG_MASK};

        let log = 
            Syslog
                ::<SyslogFile, DefaultSyslogFormatterFile, SyslogQueue<_>>
                ::openlog_with(
                    Some("test2"), 
                    LogStat::LOG_CONS | LogStat::LOG_NDELAY | LogStat::LOG_PID, 
                    LogFacility::LOG_DAEMON, 
                    SyslogFile::new("/tmp/syslog_rs_test2.log")
                );
                    

        assert_eq!(log.is_ok(), true, "{}", log.err().unwrap());

        let log = Arc::new(log.unwrap());
        let c1_log = log.clone();
        let c2_log = log.clone();

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(200));
                let now = Instant::now();
                c1_log.syslog(Priority::LOG_ALERT, format!("a message from thread 1 #{}[]", i));
                let elapsed = now.elapsed();
                println!("t1: {:?}", elapsed);
            }
        });

        thread::spawn(move|| {
            for i in 0..5
            {
                thread::sleep(Duration::from_nanos(201));
                let now = Instant::now();
                c2_log.syslog(Priority::LOG_DEBUG, format!("きるさお命泉ぶねりよ日子金れっ {}", i));
                let elapsed = now.elapsed();
                println!("t2: {:?}", elapsed);
            }
        });

        let res = log.setlogmask(!LOG_MASK!(Priority::LOG_ERR));

        assert_eq!(res.is_ok(), true, "{}", res.err().unwrap());
        assert_eq!(res.unwrap(), 0xff, "should be 0xff");

        let now = Instant::now();
        log.syslog(Priority::LOG_DEBUG, format!("A message from main, きるさお命泉ぶねりよ日子金れっ"));
        let elapsed = now.elapsed();
        println!("main: {:?}", elapsed);

        thread::sleep(Duration::from_secs(2));

        let _ = log.closelog();

        thread::sleep(Duration::from_millis(500));

        let res = log.setlogmask(!LOG_MASK!(Priority::LOG_ERR));

        assert_eq!(res.is_ok(), true);

        return;
    }

}