uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-17 22:29:55 +05:00
Code Issues Packages Projects Releases Wiki Activity

even better parallel stres testing

Browse Source
This commit is contained in:
Radu Ioan Fericean
2012-08-06 14:24:27 +03:00
parent d41c9d562a
commit 24b5b759b2
2 changed files with 23 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
cmd/stress/cgr-raterstress/cgr-raterstress.go
View File

@@ -25,18 +25,21 @@ import (
"net/rpc"
//"net/rpc/jsonrpc"
"net/rpc/jsonrpc"
"runtime"
"time"
)
var (
balancer = flag.String("balancer", "localhost:2001", "balancer server address")
runs = flag.Int("runs", 10000, "stress cycle number")
parallel = flag.Bool("parallel", false, "run requests in parallel")
parallel = flag.Int("parallel", 0, "run n requests in parallel")
json = flag.Bool("json", false, "use JSON for RPC encoding")
)
func main() {
flag.Parse()
runtime.GOMAXPROCS(runtime.NumCPU())
t1 := time.Date(2012, time.February, 02, 17, 30, 0, 0, time.UTC)
t2 := time.Date(2012, time.February, 02, 18, 30, 0, 0, time.UTC)
cd := timespans.CallDescriptor{Direction: "OUT", TOR: "0", Tenant: "vdf", Subject: "rif", Destination: "0256", TimeStart: t1, TimeEnd: t2}
@@ -44,20 +47,31 @@ func main() {
var client *rpc.Client
var err error
if *json {
client, err = jsonrpc.Dial("tcp", "localhost:1234")
client, err = jsonrpc.Dial("tcp", *balancer)
} else {
client, err = rpc.Dial("tcp", "localhost:1234")
client, err = rpc.Dial("tcp", *balancer)
}
if err != nil {
log.Panic("Could not connect to rater: ", err)
log.Fatal("Could not connect to rater: ", err)
}
start := time.Now()
if *parallel {
var divCall *rpc.Call
if *parallel > 0 {
// var divCall *rpc.Call
var sem = make(chan int, *parallel)
var finish = make(chan int)
for i := 0; i < *runs; i++ {
divCall = client.Go("Responder.GetCost", cd, &result, nil)
go func() {
sem <- 1
client.Call("Responder.GetCost", cd, &result)
<-sem
finish <- 1
// divCall = client.Go("Responder.GetCost", cd, &result, nil)
}()
}
<-divCall.Done
for i := 0; i < *runs; i++ {
<-finish
}
// <-divCall.Done
} else {
for j := 0; j < *runs; j++ {
client.Call("Responder.GetCost", cd, &result)

2
timespans/accountlock_test.go
View File

@@ -24,7 +24,7 @@ import (
"log"
)
func ATestAccountLock(t *testing.T) {
func ATestAccountLock(t *testing.T) {
go AccLock.Guard("1", func() (float64, error) {
log.Print("first 1")
time.Sleep(1 * time.Second)