[1.8.9] Inserting my own ChannelHandler into minecraft channel pipeline doesn't work

[xParadoxical_]

So, as the title says, I'm inserting my own ChannelHandler (which extends ChannelInboundHandlerAdapter) into Minecraft.getMinecraft().getNetHandler().getNetworkManager().channel().pipeline(), but my handler's channelRead function never gets executed. I checked in minecraft code that I can get the proper channel (where are all of minecraft's ChannelHandlers) using method above, but apparently I can't. I don't know what am I doing wrong.

My main goal is to create a clientside mod that detects when the client doesn't get any packets from the server - that is, when a network lag occurs. (I'm currently writing it in my mod where I have all of my useful things - later I'll move it out to a separate mod.)

 

Code:

- Main mod class:

Spoiler

    //...
    @Mod.EventHandler
    public void init(FMLInitializationEvent e) {
        //...
        MinecraftForge.EVENT_BUS.register(new LagEventHandlers());
        //...
    }
    //...

 

-LagEventHandlers:

Spoiler

package com.paradoxical.automeow;

import net.minecraft.client.Minecraft;
import net.minecraft.util.EnumChatFormatting;
import net.minecraftforge.event.entity.EntityJoinWorldEvent;
import net.minecraftforge.fml.common.eventhandler.SubscribeEvent;
import net.minecraftforge.fml.common.gameevent.TickEvent;
import net.minecraftforge.fml.common.network.FMLNetworkEvent;

import java.util.Date;

public class LagEventHandlers {
    private int step = -30;

    @SubscribeEvent
    public void onTick(TickEvent.ClientTickEvent e) {
        if (LagDetectorChannelHandler.c)
            if (step == 3) {
                step = 0;
                long lag = new Date().getTime() - LagDetectorChannelHandler.last;
                if (lag > 15 && LagDetectorChannelHandler.avg.get() <= 0.85D && LagDetectorChannelHandler.avg.alive()) {
                    Minecraft.getMinecraft().ingameGUI.setRecordPlaying(EnumChatFormatting.RED + "Received no packets from server for " +
                                    EnumChatFormatting.BOLD + lag + "ms", true); //Setting a message on action bar
                }
            } else step++;
    }

    private boolean joined = false;

    @SubscribeEvent
    public void onEntityJoin(EntityJoinWorldEvent e) {
        if (!joined && e.entity.getName().equals(Minecraft.getMinecraft().getSession().getUsername())) {
            joined = true;
            if (!LagDetectorChannelHandler.a) {
                LagDetectorChannelHandler.a = true;
                Minecraft.getMinecraft().getNetHandler()
                        .getNetworkManager()
                        .channel()
                        .pipeline().addLast("lag_handler", new LagDetectorChannelHandler());
                AutoMeow.log("Added a channel handler");
            }
            LagDetectorChannelHandler.init();
            LagDetectorChannelHandler.c = true;
            step = -30;
        }
    }

    @SubscribeEvent
    public void onDisconnection(FMLNetworkEvent.ClientDisconnectionFromServerEvent e) {
        LagDetectorChannelHandler.c = false;
        LagDetectorChannelHandler.uninit();
        step = 0;
        joined = false;
    }
}

 

-LagDetectorChannelHandler:

Spoiler

package com.paradoxical.automeow;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import net.minecraft.client.Minecraft;
import net.minecraft.network.Packet;
import net.minecraft.util.ChatComponentText;

import java.util.Date;

public class LagDetectorChannelHandler extends ChannelInboundHandlerAdapter {
    //All of the variables are static for simplicity because this class is a singleton
    static long last = 0;
    static boolean c = false; //connected to server?
    static TimeAverage avg;
    static boolean a = false; //is this handler added?

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (c) {
            Minecraft.getMinecraft().thePlayer.addChatMessage(new ChatComponentText((msg instanceof Packet) + " " + msg.getClass().getName() + " " + last)); //debug
            if (msg instanceof Packet && msg.getClass().getName().startsWith("S")) { //Is this packet a server to client packet?
                last = new Date().getTime();
                avg.add(1);
            }
        }

        super.channelRead(ctx, msg);
    }

    static void init() {
        avg = new TimeAverage(150);
    }

    static void uninit() {
        last = 0;
        avg = null;
    }
}

 

 

Edited March 3, 2019 by xParadoxical_

[DaemonUmbra]

1.8.9 is no longer supported on this forum due to its age.

Please update to a modern version of Minecraft to receive support.