@@ -437,26 +437,9 @@ else if( H2O.ICE_ROOT.getScheme() == null || Schemes.FILE.equals(H2O.ICE_ROOT.ge
437
437
log0 (l4j , e );
438
438
}
439
439
440
- if ( Paxos ._cloudLocked && logToKV ) logToKV (e .when .startAsString (), e .thread , e .kind , e .sys , e .body (0 ));
441
440
if (printOnOut || printAll ) unwrap (System .out , e .toShortString ());
442
441
e .printMe = false ;
443
442
}
444
- /** We also log events to the store. */
445
- private static void logToKV (final String date , final String thr , final Kind kind , final Sys sys , final String msg ) {
446
- // Make the LOG_KEY lazily, since we cannot make it before the cloud forms
447
- if ( LOG_KEY == null )
448
- if ( !Paxos ._cloudLocked ) return ; // No K/V logging before cloud formed
449
- synchronized (Log .class ) {
450
- if ( LOG_KEY == null ) LOG_KEY = Key .make ("Log" , (byte ) 0 , Key .BUILT_IN_KEY );
451
- }
452
- final long pid = PID ; // Run locally
453
- final H2ONode h2o = H2O .SELF ; // Run locally
454
- new TAtomic <LogStr >() {
455
- @ Override public LogStr atomic (LogStr l ) {
456
- return new LogStr (l , date , h2o , pid , thr , kind , sys , msg );
457
- }
458
- }.fork (LOG_KEY );
459
- }
460
443
/** Record an exception to the log file and store. */
461
444
static public <T extends Throwable > T err (Sys t , String msg , T exception ) {
462
445
Event e = Event .make (t , Kind .ERRR , exception , msg );
0 commit comments