Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.fasterxml.clustermate.client.operation;
 
 import java.util.*;
 
 
 public class OperationBase<K extends EntryKey,
    CONFIG extends StoreClientConfig<K, CONFIG>
    protected final CONFIG _config;
    protected final OperationConfig _operationConfig;
    protected final CallConfig _callConfig;
    protected final boolean _noRetries;
    
    protected final long _startTime;
    protected final K _key;
    public OperationBase(CONFIG configlong startTime, K key)
    {
         = config;
         = config.getOperationConfig();
         = config.getCallConfig();
         = !config.getOperationConfig().getAllowRetries();
         = startTime;
         = key;
    }
    /*
    /**********************************************************************
    /* Helper methods for sub-classes
    /**********************************************************************
     */
    protected <T> List<T> _add(List<T> list, T entry) {
        if (list == null) {
            list = new LinkedList<T>();
        }
        list.add(entry);
        return list;
    }
    
    protected void _doDelay(long startTimelong currTimelong endTime)
        throws InterruptedException
    {
        long timeSpent = currTime - startTime;
        // only add delay if we have had quick failures (signaling overload)
        if (timeSpent < 1000L) {
            long timeLeft = endTime - currTime;
            // also, only wait if we still have some time; and then modest amount (250 mecs)
            if (timeLeft >= (4 * .)) {
                Thread.sleep(.);
            }
        }
    }
New to GrepCode? Check out our FAQ X