andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Remove 'public' modifier which is unnecessary

Browse Source
This commit is contained in:
Trustin Lee 2012-06-12 20:07:47 +09:00
parent 65111fce1d
commit a6f5af6116
1 changed files with 37 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/main/java/org/jboss/netty/handler/codec/spdy/SpdySession.java
View File

@ -35,26 +35,26 @@ final class SpdySession {
SpdySession() { SpdySession() {
} }
public int numActiveStreams() { int numActiveStreams() {
return activeStreams.size(); return activeStreams.size();
} }
public boolean noActiveStreams() { boolean noActiveStreams() {
return activeStreams.isEmpty(); return activeStreams.isEmpty();
} }
public boolean isActiveStream(int streamID) { boolean isActiveStream(int streamID) {
return activeStreams.containsKey(new Integer(streamID)); return activeStreams.containsKey(new Integer(streamID));
} }
// Stream-IDs should be iterated in priority order // Stream-IDs should be iterated in priority order
public Set<Integer> getActiveStreams() { Set<Integer> getActiveStreams() {
TreeSet<Integer> StreamIDs = new TreeSet<Integer>(new PriorityComparator()); TreeSet<Integer> StreamIDs = new TreeSet<Integer>(new PriorityComparator());
StreamIDs.addAll(activeStreams.keySet()); StreamIDs.addAll(activeStreams.keySet());
return StreamIDs; return StreamIDs;
} }
public void acceptStream( void acceptStream(
int streamID, byte priority, boolean remoteSideClosed, boolean localSideClosed, int streamID, byte priority, boolean remoteSideClosed, boolean localSideClosed,
int sendWindowSize, int receiveWindowSize) { int sendWindowSize, int receiveWindowSize) {
if (!remoteSideClosed || !localSideClosed) { if (!remoteSideClosed || !localSideClosed) {
@ -64,7 +64,7 @@ final class SpdySession {
} }
} }
public void removeStream(int streamID) { void removeStream(int streamID) {
Integer StreamID = new Integer(streamID); Integer StreamID = new Integer(streamID);
StreamState state = activeStreams.get(StreamID); StreamState state = activeStreams.get(StreamID);
activeStreams.remove(StreamID); activeStreams.remove(StreamID);
@ -77,12 +77,12 @@ final class SpdySession {
} }
} }
public boolean isRemoteSideClosed(int streamID) { boolean isRemoteSideClosed(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state == null || state.isRemoteSideClosed(); return state == null || state.isRemoteSideClosed();
} }
public void closeRemoteSide(int streamID) { void closeRemoteSide(int streamID) {
Integer StreamID = new Integer(streamID); Integer StreamID = new Integer(streamID);
StreamState state = activeStreams.get(StreamID); StreamState state = activeStreams.get(StreamID);
if (state != null) { if (state != null) {
@ -93,12 +93,12 @@ final class SpdySession {
} }
} }
public boolean isLocalSideClosed(int streamID) { boolean isLocalSideClosed(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state == null || state.isLocalSideClosed(); return state == null || state.isLocalSideClosed();
} }
public void closeLocalSide(int streamID) { void closeLocalSide(int streamID) {
Integer StreamID = new Integer(streamID); Integer StreamID = new Integer(streamID);
StreamState state = activeStreams.get(StreamID); StreamState state = activeStreams.get(StreamID);
if (state != null) { if (state != null) {
@ -114,29 +114,29 @@ final class SpdySession {
* no need to synchronize access to the StreamState * no need to synchronize access to the StreamState
*/ */
public boolean hasReceivedReply(int streamID) { boolean hasReceivedReply(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null && state.hasReceivedReply(); return state != null && state.hasReceivedReply();
} }
public void receivedReply(int streamID) { void receivedReply(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
if (state != null) { if (state != null) {
state.receivedReply(); state.receivedReply();
} }
} }
public int getSendWindowSize(int streamID) { int getSendWindowSize(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null ? state.getSendWindowSize() : -1; return state != null ? state.getSendWindowSize() : -1;
} }
public int updateSendWindowSize(int streamID, int deltaWindowSize) { int updateSendWindowSize(int streamID, int deltaWindowSize) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null ? state.updateSendWindowSize(deltaWindowSize) : -1; return state != null ? state.updateSendWindowSize(deltaWindowSize) : -1;
} }
public int updateReceiveWindowSize(int streamID, int deltaWindowSize) { int updateReceiveWindowSize(int streamID, int deltaWindowSize) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
if (deltaWindowSize > 0) { if (deltaWindowSize > 0) {
state.setReceiveWindowSizeLowerBound(0); state.setReceiveWindowSizeLowerBound(0);
@ -144,12 +144,12 @@ final class SpdySession {
return state != null ? state.updateReceiveWindowSize(deltaWindowSize) : -1; return state != null ? state.updateReceiveWindowSize(deltaWindowSize) : -1;
} }
public int getReceiveWindowSizeLowerBound(int streamID) { int getReceiveWindowSizeLowerBound(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null ? state.getReceiveWindowSizeLowerBound() : 0; return state != null ? state.getReceiveWindowSizeLowerBound() : 0;
} }
public void updateAllReceiveWindowSizes(int deltaWindowSize) { void updateAllReceiveWindowSizes(int deltaWindowSize) {
for (StreamState state: activeStreams.values()) { for (StreamState state: activeStreams.values()) {
state.updateReceiveWindowSize(deltaWindowSize); state.updateReceiveWindowSize(deltaWindowSize);
if (deltaWindowSize < 0) { if (deltaWindowSize < 0) {
@ -158,17 +158,17 @@ final class SpdySession {
} }
} }
public boolean putPendingWrite(int streamID, MessageEvent evt) { boolean putPendingWrite(int streamID, MessageEvent evt) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null && state.putPendingWrite(evt); return state != null && state.putPendingWrite(evt);
} }
public MessageEvent getPendingWrite(int streamID) { MessageEvent getPendingWrite(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null ? state.getPendingWrite() : null; return state != null ? state.getPendingWrite() : null;
} }
public MessageEvent removePendingWrite(int streamID) { MessageEvent removePendingWrite(int streamID) {
StreamState state = activeStreams.get(new Integer(streamID)); StreamState state = activeStreams.get(new Integer(streamID));
return state != null ? state.removePendingWrite() : null; return state != null ? state.removePendingWrite() : null;
} }
@ -185,7 +185,7 @@ final class SpdySession {
private final ConcurrentLinkedQueue<MessageEvent> pendingWriteQueue = private final ConcurrentLinkedQueue<MessageEvent> pendingWriteQueue =
new ConcurrentLinkedQueue<MessageEvent>(); new ConcurrentLinkedQueue<MessageEvent>();
public StreamState( StreamState(
byte priority, boolean remoteSideClosed, boolean localSideClosed, byte priority, boolean remoteSideClosed, boolean localSideClosed,
int sendWindowSize, int receiveWindowSize) { int sendWindowSize, int receiveWindowSize) {
this.priority = priority; this.priority = priority;
@ -195,70 +195,70 @@ final class SpdySession {
this.receiveWindowSize = new AtomicInteger(receiveWindowSize); this.receiveWindowSize = new AtomicInteger(receiveWindowSize);
} }
public byte getPriority() { byte getPriority() {
return priority; return priority;
} }
public boolean isRemoteSideClosed() { boolean isRemoteSideClosed() {
return remoteSideClosed; return remoteSideClosed;
} }
public void closeRemoteSide() { void closeRemoteSide() {
remoteSideClosed = true; remoteSideClosed = true;
} }
public boolean isLocalSideClosed() { boolean isLocalSideClosed() {
return localSideClosed; return localSideClosed;
} }
public void closeLocalSide() { void closeLocalSide() {
localSideClosed = true; localSideClosed = true;
} }
public boolean hasReceivedReply() { boolean hasReceivedReply() {
return receivedReply; return receivedReply;
} }
public void receivedReply() { void receivedReply() {
receivedReply = true; receivedReply = true;
} }
public int getSendWindowSize() { int getSendWindowSize() {
return sendWindowSize.get(); return sendWindowSize.get();
} }
public int updateSendWindowSize(int deltaWindowSize) { int updateSendWindowSize(int deltaWindowSize) {
return sendWindowSize.addAndGet(deltaWindowSize); return sendWindowSize.addAndGet(deltaWindowSize);
} }
public int updateReceiveWindowSize(int deltaWindowSize) { int updateReceiveWindowSize(int deltaWindowSize) {
return receiveWindowSize.addAndGet(deltaWindowSize); return receiveWindowSize.addAndGet(deltaWindowSize);
} }
public int getReceiveWindowSizeLowerBound() { int getReceiveWindowSizeLowerBound() {
return receiveWindowSizeLowerBound; return receiveWindowSizeLowerBound;
} }
public void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) { void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) {
this.receiveWindowSizeLowerBound = receiveWindowSizeLowerBound; this.receiveWindowSizeLowerBound = receiveWindowSizeLowerBound;
} }
public boolean putPendingWrite(MessageEvent evt) { boolean putPendingWrite(MessageEvent evt) {
return pendingWriteQueue.offer(evt); return pendingWriteQueue.offer(evt);
} }
public MessageEvent getPendingWrite() { MessageEvent getPendingWrite() {
return pendingWriteQueue.peek(); return pendingWriteQueue.peek();
} }
public MessageEvent removePendingWrite() { MessageEvent removePendingWrite() {
return pendingWriteQueue.poll(); return pendingWriteQueue.poll();
} }
} }
private final class PriorityComparator implements Comparator<Integer> { private final class PriorityComparator implements Comparator<Integer> {
public PriorityComparator() { PriorityComparator() {
super(); super();
} }