[VOL-3187]Pass Context down the execution call hierarchy across voltha-go codebase
Change-Id: I6bc2a0f7226c1beed4ae01a15d7b5c4dc04358d8
diff --git a/db/model/common.go b/db/model/common.go
index a501c52..3ee6e9e 100644
--- a/db/model/common.go
+++ b/db/model/common.go
@@ -21,12 +21,12 @@
"github.com/opencord/voltha-lib-go/v3/pkg/log"
)
-var logger log.Logger
+var logger log.CLogger
func init() {
// Setup this package so that it's log level can be modified at run time
var err error
- logger, err = log.AddPackage(log.JSON, log.ErrorLevel, log.Fields{"pkg": "model"})
+ logger, err = log.RegisterPackage(log.JSON, log.ErrorLevel, log.Fields{"pkg": "model"})
if err != nil {
panic(err)
}
diff --git a/db/model/proxy.go b/db/model/proxy.go
index cd35507..1f02544 100644
--- a/db/model/proxy.go
+++ b/db/model/proxy.go
@@ -68,7 +68,7 @@
// List will retrieve information from the data model at the proxy's path location, and write it to the target slice
// target must be a type of the form *[]<proto.Message Type> For example: *[]*voltha.Device
func (p *Proxy) List(ctx context.Context, target interface{}) error {
- logger.Debugw("proxy-list", log.Fields{
+ logger.Debugw(ctx, "proxy-list", log.Fields{
"path": p.path,
})
@@ -92,7 +92,7 @@
return fmt.Errorf("failed to retrieve %s from kvstore: %s", p.path, err)
}
- logger.Debugw("parsing-data-blobs", log.Fields{
+ logger.Debugw(ctx, "parsing-data-blobs", log.Fields{
"path": p.path,
"size": len(blobs),
})
@@ -115,7 +115,7 @@
func (p *Proxy) Get(ctx context.Context, id string, target proto.Message) (bool, error) {
completePath := p.path + id
- logger.Debugw("proxy-get", log.Fields{
+ logger.Debugw(ctx, "proxy-get", log.Fields{
"path": completePath,
})
@@ -126,7 +126,7 @@
return false, nil // this blob does not exist
}
- logger.Debugw("parsing-data-blobs", log.Fields{
+ logger.Debugw(ctx, "parsing-data-blobs", log.Fields{
"path": completePath,
})
@@ -140,7 +140,7 @@
func (p *Proxy) Set(ctx context.Context, id string, data proto.Message) error {
completePath := p.path + id
- logger.Debugw("proxy-add", log.Fields{
+ logger.Debugw(ctx, "proxy-add", log.Fields{
"path": completePath,
})
@@ -159,7 +159,7 @@
func (p *Proxy) Remove(ctx context.Context, id string) error {
completePath := p.path + id
- logger.Debugw("proxy-remove", log.Fields{
+ logger.Debugw(ctx, "proxy-remove", log.Fields{
"path": completePath,
})