Skip to content

Commit 189a62d

Browse files
committedMay 14, 2024··
fix(broadcast): removed name conflict on method names
1 parent ded0579 commit 189a62d

File tree

5 files changed

+20
-25
lines changed

5 files changed

+20
-25
lines changed
 

‎cmd/protoc-gen-gorums/dev/zorums_qspec_gorums.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cmd/protoc-gen-gorums/dev/zorums_server_gorums.pb.go

+6-6
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cmd/protoc-gen-gorums/gengorums/template_server.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -128,10 +128,10 @@ const (
128128
{{$service := .GoName}}
129129
{{- range .Methods}}
130130
{{- if isBroadcast .}}
131-
{{.GoName}}Method string = "{{.Desc.FullName}}"
131+
{{$service}}{{.GoName}} string = "{{.Desc.FullName}}"
132132
{{- else }}
133133
{{- if isBroadcastCall .}}
134-
{{.GoName}}Method string = "{{.Desc.FullName}}"
134+
{{$service}}{{.GoName}} string = "{{.Desc.FullName}}"
135135
{{- end}}
136136
{{- end}}
137137
{{- end}}

‎tests/broadcast/broadcast_gorums.pb.go

+10-10
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎tests/broadcast/server.go

+1-6
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,8 @@ type testServer struct {
3434
}
3535

3636
func newtestServer(addr string, srvAddresses []string, _ int) *testServer {
37-
// enable profiling
38-
//go func() {
39-
// http.ListenAndServe(fmt.Sprintf(":1000%v", i), nil)
40-
//}()
4137
srv := testServer{
42-
Server: NewServer(gorums.WithOrder(BroadcastCall)),
38+
Server: NewServer(),
4339
numMsg: map[string]int{"BC": 0, "QC": 0, "QCB": 0, "QCM": 0, "M": 0, "BI": 0, "B": 0},
4440
respChan: make(map[int64]response),
4541
leader: leader,
@@ -51,7 +47,6 @@ func newtestServer(addr string, srvAddresses []string, _ int) *testServer {
5147
srv.processingTime = 100 * time.Millisecond
5248
}
5349
srv.mgr = NewManager(
54-
gorums.WithSendBufferSize(uint(2*len(srvAddresses))),
5550
gorums.WithPublicKey("server"),
5651
gorums.WithGrpcDialOptions(
5752
grpc.WithTransportCredentials(insecure.NewCredentials()),

0 commit comments

Comments
 (0)
Please sign in to comment.