Lte3000Client.java 1.95 KB
package com.example.mina.client.lte3000;

import com.example.mina.client.base.AbstractClient;
import com.example.mina.client.coder.ByteFactory;
import com.example.mina.client.entity.AbstractClientMessage;
import com.example.mina.client.entity.Command;
import com.example.mina.client.entity.Lte3000Message;
import com.example.mina.server.entity.Lte3000DataBuffer;
import com.example.mina.server.util.Lte3000CommandHelper;

/**
 * @author dy
 * @date 2021/3/10
 */
public class Lte3000Client extends AbstractClient {

    @Override
    protected void init(AbstractClientMessage abstractClientMessage) {
        protocolCodecFactory = new ByteFactory();
        abstractVirtualBoxClientHandler = new Lte3000ClientHandler(abstractClientMessage, hardwareDataBuffer);
    }

    @Override
    protected void initHardwareDataBuffer() {
        hardwareDataBuffer = new Lte3000DataBuffer(32, 32, 30);
    }

    @Override
    protected void initClientMessage() {
        abstractClientMessage = new Lte3000Message();
        abstractClientMessage.setHost("localhost");
        abstractClientMessage.setPort(9102);
        for (int i = 0; i < this.hardwareDataBuffer.getMaxRow(); i++) {
            abstractClientMessage.getCommands().add(new Command("", Lte3000CommandHelper.genCommandGetCross(i + 1)));
        }

        // query attenuation
        // the LTE attenuation is bound to column
        for (int j = 0; j < this.hardwareDataBuffer.getMaxCol(); j++) {
            abstractClientMessage.getCommands().add(new Command("", Lte3000CommandHelper.genCommandGetAttn(j + 1)));
        }

    }

    @Override
    public boolean setAttenuation(int row, int col, int attenuation) {
        ioSession.write("abcdfd".getBytes());
        return false;
    }

    @Override
    public int getAttenuation(int row, int col) {
        return 0;
    }

    @Override
    public Boolean reset() {
        return null;
    }

    @Override
    public int[][] getAll() {
        return new int[0][];
    }

}