Package org.jgroups.protocols.pbcast

Examples of org.jgroups.protocols.pbcast.STABLE.runMessageGarbageCollection()

282
283
284
285
286
287
288
289
290
291
292
    }

    private static void runStableProtocol(JChannel ch) {
        STABLE stable=(STABLE)ch.getProtocolStack().findProtocol(STABLE.class);
        if(stable != null)
            stable.runMessageGarbageCollection();
    }

    protected boolean isMulticastTransport(JChannel ch) {
        return ch.getProtocolStack().getTransport().supportsMulticasting();
    }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
            for(JChannel ch: channels) {
                MyReceiver receiver=(MyReceiver)ch.getReceiver();
                int received=receiver.getReceived();
                System.out.println(ch.getAddress() + ": " + received);
                STABLE stable=(STABLE)ch.getProtocolStack().findProtocol(STABLE.class);
                stable.runMessageGarbageCollection();
                if(received != TOTAL_NUM_MSGS) {
                    done=false;
                    break;
                }
            }
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
            msg.setFlag(Message.OOB);
            c1.send(msg);
        }
        STABLE stable=(STABLE)c1.getProtocolStack().findProtocol(STABLE.class);
        if(stable != null)
            stable.runMessageGarbageCollection();
        Collection<Integer> msgs=receiver.getMsgs();

        for(int i=0; i < 20; i++) {
            if(msgs.size() == NUM)
                break;
View Full Code Here
416
417
418
419
420
421
422
423
424
425
426
    private static void sendStableMessages(JChannel ... channels) {
        for(JChannel ch: channels) {
            STABLE stable=(STABLE)ch.getProtocolStack().findProtocol(STABLE.class);
            if(stable != null)
                stable.runMessageGarbageCollection();
        }
    }

    private static class BlockingReceiver extends ReceiverAdapter {
        final Lock lock;
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
    private static void sendStableMessages(JChannel ... channels) {
        for(JChannel ch: channels) {
            STABLE stable=(STABLE)ch.getProtocolStack().findProtocol(STABLE.class);
            if(stable != null)
                stable.runMessageGarbageCollection();
        }
    }

    protected static void removeDUPL(JChannel ... channels) {
        for(JChannel ch: channels) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.