<commit_before>package com.mercury.platform.server.init;

import com.mercury.platform.server.handlers.ClientHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.serialization.ClassResolver;
import io.netty.handler.codec.serialization.ClassResolvers;
import io.netty.handler.codec.serialization.ObjectDecoder;
import io.netty.handler.codec.serialization.ObjectEncoder;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * Created by Frost on 14.01.2017.
 */
public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {

    private static final Logger LOGGER = LogManager.getLogger(ClientChannelInitializer.class);

    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        LOGGER.info("Initializing channel, server address = {}" , socketChannel.remoteAddress().getHostName());
        socketChannel.pipeline().addLast(new ObjectEncoder());
        ClassLoader classLoader = this.getClass().getClassLoader();
        ClassResolver classResolver = ClassResolvers.weakCachingResolver(classLoader);
        socketChannel.pipeline().addLast(new ObjectDecoder(classResolver));
        socketChannel.pipeline().addLast(new ClientHandler());
        LOGGER.info("Client channel was initialized");
    }
}
<commit_msg>updated logging ClientChannelInitializer<commit_after>package com.mercury.platform.server.init;

import com.mercury.platform.server.handlers.ClientHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.serialization.ClassResolver;
import io.netty.handler.codec.serialization.ClassResolvers;
import io.netty.handler.codec.serialization.ObjectDecoder;
import io.netty.handler.codec.serialization.ObjectEncoder;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * Created by Frost on 14.01.2017.
 */
public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {

    private static final Logger LOGGER = LogManager.getLogger(ClientChannelInitializer.class);

    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        LOGGER.info("Initializing client channel");
        socketChannel.pipeline().addLast(new ObjectEncoder());
        ClassLoader classLoader = this.getClass().getClassLoader();
        ClassResolver classResolver = ClassResolvers.weakCachingResolver(classLoader);
        socketChannel.pipeline().addLast(new ObjectDecoder(classResolver));
        socketChannel.pipeline().addLast(new ClientHandler());
        LOGGER.info("Client channel was initialized");
    }
}

{'fraction_non_alphanumeric': 0.1009843237331389, 'fraction_numerical': 0.007291286912139993, 'mean_word_length': 5.32258064516129, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6445033', 'n_tokens_mistral': 733, 'n_tokens_neox': 734, 'n_words': 128}