Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
- Application is no longer blocked when programming hundreds of flows. The Barrier...
[controller.git]
/
opendaylight
/
protocol_plugins
/
openflow
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
protocol_plugin
/
openflow
/
core
/
internal
/
PriorityMessage.java
diff --git
a/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/PriorityMessage.java
b/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/PriorityMessage.java
index 2f23d36e073ca9aa6ccc95e335b3bd6295ca419f..0c66dccd013b150e8c8631fdfe33f47b6b219ac2 100644
(file)
--- a/
opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/PriorityMessage.java
+++ b/
opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/PriorityMessage.java
@@
-23,11
+23,18
@@
class PriorityMessage {
int priority;
final static AtomicLong seq = new AtomicLong();
final long seqNum;
int priority;
final static AtomicLong seq = new AtomicLong();
final long seqNum;
-
+ boolean syncReply; // set to true if we want to be blocked until the response arrives
+
public PriorityMessage(OFMessage msg, int priority) {
this.msg = msg;
this.priority = priority;
this.seqNum = seq.getAndIncrement();
public PriorityMessage(OFMessage msg, int priority) {
this.msg = msg;
this.priority = priority;
this.seqNum = seq.getAndIncrement();
+ this.syncReply = false;
+ }
+
+ public PriorityMessage(OFMessage msg, int priority, boolean syncReply) {
+ this(msg, priority);
+ this.syncReply = syncReply;
}
public OFMessage getMsg() {
}
public OFMessage getMsg() {