Qortal/altcoinj
3
0
Fork 0
mirror of https://github.com/Qortal/altcoinj.git synced 2025-02-07 06:44:16 +00:00
Code Issues Projects Releases Wiki Activity

Fix FakeChannelSink so events are put into the queue in the right order (BEFORE running event handlers, not after).

Browse Source
This commit is contained in:
Mike Hearn 2012-12-06 15:01:40 +01:00
parent 7bfef81664
commit e20c35bf50
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
core/src/test/java/com/google/bitcoin/core/FakeChannelSink.java
View File

@ -1,18 +1,19 @@
package com.google.bitcoin.core; package com.google.bitcoin.core;
import static org.jboss.netty.channel.Channels.fireChannelConnected;
import org.jboss.netty.channel.*; import org.jboss.netty.channel.*;
import static org.jboss.netty.channel.Channels.fireChannelConnected;
public class FakeChannelSink extends AbstractChannelSink { public class FakeChannelSink extends AbstractChannelSink {
public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws Exception {
throws Exception {
if (e instanceof ChannelStateEvent) { if (e instanceof ChannelStateEvent) {
ChannelStateEvent event = (ChannelStateEvent) e; ChannelStateEvent event = (ChannelStateEvent) e;
FakeChannel channel = FakeChannel channel = (FakeChannel) event.getChannel();
(FakeChannel) event.getChannel(); boolean offered = channel.events.offer(event);
assert offered;
ChannelFuture future = event.getFuture(); ChannelFuture future = event.getFuture();
ChannelState state = event.getState(); ChannelState state = event.getState();
Object value = event.getValue(); Object value = event.getValue();
@ -42,8 +43,6 @@ public class FakeChannelSink extends AbstractChannelSink {
future.setSuccess(); future.setSuccess();
break; break;
} }
boolean offered = channel.events.offer(event);
assert offered;
} else if (e instanceof MessageEvent) { } else if (e instanceof MessageEvent) {
MessageEvent event = (MessageEvent) e; MessageEvent event = (MessageEvent) e;
FakeChannel channel = (FakeChannel) event.getChannel(); FakeChannel channel = (FakeChannel) event.getChannel();