opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ConnectingClientConnection.java

   1 /*
   2  * Copyright (c) 2016 Cisco Systems, Inc. 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.client;
   9
  10 import java.util.Optional;
  11 import org.opendaylight.controller.cluster.access.concepts.RequestException;
  12
  13 public final class ConnectingClientConnection<T extends BackendInfo> extends AbstractClientConnection<T> {
  14     /**
  15      * A wild estimate on how deep a queue should be. Without having knowledge of the remote actor we can only
  16      * guess its processing capabilities while we are doing initial buffering. With {@link AveragingProgressTracker}
  17      * this boils down to a burst of up to 2000 messages before we start throttling.
  18      */
  19     private static final int TARGET_QUEUE_DEPTH = 4000;
  20
  21     // Initial state, never instantiated externally
  22     ConnectingClientConnection(final ClientActorContext context, final Long cookie, final String backendName) {
  23         super(context, cookie, backendName, TARGET_QUEUE_DEPTH);
  24     }
  25
  26     @Override
  27     public Optional<T> getBackendInfo() {
  28         return Optional.empty();
  29     }
  30
  31     @Override
  32     long backendSilentTicks(final long now) {
  33         // We are still connecting and do not want the timer to attempt a reconnect
  34         return 0;
  35     }
  36
  37     @Override
  38     ClientActorBehavior<T> lockedReconnect(final ClientActorBehavior<T> current, final RequestException cause) {
  39         throw new UnsupportedOperationException("Attempted to reconnect a connecting connection", cause);
  40     }
  41 }