Skip to content

Commit 7183cde

Browse files
committed
feat: Add flags to enable multi-conn support
1 parent 5ade843 commit 7183cde

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ $ rm -f disk.img && truncate -s 10G disk.img && go run ./cmd/go-nbd-example-serv
190190
$ go run ./cmd/go-nbd-example-server-memory .
191191

192192
# With the C NBD client
193-
$ sudo umount ~/Downloads/mnt; sudo nbd-client -d /dev/nbd1 && echo 'NBD starting' | sudo tee /dev/kmsg && sudo nbd-client -N default localhost 10809
193+
$ sudo umount ~/Downloads/mnt; sudo nbd-client -d /dev/nbd1 && echo 'NBD starting' | sudo tee /dev/kmsg && sudo nbd-client -N default localhost 10809 /dev/nbd1
194194

195195
# With the Go NBD client
196196
$ sudo umount ~/Downloads/mnt; go build -o /tmp/go-nbd-example-client ./cmd/go-nbd-example-client/ && sudo /tmp/go-nbd-example-client --file /dev/nbd1

cmd/go-nbd-example-server-file/main.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ func main() {
2121
minimumBlockSize := flag.Uint("minimum-block-size", 1, "Minimum block size")
2222
preferredBlockSize := flag.Uint("preferred-block-size", client.MaximumBlockSize, "Preferred block size")
2323
maximumBlockSize := flag.Uint("maximum-block-size", 0xffffffff, "Maximum block size")
24+
multiConn := flag.Bool("multi-conn", true, "Whether to advertise support for multiple simultaneous connections")
2425

2526
flag.Parse()
2627

@@ -88,6 +89,7 @@ func main() {
8889
MinimumBlockSize: uint32(*minimumBlockSize),
8990
PreferredBlockSize: uint32(*preferredBlockSize),
9091
MaximumBlockSize: uint32(*maximumBlockSize),
92+
SupportsMultiConn: *multiConn,
9193
}); err != nil {
9294
panic(err)
9395
}

cmd/go-nbd-example-server-memory/main.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ func main() {
2020
minimumBlockSize := flag.Uint("minimum-block-size", 1, "Minimum block size")
2121
preferredBlockSize := flag.Uint("preferred-block-size", client.MaximumBlockSize, "Preferred block size")
2222
maximumBlockSize := flag.Uint("maximum-block-size", 0xffffffff, "Maximum block size")
23+
multiConn := flag.Bool("multi-conn", true, "Whether to advertise support for multiple simultaneous connections")
2324

2425
flag.Parse()
2526

@@ -73,6 +74,7 @@ func main() {
7374
MinimumBlockSize: uint32(*minimumBlockSize),
7475
PreferredBlockSize: uint32(*preferredBlockSize),
7576
MaximumBlockSize: uint32(*maximumBlockSize),
77+
SupportsMultiConn: *multiConn,
7678
}); err != nil {
7779
panic(err)
7880
}

0 commit comments

Comments
 (0)