diff options
| author | wbc6080 <wangbincheng4@huawei.com> | 2023-12-20 10:33:23 +0800 |
|---|---|---|
| committer | wbc6080 <wangbincheng4@huawei.com> | 2023-12-29 10:14:16 +0800 |
| commit | 51c6081cf9e303060b974d5e17dc835fee77830a (patch) | |
| tree | 193fc277013c775b827bad47598543f150fdd843 /edge | |
| parent | Merge pull request #5299 from Shelley-BaoYue/remove-runtimetype (diff) | |
| download | kubeedge-51c6081cf9e303060b974d5e17dc835fee77830a.tar.gz | |
support configuring dmisock path in edgecore
Signed-off-by: wbc6080 <wangbincheng4@huawei.com>
Diffstat (limited to 'edge')
| -rw-r--r-- | edge/pkg/devicetwin/dmiserver/server.go | 11 | ||||
| -rw-r--r-- | edge/test/integration/utils/test_setup.go | 1 |
2 files changed, 10 insertions, 2 deletions
diff --git a/edge/pkg/devicetwin/dmiserver/server.go b/edge/pkg/devicetwin/dmiserver/server.go index d4818f999..eed5bee91 100644 --- a/edge/pkg/devicetwin/dmiserver/server.go +++ b/edge/pkg/devicetwin/dmiserver/server.go @@ -37,6 +37,7 @@ import ( "github.com/kubeedge/kubeedge/common/constants" messagepkg "github.com/kubeedge/kubeedge/edge/pkg/common/message" "github.com/kubeedge/kubeedge/edge/pkg/common/modules" + deviceconfig "github.com/kubeedge/kubeedge/edge/pkg/devicetwin/config" "github.com/kubeedge/kubeedge/edge/pkg/devicetwin/dmiclient" "github.com/kubeedge/kubeedge/edge/pkg/devicetwin/dtcommon" "github.com/kubeedge/kubeedge/edge/pkg/metamanager/dao" @@ -168,13 +169,19 @@ func CreateMessageTwinUpdate(twin *pb.Twin) ([]byte, error) { } func StartDMIServer(cache *DMICache) { - err := initSock(SockPath) + var DMISockPath string + if deviceconfig.Get().DeviceTwin.DMISockPath != "" { + DMISockPath = deviceconfig.Get().DeviceTwin.DMISockPath + } else { + DMISockPath = SockPath + } + err := initSock(DMISockPath) if err != nil { klog.Fatalf("failed to remove uds socket with err: %v", err) return } - lis, err := net.Listen(deviceconst.UnixNetworkType, SockPath) + lis, err := net.Listen(deviceconst.UnixNetworkType, DMISockPath) if err != nil { klog.Errorf("failed to start DMI Server with err: %v", err) return diff --git a/edge/test/integration/utils/test_setup.go b/edge/test/integration/utils/test_setup.go index 8890362f0..1d89ec713 100644 --- a/edge/test/integration/utils/test_setup.go +++ b/edge/test/integration/utils/test_setup.go @@ -40,6 +40,7 @@ func CreateEdgeCoreConfigFile(nodeName string) error { c.Modules.EdgeHub.TLSCAFile = "/tmp/edgecore/rootCA.crt" c.Modules.EdgeHub.TLSCertFile = "/tmp/edgecore/kubeedge.crt" c.Modules.EdgeHub.TLSPrivateKeyFile = "/tmp/edgecore/kubeedge.key" + c.Modules.DeviceTwin.DMISockPath = "/etc/kubeedge/dmi.sock" c.Modules.EventBus.Enable = true c.Modules.EventBus.MqttMode = edgecore.MqttModeInternal c.Modules.DBTest.Enable = true |