/gem5/src/dev/net/ |
H A D | pktfifo.cc | 47 EthPacketPtr &pkt = i->packet; 71 packet->serialize(base + ".packet", cp); 80 packet = make_shared<EthPacketData>(); 81 packet->unserialize(base + ".packet", cp);
|
H A D | etherswitch.cc | 86 DPRINTF(Ethernet, "Fifo is full. Drop packet: len=%d\n", 87 std::prev(fifo.end())->packet->length); 89 _size -= std::prev(fifo.end())->packet->length; 98 // Return true if the newly pushed packet gets inserted 101 // scheduled for the old head of queue packet and schedule a new one 102 if (!empty() && fifo.begin()->packet == ptr) { 114 assert(_size >= fifo.begin()->packet->length); 115 // Erase the packet at the head of the queue 116 _size -= fifo.begin()->packet->length; 139 EtherSwitch::Interface::recvPacket(EthPacketPtr packet) argument 166 enqueue(EthPacketPtr packet, unsigned senderId) argument [all...] |
H A D | tcp_iface.cc | 300 TCPIface::sendPacket(const Header &header, const EthPacketPtr &packet) 303 sendTCP(sock, packet->data, packet->length); 328 TCPIface::recvPacket(const Header &header, EthPacketPtr &packet) 330 packet = make_shared<EthPacketData>(header.dataPacketLength); 331 bool ret = recvTCP(sock, packet->data, header.dataPacketLength); 333 packet->simLength = header.simLength; 334 packet->length = header.dataPacketLength;
|
H A D | tcp_iface.hh | 126 const EthPacketPtr &packet) override; 132 void recvPacket(const Header &header, EthPacketPtr &packet) override;
|
H A D | dist_etherlink.hh | 84 EthPacketPtr packet; member in class:DistEtherLink::Link 95 bool busy() const { return (bool)packet; } 137 * Initiate sending of a packet via this link. 139 * @param packet Ethernet packet to send 141 bool transmit(EthPacketPtr packet);
|
H A D | dist_iface.hh | 53 * 1. Send a data packet coming from a simulated Ethernet link. The packet 61 * associated receiver thread. The receiver thread saves the incoming packet 337 * Received packet descriptor. This information is used by the receive 343 EthPacketPtr packet; member in struct:DistIface::RecvScheduler::Desc 349 packet(p), sendTick(s), sendDelay(d) {} 351 packet(d.packet), sendTick(d.sendTick), sendDelay(d.sendDelay) {} 365 * incoming data packet (see the calcReceiveTick() method) 372 * schedule this object for each incoming data packet [all...] |
H A D | ethertap.hh | 106 bool recvSimulated(EthPacketPtr packet);
|
H A D | sinic.cc | 48 #include "mem/packet.hh" 383 DPRINTF(EthernetPIO, "request new packet...appending to rxList\n"); 386 DPRINTF(EthernetPIO, "packet exists...appending to rxBusy\n"); 773 "vnic %d %s (rxunique %d), packet %d, slack %d\n", 791 panic("continuing vnic without packet\n"); 825 "processing new packet for vnic %d (rxunique %d)\n", 828 // Grab a new packet from the fifo. 832 vnic->rxPacketBytes = vnic->rxIndex->packet->length; 838 IpPtr ip(vnic->rxIndex->packet); 891 rxDmaData = vnic->rxIndex->packet 997 EthPacketPtr packet = txFifo.front(); local 1166 rxFilter(const EthPacketPtr &packet) argument 1177 recvPacket(EthPacketPtr packet) argument [all...] |
H A D | i8254xGBe.cc | 51 #include "mem/packet.hh" 1221 "Part of split packet done: splitcount now %d\n", splitCount); 1227 "Part of split packet done: calling pktComplete()\n"); 1232 IGbE::RxDescCache::writePacket(EthPacketPtr packet, int pkt_offset) argument 1238 pktPtr = packet; 1246 bytesCopied = packet->length; 1248 packet->length, igbe->regs.rctl.descSize()); 1249 assert(packet->length < igbe->regs.rctl.descSize()); 1251 packet->length, &pktEvent, packet [all...] |
H A D | sinic.hh | 219 bool rxFilter(const EthPacketPtr &packet); 231 bool recvPacket(EthPacketPtr packet);
|
H A D | ns_gige.hh | 201 /** halt the tx state machine after next packet */ 215 /** num of bytes in the current packet being drained from rxDataFifo */ 217 /** halt the rx state machine after current packet */ 306 bool rxFilter(const EthPacketPtr &packet); 351 bool recvPacket(EthPacketPtr packet);
|
H A D | dist_iface.cc | 455 "Simulators out of sync - missed packet receive by %llu ticks" 481 d.sendDelay = d.packet->simLength; // assume 1 tick/byte max link speed 509 // Every packet must be sent and arrive in the same quantum 512 // No packet may be scheduled for receive in the arrival quantum 515 // Now we are about to schedule a recvDone event for the new data packet. 518 // packet is always on the top of the queue. 529 "Out of order packet received (recv_tick: %lu top(): %lu\n", 541 EthPacketPtr next_packet = descQueue.front().packet; 559 packet->serialize("rxPacket", cp); 567 packet [all...] |
/gem5/src/systemc/tlm_bridge/ |
H A D | sc_ext.hh | 41 #include "mem/packet.hh" 65 PacketPtr packet; member in class:Gem5SystemC::Gem5Extension
|
/gem5/src/cpu/minor/ |
H A D | pipe_data.cc | 185 ForwardLineData::adoptPacketData(Packet *packet) argument 187 this->packet = packet; 188 lineWidth = packet->req->getSize(); 194 line = packet->getPtr<uint8_t>(); 203 /* If packet is not NULL then the line must belong to the packet so 205 if (packet) { 206 delete packet;
|
H A D | pipe_data.hh | 204 Packet *packet; member in class:Minor::ForwardLineData 213 packet(NULL) 231 /** Use the data from a packet as line instead of allocating new 232 * space. On destruction of this object, the packet will be destroyed */ 233 void adoptPacketData(Packet *packet); 252 /** Forward flowing data between Fetch2,Decode,Execute carrying a packet of
|
H A D | fetch1.cc | 230 /* Make the necessary packet for a memory transaction */ 231 packet = new Packet(request, MemCmd::ReadReq); 232 packet->allocate(); 236 packet->pushSenderState(this); 278 if (packet) 279 delete packet; 299 * as Complete/packet == NULL */ 308 if (!request->packet) 311 /* Ensure that the packet won't delete the request */ 312 assert(request->packet 543 PacketPtr packet = response->packet; local [all...] |
H A D | lsq.cc | 66 packet(NULL), 320 DPRINTFS(MinorMem, (&port), "Retiring packet\n"); 321 packet = packet_; 546 DPRINTFS(MinorMem, (&port), "Making packet %d for request: %s" 575 /* Might as well make the overall/response packet here */ 576 /* Get the physical address for the whole request/packet from the first 645 packet->copyError(response); 650 * to contain all returning data. This is that packet's 668 if (packet->needsResponse()) 669 packet 1172 PacketPtr packet = request->getHeadPacket(); local [all...] |
H A D | fetch1.hh | 54 #include "mem/packet.hh" 92 * Retries are handled by leaving the packet on the requests queue and 128 * system, its request needs to have its packet updated as this may 130 PacketPtr packet; member in class:Minor::Fetch1::FetchRequest 139 * picking apart the response packet */ 142 /** Make a packet to use with the memory transaction */ 175 packet(NULL), 354 /** Try to send (or resend) a memory request's next/only packet to
|
H A D | execute.cc | 329 PacketPtr packet = response->packet; local 356 } else if (!packet) { 362 } else if (packet->isError()) { 366 fatal("Received error response packet for inst: %s\n", *inst); 368 assert(packet); 371 *inst, packet->getAddr(), packet->getSize()); 373 if (is_load && packet->getSize() > 0) { 375 static_cast<unsigned int>(packet [all...] |
/gem5/src/base/ |
H A D | inet.cc | 237 if (IpPtr(tcp.packet())) { 238 return __tu_cksum(IpPtr(tcp.packet())); 239 } else if (Ip6Ptr(tcp.packet())) { 240 return __tu_cksum6(Ip6Ptr(tcp.packet())); 242 panic("Unrecognized IP packet format"); 251 if (IpPtr(udp.packet())) { 252 return __tu_cksum(IpPtr(udp.packet())); 253 } else if (Ip6Ptr(udp.packet())) { 254 return __tu_cksum6(Ip6Ptr(udp.packet())); 256 panic("Unrecognized IP packet forma [all...] |
H A D | inet.hh | 182 const EthPacketPtr packet() const { return p; } function in class:Net::EthPtr 183 EthPacketPtr packet() { return p; } function in class:Net::EthPtr 324 const EthPacketPtr packet() const { return p; } function in class:Net::IpPtr 325 EthPacketPtr packet() { return p; } function in class:Net::IpPtr 440 const EthPacketPtr packet() const { return p; } function in class:Net::Ip6Ptr 441 EthPacketPtr packet() { return p; } function in class:Net::Ip6Ptr 576 const EthPacketPtr packet() const { return p; } function in class:Net::TcpPtr 577 EthPacketPtr packet() { return p; } function in class:Net::TcpPtr 671 const EthPacketPtr packet() const { return p; } function in class:Net::UdpPtr 672 EthPacketPtr packet() { retur function in class:Net::UdpPtr [all...] |
/gem5/configs/dram/ |
H A D | lat_mem_rd.py | 61 # import the packet proto definitions, and if they are not found, 66 print("Did not find packet proto definitions, attempting to generate") 69 '--proto_path=src/proto', 'src/proto/packet.proto']) 71 print("Generated packet proto definitions") 81 print("Failed to import packet proto definitions") 184 # add the packet header 199 # create a packet we can re-use for all the addresses 200 packet = packet_pb2.Packet() 201 # ReadReq is 1 in src/mem/packet.hh Command enum 202 packet [all...] |
/gem5/src/gpu-compute/ |
H A D | lds_state.hh | 196 loadData(PacketPtr packet); 200 storeData(PacketPtr packet); 204 atomicOperation(PacketPtr packet); 239 getDynInstr(PacketPtr packet); 242 processPacket(PacketPtr packet); 245 countBankConflicts(PacketPtr packet, unsigned *bankAccesses);
|
/gem5/ext/sst/ |
H A D | ExtMaster.hh | 55 #include <mem/packet.hh>
|
H A D | ExtMaster.cc | 51 #include <mem/packet.hh> 194 // get original SST packet from gem5 SenderState 199 // make (new) response packet, discard (old) original request 206 // copy the payload and then destroy gem5 packet
|