lab5_1

// MP5 Reduction
// Input: A num list of length n
// Output: Sum of the list = list[0] + list[1] + ... + list[n-1];

#include <wb.h>

#define BLOCK_SIZE 512 //@@ This value is not fixed and you can adjust it according to the situation

#define wbCheck(stmt)                                                     \
  do {                                                                    \
    cudaError_t err = stmt;                                               \
    if (err != cudaSuccess) {                                             \
      wbLog(ERROR, "Failed to run stmt ", #stmt);                         \
      wbLog(ERROR, "Got CUDA error ...  ", cudaGetErrorString(err));      \
      return -1;                                                          \
    }                                                                     \
  } while (0)

__global__ void total(float *input, float *output, int len) {
  //@@ Load a segment of the input vector into shared memory
  //@@ Traverse the reduction tree
  //@@ Write the computed sum of the block to the output vector at the correct index
__shared__ float partialSum[2*BLOCK_SIZE];


unsigned int t = threadIdx.x;
unsigned int start = 2 * blockIdx.x * blockDim.x;

if (start + t < len){
  partialSum[t] = input[start + t];
}
else {
  partialSum[t] = 0.0;
}
if (start + blockDim.x + t < len){
  partialSum[blockDim.x + t] = input[start + blockDim.x + t];
}
else {
  partialSum[blockDim.x + t] = 0.0;
}

__syncthreads();
for (unsigned int stride = blockDim.x; stride >=1; stride /= 2){
  __syncthreads();
  if (t < stride){
    partialSum[t] +=partialSum[t + stride];
  }
}
if (t==0) {
  output[blockIdx.x] = partialSum[t];
}

}

int main(int argc, char **argv) {
  int ii;
  wbArg_t args;
  float *hostInput;  // The input 1D list
  float *hostOutput; // The output list
  //@@ Initialize device input and output pointers

  int numInputElements;  // number of elements in the input list
  int numOutputElements; // number of elements in the output list

  args = wbArg_read(argc, argv);

  //Import data and create memory on host
  hostInput =
      (float *)wbImport(wbArg_getInputFile(args, 0), &numInputElements);

  for (int k = 0; k < ceil(numInputElements/2048*65535); k++){

  numOutputElements = numInputElements / (BLOCK_SIZE << 1);
  if (numInputElements % (BLOCK_SIZE << 1)) {
    numOutputElements++;
  }
  hostOutput = (float *)malloc(numOutputElements * sizeof(float));

  // The number of input elements in the input is numInputElements
  // The number of output elements in the output is numOutputElements



  //@@ Allocate GPU memory
  float *deviceInput, *deviceOutput;
  cudaMalloc((void **)&deviceInput, numInputElements*sizeof(float));
  cudaMalloc((void **)&deviceOutput, numOutputElements*sizeof(float));



  //@@ Copy input memory to the GPU
  cudaMemcpy(deviceInput, hostInput, numInputElements * sizeof(float), cudaMemcpyHostToDevice);

  //@@ Initialize the grid and block dimensions here

  dim3 DimGrid(ceil(numInputElements/(2.0*BLOCK_SIZE)), 1, 1);
  dim3 DimBlock(BLOCK_SIZE, 1, 1);


  //@@ Launch the GPU Kernel and perform CUDA computation

  total<<<DimGrid, DimBlock>>>(deviceInput, deviceOutput, numInputElements);

  cudaDeviceSynchronize();
  //@@ Copy the GPU output memory back to the CPU

  cudaMemcpy(hostOutput, deviceOutput, numOutputElements * sizeof(float), cudaMemcpyDeviceToHost);

  /********************************************************************
   * Reduce output vector on the host
   * NOTE: One could also perform the reduction of the output vector
   * recursively and support any size input.
   * For simplicity, we do not require that for this lab.
   ********************************************************************/


  //@@ Free the GPU memory

  cudaFree(deviceInput);
  cudaFree(deviceOutput);

  numInputElements = numOutputElements;
  memcpy(hostInput, hostOutput, numOutputElements *sizeof(float));

  }

  for (ii = 1; ii < numOutputElements; ii++) {
    hostOutput[0] += hostOutput[ii];
  }

  wbSolution(args, hostOutput, 1);

  free(hostInput);
  free(hostOutput);

  return 0;
}