etcd-io
/
dbtester
mirror of https://github.com/etcd-io/dbtester.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

stress: add TODO to handle duplicate timestamps

This commit is contained in:
Gyu-Ho Lee 2017-02-06 11:29:40 -08:00
parent 89eb8d31ad
commit 797edc0818
1 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
stress.go
View File

@ -99,7 +99,28 @@ func (cfg *Config) Stress(databaseID string) error {
combined.Total += st.Total
combined.Lats = append(combined.Lats, st.Lats...)
combined.TimeSeries = append(combined.TimeSeries, st.TimeSeries...)
//
// Need to handle duplicate unix second timestamps when two ranges are merged.
// This can happen when the following run happens within the same unix timesecond,
// since finishing up the previous report and restarting the next range of requests
// with different number of clients takes only 100+/- ms.
//
// For instance, we have the following raw data:
//
// unix-second, client-number, throughput
// 1486389257, 700, 30335 === ending of previous combined.TimeSeries
// 1486389258, "700", 23188 === ending of previous combined.TimeSeries
// 1486389258, 1000, 5739 === beginning of current st.TimeSeries
//
// And the line below will overwrite the 'client-number' as:
//
// unix-second, client-number, throughput
// 1486389257, 700, 30335 === ending of previous combined.TimeSeries
// 1486389258, "1000", 23188 === ending of previous combined.TimeSeries
// 1486389258, 1000, 5739 === beginning of current st.TimeSeries
//
// So now we have two duplicate unix time seconds.
//
clientsN := gcfg.BenchmarkOptions.ConnectionClientNumbers[i]
for _, v := range st.TimeSeries {
tsToClientN[v.Timestamp] = clientsN