From 9d264930679c4e941308e1444ca2fe1679943111 Mon Sep 17 00:00:00 2001
From: Radu Ioan Fericean <radu@fericean.ro>
Date: Mon, 21 Dec 2015 23:40:56 +0200
Subject: [PATCH] parallel stress addaccount tool

---
 cmd/cgr-tester/parallel/parallel.go | 44 +++++++++++++++++++++++++++++
 1 file changed, 44 insertions(+)
 create mode 100644 cmd/cgr-tester/parallel/parallel.go

diff --git a/cmd/cgr-tester/parallel/parallel.go b/cmd/cgr-tester/parallel/parallel.go
new file mode 100644
index 000000000..b249dec36
--- /dev/null
+++ b/cmd/cgr-tester/parallel/parallel.go
@@ -0,0 +1,44 @@
+package main
+
+import (
+	"bytes"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"sync"
+)
+
+func main() {
+	log.Print("Start!")
+	var wg sync.WaitGroup
+	for i := 1; i < 1002; i++ {
+		go func(index int) {
+			wg.Add(1)
+			resp, err := http.Post("http://localhost:2080/jsonrpc", "application/json", bytes.NewBuffer([]byte(fmt.Sprintf(`{"method": "ApierV1.SetAccount","params": [{"Tenant":"reglo","Account":"100%d","ActionPlanId":"PACKAGE_NEW_FOR795", "ReloadScheduler":false}], "id":%d}`, index, index))))
+			if err != nil {
+				log.Print("Post error: ", err)
+			}
+			contents, err := ioutil.ReadAll(resp.Body)
+			if err != nil {
+				log.Print("Body error: ", err)
+			}
+			log.Printf("SetAccount(%d): %s", index, string(contents))
+			wg.Done()
+		}(i)
+	}
+	wg.Wait()
+	for index := 1; index < 1002; index++ {
+		resp, err := http.Post("http://localhost:2080/jsonrpc", "application/json", bytes.NewBuffer([]byte(fmt.Sprintf(`{"method": "ApierV1.GetAccountActionPlan","params": [{"Tenant":"reglo","Account":"100%d"}], "id":%d}`, index, index))))
+		if err != nil {
+			log.Print("Post error: ", err)
+		}
+		contents, err := ioutil.ReadAll(resp.Body)
+		if err != nil {
+			log.Print("Body error: ", err)
+		}
+		log.Printf("GetAccountActionPlan(%d): %s", index, string(contents))
+	}
+
+	log.Print("Done!")
+}