OSDev.org

Code: Select all

unsigned char rx_ring[RX_BUF_TOT_LEN]; // (32k + 16 + 2k)
unsigned int cur_rx;	// Index into the Rx buffer of next Rx pkt.

Code: Select all

static const unsigned int rtl8139_rx_config =
	  RxCfgEarlyRxNone | RxCfgRcv32K | RxNoWrap |
	  (RX_FIFO_THRESH << RxCfgFIFOShift) |
	  (RX_DMA_BURST << RxCfgDMAShift); // note the 'nowrap'
rx_mode = AcceptBroadcast | AcceptMulticast | AcceptMyPhys | AcceptAllPhys; // promisc mode

outportl(ioaddr + RxConfig, rtl8139_rx_config | rx_mode);

Code: Select all

void RTL8139_RX_RECIEVE(eth_t *eth)
{

    unsigned long ioaddr = eth->ioaddr;
    
	while ((inportb(ioaddr + ChipCmd) & RxBufEmpty) == 0)							// is packet buffer empty?
    {  
        
        eth->Incoming_Packet.p_Rx_Read = eth->rx_ring + eth->cur_rx;                // pointer to CAPR
        eth->Incoming_Packet.Packet_Status = *(unsigned short*)(eth->Incoming_Packet.p_Rx_Read);       // +00 bits to get pkt_status
        eth->Incoming_Packet.Packet_Length = *(unsigned short*)(eth->Incoming_Packet.p_Rx_Read + 2);   // +16 bits to get pkt_length
        eth->Incoming_Packet.p_Packet = (eth->Incoming_Packet.p_Rx_Read + 4);       // +32 bits to jump over header
        
        if( eth->Incoming_Packet.Packet_Status & 0x0001 &&                          // make sure ROK is 1
           (eth->Incoming_Packet.Packet_Status & 0x001E) == 0 &&                    // perform multiple error checks at once
            eth->Incoming_Packet.Packet_Length <= ETH_FRAME_LEN &&                  // length must be less than 1536
            eth->Incoming_Packet.Packet_Length >= ETH_ZLEN)                         // length must be more than 60
        {
            
            eth->packetcount++;														// update packetcount
            
            if(eth->nic_num == 0){write_packetcount_eth0(eth->packetcount);}		// update packetcount window
            if(eth->nic_num == 1){write_packetcount_eth1(eth->packetcount);}		// update packetcount window
            
            eth->cur_rx = inportw(ioaddr + 0x3A);									// read next packet write buffer address (CBR)
            if(eth->cur_rx >= RX_BUF_LEN){eth->cur_rx -= RX_BUF_LEN;}				// if (bufferoverflow) { loop around to start }
            outportw(ioaddr + RxBufPtr, eth->cur_rx - 0x10);						// update CAPR 
            eth->packetlen = eth->Incoming_Packet.Packet_Length - 4;                // remove CRC
            
            //RTL8139_TX_TRANSMIT(eth);												// send to next NIC's tx buffer for transmission
            RTL8139_TX_TRANSMIT_LOOP(eth);											// send to current NIC's tx buffer for transmission  
            
        }
        else
        {
            printf("RX_ERROR! (%x) \n", eth->Incoming_Packet.Packet_Status);		// notify user of error
            RTL8139_RESET(eth);														// perform a complete reset
        }
        
        //rtl8139_update("rx");														// sync with other NIC
    }

}