File tree Expand file tree Collapse file tree 1 file changed +10
-4
lines changed
vllm/distributed/device_communicators Expand file tree Collapse file tree 1 file changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -357,8 +357,11 @@ def acquire_write(self, timeout: Optional[float] = None):
357
357
# if we wait for a long time, log a message
358
358
if (time .monotonic () - start_time
359
359
> VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning ):
360
- logger .debug ("No available block found in %s second. " ,
361
- VLLM_RINGBUFFER_WARNING_INTERVAL )
360
+ logger .debug (
361
+ ("No available shared memory broadcast block found"
362
+ " in %s second." ),
363
+ VLLM_RINGBUFFER_WARNING_INTERVAL ,
364
+ )
362
365
n_warning += 1
363
366
364
367
# if we time out, raise an exception
@@ -415,8 +418,11 @@ def acquire_read(self, timeout: Optional[float] = None):
415
418
# if we wait for a long time, log a message
416
419
if (time .monotonic () - start_time
417
420
> VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning ):
418
- logger .debug ("No available block found in %s second. " ,
419
- VLLM_RINGBUFFER_WARNING_INTERVAL )
421
+ logger .debug (
422
+ ("No available shared memory broadcast block found"
423
+ "in %s second." ),
424
+ VLLM_RINGBUFFER_WARNING_INTERVAL ,
425
+ )
420
426
n_warning += 1
421
427
422
428
# if we time out, raise an exception
You can’t perform that action at this time.
0 commit comments