From c756c799f5d4757e3a0974004750f1f3db62cecd Mon Sep 17 00:00:00 2001
From: Radu Ioan Fericean <radu@fericean.ro>
Date: Fri, 11 Oct 2013 23:15:55 +0300
Subject: [PATCH] some redis tests

---
 engine/destinations_test.go | 40 ++++++++++++++++++++++++++++++-------
 1 file changed, 33 insertions(+), 7 deletions(-)

diff --git a/engine/destinations_test.go b/engine/destinations_test.go
index 1106b10a5..70f5cc2ef 100644
--- a/engine/destinations_test.go
+++ b/engine/destinations_test.go
@@ -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) {