package xapp
import (
+ "fmt"
mdclog "gerrit.o-ran-sc.org/r/com/golog"
"time"
)
}
func (l *Log) Error(pattern string, args ...interface{}) {
- l.SetMdc("time", time.Now().Format("2019-01-02 15:04:05"))
+ l.SetMdc("time", timeFormat())
l.logger.Error(pattern, args...)
}
func (l *Log) Warn(pattern string, args ...interface{}) {
- l.SetMdc("time", time.Now().Format("2019-01-02 15:04:05"))
+ l.SetMdc("time", timeFormat())
l.logger.Warning(pattern, args...)
}
func (l *Log) Info(pattern string, args ...interface{}) {
- l.SetMdc("time", time.Now().Format("2019-01-02 15:04:05"))
+ l.SetMdc("time", timeFormat())
l.logger.Info(pattern, args...)
}
func (l *Log) Debug(pattern string, args ...interface{}) {
- l.SetMdc("time", time.Now().Format("2019-01-02 15:04:05"))
+ l.SetMdc("time", timeFormat())
l.logger.Debug(pattern, args...)
}
+
+func timeFormat() string {
+ t := time.Now()
+ return fmt.Sprintf("%d-%02d-%02dT%02d:%02d:%02d", t.Year(), t.Month(), t.Day(), t.Hour(), t.Minute(), t.Second())
+}
params.Src = strings.TrimRight(string(srcBuf[0:64]), "\000")
}
+ // Default case: a single consumer
+ if len(m.consumers) == 1 && m.consumers[0] != nil {
+ params.PayloadLen = int(rxBuffer.len)
+ params.Payload = (*[1 << 30]byte)(unsafe.Pointer(rxBuffer.payload))[:params.PayloadLen:params.PayloadLen]
+ err := m.consumers[0].Consume(params)
+ if err != nil {
+ Logger.Warn("rmrClient: Consumer returned error: %v", err)
+ }
+ return
+ }
+
+ // Special case for multiple consumers
for _, c := range m.consumers {
cptr := unsafe.Pointer(rxBuffer.payload)
params.Payload = C.GoBytes(cptr, C.int(rxBuffer.len))
params.PayloadLen = int(rxBuffer.len)
+ params.Mtype = int(rxBuffer.mtype)
+ params.SubId = int(rxBuffer.sub_id)
err := c.Consume(params)
if err != nil {