package com.dy.common.mw.channel.tcp;

import org.apache.mina.filter.codec.ProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.core.session.IoSession;

public class DataCodecFactory implements ProtocolCodecFactory {

	private TcpUnitAdapter adapter ;
    private boolean stop = false ;//为true时，停止TCP服务，并把已经TCP连接断连接

    public DataCodecFactory(TcpUnitAdapter adapter) {
    	this.adapter = adapter ;
    }

    public void stop(){
        stop = true ;
    }

    public void recover(){
        this.stop = false ;
    }


    public ProtocolEncoder getEncoder(IoSession ioSession) {
        if(stop){
            ioSession.closeNow() ;
        }
        return new DataEncoder();
    }

    public ProtocolDecoder getDecoder(IoSession ioSession) {
        if(stop){
            ioSession.closeNow() ;
        }
        return new DataDecoder(adapter.newPrefixedDataAvailableHandle());
    }
}