uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-14 20:59:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

some redis tests

Browse Source
This commit is contained in:
Radu Ioan Fericean
2013-10-11 23:15:55 +03:00
parent 824302a8f5
commit c756c799f5
1 changed files with 33 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
engine/destinations_test.go
View File

@@ -20,8 +20,10 @@ package engine
import (
"encoding/json"
"fmt"
"github.com/cgrates/cgrates/cache2go"
"github.com/cgrates/cgrates/utils"
"reflect"
"testing"
)
@@ -101,21 +103,21 @@ func TestDestinationGetNotExistsCache(t *testing.T) {
}
}
/*func TestConcurrentDestReadWrite(t *testing.T) {
/*
func TestConcurrentDestReadWrite(t *testing.T) {
dst1 := &Destination{Id: "TST_1", Prefixes: []string{"1"}}
err := storageGetter.SetDestination(dst1)
if err != nil {
t.Error("Error setting destination: ", err)
}
rec := 500
go func() {
for i := 0; i < 10; i++ {
if err := storageGetter.SetDestination(&Destination{Id: fmt.Sprintf("TST_%d", i), Prefixes: []string{"1"}}); err != nil {
t.Error("Error setting destinations: ", err)
}
for i := 0; i < rec; i++ {
storageGetter.SetDestination(&Destination{Id: fmt.Sprintf("TST_%d", i), Prefixes: []string{"1"}})
}
}()
for i := 0; i < 10; i++ {
for i := 0; i < rec; i++ {
dst2, err := storageGetter.GetDestination(dst1.Id)
if err != nil {
t.Error("Error retrieving destination: ", err)
@@ -124,8 +126,32 @@ func TestDestinationGetNotExistsCache(t *testing.T) {
t.Error("Cannot retrieve properly the destination 1", dst1, dst2)
}
}
}*/
}
func TestNonConcurrentDestReadWrite(t *testing.T) {
dst1 := &Destination{Id: "TST_1", Prefixes: []string{"1"}}
err := storageGetter.SetDestination(dst1)
if err != nil {
t.Error("Error setting destination: ", err)
}
rec := 10000
//go func(){
for i := 0; i < rec; i++ {
storageGetter.SetDestination(&Destination{Id: fmt.Sprintf("TST_%d", i), Prefixes: []string{"1"}})
}
//}()
for i := 0; i < rec; i++ {
dst2, err := storageGetter.GetDestination(dst1.Id)
if err != nil {
t.Error("Error retrieving destination: ", err)
}
if !reflect.DeepEqual(dst1, dst2) {
t.Error("Cannot retrieve properly the destination 1", dst1, dst2)
}
}
}
*/
/********************************* Benchmarks **********************************/
func BenchmarkDestinationStorageStoreRestore(b *testing.B) {