Examples of ExponentialBackoffRetry

com.bazaarvoice.ostrich.retry.ExponentialBackoffRetry
A retry policy that permits a fixed number of attempts at executing an operation. After each attempt the application will delay for a bounded exponentially increasing time period before trying again. The actual delay interval is randomized to avoid the "thundering herd" effect when there are many clients all attempting to retry at the same time.
com.netflix.curator.retry.ExponentialBackoffRetry
org.apache.curator.retry.ExponentialBackoffRetry
Retry policy that retries a set number of times with increasing sleep time between retries
tachyon.retry.ExponentialBackoffRetry
Each retry will cause a sleep to happen. This sleep will grow over time exponentially so each sleep gets much larger than the last. To make sure that this growth does not grow out of control, a max sleep is used as a bounding.

Examples of org.apache.curator.retry.ExponentialBackoffRetry

        final int                 itemQty = 1000;
        final int                 consumerQty = 4;


        Timing                    timing = new Timing();


        CuratorFramework          client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new ExponentialBackoffRetry(100, 3));
        client.start();
        try
        {
            DistributedQueue<TestQueueItem> producerQueue = QueueBuilder.builder(client, null, serializer, QUEUE_PATH).buildQueue();
            try

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

{
    @Test
    public void     testLostSession() throws Exception
    {
        Timing                  timing = new Timing();
        CuratorFramework        client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new ExponentialBackoffRetry(100, 3));
        try
        {
            client.start();


            client.create().forPath("/test-me");

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    {
        Timing                  timing = new Timing();
        CuratorFramework        client = CuratorFrameworkFactory.builder().connectString(server.getConnectString())
            .sessionTimeoutMs(timing.session())
            .connectionTimeoutMs(timing.connection())
            .retryPolicy(new ExponentialBackoffRetry(100, 3))
            .namespace("aisa")
            .build();
        try
        {
            client.start();

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    {
        Timing                  timing = new Timing();
        CuratorFramework        client = CuratorFrameworkFactory.builder().connectString(server.getConnectString())
            .sessionTimeoutMs(timing.session())
            .connectionTimeoutMs(timing.connection())
            .retryPolicy(new ExponentialBackoffRetry(100, 3))
            .build();
        try
        {
            client.start();

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry


    @Test
    public void testWaitingProcessKilledServer() throws Exception
    {
        final Timing timing = new Timing();
        final CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new ExponentialBackoffRetry(100, 3));
        try
        {
            client.start();


            final CountDownLatch latch = new CountDownLatch(1);

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    @Test
    public void testKilledSession() throws Exception
    {
        final Timing timing = new Timing();


        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new ExponentialBackoffRetry(100, 3));
        client.start();
        try
        {
            final InterProcessLock mutex1 = makeLock(client);
            final InterProcessLock mutex2 = makeLock(client);

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    @Test
    public void testWithNamespace() throws Exception
    {
        CuratorFramework client = CuratorFrameworkFactory.builder().
            connectString(server.getConnectString()).
            retryPolicy(new ExponentialBackoffRetry(100, 3)).
            namespace("test").
            build();
        client.start();
        try
        {

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    @Test
    public void testReentrantSingleLock() throws Exception
    {
        final int THREAD_QTY = 10;


        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), new ExponentialBackoffRetry(100, 3));
        client.start();
        try
        {
            final AtomicBoolean hasLock = new AtomicBoolean(false);
            final AtomicBoolean isFirst = new AtomicBoolean(true);

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    }


    @Test
    public void testReentrant2Threads() throws Exception
    {
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), new ExponentialBackoffRetry(100, 3));
        client.start();
        try
        {
            waitLatchForBar = new CountDownLatch(1);
            countLatchForBar = new CountDownLatch(1);

View Full Code Here

Examples of org.apache.curator.retry.ExponentialBackoffRetry

    }


    @Test
    public void testReentrant() throws Exception
    {
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), new ExponentialBackoffRetry(100, 3));
        client.start();
        try
        {
            InterProcessLock mutex = makeLock(client);
            foo(mutex);

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.