Skip to content

Commit 1b663bb

Browse files
committed
feat: Start adding integration tests executors
1 parent 7f897cc commit 1b663bb

File tree

7 files changed

+40
-5
lines changed

7 files changed

+40
-5
lines changed

Diff for: .gitignore

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
out

Diff for: Makefile

+34
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
# Public variables
2+
OUTPUT_DIR ?= out
3+
4+
# Private variables
5+
obj = r3map-benchmark-direct-mount r3map-benchmark-managed-mount r3map-benchmark-migration
6+
all: $(addprefix build/,$(obj))
7+
8+
# Build
9+
build: $(addprefix build/,$(obj))
10+
$(addprefix build/,$(obj)):
11+
go build -o $(OUTPUT_DIR)/$(subst build/,,$@) ./cmd/$(subst build/,,$@)
12+
13+
# Integration
14+
integration: integration/direct-mount-file integration/direct-mount-directory integration/managed-mount-file integration/managed-mount-directory
15+
16+
integration/direct-mount-file:
17+
$(OUTPUT_DIR)/r3map-benchmark-direct-mount --remote-backend=file
18+
19+
integration/direct-mount-directory:
20+
$(OUTPUT_DIR)/r3map-benchmark-direct-mount --remote-backend=directory --remote-backend-chunking
21+
22+
integration/managed-mount-file:
23+
$(OUTPUT_DIR)/r3map-benchmark-managed-mount --remote-backend=file
24+
25+
integration/managed-mount-directory:
26+
$(OUTPUT_DIR)/r3map-benchmark-managed-mount --remote-backend=directory --remote-backend-chunking
27+
28+
# Clean
29+
clean:
30+
rm -rf out
31+
32+
# Dependencies
33+
depend:
34+
go generate ./...

Diff for: cmd/r3map-benchmark-direct-mount/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ var (
5454
)
5555

5656
func main() {
57-
s := flag.Int64("size", 4096*8192, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
57+
s := flag.Int64("size", 536870912, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
5858
chunkSize := flag.Int64("chunk-size", client.MaximumBlockSize, "Chunk size to use")
5959

6060
remoteBackend := flag.String(

Diff for: cmd/r3map-benchmark-managed-mount/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ var (
5454
)
5555

5656
func main() {
57-
s := flag.Int64("size", 4096*8192, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
57+
s := flag.Int64("size", 536870912, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
5858
chunkSize := flag.Int64("chunk-size", client.MaximumBlockSize, "Chunk size to use")
5959

6060
pullWorkers := flag.Int64("pull-workers", 512, "Pull workers to launch in the background; pass in 0 to disable preemptive pull")

Diff for: cmd/r3map-benchmark-migration-server/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func main() {
4646
enableFrpc := flag.Bool("frpc", false, "Whether to use fRPC instead of Dudirekta")
4747
verbose := flag.Bool("verbose", false, "Whether to enable verbose logging")
4848

49-
size := flag.Int64("size", 4096*8192, "Size of the memory region or file to allocate")
49+
size := flag.Int64("size", 536870912, "Size of the memory region or file to allocate")
5050
chunkSize := flag.Int64("chunk-size", client.MaximumBlockSize, "Chunk size to use")
5151
maxChunkSize := flag.Int64("max-chunk-size", services.MaxChunkSize, "Maximum chunk size to support")
5252
bck := flag.String(

Diff for: cmd/r3map-benchmark-migration/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ var (
5656
)
5757

5858
func main() {
59-
s := flag.Int64("size", 4096*8192, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
59+
s := flag.Int64("size", 536870912, "Size of the memory region, file to allocate or to size assume in case of the dudirekta/gRPC/fRPC remotes")
6060
chunkSize := flag.Int64("chunk-size", client.MaximumBlockSize, "Chunk size to use")
6161

6262
pullWorkers := flag.Int64("pull-workers", 512, "Pull workers to launch in the background; pass in 0 to disable preemptive pull")

Diff for: cmd/r3map-benchmark-mount-server/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ func main() {
4141
enableFrpc := flag.Bool("frpc", false, "Whether to use fRPC instead of Dudirekta")
4242
verbose := flag.Bool("verbose", false, "Whether to enable verbose logging")
4343

44-
size := flag.Int64("size", 4096*8192, "Size of the memory region or file to allocate")
44+
size := flag.Int64("size", 536870912, "Size of the memory region or file to allocate")
4545
chunkSize := flag.Int64("chunk-size", client.MaximumBlockSize, "Chunk size to use")
4646
maxChunkSize := flag.Int64("max-chunk-size", services.MaxChunkSize, "Maximum chunk size to support")
4747
bck := flag.String(

0 commit comments

Comments
 (0)