dev/net/dist_iface.cc

60 DistIface::Sync *DistIface::sync = nullptr;
61 System *DistIface::sys = nullptr;
62 DistIface::SyncEvent *DistIface::syncEvent = nullptr;
63 unsigned DistIface::distIfaceNum = 0;
64 unsigned DistIface::recvThreadsNum = 0;
65 DistIface *DistIface::master = nullptr;
66 bool DistIface::isSwitch = false;
69 DistIface::Sync::init(Tick start_tick, Tick repeat_tick)
87 DistIface::Sync::abort()
96 DistIface::SyncSwitch::SyncSwitch(int num_nodes)
111 DistIface::SyncNode::SyncNode()
126 DistIface::SyncNode::run(bool same_tick)
133     waitNum = DistIface::recvThreadsNum;
147     DistIface::master->sendCmd(header);
158 DistIface::SyncSwitch::run(bool same_tick)
196     DistIface::master->sendCmd(header);
201 DistIface::SyncSwitch::progress(Tick send_tick,
242 DistIface::SyncNode::progress(Tick max_send_tick,
270 DistIface::SyncNode::requestCkpt(ReqType req)
281 DistIface::SyncNode::requestExit(ReqType req)
292 DistIface::Sync::drainComplete()
295         // The first DistIface object called this right before writing the
300         // Only the "first" DistIface object has to perform the sync
306 DistIface::SyncNode::serialize(CheckpointOut &cp) const
313 DistIface::SyncNode::unserialize(CheckpointIn &cp)
321 DistIface::SyncSwitch::serialize(CheckpointOut &cp) const
327 DistIface::SyncSwitch::unserialize(CheckpointIn &cp)
333 DistIface::SyncEvent::start()
337     // At this point, all DistIface objects has already called Sync::init() so
340     repeat = DistIface::sync->nextRepeat;
343     if (!DistIface::sync->run(false))
344         panic("DistIface::SyncEvent::start() aborted\n");
346     assert(!DistIface::sync->doCkpt);
347     assert(!DistIface::sync->doExit);
348     assert(!DistIface::sync->doStopSync);
349     assert(DistIface::sync->nextAt >= curTick());
350     assert(DistIface::sync->nextRepeat <= repeat);
358         reschedule(DistIface::sync->nextAt);
360         schedule(DistIface::sync->nextAt);
363            DistIface::sync->nextRepeat);
367 DistIface::SyncEvent::process()
373     // DistIface::serialize() by other gem5 processes.
379     panic_if(_draining && DistIface::sync->doCkpt,
396         if (!DistIface::sync->run(true))
400     if (DistIface::sync->doCkpt)
402     if (DistIface::sync->doExit) {
406     if (DistIface::sync->doStopSync) {
407         DistIface::sync->doStopSync = false;
411         if (DistIface::isSwitch) {
415             for (int i = 0; i < DistIface::master->sys->numContexts(); i++) {
417                     DistIface::master->sys->getThreadContext(i);
428     repeat = DistIface::sync->nextRepeat;
433 DistIface::RecvScheduler::init(Event *recv_done, Tick link_delay)
445 DistIface::RecvScheduler::calcReceiveTick(Tick send_tick,
465 DistIface::RecvScheduler::resumeRecvTicks()
498 DistIface::RecvScheduler::pushPacket(EthPacketPtr new_packet,
506     DPRINTF(DistEthernetPkt, "DistIface::recvScheduler::pushPacket "
536 DistIface::RecvScheduler::popPacket()
555 DistIface::RecvScheduler::Desc::serialize(CheckpointOut &cp) const
563 DistIface::RecvScheduler::Desc::unserialize(CheckpointIn &cp)
572 DistIface::RecvScheduler::serialize(CheckpointOut &cp) const
588 DistIface::RecvScheduler::unserialize(CheckpointIn &cp)
606 DistIface::DistIface(unsigned dist_rank,
617     DPRINTF(DistEthernet, "DistIface() ctor rank:%d\n",dist_rank);
635 DistIface::~DistIface()
651 DistIface::packetOut(EthPacketPtr pkt, Tick send_delay)
668             "DistIface::sendDataPacket() done size:%d send_delay:%llu\n",
673 DistIface::recvThreadFunc(Event *recv_done, Tick link_delay)
719 DistIface::spawnRecvThread(const Event *recv_done, Tick link_delay)
723     recvThread = new std::thread(&DistIface::recvThreadFunc,
731 DistIface::drain()
741 DistIface::drainResume() {
749 DistIface::serialize(CheckpointOut &cp) const
768 DistIface::unserialize(CheckpointIn &cp)
787 DistIface::init(const Event *done_event, Tick link_delay)
800     // Adjust the periodic sync start and interval. Different DistIface
814 DistIface::startup()
816     DPRINTF(DistEthernet, "DistIface::startup() started\n");
820     DPRINTF(DistEthernet, "DistIface::startup() done\n");
824 DistIface::readyToCkpt(Tick delay, Tick period)
827     DPRINTF(DistEthernet, "DistIface::readyToCkpt() called, delay:%lu "
848 DistIface::SyncNode::requestStopSync(ReqType req)
855 DistIface::toggleSync(ThreadContext *tc)
898 DistIface::readyToExit(Tick delay)
901     DPRINTF(DistEthernet, "DistIface::readyToExit() called, delay:%lu\n",
923 DistIface::rankParam()
936 DistIface::sizeParam()