ResFileUploadOpen.java 2.84 KB
/*
 * Decompiled with CFR 0_118.
 */
package com.scene7.is.ipp.messages;

import com.scene7.is.ipp.messages.InMessage;
import com.scene7.is.ipp.messages.Ipp;
import com.scene7.is.ipp.messages.IppInt;
import com.scene7.is.ipp.messages.Offset;
import java.io.IOException;
import java.io.Writer;

public class ResFileUploadOpen
extends InMessage {
    static int MessageNumber = 66320;
    private int transactionId_;
    private int fileId_;

    public ResFileUploadOpen(int tag, int transactionId, int fileId, int headClientId) {
        int fixedLength;
        this.tag_ = tag;
        this.headerClientId_ = headClientId;
        this.transactionId_ = transactionId;
        this.fileId_ = fileId;
        this.messageLength_ = fixedLength = 8;
        Offset pos = new Offset(0);
        this.headBuffer_ = new byte[32];
        this.bodyBuffer_ = new byte[this.messageLength_];
        Ipp.StuffHeader(this.headBuffer_, this.headerClientId_, tag, MessageNumber, this.messageLength_);
        IppInt.Stuff(this.bodyBuffer_, pos, null, this.transactionId_);
        IppInt.Stuff(this.bodyBuffer_, pos, null, this.fileId_);
        Ipp.Assert(pos.val == fixedLength, "IppWatermarkType length");
    }

    public ResFileUploadOpen() {
    }

    public void process(int headClientId, int tg, byte[] bf) {
        this.headerClientId_ = headClientId;
        this.tag_ = tg;
        this.messageLength_ = bf.length;
        this.headBuffer_ = new byte[32];
        Ipp.StuffHeader(this.headBuffer_, this.headerClientId_, this.tag_, MessageNumber, this.messageLength_);
        this.bodyBuffer_ = bf;
        Offset pos = new Offset(0);
        this.transactionId_ = IppInt.Unstuff(this.bodyBuffer_, pos);
        this.fileId_ = IppInt.Unstuff(this.bodyBuffer_, pos);
    }

    public int classification() {
        return 1;
    }

    public int id() {
        return MessageNumber;
    }

    public void print(Writer tf, String heading) throws IOException {
        tf.write("\n");
        tf.write(heading);
        tf.write(": ResFileUploadOpen ");
        Ipp.PrintHex(tf, MessageNumber);
        tf.write("\n");
        tf.write("headClientId: " + this.headerClientId() + "\n");
        Ipp.PrintTag(tf, "tag: ", this.tag());
        tf.write("length: " + this.length());
        tf.write("\n");
        IppInt.Print(tf, "transactionId: ", this.transactionId_);
        IppInt.Print(tf, "fileId: ", this.fileId_);
    }

    public String toString() {
        StringBuffer buffer = new StringBuffer();
        buffer.append("ResFileUploadOpen             ");
        buffer.append("[transactionId: " + String.valueOf(this.transactionId_) + "],");
        buffer.append("[fileId: " + String.valueOf(this.fileId_) + "],");
        return buffer.toString();
    }

    public int transactionId() {
        return this.transactionId_;
    }

    public int fileId() {
        return this.fileId_;
    }
}