2828import com .falsepattern .falsetweaks .config .ModuleConfig ;
2929import com .falsepattern .falsetweaks .config .ThreadingConfig ;
3030import com .falsepattern .falsetweaks .modules .debug .Debug ;
31+ import com .falsepattern .falsetweaks .modules .debug .DebugLogging ;
3132import com .falsepattern .falsetweaks .modules .occlusion .*;
3233import com .falsepattern .falsetweaks .modules .threadexec .FTWorker ;
3334import com .falsepattern .falsetweaks .modules .threadexec .ThreadedTask ;
4445import it .unimi .dsi .fastutil .ints .IntSet ;
4546import lombok .RequiredArgsConstructor ;
4647import lombok .val ;
47- import mega .trace .service .MEGATraceService ;
4848
4949import net .minecraft .block .Block ;
5050import net .minecraft .block .material .Material ;
6666import java .util .concurrent .LinkedBlockingDeque ;
6767import java .util .concurrent .atomic .AtomicBoolean ;
6868import java .util .concurrent .atomic .AtomicReference ;
69- import java .util .function .Supplier ;
7069
7170import static com .falsepattern .falsetweaks .modules .occlusion .OcclusionRenderer .*;
7271import static com .falsepattern .falsetweaks .modules .threadedupdates .MainThreadContainer .MAIN_THREAD ;
@@ -108,10 +107,10 @@ public void prepare(List<WorldRenderer> worldRenderersToUpdateList, int updateLi
108107 val wr = front .get (i );
109108 val task = ((IRendererUpdateResultHolder ) wr ).ft$getRendererUpdateTask ();
110109 if (!task .inFinishedQueue ) {
111- debugLog (() -> "Fresh " + worldRendererToString ( wr ) + " added to back buffer" );
110+ DebugLogging . debugLog (() -> "Fresh " + wr + " added to back buffer" );
112111 back .add (wr );
113112 } else {
114- debugLog (() -> "Finished " + worldRendererToString ( wr ) + " ignored" );
113+ DebugLogging . debugLog (() -> "Finished " + wr + " ignored" );
115114 ((WorldRendererOcclusion ) wr ).ft$setInUpdateList (false );
116115 }
117116 }
@@ -149,7 +148,7 @@ public WorldRenderer next() {
149148 updatedRenderers .front ().add (wr );
150149 updatedRenderersSet .front ().add (wr );
151150
152- debugLog (() -> "Consuming renderer " + worldRendererToString ( wr ) + " " + worldRendererUpdateTaskToString (wr ));
151+ DebugLogging . debugLog (() -> "Consuming renderer " + wr + " " + worldRendererUpdateTaskToString (wr ));
153152
154153 return wr ;
155154 }
@@ -207,7 +206,7 @@ private static int doChunkUpdateForRenderPass(WorldRenderer wr, UpdateTask task,
207206 for (int z = wr .posZ ; z < wr .posZ + 16 ; ++z ) {
208207 for (int x = wr .posX ; x < wr .posX + 16 ; ++x ) {
209208 if (task .cancelled ) {
210- debugLog (() -> "Realized renderer " + worldRendererToString ( wr ) + " is dirty, aborting update" );
209+ DebugLogging . debugLog (() -> "Realized renderer " + wr + " is dirty, aborting update" );
211210 break BlockLoop ;
212211 }
213212 flags = doChunkUpdateForRenderPassBlock (wr , task , chunkcache , tess , pass , renderblocks , x , y , z , flags );
@@ -286,28 +285,12 @@ public static boolean isMainThread() {
286285 return thread == MAIN_THREAD ;
287286 }
288287
289- public static String worldRendererToString (WorldRenderer wr ) {
290- return wr + "(" + wr .posX + ", " + wr .posY + ", " + wr .posZ + ")" ;
291- }
292-
293288 private static String worldRendererUpdateTaskToString (WorldRenderer wr ) {
294289 UpdateTask task = ((IRendererUpdateResultHolder ) wr ).ft$getRendererUpdateTask ();
295290 return task .result [0 ].renderedSomething + "" ;
296291 // TODO + " (" + (task.result[0].renderedQuads == null ? "null" : task.result[0].renderedQuads.getVertexCount()) + ")/" + task.result[1].renderedSomething + " (" + (task.result[1].renderedQuads == null ? "null" : task.result[1].renderedQuads.getVertexCount()) + ")";
297292 }
298293
299- public static void debugLog (Supplier <String > msg ) {
300- if (Debug .ENABLED && Debug .fineLog ) {
301- val msgVal = msg .get ();
302- if (Debug .fineLogTrace && Thread .currentThread ().getName ().toLowerCase ().contains ("client" )) {
303- Share .log .info (msgVal , new Throwable ());
304- } else {
305- Share .log .info (msgVal );
306- }
307- MEGATraceService .INSTANCE .message (msgVal );
308- }
309- }
310-
311294 public void init () {
312295 OcclusionHelpers .renderer .ft$setRendererUpdateOrderProvider (rendererUpdateOrderProvider );
313296 OcclusionHelpers .renderer .ft$addRenderGlobalListener (this );
@@ -381,7 +364,7 @@ private void preRendererUpdates(List<WorldRenderer> toUpdateList, int updateLimi
381364 private void updateWorkQueue (List <WorldRenderer > toUpdateList , int updateLimit ) {
382365 if (toUpdateList .isEmpty ())
383366 return ;
384- debugLog (() -> "Updating " + toUpdateList .size () + " renderers" );
367+ DebugLogging . debugLog (() -> "Updating " + toUpdateList .size () + " renderers" );
385368 taskQueueUnsorted .getAndSet (new PendingTaskUpdate (new ArrayList <>(toUpdateList ), updateLimit ));
386369 }
387370
@@ -412,7 +395,7 @@ public void onDirtyRendererChanged(WorldRenderer wr) {
412395 public void onWorldRendererDirty (WorldRenderer wr ) {
413396 UpdateTask task = ((IRendererUpdateResultHolder ) wr ).ft$getRendererUpdateTask ();
414397 if (!task .isEmpty ()) {
415- debugLog (() -> "Renderer " + worldRendererToString ( wr ) + " is dirty, cancelling task" );
398+ DebugLogging . debugLog (() -> "Renderer " + wr + " is dirty, cancelling task" );
416399 task .cancelled = true ;
417400 }
418401 }
@@ -428,7 +411,7 @@ public static boolean renderOffThread(Block block, int renderType) {
428411 * produced by the worker thread to fill them in.
429412 */
430413 public void doChunkUpdate (WorldRenderer wr , Profiler profiler ) {
431- debugLog (() -> "Starting update of renderer " + worldRendererToString ( wr ) );
414+ DebugLogging . debugLog (() -> "Starting update of renderer " + wr );
432415
433416 UpdateTask task = ((IRendererUpdateResultHolder ) wr ).ft$getRendererUpdateTask ();
434417 if (AGGRESSIVE_NEODYMIUM_THREADING ) {
@@ -542,7 +525,7 @@ public void doChunkUpdate(WorldRenderer wr, Profiler profiler) {
542525 } finally {
543526 profiler .endSection ();
544527 }
545- debugLog (() -> "Result of updating " + worldRendererToString ( wr ) + ": " + worldRendererUpdateTaskToString (wr ));
528+ DebugLogging . debugLog (() -> "Result of updating " + wr + ": " + worldRendererUpdateTaskToString (wr ));
546529 }
547530
548531 private ChunkCache getChunkCacheSnapshot (WorldRenderer wr ) {
@@ -695,7 +678,7 @@ public boolean doWork(Profiler profiler) {
695678
696679 if (task .isEmpty ()) {
697680 // No update in progress; add to task queue
698- debugLog (() -> "Adding " + worldRendererToString ( wr ) + " to task queue" );
681+ DebugLogging . debugLog (() -> "Adding " + wr + " to task queue" );
699682 try {
700683 task .chunkCache = getChunkCacheSnapshot (wr );
701684 } catch (Exception ignored ) {
@@ -727,7 +710,7 @@ private void runTask(WorldRenderer wr, Profiler profiler) {
727710 doChunkUpdate (wr , profiler );
728711 } catch (Exception e ) {
729712 ThreadedClientHooks .threadRenderPass .set (-1 );
730- Share .log .debug ("Failed to update chunk " + worldRendererToString ( wr ) , e );
713+ Share .log .debug ("Failed to update chunk " + wr , e );
731714 if (AGGRESSIVE_NEODYMIUM_THREADING ) {
732715 NeodymiumCompat .safeDiscardTask (task );
733716 }
0 commit comments