upper_lower_app.cpp File Reference

#include "upper_lower_app.hpp"

Include dependency graph for upper_lower_app.cpp:

Go to the source code of this file.

Functions
uint8_t	upper (uint8_t a)
uint8_t	lower (uint8_t a)
uint8_t	invert_case (uint8_t a)
uint64_t	invert_word (uint64_t input)
void	pPortAndDestionation (ap_uint< 32 > *pi_rank, ap_uint< 32 > *pi_size, stream< NodeId > &sDstNode_sig, ap_uint< 32 > *po_rx_ports)
void	pEnq (stream< NetworkMetaStream > &siNrc_meta, stream< NetworkWord > &siNrc_data, stream< NetworkMetaStream > &sRxtoTx_Meta, stream< NetworkWord > &sRxpToTxp_Data)
void	pDeq (stream< NodeId > &sDstNode_sig, stream< NetworkMetaStream > &sRxtoTx_Meta, stream< NetworkWord > &sRxpToTxp_Data, stream< NetworkMetaStream > &soNrc_meta, stream< NetworkWord > &soNrc_data)
void	upper_lower_app (ap_uint< 32 > *pi_rank, ap_uint< 32 > *pi_size, stream< NetworkWord > &siNrc_data, stream< NetworkWord > &soNrc_data, stream< NetworkMetaStream > &siNrc_meta, stream< NetworkMetaStream > &soNrc_meta, ap_uint< 32 > *po_rx_ports)
	Main process of the UDP/TCP Triangle Application. This HLS IP receives a packet, invert the case of ASCII characters, and forwards it to the next node in the cluster. The last forwards it to 0. More...

Function Documentation

invert_case()

uint8_t invert_case

(

uint8_t

a

)

Definition at line 53 of file upper_lower_app.cpp.

{
#pragma HLS inline
  uint8_t ret = 0x0;
  if( (a >= 0x41) && (a <= 0x5a) )
  {
    ret = a + 0x20;
  }
  else if( (a >= 0x61) && (a <= 0x7a) )
  {
    ret = a - 0x20;
  } else {
    ret = a;
  }
  return ret;
}

Here is the caller graph for this function:

invert_word()

uint64_t invert_word

(

uint64_t

input

)

Definition at line 71 of file upper_lower_app.cpp.

{
#pragma HLS inline
  uint64_t output = 0x0;
  for(uint8_t i = 0; i < 8; i++)
  {
#pragma HLS unroll factor=8
    output |= ((uint64_t) invert_case((uint8_t) (input >> i*8))) << i*8;
  }
  return output;
}

Here is the call graph for this function:

Here is the caller graph for this function:

lower()

uint8_t lower

(

uint8_t

a

)

Definition at line 43 of file upper_lower_app.cpp.

{
#pragma HLS inline
  if( (a >= 0x41) && (a <= 0x5a) )
  {
    a += 0x20;
  }
  return a;
}

pDeq()

void pDeq	(	stream< NodeId > &	sDstNode_sig,
		stream< NetworkMetaStream > &	sRxtoTx_Meta,
		stream< NetworkWord > &	sRxpToTxp_Data,
		stream< NetworkMetaStream > &	soNrc_meta,
		stream< NetworkWord > &	soNrc_data
	)

sRxpToTxp_Data.empty() &&

Definition at line 167 of file upper_lower_app.cpp.

