JarURLConnection.java [plain text]
package java.net;
import java.net.*;
import java.io.*;
import java.util.jar.*;
import java.util.zip.*;
import java.util.Map;
import java.util.Vector;
import java.util.Hashtable;
import java.security.cert.Certificate;
public abstract class JarURLConnection extends URLConnection
{
private final URL jarFileURL;
protected URLConnection jarFileURLConnection;
private final String element;
static Hashtable conn_cache = new Hashtable();
public URL getJarFileURL ()
{
return jarFileURL;
}
public String getEntryName ()
{
return element;
}
protected JarURLConnection(URL url)
throws MalformedURLException
{
super(url);
String spec = url.getFile();
int bang = spec.indexOf ("!/", 0);
if (bang == -1)
throw new MalformedURLException (url + ": No `!/' in spec.");
jarFileURL = new URL(spec.substring (0, bang));
element = (bang+2==spec.length() ? null : spec.substring (bang+2));
}
public synchronized void connect() throws IOException
{
if (connected)
return;
if (getUseCaches())
{
jarFileURLConnection = (URLConnection) conn_cache.get (jarFileURL);
if (jarFileURLConnection == null)
{
jarFileURLConnection = jarFileURL.openConnection ();
jarFileURLConnection.setUseCaches (true);
jarFileURLConnection.connect ();
conn_cache.put (jarFileURL, jarFileURLConnection);
}
}
else
{
jarFileURLConnection = jarFileURL.openConnection ();
jarFileURLConnection.connect ();
}
connected = true;
}
public InputStream getInputStream() throws IOException
{
if (!connected)
connect();
if (! doInput)
throw new ProtocolException("Can't open InputStream if doInput is false");
if (element == null)
{
InputStream jar_is = new BufferedInputStream(
jarFileURLConnection.getInputStream ());
return new JarInputStream(jar_is);
}
JarFile jarfile = null;
try
{
jarfile = getJarFile ();
}
catch (java.io.IOException x)
{
}
if (jarfile != null)
{
ZipEntry entry = jarfile.getEntry(element);
if (entry != null)
return jarfile.getInputStream (entry);
else
return null;
}
else
{
JarInputStream zis = new JarInputStream(
jarFileURLConnection.getInputStream ());
for (ZipEntry ent = zis.getNextEntry ();
ent != null;
ent = zis.getNextEntry ())
{
if (element.equals (ent.getName ()))
{
int size = (int)ent.getSize();
byte[] data = new byte[size];
zis.read (data, 0, size);
return new ByteArrayInputStream (data);
}
}
}
return null;
}
public JarEntry getJarEntry () throws IOException
{
JarFile jarfile = null;
if (element == null)
return null;
if (! doInput)
throw new ProtocolException("Can't open JarEntry if doInput is false");
try
{
jarfile = getJarFile ();
}
catch (IOException x)
{
}
if (jarfile == null)
{
JarInputStream zis = new JarInputStream(
jarFileURLConnection.getInputStream ());
for (ZipEntry ent = zis.getNextEntry ();
ent != null;
ent = zis.getNextEntry ())
{
if (element.equals (ent.getName ()))
{
return new JarEntry (ent);
}
}
}
else
{
return jarfile.getJarEntry (element);
}
return null;
}
public abstract JarFile getJarFile() throws IOException;
private Hashtable hdrHash = new Hashtable();
private Vector hdrVec = new Vector();
private boolean gotHeaders = false;
public String getHeaderField(String name)
{
try
{
getHeaders();
}
catch (IOException x)
{
return null;
}
return (String) hdrHash.get(name.toLowerCase());
}
public Map getHeaderFields()
{
try
{
getHeaders();
}
catch (IOException x)
{
return null;
}
return hdrHash;
}
public String getHeaderField(int n)
{
try
{
getHeaders();
}
catch (IOException x)
{
return null;
}
if (n < hdrVec.size())
return getField((String) hdrVec.elementAt(n));
return null;
}
public String getHeaderFieldKey(int n)
{
try
{
getHeaders();
}
catch (IOException x)
{
return null;
}
if (n < hdrVec.size())
return getKey((String) hdrVec.elementAt(n));
return null;
}
private String getKey(String str)
{
if (str == null)
return null;
int index = str.indexOf(':');
if (index >= 0)
return str.substring(0, index);
else
return null;
}
private String getField(String str)
{
if (str == null)
return null;
int index = str.indexOf(':');
if (index >= 0)
return str.substring(index + 1).trim();
else
return str;
}
private void getHeaders() throws IOException
{
if (gotHeaders)
return;
gotHeaders = true;
connect();
long len = -1;
if (element == null)
if (jarFileURLConnection != null)
len = jarFileURLConnection.getContentLength ();
else
{
JarEntry entry = getJarEntry();
if (entry != null)
len = entry.getSize ();
}
String line = "Content-length: " + len;
hdrVec.addElement(line);
String key = getKey(line);
hdrHash.put(key.toLowerCase(), Long.toString(len));
}
public Certificate[] getCertificates() throws IOException
{
return getJarEntry().getCertificates();
}
public Attributes getMainAttributes () throws IOException
{
return getManifest ().getMainAttributes ();
}
public Attributes getAttributes () throws IOException
{
return null;
}
public Manifest getManifest () throws IOException
{
JarFile file = getJarFile ();
return (file != null) ? file.getManifest() : null;
}
}