common.cpp

Go to the documentation of this file.

 
 
#include "../include/common.hpp"
 
using namespace std;
 
 
 
 
 
bool setInputDataStream(stream<UdpWord> &sDataStream, const string dataStreamName, 
            const string inpFileName, int simCnt) {
    string      strLine;
    ifstream    inpFileStream;
    string      datFile = "../../../../test/" + inpFileName;
    UdpWord     udpWord;
 
    //-- STEP-1 : OPEN FILE
    inpFileStream.open(datFile.c_str());
    if ( !inpFileStream ) {
        cout << "### ERROR : Could not open the input data file " << datFile << endl;
        return(KO);
    }
 
    //-- STEP-2 : SET DATA STREAM
    while (inpFileStream) {
 
        if (!inpFileStream.eof()) {
 
            getline(inpFileStream, strLine);
            if (strLine.empty()) continue;
            sscanf(strLine.c_str(), "%llx %x %d", &udpWord.tdata, &udpWord.tkeep, &udpWord.tlast);
 
            // Write to sDataStream
            if (sDataStream.full()) {
                printf("### ERROR : Stream is full. Cannot write stream with data from file \"%s\".\n", inpFileName.c_str());
                return(KO);
            } else {
                sDataStream.write(udpWord);
                // Print Data to console
                printf("[%4.4d] TB is filling input stream [%s] - Data write = {D=0x%16.16llX, K=0x%2.2X, L=%d} \n",
                        simCnt, dataStreamName.c_str(),
                        udpWord.tdata.to_long(), udpWord.tkeep.to_int(), udpWord.tlast.to_int());
            }
        }
    }
 
    //-- STEP-3: CLOSE FILE
    inpFileStream.close();
 
    return(OK);
}
 
 
 
 
 
bool readDataStream(stream <UdpWord> &sDataStream, UdpWord *udpWord) {
    // Get the DUT/Data results
    sDataStream.read(*udpWord);
    return(VALID);
}
 
 
 
ap_uint<64> pack_ap_uint_64_ (ap_uint<8> *buffer) {
 
    ap_uint<64>  value;
 
    value = buffer[7];
    value = (value << 8 ) + buffer[6];
    value = (value << 8 ) + buffer[5];
    value = (value << 8 ) + buffer[4];
    value = (value << 8 ) + buffer[3];
    value = (value << 8 ) + buffer[2];
    value = (value << 8 ) + buffer[1];
    value = (value << 8 ) + buffer[0];
 
    return value ;
 
}
 
 
void unpack_ap_uint_64_ (ap_uint<64> value, ap_uint<8> *buffer) {
 
  for (unsigned int i=0; i<8; i++) {
    buffer[i] = (value >> 8*i );
  }
}
 
 
bool dumpDataToFile(UdpWord *udpWord, ofstream &outFileStream) {
    if (!outFileStream.is_open()) {
        printf("### ERROR : Output file stream is not open. \n");
        return(KO);
    }
    outFileStream << hex << noshowbase << setfill('0') << setw(16) << udpWord->tdata.to_uint64();
    outFileStream << " ";
    outFileStream << hex << noshowbase << setfill('0') << setw(2)  << udpWord->tkeep.to_int();
    outFileStream << " ";
    outFileStream << setw(1) << udpWord->tlast.to_int() << "\n";
    return(OK);
}
 
 
 
 
bool getOutputDataStream(stream<UdpWord> &sDataStream,
                         const string    dataStreamName, const string outFileName, int simCnt)
{
    string      strLine;
    ofstream    outFileStream;
    string      datFile = "../../../../test/" + outFileName;
    UdpWord     udpWord;
    bool        rc = OK;
 
    //-- STEP-1 : OPEN FILE
    outFileStream.open(datFile.c_str());
    if ( !outFileStream ) {
        cout << "### ERROR : Could not open the output data file " << datFile << endl;
        return(KO);
    }
 
    //-- STEP-2 : EMPTY STREAM AND DUMP DATA TO FILE
    while (!sDataStream.empty()) {
        if (readDataStream(sDataStream, &udpWord) == VALID) {
            // Print DUT/Data to console
            printf("[%4.4d] TB is draining output stream [%s] - Data read = {D=0x%16.16llX, K=0x%2.2X, L=%d} \n",
                    simCnt, dataStreamName.c_str(),
                    udpWord.tdata.to_long(), udpWord.tkeep.to_int(), udpWord.tlast.to_int());
            if (!dumpDataToFile(&udpWord, outFileStream)) {
                rc = KO;
                break;
            }
        }
    }
 
    //-- STEP-3: CLOSE FILE
    outFileStream.close();
 
    return(rc);
}
 
 
 
