#ifdef SUPPORTS_64_BIT_ATOMICS #pragma OPENCL EXTENSION cl_khr_int64_base_atomics : enable #endif #define WARPS_PER_GROUP (FORCE_WORK_GROUP_SIZE/TILE_SIZE) typedef struct { real x, y, z; real q; real fx, fy, fz; ATOM_PARAMETER_DATA #ifndef PARAMETER_SIZE_IS_EVEN real padding; #endif } AtomData; /** * Compute nonbonded interactions. */ __kernel void computeNonbonded( #ifdef SUPPORTS_64_BIT_ATOMICS __global long* restrict forceBuffers, #else __global real4* restrict forceBuffers, #endif __global mixed* restrict energyBuffer, __global const real4* restrict posq, __global const unsigned int* restrict exclusions, __global const int2* restrict exclusionTiles, unsigned int startTileIndex, unsigned long numTileIndices #ifdef USE_CUTOFF , __global const int* restrict tiles, __global const unsigned int* restrict interactionCount, real4 periodicBoxSize, real4 invPeriodicBoxSize, real4 periodicBoxVecX, real4 periodicBoxVecY, real4 periodicBoxVecZ, unsigned int maxTiles, __global const real4* restrict blockCenter, __global const real4* restrict blockSize, __global const int* restrict interactingAtoms #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; mixed energy = 0; INIT_DERIVATIVES __local AtomData localData[FORCE_WORK_GROUP_SIZE]; // 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 int2 tileIndices = exclusionTiles[pos]; const unsigned int x = tileIndices.x; const unsigned int y = tileIndices.y; real4 force = 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 const bool hasExclusions = true; if (x == y) { // This tile is on the diagonal. const unsigned int localAtomIndex = get_local_id(0); localData[localAtomIndex].x = posq1.x; localData[localAtomIndex].y = posq1.y; localData[localAtomIndex].z = posq1.z; localData[localAtomIndex].q = posq1.w; LOAD_LOCAL_PARAMETERS_FROM_1 SYNC_WARPS; for (unsigned int j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+j; real4 posq2 = (real4) (localData[atom2].x, localData[atom2].y, localData[atom2].z, localData[atom2].q); real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC APPLY_PERIODIC_TO_DELTA(delta) #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; real invR = RSQRT(r2); real r = r2*invR; LOAD_ATOM2_PARAMETERS atom2 = y*TILE_SIZE+j; #ifdef USE_SYMMETRIC real dEdR = 0; #else real4 dEdR1 = (real4) 0; real4 dEdR2 = (real4) 0; #endif #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS || !(excl & 0x1)); #endif real tempEnergy = 0; const real interactionScale = 0.5f; COMPUTE_INTERACTION energy += 0.5f*tempEnergy; #ifdef INCLUDE_FORCES #ifdef USE_SYMMETRIC force.xyz -= delta.xyz*dEdR; #else force.xyz -= dEdR1.xyz; #endif #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; real4 tempPosq = posq[j]; localData[localAtomIndex].x = tempPosq.x; localData[localAtomIndex].y = tempPosq.y; localData[localAtomIndex].z = tempPosq.z; localData[localAtomIndex].q = tempPosq.w; LOAD_LOCAL_PARAMETERS_FROM_GLOBAL localData[localAtomIndex].fx = 0; localData[localAtomIndex].fy = 0; localData[localAtomIndex].fz = 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 = (real4) (localData[atom2].x, localData[atom2].y, localData[atom2].z, localData[atom2].q); real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC APPLY_PERIODIC_TO_DELTA(delta) #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef PRUNE_BY_CUTOFF if (r2 < MAX_CUTOFF*MAX_CUTOFF) { #endif real invR = RSQRT(r2); real r = r2*invR; LOAD_ATOM2_PARAMETERS atom2 = y*TILE_SIZE+tj; #ifdef USE_SYMMETRIC real dEdR = 0; #else real4 dEdR1 = (real4) 0; real4 dEdR2 = (real4) 0; #endif #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS || !(excl & 0x1)); #endif real tempEnergy = 0; const real interactionScale = 1.0f; COMPUTE_INTERACTION energy += tempEnergy; #ifdef INCLUDE_FORCES #ifdef USE_SYMMETRIC delta.xyz *= dEdR; force.xyz -= delta.xyz; localData[tbx+tj].fx += delta.x; localData[tbx+tj].fy += delta.y; localData[tbx+tj].fz += delta.z; #else force.xyz -= dEdR1.xyz; localData[tbx+tj].fx += dEdR2.x; localData[tbx+tj].fy += dEdR2.y; localData[tbx+tj].fz += dEdR2.z; #endif #endif #ifdef PRUNE_BY_CUTOFF } #endif #ifdef USE_EXCLUSIONS excl >>= 1; #endif tj = (tj + 1) & (TILE_SIZE - 1); SYNC_WARPS; } } // Write results. #ifdef INCLUDE_FORCES #ifdef SUPPORTS_64_BIT_ATOMICS unsigned int offset = x*TILE_SIZE + tgx; atom_add(&forceBuffers[offset], (long) (force.x*0x100000000)); atom_add(&forceBuffers[offset+PADDED_NUM_ATOMS], (long) (force.y*0x100000000)); atom_add(&forceBuffers[offset+2*PADDED_NUM_ATOMS], (long) (force.z*0x100000000)); if (x != y) { offset = y*TILE_SIZE + tgx; atom_add(&forceBuffers[offset], (long) (localData[get_local_id(0)].fx*0x100000000)); atom_add(&forceBuffers[offset+PADDED_NUM_ATOMS], (long) (localData[get_local_id(0)].fy*0x100000000)); atom_add(&forceBuffers[offset+2*PADDED_NUM_ATOMS], (long) (localData[get_local_id(0)].fz*0x100000000)); } #else unsigned int offset1 = x*TILE_SIZE + tgx + warp*PADDED_NUM_ATOMS; unsigned int offset2 = y*TILE_SIZE + tgx + warp*PADDED_NUM_ATOMS; forceBuffers[offset1].xyz += force.xyz; if (x != y) forceBuffers[offset2] += (real4) (localData[get_local_id(0)].fx, localData[get_local_id(0)].fy, localData[get_local_id(0)].fz, 0.0f); #endif #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]; if (numTiles > maxTiles) return; // There wasn't enough memory for the neighbor list. int pos = (int) (warp*(long)numTiles/totalWarps); int end = (int) ((warp+1)*(long)numTiles/totalWarps); #else int pos = (int) (startTileIndex+warp*numTileIndices/totalWarps); int end = (int) (startTileIndex+(warp+1)*numTileIndices/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) { const bool hasExclusions = false; real4 force = 0; bool includeTile = true; // Extract the coordinates of this tile. int x, y; bool singlePeriodicCopy = false; #ifdef USE_CUTOFF x = tiles[pos]; real4 blockSizeX = blockSize[x]; singlePeriodicCopy = (0.5f*periodicBoxSize.x-blockSizeX.x >= MAX_CUTOFF && 0.5f*periodicBoxSize.y-blockSizeX.y >= MAX_CUTOFF && 0.5f*periodicBoxSize.z-blockSizeX.z >= MAX_CUTOFF); #else y = (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) { int2 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); #endif 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 = interactingAtoms[pos*TILE_SIZE+tgx]; #else unsigned int j = y*TILE_SIZE + tgx; #endif atomIndices[get_local_id(0)] = j; if (j < PADDED_NUM_ATOMS) { real4 tempPosq = posq[j]; localData[localAtomIndex].x = tempPosq.x; localData[localAtomIndex].y = tempPosq.y; localData[localAtomIndex].z = tempPosq.z; localData[localAtomIndex].q = tempPosq.w; LOAD_LOCAL_PARAMETERS_FROM_GLOBAL localData[localAtomIndex].fx = 0; localData[localAtomIndex].fy = 0; localData[localAtomIndex].fz = 0; } else { localData[localAtomIndex].x = 0; localData[localAtomIndex].y = 0; localData[localAtomIndex].z = 0; CLEAR_LOCAL_PARAMETERS } 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]; APPLY_PERIODIC_TO_POS_WITH_CENTER(posq1, blockCenterX) APPLY_PERIODIC_TO_POS_WITH_CENTER(localData[localAtomIndex], blockCenterX) SYNC_WARPS; unsigned int tj = tgx; for (j = 0; j < TILE_SIZE; j++) { int atom2 = tbx+tj; real4 posq2 = (real4) (localData[atom2].x, localData[atom2].y, localData[atom2].z, localData[atom2].q); real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef PRUNE_BY_CUTOFF if (r2 < MAX_CUTOFF*MAX_CUTOFF) { #endif real invR = RSQRT(r2); real r = r2*invR; LOAD_ATOM2_PARAMETERS atom2 = atomIndices[tbx+tj]; #ifdef USE_SYMMETRIC real dEdR = 0; #else real4 dEdR1 = (real4) 0; real4 dEdR2 = (real4) 0; #endif #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS); #endif real tempEnergy = 0; const real interactionScale = 1.0f; COMPUTE_INTERACTION energy += tempEnergy; #ifdef INCLUDE_FORCES #ifdef USE_SYMMETRIC delta.xyz *= dEdR; force.xyz -= delta.xyz; localData[tbx+tj].fx += delta.x; localData[tbx+tj].fy += delta.y; localData[tbx+tj].fz += delta.z; #else force.xyz -= dEdR1.xyz; localData[tbx+tj].fx += dEdR2.x; localData[tbx+tj].fy += dEdR2.y; localData[tbx+tj].fz += dEdR2.z; #endif #endif #ifdef PRUNE_BY_CUTOFF } #endif 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 = (real4) (localData[atom2].x, localData[atom2].y, localData[atom2].z, localData[atom2].q); real4 delta = (real4) (posq2.xyz - posq1.xyz, 0); #ifdef USE_PERIODIC APPLY_PERIODIC_TO_DELTA(delta) #endif real r2 = delta.x*delta.x + delta.y*delta.y + delta.z*delta.z; #ifdef PRUNE_BY_CUTOFF if (r2 < MAX_CUTOFF*MAX_CUTOFF) { #endif real invR = RSQRT(r2); real r = r2*invR; LOAD_ATOM2_PARAMETERS atom2 = atomIndices[tbx+tj]; #ifdef USE_SYMMETRIC real dEdR = 0; #else real4 dEdR1 = (real4) 0; real4 dEdR2 = (real4) 0; #endif #ifdef USE_EXCLUSIONS bool isExcluded = (atom1 >= NUM_ATOMS || atom2 >= NUM_ATOMS); #endif real tempEnergy = 0; const real interactionScale = 1.0f; COMPUTE_INTERACTION energy += tempEnergy; #ifdef INCLUDE_FORCES #ifdef USE_SYMMETRIC delta.xyz *= dEdR; force.xyz -= delta.xyz; localData[tbx+tj].fx += delta.x; localData[tbx+tj].fy += delta.y; localData[tbx+tj].fz += delta.z; #else force.xyz -= dEdR1.xyz; localData[tbx+tj].fx += dEdR2.x; localData[tbx+tj].fy += dEdR2.y; localData[tbx+tj].fz += dEdR2.z; #endif #endif #ifdef PRUNE_BY_CUTOFF } #endif tj = (tj + 1) & (TILE_SIZE - 1); SYNC_WARPS; } } // Write results. #ifdef INCLUDE_FORCES #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(&forceBuffers[atom1], (long) (force.x*0x100000000)); atom_add(&forceBuffers[atom1+PADDED_NUM_ATOMS], (long) (force.y*0x100000000)); atom_add(&forceBuffers[atom1+2*PADDED_NUM_ATOMS], (long) (force.z*0x100000000)); if (atom2 < PADDED_NUM_ATOMS) { atom_add(&forceBuffers[atom2], (long) (localData[get_local_id(0)].fx*0x100000000)); atom_add(&forceBuffers[atom2+PADDED_NUM_ATOMS], (long) (localData[get_local_id(0)].fy*0x100000000)); atom_add(&forceBuffers[atom2+2*PADDED_NUM_ATOMS], (long) (localData[get_local_id(0)].fz*0x100000000)); } #else unsigned int offset1 = atom1 + warp*PADDED_NUM_ATOMS; unsigned int offset2 = atom2 + warp*PADDED_NUM_ATOMS; forceBuffers[offset1].xyz += force.xyz; if (atom2 < PADDED_NUM_ATOMS) forceBuffers[offset2] += (real4) (localData[get_local_id(0)].fx, localData[get_local_id(0)].fy, localData[get_local_id(0)].fz, 0.0f); #endif #endif } pos++; } #ifdef INCLUDE_ENERGY energyBuffer[get_global_id(0)] += energy; #endif SAVE_DERIVATIVES }