@@ -11,13 +11,13 @@ use crate::logger::{LdkLogger, Logger};
1111use crate :: runtime:: Runtime ;
1212use crate :: types:: DynStore ;
1313
14+ use lightning:: io;
1415use lightning:: util:: persist:: {
1516 KVStore , KVStoreSync , NETWORK_GRAPH_PERSISTENCE_KEY ,
1617 NETWORK_GRAPH_PERSISTENCE_PRIMARY_NAMESPACE , NETWORK_GRAPH_PERSISTENCE_SECONDARY_NAMESPACE ,
1718 SCORER_PERSISTENCE_KEY , SCORER_PERSISTENCE_PRIMARY_NAMESPACE ,
1819} ;
19- use lightning:: { io, log_trace} ;
20- use lightning:: { log_debug, log_error, log_info, log_warn} ;
20+ use lightning:: { log_error, log_warn} ;
2121
2222use tokio:: sync:: mpsc:: { self , error:: TrySendError } ;
2323
@@ -86,15 +86,7 @@ impl TierStore {
8686 ) {
8787 while let Some ( op) = receiver. recv ( ) . await {
8888 match Self :: apply_backup_operation ( & op, & backup_store) . await {
89- Ok ( _) => {
90- log_trace ! (
91- logger,
92- "Backup succeeded for key {}/{}/{}" ,
93- op. primary_namespace( ) ,
94- op. secondary_namespace( ) ,
95- op. key( )
96- ) ;
97- } ,
89+ Ok ( _) => { } ,
9890 Err ( e) => {
9991 log_error ! (
10092 logger,
@@ -381,16 +373,7 @@ impl TierStoreInner {
381373 )
382374 . await
383375 {
384- Ok ( data) => {
385- log_info ! (
386- self . logger,
387- "Read succeeded for key: {}/{}/{}" ,
388- primary_namespace,
389- secondary_namespace,
390- key
391- ) ;
392- Ok ( data)
393- } ,
376+ Ok ( data) => Ok ( data) ,
394377 Err ( e) => {
395378 log_error ! (
396379 self . logger,
@@ -413,12 +396,6 @@ impl TierStoreInner {
413396 . await
414397 {
415398 Ok ( keys) => {
416- log_info ! (
417- self . logger,
418- "List succeeded for namespace: {}/{}" ,
419- primary_namespace,
420- secondary_namespace
421- ) ;
422399 return Ok ( keys) ;
423400 } ,
424401 Err ( e) => {
@@ -464,7 +441,7 @@ impl TierStoreInner {
464441 Ok ( ( ) )
465442 } ,
466443 Err ( e) => {
467- log_debug ! (
444+ log_error ! (
468445 self . logger,
469446 "Skipping backup write due to primary write failure for key: {}/{}/{}." ,
470447 primary_namespace,
@@ -506,7 +483,7 @@ impl TierStoreInner {
506483 Ok ( ( ) )
507484 } ,
508485 Err ( e) => {
509- log_debug ! (
486+ log_error ! (
510487 self . logger,
511488 "Skipping backup removal due to primary removal failure for key: {}/{}/{}." ,
512489 primary_namespace,
@@ -548,7 +525,6 @@ impl TierStoreInner {
548525 )
549526 . await
550527 } else {
551- log_debug ! ( self . logger, "Ephemeral store not configured. Reading non-critical data from primary or backup stores." ) ;
552528 self . read_primary ( & primary_namespace, & secondary_namespace, & key) . await
553529 }
554530 } ,
@@ -572,8 +548,6 @@ impl TierStoreInner {
572548 )
573549 . await
574550 } else {
575- log_debug ! ( self . logger, "Ephemeral store not configured. Writing non-critical data to primary and backup stores." ) ;
576-
577551 self . primary_write_then_schedule_backup (
578552 primary_namespace. as_str ( ) ,
579553 secondary_namespace. as_str ( ) ,
@@ -611,8 +585,6 @@ impl TierStoreInner {
611585 )
612586 . await
613587 } else {
614- log_debug ! ( self . logger, "Ephemeral store not configured. Removing non-critical data from primary and backup stores." ) ;
615-
616588 self . primary_remove_then_schedule_backup (
617589 primary_namespace. as_str ( ) ,
618590 secondary_namespace. as_str ( ) ,
@@ -646,10 +618,6 @@ impl TierStoreInner {
646618 if let Some ( eph_store) = self . ephemeral_store . as_ref ( ) {
647619 KVStoreSync :: list ( eph_store. as_ref ( ) , & primary_namespace, & secondary_namespace)
648620 } else {
649- log_debug ! (
650- self . logger,
651- "Ephemeral store not configured. Listing from primary and backup stores."
652- ) ;
653621 self . list_primary ( & primary_namespace, & secondary_namespace) . await
654622 }
655623 } ,
0 commit comments