X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fprotocol_plugins%2Fopenflow%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fprotocol_plugin%2Fopenflow%2Fcore%2Finternal%2FPriorityMessage.java;h=0c66dccd013b150e8c8631fdfe33f47b6b219ac2;hb=1bad1b7ca9a87f9e1d32cfcf5a181354fc378ad4;hp=2f23d36e073ca9aa6ccc95e335b3bd6295ca419f;hpb=9fab620d933bab1ddf7eef39087fa515e6d0c988;p=controller.git 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 2f23d36e07..0c66dccd01 100644 --- 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; - + 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(); + this.syncReply = false; + } + + public PriorityMessage(OFMessage msg, int priority, boolean syncReply) { + this(msg, priority); + this.syncReply = syncReply; } public OFMessage getMsg() {