Skip to content

Commit

Permalink
Update on "[ET-VK] Adding batch processing in x axis to conv2d dw sha…
Browse files Browse the repository at this point in the history
…der by caching input texel for reuse."

This diff adds batch processing in the x axis to the conv2d dw shader by reusing input texel overlapping between consecutive tiles. The changes include modifying the glsl code for the conv2d dw output tile, adding a new parameter to the yaml file, and modifying the Convolution.cpp file to use the new parameter.

Differential Revision: [D67868671](https://our.internmc.facebook.com/intern/diff/D67868671/)

[ghstack-poisoned]
  • Loading branch information
trivedivivek committed Jan 6, 2025
2 parents 9bfe284 + 519af1d commit b6d7a76
Show file tree
Hide file tree
Showing 3 changed files with 34 additions and 33 deletions.
57 changes: 28 additions & 29 deletions backends/vulkan/runtime/graph/ops/glsl/conv2d_dw_output_tile.glsl
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@

#define op(X, A, B) ${OPERATOR}

#include "indexing_utils_u16.h"
#include "indexing_utils.h"

layout(std430) buffer;

Expand All @@ -43,35 +43,34 @@ layout(local_size_x_id = 0, local_size_y_id = 1, local_size_z_id = 2) in;
* output at a single output location.
*/
void main() {
// x divided up by batch size is used to determine 3d position
// y divided up by batch size is used to determine 3d position
// x and y are divided by batch size to determine 3d position
// since work size is calculated by x * ((y + B_Y - 1) / B_Y) * z
const ivec2 out_limits_xy_scaled = ivec2(out_limits.xy + ivec2(BATCH_SIZE_X, BATCH_SIZE_Y) - 1) / ivec2(BATCH_SIZE_X, BATCH_SIZE_Y);
const ivec2 out_limits_xy_scaled = (out_limits.xy + ivec2(BATCH_SIZE_X, BATCH_SIZE_Y) - 1) / ivec2(BATCH_SIZE_X, BATCH_SIZE_Y);

u16vec3 pos = idx_to_u16pos_x_wise(gl_GlobalInvocationID.x, out_limits_xy_scaled.x, out_limits_xy_scaled.y);
ivec3 pos = idx_to_ipos_x_wise(gl_GlobalInvocationID.x, out_limits_xy_scaled.x, out_limits_xy_scaled.y);

// scale pos.xy by batch sizes, because that's the top pixel to be processed
pos.x *= uint16_t(BATCH_SIZE_X);
pos.y *= uint16_t(BATCH_SIZE_Y);
pos.x *= BATCH_SIZE_X;
pos.y *= BATCH_SIZE_Y;

// do not process if top pixel does not fit within the output range
if (any(greaterThanEqual(u16vec3(pos.x, pos.y, pos.z), out_limits))) {
if (any(greaterThanEqual(pos, out_limits))) {
return;
}

// Compute the index of the top-left element of the overlay region. Negative
// indices indicate that the top-left element is in a region added by padding.
const u16vec2 ipos = pos.xy * u16vec2(stride) - u16vec2(padding);
const ivec2 ipos = pos.xy * stride - padding;

// Compute the start and end of the input indices to load. Padding is assumed
// to be constant 0 padding, so any reads from the padding region is skipped.
const u16vec2 start = ipos;
const u16vec2 end = ipos + u16vec2(overlay_region.xy);
const ivec2 start = ipos;
const ivec2 end = ipos + overlay_region.xy;

// sum outputs
VEC4_T sum[BATCH_SIZE_Y][BATCH_SIZE_X];

sum[0][0] = texelFetch(t_bias, u16vec2(pos.z, 0), 0);
sum[0][0] = texelFetch(t_bias, ivec2(pos.z, 0), 0);
for (int y = 0; y < BATCH_SIZE_Y; y++) {
for (int x = 0; x < BATCH_SIZE_X; x++) {
sum[y][x] = sum[0][0];
Expand All @@ -84,39 +83,39 @@ void main() {
// array to store kernel data of previous y
VEC4_T prev_kernel_line[TILE_SIZE];

uint16_t kx = uint16_t(0);
for (uint16_t y = start.y, i = uint16_t(0); i < uint16_t(TILE_SIZE + BATCH_SIZE_Y - 1); y += uint16_t(dilation.y), i++) {
for (uint16_t x = start.x, j = uint16_t(0); j < uint16_t(TILE_SIZE + BATCH_SIZE_X - 1); x += uint16_t(dilation.x), j++) {
in_texels[int(j)] = texelFetch(t_in, u16vec3(x, y, pos.z), 0);
int kx = 0;
for (int y = start.y, i = 0; i < TILE_SIZE + BATCH_SIZE_Y - 1; y += dilation.y, i++) {
for (int x = start.x, j = 0; j < TILE_SIZE + BATCH_SIZE_X - 1; x += dilation.x, j++) {
in_texels[j] = texelFetch(t_in, ivec3(x, y, pos.z), 0);
}

// from 2nd iteration onwards accumulate dot product in 2nd sum
// based on kernel line data fetched in previous iteration and input texel from this iteration
if (i > uint16_t(0)) {
for (uint16_t s = uint16_t(0); s < uint16_t(BATCH_SIZE_X); s++) {
for (uint16_t j = uint16_t(0); j < uint16_t(TILE_SIZE); j++) {
sum[1][int(s)] = fma(in_texels[int(j+s)], prev_kernel_line[int(j)], sum[1][int(s)]);
if (i > 0) {
for (int j = 0; j < TILE_SIZE; j++) {
for (int s = 0; s < BATCH_SIZE_X; s++) {
sum[1][s] = fma(in_texels[j + s], prev_kernel_line[j], sum[1][s]);
}
}
}

// accumulate dot product in 1st sum only until tile size
if (i < uint16_t(TILE_SIZE)) {
for (uint16_t j = uint16_t(0); j < uint16_t(TILE_SIZE); j++, kx++) {
prev_kernel_line[int(j)] = texelFetch(t_kernel, u16vec2(kx, pos.z), 0);
for (uint16_t s = uint16_t(0); s < uint16_t(BATCH_SIZE_X); s++) {
sum[0][int(s)] = fma(in_texels[int(j+s)], prev_kernel_line[int(j)], sum[0][int(s)]);
if (i < int(TILE_SIZE)) {
for (int j = 0; j < TILE_SIZE; j++, kx++) {
prev_kernel_line[j] = texelFetch(t_kernel, ivec2(kx, pos.z), 0);
for (int s = 0; s < BATCH_SIZE_X; s++) {
sum[0][s] = fma(in_texels[j + s], prev_kernel_line[j], sum[0][s]);
}
}
}
}

for (int i = 0; i < BATCH_SIZE_Y; i++) {
for (int j = 0; j < BATCH_SIZE_X; j++) {
if (any(greaterThanEqual(u16vec3(pos.x + j, pos.y + i, pos.z), out_limits))) {
for (int y = 0; y < BATCH_SIZE_Y; y++) {
for (int x = 0; x < BATCH_SIZE_X; x++) {
if (any(greaterThanEqual(ivec3(pos.x + x, pos.y + y, pos.z), out_limits))) {
continue;
}
imageStore(t_out, u16vec3(pos.x + j, pos.y + i, pos.z), op(sum[i][j], out_min, out_max));
imageStore(t_out, ivec3(pos.x + x, pos.y + y, pos.z), op(sum[y][x], out_min, out_max));
}
}
}
5 changes: 5 additions & 0 deletions backends/vulkan/runtime/graph/ops/glsl/indexing_utils.h
Original file line number Diff line number Diff line change
Expand Up @@ -223,6 +223,11 @@ ivec3 lpos_to_pos(const ivec3 lpos, const ivec4 axis_map) {
return pos;
}

ivec3 idx_to_ipos_x_wise(uint idx, int size_x, int size_y) {
const uint div_by_x = idx / size_x;
return ivec3(idx % size_x, div_by_x % size_y, div_by_x / size_y);
}

#ifdef USING_BUFFER
#define load_texel(buf, idx) buf[idx]
#elif defined(USING_TEXTURE2D)
Expand Down
5 changes: 1 addition & 4 deletions backends/vulkan/runtime/graph/ops/glsl/indexing_utils_u16.h
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,7 @@

u16vec3 idx_to_u16pos_x_wise(uint idx, int size_x, int size_y) {
const uint div_by_x = idx / size_x;
return u16vec3(
idx % size_x,
div_by_x % size_y,
div_by_x / size_y);
return u16vec3(idx % size_x, div_by_x % size_y, div_by_x / size_y);
}

#endif // INDEXING_UTILS_U16_H

0 comments on commit b6d7a76

Please sign in to comment.