/**
     * The timeout duration (in milliseconds) for idle connections.
     */
    private final long idleConnectionTimeout;

    /**
     * Constructs a new HcConnectionMonitorTarget.
     * @param clientConnectionManager The HttpClientConnectionManager to monitor.
     * @param idleConnectionTimeout The idle connection timeout in milliseconds.
     */

			// Now we swap in a new.
			newAcc := &AccElem{}
			old := e.cached.Swap(newAcc)
			var a AccElem
			a.Size = atomic.LoadInt64(&old.Size)
			a.Total = atomic.LoadInt64(&old.Total)
			a.N = atomic.LoadInt64(&old.N)
			e.mu.Lock()
			e.addAll(t-1, a)
			e.mu.Unlock()
			acc = newAcc
		} else {
			// We may be able to grab the new accumulator by yielding.
			runtime.Gosched()

                this.setEndDate(end);
            }

            //update the calendars so all clickable dates reflect the new time component
            this.updateCalendars();

            //update the form inputs above the calendars with the new time
            this.updateFormInputs();

            //re-render the time pickers because changing one selection can affect what's enabled in another

    * Eviction behavior depends on the mode in which NodeController is operating:
      * if the new state is "partialDisruption" or "fullDisruption" we call a user defined function that returns a new QPS to use (default 1/10 of the default rate, and the default rate respectively),
      * if the new state is "normal" we resume normal operation (go back to default limiter settings),

        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public BehaviorExceptionThrower assistBehaviorExceptionThrower() {
        return new BehaviorExceptionThrower();
    }

    @Override
    public GearedCipherManager assistGearedCipherManager() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override

 * including total record count, page size, and current page number.
 */
public class SynonymPager implements Serializable {

    /**
     * Constructs a new pager for synonyms.
     */
    public SynonymPager() {
        // do nothing
    }

    private static final long serialVersionUID = 1L;

    /** The total number of records. */
    private int allRecordCount;

 * file authentication settings used by the Fess search engine.
 */
public class FileAuthenticationService {

    /**
     * Default constructor for file authentication service.
     * Creates a new instance with default values.
     */
    public FileAuthenticationService() {
        // Default constructor
    }

    /**
     * Behavior class for file authentication database operations.
     */

 *     Arrays.asList("a", "b", "c", "d", "e");
 * List<String> actualElements =
 *     Collections.unmodifiableList(
 *         Arrays.asList("a", "b", "c", "d", "e"));
 * IteratorTester<String> iteratorTester =
 *     new IteratorTester<String>(
 *         6,
 *         IteratorFeature.UNMODIFIABLE,
 *         expectedElements,
 *         IteratorTester.KnownOrder.KNOWN_ORDER) {
 *       @Override

     */
    @Override
    protected Smb2ChangeNotifyResponse createResponse(final CIFSContext tc,
            final ServerMessageBlock2Request<Smb2ChangeNotifyResponse> req) {
        return new Smb2ChangeNotifyResponse(tc.getConfig());
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size() {

     * the path associated with this <code>SmbResource</code> object will not
     * change). To access the renamed file it is necessary to construct a
     * new <code>SmbResource</code></i>.
     *
     * @param dest
     *            An <code>SmbResource</code> that represents the new pathname
     * @throws CIFSException if an error occurs renaming the resource
     * @throws NullPointerException