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

Moved WriteMessageQueue to the util package

Browse Source
This commit is contained in:
Trustin Lee 2008-09-27 11:53:00 +00:00
parent f2c1734636
commit a0d132a4d8
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java
View File

@ -35,6 +35,7 @@ import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelSink;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.util.WriteMessageQueue;
/**
* @author The Netty Project (netty-dev@lists.jboss.org)

8
src/main/java/org/jboss/netty/channel/socket/nio/WriteMessageQueue.java → src/main/java/org/jboss/netty/util/WriteMessageQueue.java
View File

@ -20,7 +20,7 @@
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jboss.netty.channel.socket.nio;
package org.jboss.netty.util;
import java.util.AbstractQueue;
import java.util.Iterator;
@ -35,17 +35,13 @@ import org.jboss.netty.channel.MessageEvent;
* @version $Rev$, $Date$
*
*/
class WriteMessageQueue {
public class WriteMessageQueue {
private static final Queue<MessageEvent> EMPTY_QUEUE = new EmptyQueue();
private MessageEvent[] elements;
private int size;
WriteMessageQueue() {
super();
}
public synchronized void offer(MessageEvent e) {
if (elements == null) {
elements = new MessageEvent[4];