List of stable() Examples

Examples of stable()

org.jgroups.stack.NakReceiverWindow.stable()
Delete all messages <= seqno (they are stable, that is, have been received at all members). Stop when a number> seqno is encountered (all messages are ordered on seqnos).

Examples of org.jgroups.stack.NakReceiverWindow.stable()


    @ManagedOperation(description="Purges highes delivered messages and compacts the retransmission tables")
    public void purgeAndCompact() {
        for(Map.Entry<Address,ReceiverEntry> entry: recv_table.entrySet()) {
            NakReceiverWindow win=entry.getValue().received_msgs;
            win.stable(win.getHighestDelivered());
            win.compact();
        }
    }

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

        ReceiverEntry entry=recv_table.get(dest);
        NakReceiverWindow win=entry != null? entry.received_msgs : null;
        if(win != null) {
            //System.out.println("[" + local_addr + "] stable(" + dest + ", hd=" + win.getHighestDelivered() + "): " +
              //                   "win: " + win);
            win.stable(win.getHighestDelivered());
        }
    }




    private void startStableTask() {

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            win.add(2, new Message());
            win.add(3, new Message());
            win.add(4, new Message());
            check(win, 0, 4, 0);
            System.out.println("Note that the subsequent warning is expected:");
            win.stable(4); // no-op because we haven't even removed 4 messages
            check(win, 0, 4, 0);
            while(win.remove() != null);
            check(win, 0, 4, 4);
            win.stable(4);
            check(win, 4, 4, 4);

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            System.out.println("Note that the subsequent warning is expected:");
            win.stable(4); // no-op because we haven't even removed 4 messages
            check(win, 0, 4, 0);
            while(win.remove() != null);
            check(win, 0, 4, 4);
            win.stable(4);
            check(win, 4, 4, 4);
        }
        finally {
            timer.stop();
        }

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            win.add(102, new Message());
            win.add(103, new Message());
            System.out.println("win: " + win);
            check(win, 50, 103, 100);
            System.out.println("Note that the subsequent warning is expected:");
            win.stable(103); // no-op because we haven't even removed 4 messages
            check(win, 50, 103, 100);
            while(win.remove() != null);
            check(win, 50, 103, 103);
            win.stable(103);
            System.out.println("win: " + win);

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            System.out.println("Note that the subsequent warning is expected:");
            win.stable(103); // no-op because we haven't even removed 4 messages
            check(win, 50, 103, 100);
            while(win.remove() != null);
            check(win, 50, 103, 103);
            win.stable(103);
            System.out.println("win: " + win);
            check(win, 103, 103, 103);
        }
        finally {
            timer.stop();

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            check(win, 0, 6, 4);
            win.remove();
            check(win, 0, 6, 5);
            win.remove();
            check(win, 0, 6, 6);
            win.stable(4);
            check(win, 4, 6, 6);
            win.stable(6);
            check(win, 6, 6, 6);
        }
        finally {

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            check(win, 0, 6, 5);
            win.remove();
            check(win, 0, 6, 6);
            win.stable(4);
            check(win, 4, 6, 6);
            win.stable(6);
            check(win, 6, 6, 6);
        }
        finally {
            timer.stop();
        }

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            check(win, 0, 6, 0);
            win.add(5, new Message());
            check(win, 0, 6, 0);
            while(win.remove() != null) ;
            check(win, 0, 6, 6);
            win.stable(4);
            check(win, 4, 6, 6);
            win.stable(6);
            check(win, 6, 6, 6);
        }
        finally {

View Full Code Here

Examples of org.jgroups.stack.NakReceiverWindow.stable()

            check(win, 0, 6, 0);
            while(win.remove() != null) ;
            check(win, 0, 6, 6);
            win.stable(4);
            check(win, 4, 6, 6);
            win.stable(6);
            check(win, 6, 6, 6);
        }
        finally {
            timer.stop();
        }

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.