remove journal write concern from broker

broker/src/asapo_broker/database/mongodb.go

@@ -3,11 +3,13 @@
 package database
 
 import (
+	"asapo_common/logger"
 	"asapo_common/utils"
 	"encoding/json"
 	"errors"
 	"github.com/globalsign/mgo"
 	"github.com/globalsign/mgo/bson"
+	"strconv"
 	"sync"
 	"time"
 )
@@ -80,7 +82,8 @@ func (db *Mongodb) Connect(address string) (err error) {
 	if err != nil {
 		return err
 	}
-	db.session.SetSafe(&mgo.Safe{J: true})
+
+	//	db.session.SetSafe(&mgo.Safe{J: true})
 
 	if err := db.updateDatabaseList(); err != nil {
 		return err
@@ -162,9 +165,13 @@ func (db *Mongodb) GetRecordByID(dbname string, id int) ([]byte, error) {
 			Id int `json:"id""`
 		}{id}
 		res, _ := json.Marshal(&r)
+		log_str := "error getting record id " + strconv.Itoa(id) + " for " + dbname + " : " + err.Error()
+		logger.Debug(log_str)
 		return nil, &DBError{utils.StatusNoData, string(res)}
 	}
 
+	log_str := "got record id " + strconv.Itoa(id) + " for " + dbname
+	logger.Debug(log_str)
 	return utils.MapToJson(&res)
 }
 
@@ -235,8 +242,12 @@ func (db *Mongodb) GetNextRecord(db_name string) ([]byte, error) {
 
 	curPointer, err := db.getCurrentPointer(db_name)
 	if err != nil {
+		log_str := "error getting next pointer for " + db_name + ":" + err.Error()
+		logger.Debug(log_str)
 		return nil, err
 	}
+	log_str := "got next pointer " + strconv.Itoa(curPointer.Value) + " for " + db_name
+	logger.Debug(log_str)
 	return db.GetRecordByID(db_name, curPointer.Value)
 
 }

tests/automatic/broker/check_mongo_restart/check_linux.sh

@@ -93,5 +93,6 @@ start_mongo
 wait
 
 cat output.txt
-cat output.txt | grep "Processed 1000 file(s)"
+nfiles=`cat output.txt | grep "Processed" | awk   '{print $2;}'`
+test  $nfiles -ge 1000
 rm output.txt
\ No newline at end of file