Uses of Class
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage
-
Packages that use TcpDiscoveryAbstractMessage Package Description org.apache.ignite.spi.discovery.tcp Contains default TCP/IP implementation for discovery SPI.org.apache.ignite.spi.discovery.tcp.internal Contains internal implementation.org.apache.ignite.spi.discovery.tcp.messages Contains implementation messages. -
-
Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp
Fields in org.apache.ignite.spi.discovery.tcp with type parameters of type TcpDiscoveryAbstractMessage Modifier and Type Field Description protected CopyOnWriteArrayList<IgniteInClosure<TcpDiscoveryAbstractMessage>>TcpDiscoverySpi. sndMsgLsnrsMethods in org.apache.ignite.spi.discovery.tcp with parameters of type TcpDiscoveryAbstractMessage Modifier and Type Method Description protected booleanTcpDiscoverySpi. ensured(TcpDiscoveryAbstractMessage msg)protected voidTcpDiscoverySpi. startMessageProcess(TcpDiscoveryAbstractMessage msg)protected voidTcpDiscoverySpi. writeToSocket(Socket sock, OutputStream out, TcpDiscoveryAbstractMessage msg, long timeout)Writes message to the socket.protected voidTcpDiscoverySpi. writeToSocket(Socket sock, TcpDiscoveryAbstractMessage msg, byte[] data, long timeout)Writes message to the socket.protected voidTcpDiscoverySpi. writeToSocket(Socket sock, TcpDiscoveryAbstractMessage msg, long timeout)Writes message to the socket.protected voidTcpDiscoverySpi. writeToSocket(ClusterNode node, Socket sock, OutputStream out, TcpDiscoveryAbstractMessage msg, long timeout)protected voidTcpDiscoverySpi. writeToSocket(TcpDiscoveryAbstractMessage msg, Socket sock, int res, long timeout)Writes response to the socket.Method parameters in org.apache.ignite.spi.discovery.tcp with type arguments of type TcpDiscoveryAbstractMessage Modifier and Type Method Description voidTcpDiscoverySpi. addSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)FOR TEST ONLY!!!voidTcpDiscoverySpi. removeSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)FOR TEST ONLY!!! -
Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.internal
Methods in org.apache.ignite.spi.discovery.tcp.internal with parameters of type TcpDiscoveryAbstractMessage Modifier and Type Method Description voidTcpDiscoveryStatistics. onMessageProcessingFinished(TcpDiscoveryAbstractMessage msg)Collects necessary stats for message processed by SPI.voidTcpDiscoveryStatistics. onMessageProcessingStarted(TcpDiscoveryAbstractMessage msg)Collects necessary stats for message processed by SPI.voidTcpDiscoveryStatistics. onMessageReceived(TcpDiscoveryAbstractMessage msg)Collects necessary stats for message received by SPI.voidTcpDiscoveryStatistics. onMessageSent(TcpDiscoveryAbstractMessage msg, long time)Called by coordinator when ring message is sent. -
Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.messages
Subclasses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.messages Modifier and Type Class Description classTcpDiscoveryAbstractTraceableMessageAbstract traceable message for TCP discovery.classTcpDiscoveryAuthFailedMessageMessage telling joining node that its authentication failed on coordinator.classTcpDiscoveryCheckFailedMessageMessage telling joining node that it failed coordinator's validation check.classTcpDiscoveryClientAckResponseclassTcpDiscoveryClientMetricsUpdateMessageMetrics update message.classTcpDiscoveryClientPingRequestPing request.classTcpDiscoveryClientPingResponsePing request.classTcpDiscoveryClientReconnectMessageMessage telling that client node is reconnecting to topology.classTcpDiscoveryConnectionCheckMessageMessage used to check whether a node is still connected to the topology.classTcpDiscoveryCustomEventMessageWrapped for custom message.classTcpDiscoveryDiscardMessageMessage sent by coordinator when some operation handling is over.classTcpDiscoveryDummyWakeupMessageclassTcpDiscoveryDuplicateIdMessageMessage telling joining node that new topology already contain different node with same ID.classTcpDiscoveryHandshakeRequestHandshake request.classTcpDiscoveryHandshakeResponseHandshake response.classTcpDiscoveryJoinRequestMessageInitial message sent by a node that wants to enter topology.classTcpDiscoveryLoopbackProblemMessageMessage telling joining node that it has loopback problem (misconfiguration).classTcpDiscoveryMetricsUpdateMessageMetrics update message.classTcpDiscoveryNodeAddedMessageMessage telling nodes that new node should be added to topology.classTcpDiscoveryNodeAddFinishedMessageSent by coordinator across the ring to finish node add process.classTcpDiscoveryNodeFailedMessageSent by node that has detected node failure to coordinator across the ring, then sent by coordinator across the ring.classTcpDiscoveryNodeLeftMessageSent by node that is stopping to coordinator across the ring, then sent by coordinator across the ring.classTcpDiscoveryPingRequestPing request.classTcpDiscoveryPingResponsePing response.classTcpDiscoveryRingLatencyCheckMessageclassTcpDiscoveryServerOnlyCustomEventMessageWrapped for custom message that must not be delivered to the client nodes.classTcpDiscoveryStatusCheckMessageMessage sent by node to its next to ensure that next node and connection to it are alive.Methods in org.apache.ignite.spi.discovery.tcp.messages that return types with arguments of type TcpDiscoveryAbstractMessage Modifier and Type Method Description @Nullable Collection<TcpDiscoveryAbstractMessage>TcpDiscoveryNodeAddedMessage. messages()Gets pending messages sent to new node by its previous.Collection<TcpDiscoveryAbstractMessage>TcpDiscoveryClientReconnectMessage. pendingMessages()Method parameters in org.apache.ignite.spi.discovery.tcp.messages with type arguments of type TcpDiscoveryAbstractMessage Modifier and Type Method Description voidTcpDiscoveryNodeAddedMessage. messages(@Nullable Collection<TcpDiscoveryAbstractMessage> msgs, @Nullable IgniteUuid discardMsgId, @Nullable IgniteUuid discardCustomMsgId)Sets pending messages to send to new node.voidTcpDiscoveryClientReconnectMessage. pendingMessages(Collection<TcpDiscoveryAbstractMessage> msgs)Constructors in org.apache.ignite.spi.discovery.tcp.messages with parameters of type TcpDiscoveryAbstractMessage Constructor Description TcpDiscoveryAbstractMessage(TcpDiscoveryAbstractMessage msg)
-