Skip to content

[Feature] Implement MessageRecvManager and DataClientManager Fast-Fail #211

@coderzc

Description

@coderzc

Feature Description (功能描述)

Now, if MessageRecvManager or DataClientManager received the network module exception and doesn't deal with it, this will cause the computer job stuck, we can check the exception and notice the main thread shutdown node.

@Override
public void exceptionCaught(TransportException cause,
ConnectionId connectionId) {
// TODO: implement failover
LOG.error("Channel for connectionId {} occurred exception",
connectionId, cause);
DataClientManager.this.connManager.closeClient(connectionId);
}
}

@Override
public void exceptionCaught(TransportException cause,
ConnectionId connectionId) {
// TODO: implement failover
LOG.warn("Exception caught for connection:{}, root cause:",
connectionId, cause);
}

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

Status

✅ Done

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions