From a6f5af6116e25378bfd8b2ca657972ce2f7ead92 Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Tue, 12 Jun 2012 20:07:47 +0900 Subject: [PATCH] Remove 'public' modifier which is unnecessary --- .../netty/handler/codec/spdy/SpdySession.java | 74 +++++++++---------- 1 file changed, 37 insertions(+), 37 deletions(-) diff --git a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdySession.java b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdySession.java index 2f61fa2d1a..d588b2f3af 100644 --- a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdySession.java +++ b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdySession.java @@ -35,26 +35,26 @@ final class SpdySession { SpdySession() { } - public int numActiveStreams() { + int numActiveStreams() { return activeStreams.size(); } - public boolean noActiveStreams() { + boolean noActiveStreams() { return activeStreams.isEmpty(); } - public boolean isActiveStream(int streamID) { + boolean isActiveStream(int streamID) { return activeStreams.containsKey(new Integer(streamID)); } // Stream-IDs should be iterated in priority order - public Set getActiveStreams() { + Set getActiveStreams() { TreeSet StreamIDs = new TreeSet(new PriorityComparator()); StreamIDs.addAll(activeStreams.keySet()); return StreamIDs; } - public void acceptStream( + void acceptStream( int streamID, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize) { if (!remoteSideClosed || !localSideClosed) { @@ -64,7 +64,7 @@ final class SpdySession { } } - public void removeStream(int streamID) { + void removeStream(int streamID) { Integer StreamID = new Integer(streamID); StreamState state = activeStreams.get(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)); return state == null || state.isRemoteSideClosed(); } - public void closeRemoteSide(int streamID) { + void closeRemoteSide(int streamID) { Integer StreamID = new Integer(streamID); StreamState state = activeStreams.get(StreamID); 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)); return state == null || state.isLocalSideClosed(); } - public void closeLocalSide(int streamID) { + void closeLocalSide(int streamID) { Integer StreamID = new Integer(streamID); StreamState state = activeStreams.get(StreamID); if (state != null) { @@ -114,29 +114,29 @@ final class SpdySession { * no need to synchronize access to the StreamState */ - public boolean hasReceivedReply(int streamID) { + boolean hasReceivedReply(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); return state != null && state.hasReceivedReply(); } - public void receivedReply(int streamID) { + void receivedReply(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); if (state != null) { state.receivedReply(); } } - public int getSendWindowSize(int streamID) { + int getSendWindowSize(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); 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)); 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)); if (deltaWindowSize > 0) { state.setReceiveWindowSizeLowerBound(0); @@ -144,12 +144,12 @@ final class SpdySession { return state != null ? state.updateReceiveWindowSize(deltaWindowSize) : -1; } - public int getReceiveWindowSizeLowerBound(int streamID) { + int getReceiveWindowSizeLowerBound(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); return state != null ? state.getReceiveWindowSizeLowerBound() : 0; } - public void updateAllReceiveWindowSizes(int deltaWindowSize) { + void updateAllReceiveWindowSizes(int deltaWindowSize) { for (StreamState state: activeStreams.values()) { state.updateReceiveWindowSize(deltaWindowSize); 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)); return state != null && state.putPendingWrite(evt); } - public MessageEvent getPendingWrite(int streamID) { + MessageEvent getPendingWrite(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); return state != null ? state.getPendingWrite() : null; } - public MessageEvent removePendingWrite(int streamID) { + MessageEvent removePendingWrite(int streamID) { StreamState state = activeStreams.get(new Integer(streamID)); return state != null ? state.removePendingWrite() : null; } @@ -185,7 +185,7 @@ final class SpdySession { private final ConcurrentLinkedQueue pendingWriteQueue = new ConcurrentLinkedQueue(); - public StreamState( + StreamState( byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize) { this.priority = priority; @@ -195,70 +195,70 @@ final class SpdySession { this.receiveWindowSize = new AtomicInteger(receiveWindowSize); } - public byte getPriority() { + byte getPriority() { return priority; } - public boolean isRemoteSideClosed() { + boolean isRemoteSideClosed() { return remoteSideClosed; } - public void closeRemoteSide() { + void closeRemoteSide() { remoteSideClosed = true; } - public boolean isLocalSideClosed() { + boolean isLocalSideClosed() { return localSideClosed; } - public void closeLocalSide() { + void closeLocalSide() { localSideClosed = true; } - public boolean hasReceivedReply() { + boolean hasReceivedReply() { return receivedReply; } - public void receivedReply() { + void receivedReply() { receivedReply = true; } - public int getSendWindowSize() { + int getSendWindowSize() { return sendWindowSize.get(); } - public int updateSendWindowSize(int deltaWindowSize) { + int updateSendWindowSize(int deltaWindowSize) { return sendWindowSize.addAndGet(deltaWindowSize); } - public int updateReceiveWindowSize(int deltaWindowSize) { + int updateReceiveWindowSize(int deltaWindowSize) { return receiveWindowSize.addAndGet(deltaWindowSize); } - public int getReceiveWindowSizeLowerBound() { + int getReceiveWindowSizeLowerBound() { return receiveWindowSizeLowerBound; } - public void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) { + void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) { this.receiveWindowSizeLowerBound = receiveWindowSizeLowerBound; } - public boolean putPendingWrite(MessageEvent evt) { + boolean putPendingWrite(MessageEvent evt) { return pendingWriteQueue.offer(evt); } - public MessageEvent getPendingWrite() { + MessageEvent getPendingWrite() { return pendingWriteQueue.peek(); } - public MessageEvent removePendingWrite() { + MessageEvent removePendingWrite() { return pendingWriteQueue.poll(); } } private final class PriorityComparator implements Comparator { - public PriorityComparator() { + PriorityComparator() { super(); }