[OpenSPARC-T2-DV] / verif / env / fc / vera / classes / asmToVeraIntf.vr

// ========== Copyright Header Begin ==========================================
// 
// OpenSPARC T2 Processor File: asmToVeraIntf.vr
// Copyright (C) 1995-2007 Sun Microsystems, Inc. All Rights Reserved
// 4150 Network Circle, Santa Clara, California 95054, U.S.A.
//
// * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; version 2 of the License.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
// 
// For the avoidance of doubt, and except that if any non-GPL license 
// choice is available it will apply instead, Sun elects to use only 
// the General Public License version 2 (GPLv2) at this time for any 
// software where a choice of GPL license versions is made 
// available with the language indicating that GPLv2 or any later version 
// may be used, or where a choice of which version of the GPL is applied is 
// otherwise unspecified. 
//
// Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara, 
// CA 95054 USA or visit www.sun.com if you need additional information or 
// have any questions. 
// 
// ========== Copyright Header End ============================================
#include <vera_defines.vrh>
#include "globals.vri"
#include "std_display_defines.vri"
#include "std_display_class.vrh"
#include "baseUtilsClass.vrh"
#include "sparcBenchUtils.vrh"
#include "utilsClass.vrh"
#include "memArray.vrh"
#include "baseAsmToVeraIntf.vrh"
#include "generic_ev_packet.vrh"

#include "pcg_defines.vri"
//#include "pcg_types.vri"
// added this to remove NIU for OpenSparc T2
#ifndef FC_NO_NIU_T2
#include "pack_db.vrh"
#include "flow_db.vrh"
#include "flow_db_tasks.vrh"
#include "pg_top_pp.vrh"
#include "pc_top_pp.vrh"
#include "niu_tx_descp.vrh"
#include "pcg_token.vrh"

#ifndef FC_NO_PEU_VERA
#include "Testbench.vrh"
#endif
#include "niu_tx_descp.vrh"
#include "niu_tx_port.vrh"
#include "pio_driver.vrh"
#include "mac_pio_class.vrh"
#include "bmac_util.vrh"
#include "fflp_util.vrh"
#include "niu_rxdmc.vrh"
#include "pktConfig.vrh"
#endif

// #include <VeraListProgram.vrh>
#include <ListMacros.vrh>

//ras

#include "ios_injerr.vrh"
#include "ios_err_packet.vrh"
#ifndef FC_NO_NIU_T2
#include "sioniu_err_mon.vrh"
#endif
#include "siodmu_err_mon.vrh"
#ifndef GATESIM
#include "ios_err_interrupt.vrh"
#endif

// for JTAG - L2 access
#include "tcu_siu_packet.vrh"
extern tcu_siu_packet tcu_siu_pkt;
extern reg [39:0] jtagDoneMemAddr;
extern event e_StartJtag;


// THE INTENT OF THIS FILE IS TO BE A BRIDGE TO OTHER CLASSES THAT
// ACTUALLY DO THE TESTING. THIS FILE IS NOT THE PLACE TO TEST ANYTHING.
// THE CODE IN HERE SHOULD BE MINIMAL AND SHOULD SIMPLY MAKE A ZERO TIME
// CALL INTO THE CLASS THAT DOES THE REAL WORK.

#ifndef FC_NO_NIU_T2
extern CpktConfig pktConfig;
extern RxDMAChannel rx_dma[32];
extern CRDMC rdmc;
#endif
// extern class BaseAsmToVeraIntf;
extern integer config_mb;
extern integer config0_mb;
extern integer config1_mb;
extern integer flow_mb;
//extern pg pack_gen[16];

#ifndef FC_NO_PEU_VERA
extern event e_StartPEUTest;
extern integer asm2peu_mbox;
#endif

extern ios_ras_inj ras_injector;
// extern ios_err_packet err_pkt;

#ifndef GATESIM
extern ios_err_interrupt_mon ras_interrupt;
#endif

#include "ssi.vrh"
extern SSI bootrom;

ExternVeraList(ios_err_packet);

extern integer generic_ev_mbox; // mailbox for generic asm-to-vera user event 'generic_ev'


class AsmToVeraIntf extends BaseAsmToVeraIntf {

integer inj_result;
integer p0_dma_chnl[];
integer p1_dma_chnl[];


#ifndef FC_NO_NIU_T2
CMacTxPort  MacTxPort[2]; 
flow_desc flow_p0[];
flow_desc flow_p1[];
#endif
  task new();  
  
  // generic user event
  task generic_ev(
    string     arg1_str,
    reg [63:0] arg2_64bits,
    reg [63:0] arg3_64bits
  );
  // trig_pc_d(kind, 64'h1234567812345678) -> intp(tid, type, vector) hex, w/no 64'h
  // trig_pc_d(kind, 64'h1234567812345678) -> intp(tid, type, vector, src, wait)    
  task intp(reg [5:0] tid = 0,
            reg [63:0] type = 0,
            reg [63:0] vec = 0,
            integer src = 16, // 0-16 are ccx ports. 16 = NCU
            integer wait = 0);

  // dump actual RAM contents
  // trig_pc_d(1,expr(@VA(.MAIN.T1_ext_intr_200), 16, 16)) -> dump_mem(addr, amount)
  task dump_mem(reg [63:0] addr=0,
                integer amount = 8);
  
  // trig_pc_d(1,expr(@VA(.MAIN.T1_ext_intr_200), 16, 16)) -> extint(wait/delay)
  task extint(integer wait = 0, integer width = 0);
  
  task warmrst(integer wait = 0);
   
