opendaylight/md-sal/cds-access-api/src/test/java/org/opendaylight/controller/cluster/access/concepts/FailureEnvelopeTest.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.cluster.access.concepts;
   9
  10 import static org.junit.Assert.assertEquals;
  11
  12 import java.io.DataInput;
  13 import java.io.IOException;
  14 import java.io.Serial;
  15 import org.apache.commons.lang.SerializationUtils;
  16 import org.opendaylight.controller.cluster.access.ABIVersion;
  17 import org.opendaylight.yangtools.concepts.WritableIdentifier;
  18
  19 public class FailureEnvelopeTest extends AbstractEnvelopeTest<FailureEnvelope> {
  20     @Override
  21     protected EnvelopeDetails<FailureEnvelope> createEnvelope() {
  22         final var cause = new RuntimeRequestException("msg", new RuntimeException());
  23         final int causeSize = SerializationUtils.serialize(cause).length;
  24         return new EnvelopeDetails<>(new FailureEnvelope(new MockFailure(OBJECT, cause, 42), 1L, 2L, 11L),
  25             causeSize + 687);
  26     }
  27
  28     @Override
  29     protected void doAdditionalAssertions(final FailureEnvelope envelope, final FailureEnvelope resolvedObject) {
  30         assertEquals(envelope.getExecutionTimeNanos(), resolvedObject.getExecutionTimeNanos());
  31         final var expectedCause = envelope.getMessage().getCause();
  32         final var actualCause = resolvedObject.getMessage().getCause();
  33         assertEquals(expectedCause.getMessage(), actualCause.getMessage());
  34         assertEquals(expectedCause.isRetriable(), actualCause.isRetriable());
  35     }
  36
  37     private static class MockRequestFailureProxy extends AbstractRequestFailureProxy<WritableIdentifier, MockFailure> {
  38         @Serial
  39         private static final long serialVersionUID = 5015515628523887221L;
  40
  41         @SuppressWarnings("checkstyle:RedundantModifier")
  42         public MockRequestFailureProxy() {
  43             //For Externalizable
  44         }
  45
  46         private MockRequestFailureProxy(final MockFailure mockFailure) {
  47             super(mockFailure);
  48         }
  49
  50         @Override
  51         protected MockFailure createFailure(final WritableIdentifier target, final long sequence,
  52                                             final RequestException failureCause) {
  53             return new MockFailure(target, failureCause, sequence);
  54         }
  55
  56         @Override
  57         protected WritableIdentifier readTarget(final DataInput in) throws IOException {
  58             return TransactionIdentifier.readFrom(in);
  59         }
  60     }
  61
  62     private static class MockFailure extends RequestFailure<WritableIdentifier, MockFailure> {
  63         @Serial
  64         private static final long serialVersionUID = 1L;
  65
  66         MockFailure(final WritableIdentifier target, final RequestException cause, final long sequence) {
  67             super(target, sequence, cause);
  68         }
  69
  70         @Override
  71         protected AbstractRequestFailureProxy<WritableIdentifier, MockFailure> externalizableProxy(
  72                 final ABIVersion version) {
  73             return new MockRequestFailureProxy(this);
  74         }
  75
  76         @Override
  77         protected MockFailure cloneAsVersion(final ABIVersion version) {
  78             return this;
  79         }
  80     }
  81 }