Toggle navigation
Toggle navigation
This project
Loading...
Sign in
홍길동
/
onos
Go to a project
Toggle navigation
Toggle navigation pinning
Projects
Groups
Snippets
Help
Project
Activity
Repository
Pipelines
Graphs
Issues
0
Merge Requests
0
Wiki
Snippets
Network
Create a new issue
Builds
Commits
Issue Boards
Authored by
Yuta HIGUCHI
2014-11-04 17:22:26 -0800
Browse Files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit
5e8ceb455e0484b8125d3afc677ef2f379759944
5e8ceb45
1 parent
08822c42
checkstyle fixes
Change-Id: Ida02536e61f61b8883810866d28bdaad206f645d
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
7 additions
and
3 deletions
core/api/src/test/java/org/onlab/onos/event/DefaultEventSinkRegistryTest.java
utils/netty/src/main/java/org/onlab/netty/MessageDecoder.java
core/api/src/test/java/org/onlab/onos/event/DefaultEventSinkRegistryTest.java
View file @
5e8ceb4
...
...
@@ -28,11 +28,15 @@ public class DefaultEventSinkRegistryTest {
private
DefaultEventSinkRegistry
registry
;
private
static
class
FooEvent
extends
TestEvent
{
public
FooEvent
(
String
subject
)
{
super
(
Type
.
FOO
,
subject
);
}
public
FooEvent
(
String
subject
)
{
super
(
Type
.
FOO
,
subject
);
}
}
private
static
class
BarEvent
extends
TestEvent
{
public
BarEvent
(
String
subject
)
{
super
(
Type
.
BAR
,
subject
);
}
public
BarEvent
(
String
subject
)
{
super
(
Type
.
BAR
,
subject
);
}
}
private
static
class
FooSink
implements
EventSink
<
FooEvent
>
{
...
...
utils/netty/src/main/java/org/onlab/netty/MessageDecoder.java
View file @
5e8ceb4
...
...
@@ -50,7 +50,7 @@ public class MessageDecoder extends ReplayingDecoder<DecoderState> {
ByteBuf
buffer
,
List
<
Object
>
out
)
throws
Exception
{
switch
(
state
())
{
switch
(
state
())
{
case
READ_HEADER_VERSION:
int
headerVersion
=
buffer
.
readInt
();
checkState
(
headerVersion
==
MessageEncoder
.
HEADER_VERSION
,
"Unexpected header version"
);
...
...
Please
register
or
login
to post a comment