BlobOutputStream.java
2.16 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
/*
* Decompiled with CFR 0_118.
*/
package com.day.crx.delite.impl.support;
import com.day.crx.delite.impl.support.Blob;
import com.day.crx.delite.impl.support.BlobFactoryImpl;
import com.day.crx.delite.impl.support.BlobImpl;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
public class BlobOutputStream
extends OutputStream {
private int treshhold = 65536;
private byte[] data = null;
private int length = 0;
private File file;
private OutputStream out = new ByteArrayOutputStream();
private final BlobFactoryImpl factory;
public BlobOutputStream(BlobFactoryImpl factory) {
this.factory = factory;
}
public void write(byte[] bytes, int off, int len) throws IOException {
if (this.out == null) {
throw new IllegalStateException("Stream already closed.");
}
if (this.file == null && len + this.length > this.treshhold) {
this.close();
this.file = this.factory.allocateTmpFile();
this.out = new FileOutputStream(this.file);
this.out.write(this.data);
this.data = null;
}
this.out.write(bytes, off, len);
this.length += len;
}
public void write(byte[] b) throws IOException {
this.write(b, 0, b.length);
}
public void close() throws IOException {
if (this.out instanceof ByteArrayOutputStream) {
ByteArrayOutputStream bof = (ByteArrayOutputStream)this.out;
bof.close();
this.data = bof.toByteArray();
this.file = null;
this.out = null;
} else if (this.out instanceof FileOutputStream) {
this.out.close();
this.data = null;
this.out = null;
}
}
public Blob getBlob() throws IOException {
this.close();
BlobImpl blob = this.file == null ? new BlobImpl(this.factory, this.data) : new BlobImpl(this.factory, this.file);
return this.factory.register(blob);
}
public void write(int b) throws IOException {
this.write(new byte[]{(byte)b}, 0, 1);
}
}