aboutsummaryrefslogtreecommitdiffstats
path: root/pkg/flatrpc/flatrpc.go
diff options
context:
space:
mode:
authorDmitry Vyukov <dvyukov@google.com>2024-06-27 12:01:58 +0200
committerDmitry Vyukov <dvyukov@google.com>2024-07-02 15:07:08 +0000
commit07dedd50ee8834dbca4da7667e69e72b7d0565b9 (patch)
tree44925ee15f9fad9ad0641435fd459d25375c811d /pkg/flatrpc/flatrpc.go
parent6a2ff1acbd95b320444a729d9d281835be88ec66 (diff)
pkg/fuzzer: remove signal rotation
Signal rotation is intended to make the fuzzer re-discover flaky coverage in non flaky way. However, taking into accout that we get effectively the same effect after each manager restart, and that the fuzzer is overloaded with triage/smash jobs, it does not look to be worth it.
Diffstat (limited to 'pkg/flatrpc/flatrpc.go')
-rw-r--r--pkg/flatrpc/flatrpc.go52
1 files changed, 2 insertions, 50 deletions
diff --git a/pkg/flatrpc/flatrpc.go b/pkg/flatrpc/flatrpc.go
index 87f6ad19d..79c0d6cf2 100644
--- a/pkg/flatrpc/flatrpc.go
+++ b/pkg/flatrpc/flatrpc.go
@@ -2061,8 +2061,7 @@ func ExecRequestRawEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT {
}
type SignalUpdateRawT struct {
- NewMax []uint64 `json:"new_max"`
- DropMax []uint64 `json:"drop_max"`
+ NewMax []uint64 `json:"new_max"`
}
func (t *SignalUpdateRawT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT {
@@ -2078,18 +2077,8 @@ func (t *SignalUpdateRawT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffse
}
newMaxOffset = builder.EndVector(newMaxLength)
}
- dropMaxOffset := flatbuffers.UOffsetT(0)
- if t.DropMax != nil {
- dropMaxLength := len(t.DropMax)
- SignalUpdateRawStartDropMaxVector(builder, dropMaxLength)
- for j := dropMaxLength - 1; j >= 0; j-- {
- builder.PrependUint64(t.DropMax[j])
- }
- dropMaxOffset = builder.EndVector(dropMaxLength)
- }
SignalUpdateRawStart(builder)
SignalUpdateRawAddNewMax(builder, newMaxOffset)
- SignalUpdateRawAddDropMax(builder, dropMaxOffset)
return SignalUpdateRawEnd(builder)
}
@@ -2099,11 +2088,6 @@ func (rcv *SignalUpdateRaw) UnPackTo(t *SignalUpdateRawT) {
for j := 0; j < newMaxLength; j++ {
t.NewMax[j] = rcv.NewMax(j)
}
- dropMaxLength := rcv.DropMaxLength()
- t.DropMax = make([]uint64, dropMaxLength)
- for j := 0; j < dropMaxLength; j++ {
- t.DropMax[j] = rcv.DropMax(j)
- }
}
func (rcv *SignalUpdateRaw) UnPack() *SignalUpdateRawT {
@@ -2168,34 +2152,8 @@ func (rcv *SignalUpdateRaw) MutateNewMax(j int, n uint64) bool {
return false
}
-func (rcv *SignalUpdateRaw) DropMax(j int) uint64 {
- o := flatbuffers.UOffsetT(rcv._tab.Offset(6))
- if o != 0 {
- a := rcv._tab.Vector(o)
- return rcv._tab.GetUint64(a + flatbuffers.UOffsetT(j*8))
- }
- return 0
-}
-
-func (rcv *SignalUpdateRaw) DropMaxLength() int {
- o := flatbuffers.UOffsetT(rcv._tab.Offset(6))
- if o != 0 {
- return rcv._tab.VectorLen(o)
- }
- return 0
-}
-
-func (rcv *SignalUpdateRaw) MutateDropMax(j int, n uint64) bool {
- o := flatbuffers.UOffsetT(rcv._tab.Offset(6))
- if o != 0 {
- a := rcv._tab.Vector(o)
- return rcv._tab.MutateUint64(a+flatbuffers.UOffsetT(j*8), n)
- }
- return false
-}
-
func SignalUpdateRawStart(builder *flatbuffers.Builder) {
- builder.StartObject(2)
+ builder.StartObject(1)
}
func SignalUpdateRawAddNewMax(builder *flatbuffers.Builder, newMax flatbuffers.UOffsetT) {
builder.PrependUOffsetTSlot(0, flatbuffers.UOffsetT(newMax), 0)
@@ -2203,12 +2161,6 @@ func SignalUpdateRawAddNewMax(builder *flatbuffers.Builder, newMax flatbuffers.U
func SignalUpdateRawStartNewMaxVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT {
return builder.StartVector(8, numElems, 8)
}
-func SignalUpdateRawAddDropMax(builder *flatbuffers.Builder, dropMax flatbuffers.UOffsetT) {
- builder.PrependUOffsetTSlot(1, flatbuffers.UOffsetT(dropMax), 0)
-}
-func SignalUpdateRawStartDropMaxVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT {
- return builder.StartVector(8, numElems, 8)
-}
func SignalUpdateRawEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT {
return builder.EndObject()
}