Skip to content

Commit

Permalink
feat: Add flags to enable multi-conn support
Browse files Browse the repository at this point in the history
  • Loading branch information
pojntfx committed Oct 5, 2023
1 parent 5ade843 commit 7183cde
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 1 deletion.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -190,7 +190,7 @@ $ rm -f disk.img && truncate -s 10G disk.img && go run ./cmd/go-nbd-example-serv
$ go run ./cmd/go-nbd-example-server-memory .

# With the C NBD client
$ sudo umount ~/Downloads/mnt; sudo nbd-client -d /dev/nbd1 && echo 'NBD starting' | sudo tee /dev/kmsg && sudo nbd-client -N default localhost 10809
$ 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

# With the Go NBD client
$ 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
Expand Down
2 changes: 2 additions & 0 deletions cmd/go-nbd-example-server-file/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ func main() {
minimumBlockSize := flag.Uint("minimum-block-size", 1, "Minimum block size")
preferredBlockSize := flag.Uint("preferred-block-size", client.MaximumBlockSize, "Preferred block size")
maximumBlockSize := flag.Uint("maximum-block-size", 0xffffffff, "Maximum block size")
multiConn := flag.Bool("multi-conn", true, "Whether to advertise support for multiple simultaneous connections")

flag.Parse()

Expand Down Expand Up @@ -88,6 +89,7 @@ func main() {
MinimumBlockSize: uint32(*minimumBlockSize),
PreferredBlockSize: uint32(*preferredBlockSize),
MaximumBlockSize: uint32(*maximumBlockSize),
SupportsMultiConn: *multiConn,
}); err != nil {
panic(err)
}
Expand Down
2 changes: 2 additions & 0 deletions cmd/go-nbd-example-server-memory/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ func main() {
minimumBlockSize := flag.Uint("minimum-block-size", 1, "Minimum block size")
preferredBlockSize := flag.Uint("preferred-block-size", client.MaximumBlockSize, "Preferred block size")
maximumBlockSize := flag.Uint("maximum-block-size", 0xffffffff, "Maximum block size")
multiConn := flag.Bool("multi-conn", true, "Whether to advertise support for multiple simultaneous connections")

flag.Parse()

Expand Down Expand Up @@ -73,6 +74,7 @@ func main() {
MinimumBlockSize: uint32(*minimumBlockSize),
PreferredBlockSize: uint32(*preferredBlockSize),
MaximumBlockSize: uint32(*maximumBlockSize),
SupportsMultiConn: *multiConn,
}); err != nil {
panic(err)
}
Expand Down

0 comments on commit 7183cde

Please sign in to comment.