Examples of GridTcpDiscoveryStatusCheckMessage

org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryStatusCheckMessage
Message sent by node to its next to ensure that next node and connection to it are alive. Receiving node should send it across the ring, until message does not reach coordinator. Coordinator responds directly to node.
If a failed node id is specified then the message is sent across the ring up to the sender node to ensure that the failed node is actually failed.

Examples of org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryStatusCheckMessage

        boolean res = pingNode(node);


        if (!res) {
            LT.warn(log, null, "Failed to ping node (status check will be initiated): " + nodeId);


            msgWorker.addMessage(new GridTcpDiscoveryStatusCheckMessage(locNode, node.id()));
        }


        return res;
    }

View Full Code Here

Examples of org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryStatusCheckMessage

                }


                // 4. Send status check message.
                lastSent = U.currentTimeMillis();


                msgWorker.addMessage(new GridTcpDiscoveryStatusCheckMessage(locNode, null));
            }
        }

View Full Code Here

Examples of org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryStatusCheckMessage

                                    ", errMsg=" + (err != null ? err.getMessage() : "N/A") + ']');
                        }
                    }


                    if (msg instanceof GridTcpDiscoveryStatusCheckMessage) {
                        GridTcpDiscoveryStatusCheckMessage msg0 = (GridTcpDiscoveryStatusCheckMessage)msg;


                        if (next.id().equals(msg0.failedNodeId())) {
                            next = null;


                            if (log.isDebugEnabled())
                                log.debug("Discarding status check since next node has indeed failed [next=" + next +
                                    ", msg=" + msg + ']');

View Full Code Here

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.