Moving RMR message reciver into go routine and some typo error
Signed-off-by: naman.gupta <naman.gupta@samsung.com>
Change-Id: I2841b57a9932813366de26318d48d07df7776b3d
a1.Logger.Error("policy type Not Present for policyid : %v", policyTypeId)
return policyTypeNotFoundError
}
a1.Logger.Error("policy type Not Present for policyid : %v", policyTypeId)
return policyTypeNotFoundError
}
}
func (rh *Resthook) instanceValidity(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) error {
}
func (rh *Resthook) instanceValidity(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) error {
a1.Logger.Debug("policy instance Not Present ")
return policyInstanceNotFoundError
}
a1.Logger.Debug("policy instance Not Present ")
return policyInstanceNotFoundError
}
}
func (rh *Resthook) getMetaData(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) (map[string]interface{}, error) {
}
func (rh *Resthook) getMetaData(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) (map[string]interface{}, error) {
func (rh *Resthook) GetPolicyInstanceStatus(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) (*a1_mediator.A1ControllerGetPolicyInstanceStatusOKBody, error) {
err := rh.instanceValidity(policyTypeId, policyInstanceID)
func (rh *Resthook) GetPolicyInstanceStatus(policyTypeId models.PolicyTypeID, policyInstanceID models.PolicyInstanceID) (*a1_mediator.A1ControllerGetPolicyInstanceStatusOKBody, error) {
err := rh.instanceValidity(policyTypeId, policyInstanceID)
+ policyInstanceStatus := a1_mediator.A1ControllerGetPolicyInstanceStatusOKBody{}
if err != nil && err == policyInstanceNotFoundError || err == policyTypeNotFoundError {
policyInstanceStatus.InstanceStatus = "NOT IN EFFECT"
return &policyInstanceStatus, err
}
if err != nil && err == policyInstanceNotFoundError || err == policyTypeNotFoundError {
policyInstanceStatus.InstanceStatus = "NOT IN EFFECT"
return &policyInstanceStatus, err
}
- policyInstanceStatus := a1_mediator.A1ControllerGetPolicyInstanceStatusOKBody{}
metadata, err := rh.getMetaData(policyTypeId, policyInstanceID)
a1.Logger.Debug(" metadata %v", metadata)
if err != nil {
metadata, err := rh.getMetaData(policyTypeId, policyInstanceID)
a1.Logger.Debug(" metadata %v", metadata)
if err != nil {
keys[0] = instancekey
sdlInst.On("Get", a1MediatorNs, keys[:]).Return(httpBody)
keys[0] = instancekey
sdlInst.On("Get", a1MediatorNs, keys[:]).Return(httpBody)
- resp := rh.GetPolicyInstanceStatus(policyTypeId, policyInstanceID)
+ resp, errresp := rh.GetPolicyInstanceStatus(policyTypeId, policyInstanceID)
assert.NotNil(t, resp)
sdlInst.AssertExpectations(t)
}
assert.NotNil(t, resp)
sdlInst.AssertExpectations(t)
}
func (rmr *RmrSender) RmrRecieveStart() {
a1.Logger.Debug("Inside RmrRecieveStart function ")
func (rmr *RmrSender) RmrRecieveStart() {
a1.Logger.Debug("Inside RmrRecieveStart function ")
- rmr.rmrclient.Start(rmr)
+ go rmr.rmrclient.Start(rmr)
a1.Logger.Debug("Reciever started")
}
a1.Logger.Debug("Reciever started")
}