- if err := ep.Socket.(NngSocket).Send([]byte(pe)); err != nil {
- rtmgr.Logger.Error("Unable to send policy entry due to: " + err.Error())
+ b := []byte(pe)
+ for j := 0; j < len(b); j++ {
+ policy = append(policy, b[j])
+ }
+ count++
+ cumulative_policy++
+ if count == maxrecord || cumulative_policy == len(*policies) {
+ params := &RMRParams{&xapp.RMRParams{}}
+ params.Mtype = 20
+ params.PayloadLen = len(policy)
+ params.Payload = []byte(policy)
+ params.Mbuf = nil
+ params.Whid = ep.Whid
+ xapp.Rmr.SendMsg(params.RMRParams)
+ count = 0
+ policy = nil
+ xapp.Logger.Debug("Sent message with payload len = %d to %s", params.PayloadLen, ep.Uuid)