blob: 31bdbec46124d1bed158f1cfd6abeff62f89dab3 (
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
/*******************************************************************************
* Copyright (c) 2008, 2018 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.p2.core.helpers;
import java.io.*;
import java.util.Enumeration;
import java.util.zip.GZIPInputStream;
/**
* Copied from org.eclipse.ui.internal.wizards.datatransfer.TarFile.
*/
public class TarFile implements Closeable {
private File file;
private TarInputStream entryEnumerationStream;
private TarEntry curEntry;
private TarInputStream entryStream;
private InputStream internalEntryStream;
/**
* Create a new TarFile for the given file.
*
* @param file
* @throws TarException
* @throws IOException
*/
public TarFile(File file) throws TarException, IOException {
this.file = file;
InputStream in = new FileInputStream(file);
// First, check if it's a GZIPInputStream.
try {
in = new GZIPInputStream(in);
} catch (IOException e) {
//If it is not compressed we close
//the old one and recreate
in.close();
in = new FileInputStream(file);
}
try {
entryEnumerationStream = new TarInputStream(in);
} catch (TarException ex) {
in.close();
throw ex;
}
curEntry = entryEnumerationStream.getNextEntry();
}
/**
* Close the tar file input stream.
*
* @throws IOException if the file cannot be successfully closed
*/
@Override
public void close() throws IOException {
entryEnumerationStream.close();
if (internalEntryStream != null)
internalEntryStream.close();
}
/**
* Returns an enumeration cataloguing the tar archive.
*
* @return enumeration of all files in the archive
*/
public Enumeration<TarEntry> entries() {
return new Enumeration<TarEntry>() {
@Override
public boolean hasMoreElements() {
return (curEntry != null);
}
@Override
public TarEntry nextElement() {
TarEntry oldEntry = curEntry;
try {
curEntry = entryEnumerationStream.getNextEntry();
} catch (TarException e) {
curEntry = null;
} catch (IOException e) {
curEntry = null;
}
return oldEntry;
}
};
}
/**
* Returns a new InputStream for the given file in the tar archive.
*
* @param entry
* @return an input stream for the given file
* @throws TarException
* @throws IOException
*/
public InputStream getInputStream(TarEntry entry) throws TarException, IOException {
if (entryStream == null || !entryStream.skipToEntry(entry)) {
if (internalEntryStream != null) {
internalEntryStream.close();
}
internalEntryStream = new FileInputStream(file);
// First, check if it's a GZIPInputStream.
try {
internalEntryStream = new GZIPInputStream(internalEntryStream);
} catch (IOException e) {
//If it is not compressed we close
//the old one and recreate
internalEntryStream.close();
internalEntryStream = new FileInputStream(file);
}
entryStream = new TarInputStream(internalEntryStream, entry) {
@Override
public void close() {
// Ignore close() since we want to reuse the stream.
}
};
}
return entryStream;
}
/**
* Returns the path name of the file this archive represents.
*
* @return path
*/
public String getName() {
return file.getPath();
}
@Override
protected void finalize() throws Throwable {
close();
}
}
|
