Skip to content

Commit 12ee176

Browse files
authored
rpc : add check for rpc buffer type (#18242)
1 parent ed75977 commit 12ee176

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

ggml/src/ggml-rpc/ggml-rpc.cpp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -571,6 +571,10 @@ static void * ggml_backend_rpc_buffer_get_base(ggml_backend_buffer_t buffer) {
571571
return ctx->base_ptr;
572572
}
573573

574+
static bool ggml_backend_buffer_is_rpc(ggml_backend_buffer_t buffer) {
575+
return buffer->iface.free_buffer == ggml_backend_rpc_buffer_free_buffer;
576+
}
577+
574578
static rpc_tensor serialize_tensor(const ggml_tensor * tensor) {
575579
rpc_tensor result;
576580
if (!tensor) {
@@ -580,7 +584,7 @@ static rpc_tensor serialize_tensor(const ggml_tensor * tensor) {
580584

581585
result.id = reinterpret_cast<uint64_t>(tensor);
582586
result.type = tensor->type;
583-
if (tensor->buffer) {
587+
if (tensor->buffer && ggml_backend_buffer_is_rpc(tensor->buffer)) {
584588
ggml_backend_buffer_t buffer = tensor->buffer;
585589
ggml_backend_rpc_buffer_context * ctx = (ggml_backend_rpc_buffer_context *)buffer->context;
586590
result.buffer = ctx != nullptr ? ctx->remote_ptr : 0;
@@ -664,10 +668,6 @@ static void ggml_backend_rpc_buffer_get_tensor(ggml_backend_buffer_t buffer, con
664668
RPC_STATUS_ASSERT(status);
665669
}
666670

667-
static bool ggml_backend_buffer_is_rpc(ggml_backend_buffer_t buffer) {
668-
return buffer->iface.free_buffer == ggml_backend_rpc_buffer_free_buffer;
669-
}
670-
671671
static bool ggml_backend_rpc_buffer_cpy_tensor(ggml_backend_buffer_t buffer, const ggml_tensor * src, ggml_tensor * dst) {
672672
if (ggml_backend_buffer_is_rpc(src->buffer)) {
673673
// check if src and dst are on the same server

0 commit comments

Comments
 (0)