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-10-07 17:55:50 -0700
Browse Files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit
68d90470a4288c100dcc4b97cd9199fcc150ceac
68d90470
1 parent
f5ab5e2c
checkstyle fix
Change-Id: Ib6ac62007480df737cf1d3870565767539d91125
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
2 additions
and
1 deletions
core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
View file @
68d9047
...
...
@@ -124,7 +124,8 @@ public class ClusterCommunicationManager
Endpoint
nodeEp
=
new
Endpoint
(
node
.
ip
().
toString
(),
node
.
tcpPort
());
try
{
log
.
info
(
"sending..."
);
Response
resp
=
messagingService
.
sendAndReceive
(
nodeEp
,
message
.
subject
().
value
(),
SERIALIZER
.
encode
(
message
));
Response
resp
=
messagingService
.
sendAndReceive
(
nodeEp
,
message
.
subject
().
value
(),
SERIALIZER
.
encode
(
message
));
resp
.
get
(
1
,
TimeUnit
.
SECONDS
);
log
.
info
(
"sent..."
);
return
true
;
...
...
Please
register
or
login
to post a comment