package org.freertr.pipe;

import org.freertr.ifc.ifcDn;
import org.freertr.ifc.ifcNull;
import org.freertr.ifc.ifcUp;
import org.freertr.pack.packHolder;
import org.freertr.util.counter;
import org.freertr.util.state;

/**
 * interface to pipe converter
 *
 * @author matecsaba
 */
public class pipeIface implements ifcUp, Runnable {

    private ifcDn lower = new ifcNull();

    private counter cntr;

    private pipeLine pipe;

    private pipeSide pipC;

    private pipeSide pipS;

    /**
     * create handler
     */
    public pipeIface() {
        cntr = new counter();
        pipe = new pipeLine(65536, true);
        pipC = pipe.getSide();
        pipS = pipe.getSide();
        new Thread(this).start();
    }

    /**
     * get client pipe side
     *
     * @return pipe side
     */
    public pipeSide getPipe() {
        return pipC;
    }

    /**
     * set parent
     *
     * @param parent parent
     */
    public void setParent(ifcDn parent) {
        lower = parent;
    }

    /**
     * set state
     *
     * @param stat state
     */
    public void setState(state.states stat) {
    }

    /**
     * close interface
     */
    public void closeUp() {
        pipe.setClose();
    }

    /**
     * get counter
     *
     * @return counter
     */
    public counter getCounter() {
        return cntr;
    }

    /**
     * received packet
     *
     * @param pck packet
     */
    public void recvPack(packHolder pck) {
        byte[] buf = pck.getCopy();
        pipS.nonBlockPut(buf, 0, buf.length);
    }

    public void run() {
        for (;;) {
            packHolder pck = new packHolder(true, true);
            if (pck.pipeRecv(pipS, 0, 4096, 143) < 1) {
                break;
            }
            lower.sendPack(pck);
        }
    }

}