wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed deprecated NetworkMessageReceiver::receive overrides

This commit is contained in:
sfc-gh-tclinkenbeard 2020-06-13 23:17:22 -07:00
parent 8595813b7d
commit 6865923329
1 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
fdbrpc/FlowTransport.actor.cpp
View File

@ -163,13 +163,8 @@ struct EndpointNotFoundReceiver : NetworkMessageReceiver {
endpoints.insert(this, e, TaskPriority::DefaultEndpoint); endpoints.insert(this, e, TaskPriority::DefaultEndpoint);
ASSERT( e == WLTOKEN_ENDPOINT_NOT_FOUND ); ASSERT( e == WLTOKEN_ENDPOINT_NOT_FOUND );
} }
virtual void receive( ArenaReader& reader ) { virtual void receive(ArenaObjectReader& reader) override {
// Remote machine tells us it doesn't have endpoint e // Remote machine tells us it doesn't have endpoint e
Endpoint e; reader >> e;
IFailureMonitor::failureMonitor().endpointNotFound(e);
}
virtual void receive(ArenaObjectReader& reader) {
Endpoint e; Endpoint e;
reader.deserialize(e); reader.deserialize(e);
IFailureMonitor::failureMonitor().endpointNotFound(e); IFailureMonitor::failureMonitor().endpointNotFound(e);
@ -182,11 +177,7 @@ struct PingReceiver : NetworkMessageReceiver {
endpoints.insert(this, e, TaskPriority::ReadSocket); endpoints.insert(this, e, TaskPriority::ReadSocket);
ASSERT( e == WLTOKEN_PING_PACKET ); ASSERT( e == WLTOKEN_PING_PACKET );
} }
virtual void receive( ArenaReader& reader ) { virtual void receive(ArenaObjectReader& reader) override {
ReplyPromise<Void> reply; reader >> reply;
reply.send(Void());
}
virtual void receive(ArenaObjectReader& reader) {
ReplyPromise<Void> reply; ReplyPromise<Void> reply;
reader.deserialize(reply); reader.deserialize(reply);
reply.send(Void()); reply.send(Void());