bool dumpStructToFile(varin *instruct, const string outFileName, int simCnt)
{
    string      strLine;
    ofstream    outFileStream;
    string      datFile = "../../../../test/" + outFileName;
    UdpWord     udpWord;
    bool        rc = OK;
    unsigned int bytes_per_line = 8;
    
    //-- STEP-1 : OPEN FILE
    outFileStream.open(datFile.c_str());
    if ( !outFileStream ) {
        cout << "### ERROR : Could not open the output data file " << datFile << endl;
        return(KO);
    }
    ap_uint<8> value[bytes_per_line];
    unsigned int total_bytes = 0;
 
    
    intToFloatUnion intToFloat;
    
    //-- STEP-2 : DUMP STRING DATA TO FILE
    for (unsigned int i = 0, j = 0; i < INSIZE; i+=sizeof(DtUsed), j++, total_bytes+=bytes_per_line) {
      switch(j)
      {
        case 0:
          intToFloat.i = instruct->loop_nm;
          printf("DEBUG instruct->loop_nm = %u\n", (unsigned int)instruct->loop_nm);
          break;
        case 1:
          intToFloat.i = instruct->seed;
          printf("DEBUG instruct->seed = %u\n", (unsigned int)instruct->seed);
          break;  
        case 2:
          intToFloat.f = instruct->underlying;
          printf("DEBUG instruct->underlying = %f\n", instruct->underlying);
          break;
        case 3:
          intToFloat.f = instruct->volatility;
          printf("DEBUG instruct->volatility = %f\n", instruct->volatility);
          break;
        case 4:
          intToFloat.f = instruct->dividendYield;
          printf("DEBUG instruct->dividendYield = %f\n", instruct->dividendYield);
          break;
        case 5:
          intToFloat.f = instruct->riskFreeRate;
          printf("DEBUG instruct->riskFreeRate = %f\n", instruct->riskFreeRate);
          break;
        case 6:
          intToFloat.f = instruct->timeLength;
          printf("DEBUG instruct->timeLength = %f\n", instruct->timeLength);
          break;  
        case 7:
          intToFloat.f = instruct->strike;
          printf("DEBUG instruct->strike = %f\n", instruct->strike);
          break;
        case 8:
          intToFloat.i = instruct->optionType;
          printf("DEBUG instruct->optionType = %u\n", (unsigned int)instruct->optionType);
          break;
        case 9:
          intToFloat.f = instruct->requiredTolerance;
          printf("DEBUG instruct->requiredTolerance = %f\n", instruct->requiredTolerance);
          break;
        case 10:
          intToFloat.i = instruct->requiredSamples;
          printf("DEBUG instruct->requiredSamples = %u\n", (unsigned int)instruct->requiredSamples);
          break;
        case 11:
          intToFloat.i = instruct->timeSteps;
          printf("DEBUG instruct->timeSteps = %u\n", (unsigned int)instruct->timeSteps);
          break;  
        case 12:
          intToFloat.i = instruct->maxSamples;
          printf("DEBUG instruct->maxSamples = %u\n", (unsigned int)instruct->maxSamples);
          break;
        default:
          printf("ERROR: unknown value %u\n", j);
          rc = KO;
          break;
      }
      
        udpWord.tdata = (ap_uint<64>)intToFloat.i;
        udpWord.tkeep = 255;
        // We are signaling a packet termination either at the end of the image or the end of MTU
        if ((total_bytes >= (INSIZE - bytes_per_line)) || 
            ((total_bytes + bytes_per_line) % PACK_SIZE == 0)) {
          udpWord.tlast = 1;
        }
        else {
          udpWord.tlast = 0;
        }
            printf("[%4.4d] IMG TB is dumping string to file [%s] - Data read [%u] = {val=%u, D=0x%16.16llX, K=0x%2.2X, L=%d} \n",
                    simCnt, datFile.c_str(), total_bytes, value,
                    udpWord.tdata.to_long(), udpWord.tkeep.to_int(), udpWord.tlast.to_int());
            if (!dumpDataToFile(&udpWord, outFileStream)) {
          rc = KO;
              break;
            }
    }
    //-- STEP-3: CLOSE FILE
    outFileStream.close();
 
    return(rc);
}
 
 
 
