Commit 0ff22c41 authored by Vikram Ingawale's avatar Vikram Ingawale
Browse files

Revert "Merge branch 'vi_statemdlFixes' into 'devbranch'"

This reverts merge request !236
parent 3cd5ab1b
Branches
Tags
2 merge requests!239release v1.2.3,!237Revert : Panic issue re-generated with statemdl latest change.
Showing with 3 additions and 7 deletions
...@@ -95,7 +95,6 @@ var groupMutex = &sync.Mutex{} ...@@ -95,7 +95,6 @@ var groupMutex = &sync.Mutex{}
var serverStartTime time.Time var serverStartTime time.Time
var clientResponseData clientResponse var clientResponseData clientResponse
var globalClientResponseData clientResponse
var initStatus = false var initStatus = false
...@@ -416,6 +415,7 @@ func collectStatistics() { ...@@ -416,6 +415,7 @@ func collectStatistics() {
// The following lock guards these two underlying data structures. // The following lock guards these two underlying data structures.
stateMutex.Lock() stateMutex.Lock()
defer stateMutex.Unlock() defer stateMutex.Unlock()
ba, marshalError := ffjson.Marshal(clientResponseData) ba, marshalError := ffjson.Marshal(clientResponseData)
if errormdl.CheckErr(marshalError) != nil { if errormdl.CheckErr(marshalError) != nil {
loggermdl.LogError(marshalError) loggermdl.LogError(marshalError)
......
...@@ -13,10 +13,8 @@ import ( ...@@ -13,10 +13,8 @@ import (
func StateHandler(c *routing.Context) error { func StateHandler(c *routing.Context) error {
clientReponseMutex.Lock() clientReponseMutex.Lock()
defer clientReponseMutex.Unlock() defer clientReponseMutex.Unlock()
// copy `clientResponseData` into `globalClientResponseData` variable bocs we are facing concurrent read/write issue with `clientResponseData`.
globalClientResponseData = clientResponseData
c.Response.Header.Set("Access-Control-Allow-Origin", "*") c.Response.Header.Set("Access-Control-Allow-Origin", "*")
ba, err := json.Marshal(globalClientResponseData) ba, err := json.Marshal(clientResponseData)
if err != nil { if err != nil {
loggermdl.LogError("Failed to marshall statitics - ", err) loggermdl.LogError("Failed to marshall statitics - ", err)
c.SetStatusCode(417) c.SetStatusCode(417)
......
...@@ -10,8 +10,6 @@ import ( ...@@ -10,8 +10,6 @@ import (
func StateHandler(c *gin.Context) { func StateHandler(c *gin.Context) {
clientReponseMutex.Lock() clientReponseMutex.Lock()
defer clientReponseMutex.Unlock() defer clientReponseMutex.Unlock()
// copy `clientResponseData` into `globalClientResponseData` variable bocs we are facing concurrent read/write issue with `clientResponseData`.
globalClientResponseData = clientResponseData
c.Header("Access-Control-Allow-Origin", "*") c.Header("Access-Control-Allow-Origin", "*")
c.JSON(200, globalClientResponseData) c.JSON(200, clientResponseData)
} }
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment