Поправил заполнение базы:

 - уменьшил деградацию при содзании постов;
 - увеличил количество постов, тредов и голосования.

Author: bozaro

tests/check_forum_get_threads.go

@@ -175,7 +175,7 @@ func PerfForumGetThreadsSuccess(p *Perf, f *Factory) {
 	limit := GetRandomLimit()
 	var since *strfmt.DateTime
 	if rand.Int()&1 == 0 {
-		since = &p.data.GetThread(-1, 1).Created
+		since = &p.data.GetThread(-1, 1, 0.5).Created
 	}
 	desc := GetRandomDesc()
 	s := p.Session()
@@ -211,7 +211,7 @@ func PerfForumGetThreadsNotFound(p *Perf, f *Factory) {
 	limit := GetRandomLimit()
 	var since *strfmt.DateTime
 	if rand.Int()&1 == 0 {
-		since = &p.data.GetThread(-1, 1).Created
+		since = &p.data.GetThread(-1, 1, 0.5).Created
 	}
 	desc := GetRandomDesc()
 	_, err := p.c.Operations.ForumGetThreads(operations.NewForumGetThreadsParams().

tests/check_post_get_one.go

@@ -13,7 +13,7 @@ const (
 	RELATED_USER   = "user"
 	RELATED_THREAD = "thread"
 
-	POST_PASSES = 10
+	POST_PASSES = 16
 )
 
 func init() {

tests/check_thread_get_one.go

@@ -78,7 +78,7 @@ func (self *PThread) Validate(v PerfValidator, thread *models.Thread, version PV
 }
 
 func PerfThreadGetOneSuccess(p *Perf, f *Factory) {
-	thread := p.data.GetThread(-1, POST_PASSES)
+	thread := p.data.GetThread(-1, POST_PASSES, 0.5)
 	version := thread.Version
 	slugOrId := GetSlugOrId(thread.Slug, int64(thread.ID))
 	s := p.Session()

tests/check_thread_get_posts.go

@@ -347,7 +347,7 @@ func CheckThreadGetPostsNotFound(c *client.Forum, f *Factory) {
 }
 
 func PerfThreadGetPostsSuccess(p *Perf, f *Factory) {
-	thread := p.data.GetThread(-1, POST_PASSES)
+	thread := p.data.GetThread(-1, POST_PASSES, 0.5)
 	version := thread.Version
 
 	slugOrId := GetSlugOrId(thread.Slug, int64(thread.ID))

tests/filler.go

@@ -27,10 +27,10 @@ func NewPerfConfig() *PerfConfig {
 	return &PerfConfig{
 		UserCount:   1000,
 		ForumCount:  20,
-		ThreadCount: 1000,
-		PostCount:   1000000,
+		ThreadCount: 10000,
+		PostCount:   2000000,
 		PostBatch:   100,
-		VoteCount:   25000,
+		VoteCount:   100000,
 		Validate:    1.0,
 	}
 }
@@ -115,9 +115,9 @@ func FillPosts(perf *Perf, parallel int, timeout time.Time, count int, batchSize
 		go func() {
 			f := NewFactory()
 			for atomic.AddInt32(&need, -int32(batchSize)) >= 0 {
-
+				offset := float64(int32(count)-atomic.LoadInt32(&need)) / float64(count)
 				batch := make([]*models.Post, 0, batchSize)
-				thread := data.GetThread(-1, 1)
+				thread := data.GetThread(-1, POST_PASSES, offset)
 				thread.mutex.Lock() // todo: Потом исправить
 
 				parents := data.GetThreadPostsFlat(thread)
@@ -169,7 +169,7 @@ func VoteThreads(perf *Perf, parallel int, timeout time.Time, count int) {
 			for atomic.AddInt32(&need, -1) >= 0 {
 				user := data.GetUser(-1)
 
-				thread := data.GetThread(-1, 1)
+				thread := data.GetThread(-1, 1, 0.5)
 				thread.mutex.Lock() // todo: Потом исправить
 
 				old_voice := thread.Voices[user]

tests/perf_data.go

@@ -201,12 +201,18 @@ func (self *PerfData) AddThread(thread *PThread) {
 	self.Status.Thread++
 }
 
-func (self *PerfData) GetThread(index int, passes int) *PThread {
+func (self *PerfData) GetThread(index int, passes int, offset float64) *PThread {
 	self.mutex.RLock()
 	defer self.mutex.RUnlock()
-
 	if index < 0 {
-		index = getRandomIndex(len(self.threads), passes)
+		length := len(self.threads)
+		delta := int((offset+0.5)*float64(length)) % length
+		if delta < 0 {
+			delta = length - delta
+		}
+
+		index = getRandomIndex(length, passes)
+		index = (index + delta) % length
 	}
 	return self.threads[index]
 }