Package co.paralleluniverse.galaxy.core.Message

Examples of co.paralleluniverse.galaxy.core.Message.LineMessage

146
147
148
149
150
151
152
153
    }

    private void sendToOwnerOf(long line, Msg msg) throws TimeoutException {
        if (LOG.isDebugEnabled())
            LOG.debug("Sending to owner of {}: {}", Long.toHexString(line), msg);
        final LineMessage message = Message.MSG((short) -1, line, Streamables.toByteArray(msg));
        cache.doOpAsync(Type.SEND, line, null, message, null);
    }
View Full Code Here
1910
1911
1912
1913
1914
1915
1916
1917
1918
1919
1920
1921
            processLines(new LinePredicate() {
                @Override
                public boolean processLine(CacheLine line) {
                    // remove pending messages from node
                    for (Iterator<LineMessage> it = getPendingMessages(line).iterator(); it.hasNext();) {
                        LineMessage message = it.next();
                        if (message.getNode() == node)
                            it.remove();
                    }
                    processLineOnNodeEvent(line, node, newOwner);
                    return true;
                }
View Full Code Here
TOP

Related Classes of co.paralleluniverse.galaxy.core.Message.LineMessage

  • co.paralleluniverse.galaxy.core.Cache
  • co.paralleluniverse.galaxy.core.CacheTest
  • co.paralleluniverse.galaxy.core.MainMemoryTest
  • co.paralleluniverse.galaxy.core.MessageTest
  • co.paralleluniverse.galaxy.core.MessengerImpl
  • co.paralleluniverse.galaxy.core.StoreImpl
  • co.paralleluniverse.galaxy.netty.UDPCommTest
    • Copyright © 2018 www.massapicom. 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.