Function doKillCursorsRun

src/ExtMsg.actor.cpp:1323–1335

}

Future<Void> doKillCursorsRun(Reference<ExtMsgKillCursors> msg, Reference<ExtConnection> ec) {
	int64_t* ptr = msg->cursorIDs;

	// FIXME: I'm not quite sure what the contract around the memory owned by
	// BufferedConnection is. So do this copy for now to be conservative.
	int32_t numberOfCursorIDs = msg->numberOfCursorIDs;

	while (numberOfCursorIDs--) {
		Cursor::pluck(ec->cursors[*ptr++]);
	}

	return Future<Void>(Void());
}

Future<Void> ExtMsgKillCursors::run(Reference<ExtConnection> ec) {
	return doKillCursorsRun(Reference<ExtMsgKillCursors>::addRef(this), ec);