misc findbugs cleanups

This commit is contained in:
Greg Wilkins 2011-09-07 15:57:18 +10:00
parent cf45e7b647
commit 65a1e84886
9 changed files with 42 additions and 40 deletions

View File

@ -334,7 +334,9 @@ public class HttpFields
{ {
if (__cache.size()>__cacheSize) if (__cache.size()>__cacheSize)
__cache.clear(); __cache.clear();
__cache.putIfAbsent(value,buffer); Buffer b=__cache.putIfAbsent(value,buffer);
if (b!=null)
buffer=b;
} }
return buffer; return buffer;

View File

@ -35,8 +35,8 @@ import org.eclipse.jetty.util.StringUtil;
*/ */
public class GzipResponseWrapper extends HttpServletResponseWrapper public class GzipResponseWrapper extends HttpServletResponseWrapper
{ {
public static int DEFAULT_BUFFER_SIZE = 8192; public static final int DEFAULT_BUFFER_SIZE = 8192;
public static int DEFAULT_MIN_GZIP_SIZE = 256; public static final int DEFAULT_MIN_GZIP_SIZE = 256;
private HttpServletRequest _request; private HttpServletRequest _request;
private Set<String> _mimeTypes; private Set<String> _mimeTypes;

View File

@ -14,6 +14,7 @@
package org.eclipse.jetty.http.security; package org.eclipse.jetty.http.security;
import java.io.Serializable; import java.io.Serializable;
import java.util.Arrays;
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
/** /**
@ -209,7 +210,7 @@ public class Constraint implements Cloneable, Serializable
{ {
return "SC{" + _name return "SC{" + _name
+ "," + ","
+ (_anyRole ? "*" : (_roles == null ? "-" : _roles.toString())) + (_anyRole ? "*" : (_roles == null ? "-" : Arrays.asList(_roles).toString()))
+ "," + ","
+ (_dataConstraint == DC_UNSET ? "DC_UNSET}" : (_dataConstraint == DC_NONE ? "NONE}" : (_dataConstraint == DC_INTEGRAL ? "INTEGRAL}" : "CONFIDENTIAL}"))); + (_dataConstraint == DC_UNSET ? "DC_UNSET}" : (_dataConstraint == DC_NONE ? "NONE}" : (_dataConstraint == DC_INTEGRAL ? "INTEGRAL}" : "CONFIDENTIAL}")));
} }

View File

@ -152,12 +152,22 @@ public class Password extends Credential
{ {
case 1: case 1:
buf.append('0'); buf.append('0');
buf.append('0');
buf.append('0');
buf.append(x);
break;
case 2: case 2:
buf.append('0'); buf.append('0');
buf.append('0');
buf.append(x);
break;
case 3: case 3:
buf.append('0'); buf.append('0');
buf.append(x);
break;
default: default:
buf.append(x); buf.append(x);
break;
} }
} }
return buf.toString(); return buf.toString();

View File

@ -387,7 +387,7 @@ public abstract class SelectorManager extends AbstractLifeCycle implements Dumpa
private final ConcurrentLinkedQueue<Object> _changes = new ConcurrentLinkedQueue<Object>(); private final ConcurrentLinkedQueue<Object> _changes = new ConcurrentLinkedQueue<Object>();
private Selector _selector; private volatile Selector _selector;
private volatile Thread _selecting; private volatile Thread _selecting;
private int _jvmBug; private int _jvmBug;
@ -975,7 +975,8 @@ public abstract class SelectorManager extends AbstractLifeCycle implements Dumpa
// close endpoints and selector // close endpoints and selector
synchronized (this) synchronized (this)
{ {
for (SelectionKey key:_selector.keys()) Selector selector=_selector;
for (SelectionKey key:selector.keys())
{ {
if (key==null) if (key==null)
continue; continue;
@ -998,8 +999,9 @@ public abstract class SelectorManager extends AbstractLifeCycle implements Dumpa
_timeout.cancelAll(); _timeout.cancelAll();
try try
{ {
if (_selector != null) selector=_selector;
_selector.close(); if (selector != null)
selector.close();
} }
catch (IOException e) catch (IOException e)
{ {

View File

@ -300,7 +300,12 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
} }
} }
} }
catch (Exception x) catch (ThreadDeath x)
{
super.close();
throw x;
}
catch (Throwable x)
{ {
LOG.debug(x); LOG.debug(x);
super.close(); super.close();
@ -444,8 +449,11 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
case BUFFER_OVERFLOW: case BUFFER_OVERFLOW:
case BUFFER_UNDERFLOW: case BUFFER_UNDERFLOW:
LOG.warn("wrap {}",_result); LOG.warn("wrap {}",_result);
_closing=true;
break;
case CLOSED: case CLOSED:
_closing=true; _closing=true;
break;
} }
_outNIOBuffer.setPutIndex(put+_result.bytesProduced()); _outNIOBuffer.setPutIndex(put+_result.bytesProduced());
@ -500,7 +508,7 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException
{ {
int consumed=0; int consumed=0;
int available=header.length(); int available=header==null?0:header.length();
if (buffer!=null) if (buffer!=null)
available+=buffer.length(); available+=buffer.length();
@ -599,8 +607,11 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
case BUFFER_OVERFLOW: case BUFFER_OVERFLOW:
case BUFFER_UNDERFLOW: case BUFFER_UNDERFLOW:
LOG.warn("unwrap {}",_result); LOG.warn("unwrap {}",_result);
_closing=true;
break;
case CLOSED: case CLOSED:
_closing=true; _closing=true;
break;
} }
_outNIOBuffer.setPutIndex(put+_result.bytesProduced()); _outNIOBuffer.setPutIndex(put+_result.bytesProduced());
} }
@ -895,6 +906,8 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
case BUFFER_OVERFLOW: case BUFFER_OVERFLOW:
case BUFFER_UNDERFLOW: case BUFFER_UNDERFLOW:
LOG.warn("unwrap {}",_result); LOG.warn("unwrap {}",_result);
_closing=true;
return _result.bytesConsumed()>0?_result.bytesConsumed():-1;
case OK: case OK:
return _result.bytesConsumed(); return _result.bytesConsumed();
@ -965,6 +978,8 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
case BUFFER_OVERFLOW: case BUFFER_OVERFLOW:
case BUFFER_UNDERFLOW: case BUFFER_UNDERFLOW:
LOG.warn("unwrap {}",_result); LOG.warn("unwrap {}",_result);
_closing=true;
return _result.bytesConsumed()>0?_result.bytesConsumed():-1;
case OK: case OK:
return _result.bytesConsumed(); return _result.bytesConsumed();

View File

@ -42,33 +42,4 @@ public class IOTest
out.toString(), out.toString(),
"The quick brown fox jumped over the lazy dog"); "The quick brown fox jumped over the lazy dog");
} }
@Test
public void testStringSpeed()
{
String s="012345678901234567890000000000000000000000000";
char[] ca = new char[s.length()];
int loops=1000000;
long start=System.currentTimeMillis();
long result=0;
for (int loop=0;loop<loops;loop++)
{
for (int c=s.length();c-->0;)
result+=s.charAt(c);
}
long end=System.currentTimeMillis();
System.err.println("charAt "+(end-start)+" "+result);
start=System.currentTimeMillis();
result=0;
for (int loop=0;loop<loops;loop++)
{
s.getChars(0, s.length(), ca, 0);
for (int c=s.length();c-->0;)
result+=ca[c];
}
end=System.currentTimeMillis();
System.err.println("getChars "+(end-start)+" "+result);
}
} }

View File

@ -115,6 +115,7 @@ public class DigestAuthenticator extends LoginAuthenticator
break; break;
case ',': case ',':
name = null; name = null;
break;
case ' ': case ' ':
break; break;

View File

@ -80,7 +80,7 @@ public class WebSocketClientTest
{ {
} }
}; };
Future<WebSocket.Connection> future = client.open(new URI("ws://127.0.0.1:" + _serverPort + "/"), websocket); client.open(new URI("ws://127.0.0.1:" + _serverPort + "/"), websocket);
Socket socket = _server.accept(); Socket socket = _server.accept();
accept(socket); accept(socket);