Fix UpdateOption

Signed-off-by: MyonKeminta <MyonKeminta@users.noreply.github.com>
MyonKeminta · Jul 3, 2024 · d25a8c8 · d25a8c8
1 parent a41e40c
commit d25a8c8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/client/client.go b/client/client.go
@@ -735,6 +735,12 @@ func (c *client) UpdateOption(option DynamicOption, value any) error {
 			return errors.New("[pd] invalid value type for EnableFollowerHandle option, it should be bool")
 		}
 		c.option.setEnableFollowerHandle(enable)
+	case TSOClientConcurrencyFactor:
+		value, ok := value.(int)
+		if !ok {
+			return errors.New("[pd] invalid value type for TSOClientConcurrencyFactor option, it should be int")
+		}
+		c.option.setTSOClientConcurrencyFactor(value)
 	default:
 		return errors.New("[pd] unsupported client option")
 	}

diff --git a/client/tso_stream.go b/client/tso_stream.go
@@ -724,6 +724,8 @@ func (h *histogram) String() string {
 			}
 
 			put(lastValue, lastValueCount)
+			lastValue = h.buckets[i]
+			lastValueCount = 1
 		}
 
 		put(lastValue, lastValueCount)