#ifdef SUPPORTS_64_BIT_ATOMICS #pragma OPENCL EXTENSION cl_khr_int64_base_atomics : enable #endif /** * Compute a value based on pair interactions. */ __kernel void computeN2Value(__global const real4* restrict posq, __local real4* restrict local_posq, __global const unsigned int* restrict exclusions, __global const ushort2* exclusionTiles, #ifdef SUPPORTS_64_BIT_ATOMICS __global long* restrict global_value, #else __global real* restrict global_value, #endif __local real* restrict local_value, #ifdef USE_CUTOFF __global const ushort2* restrict tiles, __global const unsigned int* restrict interactionCount, real4 periodicBoxSize, real4 invPeriodicBoxSize, unsigned int maxTiles, __global const real4* restrict blockCenter, __global const int* restrict interactingAtoms #else unsigned int numTiles #endif PARAMETER_ARGUMENTS) { const unsigned int totalWarps = get_global_size(0)/TILE_SIZE; const unsigned int warp = get_global_id(0)/TILE_SIZE; const unsigned int tgx = get_local_id(0) & (TILE_SIZE-1); const unsigned int tbx = get_local_id(0) - tgx; // First loop: process tiles that contain exclusions. const unsigned int firstExclusionTile = FIRST_EXCLUSION_TILE+warp*(LAST_EXCLUSION_TILE-FIRST_EXCLUSION_TILE)/totalWarps; const unsigned int lastExclusionTile = FIRST_EXCLUSION_TILE+(warp+1)*(LAST_EXCLUSION_TILE-FIRST_EXCLUSION_TILE)/totalWarps; for (int pos = firstExclusionTile; pos < lastExclusionTile; pos++) { const ushort2 tileIndices = exclusionTiles[pos]; const unsigned int x = tileIndices.x; const unsigned int y = tileIndices.y; real value = 0; unsigned int atom1 = x*TILE_SIZE + tgx; real4 posq1 = posq[atom1]; LOAD_ATOM1_PARAMETERS #ifdef USE_EXCLUSIONS unsigned int excl = exclusions[pos*TILE_SIZE+tgx]; #endif if (x == y) { // This tile is on the diagonal. const unsigned int localAtomIndex = get_local_id(0); local_posq[localAtomIndex] = posq1; LOAD_LOCAL_PARAMETERS_FROM_1 SYNC_WARPS; for (unsigned int j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+j; real4 posq2 = local_posq[atom2]; real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC delta.xyz -= floor(delta.xyz*invPeriodicBoxSize.xyz+0.5f)*periodicBoxSize.xyz; #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef USE_CUTOFF if (r2 < CUTOFF_SQUARED) { #endif real invR = RSQRT(r2); real r = RECIP(invR); LOAD_ATOM2_PARAMETERS atom2 = y*TILE_SIZE+j; real tempValue1 = 0; real tempValue2 = 0; #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS || !(excl & 0x1)); if (!isExcluded && atom1 != atom2) { #else if (atom1 < NUM_ATOMS && atom2 < NUM_ATOMS && atom1 != atom2) { #endif COMPUTE_VALUE } value += tempValue1; #ifdef USE_CUTOFF } #endif #ifdef USE_EXCLUSIONS excl >>= 1; #endif SYNC_WARPS; } } else { // This is an off-diagonal tile. const unsigned int localAtomIndex = get_local_id(0); unsigned int j = y*TILE_SIZE + tgx; local_posq[localAtomIndex] = posq[j]; LOAD_LOCAL_PARAMETERS_FROM_GLOBAL local_value[localAtomIndex] = 0; SYNC_WARPS; #ifdef USE_EXCLUSIONS excl = (excl >> tgx) | (excl << (TILE_SIZE - tgx)); #endif unsigned int tj = tgx; for (j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+tj; real4 posq2 = local_posq[atom2]; real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC delta.xyz -= floor(delta.xyz*invPeriodicBoxSize.xyz+0.5f)*periodicBoxSize.xyz; #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef USE_CUTOFF if (r2 < CUTOFF_SQUARED) { #endif real invR = RSQRT(r2); real r = RECIP(invR); LOAD_ATOM2_PARAMETERS atom2 = y*TILE_SIZE+tj; real tempValue1 = 0; real tempValue2 = 0; #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS || !(excl & 0x1)); if (!isExcluded) { #else if (atom1 < NUM_ATOMS && atom2 < NUM_ATOMS) { #endif COMPUTE_VALUE } value += tempValue1; local_value[tbx+tj] += tempValue2; #ifdef USE_CUTOFF } #endif #ifdef USE_EXCLUSIONS excl >>= 1; #endif tj = (tj + 1) & (TILE_SIZE - 1); SYNC_WARPS; } } // Write results. #ifdef SUPPORTS_64_BIT_ATOMICS unsigned int offset = x*TILE_SIZE + tgx; atom_add(&global_value[offset], (long) (value*0x100000000)); if (x != y) { offset = y*TILE_SIZE + tgx; atom_add(&global_value[offset], (long) (local_value[get_local_id(0)]*0x100000000)); } #else unsigned int offset1 = x*TILE_SIZE + tgx + warp*PADDED_NUM_ATOMS; unsigned int offset2 = y*TILE_SIZE + tgx + warp*PADDED_NUM_ATOMS; global_value[offset1] += value; if (x != y) global_value[offset2] += local_value[get_local_id(0)]; #endif } // Second loop: tiles without exclusions, either from the neighbor list (with cutoff) or just enumerating all // of them (no cutoff). #ifdef USE_CUTOFF unsigned int numTiles = interactionCount[0]; int pos = warp*(numTiles > maxTiles ? NUM_BLOCKS*(NUM_BLOCKS+1)/2 : numTiles)/totalWarps; int end = (warp+1)*(numTiles > maxTiles ? NUM_BLOCKS*(NUM_BLOCKS+1)/2 : numTiles)/totalWarps; #else int pos = warp*numTiles/totalWarps; int end = (warp+1)*numTiles/totalWarps; #endif int skipBase = 0; int currentSkipIndex = tbx; __local int atomIndices[FORCE_WORK_GROUP_SIZE]; __local volatile int skipTiles[FORCE_WORK_GROUP_SIZE]; skipTiles[get_local_id(0)] = -1; while (pos < end) { real value = 0; bool includeTile = true; // Extract the coordinates of this tile. unsigned int x, y; bool singlePeriodicCopy = false; #ifdef USE_CUTOFF if (numTiles <= maxTiles) { ushort2 tileIndices = tiles[pos]; x = tileIndices.x; singlePeriodicCopy = tileIndices.y; } else #endif { y = (unsigned int) floor(NUM_BLOCKS+0.5f-SQRT((NUM_BLOCKS+0.5f)*(NUM_BLOCKS+0.5f)-2*pos)); x = (pos-y*NUM_BLOCKS+y*(y+1)/2); if (x < y || x >= NUM_BLOCKS) { // Occasionally happens due to roundoff error. y += (x < y ? -1 : 1); x = (pos-y*NUM_BLOCKS+y*(y+1)/2); } // Skip over tiles that have exclusions, since they were already processed. SYNC_WARPS; while (skipTiles[tbx+TILE_SIZE-1] < pos) { SYNC_WARPS; if (skipBase+tgx < NUM_TILES_WITH_EXCLUSIONS) { ushort2 tile = exclusionTiles[skipBase+tgx]; skipTiles[get_local_id(0)] = tile.x + tile.y*NUM_BLOCKS - tile.y*(tile.y+1)/2; } else skipTiles[get_local_id(0)] = end; skipBase += TILE_SIZE; currentSkipIndex = tbx; SYNC_WARPS; } while (skipTiles[currentSkipIndex] < pos) currentSkipIndex++; includeTile = (skipTiles[currentSkipIndex] != pos); } if (includeTile) { unsigned int atom1 = x*TILE_SIZE + tgx; // Load atom data for this tile. real4 posq1 = posq[atom1]; LOAD_ATOM1_PARAMETERS const unsigned int localAtomIndex = get_local_id(0); #ifdef USE_CUTOFF unsigned int j = (numTiles <= maxTiles ? interactingAtoms[pos*TILE_SIZE+tgx] : y*TILE_SIZE + tgx); #else unsigned int j = y*TILE_SIZE + tgx; #endif atomIndices[get_local_id(0)] = j; if (j < PADDED_NUM_ATOMS) { local_posq[localAtomIndex] = posq[j]; LOAD_LOCAL_PARAMETERS_FROM_GLOBAL local_value[localAtomIndex] = 0; } SYNC_WARPS; #ifdef USE_PERIODIC if (singlePeriodicCopy) { // The box is small enough that we can just translate all the atoms into a single periodic // box, then skip having to apply periodic boundary conditions later. real4 blockCenterX = blockCenter[x]; posq1.xyz -= floor((posq1.xyz-blockCenterX.xyz)*invPeriodicBoxSize.xyz+0.5f)*periodicBoxSize.xyz; local_posq[get_local_id(0)].x -= floor((local_posq[get_local_id(0)].x-blockCenterX.x)*invPeriodicBoxSize.x+0.5f)*periodicBoxSize.x; local_posq[get_local_id(0)].y -= floor((local_posq[get_local_id(0)].y-blockCenterX.y)*invPeriodicBoxSize.y+0.5f)*periodicBoxSize.y; local_posq[get_local_id(0)].z -= floor((local_posq[get_local_id(0)].z-blockCenterX.z)*invPeriodicBoxSize.z+0.5f)*periodicBoxSize.z; SYNC_WARPS; unsigned int tj = tgx; for (j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+tj; real4 posq2 = local_posq[atom2]; real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; if (r2 < CUTOFF_SQUARED) { real invR = RSQRT(r2); real r = RECIP(invR); LOAD_ATOM2_PARAMETERS atom2 = atomIndices[tbx+tj]; real tempValue1 = 0; real tempValue2 = 0; if (atom1 < NUM_ATOMS && atom2 < NUM_ATOMS) { COMPUTE_VALUE } value += tempValue1; local_value[tbx+tj] += tempValue2; } tj = (tj + 1) & (TILE_SIZE - 1); SYNC_WARPS; } } else #endif { // We need to apply periodic boundary conditions separately for each interaction. unsigned int tj = tgx; for (j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+tj; real4 posq2 = local_posq[atom2]; real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC delta.xyz -= floor(delta.xyz*invPeriodicBoxSize.xyz+0.5f)*periodicBoxSize.xyz; #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef USE_CUTOFF if (r2 < CUTOFF_SQUARED) { #endif real invR = RSQRT(r2); real r = RECIP(invR); LOAD_ATOM2_PARAMETERS atom2 = atomIndices[tbx+tj]; real tempValue1 = 0; real tempValue2 = 0; if (atom1 < NUM_ATOMS && atom2 < NUM_ATOMS) { COMPUTE_VALUE } value += tempValue1; local_value[tbx+tj] += tempValue2; #ifdef USE_CUTOFF } #endif tj = (tj + 1) & (TILE_SIZE - 1); SYNC_WARPS; } } // Write results. #ifdef USE_CUTOFF unsigned int atom2 = atomIndices[get_local_id(0)]; #else unsigned int atom2 = y*TILE_SIZE + tgx; #endif #ifdef SUPPORTS_64_BIT_ATOMICS atom_add(&global_value[atom1], (long) (value*0x100000000)); if (atom2 < PADDED_NUM_ATOMS) atom_add(&global_value[atom2], (long) (local_value[get_local_id(0)]*0x100000000)); #else unsigned int offset1 = atom1 + warp*PADDED_NUM_ATOMS; unsigned int offset2 = atom2 + warp*PADDED_NUM_ATOMS; global_value[offset1] += value; if (atom2 < PADDED_NUM_ATOMS) global_value[offset2] += local_value[get_local_id(0)]; #endif } pos++; } }