Skip to content

Commit 19c0eb0

Browse files
committed
Handled logs related review comments
1 parent c65cc4a commit 19c0eb0

File tree

3 files changed

+11
-63
lines changed

3 files changed

+11
-63
lines changed

models/yang/annotations/openconfig-interfaces-annot.yang

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -109,18 +109,6 @@ module openconfig-interfaces-annot {
109109
}
110110
}
111111

112-
deviation /oc-intf:interfaces/oc-intf:interface/oc-intf:config/oc-intf:name {
113-
deviate add {
114-
sonic-ext:field-transformer "intf_name_xfmr";
115-
}
116-
}
117-
118-
deviation /oc-intf:interfaces/oc-intf:interface/oc-intf:state/oc-intf:name {
119-
deviate add {
120-
sonic-ext:field-transformer "intf_name_xfmr";
121-
}
122-
}
123-
124112
deviation /oc-intf:interfaces/oc-intf:interface/oc-intf:config/oc-intf:mtu {
125113
deviate add {
126114
sonic-ext:field-transformer "intf_mtu_xfmr";

translib/transformer/sw_portchannel.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -242,8 +242,8 @@ var YangToDb_lag_min_links_xfmr FieldXfmrYangToDb = func(inParams XfmrParams) (m
242242
intfType, _, err := getIntfTypeByName(ifKey)
243243
if intfType != IntfTypePortChannel || err != nil {
244244
errStr := "Invalid interface type: " + ifKey
245-
log.Warning(errStr)
246-
return res_map, errors.New(errStr)
245+
err = tlerr.InvalidArgsError{Format: errStr}
246+
return res_map, err
247247
}
248248

249249
minLinks, _ := inParams.param.(*uint16)

translib/transformer/xfmr_intf.go

Lines changed: 9 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,6 @@ func init() {
4343
XlateFuncBind("DbToYang_intf_tbl_key_xfmr", DbToYang_intf_tbl_key_xfmr)
4444
XlateFuncBind("YangToDb_intf_mtu_xfmr", YangToDb_intf_mtu_xfmr)
4545
XlateFuncBind("DbToYang_intf_mtu_xfmr", DbToYang_intf_mtu_xfmr)
46-
XlateFuncBind("YangToDb_intf_name_xfmr", YangToDb_intf_name_xfmr)
47-
XlateFuncBind("DbToYang_intf_name_xfmr", DbToYang_intf_name_xfmr)
4846
XlateFuncBind("DbToYang_intf_admin_status_xfmr", DbToYang_intf_admin_status_xfmr)
4947
XlateFuncBind("YangToDb_intf_enabled_xfmr", YangToDb_intf_enabled_xfmr)
5048
XlateFuncBind("DbToYang_intf_enabled_xfmr", DbToYang_intf_enabled_xfmr)
@@ -426,7 +424,7 @@ var intf_table_xfmr TableXfmrFunc = func(inParams XfmrParams) ([]string, error)
426424
} else if intfType != IntfTypeEthernet &&
427425
strings.HasPrefix(targetUriPath, "/openconfig-interfaces:interfaces/interface/openconfig-if-ethernet:ethernet") {
428426
//Checking interface type at container level, if not Ethernet type return nil
429-
return nil, errors.New("Container not supported for given interface type")
427+
return nil, tlerr.InvalidArgs("Container not supported for given interface type")
430428
} else if intfType != IntfTypePortChannel &&
431429
strings.HasPrefix(targetUriPath, "/openconfig-interfaces:interfaces/interface/openconfig-if-aggregate:aggregation") {
432430
//Checking interface type at container level, if not PortChannel type return nil
@@ -839,8 +837,8 @@ var YangToDb_intf_eth_port_config_xfmr SubTreeXfmrYangToDb = func(inParams XfmrP
839837

840838
prevLagId, err := retrievePortChannelAssociatedWithIntf(&inParams, &ifName)
841839
if prevLagId != nil && *prevLagId != *lagId && inParams.oper != REPLACE {
842-
log.Errorf("%s Interface is already member of %s", ifName, *prevLagId)
843-
return nil, errors.New(ifName + " Interface is already member of " + *prevLagId)
840+
errStr := ifName + " Interface is already member of " + *prevLagId
841+
return nil, tlerr.InvalidArgsError{Format: errStr}
844842
}
845843

846844
case DELETE:
@@ -1089,7 +1087,6 @@ var DbToYangPath_intf_eth_port_config_path_xfmr PathXfmrDbToYangFunc = func(para
10891087
}
10901088

10911089
var DbToYang_intf_eth_auto_neg_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams) (map[string]interface{}, error) {
1092-
var err error
10931090
result := make(map[string]interface{})
10941091

10951092
intfType, _, ierr := getIntfTypeByName(inParams.key)
@@ -1109,8 +1106,8 @@ var DbToYang_intf_eth_auto_neg_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams
11091106

11101107
prtInst, tblErr := d.GetEntry(&pTbl, db.Key{Comp: []string{inParams.key}})
11111108
if tblErr != nil {
1112-
log.Info("DbToYang_intf_eth_auto_neg_xfmr key not found : ", inParams.key)
1113-
return result, errors.New("Interface not found : " + inParams.key)
1109+
errStr := "Interface not found : " + inParams.key
1110+
return result, tlerr.InvalidArgsError{Format: errStr}
11141111
}
11151112

11161113
autoNeg, ok := prtInst.Field[PORT_AUTONEG]
@@ -1123,7 +1120,7 @@ var DbToYang_intf_eth_auto_neg_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams
11231120
} else {
11241121
log.Info("auto-negotiate field not found in DB")
11251122
}
1126-
return result, err
1123+
return result, nil
11271124
}
11281125

11291126
var DbToYang_intf_eth_port_speed_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams) (map[string]interface{}, error) {
@@ -3220,19 +3217,17 @@ var YangToDb_intf_type_xfmr FieldXfmrYangToDb = func(inParams XfmrParams) (map[s
32203217
ifName := pathInfo.Var("name")
32213218
intfType, _, err := getIntfTypeByName(ifName)
32223219
if intfType == IntfTypeUnset || err != nil {
3223-
log.Info("DbToYang_intf_type_xfmr - Invalid interface type IntfTypeUnset")
3224-
return res_map, errors.New("Invalid interface type IntfTypeUnset")
3220+
return res_map, errors.New("Invalid interface type")
32253221
}
32263222

3227-
err = errors.New("Invalid interface type received")
32283223
interfaceType, ok := inParams.param.(ocbinds.E_IETFInterfaces_InterfaceType)
32293224
if !ok {
3230-
return nil, err
3225+
return nil, errors.New("Unsupported interface type")
32313226
}
32323227

32333228
if (intfType == IntfTypeEthernet && interfaceType != ocbinds.IETFInterfaces_InterfaceType_ethernetCsmacd) ||
32343229
(intfType == IntfTypePortChannel && interfaceType != ocbinds.IETFInterfaces_InterfaceType_ieee8023adLag) {
3235-
return res_map, err
3230+
return res_map, errors.New("Unsupported interface type")
32363231
}
32373232

32383233
return res_map, nil
@@ -3500,38 +3495,3 @@ var DbToYang_intf_cpu_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams) (map[st
35003495
result["cpu"] = false
35013496
return result, nil
35023497
}
3503-
3504-
var YangToDb_intf_name_xfmr FieldXfmrYangToDb = func(inParams XfmrParams) (map[string]string, error) {
3505-
res_map := make(map[string]string)
3506-
3507-
pathInfo := NewPathInfo(inParams.uri)
3508-
ifName := pathInfo.Var("name")
3509-
intfType, _, err := getIntfTypeByName(ifName)
3510-
if intfType == IntfTypeUnset || err != nil {
3511-
log.Info("DbToYang_intf_name_xfmr - Invalid interface type IntfTypeUnset")
3512-
return res_map, errors.New("Invalid interface type IntfTypeUnset")
3513-
}
3514-
3515-
err = errors.New("Invalid interface config/name received")
3516-
configName, ok := inParams.param.(*string)
3517-
if !ok || ifName != *configName {
3518-
return nil, err
3519-
}
3520-
3521-
res_map["NULL"] = "NULL"
3522-
return res_map, nil
3523-
}
3524-
3525-
var DbToYang_intf_name_xfmr FieldXfmrDbtoYang = func(inParams XfmrParams) (map[string]interface{}, error) {
3526-
var err error
3527-
result := make(map[string]interface{})
3528-
3529-
intfType, _, err := getIntfTypeByName(inParams.key)
3530-
if intfType == IntfTypeUnset || err != nil {
3531-
log.Info("DbToYang_intf_name_xfmr - Invalid interface type IntfTypeUnset")
3532-
return result, errors.New("Invalid interface type IntfTypeUnset")
3533-
}
3534-
3535-
result["name"] = inParams.key
3536-
return result, nil
3537-
}

0 commit comments

Comments
 (0)