| Methods Summary |
|---|
| protected void | addHeader(java.lang.String name, java.lang.String value, boolean replace)
Iterator it = header_map.keySet().iterator();
while( it.hasNext()){
String key = (String)it.next();
if ( key.equalsIgnoreCase( name )){
if ( replace ){
it.remove();
}else{
return;
}
}
}
header_map.put( name, value );
|
| protected void | complete()
byte[] reply_bytes = baos.toByteArray();
// System.out.println( "TrackerWebPageResponse::complete: data = " + reply_bytes.length );
String status_string = "BAD";
// random collection
if ( reply_status == 200 ){
status_string = "OK";
}else if ( reply_status == 204 ){
status_string = "No Content";
}else if ( reply_status == 206 ){
status_string = "Partial Content";
}else if ( reply_status == 401 ){
status_string = "Unauthorized";
}else if ( reply_status == 404 ){
status_string = "Not Found";
}else if ( reply_status == 501 ){
status_string = "Not Implemented";
}
String reply_header = "HTTP/1.1 " + reply_status + " " + status_string + NL;
// add header fields if not already present
addHeader( "Server", Constants.AZUREUS_NAME + " " + Constants.AZUREUS_VERSION, false );
addHeader( "Connection", "close", false );
addHeader( "Content-Type", content_type, false );
Iterator it = header_map.keySet().iterator();
while( it.hasNext()){
String name = (String)it.next();
String value = (String)header_map.get(name);
reply_header += name + ": " + value + NL;
}
reply_header +=
"Content-Length: " + reply_bytes.length + NL +
NL;
// System.out.println( "writing reply:" + reply_header );
os.write( reply_header.getBytes());
os.flush();
os.write( reply_bytes );
os.flush();
|
| public java.io.OutputStream | getOutputStream()
return( baos );
|
| public void | setContentType(java.lang.String type)
content_type = type;
|
| public void | setExpires(long time)
String formatted_date = TimeFormatter.getHTTPDate( time );
setHeader( "Expires", formatted_date );
|
| public void | setHeader(java.lang.String name, java.lang.String value)
addHeader( name, value, true );
|
| public void | setLastModified(long time)
String formatted_date = TimeFormatter.getHTTPDate( time );
setHeader( "Last-Modified", formatted_date );
|
| public void | setReplyStatus(int status)
reply_status = status;
|
| public boolean | useFile(java.lang.String root_dir, java.lang.String relative_url)
String target = root_dir + relative_url.replace('/",File.separatorChar);
File canonical_file = new File(target).getCanonicalFile();
// make sure some fool isn't trying to use ../../ to escape from web dir
if ( !canonical_file.toString().startsWith( root_dir )){
return( false );
}
if ( canonical_file.isDirectory()){
return( false );
}
if ( canonical_file.canRead()){
String str = canonical_file.toString().toLowerCase();
int pos = str.lastIndexOf( "." );
if ( pos == -1 ){
return( false );
}
String file_type = str.substring(pos+1);
FileInputStream fis = null;
try{
fis = new FileInputStream(canonical_file);
useStream( file_type, fis );
return( true );
}finally{
if ( fis != null ){
fis.close();
}
}
}
return( false );
|
| public void | useStream(java.lang.String file_type, java.io.InputStream input_stream)
OutputStream os = getOutputStream();
String response_type = HTTPUtils.guessContentTypeFromFileType(file_type);
if ( HTTPUtils.useCompressionForFileType(response_type)){
Map headers = request.getHeaders();
String accept_encoding = (String)headers.get("accept-encoding");
if ( HTTPUtils.canGZIP(accept_encoding)){
os = new GZIPOutputStream(os);
header_map.put("Content-Encoding", "gzip");
}
}
setContentType( response_type );
byte[] buffer = new byte[4096];
while(true){
int len = input_stream.read(buffer);
if ( len <= 0 ){
break;
}
os.write( buffer, 0, len );
}
if ( os instanceof GZIPOutputStream ){
((GZIPOutputStream)os).finish();
}
|
| public void | writeTorrent(org.gudy.azureus2.plugins.tracker.TrackerTorrent tracker_torrent)
try{
TRHostTorrent host_torrent = ((TrackerTorrentImpl)tracker_torrent).getHostTorrent();
TOTorrent torrent = host_torrent.getTorrent();
// make a copy of the torrent
TOTorrent torrent_to_send = TOTorrentFactory.deserialiseFromMap(torrent.serialiseToMap());
// remove any non-standard stuff (e.g. resume data)
torrent_to_send.removeAdditionalProperties();
if ( !TorrentUtils.isDecentralised( torrent_to_send )){
URL[][] url_sets = TRTrackerUtils.getAnnounceURLs();
// if tracker ip not set then assume they know what they're doing
if ( host_torrent.getStatus() != TRHostTorrent.TS_PUBLISHED && url_sets.length > 0 ){
// if the user has disabled the mangling of urls when hosting then don't do it here
// either
if ( COConfigurationManager.getBooleanParameter("Tracker Host Add Our Announce URLs")){
String protocol = torrent_to_send.getAnnounceURL().getProtocol();
for (int i=0;i<url_sets.length;i++){
URL[] urls = url_sets[i];
if ( urls[0].getProtocol().equalsIgnoreCase( protocol )){
torrent_to_send.setAnnounceURL( urls[0] );
torrent_to_send.getAnnounceURLGroup().setAnnounceURLSets( new TOTorrentAnnounceURLSet[0]);
for (int j=1;j<urls.length;j++){
TorrentUtils.announceGroupsInsertLast( torrent_to_send, new URL[]{ urls[j] });
}
break;
}
}
}
}
}
baos.write( BEncoder.encode( torrent_to_send.serialiseToMap()));
setContentType( "application/x-bittorrent" );
}catch( TOTorrentException e ){
Debug.printStackTrace( e );
throw( new IOException( e.toString()));
}
|
