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 com.google.common.base.Verify.verifyNotNull;
  11 import static java.util.Objects.requireNonNull;
  12 import static org.junit.Assert.assertEquals;
  13
  14 import java.io.DataInput;
  15 import java.io.IOException;
  16 import org.apache.commons.lang3.SerializationUtils;
  17 import org.opendaylight.controller.cluster.access.ABIVersion;
  18 import org.opendaylight.yangtools.concepts.WritableIdentifier;
  19
  20 public class FailureEnvelopeTest extends AbstractEnvelopeTest<FailureEnvelope> {
  21     @Override
  22     protected EnvelopeDetails<FailureEnvelope> createEnvelope() {
  23         final var cause = new RuntimeRequestException("msg", new RuntimeException());
  24         final int causeSize = SerializationUtils.serialize(cause).length;
  25         return new EnvelopeDetails<>(new FailureEnvelope(new MockFailure(OBJECT, cause, 42), 1L, 2L, 11L),
  26             causeSize + 216);
  27     }
  28
  29     @Override
  30     protected void doAdditionalAssertions(final FailureEnvelope envelope, final FailureEnvelope resolvedObject) {
  31         assertEquals(envelope.getExecutionTimeNanos(), resolvedObject.getExecutionTimeNanos());
  32         final var expectedCause = envelope.getMessage().getCause();
  33         final var actualCause = resolvedObject.getMessage().getCause();
  34         assertEquals(expectedCause.getMessage(), actualCause.getMessage());
  35         assertEquals(expectedCause.isRetriable(), actualCause.isRetriable());
  36     }
  37
  38     private static class MockRequestFailureProxy implements RequestFailure.SerialForm<WritableIdentifier, MockFailure> {
  39         @java.io.Serial
  40         private static final long serialVersionUID = 5015515628523887221L;
  41
  42         private MockFailure message;
  43
  44         @SuppressWarnings("checkstyle:RedundantModifier")
  45         public MockRequestFailureProxy() {
  46             //For Externalizable
  47         }
  48
  49         private MockRequestFailureProxy(final MockFailure mockFailure) {
  50             message = requireNonNull(mockFailure);
  51         }
  52
  53         @Override
  54         public MockFailure createFailure(final WritableIdentifier target, final long sequence,
  55                 final RequestException failureCause) {
  56             return new MockFailure(target, failureCause, sequence);
  57         }
  58
  59         @Override
  60         public WritableIdentifier readTarget(final DataInput in) throws IOException {
  61             return TransactionIdentifier.readFrom(in);
  62         }
  63
  64         @Override
  65         public MockFailure message() {
  66             return verifyNotNull(message);
  67         }
  68
  69         @Override
  70         public void setMessage(final MockFailure message) {
  71             this.message = requireNonNull(message);
  72         }
  73
  74         @Override
  75         public Object readResolve() {
  76             return message();
  77         }
  78     }
  79
  80     private static class MockFailure extends RequestFailure<WritableIdentifier, MockFailure> {
  81         @java.io.Serial
  82         private static final long serialVersionUID = 1L;
  83
  84         MockFailure(final WritableIdentifier target, final RequestException cause, final long sequence) {
  85             super(target, sequence, cause);
  86         }
  87
  88         @Override
  89         protected RequestFailure.SerialForm<WritableIdentifier, MockFailure> externalizableProxy(
  90                 final ABIVersion version) {
  91             return new MockRequestFailureProxy(this);
  92         }
  93
  94         @Override
  95         protected MockFailure cloneAsVersion(final ABIVersion version) {
  96             return this;
  97         }
  98     }
  99 }