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-05 16:42:12 -0800
Browse Files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit
39ae550bacf8057443cd8083c327c2e5d4b71486
39ae550b
1 parent
661b9b27
log related fixes
Change-Id: Ie83feb7b135c046319ef76e9204b07ecc25caf02
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
8 additions
and
3 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/service/impl/DatabaseStateMachine.java
core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
View file @
39ae550
...
...
@@ -159,7 +159,7 @@ public class ClusterCommunicationManager
return
messagingService
.
sendAndReceive
(
nodeEp
,
message
.
subject
().
value
(),
SERIALIZER
.
encode
(
message
));
}
catch
(
IOException
e
)
{
log
.
error
(
"Failed interaction with remote nodeId: "
+
toNodeId
,
e
);
log
.
trace
(
"Failed interaction with remote nodeId: "
+
toNodeId
,
e
);
throw
e
;
}
}
...
...
core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseStateMachine.java
View file @
39ae550
package
org
.
onlab
.
onos
.
store
.
service
.
impl
;
import
static
org
.
slf4j
.
LoggerFactory
.
getLogger
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.Map
;
...
...
@@ -16,6 +18,7 @@ import org.onlab.onos.store.service.VersionedValue;
import
org.onlab.onos.store.service.WriteRequest
;
import
org.onlab.onos.store.service.WriteResult
;
import
org.onlab.util.KryoNamespace
;
import
org.slf4j.Logger
;
import
com.google.common.collect.Maps
;
...
...
@@ -28,6 +31,8 @@ import com.google.common.collect.Maps;
*/
public
class
DatabaseStateMachine
implements
StateMachine
{
private
final
Logger
log
=
getLogger
(
getClass
());
public
static
final
KryoSerializer
SERIALIZER
=
new
KryoSerializer
()
{
@Override
protected
void
setupKryoPool
()
{
...
...
@@ -161,7 +166,7 @@ public class DatabaseStateMachine implements StateMachine {
try
{
return
SERIALIZER
.
encode
(
state
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
(
);
log
.
error
(
"Snapshot serialization error"
,
e
);
return
null
;
}
}
...
...
@@ -171,7 +176,7 @@ public class DatabaseStateMachine implements StateMachine {
try
{
this
.
state
=
SERIALIZER
.
decode
(
data
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
(
);
log
.
error
(
"Snapshot deserialization error"
,
e
);
}
}
}
...
...
Please
register
or
login
to post a comment