RpcCallCodec.java 文件源码

@Override
protected void encode(ChannelHandlerContext ctx, RpcCall call, List<Object> out) throws Exception {
    final PacketBuffer output = new PacketBuffer(Unpooled.buffer());

    {
        final IRpcTarget targetWrapper = call.target;
        int targetId = CommonRegistryCallbacks.mapObjectToId(targetRegistry, targetWrapper.getClass());
        output.writeVarInt(targetId);
        targetWrapper.writeToStream(output);
    }

    {
        final BiMap<MethodEntry, Integer> eventIdMap = CommonRegistryCallbacks.getEntryIdMap(methodRegistry);
        int methodId = eventIdMap.get(call.method);
        output.writeVarInt(methodId);
        MethodParamsCodec paramsCodec = call.method.paramsCodec;
        paramsCodec.writeArgs(output, call.args);
    }

    FMLProxyPacket packet = new FMLProxyPacket(output, RpcCallDispatcher.CHANNEL_NAME);
    out.add(packet);
}