simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/WaitForMessageEvent.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */
   2 package org.opendaylight.openflowjava.protocol.impl.clients;
   3
   4 import java.util.Arrays;
   5
   6 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;
   7 import org.slf4j.Logger;
   8 import org.slf4j.LoggerFactory;
   9
  10
  11
  12 public class WaitForMessageEvent implements ClientEvent {
  13
  14     private static final Logger LOGGER = LoggerFactory.getLogger(WaitForMessageEvent.class);
  15     private byte[] headerExpected;
  16     private byte[] headerReceived;
  17
  18     public WaitForMessageEvent(byte[] headerAwaited) {
  19         this.headerExpected = headerAwaited;
  20     }
  21
  22     @Override
  23     public boolean eventExecuted() {
  24         if (headerReceived == null) {
  25             return false;
  26         }
  27         if (!Arrays.equals(headerExpected, headerReceived)) {
  28             LOGGER.debug("expected msg: " + ByteBufUtils.bytesToHexString(headerExpected));
  29             LOGGER.debug("received msg: " + ByteBufUtils.bytesToHexString(headerReceived));
  30             return false;
  31         }
  32         LOGGER.info("Headers OK");
  33         return true;
  34     }
  35
  36     public void setHeaderReceived(byte[] headerReceived) {
  37         this.headerReceived = headerReceived;
  38     }
  39
  40
  41 }