{
  //-- DIRECTIVES FOR THIS PROCESS ------------------------------------------
#pragma HLS inline off
#pragma HLS pipeline II=1
  //-- STATIC VARIABLES (with RESET) ------------------------------------------
  static PacketFsmType dequeueFSM = WAIT_FOR_META;
#pragma HLS reset variable=dequeueFSM
  //-- STATIC DATAFLOW VARIABLES ------------------------------------------
  static NetworkMeta meta_out;
  static NodeId dst_rank;
  //-- LOCAL VARIABLES ------------------------------------------------------
  NetworkWord  udpWordTx = NetworkWord();
  //NetworkMeta  meta_in = NetworkMeta();
 
  switch(dequeueFSM)
  {
    default:
    case WAIT_FOR_META:
      if(!sDstNode_sig.empty())
      {
        dst_rank = sDstNode_sig.read();
        dequeueFSM = WAIT_FOR_STREAM_PAIR;
        //Triangle app needs to be reset to process new rank
      }
      break;
    case WAIT_FOR_STREAM_PAIR:
      //-- Forward incoming chunk to SHELL
      if ( 
          !sRxtoTx_Meta.empty()
          //&& !soNrc_data.full() 
          && !soNrc_meta.full()
        )
      {
        //udpWordTx = sRxpToTxp_Data.read();
        //soNrc_data.write(udpWordTx);
 
        NetworkMeta meta_in = sRxtoTx_Meta.read().tdata;
        meta_out = NetworkMeta();
        //meta_out_stream.tlast = 1;
        //meta_out_stream.tkeep = 0xFF; //just to be sure!
 
        //meta_out.dst_rank = (*pi_rank + 1) % *pi_size;
        meta_out.dst_rank = dst_rank;
        //printf("meat_out.dst_rank: %d\n", (int) meta_out_stream.tdata.dst_rank);
        meta_out.dst_port = DEFAULT_TX_PORT;
        //meta_out.src_rank = (NodeId) *pi_rank;
        meta_out.src_rank = 0; //will be ignored, it is always this FPGA...
        meta_out.src_port = DEFAULT_RX_PORT;
        meta_out.len = meta_in.len;
 
       soNrc_meta.write(NetworkMeta(meta_out));
 
        //if(udpWordTx.tlast != 1)
        //{
          dequeueFSM = PROCESSING_PACKET;
        //}
        //dequeueFSM = WRITE_META;
      }
      break;
    //case WRITE_META:
    //  if(!soNrc_meta.full())
    //  {
    //   soNrc_meta.write(NetworkMeta(meta_out));
    //   dequeueFSM = PROCESSING_PACKET;
    //  }
    //  break;
 
    case PROCESSING_PACKET:
      if( !sRxpToTxp_Data.empty() && !soNrc_data.full())
      {
        udpWordTx = sRxpToTxp_Data.read();
        soNrc_data.write(udpWordTx);
 
        if(udpWordTx.tlast == 1)
        {
          dequeueFSM = WAIT_FOR_STREAM_PAIR;
        }
 
      }
      break;
  }
 
}

Here is the caller graph for this function:

pEnq()

void pEnq	(	stream< NetworkMetaStream > &	siNrc_meta,
		stream< NetworkWord > &	siNrc_data,
		stream< NetworkMetaStream > &	sRxtoTx_Meta,
		stream< NetworkWord > &	sRxpToTxp_Data
	)

Definition at line 119 of file upper_lower_app.cpp.

