1#![doc(
349 html_logo_url = "https://prev.rust-lang.org/logos/rust-logo-128x128-blk-v2.png",
350 html_favicon_url = "https://prev.rust-lang.org/favicon.ico",
351 html_root_url = "https://docs.rs/log/0.4.33"
352)]
353#![warn(missing_docs)]
354#![deny(missing_debug_implementations, unconditional_recursion)]
355#![cfg_attr(all(not(feature = "std"), not(test)), no_std)]
356
357#[cfg(any(
358 all(feature = "max_level_off", feature = "max_level_error"),
359 all(feature = "max_level_off", feature = "max_level_warn"),
360 all(feature = "max_level_off", feature = "max_level_info"),
361 all(feature = "max_level_off", feature = "max_level_debug"),
362 all(feature = "max_level_off", feature = "max_level_trace"),
363 all(feature = "max_level_error", feature = "max_level_warn"),
364 all(feature = "max_level_error", feature = "max_level_info"),
365 all(feature = "max_level_error", feature = "max_level_debug"),
366 all(feature = "max_level_error", feature = "max_level_trace"),
367 all(feature = "max_level_warn", feature = "max_level_info"),
368 all(feature = "max_level_warn", feature = "max_level_debug"),
369 all(feature = "max_level_warn", feature = "max_level_trace"),
370 all(feature = "max_level_info", feature = "max_level_debug"),
371 all(feature = "max_level_info", feature = "max_level_trace"),
372 all(feature = "max_level_debug", feature = "max_level_trace"),
373))]
374compile_error!("multiple max_level_* features set");
375
376#[rustfmt::skip]
377#[cfg(any(
378 all(feature = "release_max_level_off", feature = "release_max_level_error"),
379 all(feature = "release_max_level_off", feature = "release_max_level_warn"),
380 all(feature = "release_max_level_off", feature = "release_max_level_info"),
381 all(feature = "release_max_level_off", feature = "release_max_level_debug"),
382 all(feature = "release_max_level_off", feature = "release_max_level_trace"),
383 all(feature = "release_max_level_error", feature = "release_max_level_warn"),
384 all(feature = "release_max_level_error", feature = "release_max_level_info"),
385 all(feature = "release_max_level_error", feature = "release_max_level_debug"),
386 all(feature = "release_max_level_error", feature = "release_max_level_trace"),
387 all(feature = "release_max_level_warn", feature = "release_max_level_info"),
388 all(feature = "release_max_level_warn", feature = "release_max_level_debug"),
389 all(feature = "release_max_level_warn", feature = "release_max_level_trace"),
390 all(feature = "release_max_level_info", feature = "release_max_level_debug"),
391 all(feature = "release_max_level_info", feature = "release_max_level_trace"),
392 all(feature = "release_max_level_debug", feature = "release_max_level_trace"),
393))]
394compile_error!("multiple release_max_level_* features set");
395
396#[cfg(all(not(feature = "std"), not(test)))]
397extern crate core as std;
398
399use std::cfg;
400#[cfg(feature = "std")]
401use std::error;
402use std::str::FromStr;
403use std::{cmp, fmt, mem};
404
405#[macro_use]
406mod macros;
407mod serde;
408
409#[cfg(feature = "kv")]
410pub mod kv;
411
412#[cfg(target_has_atomic = "ptr")]
413use std::sync::atomic::{AtomicUsize, Ordering};
414
415#[cfg(not(target_has_atomic = "ptr"))]
416use std::cell::Cell;
417#[cfg(not(target_has_atomic = "ptr"))]
418use std::sync::atomic::Ordering;
419
420#[cfg(not(target_has_atomic = "ptr"))]
421struct AtomicUsize {
422 v: Cell<usize>,
423}
424
425#[cfg(not(target_has_atomic = "ptr"))]
426impl AtomicUsize {
427 const fn new(v: usize) -> AtomicUsize {
428 AtomicUsize { v: Cell::new(v) }
429 }
430
431 fn load(&self, _order: Ordering) -> usize {
432 self.v.get()
433 }
434
435 fn store(&self, val: usize, _order: Ordering) {
436 self.v.set(val)
437 }
438}
439
440#[cfg(not(target_has_atomic = "ptr"))]
443unsafe impl Sync for AtomicUsize {}
444
445static mut LOGGER: &dyn Log = &NopLogger;
448
449static STATE: AtomicUsize = AtomicUsize::new(0);
450
451const UNINITIALIZED: usize = 0;
455const INITIALIZING: usize = 1;
456const INITIALIZED: usize = 2;
457
458static MAX_LOG_LEVEL_FILTER: AtomicUsize = AtomicUsize::new(0);
459
460static LOG_LEVEL_NAMES: [&str; 6] = ["OFF", "ERROR", "WARN", "INFO", "DEBUG", "TRACE"];
461
462static SET_LOGGER_ERROR: &str = "attempted to set a logger after the logging system \
463 was already initialized";
464static LEVEL_PARSE_ERROR: &str =
465 "attempted to convert a string that doesn't match an existing log level";
466
467#[repr(usize)]
474#[derive(#[automatically_derived]
impl ::core::clone::Clone for Level {
#[inline]
fn clone(&self) -> Level { *self }
}Clone, #[automatically_derived]
impl ::core::marker::Copy for Level { }Copy, #[automatically_derived]
impl ::core::cmp::PartialEq for Level {
#[inline]
fn eq(&self, other: &Level) -> bool {
let __self_discr = ::core::intrinsics::discriminant_value(self);
let __arg1_discr = ::core::intrinsics::discriminant_value(other);
__self_discr == __arg1_discr
}
}PartialEq, #[automatically_derived]
impl ::core::cmp::Eq for Level {
#[inline]
#[doc(hidden)]
#[coverage(off)]
fn assert_fields_are_eq(&self) {}
}Eq, #[automatically_derived]
impl ::core::cmp::PartialOrd for Level {
#[inline]
fn partial_cmp(&self, other: &Level)
-> ::core::option::Option<::core::cmp::Ordering> {
::core::option::Option::Some(::core::cmp::Ord::cmp(self, other))
}
}PartialOrd, #[automatically_derived]
impl ::core::cmp::Ord for Level {
#[inline]
fn cmp(&self, other: &Level) -> ::core::cmp::Ordering {
let __self_discr = ::core::intrinsics::discriminant_value(self);
let __arg1_discr = ::core::intrinsics::discriminant_value(other);
::core::cmp::Ord::cmp(&__self_discr, &__arg1_discr)
}
}Ord, #[automatically_derived]
impl ::core::fmt::Debug for Level {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::write_str(f,
match self {
Level::Error => "Error",
Level::Warn => "Warn",
Level::Info => "Info",
Level::Debug => "Debug",
Level::Trace => "Trace",
})
}
}Debug, #[automatically_derived]
impl ::core::hash::Hash for Level {
#[inline]
fn hash<__H: ::core::hash::Hasher>(&self, state: &mut __H) {
let __self_discr = ::core::intrinsics::discriminant_value(self);
::core::hash::Hash::hash(&__self_discr, state)
}
}Hash)]
475pub enum Level {
476 Error = 1,
483 Warn,
487 Info,
491 Debug,
495 Trace,
499}
500
501impl PartialEq<LevelFilter> for Level {
502 #[inline]
503 fn eq(&self, other: &LevelFilter) -> bool {
504 *self as usize == *other as usize
505 }
506}
507
508impl PartialOrd<LevelFilter> for Level {
509 #[inline]
510 fn partial_cmp(&self, other: &LevelFilter) -> Option<cmp::Ordering> {
511 Some((*self as usize).cmp(&(*other as usize)))
512 }
513}
514
515impl FromStr for Level {
516 type Err = ParseLevelError;
517 fn from_str(level: &str) -> Result<Level, Self::Err> {
518 for idx in 1..LOG_LEVEL_NAMES.len() {
520 if LOG_LEVEL_NAMES[idx].eq_ignore_ascii_case(level) {
521 return Ok(Level::from_usize(idx).unwrap());
522 }
523 }
524 Err(ParseLevelError(()))
525 }
526}
527
528impl fmt::Display for Level {
529 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
530 fmt.pad(self.as_str())
531 }
532}
533
534impl Level {
535 fn from_usize(u: usize) -> Option<Level> {
536 match u {
537 1 => Some(Level::Error),
538 2 => Some(Level::Warn),
539 3 => Some(Level::Info),
540 4 => Some(Level::Debug),
541 5 => Some(Level::Trace),
542 _ => None,
543 }
544 }
545
546 #[inline]
548 pub fn max() -> Level {
549 Level::Trace
550 }
551
552 #[inline]
554 pub fn to_level_filter(&self) -> LevelFilter {
555 LevelFilter::from_usize(*self as usize).unwrap()
556 }
557
558 pub fn as_str(&self) -> &'static str {
562 LOG_LEVEL_NAMES[*self as usize]
563 }
564
565 pub fn iter() -> impl Iterator<Item = Self> {
580 (1..6).map(|i| Self::from_usize(i).unwrap())
581 }
582
583 pub fn increment_severity(&self) -> Self {
600 let current = *self as usize;
601 Self::from_usize(current + 1).unwrap_or(*self)
602 }
603
604 pub fn decrement_severity(&self) -> Self {
621 let current = *self as usize;
622 Self::from_usize(current.saturating_sub(1)).unwrap_or(*self)
623 }
624}
625
626#[repr(usize)]
635#[derive(#[automatically_derived]
impl ::core::clone::Clone for LevelFilter {
#[inline]
fn clone(&self) -> LevelFilter { *self }
}Clone, #[automatically_derived]
impl ::core::marker::Copy for LevelFilter { }Copy, #[automatically_derived]
impl ::core::cmp::PartialEq for LevelFilter {
#[inline]
fn eq(&self, other: &LevelFilter) -> bool {
let __self_discr = ::core::intrinsics::discriminant_value(self);
let __arg1_discr = ::core::intrinsics::discriminant_value(other);
__self_discr == __arg1_discr
}
}PartialEq, #[automatically_derived]
impl ::core::cmp::Eq for LevelFilter {
#[inline]
#[doc(hidden)]
#[coverage(off)]
fn assert_fields_are_eq(&self) {}
}Eq, #[automatically_derived]
impl ::core::cmp::PartialOrd for LevelFilter {
#[inline]
fn partial_cmp(&self, other: &LevelFilter)
-> ::core::option::Option<::core::cmp::Ordering> {
::core::option::Option::Some(::core::cmp::Ord::cmp(self, other))
}
}PartialOrd, #[automatically_derived]
impl ::core::cmp::Ord for LevelFilter {
#[inline]
fn cmp(&self, other: &LevelFilter) -> ::core::cmp::Ordering {
let __self_discr = ::core::intrinsics::discriminant_value(self);
let __arg1_discr = ::core::intrinsics::discriminant_value(other);
::core::cmp::Ord::cmp(&__self_discr, &__arg1_discr)
}
}Ord, #[automatically_derived]
impl ::core::fmt::Debug for LevelFilter {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::write_str(f,
match self {
LevelFilter::Off => "Off",
LevelFilter::Error => "Error",
LevelFilter::Warn => "Warn",
LevelFilter::Info => "Info",
LevelFilter::Debug => "Debug",
LevelFilter::Trace => "Trace",
})
}
}Debug, #[automatically_derived]
impl ::core::hash::Hash for LevelFilter {
#[inline]
fn hash<__H: ::core::hash::Hasher>(&self, state: &mut __H) {
let __self_discr = ::core::intrinsics::discriminant_value(self);
::core::hash::Hash::hash(&__self_discr, state)
}
}Hash)]
636pub enum LevelFilter {
637 Off,
639 Error,
641 Warn,
643 Info,
645 Debug,
647 Trace,
649}
650
651impl PartialEq<Level> for LevelFilter {
652 #[inline]
653 fn eq(&self, other: &Level) -> bool {
654 other.eq(self)
655 }
656}
657
658impl PartialOrd<Level> for LevelFilter {
659 #[inline]
660 fn partial_cmp(&self, other: &Level) -> Option<cmp::Ordering> {
661 Some((*self as usize).cmp(&(*other as usize)))
662 }
663}
664
665impl FromStr for LevelFilter {
666 type Err = ParseLevelError;
667 fn from_str(level: &str) -> Result<LevelFilter, Self::Err> {
668 for idx in 0..LOG_LEVEL_NAMES.len() {
670 if LOG_LEVEL_NAMES[idx].eq_ignore_ascii_case(level) {
671 return Ok(LevelFilter::from_usize(idx).unwrap());
672 }
673 }
674 Err(ParseLevelError(()))
675 }
676}
677
678impl fmt::Display for LevelFilter {
679 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
680 fmt.pad(self.as_str())
681 }
682}
683
684impl LevelFilter {
685 fn from_usize(u: usize) -> Option<LevelFilter> {
686 match u {
687 0 => Some(LevelFilter::Off),
688 1 => Some(LevelFilter::Error),
689 2 => Some(LevelFilter::Warn),
690 3 => Some(LevelFilter::Info),
691 4 => Some(LevelFilter::Debug),
692 5 => Some(LevelFilter::Trace),
693 _ => None,
694 }
695 }
696
697 #[inline]
699 pub fn max() -> LevelFilter {
700 LevelFilter::Trace
701 }
702
703 #[inline]
707 pub fn to_level(&self) -> Option<Level> {
708 Level::from_usize(*self as usize)
709 }
710
711 pub fn as_str(&self) -> &'static str {
715 LOG_LEVEL_NAMES[*self as usize]
716 }
717
718 pub fn iter() -> impl Iterator<Item = Self> {
733 (0..6).map(|i| Self::from_usize(i).unwrap())
734 }
735
736 pub fn increment_severity(&self) -> Self {
753 let current = *self as usize;
754 Self::from_usize(current + 1).unwrap_or(*self)
755 }
756
757 pub fn decrement_severity(&self) -> Self {
775 let current = *self as usize;
776 Self::from_usize(current.saturating_sub(1)).unwrap_or(*self)
777 }
778}
779
780#[derive(#[automatically_derived]
impl<'a> ::core::marker::Copy for MaybeStaticStr<'a> { }Copy, #[automatically_derived]
impl<'a> ::core::clone::Clone for MaybeStaticStr<'a> {
#[inline]
fn clone(&self) -> MaybeStaticStr<'a> {
let _: ::core::clone::AssertParamIsClone<&'static str>;
let _: ::core::clone::AssertParamIsClone<&'a str>;
*self
}
}Clone, #[automatically_derived]
impl<'a> ::core::fmt::Debug for MaybeStaticStr<'a> {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
match self {
MaybeStaticStr::Static(__self_0) =>
::core::fmt::Formatter::debug_tuple_field1_finish(f, "Static",
&__self_0),
MaybeStaticStr::Borrowed(__self_0) =>
::core::fmt::Formatter::debug_tuple_field1_finish(f,
"Borrowed", &__self_0),
}
}
}Debug)]
781enum MaybeStaticStr<'a> {
782 Static(&'static str),
783 Borrowed(&'a str),
784}
785
786impl<'a> MaybeStaticStr<'a> {
787 #[inline]
788 fn get(&self) -> &'a str {
789 match *self {
790 MaybeStaticStr::Static(s) => s,
791 MaybeStaticStr::Borrowed(s) => s,
792 }
793 }
794}
795
796impl Eq for MaybeStaticStr<'_> {}
797
798impl PartialEq for MaybeStaticStr<'_> {
799 fn eq(&self, other: &Self) -> bool {
800 self.get() == other.get()
801 }
802}
803
804impl Ord for MaybeStaticStr<'_> {
805 fn cmp(&self, other: &Self) -> core::cmp::Ordering {
806 self.get().cmp(other.get())
807 }
808}
809
810impl PartialOrd for MaybeStaticStr<'_> {
811 fn partial_cmp(&self, other: &Self) -> Option<core::cmp::Ordering> {
812 Some(self.cmp(other))
813 }
814}
815
816impl std::hash::Hash for MaybeStaticStr<'_> {
817 fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
818 self.get().hash(state);
819 }
820}
821
822#[derive(#[automatically_derived]
impl<'a> ::core::clone::Clone for Record<'a> {
#[inline]
fn clone(&self) -> Record<'a> {
Record {
metadata: ::core::clone::Clone::clone(&self.metadata),
args: ::core::clone::Clone::clone(&self.args),
module_path: ::core::clone::Clone::clone(&self.module_path),
file: ::core::clone::Clone::clone(&self.file),
line: ::core::clone::Clone::clone(&self.line),
}
}
}Clone, #[automatically_derived]
impl<'a> ::core::fmt::Debug for Record<'a> {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_struct_field5_finish(f, "Record",
"metadata", &self.metadata, "args", &self.args, "module_path",
&self.module_path, "file", &self.file, "line", &&self.line)
}
}Debug)]
868pub struct Record<'a> {
869 metadata: Metadata<'a>,
870 args: fmt::Arguments<'a>,
871 module_path: Option<MaybeStaticStr<'a>>,
872 file: Option<MaybeStaticStr<'a>>,
873 line: Option<u32>,
874 #[cfg(feature = "kv")]
875 key_values: KeyValues<'a>,
876}
877
878#[cfg(feature = "kv")]
883#[derive(Clone)]
884struct KeyValues<'a>(&'a dyn kv::Source);
885
886#[cfg(feature = "kv")]
887impl<'a> fmt::Debug for KeyValues<'a> {
888 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
889 let mut visitor = f.debug_map();
890 self.0.visit(&mut visitor).map_err(|_| fmt::Error)?;
891 visitor.finish()
892 }
893}
894
895impl<'a> Record<'a> {
896 #[inline]
898 pub fn builder() -> RecordBuilder<'a> {
899 RecordBuilder::new()
900 }
901
902 #[inline]
904 pub fn args(&self) -> &fmt::Arguments<'a> {
905 &self.args
906 }
907
908 #[inline]
910 pub fn metadata(&self) -> &Metadata<'a> {
911 &self.metadata
912 }
913
914 #[inline]
916 pub fn level(&self) -> Level {
917 self.metadata.level()
918 }
919
920 #[inline]
922 pub fn target(&self) -> &'a str {
923 self.metadata.target()
924 }
925
926 #[inline]
928 pub fn module_path(&self) -> Option<&'a str> {
929 self.module_path.map(|s| s.get())
930 }
931
932 #[inline]
934 pub fn module_path_static(&self) -> Option<&'static str> {
935 match self.module_path {
936 Some(MaybeStaticStr::Static(s)) => Some(s),
937 _ => None,
938 }
939 }
940
941 #[inline]
943 pub fn file(&self) -> Option<&'a str> {
944 self.file.map(|s| s.get())
945 }
946
947 #[inline]
949 pub fn file_static(&self) -> Option<&'static str> {
950 match self.file {
951 Some(MaybeStaticStr::Static(s)) => Some(s),
952 _ => None,
953 }
954 }
955
956 #[inline]
958 pub fn line(&self) -> Option<u32> {
959 self.line
960 }
961
962 #[cfg(feature = "kv")]
964 #[inline]
965 pub fn key_values(&self) -> &dyn kv::Source {
966 self.key_values.0
967 }
968
969 #[cfg(feature = "kv")]
971 #[inline]
972 pub fn to_builder(&self) -> RecordBuilder<'_> {
973 RecordBuilder {
974 record: Record {
975 metadata: Metadata {
976 level: self.metadata.level,
977 target: self.metadata.target,
978 },
979 args: self.args,
980 module_path: self.module_path,
981 file: self.file,
982 line: self.line,
983 key_values: self.key_values.clone(),
984 },
985 }
986 }
987}
988
989#[derive(#[automatically_derived]
impl<'a> ::core::fmt::Debug for RecordBuilder<'a> {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_struct_field1_finish(f, "RecordBuilder",
"record", &&self.record)
}
}Debug)]
1029pub struct RecordBuilder<'a> {
1030 record: Record<'a>,
1031}
1032
1033impl<'a> RecordBuilder<'a> {
1034 #[inline]
1047 pub fn new() -> RecordBuilder<'a> {
1048 RecordBuilder {
1049 record: Record {
1050 args: format_args!("")format_args!(""),
1051 metadata: Metadata::builder().build(),
1052 module_path: None,
1053 file: None,
1054 line: None,
1055 #[cfg(feature = "kv")]
1056 key_values: KeyValues(&None::<(kv::Key, kv::Value)>),
1057 },
1058 }
1059 }
1060
1061 #[inline]
1063 pub fn args(&mut self, args: fmt::Arguments<'a>) -> &mut RecordBuilder<'a> {
1064 self.record.args = args;
1065 self
1066 }
1067
1068 #[inline]
1070 pub fn metadata(&mut self, metadata: Metadata<'a>) -> &mut RecordBuilder<'a> {
1071 self.record.metadata = metadata;
1072 self
1073 }
1074
1075 #[inline]
1077 pub fn level(&mut self, level: Level) -> &mut RecordBuilder<'a> {
1078 self.record.metadata.level = level;
1079 self
1080 }
1081
1082 #[inline]
1084 pub fn target(&mut self, target: &'a str) -> &mut RecordBuilder<'a> {
1085 self.record.metadata.target = target;
1086 self
1087 }
1088
1089 #[inline]
1091 pub fn module_path(&mut self, path: Option<&'a str>) -> &mut RecordBuilder<'a> {
1092 self.record.module_path = path.map(MaybeStaticStr::Borrowed);
1093 self
1094 }
1095
1096 #[inline]
1098 pub fn module_path_static(&mut self, path: Option<&'static str>) -> &mut RecordBuilder<'a> {
1099 self.record.module_path = path.map(MaybeStaticStr::Static);
1100 self
1101 }
1102
1103 #[inline]
1105 pub fn file(&mut self, file: Option<&'a str>) -> &mut RecordBuilder<'a> {
1106 self.record.file = file.map(MaybeStaticStr::Borrowed);
1107 self
1108 }
1109
1110 #[inline]
1112 pub fn file_static(&mut self, file: Option<&'static str>) -> &mut RecordBuilder<'a> {
1113 self.record.file = file.map(MaybeStaticStr::Static);
1114 self
1115 }
1116
1117 #[inline]
1119 pub fn line(&mut self, line: Option<u32>) -> &mut RecordBuilder<'a> {
1120 self.record.line = line;
1121 self
1122 }
1123
1124 #[cfg(feature = "kv")]
1126 #[inline]
1127 pub fn key_values(&mut self, kvs: &'a dyn kv::Source) -> &mut RecordBuilder<'a> {
1128 self.record.key_values = KeyValues(kvs);
1129 self
1130 }
1131
1132 #[inline]
1134 pub fn build(&self) -> Record<'a> {
1135 self.record.clone()
1136 }
1137}
1138
1139impl Default for RecordBuilder<'_> {
1140 fn default() -> Self {
1141 Self::new()
1142 }
1143}
1144
1145#[derive(#[automatically_derived]
impl<'a> ::core::clone::Clone for Metadata<'a> {
#[inline]
fn clone(&self) -> Metadata<'a> {
Metadata {
level: ::core::clone::Clone::clone(&self.level),
target: ::core::clone::Clone::clone(&self.target),
}
}
}Clone, #[automatically_derived]
impl<'a> ::core::cmp::Eq for Metadata<'a> {
#[inline]
#[doc(hidden)]
#[coverage(off)]
fn assert_fields_are_eq(&self) {
let _: ::core::cmp::AssertParamIsEq<Level>;
let _: ::core::cmp::AssertParamIsEq<&'a str>;
}
}Eq, #[automatically_derived]
impl<'a> ::core::cmp::PartialEq for Metadata<'a> {
#[inline]
fn eq(&self, other: &Metadata<'a>) -> bool {
self.level == other.level && self.target == other.target
}
}PartialEq, #[automatically_derived]
impl<'a> ::core::cmp::Ord for Metadata<'a> {
#[inline]
fn cmp(&self, other: &Metadata<'a>) -> ::core::cmp::Ordering {
match ::core::cmp::Ord::cmp(&self.level, &other.level) {
::core::cmp::Ordering::Equal =>
::core::cmp::Ord::cmp(&self.target, &other.target),
cmp => cmp,
}
}
}Ord, #[automatically_derived]
impl<'a> ::core::cmp::PartialOrd for Metadata<'a> {
#[inline]
fn partial_cmp(&self, other: &Metadata<'a>)
-> ::core::option::Option<::core::cmp::Ordering> {
::core::option::Option::Some(::core::cmp::Ord::cmp(self, other))
}
}PartialOrd, #[automatically_derived]
impl<'a> ::core::hash::Hash for Metadata<'a> {
#[inline]
fn hash<__H: ::core::hash::Hasher>(&self, state: &mut __H) {
::core::hash::Hash::hash(&self.level, state);
::core::hash::Hash::hash(&self.target, state)
}
}Hash, #[automatically_derived]
impl<'a> ::core::fmt::Debug for Metadata<'a> {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_struct_field2_finish(f, "Metadata",
"level", &self.level, "target", &&self.target)
}
}Debug)]
1184pub struct Metadata<'a> {
1185 level: Level,
1186 target: &'a str,
1187}
1188
1189impl<'a> Metadata<'a> {
1190 #[inline]
1192 pub fn builder() -> MetadataBuilder<'a> {
1193 MetadataBuilder::new()
1194 }
1195
1196 #[inline]
1198 pub fn level(&self) -> Level {
1199 self.level
1200 }
1201
1202 #[inline]
1204 pub fn target(&self) -> &'a str {
1205 self.target
1206 }
1207}
1208
1209#[derive(#[automatically_derived]
impl<'a> ::core::cmp::Eq for MetadataBuilder<'a> {
#[inline]
#[doc(hidden)]
#[coverage(off)]
fn assert_fields_are_eq(&self) {
let _: ::core::cmp::AssertParamIsEq<Metadata<'a>>;
}
}Eq, #[automatically_derived]
impl<'a> ::core::cmp::PartialEq for MetadataBuilder<'a> {
#[inline]
fn eq(&self, other: &MetadataBuilder<'a>) -> bool {
self.metadata == other.metadata
}
}PartialEq, #[automatically_derived]
impl<'a> ::core::cmp::Ord for MetadataBuilder<'a> {
#[inline]
fn cmp(&self, other: &MetadataBuilder<'a>) -> ::core::cmp::Ordering {
::core::cmp::Ord::cmp(&self.metadata, &other.metadata)
}
}Ord, #[automatically_derived]
impl<'a> ::core::cmp::PartialOrd for MetadataBuilder<'a> {
#[inline]
fn partial_cmp(&self, other: &MetadataBuilder<'a>)
-> ::core::option::Option<::core::cmp::Ordering> {
::core::option::Option::Some(::core::cmp::Ord::cmp(self, other))
}
}PartialOrd, #[automatically_derived]
impl<'a> ::core::hash::Hash for MetadataBuilder<'a> {
#[inline]
fn hash<__H: ::core::hash::Hasher>(&self, state: &mut __H) {
::core::hash::Hash::hash(&self.metadata, state)
}
}Hash, #[automatically_derived]
impl<'a> ::core::fmt::Debug for MetadataBuilder<'a> {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_struct_field1_finish(f,
"MetadataBuilder", "metadata", &&self.metadata)
}
}Debug)]
1226pub struct MetadataBuilder<'a> {
1227 metadata: Metadata<'a>,
1228}
1229
1230impl<'a> MetadataBuilder<'a> {
1231 #[inline]
1238 pub fn new() -> MetadataBuilder<'a> {
1239 MetadataBuilder {
1240 metadata: Metadata {
1241 level: Level::Info,
1242 target: "",
1243 },
1244 }
1245 }
1246
1247 #[inline]
1249 pub fn level(&mut self, arg: Level) -> &mut MetadataBuilder<'a> {
1250 self.metadata.level = arg;
1251 self
1252 }
1253
1254 #[inline]
1256 pub fn target(&mut self, target: &'a str) -> &mut MetadataBuilder<'a> {
1257 self.metadata.target = target;
1258 self
1259 }
1260
1261 #[inline]
1263 pub fn build(&self) -> Metadata<'a> {
1264 self.metadata.clone()
1265 }
1266}
1267
1268impl Default for MetadataBuilder<'_> {
1269 fn default() -> Self {
1270 Self::new()
1271 }
1272}
1273
1274pub trait Log: Sync + Send {
1276 fn enabled(&self, metadata: &Metadata) -> bool;
1289
1290 fn log(&self, record: &Record);
1298
1299 fn flush(&self);
1306}
1307
1308struct NopLogger;
1310
1311impl Log for NopLogger {
1312 fn enabled(&self, _: &Metadata) -> bool {
1313 false
1314 }
1315
1316 fn log(&self, _: &Record) {}
1317 fn flush(&self) {}
1318}
1319
1320impl<T> Log for &'_ T
1321where
1322 T: ?Sized + Log,
1323{
1324 fn enabled(&self, metadata: &Metadata) -> bool {
1325 (**self).enabled(metadata)
1326 }
1327
1328 fn log(&self, record: &Record) {
1329 (**self).log(record);
1330 }
1331 fn flush(&self) {
1332 (**self).flush();
1333 }
1334}
1335
1336#[cfg(feature = "std")]
1337impl<T> Log for std::boxed::Box<T>
1338where
1339 T: ?Sized + Log,
1340{
1341 fn enabled(&self, metadata: &Metadata) -> bool {
1342 self.as_ref().enabled(metadata)
1343 }
1344
1345 fn log(&self, record: &Record) {
1346 self.as_ref().log(record);
1347 }
1348 fn flush(&self) {
1349 self.as_ref().flush();
1350 }
1351}
1352
1353#[cfg(feature = "std")]
1354impl<T> Log for std::sync::Arc<T>
1355where
1356 T: ?Sized + Log,
1357{
1358 fn enabled(&self, metadata: &Metadata) -> bool {
1359 self.as_ref().enabled(metadata)
1360 }
1361
1362 fn log(&self, record: &Record) {
1363 self.as_ref().log(record);
1364 }
1365 fn flush(&self) {
1366 self.as_ref().flush();
1367 }
1368}
1369
1370#[inline]
1376#[cfg(target_has_atomic = "ptr")]
1377pub fn set_max_level(level: LevelFilter) {
1378 MAX_LOG_LEVEL_FILTER.store(level as usize, Ordering::Relaxed);
1379}
1380
1381#[inline]
1401pub unsafe fn set_max_level_racy(level: LevelFilter) {
1402 MAX_LOG_LEVEL_FILTER.store(level as usize, Ordering::Relaxed);
1406}
1407
1408#[inline(always)]
1422pub fn max_level() -> LevelFilter {
1423 unsafe { mem::transmute(MAX_LOG_LEVEL_FILTER.load(Ordering::Relaxed)) }
1430}
1431
1432#[cfg(all(feature = "std", target_has_atomic = "ptr"))]
1446pub fn set_boxed_logger(logger: Box<dyn Log>) -> Result<(), SetLoggerError> {
1447 set_logger_inner(|| Box::leak(logger))
1448}
1449
1450#[cfg(target_has_atomic = "ptr")]
1504pub fn set_logger(logger: &'static dyn Log) -> Result<(), SetLoggerError> {
1505 set_logger_inner(|| logger)
1506}
1507
1508#[cfg(target_has_atomic = "ptr")]
1509fn set_logger_inner<F>(make_logger: F) -> Result<(), SetLoggerError>
1510where
1511 F: FnOnce() -> &'static dyn Log,
1512{
1513 match STATE.compare_exchange(
1514 UNINITIALIZED,
1515 INITIALIZING,
1516 Ordering::Acquire,
1517 Ordering::Relaxed,
1518 ) {
1519 Ok(UNINITIALIZED) => {
1520 unsafe {
1521 LOGGER = make_logger();
1522 }
1523 STATE.store(INITIALIZED, Ordering::Release);
1524 Ok(())
1525 }
1526 Err(INITIALIZING) => {
1527 while STATE.load(Ordering::Relaxed) == INITIALIZING {
1528 std::hint::spin_loop();
1529 }
1530 Err(SetLoggerError(()))
1531 }
1532 _ => Err(SetLoggerError(())),
1533 }
1534}
1535
1536pub unsafe fn set_logger_racy(logger: &'static dyn Log) -> Result<(), SetLoggerError> {
1556 match STATE.load(Ordering::Acquire) {
1557 UNINITIALIZED => {
1558 LOGGER = logger;
1559 STATE.store(INITIALIZED, Ordering::Release);
1560 Ok(())
1561 }
1562 INITIALIZING => {
1563 {
::core::panicking::panic_fmt(format_args!("internal error: entered unreachable code: {0}",
format_args!("set_logger_racy must not be used with other initialization functions")));
}unreachable!("set_logger_racy must not be used with other initialization functions")
1565 }
1566 _ => Err(SetLoggerError(())),
1567 }
1568}
1569
1570#[allow(missing_copy_implementations)]
1574#[derive(#[automatically_derived]
#[allow(missing_copy_implementations)]
impl ::core::fmt::Debug for SetLoggerError {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_tuple_field1_finish(f, "SetLoggerError",
&&self.0)
}
}Debug)]
1575pub struct SetLoggerError(());
1576
1577impl fmt::Display for SetLoggerError {
1578 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
1579 fmt.write_str(SET_LOGGER_ERROR)
1580 }
1581}
1582
1583#[cfg(feature = "std")]
1585impl error::Error for SetLoggerError {}
1586
1587#[allow(missing_copy_implementations)]
1591#[derive(#[automatically_derived]
#[allow(missing_copy_implementations)]
impl ::core::fmt::Debug for ParseLevelError {
#[inline]
fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
::core::fmt::Formatter::debug_tuple_field1_finish(f,
"ParseLevelError", &&self.0)
}
}Debug, #[automatically_derived]
#[allow(missing_copy_implementations)]
impl ::core::cmp::PartialEq for ParseLevelError {
#[inline]
fn eq(&self, other: &ParseLevelError) -> bool { self.0 == other.0 }
}PartialEq, #[automatically_derived]
#[allow(missing_copy_implementations)]
impl ::core::cmp::Eq for ParseLevelError {
#[inline]
#[doc(hidden)]
#[coverage(off)]
fn assert_fields_are_eq(&self) {
let _: ::core::cmp::AssertParamIsEq<()>;
}
}Eq)]
1592pub struct ParseLevelError(());
1593
1594impl fmt::Display for ParseLevelError {
1595 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
1596 fmt.write_str(LEVEL_PARSE_ERROR)
1597 }
1598}
1599
1600#[cfg(feature = "std")]
1602impl error::Error for ParseLevelError {}
1603
1604pub fn logger() -> &'static dyn Log {
1608 if STATE.load(Ordering::Acquire) != INITIALIZED {
1617 static NOP: NopLogger = NopLogger;
1618 &NOP
1619 } else {
1620 unsafe { LOGGER }
1621 }
1622}
1623
1624#[doc(hidden)]
1626pub mod __private_api;
1627
1628pub const STATIC_MAX_LEVEL: LevelFilter = match truecfg!(debug_assertions) {
1638 false if falsecfg!(feature = "release_max_level_off") => LevelFilter::Off,
1639 false if falsecfg!(feature = "release_max_level_error") => LevelFilter::Error,
1640 false if falsecfg!(feature = "release_max_level_warn") => LevelFilter::Warn,
1641 false if falsecfg!(feature = "release_max_level_info") => LevelFilter::Info,
1642 false if falsecfg!(feature = "release_max_level_debug") => LevelFilter::Debug,
1643 false if falsecfg!(feature = "release_max_level_trace") => LevelFilter::Trace,
1644 _ if falsecfg!(feature = "max_level_off") => LevelFilter::Off,
1645 _ if falsecfg!(feature = "max_level_error") => LevelFilter::Error,
1646 _ if falsecfg!(feature = "max_level_warn") => LevelFilter::Warn,
1647 _ if falsecfg!(feature = "max_level_info") => LevelFilter::Info,
1648 _ if falsecfg!(feature = "max_level_debug") => LevelFilter::Debug,
1649 _ => LevelFilter::Trace,
1650};
1651
1652#[cfg(test)]
1653mod tests {
1654 use super::{Level, LevelFilter, ParseLevelError, STATIC_MAX_LEVEL};
1655
1656 #[test]
1657 fn test_levelfilter_from_str() {
1658 let tests = [
1659 ("off", Ok(LevelFilter::Off)),
1660 ("error", Ok(LevelFilter::Error)),
1661 ("warn", Ok(LevelFilter::Warn)),
1662 ("info", Ok(LevelFilter::Info)),
1663 ("debug", Ok(LevelFilter::Debug)),
1664 ("trace", Ok(LevelFilter::Trace)),
1665 ("OFF", Ok(LevelFilter::Off)),
1666 ("ERROR", Ok(LevelFilter::Error)),
1667 ("WARN", Ok(LevelFilter::Warn)),
1668 ("INFO", Ok(LevelFilter::Info)),
1669 ("DEBUG", Ok(LevelFilter::Debug)),
1670 ("TRACE", Ok(LevelFilter::Trace)),
1671 ("asdf", Err(ParseLevelError(()))),
1672 ];
1673 for &(s, ref expected) in &tests {
1674 assert_eq!(expected, &s.parse());
1675 }
1676 }
1677
1678 #[test]
1679 fn test_level_from_str() {
1680 let tests = [
1681 ("OFF", Err(ParseLevelError(()))),
1682 ("error", Ok(Level::Error)),
1683 ("warn", Ok(Level::Warn)),
1684 ("info", Ok(Level::Info)),
1685 ("debug", Ok(Level::Debug)),
1686 ("trace", Ok(Level::Trace)),
1687 ("ERROR", Ok(Level::Error)),
1688 ("WARN", Ok(Level::Warn)),
1689 ("INFO", Ok(Level::Info)),
1690 ("DEBUG", Ok(Level::Debug)),
1691 ("TRACE", Ok(Level::Trace)),
1692 ("asdf", Err(ParseLevelError(()))),
1693 ];
1694 for &(s, ref expected) in &tests {
1695 assert_eq!(expected, &s.parse());
1696 }
1697 }
1698
1699 #[test]
1700 fn test_level_as_str() {
1701 let tests = &[
1702 (Level::Error, "ERROR"),
1703 (Level::Warn, "WARN"),
1704 (Level::Info, "INFO"),
1705 (Level::Debug, "DEBUG"),
1706 (Level::Trace, "TRACE"),
1707 ];
1708 for (input, expected) in tests {
1709 assert_eq!(*expected, input.as_str());
1710 }
1711 }
1712
1713 #[test]
1714 fn test_level_show() {
1715 assert_eq!("INFO", Level::Info.to_string());
1716 assert_eq!("ERROR", Level::Error.to_string());
1717 }
1718
1719 #[test]
1720 fn test_levelfilter_show() {
1721 assert_eq!("OFF", LevelFilter::Off.to_string());
1722 assert_eq!("ERROR", LevelFilter::Error.to_string());
1723 }
1724
1725 #[test]
1726 fn test_cross_cmp() {
1727 assert!(Level::Debug > LevelFilter::Error);
1728 assert!(LevelFilter::Warn < Level::Trace);
1729 assert!(LevelFilter::Off < Level::Error);
1730 }
1731
1732 #[test]
1733 fn test_cross_eq() {
1734 assert!(Level::Error == LevelFilter::Error);
1735 assert!(LevelFilter::Off != Level::Error);
1736 assert!(Level::Trace == LevelFilter::Trace);
1737 }
1738
1739 #[test]
1740 fn test_to_level() {
1741 assert_eq!(Some(Level::Error), LevelFilter::Error.to_level());
1742 assert_eq!(None, LevelFilter::Off.to_level());
1743 assert_eq!(Some(Level::Debug), LevelFilter::Debug.to_level());
1744 }
1745
1746 #[test]
1747 fn test_to_level_filter() {
1748 assert_eq!(LevelFilter::Error, Level::Error.to_level_filter());
1749 assert_eq!(LevelFilter::Trace, Level::Trace.to_level_filter());
1750 }
1751
1752 #[test]
1753 fn test_level_filter_as_str() {
1754 let tests = &[
1755 (LevelFilter::Off, "OFF"),
1756 (LevelFilter::Error, "ERROR"),
1757 (LevelFilter::Warn, "WARN"),
1758 (LevelFilter::Info, "INFO"),
1759 (LevelFilter::Debug, "DEBUG"),
1760 (LevelFilter::Trace, "TRACE"),
1761 ];
1762 for (input, expected) in tests {
1763 assert_eq!(*expected, input.as_str());
1764 }
1765 }
1766
1767 #[test]
1768 fn test_level_up() {
1769 let info = Level::Info;
1770 let up = info.increment_severity();
1771 assert_eq!(up, Level::Debug);
1772
1773 let trace = Level::Trace;
1774 let up = trace.increment_severity();
1775 assert_eq!(up, trace);
1777 }
1778
1779 #[test]
1780 fn test_level_filter_up() {
1781 let info = LevelFilter::Info;
1782 let up = info.increment_severity();
1783 assert_eq!(up, LevelFilter::Debug);
1784
1785 let trace = LevelFilter::Trace;
1786 let up = trace.increment_severity();
1787 assert_eq!(up, trace);
1789 }
1790
1791 #[test]
1792 fn test_level_down() {
1793 let info = Level::Info;
1794 let down = info.decrement_severity();
1795 assert_eq!(down, Level::Warn);
1796
1797 let error = Level::Error;
1798 let down = error.decrement_severity();
1799 assert_eq!(down, error);
1801 }
1802
1803 #[test]
1804 fn test_level_filter_down() {
1805 let info = LevelFilter::Info;
1806 let down = info.decrement_severity();
1807 assert_eq!(down, LevelFilter::Warn);
1808
1809 let error = LevelFilter::Error;
1810 let down = error.decrement_severity();
1811 assert_eq!(down, LevelFilter::Off);
1812 assert_eq!(down.decrement_severity(), down);
1814 }
1815
1816 #[test]
1817 #[cfg_attr(not(debug_assertions), ignore)]
1818 fn test_static_max_level_debug() {
1819 if cfg!(feature = "max_level_off") {
1820 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Off);
1821 } else if cfg!(feature = "max_level_error") {
1822 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Error);
1823 } else if cfg!(feature = "max_level_warn") {
1824 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Warn);
1825 } else if cfg!(feature = "max_level_info") {
1826 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Info);
1827 } else if cfg!(feature = "max_level_debug") {
1828 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Debug);
1829 } else {
1830 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Trace);
1831 }
1832 }
1833
1834 #[test]
1835 #[cfg_attr(debug_assertions, ignore)]
1836 fn test_static_max_level_release() {
1837 if cfg!(feature = "release_max_level_off") {
1838 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Off);
1839 } else if cfg!(feature = "release_max_level_error") {
1840 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Error);
1841 } else if cfg!(feature = "release_max_level_warn") {
1842 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Warn);
1843 } else if cfg!(feature = "release_max_level_info") {
1844 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Info);
1845 } else if cfg!(feature = "release_max_level_debug") {
1846 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Debug);
1847 } else if cfg!(feature = "release_max_level_trace") {
1848 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Trace);
1849 } else if cfg!(feature = "max_level_off") {
1850 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Off);
1851 } else if cfg!(feature = "max_level_error") {
1852 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Error);
1853 } else if cfg!(feature = "max_level_warn") {
1854 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Warn);
1855 } else if cfg!(feature = "max_level_info") {
1856 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Info);
1857 } else if cfg!(feature = "max_level_debug") {
1858 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Debug);
1859 } else {
1860 assert_eq!(STATIC_MAX_LEVEL, LevelFilter::Trace);
1861 }
1862 }
1863
1864 #[test]
1865 #[cfg(feature = "std")]
1866 fn test_error_trait() {
1867 use super::SetLoggerError;
1868 let e = SetLoggerError(());
1869 assert_eq!(
1870 &e.to_string(),
1871 "attempted to set a logger after the logging system \
1872 was already initialized"
1873 );
1874 }
1875
1876 #[test]
1877 fn test_metadata_builder() {
1878 use super::MetadataBuilder;
1879 let target = "myApp";
1880 let metadata_test = MetadataBuilder::new()
1881 .level(Level::Debug)
1882 .target(target)
1883 .build();
1884 assert_eq!(metadata_test.level(), Level::Debug);
1885 assert_eq!(metadata_test.target(), "myApp");
1886 }
1887
1888 #[test]
1889 fn test_metadata_convenience_builder() {
1890 use super::Metadata;
1891 let target = "myApp";
1892 let metadata_test = Metadata::builder()
1893 .level(Level::Debug)
1894 .target(target)
1895 .build();
1896 assert_eq!(metadata_test.level(), Level::Debug);
1897 assert_eq!(metadata_test.target(), "myApp");
1898 }
1899
1900 #[test]
1901 fn test_record_builder() {
1902 use super::{MetadataBuilder, RecordBuilder};
1903 let target = "myApp";
1904 let metadata = MetadataBuilder::new().target(target).build();
1905 let fmt_args = format_args!("hello");
1906 let record_test = RecordBuilder::new()
1907 .args(fmt_args)
1908 .metadata(metadata)
1909 .module_path(Some("foo"))
1910 .file(Some("bar"))
1911 .line(Some(30))
1912 .build();
1913 assert_eq!(record_test.metadata().target(), "myApp");
1914 assert_eq!(record_test.module_path(), Some("foo"));
1915 assert_eq!(record_test.file(), Some("bar"));
1916 assert_eq!(record_test.line(), Some(30));
1917 }
1918
1919 #[test]
1920 fn test_record_convenience_builder() {
1921 use super::{Metadata, Record};
1922 let target = "myApp";
1923 let metadata = Metadata::builder().target(target).build();
1924 let fmt_args = format_args!("hello");
1925 let record_test = Record::builder()
1926 .args(fmt_args)
1927 .metadata(metadata)
1928 .module_path(Some("foo"))
1929 .file(Some("bar"))
1930 .line(Some(30))
1931 .build();
1932 assert_eq!(record_test.target(), "myApp");
1933 assert_eq!(record_test.module_path(), Some("foo"));
1934 assert_eq!(record_test.file(), Some("bar"));
1935 assert_eq!(record_test.line(), Some(30));
1936 }
1937
1938 #[test]
1939 fn test_record_complete_builder() {
1940 use super::{Level, Record};
1941 let target = "myApp";
1942 let record_test = Record::builder()
1943 .module_path(Some("foo"))
1944 .file(Some("bar"))
1945 .line(Some(30))
1946 .target(target)
1947 .level(Level::Error)
1948 .build();
1949 assert_eq!(record_test.target(), "myApp");
1950 assert_eq!(record_test.level(), Level::Error);
1951 assert_eq!(record_test.module_path(), Some("foo"));
1952 assert_eq!(record_test.file(), Some("bar"));
1953 assert_eq!(record_test.line(), Some(30));
1954 }
1955
1956 #[test]
1957 #[cfg(feature = "kv")]
1958 fn test_record_key_values_builder() {
1959 use super::Record;
1960 use crate::kv::{self, VisitSource};
1961
1962 struct TestVisitSource {
1963 seen_pairs: usize,
1964 }
1965
1966 impl<'kvs> VisitSource<'kvs> for TestVisitSource {
1967 fn visit_pair(
1968 &mut self,
1969 _: kv::Key<'kvs>,
1970 _: kv::Value<'kvs>,
1971 ) -> Result<(), kv::Error> {
1972 self.seen_pairs += 1;
1973 Ok(())
1974 }
1975 }
1976
1977 let kvs: &[(&str, i32)] = &[("a", 1), ("b", 2)];
1978 let record_test = Record::builder().key_values(&kvs).build();
1979
1980 let mut visitor = TestVisitSource { seen_pairs: 0 };
1981
1982 record_test.key_values().visit(&mut visitor).unwrap();
1983
1984 assert_eq!(2, visitor.seen_pairs);
1985 }
1986
1987 #[test]
1988 #[cfg(feature = "kv")]
1989 fn test_record_key_values_get_coerce() {
1990 use super::Record;
1991
1992 let kvs: &[(&str, &str)] = &[("a", "1"), ("b", "2")];
1993 let record = Record::builder().key_values(&kvs).build();
1994
1995 assert_eq!(
1996 "2",
1997 record
1998 .key_values()
1999 .get("b".into())
2000 .expect("missing key")
2001 .to_borrowed_str()
2002 .expect("invalid value")
2003 );
2004 }
2005
2006 #[test]
2009 fn test_foreign_impl() {
2010 use super::Log;
2011 #[cfg(feature = "std")]
2012 use std::sync::Arc;
2013
2014 fn assert_is_log<T: Log + ?Sized>() {}
2015
2016 assert_is_log::<&dyn Log>();
2017
2018 #[cfg(feature = "std")]
2019 assert_is_log::<Box<dyn Log>>();
2020
2021 #[cfg(feature = "std")]
2022 assert_is_log::<Arc<dyn Log>>();
2023
2024 #[allow(unused)]
2026 fn forall<T: Log + ?Sized>() {
2027 #[cfg(feature = "std")]
2028 assert_is_log::<Box<T>>();
2029
2030 assert_is_log::<&T>();
2031
2032 #[cfg(feature = "std")]
2033 assert_is_log::<Arc<T>>();
2034 }
2035 }
2036}