1
package org.jvnet.hudson.remcom;
3
import java.io.DataInputStream;
4
import java.io.IOException;
5
import java.io.OutputStream;
8
* @author Kohsuke Kawaguchi
10
class Payload extends Packet {
11
public static Object/*byte[] or RemComResponse*/ read(DataInputStream in) throws IOException {
12
byte[] len = new byte[4];
14
int size = readInt(len,0);
17
// EOF from the service
18
return new RemComResponse(in);
22
throw new IllegalArgumentException("Negative: "+size);
23
byte[] buf = new byte[size];
29
public static void write(byte[] data, int offset, int len, OutputStream dst) throws IOException {
30
byte[] pack = new byte[len+4];
31
setIntAt(len, pack, 0); // len
32
System.arraycopy(data,offset, pack, 4, len);