dist_iface.cc (11325:67cc559d513a) dist_iface.cc (11622:0b2aaf6f5c78)
1/*
2 * Copyright (c) 2015 ARM Limited
3 * All rights reserved
4 *
5 * The license below extends only to copyright in the software and shall
6 * not be construed as granting a license to any other intellectual
7 * property including but not limited to intellectual property relating
8 * to a hardware implementation of the functionality of the software

--- 596 unchanged lines hidden (view full) ---

605 // Main loop to wait for and process any incoming message.
606 for (;;) {
607 // recvHeader() blocks until the next dist header packet comes in.
608 if (!recvHeader(header)) {
609 // We lost connection to the peer gem5 processes most likely
610 // because one of them called m5 exit. So we stop here.
611 // Grab the eventq lock to stop the simulation thread
612 curEventQueue()->lock();
1/*
2 * Copyright (c) 2015 ARM Limited
3 * All rights reserved
4 *
5 * The license below extends only to copyright in the software and shall
6 * not be construed as granting a license to any other intellectual
7 * property including but not limited to intellectual property relating
8 * to a hardware implementation of the functionality of the software

--- 596 unchanged lines hidden (view full) ---

605 // Main loop to wait for and process any incoming message.
606 for (;;) {
607 // recvHeader() blocks until the next dist header packet comes in.
608 if (!recvHeader(header)) {
609 // We lost connection to the peer gem5 processes most likely
610 // because one of them called m5 exit. So we stop here.
611 // Grab the eventq lock to stop the simulation thread
612 curEventQueue()->lock();
613 exit_message("info",
614 0,
615 "Message server closed connection, "
616 "simulation is exiting");
613 exitSimLoop("Message server closed connection, simulator "
614 "is exiting");
615 curEventQueue()->unlock();
616 break;
617 }
618
619 // We got a valid dist header packet, let's process it
620 if (header.msgType == MsgType::dataDescriptor) {
621 recvPacket(header, new_packet);
622 recvScheduler.pushPacket(new_packet,
623 header.sendTick,
624 header.sendDelay);

--- 184 unchanged lines hidden --- 		617 }
618
619 // We got a valid dist header packet, let's process it
620 if (header.msgType == MsgType::dataDescriptor) {
621 recvPacket(header, new_packet);
622 recvScheduler.pushPacket(new_packet,
623 header.sendTick,
624 header.sendDelay);

--- 184 unchanged lines hidden ---