Skip to content

Commit 3491e36

Browse files
authored
python: minor test improvement (#221)
* python: minor test improvement Signed-off-by: Tim Stamler <tstamler@nvidia.com>
1 parent ac661ee commit 3491e36

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

examples/python/blocking_send_recv_example.py

+11-1
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ def parse_args():
2626
parser = argparse.ArgumentParser()
2727
parser.add_argument("--ip", type=str, required=True)
2828
parser.add_argument("--port", type=int, default=5555)
29+
parser.add_argument("--use_cuda", type=bool, default=False)
2930
parser.add_argument(
3031
"--mode",
3132
type=str,
@@ -47,10 +48,19 @@ def parse_args():
4748

4849
# Allocate memory and register with NIXL
4950
agent = nixl_agent(args.mode, config)
50-
if args.mode == "target":
51+
if args.mode == "target" and args.use_cuda:
52+
tensors = [
53+
torch.ones(10, dtype=torch.float32, device="cuda:0") for _ in range(2)
54+
]
55+
elif args.use_cuda:
56+
tensors = [
57+
torch.zeros(10, dtype=torch.float32, device="cuda:0") for _ in range(2)
58+
]
59+
elif args.mode == "target" and not args.use_cuda:
5160
tensors = [torch.ones(10, dtype=torch.float32) for _ in range(2)]
5261
else:
5362
tensors = [torch.zeros(10, dtype=torch.float32) for _ in range(2)]
63+
5464
print(f"{args.mode} Tensors: {tensors}")
5565

5666
reg_descs = agent.register_memory(tensors)

src/api/python/_api.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -766,7 +766,7 @@ def get_xfer_descs(
766766
gpu_id = descs.get_device()
767767
if gpu_id == -1: # DRAM
768768
gpu_id = 0
769-
new_descs = nixlBind.nixlRegDList(
769+
new_descs = nixlBind.nixlXferDList(
770770
self.nixl_mems[mem_type],
771771
[(base_addr, region_len, gpu_id)],
772772
is_sorted,

0 commit comments

Comments
 (0)