Skip to content

Commit 214dea0

Browse files
authored
WOQ: improve first token by prefetching (#2663)
* WOQ: improve first token by prefetching * Move prefetching immediately after loading data
1 parent 78bc804 commit 214dea0

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

csrc/cpu/aten/kernels/WoqTppKrnl.cpp

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -914,6 +914,13 @@ struct dequant_n_grouped {
914914
is_4bit_flag ? &qB[k * ldb / 2 + n / 2] : &qB[k * ldb + n],
915915
vscales,
916916
vzps);
917+
// prefetch qB data
918+
if constexpr (PREFETCH_K_DIST > 0) {
919+
auto prefetch_addr = is_4bit_flag
920+
? &qB[(k + PREFETCH_K_DIST) * ldb / 2 + n / 2]
921+
: &qB[(k + PREFETCH_K_DIST) * ldb + n];
922+
_mm_prefetch(prefetch_addr, _MM_HINT_T0);
923+
}
917924
// store vb to B
918925
store(B + k * N + n, vbs);
919926
}
@@ -1001,6 +1008,13 @@ struct dequant_n_grouped<bfloat16, ldb, N_GROUP_SIZE, qw_type> {
10011008
: &qB[(k + 1) * ldb + n],
10021009
vscales,
10031010
vzps);
1011+
// prefetch qB data
1012+
if constexpr (PREFETCH_K_DIST > 0) {
1013+
auto prefetch_addr = is_4bit_flag
1014+
? &qB[(k + PREFETCH_K_DIST) * ldb / 2 + n / 2]
1015+
: &qB[(k + PREFETCH_K_DIST) * ldb + n];
1016+
_mm_prefetch(prefetch_addr, _MM_HINT_T0);
1017+
}
10041018
typename VA::type vbs[2];
10051019
compile_time_for<COLS>::op([&](auto i) {
10061020
auto [low, high] = interleave(vbs_k0[i], vbs_k1[i]);

0 commit comments

Comments
 (0)