bool dumpFileToArray(const string inpFileName, DtUsed* out, int simCnt) {
    string      strLine;
    ifstream    inpFileStream;
    string      datFile = "../../../../test/" + inpFileName;
    UdpWord     udpWord;
    unsigned int i = 0;
    unsigned int bytes_per_line = 8;
    ap_uint<8> value[bytes_per_line];
    intToFloatUnion intToFloat;
    //-- STEP-1 : OPEN FILE
    inpFileStream.open(datFile.c_str());
    if ( !inpFileStream ) {
        cout << "### ERROR : Could not open the input data file " << datFile << endl;
        return(KO);
    }
 
    //-- STEP-2 : SET DATA STREAM
    while (inpFileStream) {
 
        if (!inpFileStream.eof()) {
 
          getline(inpFileStream, strLine);
          if (strLine.empty()) continue;
          sscanf(strLine.c_str(), "%llx %x %d", &udpWord.tdata, &udpWord.tkeep, &udpWord.tlast);
      //unpack_ap_uint_64_(udpWord.tdata, value);
 
      intToFloatUnion intToFloat;
      intToFloat.i  = (DtUsedInt)(udpWord.tdata);
      assert(i<OUTDEP);
      out[i++] = intToFloat.f;
    }
    }
 
    //-- STEP-3: CLOSE FILE
    inpFileStream.close();
 
    return(OK);
}
 
 
static inline ssize_t
writeArrayToFile(const char *fname, DtUsed* out)
{
    int rc;
    FILE *fp;
 
    if ((fname == NULL) || (out == NULL))
        return -EINVAL;
 
    fp = fopen(fname, "w+");
    if (!fp) {
        fprintf(stderr, "err: Cannot open file %s: %s\n",
            fname, strerror(errno));
        return -ENODEV;
    }
    for (unsigned int i = 0; i < OUTDEP; i++) {
        rc = fprintf(fp,"%f\n", out[i]);
        if (rc == -1) {
        fprintf(stderr, "err: Cannot write to %s: %s\n",
            fname, strerror(errno));
        fclose(fp);
        return -EIO;
        }
    }
    fclose(fp);
    return rc;
}
 
 
 
unsigned int 
readFileConfigToStruct(const char *fname, varin *instruct) {
 
    if ((fname == NULL) || (instruct == NULL))
    return -EINVAL;
    
    std::ifstream ifile(fname, std::ios::in);
 
    //check to see that the file was opened correctly:
    if (!ifile.is_open()) {
        std::cerr << "There was a problem opening the input file!\n";
        return -EIO;
    }
    unsigned int i, j;
    for (i = 0, j = 0; i < INSIZE; i+=sizeof(DtUsed), j++) {
      switch(j)
      {
    case 0:
      ifile >> instruct->loop_nm;
      printf("DEBUG instruct->loop_nm = %u\n", (unsigned int)instruct->loop_nm);
      break;
    case 1:
      ifile >> instruct->seed;
      printf("DEBUG instruct->seed = %u\n", (unsigned int)instruct->seed);
      break;  
    case 2:
      ifile >> instruct->underlying;
      printf("DEBUG instruct->underlying = %f\n", instruct->underlying);
      break;
    case 3:
      ifile >> instruct->volatility;
      printf("DEBUG instruct->volatility = %f\n", instruct->volatility);
      break;
    case 4:
      ifile >> instruct->dividendYield;
      printf("DEBUG instruct->dividendYield = %f\n", instruct->dividendYield);
      break;
    case 5:
      ifile >> instruct->riskFreeRate;
      printf("DEBUG instruct->riskFreeRate = %f\n", instruct->riskFreeRate);
      break;
    case 6:
      ifile >> instruct->timeLength;
      printf("DEBUG instruct->timeLength = %f\n", instruct->timeLength);
      break;  
    case 7:
      ifile >> instruct->strike;
      printf("DEBUG instruct->strike = %f\n", instruct->strike);
      break;
    case 8:
      ifile >> instruct->optionType;
      printf("DEBUG instruct->optionType = %u\n", (unsigned int)instruct->optionType);
      break;
    case 9:
      ifile >> instruct->requiredTolerance;
      printf("DEBUG instruct->requiredTolerance = %f\n", instruct->requiredTolerance);
      break;
    case 10:
      ifile >> instruct->requiredSamples;
      printf("DEBUG instruct->requiredSamples = %u\n", (unsigned int)instruct->requiredSamples);
      break;
    case 11:
      ifile >> instruct->timeSteps;
      printf("DEBUG instruct->timeSteps = %u\n", (unsigned int)instruct->timeSteps);
      break;  
    case 12:
      ifile >> instruct->maxSamples;
      printf("DEBUG instruct->maxSamples = %u\n", (unsigned int)instruct->maxSamples);
      break;
    default:
      break;
      }
    }
    return (i);
}