blob: 23977297d5d315d84c61e1a0d0abca42999b241d (
plain) (
blame)
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
/*******************************************************************************
* Copyright (c) 2006, 2013 IBM Corporation and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* IBM Corporation - initial API and implementation
*******************************************************************************/
package org.eclipse.equinox.internal.transforms;
import java.io.*;
import java.net.MalformedURLException;
import java.net.URL;
import org.eclipse.osgi.framework.log.FrameworkLogEntry;
import org.eclipse.osgi.internal.framework.EquinoxContainer;
import org.eclipse.osgi.storage.bundlefile.BundleEntry;
/**
* This class is capable of providing a transformed version of an entry contained within a base bundle entity.
*/
public class TransformedBundleEntry extends BundleEntry {
long timestamp;
private InputStream stream;
private BundleEntry original;
private TransformedBundleFile bundleFile;
/**
* Create a wrapped bundle entry. Calls to obtain the content of this entry will be resolved via the provided input stream rather than the original.
* @param bundleFile the host bundle file
* @param original the original entry
* @param wrappedStream the override stream
*/
public TransformedBundleEntry(TransformedBundleFile bundleFile, BundleEntry original, InputStream wrappedStream) {
this.stream = wrappedStream;
this.bundleFile = bundleFile;
this.original = original;
timestamp = System.currentTimeMillis();
}
@SuppressWarnings("deprecation")
public URL getFileURL() {
try {
File file = bundleFile.getFile(getName(), false);
if (file != null)
return file.toURL();
} catch (MalformedURLException e) {
// This can not happen.
}
return null;
}
public InputStream getInputStream() {
return stream;
}
public URL getLocalURL() {
return getFileURL();
}
public String getName() {
return original.getName();
}
/**
* Obtaining the size means inspecting the transformed stream.
* If this stream does not support marks the stream is drained and a copy is retained for later use.
*/
public long getSize() {
ByteArrayOutputStream tempBuffer = new ByteArrayOutputStream(1024);
byte[] buffer = new byte[1024];
int i = 0;
try {
while ((i = stream.read(buffer)) > -1) {
tempBuffer.write(buffer, 0, i);
}
if (stream.markSupported()) {
try {
stream.reset();
} catch (IOException e) {
stream = new ByteArrayInputStream(tempBuffer.toByteArray());
}
} else {
stream = new ByteArrayInputStream(tempBuffer.toByteArray());
}
} catch (IOException e) {
bundleFile.getGeneration().getBundleInfo().getStorage().getLogServices().log(EquinoxContainer.NAME, FrameworkLogEntry.ERROR, "Problem calculating size of stream for file. Stream may now be corrupted : " //$NON-NLS-1$
+ getName(), e);
}
return tempBuffer.size();
}
public long getTime() {
return timestamp;
}
}
|