  // SPC BFM will do a store. Pick correct port w/ BFM!!!
  // trig_pc_d(1,...) -> store(cpu/ccxPort, addr, data)
  task store(reg [7:0] ccxPortMask = 0,
             reg [63:0] addr=0,
             reg [63:0] data=0);

task IosErrInj (string errtype, bit [15:0] ctag, bit [39:0] pa);
task IosRandErrInj (string errtype, integer num_errs, integer weight);

task jtagRdWrL2 (
    reg [63:0] paAddr,
    reg [63:0] data,
    reg [63:0] jtagDoneAddrMem,
    reg rdwr // =0 asm->VERA,  =1 VERA->asm
);


#ifndef FC_NO_NIU_T2
task pktGenConfig (
    integer mac_port,
    integer frame_type,
    integer frame_class,
    integer data_length,
    (integer tx_multi_port = 0, integer data_length_p1 = -1)
);

task NIU_AddTxChannels (
    integer mac_port, 
    integer dma_no,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task NIU_SetTxMaxBurst (
    integer mac_port, 
    integer dma_no, 
    integer SetTxMaxBurst_Data,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task NIU_TxDMAActivate (
    integer mac_port, 
    integer dma_activelist,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task NIU_InitTxDma (
    integer mac_port, 
    integer dma_no,
    bit Xlate,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task NIU_EXIT_chk (
    integer mac_port
);

task NIU_SetTxRingKick (
    integer mac_port,
    integer dma_no,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task TxPktGen (
    integer mac_port,
    integer dmaport,
    integer numofpacket,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task TxPktGen_int (
    integer mac_port,
    integer dmaport,
    integer numofpacket,
    (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0)
);

task NIU_InitRxDma (
    integer RxDmaChnlNo, 
    integer RxDescRingLen, 
    bit [39:0] RxRingStartAddr, 
    bit [63:0] RbrConfData, 
    integer RxInitKick,
    bit Xlate,
    (bit [15:0] rx_multi_dma = 16'h0)
);

task NIU_RxPktConf (
    integer RxPktCnt,
    (integer iport = 0)
);

task NIU_RxGenPkt (
    integer mac_port, 
    integer RxDmaChnlNo, 
    integer RxPktCnt, 
    integer RxPktLen,
    (integer rx_multi_PORT = 0, bit [15:0] rx_multi_DMA = 16'h0)
);

task NIU_internalrx (
    integer mac_port, 
    integer RxDmaChnlNo, 
    integer RxPktCnt, 
    integer RxPktLen,
    (integer rx_multi_port = 0, bit [15:0] rx_multi_dma = 16'h0)
);
#endif


task marker(
  string what,
  reg [5:0] fromTid,
  reg [63:0] pc
);
 // trig_pc_d(1,expr(@VA(.MAIN.lable) -> L2ErrTrapCount(register with trap count)
  //task for fc random error injection in data array of L2
  task L2ErrTrapCount(reg [8:0] count=0);

task reset_now(
  string what
);

#ifndef FC_NO_PEU_VERA
task set_StartPEUTest ();
task EnablePCIeEgCmd (string      cmdType,
                      bit [63:0]  addr,
                      bit [31:0]  txLen,
                      bit [31:0]  startData,
                      string      err);

task EnablePCIeIgCmd (string      cmdType,
                      bit [63:0]  StartAddr,
                      bit [63:0]  EndAddr,
                      string      txLen,
                      bit [31:0]  NumCmds,
                      string      err);
#endif


}


task AsmToVeraIntf::new() {
  probe_if.gOutOfBoot <= 64'h0;
  random_rst_if.POR_from_UserEvent <= 0;
  random_rst_if.PB_RST_from_UserEvent <= 0;
}

// generic user event
task AsmToVeraIntf::generic_ev(string     arg1_str,
                reg [63:0] arg2_64bits,
                reg [63:0] arg3_64bits)
{
  Generic_ev_packet pkt = new();
  pkt.arg1_str = arg1_str;
  pkt.arg2_64bits = arg2_64bits;
  pkt.arg3_64bits = arg3_64bits;
  mailbox_put (generic_ev_mbox, pkt);
}
// trig_pc_d(kind, 64'h1234567812345678) -> intp(tid, type, vector) hex, w/no 64'h
// trig_pc_d(kind, 64'h1234567812345678) -> intp(tid, type, vector, src, wait)    
task AsmToVeraIntf::intp(reg [5:0] tid = 0,
                         reg [63:0] type = 0,
                         reg [63:0] vec = 0,
                         integer src = DEV_NCU, // 0-16 are ccx ports. 16 = NCU
                         integer wait = 0)
{

   error("AsmToVeraIntf::intp is not coded yet for NCU RTL!!!\n");

  fork {
    repeat (wait) @(posedge CLOCK);
    gUtil.sendIntr(tid,type,vec,src);
  }
  join none
}

// dump actual RAM contents
// trig_pc_d(1,expr(@VA(.MAIN.T1_ext_intr_200), 16, 16)) -> dump_mem(addr, amount)
task AsmToVeraIntf::dump_mem(reg [63:0] addr=0,
                             integer amount = 8)
{
  gMem.dumpMem(addr,amount); 
}

// trig_pc_d(1,expr(@VA(.MAIN.T1_ext_intr_200), 16, 16)) -> extint(wait/delay)
task AsmToVeraIntf::extint(integer wait = 0, integer width = 0)
{
//  error("AsmToVeraIntf::extint is not coded yet\n");
  bootrom.pulse_ssi_int_l(wait, width);
}

task AsmToVeraIntf::warmrst(integer wait = 0)
{
  error("AsmToVeraIntf::warmrst is not coded yet\n");
}


// SPC BFM will do a store. Pick correct port w/ BFM!!!
// trig_pc_d(1,...) -> store(cpu/ccxPort, addr, data)
task AsmToVeraIntf::store(reg [7:0] ccxPortMask = 0,
                          reg [63:0] addr=0,
                          reg [63:0] data=0)
{
  error("AsmToVeraIntf::store is not coded yet\n");
}

// ***********************************************************************************
// JTAG Read/Write L2 Task
// ***********************************************************************************
task AsmToVeraIntf::jtagRdWrL2 (reg [63:0] paAddr=0,
                                reg [63:0] data=0,
                                reg [63:0] jtagDoneAddrMem=0,
                                reg rdwr=0) // rd=0 asm->VERA, wr=1 VERA->asm
{
  reg [63:0] header;

  printf ("\n In jtagRdWr... setting StartJtag\n");
  if (rdwr) { // VERA -> asm
    header = {24'h820000, paAddr[39:0]};  // write operation
    // save to share packet
    tcu_siu_pkt.header = header;
    tcu_siu_pkt.payload = data;
    tcu_siu_pkt.type = JTAG_WR;
  }
  else { // asm -> VERA
    header = {24'h810000, paAddr[39:0]};  // read operation
    // save to share packet
    tcu_siu_pkt.header = header;
    tcu_siu_pkt.payload = data;
    tcu_siu_pkt.type = JTAG_RD;
  }
  jtagDoneMemAddr = jtagDoneAddrMem[39:0];  // only 40 bits of PA are used
  trigger (ON, e_StartJtag);
}

#ifndef FC_NO_NIU_T2
// ***********************************************************************************
// NIU Tx Tasks
// ***********************************************************************************
task AsmToVeraIntf::pktGenConfig (integer mac_port, 
                                  integer frame_type, 
                                  integer frame_class, 
                                  integer data_length,
                                  (integer tx_multi_port = 0, integer data_length_p1 = -1))
{
//integer data_length;
integer pkt_length;
integer byte_incr;
integer mark_bit;
flow_desc flow0;
flow_desc flow1;
//TxPacketGenConfig config;
TxPacketGenConfig config0;
TxPacketGenConfig config1;

if (tx_multi_port == 0)
  {
   if (mac_port == 0)
    {
     PR_INFO("fc_niu_asm_event", MON_INFO,
             psprintf("KHH-TX Debug : Configuring TX PKTGEN for Port %0d", mac_port));
     flow0= new;
   
     flow0.frame.frame_type = frame_type;			// 072105 flow0.frame.frame_type = 2;
     flow0.frame.frame_class = frame_class; 		// 072105 flow0.frame.frame_class = CL_IP;
     flow0.frame.type = -1;
     flow0.frame.class_mask = 0;
     flow0.frame.class_funct = CLF_SRC;
     flow0.frame.data_type = DAT_SEQ|DAT_LEN_EXACT  ;
     flow0.frame.data_seed = 0;

     flow0.src_node.l2_addr = 48'h00_a5_5a_a5_5a_a5; 		// flow0.src_node.l2_addr = 48'haaaa_1111_0000;
     flow0.src_node.tci     = random(); 				// flow0.src_node.tci     = 16'hcb00;
     flow0.src_node.ip_addr = random();			// IPv4 address of this substation 	// flow0.src_node.ip_addr = 32'hcccc_0000;
     flow0.src_node.ipv6_addr = random();
							//  flow0.src_node.src_port = 20'h00001;


     flow0.dst_node.l2_addr = 48'h00_55_55_55_55_55; 		// flow0.dst_node.l2_addr = 48'hdddd_bbbb_0000;
     flow0.dst_node.tci     = random(); 				// flow0.dst_node.tci     = 16'hcb00;
     flow0.dst_node.ip_addr = random(); 			// flow0.dst_node.ip_addr = 32'h8888_0000;
     flow0.dst_node.ipv6_addr = random();
							// flow0.dst_node.src_port = 20'h00001;

     flow0.tup.src_tcp_udp_port = random();		// Source TCP/UDP Port	//  flow0.tup.src_tcp_udp_port = 16'h1234;
     flow0.tup.dst_tcp_udp_port = random();		// Destination TCP/UDP Port //  flow0.tup.dst_tcp_udp_port = 16'hABCD;

     flow0.rx_param.rcv_isn = 32'h1357_abef; 		// flow0.rx_param.rcv_isn = 32'hA5A5_F5F5;

     flow0.fl_state.tcp_flags = 6'b00_0010;

     flow0.flow_no = 0;

     flow0.partial_chksum = 1;

     flow0.psu_hdr[0] = 8'hdc;
     flow0.psu_hdr[1] = 8'h92;


//  if (get_plus_arg (CHECK, "TX_PKT_LEN"))
//    data_length = get_plus_arg (NUM, "TX_PKT_LEN");
//  else
//    data_length = 52; 	//MAQ: 020905 data_length = 64;

      if( get_plus_arg (CHECK, "TX_PKT_SIZE_SWEEP")) {
           byte_incr = get_plus_arg (NUM, "TX_PKT_INCR");
      } else byte_incr = 0;

     config0 = new();
     config0.mac_id = mac_port;
     config0.flow = flow0;

     if (get_plus_arg (CHECK, "TX_INT_MARK"))
       mark_bit = get_plus_arg (NUM, "TX_INT_MARK");
     else
       mark_bit = 0; 

     config0.mark_bit = mark_bit;

//072005   pkt_length = data_length;
//072005   if(pkt_length > 1500)
//072005    pkt_length = data_length ;
//072005   config.data_length = pkt_length;

     config0.data_length = data_length;
     if (get_plus_arg (CHECK, "TX_GATHER"))
   	config0.g_mode = 1;
     else
   	config0.g_mode = 0;

      mailbox_put (config0_mb, config0);
    }
   else if (mac_port == 1)
    {
     PR_INFO("fc_niu_asm_event", MON_INFO,
             psprintf("KHH-TX Debug : Configuring TX PKTGEN for Port %0d", mac_port));
     flow1= new;
   
     flow1.frame.frame_type = frame_type;			// 072105 flow1.frame.frame_type = 2;
     flow1.frame.frame_class = frame_class; 		// 072105 flow1.frame.frame_class = CL_IP;
     flow1.frame.type = -1;
     flow1.frame.class_mask = 0;
     flow1.frame.class_funct = CLF_SRC;
     flow1.frame.data_type = DAT_SEQ|DAT_LEN_EXACT  ;
     flow1.frame.data_seed = 0;

     flow1.src_node.l2_addr = 48'h00_b5_b6_b7_b8_b9; 		// flow1.src_node.l2_addr = 48'haaaa_1111_0000;
     flow1.src_node.tci     = random(); 				// flow1.src_node.tci     = 16'hcb00;
     flow1.src_node.ip_addr = random();			// IPv4 address of this substation 	// flow1.src_node.ip_addr = 32'hcccc_0000;
     flow1.src_node.ipv6_addr = random();
							//  flow1.src_node.src_port = 20'h00001;

     flow1.dst_node.l2_addr = 48'h00_65_66_67_68_69; 		// flow1.dst_node.l2_addr = 48'hdddd_bbbb_0000;
     flow1.dst_node.tci     = random(); 				// flow1.dst_node.tci     = 16'hcb00;
     flow1.dst_node.ip_addr = random(); 			// flow1.dst_node.ip_addr = 32'h8888_0000;
     flow1.dst_node.ipv6_addr = random();
							// flow1.dst_node.src_port = 20'h00001;

     flow1.tup.src_tcp_udp_port = random();		// Source TCP/UDP Port	//  flow1.tup.src_tcp_udp_port = 16'h1234;
     flow1.tup.dst_tcp_udp_port = random();		// Destination TCP/UDP Port //  flow1.tup.dst_tcp_udp_port = 16'hABCD;

     flow1.rx_param.rcv_isn = 32'h1213_1415; 		// flow1.rx_param.rcv_isn = 32'hA5A5_F5F5;

     flow1.fl_state.tcp_flags = 6'b00_0010;

     flow1.flow_no = 0;

     flow1.partial_chksum = 1;

     flow1.psu_hdr[0] = 8'hab;
     flow1.psu_hdr[1] = 8'hcd;


//  if (get_plus_arg (CHECK, "TX_PKT_LEN"))
//    data_length = get_plus_arg (NUM, "TX_PKT_LEN");
//  else
//    data_length = 52; 	//MAQ: 020905 data_length = 64;

      if( get_plus_arg (CHECK, "TX_PKT_SIZE_SWEEP")) {
           byte_incr = get_plus_arg (NUM, "TX_PKT_INCR");
      } else byte_incr = 0;

     config1 = new();
     config1.mac_id = mac_port;
     config1.flow = flow1;

     if (get_plus_arg (CHECK, "TX_INT_MARK"))
       mark_bit = get_plus_arg (NUM, "TX_INT_MARK");
     else
       mark_bit = 0; 
   
     config1.mark_bit = mark_bit;

//072005   pkt_length = data_length;
//072005   if(pkt_length > 1500)
//072005    pkt_length = data_length ;
//072005   config.data_length = pkt_length;

     config1.data_length = data_length;
     if (get_plus_arg (CHECK, "TX_GATHER"))
   	config1.g_mode = 1;
     else
   	config1.g_mode = 0;
   
      mailbox_put (config1_mb, config1);
    }
   else
    {
     PR_ERROR("fc_niu_asm_event", MON_ERROR,
              psprintf("pktGenConfig: Unexpected TX Port Value %0d", mac_port));
    }
  }
else
  {
   mac_port = 0;
     PR_INFO("fc_niu_asm_event", MON_INFO,
             psprintf("KHH-TX Debug : Configuring TX PKTGEN for Port %0d", mac_port));
     flow0= new;
   
     flow0.frame.frame_type = frame_type;			// 072105 flow0.frame.frame_type = 2;
     flow0.frame.frame_class = frame_class; 		// 072105 flow0.frame.frame_class = CL_IP;
     flow0.frame.type = -1;
     flow0.frame.class_mask = 0;
     flow0.frame.class_funct = CLF_SRC;
     flow0.frame.data_type = DAT_SEQ|DAT_LEN_EXACT  ;
     flow0.frame.data_seed = 0;

     flow0.src_node.l2_addr = 48'h00_a5_5a_a5_5a_a5; 		// flow0.src_node.l2_addr = 48'haaaa_1111_0000;
     flow0.src_node.tci     = random(); 				// flow0.src_node.tci     = 16'hcb00;
     flow0.src_node.ip_addr = random();			// IPv4 address of this substation 	// flow0.src_node.ip_addr = 32'hcccc_0000;
     flow0.src_node.ipv6_addr = random();
							//  flow0.src_node.src_port = 20'h00001;

     flow0.dst_node.l2_addr = 48'h00_55_55_55_55_55; 		// flow0.dst_node.l2_addr = 48'hdddd_bbbb_0000;
     flow0.dst_node.tci     = random(); 				// flow0.dst_node.tci     = 16'hcb00;
     flow0.dst_node.ip_addr = random(); 			// flow0.dst_node.ip_addr = 32'h8888_0000;
     flow0.dst_node.ipv6_addr = random();
							// flow0.dst_node.src_port = 20'h00001;

     flow0.tup.src_tcp_udp_port = random();		// Source TCP/UDP Port	//  flow0.tup.src_tcp_udp_port = 16'h1234;
     flow0.tup.dst_tcp_udp_port = random();		// Destination TCP/UDP Port //  flow0.tup.dst_tcp_udp_port = 16'hABCD;

     flow0.rx_param.rcv_isn = 32'h1357_abef; 		// flow0.rx_param.rcv_isn = 32'hA5A5_F5F5;

     flow0.fl_state.tcp_flags = 6'b00_0010;

     flow0.flow_no = 0;

     flow0.partial_chksum = 1;

     flow0.psu_hdr[0] = 8'hdc;
     flow0.psu_hdr[1] = 8'h92;


//  if (get_plus_arg (CHECK, "TX_PKT_LEN"))
//    data_length = get_plus_arg (NUM, "TX_PKT_LEN");
//  else
//    data_length = 52; 	//MAQ: 020905 data_length = 64;

      if( get_plus_arg (CHECK, "TX_PKT_SIZE_SWEEP")) {
           byte_incr = get_plus_arg (NUM, "TX_PKT_INCR");
      } else byte_incr = 0;

     config0 = new();
     config0.mac_id = mac_port;
     config0.flow = flow0;

     if (get_plus_arg (CHECK, "TX_INT_MARK"))
       mark_bit = get_plus_arg (NUM, "TX_INT_MARK");
     else
       mark_bit = 0; 

     config0.mark_bit = mark_bit;

//072005   pkt_length = data_length;
//072005   if(pkt_length > 1500)
//072005    pkt_length = data_length ;
//072005   config.data_length = pkt_length;

     config0.data_length = data_length;
     if (get_plus_arg (CHECK, "TX_GATHER"))
   	config0.g_mode = 1;
     else
   	config0.g_mode = 0;

      mailbox_put (config0_mb, config0);
     
   mac_port = 1;
     
     PR_INFO("fc_niu_asm_event", MON_INFO,
             psprintf("KHH-TX Debug : Configuring TX PKTGEN for Port %0d", mac_port));
     flow1= new;
   
     flow1.frame.frame_type = frame_type;			// 072105 flow1.frame.frame_type = 2;
     flow1.frame.frame_class = frame_class; 		// 072105 flow1.frame.frame_class = CL_IP;
     flow1.frame.type = -1;
     flow1.frame.class_mask = 0;
     flow1.frame.class_funct = CLF_SRC;
     flow1.frame.data_type = DAT_SEQ|DAT_LEN_EXACT  ;
     flow1.frame.data_seed = 0;

     flow1.src_node.l2_addr = 48'h00_b5_b6_b7_b8_b9; 		// flow1.src_node.l2_addr = 48'haaaa_1111_0000;
     flow1.src_node.tci     = random(); 				// flow1.src_node.tci     = 16'hcb00;
     flow1.src_node.ip_addr = random();			// IPv4 address of this substation 	// flow1.src_node.ip_addr = 32'hcccc_0000;
     flow1.src_node.ipv6_addr = random();
							//  flow1.src_node.src_port = 20'h00001;

     flow1.dst_node.l2_addr = 48'h00_65_66_67_68_69; 		// flow1.dst_node.l2_addr = 48'hdddd_bbbb_0000;
     flow1.dst_node.tci     = random(); 				// flow1.dst_node.tci     = 16'hcb00;
     flow1.dst_node.ip_addr = random(); 			// flow1.dst_node.ip_addr = 32'h8888_0000;
     flow1.dst_node.ipv6_addr = random();
							// flow1.dst_node.src_port = 20'h00001;

     flow1.tup.src_tcp_udp_port = random();		// Source TCP/UDP Port	//  flow1.tup.src_tcp_udp_port = 16'h1234;
     flow1.tup.dst_tcp_udp_port = random();		// Destination TCP/UDP Port //  flow1.tup.dst_tcp_udp_port = 16'hABCD;

     flow1.rx_param.rcv_isn = 32'h1213_1415; 		// flow1.rx_param.rcv_isn = 32'hA5A5_F5F5;

     flow1.fl_state.tcp_flags = 6'b00_0010;

     flow1.flow_no = 0;

     flow1.partial_chksum = 1;

     flow1.psu_hdr[0] = 8'hab;
     flow1.psu_hdr[1] = 8'hcd;


//  if (get_plus_arg (CHECK, "TX_PKT_LEN"))
//    data_length = get_plus_arg (NUM, "TX_PKT_LEN");
//  else
//    data_length = 52; 	//MAQ: 020905 data_length = 64;

      if( get_plus_arg (CHECK, "TX_PKT_SIZE_SWEEP")) {
           byte_incr = get_plus_arg (NUM, "TX_PKT_INCR");
      } else byte_incr = 0;

     config1 = new();
     config1.mac_id = mac_port;
     config1.flow = flow1;

     if (get_plus_arg (CHECK, "TX_INT_MARK"))
       mark_bit = get_plus_arg (NUM, "TX_INT_MARK");
     else
       mark_bit = 0; 
   
     config1.mark_bit = mark_bit;

//072005   pkt_length = data_length;
//072005   if(pkt_length > 1500)
//072005    pkt_length = data_length ;
//072005   config.data_length = pkt_length;

     if (data_length_p1 == -1)
       {
        data_length_p1 = 80;
       }
     config1.data_length = data_length_p1;
     if (get_plus_arg (CHECK, "TX_GATHER"))
   	config1.g_mode = 1;
     else
   	config1.g_mode = 0;
   
      mailbox_put (config1_mb, config1);
  }
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_SetTxRingKick (integer mac_port, integer dma_no,
                                       (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{

 PR_INFO("fc_niu_asm_event", MON_INFO,
         psprintf("KHH-TX Debug : B4 FOR NIU_SetTxRingKick, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 PR_INFO("fc_niu_asm_event", MON_INFO,
         psprintf("KHH-TX Debug : AF FOR NIU_SetTxRingKick, NIU_TX_MULTI_PORT = %0d & NIU_TX_MULTI_DMA_P0 = %h MODE", tx_multi_port, tx_multi_dma_p0));
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }
 PR_INFO("fc_niu_asm_event", MON_INFO,
         psprintf("KHH-TX Debug : AF FOR NIU_SetTxRingKick, NIU_TX_MULTI_PORT = %0d & NIU_TX_MULTI_DMA_P1 = %h MODE", tx_multi_port, tx_multi_dma_p1));

 if (tx_multi_dma_p1[15:0]  & tx_multi_dma_p0[15:0])
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_SetTxRingKick: Same DMA assigned to multiple ports: TX_MULTI_DMA_P0 = 0x%h, TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
   }

 if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("MAQ-Debug : B4 setTxRingKick ring_current_addr = %h", MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr));
    MacTxPort[mac_port].dma[dma_no].setTxRingKick(MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr);
    PR_INFO("fc_niu_asm_event", MON_INFO,
            "MAQ-Debug : After setTxRingKick");
   }
 else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_SetTxRingKick, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h, MAC_PORT = %0d, DMA_NO = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1, mac_port, dma_no));
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-Debug : P0 TX_DMA0 setTxRingKick ring_current_addr = %h", MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr));
          MacTxPort[mac_port].dma[dma_no].setTxRingKick(MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr); 
   }
 else if (tx_multi_port == 1 && (tx_multi_dma_p1[15:0]  == 16'h0 || tx_multi_dma_p0[15:0] == 16'h0))
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
            psprintf("NIU_SetTxRingKick: For NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_dma_p0, tx_multi_dma_p1));
   }
 else if (tx_multi_port == 1 && tx_multi_dma_p1[15:0]  > 16'h0 && tx_multi_dma_p0[15:0] > 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_SetTxRingKick, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h, MAC_PORT = %0d & DMA_NO = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1, mac_port, dma_no));
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-Debug : P0 TX_DMA0 setTxRingKick ring_current_addr = %h", MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr));
          MacTxPort[mac_port].dma[dma_no].setTxRingKick(MacTxPort[mac_port].dma[dma_no].desc_ring.ring_current_addr); 
   }
 else
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_SetTxRingKick: Invalid combination for NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
   }
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_AddTxChannels (integer mac_port, integer dma_no,
                                       (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{

 PR_INFO("fc_niu_asm_event", MON_INFO,
         psprintf("KHH-TX Debug : FOR NIU_AddTxChannels, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }
/*
 if (tx_multi_dma_p1[15:0]  & tx_multi_dma_p0[15:0])
   {
    printf("ERROR : NIU_AddTxChannels, FOR TX_MULTI_DMA_P0 = %h, same dma assigned to multiple ports.\n", tx_multi_dma_p0);
    printf("ERROR : NIU_AddTxChannels, FOR TX_MULTI_DMA_P1 = %h, same dma assigned to multiple ports.\n", tx_multi_dma_p1);
   }
 else
   {
    if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
      {
       printf("KHH-TX Debug : FOR NIU_AddTxChannels, MAC_PORT = %d & DMA_NO = %d.\n", mac_port, dma_no);
       MacTxPort[mac_port].add_channels(dma_no);
      }
    else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
      {
       printf("KHH-TX Debug : FOR NIU_AddTxChannels, NIU_TX_MULTI_PORT = %d & NIU_TX_MULTI_DMA_P0 = %h MODE.\n", tx_multi_port, tx_multi_dma_p0);
       printf("KHH-TX Debug : FOR NIU_AddTxChannels, NIU_TX_MULTI_PORT = %d & NIU_TX_MULTI_DMA_P1 = %h MODE.\n", tx_multi_port, tx_multi_dma_p1);
       if (mac_port == 0)
         {
          if (tx_multi_dma_p0[0] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(0);
            }
          if (tx_multi_dma_p0[1] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(1);
            }
          if (tx_multi_dma_p0[2] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(2);
            }
          if (tx_multi_dma_p0[3] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(3);
            }
          if (tx_multi_dma_p0[4] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(4);
            }
          if (tx_multi_dma_p0[5] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(5);
            }
          if (tx_multi_dma_p0[6] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(6);
            }
          if (tx_multi_dma_p0[7] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(7);
            }
          if (tx_multi_dma_p0[8] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(8);
            }
          if (tx_multi_dma_p0[9] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(9);
            }
          if (tx_multi_dma_p0[10] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(10);
            }
          if (tx_multi_dma_p0[11] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(11);
            }
          if (tx_multi_dma_p0[12] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(12);
            }
          if (tx_multi_dma_p0[13] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(13);
            }
          if (tx_multi_dma_p0[14] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(14);
            }
          if (tx_multi_dma_p0[15] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(15);
            }
         }
       else if (mac_port == 1)
         {
          if (tx_multi_dma_p1[0] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(0);
            }
          if (tx_multi_dma_p1[1] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(1);
            }
          if (tx_multi_dma_p1[2] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(2);
            }
          if (tx_multi_dma_p1[3] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(3);
            }
          if (tx_multi_dma_p1[4] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(4);
            }
          if (tx_multi_dma_p1[5] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(5);
            }
          if (tx_multi_dma_p1[6] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(6);
            }
          if (tx_multi_dma_p1[7] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(7);
            }
          if (tx_multi_dma_p1[8] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(8);
            }
          if (tx_multi_dma_p1[9] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(9);
            }
          if (tx_multi_dma_p1[10] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(10);
            }
          if (tx_multi_dma_p1[11] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(11);
            }
          if (tx_multi_dma_p1[12] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(12);
            }
          if (tx_multi_dma_p1[13] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(13);
            }
          if (tx_multi_dma_p1[14] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(14);
            }
          if (tx_multi_dma_p1[15] == 1'b1)
            {
             MacTxPort[mac_port].add_channels(15);
            }
         }
       else
       {
        printf("KHH-TX ERROR : FOR NIU_AddTxChannels, Unexpected TX Port Value %d.\n", mac_port);
       }
      }
    else if (tx_multi_port == 1 && (tx_multi_dma_p0[15:0] == 16'h0 || tx_multi_dma_p1[15:0] == 16'h0))
      {
       printf("KHH-TX ERROR : FOR NIU_AddTxChannels, FOR NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = %h.\n", tx_multi_dma_p0);
       printf("KHH-TX ERROR : FOR NIU_AddTxChannels, FOR NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P1 = %h.\n", tx_multi_dma_p1);
      }
    else if (tx_multi_port == 1 && tx_multi_dma_p0[15:0] > 16'h0 && tx_multi_dma_p1[15:0] > 16'h0)
      {
       printf("KHH-TX Debug : FOR NIU_AddTxChannels, NIU_TX_MULTI_PORT = %d & NIU_TX_MULTI_DMA_P0 = %h MODE.\n", tx_multi_port, tx_multi_dma_p0);
       printf("KHH-TX Debug : FOR NIU_AddTxChannels, NIU_TX_MULTI_PORT = %d & NIU_TX_MULTI_DMA_P1 = %h MODE.\n", tx_multi_port, tx_multi_dma_p1);
       mac_port = 0;
          if (tx_multi_dma_p0[0] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA0 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(0);
            }
          if (tx_multi_dma_p0[1] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA1 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(1);
            }
          if (tx_multi_dma_p0[2] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA2 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(2);
            }
          if (tx_multi_dma_p0[3] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA3 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(3);
            }
          if (tx_multi_dma_p0[4] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA4 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(4);
            }
          if (tx_multi_dma_p0[5] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA5 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(5);
            }
          if (tx_multi_dma_p0[6] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA6 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(6);
            }
          if (tx_multi_dma_p0[7] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA7 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(7);
            }
          if (tx_multi_dma_p0[8] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA8 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(8);
            }
          if (tx_multi_dma_p0[9] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA9 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(9);
            }
          if (tx_multi_dma_p0[10] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA10 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(10);
            }
          if (tx_multi_dma_p0[11] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA11 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(11);
            }
          if (tx_multi_dma_p0[12] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA12 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(12);
            }
          if (tx_multi_dma_p0[13] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA13 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(13);
            }
          if (tx_multi_dma_p0[14] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA14 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(14);
            }
          if (tx_multi_dma_p0[15] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA15 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(15);
            }
       mac_port = 1;
          if (tx_multi_dma_p1[0] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA0 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(0);
            }
          if (tx_multi_dma_p1[1] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA1 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(1);
            }
          if (tx_multi_dma_p1[2] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA2 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(2);
            }
          if (tx_multi_dma_p1[3] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA3 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(3);
            }
          if (tx_multi_dma_p1[4] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA4 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(4);
            }
          if (tx_multi_dma_p1[5] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA5 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(5);
            }
          if (tx_multi_dma_p1[6] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA6 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(6);
            }
          if (tx_multi_dma_p1[7] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA7 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(7);
            }
          if (tx_multi_dma_p1[8] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA8 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(8);
            }
          if (tx_multi_dma_p1[9] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA9 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(9);
            }
          if (tx_multi_dma_p1[10] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA10 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(10);
            }
          if (tx_multi_dma_p1[11] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA11 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(11);
            }
          if (tx_multi_dma_p1[12] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA12 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(12);
            }
          if (tx_multi_dma_p1[13] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA13 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(13);
            }
          if (tx_multi_dma_p1[14] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA14 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(14);
            }
          if (tx_multi_dma_p1[15] == 1'b1)
            {
             printf("KHH-TX Debug : FOR DMA15 NIU_AddTxChannels FOR PORT %d.\n", mac_port);
             MacTxPort[mac_port].add_channels(15);
            }
        }
       else
       {
        printf("KHH-TX ERROR : FOR NIU_AddTxChannels, INVALID COMBINATION FOR NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = %h.\n",tx_multi_port, tx_multi_dma_p0);
        printf("KHH-TX ERROR : FOR NIU_AddTxChannels, INVALID COMBINATION FOR NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P1 = %h.\n",tx_multi_port, tx_multi_dma_p1);
       }
   }
*/
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_SetTxMaxBurst (integer mac_port, integer dma_no, integer SetTxMaxBurst_Data, 
                                       (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{
integer mac_id = mac_port;     

 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }

 if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_SetTxMaxBurst, MAC_ID = %0d & DMA_NO = %0d", mac_id, dma_no));
    MacTxPort[mac_id].dma[dma_no].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
   }
 else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_SetTxMaxBurst, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
    if (mac_id == 0)
      {
       if (tx_multi_dma_p0[0] == 1'b1)
         {
          MacTxPort[mac_id].dma[0].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[1] == 1'b1)
         {
          MacTxPort[mac_id].dma[1].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[2] == 1'b1)
         {
          MacTxPort[mac_id].dma[2].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[3] == 1'b1)
         {
          MacTxPort[mac_id].dma[3].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[4] == 1'b1)
         {
          MacTxPort[mac_id].dma[4].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[5] == 1'b1)
         {
          MacTxPort[mac_id].dma[5].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[6] == 1'b1)
         {
          MacTxPort[mac_id].dma[6].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[7] == 1'b1)
         {
          MacTxPort[mac_id].dma[7].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[8] == 1'b1)
         {
          MacTxPort[mac_id].dma[8].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[9] == 1'b1)
         {
          MacTxPort[mac_id].dma[9].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[10] == 1'b1)
         {
          MacTxPort[mac_id].dma[10].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[11] == 1'b1)
         {
          MacTxPort[mac_id].dma[11].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[12] == 1'b1)
         {
          MacTxPort[mac_id].dma[12].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[13] == 1'b1)
         {
          MacTxPort[mac_id].dma[13].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[14] == 1'b1)
         {
          MacTxPort[mac_id].dma[14].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[15] == 1'b1)
         {
          MacTxPort[mac_id].dma[15].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
      }
    else if (mac_id == 1)
      {
       if (tx_multi_dma_p1[0] == 1'b1)
         {
          MacTxPort[mac_id].dma[0].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[1] == 1'b1)
         {
          MacTxPort[mac_id].dma[1].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[2] == 1'b1)
         {
          MacTxPort[mac_id].dma[2].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[3] == 1'b1)
         {
          MacTxPort[mac_id].dma[3].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[4] == 1'b1)
         {
          MacTxPort[mac_id].dma[4].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[5] == 1'b1)
         {
          MacTxPort[mac_id].dma[5].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[6] == 1'b1)
         {
          MacTxPort[mac_id].dma[6].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[7] == 1'b1)
         {
          MacTxPort[mac_id].dma[7].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[8] == 1'b1)
         {
          MacTxPort[mac_id].dma[8].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[9] == 1'b1)
         {
          MacTxPort[mac_id].dma[9].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[10] == 1'b1)
         {
          MacTxPort[mac_id].dma[10].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[11] == 1'b1)
         {
          MacTxPort[mac_id].dma[11].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[12] == 1'b1)
         {
          MacTxPort[mac_id].dma[12].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[13] == 1'b1)
         {
          MacTxPort[mac_id].dma[13].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[14] == 1'b1)
         {
          MacTxPort[mac_id].dma[14].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[15] == 1'b1)
         {
          MacTxPort[mac_id].dma[15].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
      }
    else
      {
        PR_ERROR("fc_niu_asm_event", MON_ERROR,
                 psprintf("NIU_SetTxMaxBurst: Unexpected TX Port Value %0d", mac_port));
      }
   }
 else if (tx_multi_port == 1 && (tx_multi_dma_p0[15:0] == 16'h0 || tx_multi_dma_p1[15:0] == 16'h0))
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_SetTxMaxBurst: NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_dma_p0, tx_multi_dma_p1));
   }
 else if (tx_multi_port == 1 && tx_multi_dma_p0[15:0] > 16'h0 && tx_multi_dma_p1[15:0] > 16'h0)
   {
    if (tx_multi_dma_p1[15:0]  & tx_multi_dma_p0[15:0])
      {
       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                psprintf("NIU_SetTxMaxBurst: Same DMA assigned to multiple ports: TX_MULTI_DMA_P0 = 0x%h, TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
      }
    else
      {
       PR_INFO("fc_niu_asm_event", MON_INFO,
               psprintf("KHH-TX Debug : FOR NIU_SetTxMaxBurst, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
       mac_id = 0;
       if (tx_multi_dma_p0[0] == 1'b1)
         {
          MacTxPort[mac_id].dma[0].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[1] == 1'b1)
         {
          MacTxPort[mac_id].dma[1].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[2] == 1'b1)
         {
          MacTxPort[mac_id].dma[2].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[3] == 1'b1)
         {
          MacTxPort[mac_id].dma[3].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[4] == 1'b1)
         {
          MacTxPort[mac_id].dma[4].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[5] == 1'b1)
         {
          MacTxPort[mac_id].dma[5].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[6] == 1'b1)
         {
          MacTxPort[mac_id].dma[6].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[7] == 1'b1)
         {
          MacTxPort[mac_id].dma[7].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[8] == 1'b1)
         {
          MacTxPort[mac_id].dma[8].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[9] == 1'b1)
         {
          MacTxPort[mac_id].dma[9].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[10] == 1'b1)
         {
          MacTxPort[mac_id].dma[10].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[11] == 1'b1)
         {
          MacTxPort[mac_id].dma[11].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[12] == 1'b1)
         {
          MacTxPort[mac_id].dma[12].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[13] == 1'b1)
         {
          MacTxPort[mac_id].dma[13].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[14] == 1'b1)
         {
          MacTxPort[mac_id].dma[14].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p0[15] == 1'b1)
         {
          MacTxPort[mac_id].dma[15].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       mac_id = 1;
       if (tx_multi_dma_p1[0] == 1'b1)
         {
          MacTxPort[mac_id].dma[0].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[1] == 1'b1)
         {
          MacTxPort[mac_id].dma[1].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[2] == 1'b1)
         {
          MacTxPort[mac_id].dma[2].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[3] == 1'b1)
         {
          MacTxPort[mac_id].dma[3].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[4] == 1'b1)
         {
          MacTxPort[mac_id].dma[4].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[5] == 1'b1)
         {
          MacTxPort[mac_id].dma[5].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[6] == 1'b1)
         {
          MacTxPort[mac_id].dma[6].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[7] == 1'b1)
         {
          MacTxPort[mac_id].dma[7].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[8] == 1'b1)
         {
          MacTxPort[mac_id].dma[8].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[9] == 1'b1)
         {
          MacTxPort[mac_id].dma[9].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[10] == 1'b1)
         {
          MacTxPort[mac_id].dma[10].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[11] == 1'b1)
         {
          MacTxPort[mac_id].dma[11].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[12] == 1'b1)
         {
          MacTxPort[mac_id].dma[12].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[13] == 1'b1)
         {
          MacTxPort[mac_id].dma[13].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[14] == 1'b1)
         {
          MacTxPort[mac_id].dma[14].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
       if (tx_multi_dma_p1[15] == 1'b1)
         {
          MacTxPort[mac_id].dma[15].SetTxMaxBurst(SetTxMaxBurst_Data); 	// MacTxPort[mac_id].dma[j].SetTxMaxBurst(32'd500);
         }
      }
   }
 else
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_SetTxMaxBurst: Invalid combination for NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
   }
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_TxDMAActivate (integer mac_port, integer dma_activelist, 
                                       (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
/*@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
    MacTxPort[mac_id].SetActive(dma_activelist);

  dma_activelist is a 32 bit parameter which each bit signifies a dma value as shown below:

      b15   b14   b13   b12   b11   b10   b9    b8    b7    b6    b5    b4    b3    b2    b1    b0
     dma15 dma14 dma13 dma12 dma11 dma10 dma9  dma8  dma7  dma6  dma5  dma4  dma3  dma2  dma1  dma0
@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@*/
{
integer mac_id = mac_port;     
integer tx_multi_dma_p0_list = 0;     
integer tx_multi_dma_p1_list = 0;     
bit [31:0] dma_no = 32'h0;

integer mac_id_0 = 0;     
integer mac_id_1 = 0;     

 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }

dma_no = dma_activelist;

 PR_INFO("fc_niu_asm_event", MON_INFO,
         psprintf("KHH-TX Debug : FOR NIU_TxDMAActivate, MAC_ID = %0d DMA_ACTIVELIST = %0d DMA_NO = %0d", mac_id, dma_activelist, dma_no));


tx_multi_dma_p0_list = {16'h0,tx_multi_dma_p0[15:0]};
tx_multi_dma_p1_list = {16'h0,tx_multi_dma_p1[15:0]};

 if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
   {
    MacTxPort[mac_id] = new(mac_id);
     if (dma_no[0])
       {
        MacTxPort[mac_id].add_channels(0);
       }
     else if (dma_no[1])
       {
        MacTxPort[mac_id].add_channels(1);
       }
     else if (dma_no[2])
       {
        MacTxPort[mac_id].add_channels(2);
       }
     else if (dma_no[3])
       {
        MacTxPort[mac_id].add_channels(3);
       }
     else if (dma_no[4])
       {
        MacTxPort[mac_id].add_channels(4);
       }
     else if (dma_no[5])
       {
        MacTxPort[mac_id].add_channels(5);
       }
     else if (dma_no[6])
       {
        MacTxPort[mac_id].add_channels(6);
       }
     else if (dma_no[7])
       {
        MacTxPort[mac_id].add_channels(7);
       }
     else if (dma_no[8])
       {
        MacTxPort[mac_id].add_channels(8);
       }
     else if (dma_no[9])
       {
        MacTxPort[mac_id].add_channels(9);
       }
     else if (dma_no[10])
       {
        MacTxPort[mac_id].add_channels(10);
       }
     else if (dma_no[11])
       {
        MacTxPort[mac_id].add_channels(11);
       }
     else if (dma_no[12])
       {
        MacTxPort[mac_id].add_channels(12);
       }
     else if (dma_no[13])
       {
        MacTxPort[mac_id].add_channels(13);
       }
     else if (dma_no[14])
       {
        MacTxPort[mac_id].add_channels(14);
       }
     else if (dma_no[15])
       {
        MacTxPort[mac_id].add_channels(15);
       }
     else
       {
        PR_ERROR("fc_niu_asm_event", MON_ERROR,
                 psprintf("NIU_TxDMAActivate: Unexpected DMA value of 0x%h", dma_no));
       }
        
    MacTxPort[mac_id].SetActive(dma_activelist);
   }
 else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_TxDMAActivate, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
    if (mac_id == 0)
      {
       MacTxPort[mac_id] = new(mac_id);

        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
        //@@ Add requested dma channels for port 0                @@
        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
          if (tx_multi_dma_p0[0] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(0);
            }
          if (tx_multi_dma_p0[1] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(1);
            }
          if (tx_multi_dma_p0[2] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(2);
            }
          if (tx_multi_dma_p0[3] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(3);
            }
          if (tx_multi_dma_p0[4] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(4);
            }
          if (tx_multi_dma_p0[5] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(5);
            }
          if (tx_multi_dma_p0[6] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(6);
            }
          if (tx_multi_dma_p0[7] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(7);
            }
          if (tx_multi_dma_p0[8] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(8);
            }
          if (tx_multi_dma_p0[9] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(9);
            }
          if (tx_multi_dma_p0[10] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(10);
            }
          if (tx_multi_dma_p0[11] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(11);
            }
          if (tx_multi_dma_p0[12] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(12);
            }
          if (tx_multi_dma_p0[13] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(13);
            }
          if (tx_multi_dma_p0[14] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(14);
            }
          if (tx_multi_dma_p0[15] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(15);
            }
       MacTxPort[mac_id].SetActive(tx_multi_dma_p0_list);
      }
    else if (mac_id == 1)
      {
       MacTxPort[mac_id] = new(mac_id);

        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
        //@@ Add requested dma channels for port 1                @@
        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
          if (tx_multi_dma_p1[0] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(0);
            }
          if (tx_multi_dma_p1[1] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(1);
            }
          if (tx_multi_dma_p1[2] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(2);
            }
          if (tx_multi_dma_p1[3] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(3);
            }
          if (tx_multi_dma_p1[4] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(4);
            }
          if (tx_multi_dma_p1[5] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(5);
            }
          if (tx_multi_dma_p1[6] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(6);
            }
          if (tx_multi_dma_p1[7] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(7);
            }
          if (tx_multi_dma_p1[8] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(8);
            }
          if (tx_multi_dma_p1[9] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(9);
            }
          if (tx_multi_dma_p1[10] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(10);
            }
          if (tx_multi_dma_p1[11] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(11);
            }
          if (tx_multi_dma_p1[12] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(12);
            }
          if (tx_multi_dma_p1[13] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(13);
            }
          if (tx_multi_dma_p1[14] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(14);
            }
          if (tx_multi_dma_p1[15] == 1'b1)
            {
             MacTxPort[mac_id].add_channels(15);
            }
       MacTxPort[mac_id].SetActive(tx_multi_dma_p1_list);
      }
    else
      {
       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                psprintf("NIU_TxDMAActivate: Unexpected TX Port Value %0d", mac_port));
      }
   }
 else if (tx_multi_port == 1 && (tx_multi_dma_p0[15:0] == 16'h0 || tx_multi_dma_p1[15:0]  == 16'h0))
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_TxDMAActivate: NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
   }
 else if (tx_multi_port == 1 && tx_multi_dma_p0[15:0] > 16'h0 && tx_multi_dma_p1[15:0]  > 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_TxDMAActivate, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));

    if (tx_multi_dma_p1[15:0]  & tx_multi_dma_p0[15:0])
      {
       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                psprintf("NIU_TxDMAActivate: Same DMA assigned to multiple ports: TX_MULTI_DMA_P0 = 0x%h, TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
      }
    else
      {

//  KHOSROW    1<<tx_multi_dma_p0
//  Shifting method should be implemented when we get a chance

       mac_id_0 = 0;
       MacTxPort[mac_id_0] = new(mac_id_0);

        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
        //@@ Add requested dma channels for port 0                @@
        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
          if (tx_multi_dma_p0[0] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(0);
            }
          if (tx_multi_dma_p0[1] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(1);
            }
          if (tx_multi_dma_p0[2] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(2);
            }
          if (tx_multi_dma_p0[3] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(3);
            }
          if (tx_multi_dma_p0[4] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(4);
            }
          if (tx_multi_dma_p0[5] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(5);
            }
          if (tx_multi_dma_p0[6] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(6);
            }
          if (tx_multi_dma_p0[7] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(7);
            }
          if (tx_multi_dma_p0[8] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(8);
            }
          if (tx_multi_dma_p0[9] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(9);
            }
          if (tx_multi_dma_p0[10] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(10);
            }
          if (tx_multi_dma_p0[11] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(11);
            }
          if (tx_multi_dma_p0[12] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(12);
            }
          if (tx_multi_dma_p0[13] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(13);
            }
          if (tx_multi_dma_p0[14] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(14);
            }
          if (tx_multi_dma_p0[15] == 1'b1)
            {
             MacTxPort[mac_id_0].add_channels(15);
            }
       MacTxPort[mac_id_0].SetActive(tx_multi_dma_p0_list);
       mac_id_1 = 1;
       MacTxPort[mac_id_1] = new(mac_id_1);

        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
        //@@ Add requested dma channels for port 1                @@
        //@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
          if (tx_multi_dma_p1[0] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(0);
            }
          if (tx_multi_dma_p1[1] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(1);
            }
          if (tx_multi_dma_p1[2] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(2);
            }
          if (tx_multi_dma_p1[3] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(3);
            }
          if (tx_multi_dma_p1[4] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(4);
            }
          if (tx_multi_dma_p1[5] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(5);
            }
          if (tx_multi_dma_p1[6] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(6);
            }
          if (tx_multi_dma_p1[7] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(7);
            }
          if (tx_multi_dma_p1[8] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(8);
            }
          if (tx_multi_dma_p1[9] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(9);
            }
          if (tx_multi_dma_p1[10] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(10);
            }
          if (tx_multi_dma_p1[11] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(11);
            }
          if (tx_multi_dma_p1[12] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(12);
            }
          if (tx_multi_dma_p1[13] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(13);
            }
          if (tx_multi_dma_p1[14] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(14);
            }
          if (tx_multi_dma_p1[15] == 1'b1)
            {
             MacTxPort[mac_id_1].add_channels(15);
            }
       MacTxPort[mac_id_1].SetActive(tx_multi_dma_p1_list);
      }
   }
 else
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_TxDMAActivate: Invalid combination for NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h",tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
   }
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_InitTxDma (integer mac_port, integer dma_no, bit Xlate,
                                   (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{
bit [39:0] rng_st_addr;
integer mac_id = mac_port;     
bit[12:0] length;
bit [5:0] rand_num;
bit [63:0] config_data;

 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }

 if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_InitTxDma, MAC_ID = %0d & DMA_NO = %0d", mac_id, dma_no));
    MacTxPort[mac_id].dma[dma_no].xlate_on = Xlate;
    MacTxPort[mac_id].dma[dma_no].InitTXDMA(256,rng_st_addr); // 20 is ring-size, changed to 32
   }
 else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR NIU_InitTxDma, NIU_TX_MULTI_PORT = %0d, MAC_PORT = %0d, DMA_NO = %0h, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, mac_port, dma_no, tx_multi_dma_p0, tx_multi_dma_p1));
          MacTxPort[mac_id].dma[dma_no].xlate_on = Xlate;
          MacTxPort[mac_id].dma[dma_no].InitTXDMA(256,rng_st_addr); // 20 is ring-size, changed to 32
   }
 else if (tx_multi_port == 1 && (tx_multi_dma_p0[15:0] == 16'h0 || tx_multi_dma_p1[15:0]  == 16'h0))
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_InitTxDma: NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_dma_p0, tx_multi_dma_p1));
   }
 else if (tx_multi_port == 1 && tx_multi_dma_p0[15:0] > 16'h0 && tx_multi_dma_p1[15:0]  > 16'h0)
   {
    if (tx_multi_dma_p1[15:0]  & tx_multi_dma_p0[15:0])
      {
       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                psprintf("NIU_InitTxDma: Same DMA assigned to multiple ports: TX_MULTI_DMA_P0 = 0x%h, TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
      }
    else
      {
       PR_INFO("fc_niu_asm_event", MON_INFO,
               psprintf("KHH-TX Debug : FOR NIU_InitTxDma, NIU_TX_MULTI_PORT = %0d, MAC_PORT = %0d, DMA_NO = %0h, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, mac_port, dma_no, tx_multi_dma_p0, tx_multi_dma_p1));
       MacTxPort[mac_id].dma[dma_no].xlate_on = Xlate;
       MacTxPort[mac_id].dma[dma_no].InitTXDMA(256,rng_st_addr); // 20 is ring-size, changed to 32
      }
   }
 else
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("NIU_InitTxDma: Invalid combination for NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
   }


/*
length = 13'h0fff;
rand_num = random()%64;

   MacTxPort[mac_id].dma[dma_no].SetTxLPValid(64'h3);
   MacTxPort[mac_id].dma[dma_no].SetTxLPMask1(64'h0);
   MacTxPort[mac_id].dma[dma_no].SetTxLPMask2(64'h0);
   MacTxPort[mac_id].dma[dma_no].ring_start_addr = 44'h000  + dma_no*44'h0_0001_0000;
   MacTxPort[mac_id].dma[dma_no].ring_current_addr = 44'h000  + dma_no*44'h0_0001_0000;

  if (get_plus_arg (CHECK, "TX_GATHER"))
    MacTxPort[mac_id].dma[dma_no].gather_mode = 1;
  else
    MacTxPort[mac_id].dma[dma_no].gather_mode = 0;


 config_data = {3'h0,length,4'h0,4'h0,MacTxPort[mac_id].dma[dma_no].ring_start_addr[39:6],rand_num};
// config_data = {16'h0FFF,4'h0,MacTxPort[mac_id].dma[0].ring_start_addr[43:0]};
 MacTxPort[mac_id].dma[dma_no].setTxRingConfig(config_data);
*/
}

// ***********************************************************************************
task AsmToVeraIntf::NIU_EXIT_chk (integer mac_port)
{
integer mac_id = mac_port;     // port 0 hardcoded; MAQ

  MacTxPort[mac_id].check_exit_status();
}

// ***********************************************************************************
task AsmToVeraIntf::TxPktGen (integer mac_port, integer dmaport, integer numofpacket,
                              (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{

 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }
 fork
 {
   TxPktGen_int(mac_port, dmaport, numofpacket,
                tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1);
 }
 join none
}

// ***********************************************************************************
task AsmToVeraIntf::TxPktGen_int (integer mac_port, integer dmaport, integer numofpacket,
                                  (integer tx_multi_port = 0, bit [15:0] tx_multi_dma_p0 = 16'h0, bit [15:0] tx_multi_dma_p1 = 16'h0))
{

//static TxPacketGenConfig PktGenConfig;
static TxPacketGenConfig PktGenConfig0;
static TxPacketGenConfig PktGenConfig1;
//TxPacketGenConfig config;
TxPacketGenConfig config0;
TxPacketGenConfig config1;
integer i, j;

bit interrupt_last_packet = 1'b0;

integer mac_id = mac_port;

    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("TxPktGen_int:  mac_port = %0d, dmaport = %0d, numofpacket = %0d, tx_multi_port = %0d, tx_multi_dma_p0 = %0d, tx_multi_dma_p1 = %0d", mac_port, dmaport, numofpacket, tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));

PktGenConfig0 = new;
PktGenConfig1 = new;

 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P0="))
   {
    tx_multi_dma_p0 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P0=");
   }
 if (get_plus_arg (CHECK, "NIU_TX_MULTI_DMA_P1="))
   {
    tx_multi_dma_p1 = get_plus_arg( HNUM, "NIU_TX_MULTI_DMA_P1=");
   }

 if (get_plus_arg (CHECK, "NIU_TX_MARK_LAST_PACKET_FOR_INTERRUPT"))
   {
    interrupt_last_packet = 1'b1;
   }

// printf("MAQ-Debug : After  Initia desc_ring.ring_current_addr = %h \n", MacTxPort[mac_id].dma[dmaport].desc_ring.ring_current_addr);
// printf("MAQ-Debug : After  Initia dma.ring_current_addr = %h \n", MacTxPort[mac_id].dma[dmaport].ring_current_addr);

//if (mailbox_get(NO_WAIT, config_mb, config))
//    PktGenConfig = config;

//  for (i=0; i<numofpacket; i++){
//        MacTxPort[mac_id].dma[dmaport].gen_txpacket(i, PktGenConfig);
// 	printf("MAQ-Debug : Inloop  desc_ring.ring_current_addr = %h \n", MacTxPort[mac_id].dma[dmaport].desc_ring.ring_current_addr);
// 	printf("MAQ-Debug : Inloop  dma.ring_current_addr = %h \n", MacTxPort[mac_id].dma[dmaport].ring_current_addr);
//  }

 if (tx_multi_port == 0 && tx_multi_dma_p0 == 16'h0 && tx_multi_dma_p1 == 16'h0)
   {
    if (mac_id == 0)
      {
       if (mailbox_get(NO_WAIT, config0_mb, config0))
           PktGenConfig0 = config0;

         for (i=0; i<numofpacket; i++){
           if (interrupt_last_packet && i == numofpacket-1)
             PktGenConfig0.mark_bit = 1;
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("KHH-TX Debug : FOR TxPktGen_int, FOR PORT0 I = %0d, MARK_BIT = %0d", i, PktGenConfig0.mark_bit));
               MacTxPort[mac_id].dma[dmaport].gen_txpacket(i, PktGenConfig0);
         }
      }
    else if (mac_id == 1)
      {
       if (mailbox_get(NO_WAIT, config1_mb, config1))
           PktGenConfig1 = config1;

         for (i=0; i<numofpacket; i++){
           if (interrupt_last_packet && i == numofpacket-1)
             PktGenConfig1.mark_bit = 1;
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("KHH-TX Debug : FOR TxPktGen_int, FOR PORT1 I = %0d, MARK_BIT = %0d", i, PktGenConfig1.mark_bit));
               MacTxPort[mac_id].dma[dmaport].gen_txpacket(i, PktGenConfig1);
         }
      }
    else
      {
       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                psprintf("TxPktGen_int: Invalid MAC port = %0d", mac_id));
      }
   }
 else if (tx_multi_port == 0 && (tx_multi_dma_p0 > 16'h0 || tx_multi_dma_p1 > 16'h0))
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR TxPktGen_int, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
    if (mac_id == 0)
      {
       if (mailbox_get(NO_WAIT, config0_mb, config0))
           PktGenConfig0 = config0;

       for (i=0; i<numofpacket; i++)
          {
           j = 0;
           if (tx_multi_dma_p0[0] == 1'b1)
             {
              MacTxPort[mac_id].dma[0].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[0]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[1] == 1'b1)
             {
              MacTxPort[mac_id].dma[1].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[1]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[2] == 1'b1)
             {
              MacTxPort[mac_id].dma[2].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[2]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[3] == 1'b1)
             {
              MacTxPort[mac_id].dma[3].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[3]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[4] == 1'b1)
             {
              MacTxPort[mac_id].dma[4].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[4]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[5] == 1'b1)
             {
              MacTxPort[mac_id].dma[5].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[5]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[6] == 1'b1)
             {
              MacTxPort[mac_id].dma[6].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[6]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[7] == 1'b1)
             {
              MacTxPort[mac_id].dma[7].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[7]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[8] == 1'b1)
             {
              MacTxPort[mac_id].dma[8].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[8]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[9] == 1'b1)
             {
              MacTxPort[mac_id].dma[9].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[9]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[10] == 1'b1)
             {
              MacTxPort[mac_id].dma[10].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[10]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[11] == 1'b1)
             {
              MacTxPort[mac_id].dma[11].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[11]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[12] == 1'b1)
             {
              MacTxPort[mac_id].dma[12].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[12]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[13] == 1'b1)
             {
              MacTxPort[mac_id].dma[13].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[13]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[14] == 1'b1)
             {
              MacTxPort[mac_id].dma[14].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[14]));
              j = j + 1;
             }
           if (tx_multi_dma_p0[15] == 1'b1)
             {
              MacTxPort[mac_id].dma[15].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p0[15]));
              j = j + 1;
             }

           if (j>1)
             {
              i = i + (j-1);
             }
          }
      }
    else if (mac_id == 1)
      {
       if (mailbox_get(NO_WAIT, config1_mb, config1))
           PktGenConfig1 = config1;

       for (i=0; i<numofpacket; i++)
          {
           j = 0;
           if (tx_multi_dma_p1[0] == 1'b1)
             {
              MacTxPort[mac_id].dma[0].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[0]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[1] == 1'b1)
             {
              MacTxPort[mac_id].dma[1].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[1]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[2] == 1'b1)
             {
              MacTxPort[mac_id].dma[2].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[2]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[3] == 1'b1)
             {
              MacTxPort[mac_id].dma[3].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[3]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[4] == 1'b1)
             {
              MacTxPort[mac_id].dma[4].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[4]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[5] == 1'b1)
             {
              MacTxPort[mac_id].dma[5].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[5]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[6] == 1'b1)
             {
              MacTxPort[mac_id].dma[6].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[6]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[7] == 1'b1)
             {
              MacTxPort[mac_id].dma[7].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[7]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[8] == 1'b1)
             {
              MacTxPort[mac_id].dma[8].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[8]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[9] == 1'b1)
             {
              MacTxPort[mac_id].dma[9].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[9]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[10] == 1'b1)
             {
              MacTxPort[mac_id].dma[10].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[10]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[11] == 1'b1)
             {
              MacTxPort[mac_id].dma[11].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[11]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[12] == 1'b1)
             {
              MacTxPort[mac_id].dma[12].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[12]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[13] == 1'b1)
             {
              MacTxPort[mac_id].dma[13].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[13]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[14] == 1'b1)
             {
              MacTxPort[mac_id].dma[14].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[14]));
              j = j + 1;
             }
           if (tx_multi_dma_p1[15] == 1'b1)
             {
              MacTxPort[mac_id].dma[15].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = %0d", numofpacket,i,mac_id,tx_multi_dma_p1[15]));
              j = j + 1;
             }

           if (j>1)
             {
              i = i + (j-1);
             }
          }
      }
    else
    {
     PR_ERROR("fc_niu_asm_event", MON_ERROR,
              psprintf("TxPktGen_int: Unexpected TX Port Value %0d", mac_id));
    }
   }
 else if (tx_multi_port == 1 && (tx_multi_dma_p0[15:0] == 16'h0 && tx_multi_dma_p1[15:0]  == 16'h0))
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("TxPktGen_int: For NIU_TX_MULTI_PORT, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_dma_p0, tx_multi_dma_p1));
   }
 else if (tx_multi_port == 1 && tx_multi_dma_p0[15:0] > 16'h0 && tx_multi_dma_p1[15:0]  > 16'h0)
   {
    PR_INFO("fc_niu_asm_event", MON_INFO,
            psprintf("KHH-TX Debug : FOR TxPktGen_int, NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = %h, NIU_TX_MULTI_DMA_P1 = %h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
    mac_id = 0;
       if (mailbox_get(NO_WAIT, config0_mb, config0))
           PktGenConfig0 = config0;

       for (i=0; i<numofpacket/2; i++)
          {
           j = 0;
           if (tx_multi_dma_p0[0] == 1'b1)
             {
              MacTxPort[mac_id].dma[0].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 0", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[1] == 1'b1)
             {
              MacTxPort[mac_id].dma[1].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 1", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[2] == 1'b1)
             {
              MacTxPort[mac_id].dma[2].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 2", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[3] == 1'b1)
             {
              MacTxPort[mac_id].dma[3].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 3", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[4] == 1'b1)
             {
              MacTxPort[mac_id].dma[4].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 4", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[5] == 1'b1)
             {
              MacTxPort[mac_id].dma[5].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 5", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[6] == 1'b1)
             {
              MacTxPort[mac_id].dma[6].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 6", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[7] == 1'b1)
             {
              MacTxPort[mac_id].dma[7].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 7", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[8] == 1'b1)
             {
              MacTxPort[mac_id].dma[0].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 8", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[9] == 1'b1)
             {
              MacTxPort[mac_id].dma[1].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 9", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[10] == 1'b1)
             {
              MacTxPort[mac_id].dma[2].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 10", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[11] == 1'b1)
             {
              MacTxPort[mac_id].dma[3].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 11", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[12] == 1'b1)
             {
              MacTxPort[mac_id].dma[4].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 12", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[13] == 1'b1)
             {
              MacTxPort[mac_id].dma[5].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 13", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[14] == 1'b1)
             {
              MacTxPort[mac_id].dma[6].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 14", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p0[15] == 1'b1)
             {
              MacTxPort[mac_id].dma[7].gen_txpacket(i, PktGenConfig0);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 15", numofpacket,i,mac_id));
              j = j + 1;
             }

           if (j>1)
             {
              i = i + (j-1);
             }
          }
    mac_id = 1;
       if (mailbox_get(NO_WAIT, config1_mb, config1))
           PktGenConfig1 = config1;

//     for (i=0; i<numofpacket/2; i++)
       for (i=numofpacket/2; i<numofpacket; i++)
          {
           j = 0;
           if (tx_multi_dma_p1[0] == 1'b1)
             {
              MacTxPort[mac_id].dma[0].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 0", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[1] == 1'b1)
             {
              MacTxPort[mac_id].dma[1].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 1", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[2] == 1'b1)
             {
              MacTxPort[mac_id].dma[2].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 2", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[3] == 1'b1)
             {
              MacTxPort[mac_id].dma[3].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 3", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[4] == 1'b1)
             {
              MacTxPort[mac_id].dma[4].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 4", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[5] == 1'b1)
             {
              MacTxPort[mac_id].dma[5].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 5", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[6] == 1'b1)
             {
              MacTxPort[mac_id].dma[6].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 6", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[7] == 1'b1)
             {
              MacTxPort[mac_id].dma[7].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 7", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[8] == 1'b1)
             {
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : B4 FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 8", numofpacket,i,mac_id));
              MacTxPort[mac_id].dma[8].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : AF FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 8", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[9] == 1'b1)
             {
              MacTxPort[mac_id].dma[9].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 9", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[10] == 1'b1)
             {
              MacTxPort[mac_id].dma[10].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 10", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[11] == 1'b1)
             {
              MacTxPort[mac_id].dma[11].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 11", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[12] == 1'b1)
             {
              MacTxPort[mac_id].dma[12].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 12", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[13] == 1'b1)
             {
              MacTxPort[mac_id].dma[13].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 13", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[14] == 1'b1)
             {
              MacTxPort[mac_id].dma[14].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 14", numofpacket,i,mac_id));
              j = j + 1;
             }
           if (tx_multi_dma_p1[15] == 1'b1)
             {
              MacTxPort[mac_id].dma[15].gen_txpacket(i, PktGenConfig1);
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("KHH-TX Debug : FOR PKT_CNT = %0d, SENT PKT = %0d TO TX_PORT = %0d TO DMA = 15", numofpacket,i,mac_id));
              j = j + 1;
             }

           if (j>1)
             {
              i = i + (j-1);
             }
          }
   }
 else
   {
    PR_ERROR("fc_niu_asm_event", MON_ERROR,
             psprintf("TxPktGen_int: Invalid combination for NIU_TX_MULTI_PORT = %0d, NIU_TX_MULTI_DMA_P0 = 0x%h, NIU_TX_MULTI_DMA_P1 = 0x%h", tx_multi_port, tx_multi_dma_p0, tx_multi_dma_p1));
   }
}

// ***********************************************************************************
// NIU Rx Tasks
// ***********************************************************************************
task AsmToVeraIntf::NIU_InitRxDma (integer RxDmaChnlNo, 
                                   integer RxDescRingLen, 
                                   bit [39:0] RxRingStartAddr, 
                                   bit [63:0] RbrConfData, 
                                   integer RxInitKick, 
                                   bit Xlate, 
                                   (bit [15:0] rx_multi_dma= 16'h0))
{
       bit [39:0] ring_start_address;
       bit [15:0] initial_kick;
       bit [15:0] desc_ring_length;
       bit [63:0] rbr_config_B_data;
       integer dma_chnl;
//       bit xlate = 1;

        // One single function to initialize the whole RXDMA channel
        // This function should be called for each RXDMA channel you want to initialize
	dma_chnl = RxDmaChnlNo;
        desc_ring_length = RxDescRingLen;
        ring_start_address = RxRingStartAddr;
        initial_kick = RxInitKick;
	rbr_config_B_data = RbrConfData;
        fork
        {
        rdmc.InitRXDMA(dma_chnl, desc_ring_length, ring_start_address, rbr_config_B_data, initial_kick, Xlate);
        }
        join none
        PR_INFO("fc_niu_asm_event", MON_INFO,
                "MAQ-DEBUG: NIU_InitRxDma Done");

}

// ***********************************************************************************
task AsmToVeraIntf::NIU_RxPktConf (integer RxPktCnt, (integer iport = 0))
{
integer n;
 bit [12:0] ii = 12'h0;
 bit [7:0] DA_L = 8'h0;

/*
     for(n = 0; n< RxPktCnt; n++) {
        
        flow[n] = new;
        flow[n].src_node.l2_addr =  48'hde_f0_72_94_38_15;
        flow[n].src_node.tos     =  8'hf5;
        flow[n].src_node.tci     = 16'hcb00;
        flow[n].src_node.ip_addr = 32'hcccc_0000;
        flow[n].src_node.src_port = 20'h00001;
                
        flow[n].dst_node.l2_addr = 48'h12_34_56_78_9a_bc;
        flow[n].dst_node.tci     = 16'hcb00;
        flow[n].dst_node.ip_addr = 32'h8888_0000;
        flow[n].dst_node.src_port = 20'h00001;
                
        flow[n].tup.src_tcp_udp_port = 16'h1234;
        flow[n].tup.dst_tcp_udp_port = 16'hABCD;
        flow[n].frame.frame_type = 5'b00010;
        flow[n].frame.frame_class = CL_IP;
        flow[n].frame.type = -1;
        flow[n].frame.class_mask = 0;
        flow[n].frame.class_funct = CLF_SRC;
        flow[n].frame.data_type = DAT_SEQ |DAT_LEN_EXACT;
        flow[n].frame.data_seed = 128;
        flow[n].rx_param.rcv_isn = 32'hA5A5_F5F5;
        flow[n].fl_state.tcp_flags = 6'b00_0010;
        flow[n].flow_no = 0;
      }
	printf("MAQ-DEBUG: NIU_RxPktConf Done  Time: %0d.\n", {get_time(HI),get_time(LO)});

// 	mailbox_put (flow_mb, rxflow);
*/
  DA_L = 8'h0;
  if (iport === 0)
    {
     for(n = 0; n< RxPktCnt; n++) {

        flow_p0[n] = new;
        flow_p0[n].frame.frame_type     = 5'b00010;
        flow_p0[n].frame.frame_class    = CL_IP;
        flow_p0[n].src_node.l2_addr     =  48'hde_f0_72_a0_a0_a0;
        flow_p0[n].src_node.tos         =  8'hf5;
        flow_p0[n].src_node.tci         = {ii[3:0],ii};
        flow_p0[n].src_node.ip_addr     = 32'hcccc_a0a0;
        flow_p0[n].src_node.src_port    = 20'h000a0;

        flow_p0[n].dst_node.l2_addr     = {40'h12_34_56_a0_a0,DA_L};
        flow_p0[n].dst_node.tci         = 16'hcb00;
        flow_p0[n].dst_node.ip_addr     = 32'h8888_b0b0;
        flow_p0[n].dst_node.src_port    = 20'h000b0;

        flow_p0[n].tup.src_tcp_udp_port = 16'h12a0;
        flow_p0[n].tup.dst_tcp_udp_port = 16'habb0;
        flow_p0[n].frame.type           = -1;
        flow_p0[n].frame.class_mask     = 0;
        flow_p0[n].frame.class_funct    = CLF_SRC;
        flow_p0[n].frame.data_type      = DAT_SEQ |DAT_LEN_EXACT;
        flow_p0[n].frame.data_seed      = 128;
        flow_p0[n].rx_param.rcv_isn     = 32'hA5A5_a0a0;
        flow_p0[n].fl_state.tcp_flags   = 6'b00_0010;
        flow_p0[n].flow_no = 0;
        ii = ii +1;
        if (DA_L == 8'h07)
          {
           DA_L = 8'h00;
          }
        else
          {
           DA_L = DA_L + 1;
          }
      }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxPktConf Done for IPORT %0d", iport));
    }
  else if (iport === 1)
    {
     for(n = 0; n< RxPktCnt; n++) {

        flow_p1[n] = new;
        flow_p1[n].frame.frame_type     = 5'b00010;
        flow_p1[n].frame.frame_class    = CL_IP;
        flow_p1[n].src_node.l2_addr     =  48'hde_f0_72_a1_a1_a1;
        flow_p1[n].src_node.tos         =  8'hf5;
        flow_p1[n].src_node.tci         = {ii[3:0],ii};
        flow_p1[n].src_node.ip_addr     = 32'hcccc_a1a1;
        flow_p1[n].src_node.src_port    = 20'h000a1;

        flow_p1[n].dst_node.l2_addr     = 48'h12_34_56_b1_b1_b1;
        flow_p1[n].dst_node.tci         = 16'hcb00;
        flow_p1[n].dst_node.ip_addr     = 32'h8888_b1b1;
        flow_p1[n].dst_node.src_port    = 20'h000b1;

        flow_p1[n].tup.src_tcp_udp_port = 16'h12a1;
        flow_p1[n].tup.dst_tcp_udp_port = 16'habb1;
        flow_p1[n].frame.type           = -1;
        flow_p1[n].frame.class_mask     = 0;
        flow_p1[n].frame.class_funct    = CLF_SRC;
        flow_p1[n].frame.data_type      = DAT_SEQ |DAT_LEN_EXACT;
        flow_p1[n].frame.data_seed      = 128;
        flow_p1[n].rx_param.rcv_isn     = 32'hA5A5_a1a1;
        flow_p1[n].fl_state.tcp_flags   = 6'b00_0010;
        flow_p1[n].flow_no = 0;
        ii = ii +1;
      }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxPktConf Done for IPORT %0d", iport));
    }
  else
    {
     PR_ERROR("fc_niu_asm_event", MON_ERROR,
              psprintf("NIU_RxPktConf does not support MAC port %0d", iport));
    }

}

// ***********************************************************************************
task AsmToVeraIntf::NIU_RxGenPkt (integer mac_port, 
                                  integer RxDmaChnlNo, 
                                  integer RxPktCnt, 
                                  integer RxPktLen,
                                  (integer rx_multi_PORT=0,
                                  bit [15:0] rx_multi_DMA= 16'h0))
{
integer portid;
integer chnlid;
integer pktcnt;
integer pktlen;
integer rx_multi_port;
bit [15:0] rx_multi_dma;

portid = mac_port;
chnlid = RxDmaChnlNo;
pktcnt = RxPktCnt;
pktlen = RxPktLen;
rx_multi_port = rx_multi_PORT;
rx_multi_dma  = rx_multi_DMA;

  fork
  {
   NIU_internalrx(portid, chnlid, pktcnt, pktlen, rx_multi_port, rx_multi_dma);
  }
  join none
}
task AsmToVeraIntf::NIU_internalrx(integer mac_port,
                                   integer RxDmaChnlNo,
                                   integer RxPktCnt,
                                   integer RxPktLen,
                                   (integer rx_multi_port=0,
                                   bit [15:0] rx_multi_dma= 16'h0))
{
shadow integer n;
integer data_length;
shadow integer no_of_pkts;
integer last_packet;
integer sweep;
shadow integer mac_id;
integer dma_chnl;
bit[47:0] mac_addr;

        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("KH-DEBUG: NIU_internalrx MAC_PORT = %0d, MULTI_PORT = %0d, MULTI_DMA = 0x%h", mac_port, rx_multi_port, rx_multi_dma));

	sweep = 0;
	mac_id = mac_port;
	dma_chnl = RxDmaChnlNo;
	data_length = RxPktLen;

       if (rx_multi_port == 1'b1)
          {
	   no_of_pkts = RxPktCnt/2;
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("KH-DEBUG: NIU_internalrx MULTI-PORT NO_OF_PKTS = %0d", no_of_pkts));
          }
        else
          {
	   no_of_pkts = RxPktCnt;
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("KH-DEBUG: NIU_internalrx SINGLE-PORT NO_OF_PKTS = %0d", no_of_pkts));
          }
/*
      for(n = 0; n< no_of_pkts; n++) {
      if ( mac_id ==0 | mac_id==1 ) {
           case(n%4) {
                         0:{ mac_addr = 48'h0100_FFFF_0001;
                flow[n].dst_node.l2_addr = mac_addr;
                           }
                         1:{ mac_addr = 48'h1111_FFFF_0003;
                flow[n].dst_node.l2_addr = mac_addr;
                           }
                         2:{ mac_addr = 48'h2722_FFFF_0005;
                flow[n].dst_node.l2_addr = mac_addr;
                           }
                         3:{ mac_addr = 48'h3333_FFFF_0007;
                flow[n].dst_node.l2_addr = mac_addr;
                           }
                   default  :{ mac_addr = 48'h2722_FFFF_0005;
            }
          }
        }
      }

       for(n = 0; n< no_of_pkts; n++) {
              printf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d, Time: %0d.\n",
                 mac_id,n,data_length, {get_time(HI),get_time(LO)});
          // Generate and send the packet
          last_packet = (n==(no_of_pkts-1));
          pktConfig.gen_rxPacket(flow[n], data_length,dma_chnl,mac_id,last_packet);

         case (sweep){
           1: data_length = data_length + 1;
           2: data_length = data_length + 2;
           3: data_length = data_length + 3;
           4: data_length = data_length + 4;
            default : data_length = data_length;
          }
       }
	printf("MAQ-DEBUG: NIU_RxGenPkt Done  Time: %0d.\n", {get_time(HI),get_time(LO)});
*/
  if (rx_multi_port == 0 && mac_id == 0 && rx_multi_dma == 16'h0)
    {
      for(n = 0; n< no_of_pkts; n++) {
           case(n%4) {
                         0:{ mac_addr = 48'h0100_FFFF_0001;
                flow_p0[n].dst_node.l2_addr = mac_addr;
                           }
                         1:{ mac_addr = 48'h1111_FFFF_0003;
                flow_p0[n].dst_node.l2_addr = mac_addr;
                           }
                         2:{ mac_addr = 48'h2722_FFFF_0005;
                flow_p0[n].dst_node.l2_addr = mac_addr;
                           }
                         3:{ mac_addr = 48'h3333_FFFF_0007;
                flow_p0[n].dst_node.l2_addr = mac_addr;
                           }
                   default  :{ mac_addr = 48'h2722_FFFF_0005;
            }
          }
      }

       for(n = 0; n< no_of_pkts; n++) {
          PR_INFO("fc_niu_asm_event", MON_INFO,
                  psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                 mac_id, n, data_length));
          // Generate and send the packet
          last_packet = (n==(no_of_pkts-1));
          pktConfig.gen_rxPacket(flow_p0[n], data_length,dma_chnl,mac_id,last_packet);

         case (sweep){
           1: data_length = data_length + 1;
           2: data_length = data_length + 2;
           3: data_length = data_length + 3;
           4: data_length = data_length + 4;
            default : data_length = data_length;
          }
       }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d", mac_id));
    }
  else if (rx_multi_port == 0 && mac_id == 0 && rx_multi_dma[7:0] > 0)
    {
      for(n = 0; n< no_of_pkts; n++) {
            case (rx_multi_dma[7:0])
                {
                 8'h0:{
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: Expected MULTI_DMA[3:0] = 'h%h to be greater than 8'h0", rx_multi_dma[3:0]));
                      }
                 8'h1:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                      }
                 8'h2:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 1;
                      }
                 8'h3:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 1;
                         }
                      }
                 8'h4:{
                       mac_addr = 48'h1234_56a0_a002;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;
                      }
                 8'h5:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }
                      }
                 8'h6:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 1;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }
                      }
                 8'h7:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }
                      }
                 8'h8:{
                       mac_addr = 48'h1234_56a0_a003;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 3;
                      }
                 8'h9:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'ha:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 1;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'hb:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'hc:{
                       mac_addr = 48'h1234_56a0_a002;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'hd:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'he:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 1;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'hf:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 3;
                         }
                      }
                 8'h10:{
                       mac_addr = 48'h1234_56a0_a004;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;
                      }
                 8'h20:{
                       mac_addr = 48'h1234_56a0_a005;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 5;
                      }
                 8'h40:{
                       mac_addr = 48'h1234_56a0_a006;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 6;
                      }
                 8'h80:{
                       mac_addr = 48'h1234_56a0_a007;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 7;
                      }
                 8'ha0:{
                       mac_addr = 48'h1234_56a0_a005;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 5;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                 8'hb0:{
                       mac_addr = 48'h1234_56a0_a004;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a005;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 5;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                 8'hc0:{
                       mac_addr = 48'h1234_56a0_a006;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 6;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                 8'hd0:{
                       mac_addr = 48'h1234_56a0_a004;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a006;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                 8'he0:{
                       mac_addr = 48'h1234_56a0_a005;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 5;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a006;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                 8'hf0:{
                       mac_addr = 48'h1234_56a0_a004;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a005;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 5;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a006;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a007;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 7;
                         }
                      }
                   default  :{ mac_addr = 48'h2722_FFFF_0005;
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: UN-Expected MULTI_DMA[7:0] = 0x%h assignment for MAC_ID = %0d", rx_multi_dma[7:0], mac_id));
            }
          }
      }

       for(n = 0; n< no_of_pkts; n++) {
              PR_INFO("fc_niu_asm_event", MON_INFO,
                      psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                               mac_id,n,data_length));
          // Generate and send the packet
          last_packet = (n==(no_of_pkts-1));
          pktConfig.gen_rxPacket(flow_p0[n], data_length,p0_dma_chnl[n],mac_id,last_packet);

         case (sweep){
           1: data_length = data_length + 1;
           2: data_length = data_length + 2;
           3: data_length = data_length + 3;
           4: data_length = data_length + 4;
            default : data_length = data_length;
          }
       }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d",mac_id));
    }
 else if (rx_multi_port == 0 && mac_id == 1 && rx_multi_dma[15:8] > 0)
    {
      for(n = 0; n< no_of_pkts; n++) {
            case (rx_multi_dma[15:8])
                {
                 8'h0:{
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: Expected MULTI_DMA[15:8] = 'h%h to be greater than 8'h0",rx_multi_dma[15:8]));
                      }
                 8'h1:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;
                      }
                 8'h2:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 6;
                      }
                 8'h3:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 6;
                         }
                      }
                 8'h4:{
                       mac_addr = 48'h1234_56b0_b002;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 5;
                      }
                 8'h5:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }
                      }
                 8'h6:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 6;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }
                      }
                 8'h7:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }
                      }
                 8'h8:{
                       mac_addr = 48'h1234_56b0_b003;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 4;
                      }
                 8'h9:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'ha:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 6;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'hb:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'hc:{
                       mac_addr = 48'h1234_56b0_b002;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 5;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'hd:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'he:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 6;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'hf:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 6;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 4;
                         }
                      }
                 8'h10:{
                       mac_addr = 48'h1234_56b0_b004;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;
                      }
                 8'h20:{
                       mac_addr = 48'h1234_56b0_b005;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 2;
                      }
                 8'h40:{
                       mac_addr = 48'h1234_56b0_b006;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                      }
                 8'h80:{
                       mac_addr = 48'h1234_56b0_b007;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 0;
                      }
                 8'ha0:{
                       mac_addr = 48'h1234_56b0_b005;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 2;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                 8'hb0:{
                       mac_addr = 48'h1234_56b0_b004;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b005;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 2;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                 8'hc0:{
                       mac_addr = 48'h1234_56b0_b006;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                 8'hd0:{
                       mac_addr = 48'h1234_56b0_b004;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b006;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                 8'he0:{
                       mac_addr = 48'h1234_56b0_b005;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 2;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b006;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                 8'hf0:{
                       mac_addr = 48'h1234_56b0_b004;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b005;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 2;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b006;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 1;
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b007;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 0;
                         }
                      }
                   default  :
                      {
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: UN-Expected MULTI_DMA[15:8] = 0x%h assignment for MAC_ID = %0d",rx_multi_dma[15:8],mac_id));
                      }
          }
      }

       for(n = 0; n< no_of_pkts; n++) {
          PR_INFO("fc_niu_asm_event", MON_INFO,
                  psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                           mac_id,n,data_length));
          // Generate and send the packet
          last_packet = (n==(no_of_pkts-1));
          pktConfig.gen_rxPacket(flow_p1[n], data_length,p1_dma_chnl[n],mac_id,last_packet);

         case (sweep){
           1: data_length = data_length + 1;
           2: data_length = data_length + 2;
           3: data_length = data_length + 3;
           4: data_length = data_length + 4;
            default : data_length = data_length;
          }
       }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d", mac_id));
    }
  else if (rx_multi_port == 0 && mac_id == 1 && rx_multi_dma == 16'h0)
//else if (rx_multi_port == 0 && mac_id == 1)
    {
      for(n = 0; n< no_of_pkts; n++) {
           case(n%4) {
                         0:{ mac_addr = 48'h0100_FFFF_0001;
                flow_p1[n].dst_node.l2_addr = mac_addr;
                           }
                         1:{ mac_addr = 48'h1111_FFFF_0003;
                flow_p1[n].dst_node.l2_addr = mac_addr;
                           }
                         2:{ mac_addr = 48'h2722_FFFF_0005;
                flow_p1[n].dst_node.l2_addr = mac_addr;
                           }
                         3:{ mac_addr = 48'h3333_FFFF_0007;
                flow_p1[n].dst_node.l2_addr = mac_addr;
                           }
                   default  :{ mac_addr = 48'h2722_FFFF_0005;
            }
          }
      }

       for(n = 0; n< no_of_pkts; n++) {
          PR_INFO("fc_niu_asm_event", MON_INFO,
                  psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                           mac_id,n,data_length));
          // Generate and send the packet
          last_packet = (n==(no_of_pkts-1));
          pktConfig.gen_rxPacket(flow_p1[n], data_length,dma_chnl,mac_id,last_packet);

         case (sweep){
           1: data_length = data_length + 1;
           2: data_length = data_length + 2;
           3: data_length = data_length + 3;
           4: data_length = data_length + 4;
            default : data_length = data_length;
          }
       }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d", mac_id));
    }
  else if (rx_multi_port == 1 && (rx_multi_dma[3:0] > 0 || rx_multi_dma[7:4] > 0))
//else if (rx_multi_port == 1)
    {
     PR_INFO("fc_niu_asm_event", MON_INFO,
             "KH-DEBUG: NIU_RxGenPkt Sending Packets to both IPORT 0 & IPORT 1");
     PR_INFO("fc_niu_asm_event", MON_INFO,
             psprintf("KH-DEBUG: B4FORK MULTI_PORT = %0d, MULTI_DMA =%h", rx_multi_port, rx_multi_dma));
     fork
      {
        mac_id = 0;
       PR_INFO("fc_niu_asm_event", MON_INFO,
               "KH-DEBUG: NIU_RxGenPkt START Sending Packets to both IPORT 0 in MULTI_PORT MODE");
       PR_INFO("fc_niu_asm_event", MON_INFO,
               psprintf("KH-DEBUG: MULTI_PORT = %0d, MULTI_DMA =%h", rx_multi_port,rx_multi_dma));
       for(n = 0; n< no_of_pkts; n++) {
            case (rx_multi_dma[3:0])
                {
                 4'h0:{
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: Expected MULTI_DMA[3:0] = 'h%h to be greater than 4'h0",rx_multi_dma[3:0]));
                      }
                 4'h1:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-10: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                      }
                 4'h2:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-20: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                      }
                 4'h3:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-30: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-31: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'h4:{
                       mac_addr = 48'h1234_56a0_a002;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-40: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                      }
                 4'h5:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-50: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-51: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'h6:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-60: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-61: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'h7:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-70: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-71: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-72: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'h8:{
                       mac_addr = 48'h1234_56a0_a003;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 6;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-80: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                      }
                 4'h9:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-90: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-91: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'ha:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-A0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-A1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'hb:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-B0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-B1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-B2: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'hc:{
                       mac_addr = 48'h1234_56a0_a002;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 4;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-C0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-C1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'hd:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-D0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-D1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-D2: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'he:{
                       mac_addr = 48'h1234_56a0_a001;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 2;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-E0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-E1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-E2: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                 4'hf:{
                       mac_addr = 48'h1234_56a0_a000;
                       flow_p0[n].dst_node.l2_addr = mac_addr;
                       p0_dma_chnl[n] = 0;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-F0: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a001;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 2;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F1: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a002;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 4;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F2: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56a0_a003;
                          flow_p0[n].dst_node.l2_addr = mac_addr;
                          p0_dma_chnl[n] = 6;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F3: FOR FLOW_P0[%0d], DMA_CHNL[%0d] = %0d",n,n,p0_dma_chnl[n]));
                         }
                      }
                   default  :
                      {mac_addr = 48'h2722_FFFF_0005;
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: UN-Expected MULTI_DMA[3:0] = 'h%h assignment for MAC_ID = %0d",rx_multi_dma[3:0],mac_id));
                      }
                }
       }
//      mac_id = 0;
        for(n = 0; n< no_of_pkts; n++) {
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                            mac_id,n,data_length));
           // Generate and send the packet
           last_packet = (n==(no_of_pkts-1));
           pktConfig.gen_rxPacket(flow_p0[n], data_length,p0_dma_chnl[n],mac_id,last_packet);

          case (sweep){
            1: data_length = data_length + 1;
            2: data_length = data_length + 2;
            3: data_length = data_length + 3;
            4: data_length = data_length + 4;
             default : data_length = data_length;
           }
        }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d", mac_id));
      }
      {
       mac_id = 1;
       for(n = 0; n< no_of_pkts; n++) {
            case (rx_multi_dma[7:4])
                {
                 4'h0:{
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: Expected MULTI_DMA[7:4] = 'h%h to be greater than 4'h0",rx_multi_dma[7:4]));
                      }
                 4'h1:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-10: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                      }
                 4'h2:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-20: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                      }
                 4'h3:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-30: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 3;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-31: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'h4:{
                       mac_addr = 48'h1234_56b0_b002;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 5;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-40: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                      }
                 4'h5:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-50: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-51: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'h6:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-60: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-61: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'h7:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-70: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 3;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-71: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-72: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'h8:{
                       mac_addr = 48'h1234_56b0_b003;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 7;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-80: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                      }
                 4'h9:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-90: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-91: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'ha:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-A0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-A1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'hb:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-B0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 3;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-B1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-B2: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'hc:{
                       mac_addr = 48'h1234_56b0_b002;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 5;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-C0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-C1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'hd:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-D0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-D1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-D2: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'he:{
                       mac_addr = 48'h1234_56b0_b001;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 3;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-E0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-E1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-E2: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                 4'hf:{
                       mac_addr = 48'h1234_56b0_b000;
                       flow_p1[n].dst_node.l2_addr = mac_addr;
                       p1_dma_chnl[n] = 1;
                       PR_INFO("fc_niu_asm_event", MON_INFO,
                               psprintf("KHH-INFO-F0: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b001;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 3;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F1: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b002;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 5;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F2: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }

                       n++;
                       if (n<no_of_pkts)
                         {
                          mac_addr = 48'h1234_56b0_b003;
                          flow_p1[n].dst_node.l2_addr = mac_addr;
                          p1_dma_chnl[n] = 7;
                          PR_INFO("fc_niu_asm_event", MON_INFO,
                                  psprintf("KHH-INFO-F3: FOR FLOW_P1[%0d], DMA_CHNL[%0d] = %0d",n,n,p1_dma_chnl[n]));
                         }
                      }
                   default  :
                      {
                       PR_ERROR("fc_niu_asm_event", MON_ERROR,
                                psprintf("NIU_RxGenPkt: UN-Expected MULTI_DMA[7:4] = 'h%h assignment for MAC_ID = %0d",rx_multi_dma[7:4],mac_id));
                      }
                  }
          }
//      mac_id = 1;
        for(n = 0; n< no_of_pkts; n++) {
           PR_INFO("fc_niu_asm_event", MON_INFO,
                   psprintf("DEBUG: niu_rx_template_test: Sending frame to MAC[%0d]. Sequence: %0d, Frame Length: %0d",
                            mac_id,n,data_length));
           // Generate and send the packet
           last_packet = (n==(no_of_pkts-1));
           pktConfig.gen_rxPacket(flow_p1[n], data_length,p1_dma_chnl[n],mac_id,last_packet);

          case (sweep){
            1: data_length = data_length + 1;
            2: data_length = data_length + 2;
            3: data_length = data_length + 3;
            4: data_length = data_length + 4;
             default : data_length = data_length;
           }
        }
        PR_INFO("fc_niu_asm_event", MON_INFO,
                psprintf("MAQ-DEBUG: NIU_RxGenPkt Done FOR IPORT %0d", mac_id));
      }
     join none
    }
  else
    {
     PR_ERROR("fc_niu_asm_event", MON_ERROR,
              psprintf("NIU_RxGenPkt: Not Valid Value for rx_multi_port = %0d",rx_multi_port));
    }
}
#endif


// ***********************************************************************************


#ifndef FC_NO_PEU_VERA
task AsmToVeraIntf::set_StartPEUTest () {

  printf ("\n In set_StartPEUTest... setting StartPEUTest\n");
  trigger (ON, e_StartPEUTest);
}


//----------------------------------------------------------------
// Enable PCIe endpoint to expect a request from N2.
// This routine, called from the Assembly via a user event,
// triggers 1 Egress Command from N2.
// Since the Denali end-point errors on un-expected packets,
// it must be notified everytime N2 sends it a packet.
//
// cmdType:  Type of command to transmit
//             CFGRD0  = Config Read  Type 0
//             CFGRD1  = Config Read  Type 1
//             CFGWR0  = Config Write Type 0
//             CFGWR1  = Config Write Type 1
//             IORD    = I/O Read
//             IOWR    = I/O Write
//             MRD     = Memory Read
//             MWR     = Memory Write
//
// addr: Request Address
//
// txLen: Request length in bytes.
//
// startData: Soon to be obsolete.
//
// error: currently undefined.
//----------------------------------------------------------------

task AsmToVeraIntf::EnablePCIeEgCmd (string      cmdType,
                                     bit [63:0]  addr,
                                     bit [31:0]  txLen,
                                     bit [31:0]  startData,
                                     string      err) {

  N2fcPEUparams PEUparams = new ();

  PEUparams.cmdType       = cmdType;
  PEUparams.addr          = addr;
  PEUparams.txLen         = txLen;
  PEUparams.startData     = startData;
  PEUparams.err           = err;

  mailbox_put (asm2peu_mbox, PEUparams);
  
}

//----------------------------------------------------------------
// Enable PCIe endpoint to transmit a DMA command to N2.
// This routine, called from the Assembly via a user event,
// triggers multple Ingress DMA commands to N2.
//
// cmdType:  Type of command to transmit
//             DMAWR  = Memory Write only
//             DMARD  = Memory Read only
//             RANDOM = Random Memory R/W
//
// StartAddr and EndAddr together define the range of addresses
// within which Vera is allowed to randomize.
//
// TxLen: Request length in bytes. Converted from string to
//        hex in N2fcCtx.vr routine. Valid values
//        RANDOM  = Random Size
//        1       = 1 byte
//        2       = 2 bytes, and so on upto PCIe max size.
//
// NumCmds: Number of commands to transmit
//
// error: currently undefined.
//----------------------------------------------------------------

task AsmToVeraIntf::EnablePCIeIgCmd (string      cmdType,
                                     bit [63:0]  StartAddr,
                                     bit [63:0]  EndAddr,
                                     string      txLen,
                                     bit [31:0]  NumCmds,
                                     string      err) {

  N2fcPEUparams PEUparams = new ();

  PEUparams.cmdType       = cmdType;
  PEUparams.StartAddr     = StartAddr;
  PEUparams.EndAddr       = EndAddr;
  PEUparams.DMATxLen      = txLen;
  PEUparams.NumCmds       = NumCmds;
  PEUparams.err           = err;

  mailbox_put (asm2peu_mbox, PEUparams);
  
}
#endif

task AsmToVeraIntf::IosErrInj (string errtype, bit [15:0] ctag, bit [39:0] pa) {

   integer inj_result;
   integer errt =1;

   ios_err_packet err_pkt;

//   ios_ras_inj ras_injector;

   SocErr_Type err_type;

#ifndef GATESIM
   ras_interrupt.monitor_err_interrupt(ras_injector, 4000);
#endif

/*   ras_injector = new(niu_sii_inj_bind, dmu_sii_inj_bind, sio_niu_inj_bind, sio_dmu_inj_bind,
                 l2_0_sio_inj_bind, l2_1_sio_inj_bind, l2_2_sio_inj_bind, l2_3_sio_inj_bind,
                 l2_4_sio_inj_bind, l2_5_sio_inj_bind, l2_6_sio_inj_bind, l2_7_sio_inj_bind,
                 sii_ncu_inj_bind, dbg);
*/

   case (errtype) {
#ifndef FC_NO_NIU_T2
      "NIUSII_CUE": err_type = NIUSII_CUE;
      "NIUSII_CCE": err_type = NIUSII_CCE;
      "NIUSII_AP":  err_type = NIUSII_AP;
      "NIUSII_DP":  err_type = NIUSII_DP;
      "NIUSII_CMDP": err_type = NIUSII_CMDP;
      "NIUSII_IOAE": err_type = NIUSII_IOAE;
      "NIUSII_IOUE": err_type = NIUSII_IOUE;
      "SIONIU_DP":  err_type = SIONIU_DP;
      "SIONIU_CUE": err_type = SIONIU_CUE;
      "SIONIU_CCE": err_type = SIONIU_CCE;
#endif
      "DMUSII_CUE": err_type = DMUSII_CUE;
      "DMUSII_CCE": err_type = DMUSII_CCE;
      "DMUSII_AP":  err_type = DMUSII_AP;
      "DMUSII_DP":  err_type = DMUSII_DP;
      "DMUSII_BEP": err_type = DMUSII_BEP;
      "DMUSII_CMDP": err_type = DMUSII_CMDP;
      "DMUSII_TOUT": err_type = DMUSII_TOUT;
      "DMUSII_IOAE": err_type = DMUSII_IOAE;
      "DMUSII_IOUE": err_type = DMUSII_IOUE;
      "SIODMU_DP":  err_type = SIODMU_DP;
      "SIODMU_CUE": err_type = SIODMU_CUE;
      "SIODMU_CCE": err_type = SIODMU_CCE;
      "L2SIO_DP":   err_type = L2SIO_DP;
      "L2SIO_EBIT": err_type = L2SIO_EBIT;	
      "L2SIO_CUE":  err_type = L2SIO_CUE;
      "L2SIO_CCE":  err_type = L2SIO_CCE;
      "SIINCU_DP":  err_type = SIINCU_DP;
      "SIINCU_CUE": err_type = SIINCU_CUE;
      "SIINCU_CCE": err_type = SIINCU_CCE;
      "DMUNCU_WRACK_P": err_type = DMUNCU_WRACK_P;
      "NCUDMU_MONDO_IDP": err_type = NCUDMU_MONDO_IDP;
      "SIIDMU_WRACK_P": err_type  = SIIDMU_WRACK_P; 
      default: errt = 0;
   }

   err_pkt = new(err_type, ctag, pa);
 
   inj_result = ras_injector.inj_err_packet(err_pkt);
 
   // printf ("\n IOS Error Injector end\n");
}


task AsmToVeraIntf::L2ErrTrapCount(reg [8:0] count=0)
{
//  DAtrap DATrp = new();
  gUtil.l2_trap_count(count);
  printf("In L2 Trap Counting task");
}

task AsmToVeraIntf::IosRandErrInj (string errtype, integer num_errs, integer weight) {

   integer inj_result;
   integer errt =1;

   ios_err_packet err_pkt;

   SocErr_Type err_type;

#ifndef GATESIM
   ras_interrupt.monitor_err_interrupt(ras_injector, 4000);
#endif

   case (errtype) {
#ifndef FC_NO_NIU_T2
      "NIUSII_CUE": err_type = NIUSII_CUE;
      "NIUSII_CCE": err_type = NIUSII_CCE;
      "NIUSII_AP":  err_type = NIUSII_AP;
      "NIUSII_DP":  err_type = NIUSII_DP;
      "SIONIU_DP":  err_type = SIONIU_DP;
      "SIONIU_CUE": err_type = SIONIU_CUE;
      "SIONIU_CCE": err_type = SIONIU_CCE;
#endif
      "DMUSII_CUE": err_type = DMUSII_CUE;
      "DMUSII_CCE": err_type = DMUSII_CCE;
      "DMUSII_AP":  err_type = DMUSII_AP;
      "DMUSII_DP":  err_type = DMUSII_DP;
      "SIODMU_DP":  err_type = SIODMU_DP;
      "SIODMU_CUE": err_type = SIODMU_CUE;
      "SIODMU_CCE": err_type = SIODMU_CCE;
      "L2SIO_DP":   err_type = L2SIO_DP;
      "L2SIO_CUE":  err_type = L2SIO_CUE;
      "L2SIO_CCE":  err_type = L2SIO_CCE;
      "SIINCU_DP":  err_type = SIINCU_DP;
      "SIINCU_CCE": err_type = SIINCU_CCE;
      "SIINCU_CUE": err_type = SIINCU_CUE;
      default: errt = 0;
   }

// needed?   err_pkt = new(err_type, ctag, pa);

   inj_result = ras_injector.inj_rand_err(err_type, num_errs, weight);

   // printf ("\n IOS Random Error Injector end\n");
}


// Use this to mark progress or a location in code. Any action can be
// performed based on the string passed in. This is very flexible if all
// you need is tid and pc.
task AsmToVeraIntf::marker(string what, reg [5:0] fromTid, reg [63:0] pc)
{
  case (what) {
    "bootEnd": {       
      // gOutOfBoot works with User Events to show asm diag progress.
      // Function gUtil.getRunStatus will tell you which threads are running.
      // (so will top_if.core_running_status)
      // Function gUtil.getThreadEnables will tell you what +thread was.
      // (so will top_if.th_check_enable)
      //
      // for SW thread startup, you will not know what threads are supposed
      // to start so it will be hard to wait for all to start in that case!
      //
      // Here is how you could use gOutOfBoot if +thread is used:
      // while (top_if.th_check_enable !== gOutOfBoot) wait_var(gOutOfBoot);
      gOutOfBoot[fromTid] = 1;
      probe_if.gOutOfBoot[fromTid] <= gOutOfBoot[fromTid];
    }
    "bootStart": {
      // see comments for bootEnd above. This will clear bits in gOutOfBoot
      // when that thread starts boot code execution after a reset.
      // 
      // Here is how you could use gOutOfBoot if +thread is used, once you
      // detect a warm reset has started.

      // Any thread has started boot code after this line of code
      // while (top_if.th_check_enable === gOutOfBoot) wait_var(gOutOfBoot);
      
      // All threads have started boot code after this line of code.
      // With the large staggering of 64 threads, gOutOfBoot may NEVER
      // be zero!!!
      // while (gOutOfBoot) wait_var(gOutOfBoot);
      
      // All threads have finished boot code after this line of code
      // while (top_if.th_check_enable !== gOutOfBoot) wait_var(gOutOfBoot);
      gOutOfBoot[fromTid] = 0;
      probe_if.gOutOfBoot[fromTid] <= gOutOfBoot[fromTid];
    }
    default: error("AsmToVeraIntf::marker got unknown string (%s)!\n", what);
  } // case

}
task AsmToVeraIntf::reset_now(string what)
{
  case (what) {
    "PWRON_RST": {
      random_rst_if.POR_from_UserEvent <= 1;
    }
    "PB_RST": {
      random_rst_if.PB_RST_from_UserEvent <= 1;
    }
    default: error("AsmToVeraIntf::reset_now got unknown string (%s)!\n", what);
  } // case

}