Searched refs:packet (Results 26 - 50 of 59) sorted by relevance

123

/gem5/src/dev/net/
H A Dpktfifo.cc47 EthPacketPtr &pkt = i->packet;
71 packet->serialize(base + ".packet", cp);
80 packet = make_shared<EthPacketData>();
81 packet->unserialize(base + ".packet", cp);
H A Detherswitch.cc86 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 Dtcp_iface.cc300 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 Dtcp_iface.hh126 const EthPacketPtr &packet) override;
132 void recvPacket(const Header &header, EthPacketPtr &packet) override;
H A Ddist_etherlink.hh84 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 Ddist_iface.hh53 * 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 Dethertap.hh106 bool recvSimulated(EthPacketPtr packet);
H A Dsinic.cc48 #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 Di8254xGBe.cc51 #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 Dsinic.hh219 bool rxFilter(const EthPacketPtr &packet);
231 bool recvPacket(EthPacketPtr packet);
H A Dns_gige.hh201 /** 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 Ddist_iface.cc455 "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 Dsc_ext.hh41 #include "mem/packet.hh"
65 PacketPtr packet; member in class:Gem5SystemC::Gem5Extension
/gem5/src/cpu/minor/
H A Dpipe_data.cc185 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 Dpipe_data.hh204 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 Dfetch1.cc230 /* 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 Dlsq.cc66 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 Dfetch1.hh54 #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 Dexecute.cc329 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 Dinet.cc237 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 Dinet.hh182 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 Dlat_mem_rd.py61 # 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 Dlds_state.hh196 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 DExtMaster.hh55 #include <mem/packet.hh>
H A DExtMaster.cc51 #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

Completed in 32 milliseconds

123