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