Subversion Repositories 1g_ethernet_dpi

//////////////////////////////////////////////////////////////////////////////////

// Company:

// Engineer:        IK

//

// Create Date:     11:35:01 03/21/2013

// Design Name:

// Module Name:     bfm_eth_log_cl

// Project Name:

// Target Devices:

// Tool versions:

// Description:

//

//

// Revision:

// Revision 0.01 - File Created,

//

//////////////////////////////////////////////////////////////////////////////////

`timescale 1ns / 1ps

typedef virtual interface rgmii_rx_if virt_rx_if_t;

class bfm_eth_log_cl;

//////////////////////////////////////////////////////////////////////////////////

    //

    virt_rx_if_t    vif_rx;

    virt_rx_if_t    vif_tx;

    //

    string          name;

    bit             verbose;

    //

    int             fd, fd_idx;

    pcap_pkg::u_pcap_hdr_t      sv_pcap_hdr_u;

    pcap_pkg::u_pcaprec_hdr_t   sv_pcaprec_hdr_u;

    //

    static int idx=0;

//////////////////////////////////////////////////////////////////////////////////

static function int next_id;

    next_id = idx++;

endfunction : next_id

function new (string name = "logger", virt_rx_if_t rx, virt_rx_if_t tx, bit i_verbose=0);

    string str;

    // name

    str.itoa(next_id());

    this.name = {name, "#" ,str};

    this.verbose = i_verbose;

    //

    this.fd = 0; this.fd_idx = 0;

    // fill-in pcap_hdr

    sv_pcap_hdr_u.pcap_hdr.magic_number = 32'ha1b2c3d4;

    sv_pcap_hdr_u.pcap_hdr.version_major = 2;

    sv_pcap_hdr_u.pcap_hdr.version_minor = 4;

    sv_pcap_hdr_u.pcap_hdr.thiszone = 0;

    sv_pcap_hdr_u.pcap_hdr.sigfigs = 0;

    sv_pcap_hdr_u.pcap_hdr.snaplen = 256*1024; // 256KB

    sv_pcap_hdr_u.pcap_hdr.network = 1;

    // if

    this.vif_rx = rx;

    this.vif_tx = tx;

    // Final

endfunction : new

//////////////////////////////////////////////////////////////////////////////////

task init;

    vif_rx.init();

    vif_tx.init();

    $display("%s ready", this.name);

    // Final

endtask : init

task log_run;

    // dec var

    int rx_pkt_len, tx_pkt_len;

    // if we are in RUN

    if (fd_idx)

        begin   :   _RE

            $fclose(fd);

            $display("[%t]: %m: re-open PCAP, last frm can be dropped!", $time);

        end

    // pcap-open

    fd = $fopen($sformatf("%s_%02d.pcap", name, fd_idx++), "wb");

    // write pcap-hdr

    for (int i = 0; i < pcap_pkg::pcap_hdr_sz; i++)

        $fwrite(fd, "%c", 8'(sv_pcap_hdr_u.data[i]));

    // sta RX-LOG

    fork

        forever

            begin   :   LOG_RX

                // get ETH-pkt

                vif_rx.rx_pkt();

                // get pkt-id

                rx_pkt_len = vif_rx.rx_pkt_len();

                // prep-hdr

                sv_pcaprec_hdr_u.pcaprec_hdr.ts_sec     =   ($time/1_000_000);

                sv_pcaprec_hdr_u.pcaprec_hdr.ts_usec    =   ($time%1_000_000);

                sv_pcaprec_hdr_u.pcaprec_hdr.incl_len   =   rx_pkt_len;

                sv_pcaprec_hdr_u.pcaprec_hdr.orig_len   =   rx_pkt_len;

                // wr-hdr

                for (int i = 0; i < pcap_pkg::pcaprec_hdr_sz; i++)

                     $fwrite(fd, "%c", 8'(sv_pcaprec_hdr_u.data[i]));

                // wr-data

                for (int i = 0; i < rx_pkt_len; i++)

                    $fwrite(fd, "%c", 8'(vif_rx.rx_pkt_data(i)));

                //

                if (verbose)

                    $display("[%t]: %m: rx-pkt_len=%h", $time, rx_pkt_len);

            end

    join_none

    // sta TX-LOG

    fork

        forever

            begin   :   LOG_TX

                // get ETH-pkt

                vif_tx.rx_pkt();

                // get pkt-id

                tx_pkt_len = vif_tx.rx_pkt_len();

                // prep-hdr

                sv_pcaprec_hdr_u.pcaprec_hdr.ts_sec     =   ($time/1_000_000);

                sv_pcaprec_hdr_u.pcaprec_hdr.ts_usec    =   ($time%1_000_000);

                sv_pcaprec_hdr_u.pcaprec_hdr.incl_len   =   tx_pkt_len;

                sv_pcaprec_hdr_u.pcaprec_hdr.orig_len   =   tx_pkt_len;

                // wr-hdr

                for (int i = 0; i < pcap_pkg::pcaprec_hdr_sz; i++)

                     $fwrite(fd, "%c", 8'(sv_pcaprec_hdr_u.data[i]));

                // wr-data

                for (int i = 0; i < tx_pkt_len; i++)

                    $fwrite(fd, "%c", 8'(vif_tx.rx_pkt_data(i)));

                //

                if (verbose)

                    $display("[%t]: %m: tx-pkt_len=%h", $time, tx_pkt_len);

            end

    join_none

    //

endtask : log_run

task log_stop;

    if (fd)

        begin   :   STOP_LOG

            // close pcap-file

            $fclose(fd); fd = 0;

            // fd=INVALID, so we must stop logging NOW

            disable log_run;

        end

endtask : log_stop

//////////////////////////////////////////////////////////////////////////////////

endclass : bfm_eth_log_cl