core/src/main/java/spark/network/netty/FileClientChannelInitializer.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

package spark.network.netty;

import io.netty.buffer.BufType;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringEncoder;


class FileClientChannelInitializer extends ChannelInitializer<SocketChannel> {

  private FileClientHandler fhandler;

  public FileClientChannelInitializer(FileClientHandler handler) {
    fhandler = handler;
  }

  @Override
  public void initChannel(SocketChannel channel) {
    // file no more than 2G
    channel.pipeline()
      .addLast("encoder", new StringEncoder(BufType.BYTE))
      .addLast("handler", fhandler);
  }
}