/**
 * 
 */
package divpro;

import connect.FlowListener;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import protobuf.MasterMessage;
import protobuf.MasterMessage.Message;

/**
 * @Description:  
 * @version: v1.0.0
 * @author: wbl
 * @date: 2019年9月3日 下午4:35:15
 */
public class Check104Handler extends ChannelInboundHandlerAdapter{
	 @Override
	 public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		 String body = msg.toString();
		 String ipport = body.split("_")[0];
		 String data = body.split("_")[1];
		 FlowListener.getInstance().writeFlow(ipport, data.length()/2);
		 if(data.length() < 6){
			 return;
		 }
		 Channel channel = MasterSlotsPartition.getInstance().getActiveMaster();
		 Message mast = MasterMessage.Message.newBuilder().setIp(ipport.split(":")[0])
	 				.setPort(ipport.split(":")[1]).setProtocolId(DivMultiprotocolSelection.PROTOCOL_TYPES)
	 				.setContent(data).build();

		 channel.writeAndFlush(mast);
	 }
}