astra-sim-alibabacloud/astra-sim/system/BaseStream.cc

/******************************************************************************
This source code is licensed under the MIT license found in the
LICENSE file in the root directory of this source tree.
*******************************************************************************/

#include "BaseStream.hh"
#include "StreamBaseline.hh"
namespace AstraSim {
void BaseStream::changeState(StreamState state) {
  this->state = state;
}
BaseStream::BaseStream(
    int stream_num,
    Sys* owner,
    std::list<CollectivePhase> phases_to_go) {
  this->stream_num = stream_num;
  this->owner = owner;
  this->initialized = false;
  this->phases_to_go = phases_to_go;
  for (auto& vn : phases_to_go) {
    if (vn.algorithm != nullptr) {
      vn.init(this);
    }
  }
  state = StreamState::Created;
  preferred_scheduling = SchedulingPolicy::None;
  creation_time = Sys::boostedTick();
  total_packets_sent = 0;
  current_queue_id = -1;
  priority = 0;
}
} // namespace AstraSim