{
  //-- DIRECTIVES FOR THIS PROCESS ------------------------------------------
#pragma HLS inline off
#pragma HLS pipeline II=1
  //-- STATIC VARIABLES (with RESET) ------------------------------------------
  static PacketFsmType enqueueFSM = WAIT_FOR_META;
#pragma HLS reset variable=enqueueFSM
  //-- LOCAL VARIABLES ------------------------------------------------------
  NetworkWord udpWord = NetworkWord();
  NetworkMetaStream  meta_tmp = NetworkMetaStream();
  NetworkWord newWord = NetworkWord();
  
  switch(enqueueFSM)
  {
    default:
    case WAIT_FOR_META: 
      if ( !siNrc_meta.empty() && !sRxtoTx_Meta.full() )
      {
        meta_tmp = siNrc_meta.read();
        meta_tmp.tlast = 1; //just to be sure...
        sRxtoTx_Meta.write(meta_tmp);
        enqueueFSM = PROCESSING_PACKET;
      }
      break;
 
    case PROCESSING_PACKET:
      if ( !siNrc_data.empty() && !sRxpToTxp_Data.full() )
      {
        //-- Read incoming data chunk
        udpWord = siNrc_data.read();
        newWord = NetworkWord(invert_word(udpWord.tdata), udpWord.tkeep, udpWord.tlast);
        sRxpToTxp_Data.write(newWord);
        if(udpWord.tlast == 1)
        {
          enqueueFSM = WAIT_FOR_META;
        }
      }
      break;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

pPortAndDestionation()

void pPortAndDestionation	(	ap_uint< 32 > *	pi_rank,
		ap_uint< 32 > *	pi_size,
		stream< NodeId > &	sDstNode_sig,
		ap_uint< 32 > *	po_rx_ports
	)

Definition at line 84 of file upper_lower_app.cpp.

{
  //-- DIRECTIVES FOR THIS PROCESS ------------------------------------------
#pragma HLS inline off
//#pragma HLS pipeline II=1 //not necessary
  //-- STATIC VARIABLES (with RESET) ------------------------------------------
  static PortFsmType port_fsm = FSM_WRITE_NEW_DATA;
#pragma HLS reset variable=port_fsm
 
 
  switch(port_fsm)
  {
    default:
    case FSM_WRITE_NEW_DATA:
        //Triangle app needs to be reset to process new rank
        if(!sDstNode_sig.full())
        {
          NodeId dst_rank = (*pi_rank + 1) % *pi_size;
          printf("rank: %d; size: %d; \n", (int) *pi_rank, (int) *pi_size);
          sDstNode_sig.write(dst_rank);
          port_fsm = FSM_DONE;
        }
        break;
    case FSM_DONE:
        *po_rx_ports = 0x1; //currently work only with default ports...
        break;
  }
}

Here is the caller graph for this function:

upper()

uint8_t upper

(

uint8_t

a

)

Copyright 2016 – 2022 IBM Corporation

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Definition at line 31 of file upper_lower_app.cpp.

{
#pragma HLS inline
  if( (a >= 0x61) && (a <= 0x7a) )
  {
    a -= 0x20;
  }
  return a;
}

upper_lower_app()

void upper_lower_app	(	ap_uint< 32 > *	pi_rank,
		ap_uint< 32 > *	pi_size,
		stream< NetworkWord > &	siNrc_data,
		stream< NetworkWord > &	soNrc_data,
		stream< NetworkMetaStream > &	siNrc_meta,
		stream< NetworkMetaStream > &	soNrc_meta,
		ap_uint< 32 > *	po_rx_ports
	)

Main process of the UDP/TCP Triangle Application. This HLS IP receives a packet, invert the case of ASCII characters, and forwards it to the next node in the cluster. The last forwards it to 0.

Returns

Nothing.

Definition at line 269 of file upper_lower_app.cpp.

{
 
  //-- DIRECTIVES FOR THE BLOCK ---------------------------------------------
#pragma HLS INTERFACE ap_ctrl_none port=return
 
#pragma HLS INTERFACE axis register both port=siNrc_data
#pragma HLS INTERFACE axis register both port=soNrc_data
 
#pragma HLS INTERFACE axis register both port=siNrc_meta
#pragma HLS INTERFACE axis register both port=soNrc_meta
 
#pragma HLS INTERFACE ap_vld register port=po_rx_ports name=poROL_NRC_Rx_ports
#pragma HLS INTERFACE ap_vld register port=pi_rank name=piFMC_ROL_rank
#pragma HLS INTERFACE ap_vld register port=pi_size name=piFMC_ROL_size
 
 
  //-- DIRECTIVES FOR THIS PROCESS ------------------------------------------
#pragma HLS DATAFLOW
 
  //-- STATIC VARIABLES (with RESET) ------------------------------------------
 
  //-- STATIC DATAFLOW VARIABLES ------------------------------------------
  static stream<NetworkWord>       sRxpToTxp_Data("sRxpToTxP_Data");
  static stream<NetworkMetaStream> sRxtoTx_Meta("sRxtoTx_Meta");
  static stream<NodeId>            sDstNode_sig("sDstNode_sig");
 
#pragma HLS STREAM variable=sRxpToTxp_Data   depth=252
#pragma HLS STREAM variable=sRxtoTx_Meta     depth=32
#pragma HLS STREAM variable=sDstNode_sig     depth=1
 
 
  //-- LOCAL VARIABLES ------------------------------------------------------
 
  pPortAndDestionation(pi_rank, pi_size, sDstNode_sig, po_rx_ports);
 
  pEnq(siNrc_meta, siNrc_data, sRxtoTx_Meta, sRxpToTxp_Data);
 
  pDeq(sDstNode_sig, sRxtoTx_Meta, sRxpToTxp_Data, soNrc_meta, soNrc_data);
 
}

Here is the call graph for this function: