Before we use a map in DataStreamRecvr to save the StopWatch corresponding to the pending closures. But we need to take care of the consistency between the map and pending closures queue, it is very error-prone. If it is not consistent, BE will crash. So we remove the map in DataStreamRecvr and replace by vector<pair<Closure*, MonotonicStopWatch>>.