- params := &RMRParams{&xapp.RMRParams{}}
- params.Mtype = 20
- params.PayloadLen = len([]byte(pe))
- params.Payload =[]byte(pe)
- params.Mbuf = nil
- params.Whid = ep.Whid
- time.Sleep(1 * time.Millisecond)
- xapp.Rmr.SendMsg(params.RMRParams)
+ 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)
+ }