1 /*
2  * Copyright (c) 2021 Huawei Device Co., Ltd.
3  * Licensed under the Apache License, Version 2.0 (the "License");
4  * you may not use this file except in compliance with the License.
5  * You may obtain a copy of the License at
6  *
7  * http://www.apache.org/licenses/LICENSE-2.0
8  *
9  * Unless required by applicable law or agreed to in writing, software
10  * distributed under the License is distributed on an "AS IS" BASIS,
11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  * See the License for the specific language governing permissions and
13  * limitations under the License.
14  */
15 #include <gtest/gtest.h>
16 
17 #include "init_param.h"
18 #include "param_base.h"
19 #include "param_message.h"
20 #include "param_stub.h"
21 #include "param_init.h"
22 #include "trigger_manager.h"
23 #include "param_utils.h"
24 #include "param_osadp.h"
25 #include "param_manager.h"
26 #include "sys_param.h"
27 
28 using namespace testing::ext;
29 using namespace std;
30 
31 extern "C" {
32 void ParamWorBaseLog(InitLogLevel logLevel, uint32_t domain, const char *tag, const char *fmt, ...);
OnClose(const TaskHandle taskHandle)33 static void OnClose(const TaskHandle taskHandle)
34 {
35 }
36 }
37 
CheckServerParamValue(const char * name,const char * expectValue)38 static int CheckServerParamValue(const char *name, const char *expectValue)
39 {
40     char tmp[PARAM_BUFFER_SIZE] = {0};
41     u_int32_t len = sizeof(tmp);
42     SystemReadParam(name, tmp, &len);
43     printf("CheckParamValue name %s value: \'%s\' expectValue:\'%s\' \n", name, tmp, expectValue);
44     EXPECT_GE((int)strlen(tmp), 0);
45     if (expectValue != nullptr) {
46         EXPECT_EQ(strcmp(tmp, expectValue), 0);
47     }
48     return 0;
49 }
50 
51 namespace init_ut {
52 class ParamUnitTest : public ::testing::Test {
53 public:
ParamUnitTest()54     ParamUnitTest() {}
~ParamUnitTest()55     virtual ~ParamUnitTest() {}
56 
SetUpTestCase(void)57     static void SetUpTestCase(void) {}
SetUp()58     void SetUp() {}
TearDown()59     void TearDown() {}
TestBody()60     void TestBody() {}
61 
TestSetParams(const char * params[][1+1],int num)62     int TestSetParams(const char *params[][1 + 1], int num)
63     {
64         for (int i = 0; i < num; i++) {
65             SystemWriteParam(params[i][0], params[i][1]);
66         }
67 
68         // check
69         for (int i = 0; i < num; i++) {
70             CheckServerParamValue(params[i][0], params[i][1]);
71         }
72 
73         for (int i = num - 1; i >= 0; i--) {
74             CheckServerParamValue(params[i][0], params[i][1]);
75         }
76         return 0;
77     }
78 
TestAddSecurityLabel1()79     int TestAddSecurityLabel1()
80     {
81         GetParamSecurityLabel()->cred.gid = 9999;  // 9999 test gid
82         const char *name = "label1.test.aaa.bbb.ccc.dddd.eee";
83         const char *value = "2001";
84         uint32_t labelIndex = 0;
85         SystemWriteParam(name, value);
86         // get root
87         WorkSpace *workspace = GetWorkSpace(WORKSPACE_INDEX_DAC);
88         (void)FindTrieNode(workspace, name, strlen(name), &labelIndex);
89         ParamSecurityNode *node = (ParamSecurityNode *)GetTrieNode(workspace, labelIndex);
90         if (node == nullptr) {
91             EXPECT_EQ(1, 0);
92             return 0;
93         }
94         EXPECT_EQ(node->gid, DAC_DEFAULT_GROUP);
95         return 0;
96     }
97 
98     // 添加一个label,最长匹配到这个节点
TestAddSecurityLabel2()99     int TestAddSecurityLabel2()
100     {
101         GetParamSecurityLabel()->cred.gid = 9999;  // 9999 test gid
102         const char *name = "label2.test.aaa.bbb.ccc.dddd.eee";
103         const char *value = "2001";
104         ParamAuditData auditData = {};
105         auditData.name = "label2.test.aaa";
106         auditData.dacData.gid = 202;  // 202 test dac gid
107         auditData.dacData.uid = geteuid();
108         auditData.dacData.mode = 0666;  // 0666 test mode
109         SystemWriteParam(name, value);
110         uint32_t labelIndex = 0;
111         AddSecurityLabel(&auditData);
112         WorkSpace *workspace = GetWorkSpace(WORKSPACE_INDEX_DAC);
113         (void)FindTrieNode(workspace, name, strlen(name), &labelIndex);
114         ParamSecurityNode *node = (ParamSecurityNode *)GetTrieNode(workspace, labelIndex);
115         if (node == nullptr) {
116             EXPECT_EQ(1, 0);
117             return 0;
118         }
119         EXPECT_EQ(node->gid, auditData.dacData.gid);
120         return 0;
121     }
122 
123     // 添加一个label,最长匹配到最后一个相同节点
TestAddSecurityLabel3()124     int TestAddSecurityLabel3()
125     {
126         GetParamSecurityLabel()->cred.gid = 9999;  // 9999 test gid
127         const char *name = "label3.test.aaa.bbb.ccc.dddd.eee";
128         const char *value = "2001";
129         ParamAuditData auditData = {};
130         auditData.name = "label3.test.aaa";
131         auditData.dacData.gid = 203;  // 203 test gid
132         auditData.dacData.uid = geteuid();
133         auditData.dacData.mode = 0666;  // 0666 test mode
134         SystemWriteParam(name, value);
135         AddSecurityLabel(&auditData);
136 
137         auditData.name = "label3.test.aaa.bbb.ccc.dddd.eee.dddd";
138         auditData.dacData.gid = 202;  // 202 test dac gid
139         auditData.dacData.uid = geteuid();
140         auditData.dacData.mode = 0666;  // 0666 test mode
141         SystemWriteParam(name, value);
142         AddSecurityLabel(&auditData);
143 
144         uint32_t labelIndex = 0;
145         WorkSpace *workspace = GetWorkSpace(WORKSPACE_INDEX_DAC);
146         ParamTrieNode *paramNode = FindTrieNode(workspace, name, strlen(name), &labelIndex);
147         ParamSecurityNode *node = (ParamSecurityNode *)GetTrieNode(workspace, labelIndex);
148         if (paramNode == nullptr || node == nullptr) {
149             EXPECT_EQ(1, 0);
150             return 0;
151         }
152         EXPECT_EQ((int)node->gid, 203);  // 203 test gid
153         return 0;
154     }
155 
156     // 添加一个label,完全匹配
TestAddSecurityLabel4()157     int TestAddSecurityLabel4()
158     {
159 #if !(defined __LITEOS_A__ || defined __LITEOS_M__)
160         ResetParamSecurityLabel();
161 #endif
162         GetParamSecurityLabel()->cred.gid = 9999;  // 9999 test gid
163         const char *name = "label4.test.aaa.bbb.ccc.dddd.eee";
164         const char *value = "2001";
165         ParamAuditData auditData = {};
166         auditData.name = "label4.test.aaa.bbb.ccc.dddd.eee";
167         auditData.dacData.gid = 203;  // 203 test gid
168         auditData.dacData.uid = geteuid();
169         auditData.dacData.mode = 0666;  // 0666 test mode
170         SystemWriteParam(name, value);
171         uint32_t labelIndex = 0;
172         AddSecurityLabel(&auditData);
173         WorkSpace *workspace = GetWorkSpace(WORKSPACE_INDEX_DAC);
174         ParamTrieNode *paramNode = FindTrieNode(workspace, name, strlen(name), &labelIndex);
175         ParamSecurityNode *node = (ParamSecurityNode *)GetTrieNode(workspace, labelIndex);
176         if (paramNode == nullptr || node == nullptr) {
177             EXPECT_EQ(1, 0);
178             return 0;
179         }
180         EXPECT_EQ(node->gid, auditData.dacData.gid);
181         return 0;
182     }
183 
TestBufferValue(char * buffer,uint32_t len)184     void TestBufferValue(char *buffer, uint32_t len)
185     {
186         const int printBase = 10;
187         for (uint32_t index = 0; index <= len; index++) {
188             buffer[index] = '0' + index % printBase;
189             if (index != 0 && index % printBase == 0) {
190                 buffer[index] = '.';
191             }
192         }
193         buffer[len] = '\0';
194     }
195 
TestNameIsValid()196     int TestNameIsValid()
197     {
198         char buffer[PARAM_BUFFER_SIZE];
199         // set name length = 127
200         TestBufferValue(buffer, PARAM_NAME_LEN_MAX - 1);
201         int ret = SystemWriteParam(buffer, "1111");
202         EXPECT_EQ(ret, 0);
203         TestBufferValue(buffer, PARAM_NAME_LEN_MAX);
204         ret = SystemWriteParam(buffer, "1111");
205         EXPECT_NE(ret, 0);
206         TestBufferValue(buffer, PARAM_NAME_LEN_MAX + 1);
207         ret = SystemWriteParam(buffer, "1111");
208         EXPECT_NE(ret, 0);
209 
210         // 保存一个只读的属性,大于最大值
211         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX - 1);
212         ret = SystemWriteParam("const.test_readonly.dddddddddddddddddd.fffffffffffffffffff", buffer);
213         EXPECT_EQ(ret, 0);
214 
215         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX + 1);
216         ret = SystemWriteParam("const.test_readonly.aaaaaaaaaaaaaaaaaa.fffffffffffffffffff", buffer);
217         EXPECT_EQ(ret, 0);
218 
219         // 更新只读项目
220         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX - 1);
221         ret = SystemWriteParam("const.test_readonly.dddddddddddddddddd.fffffffffffffffffff", buffer);
222         EXPECT_NE(ret, 0);
223 
224         // 写普通属性
225         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX - 1);
226         ret = SystemWriteParam("test.bigvalue.dddddddddddddddddd.fffffffffffffffffff", buffer);
227         EXPECT_EQ(ret, 0);
228         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX + 1);
229         ret = SystemWriteParam("test.bigvalue.dddddddddddddddddd.fffffffffffffffffff", buffer);
230         EXPECT_NE(ret, 0);
231 
232         // invalid name
233         TestBufferValue(buffer, PARAM_VALUE_LEN_MAX - 1);
234         ret = SystemWriteParam("test.invalidname..fffffffffffffffffff", buffer);
235         EXPECT_NE(ret, 0);
236         ret = SystemWriteParam("test.invalidname.%fffffffffffffffffff", buffer);
237         EXPECT_NE(ret, 0);
238         ret = SystemWriteParam("test.invalidname.$fffffffffffffffffff", buffer);
239         EXPECT_NE(ret, 0);
240         return 0;
241     }
242 
TestParamTraversal()243     int TestParamTraversal()
244     {
245         char value[PARAM_BUFFER_SIZE + PARAM_BUFFER_SIZE] = {0};
246         SystemTraversalParameter(
247             "",
248             [](ParamHandle handle, void *cookie) {
249                 SystemGetParameterName(handle, (char *)cookie, PARAM_BUFFER_SIZE);
250                 u_int32_t len = PARAM_BUFFER_SIZE;
251                 SystemGetParameterValue(handle, ((char *)cookie) + PARAM_BUFFER_SIZE, &len);
252                 printf("$$$$$$$$Param %s=%s \n", (char *)cookie, ((char *)cookie) + PARAM_BUFFER_SIZE);
253             },
254             (void *)value);
255         return 0;
256     }
257 
TestUpdateParam(const char * name,const char * value)258     int TestUpdateParam(const char *name, const char *value)
259     {
260         SystemWriteParam(name, value);
261         SystemWriteParam(name, value);
262         SystemWriteParam(name, value);
263         SystemWriteParam(name, value);
264         CheckServerParamValue(name, value);
265         return 0;
266     }
267 
TestPersistParam()268     int TestPersistParam()
269     {
270         ParamAuditData auditData = {};
271         auditData.name = "persist.";
272         auditData.dacData.gid = 0;
273         auditData.dacData.uid = 0;
274         auditData.dacData.mode = 0777;  // 0777 test mode
275         AddSecurityLabel(&auditData);
276 
277         LoadPersistParams();
278         SystemWriteParam("persist.111.ffff.bbbb.cccc.dddd.eeee", "1101");
279         SystemWriteParam("persist.111.aaaa.bbbb.cccc.dddd.eeee", "1102");
280         SystemWriteParam("persist.111.bbbb.cccc.dddd.eeee", "1103");
281         CheckServerParamValue("persist.111.bbbb.cccc.dddd.eeee", "1103");
282 
283         SystemWriteParam("persist.111.cccc.bbbb.cccc.dddd.eeee", "1104");
284         SystemWriteParam("persist.111.eeee.bbbb.cccc.dddd.eeee", "1105");
285         CheckServerParamValue("persist.111.ffff.bbbb.cccc.dddd.eeee", "1101");
286         SystemWriteParam("persist.111.ffff.bbbb.cccc.dddd.eeee", "1106");
287         CheckServerParamValue("persist.111.ffff.bbbb.cccc.dddd.eeee", "1106");
288         sleep(1);
289         SystemWriteParam("persist.111.bbbb.cccc.dddd.1107", "1107");
290         SystemWriteParam("persist.111.bbbb.cccc.dddd.1108", "1108");
291         SystemWriteParam("persist.111.bbbb.cccc.dddd.1109", "1108");
292         sleep(1);
293         SystemWriteParam("persist.111.bbbb.cccc.dddd.1110", "1108");
294         SystemWriteParam("persist.111.bbbb.cccc.dddd.1111", "1108");
295         TimerCallbackForSave(nullptr, nullptr);
296         LoadPersistParams();
297         return 0;
298     }
299 
TestDumpParamMemory()300     int TestDumpParamMemory()
301     {
302         SystemDumpParameters(1, -1, nullptr);
303         return 0;
304     }
305 
GetWorkSpaceIndex(const char * name)306     uint32_t GetWorkSpaceIndex(const char *name)
307     {
308 #ifdef PARAM_SUPPORT_SELINUX
309         ParamWorkSpace *paramSpace = GetParamWorkSpace();
310         PARAM_CHECK(paramSpace != nullptr, return (uint32_t)-1, "Invalid paramSpace");
311         return (paramSpace->selinuxSpace.getParamLabelIndex != nullptr) ?
312             paramSpace->selinuxSpace.getParamLabelIndex(name) + WORKSPACE_INDEX_BASE : (uint32_t)-1;
313 #else
314         return 0;
315 #endif
316     }
317 };
318 
319 HWTEST_F(ParamUnitTest, Init_TestPersistParam_001, TestSize.Level0)
320 {
321     ParamUnitTest test;
322     test.TestPersistParam();
323 }
324 
325 HWTEST_F(ParamUnitTest, Init_TestSetParam_001, TestSize.Level0)
326 {
327     ParamUnitTest test;
328     const char *params[][2] = {{"111.2222", "1"},
329                                {"111.2222.3333", "2"},
330                                {"111.2222.3333.4444", "3"},
331                                {"111.2222.3333.4444.666", "4"},
332                                {"111.2222.3333.4444.666.777", "5"}};
333     test.TestSetParams(params, 5);
334 }
335 
336 HWTEST_F(ParamUnitTest, Init_TestSetParam_002, TestSize.Level0)
337 {
338     ParamUnitTest test;
339     const char *params[][2] = {{"111.2222.xxxx.xxx.xxx", "1_1"},
340                                {"111.2222.3333.xxx", "1_2"},
341                                {"111.2222.xxxx.3333.4444", "1_3"},
342                                {"111.2222.3333.xxxx.4444.666", "1_4"},
343                                {"111.2222.3333.4444.666.xxxxx.777", "1_5"}};
344     test.TestSetParams(params, 5);
345 
346     const char *ctrlParams[][2] = {{"ctl.start.111.2222.xxxx.xxx.xxx", "2_1"},
347                                    {"ctl.start.111.2222.3333.xxx", "2_2"},
348                                    {"ctl.start.111.2222.xxxx.3333.4444", "2_3"},
349                                    {"ctl.start.111.2222.3333.xxxx.4444.666", "2_4"},
350                                    {"ctl.start.111.2222.3333.4444.666.xxxxx.777", "2_5"}};
351     test.TestSetParams(ctrlParams, 5);
352 
353     const char *sysParams[][2] = {{"ohos.startup.powerctrl.111.2222.xxxx.xxx.xxx", "3_1"},
354                                   {"ohos.startup.powerctrl.111.2222.3333.xxx", "3_2"},
355                                   {"ohos.startup.powerctrl.111.2222.xxxx.3333.4444", "3_3"},
356                                   {"ohos.startup.powerctrl.111.2222.3333.xxxx.4444.666", "3_4"},
357                                   {"ohos.startup.powerctrl.111.2222.3333.4444.666.xxxxx.777", "3_5"}};
358     test.TestSetParams(sysParams, 5);
359 }
360 
361 HWTEST_F(ParamUnitTest, Init_TestNameIsValid_001, TestSize.Level0)
362 {
363     ParamUnitTest test;
364     test.TestNameIsValid();
365 }
366 
367 HWTEST_F(ParamUnitTest, Init_TestParamValue_001, TestSize.Level0)
368 {
369     // support empty string
370     const char *name = "test_readonly.dddddddddddddddddd.fffffffffffffffffff";
371     int ret = SystemWriteParam(name, "");
372     EXPECT_EQ(ret, 0);
373     CheckServerParamValue(name, "");
374     ret = SystemWriteParam(name, "111111111");
375     EXPECT_EQ(ret, 0);
376     CheckServerParamValue(name, "111111111");
377     ret = SystemWriteParam(name, "");
378     EXPECT_EQ(ret, 0);
379     CheckServerParamValue(name, "");
380 }
381 
382 HWTEST_F(ParamUnitTest, Init_TestAddSecurityLabel_001, TestSize.Level0)
383 {
384     ParamUnitTest test;
385     test.TestAddSecurityLabel1();
386 }
387 
388 HWTEST_F(ParamUnitTest, Init_TestAddSecurityLabel_002, TestSize.Level0)
389 {
390     ParamUnitTest test;
391     test.TestAddSecurityLabel2();
392 }
393 
394 HWTEST_F(ParamUnitTest, Init_TestAddSecurityLabel_003, TestSize.Level0)
395 {
396     ParamUnitTest test;
397     test.TestAddSecurityLabel3();
398 }
399 
400 HWTEST_F(ParamUnitTest, Init_TestAddSecurityLabel_004, TestSize.Level0)
401 {
402     ParamUnitTest test;
403     test.TestAddSecurityLabel4();
404 }
405 
406 HWTEST_F(ParamUnitTest, Init_TestUpdateParam_001, TestSize.Level0)
407 {
408     ParamUnitTest test;
409     test.TestUpdateParam("test.aaa.bbb.ccc.ddd", "100");
410     test.TestUpdateParam("test.aaa.bbb.ccc.ddd", "101");
411     test.TestUpdateParam("test.aaa.bbb.ccc.ddd", "102");
412     test.TestUpdateParam("test.aaa.bbb.ccc.ddd", "103");
413     test.TestUpdateParam("net.tcp.default_init_rwnd", "60");
414 }
415 
416 HWTEST_F(ParamUnitTest, Init_TestParamTraversal_001, TestSize.Level0)
417 {
418     ParamUnitTest test;
419     test.TestParamTraversal();
420 }
421 
422 HWTEST_F(ParamUnitTest, Init_TestDumpParamMemory_001, TestSize.Level0)
423 {
424     ParamUnitTest test;
425     test.TestDumpParamMemory();
426 }
427 
428 HWTEST_F(ParamUnitTest, Init_TestLinuxRWLock_001, TestSize.Level0)
429 {
430     ParamRWMutexCreate(nullptr);
431     ParamRWMutexWRLock(nullptr);
432     ParamRWMutexRDLock(nullptr);
433     ParamRWMutexUnlock(nullptr);
434     ParamRWMutexDelete(nullptr);
435     ParamMutexDelete(nullptr);
436 }
437 
438 HWTEST_F(ParamUnitTest, Init_TestWorkSpace_001, TestSize.Level0)
439 {
440     int ret = AddWorkSpace("test.workspace.1", GetWorkSpaceIndex("test.workspace.1"), 0, PARAM_WORKSPACE_DEF);
441     EXPECT_EQ(ret, 0);
442     ret = AddWorkSpace("test.workspace.2", GetWorkSpaceIndex("test.workspace.2"), 0, PARAM_WORKSPACE_DEF);
443     EXPECT_EQ(ret, 0);
444     ret = AddWorkSpace("test.workspace.3", GetWorkSpaceIndex("test.workspace.3"), 0, PARAM_WORKSPACE_DEF);
445     EXPECT_EQ(ret, 0);
446     WorkSpace *space = GetWorkSpace(GetWorkSpaceIndex("test.workspace.1"));
447     EXPECT_NE(space, nullptr);
448     CloseWorkSpace(nullptr);
449 }
450 
451 HWTEST_F(ParamUnitTest, Init_TestWorkSpace_002, TestSize.Level0)
452 {
453     const char *spaceName = "test.workspace2";
454     const size_t size = strlen(spaceName) + 1;
455     WorkSpace *workSpace = (WorkSpace *)malloc(sizeof(WorkSpace) + size);
456     if (workSpace == nullptr) {
457         EXPECT_NE(workSpace, nullptr);
458         return;
459     }
460     workSpace->flags = 0;
461     workSpace->area = nullptr;
462     int ret = PARAM_STRCPY(workSpace->fileName, size, spaceName);
463     EXPECT_EQ(ret, 0);
464     CloseWorkSpace(workSpace);
465     free(workSpace);
466 }
467 
468 #if !(defined __LITEOS_A__ || defined __LITEOS_M__) // can not support parameter type
469 HWTEST_F(ParamUnitTest, Init_TestParamValueType_001, TestSize.Level0)
470 {
471     int ret = SystemWriteParam("test.type.int.1000", "10000");
472     EXPECT_EQ(ret, 0);
473 
474     ret = SystemWriteParam("test.type.int.1001", "-1111111144444444444441111111666666661");
475     EXPECT_EQ(ret, PARAM_CODE_INVALID_VALUE);
476     ret = SystemWriteParam("test.type.int.1001", "1111111111444444444444411111166666666");
477     EXPECT_EQ(ret, PARAM_CODE_INVALID_VALUE);
478 }
479 
480 HWTEST_F(ParamUnitTest, Init_TestParamValueType_002, TestSize.Level0)
481 {
482     int ret = SystemWriteParam("test.type.bool.1000", "10000");
483     EXPECT_EQ(ret, PARAM_CODE_INVALID_VALUE);
484 
485     ret = SystemWriteParam("test.type.bool.1001", "-1111111111111111");
486     EXPECT_EQ(ret, PARAM_CODE_INVALID_VALUE);
487     ret = SystemWriteParam("test.type.bool.1001", "1111111111111111");
488     EXPECT_EQ(ret, PARAM_CODE_INVALID_VALUE);
489     ret = SystemWriteParam("test.type.bool.1001", "true");
490     EXPECT_EQ(ret, 0);
491     ret = SystemWriteParam("test.type.bool.1001", "false");
492     EXPECT_EQ(ret, 0);
493     ret = SystemWriteParam("test.type.bool.1001", "1");
494     EXPECT_EQ(ret, 0);
495     ret = SystemWriteParam("test.type.bool.1001", "0");
496     EXPECT_EQ(ret, 0);
497     ret = SystemWriteParam("test.type.bool.1001", "on");
498     EXPECT_EQ(ret, 0);
499     ret = SystemWriteParam("test.type.bool.1001", "off");
500     EXPECT_EQ(ret, 0);
501     ret = SystemWriteParam("test.type.bool.1001", "yes");
502     EXPECT_EQ(ret, 0);
503     ret = SystemWriteParam("test.type.bool.1001", "no");
504     EXPECT_EQ(ret, 0);
505     ret = SystemWriteParam("test.type.bool.1001", "y");
506     EXPECT_EQ(ret, 0);
507     ret = SystemWriteParam("test.type.bool.1001", "n");
508     EXPECT_EQ(ret, 0);
509 }
510 #endif
511 
512 HWTEST_F(ParamUnitTest, Init_TestGetServiceCtlName_001, TestSize.Level0)
513 {
514     ServiceCtrlInfo *serviceInfo = nullptr;
515     GetServiceCtrlInfo("ohos.startup.powerctrl", "reboot,updater", &serviceInfo);
516     if (serviceInfo != nullptr) {
517         EXPECT_STREQ(serviceInfo->realKey, "ohos.servicectrl.reboot.updater.reboot,updater");
518         free(serviceInfo);
519     }
520     GetServiceCtrlInfo("ohos.ctl.stop", "test", &serviceInfo);
521     if (serviceInfo != nullptr) {
522         EXPECT_STREQ(serviceInfo->realKey, "ohos.servicectrl.stop.test");
523         free(serviceInfo);
524     }
525     GetServiceCtrlInfo("ohos.servicectrl.stop", "test", &serviceInfo);
526     if (serviceInfo != nullptr) {
527         EXPECT_STREQ(serviceInfo->realKey, "ohos.servicectrl.stop.test");
528         free(serviceInfo);
529     }
530     ParamWorBaseLog(INIT_DEBUG, PARAN_DOMAIN, "PARAM", "%s", "ParamWorBaseLog");
531 }
532 
533 HWTEST_F(ParamUnitTest, Init_TestFindTrieNode_001, TestSize.Level0)
534 {
535     int ret = AddWorkSpace("test.workspace.1", GetWorkSpaceIndex("test.workspace.1"), 0, PARAM_WORKSPACE_DEF);
536     EXPECT_EQ(ret, 0);
537     WorkSpace *space = GetWorkSpaceByName("test.workspace.1");
538     ASSERT_NE(space, nullptr);
539     ParamTrieNode *node = FindTrieNode(nullptr, nullptr, 0, nullptr);
540     ASSERT_EQ(node, nullptr);
541     node = FindTrieNode(space, nullptr, 0, nullptr);
542     ASSERT_EQ(node, nullptr);
543     node = FindTrieNode(space, "111111", 0, nullptr);
544     ASSERT_EQ(node, nullptr);
545     node = FindTrieNode(space, "find.test.111111", strlen("find.test.111111"), nullptr);
546     ASSERT_EQ(node, nullptr);
547 }
548 
549 #ifndef OHOS_LITE
550 HWTEST_F(ParamUnitTest, Init_TestConnectServer_001, TestSize.Level0)
551 {
552     int ret = ConnectServer(-1, CLIENT_PIPE_NAME);
553     EXPECT_NE(ret, 0);
554     int fd = socket(PF_UNIX, SOCK_STREAM, 0);
555     ret = ConnectServer(fd, "");
556     EXPECT_NE(ret, 0);
557     ret = ConnectServer(fd, CLIENT_PIPE_NAME);
558     EXPECT_EQ(ret, 0);
559     close(fd);
560 }
561 
562 HWTEST_F(ParamUnitTest, Init_TestRequestMessage_001, TestSize.Level0)
563 {
564     const int maxSize = 1024 * 64 + 10;
565     const int msgSize = sizeof(ParamMessage) + 128; // 128 TEST
566     ParamMessage *msg = CreateParamMessage(0, nullptr, msgSize);
567     EXPECT_EQ(msg, nullptr);
568     msg = CreateParamMessage(0, "nullptr", maxSize);
569     EXPECT_EQ(msg, nullptr);
570     msg = CreateParamMessage(0, "22222222222222222222222222222222222222222"
571         "333333333333333333333333333333333333333333333333333333333333333333333"
572         "555555555555555555555555555555555555555555555555555555555555555555555", msgSize);
573     EXPECT_EQ(msg, nullptr);
574 
575     // success
576     msg = CreateParamMessage(0, "22222222222222222222222222222222222222222", msgSize);
577     EXPECT_NE(msg, nullptr);
578     uint32_t start = 0;
579     int ret = FillParamMsgContent(nullptr, &start, 0, nullptr, 0);
580     EXPECT_NE(ret, 0);
581     ret = FillParamMsgContent(msg, nullptr, 0, nullptr, 0);
582     EXPECT_NE(ret, 0);
583     ret = FillParamMsgContent(msg, &start, 0, nullptr, 0);
584     EXPECT_NE(ret, 0);
585     ret = FillParamMsgContent(msg, &start, 0, "22222", 0);
586     EXPECT_EQ(ret, 0);
587     ret = FillParamMsgContent(msg, &start, 0, "22222", msgSize);
588     EXPECT_NE(ret, 0);
589     // fill success
590     ret = FillParamMsgContent(msg, &start, 0, "22222", strlen("22222"));
591     EXPECT_EQ(ret, 0);
592     msg->msgSize = start + sizeof(ParamMessage);
593 
594     uint32_t offset = 0;
595     ParamMsgContent *content = GetNextContent(nullptr, &offset);
596     EXPECT_EQ(content, nullptr);
597     content = GetNextContent(msg, nullptr);
598     EXPECT_EQ(content, nullptr);
599     offset = 0;
600     content = GetNextContent(msg, &offset);
601     EXPECT_NE(content, nullptr);
602     content = GetNextContent(msg, &offset);
603     EXPECT_NE(content, nullptr);
604     free(msg);
605 }
606 
607 HWTEST_F(ParamUnitTest, Init_TestServerTaskFail_001, TestSize.Level0)
608 {
609     ParamTaskPtr serverTask = nullptr;
610     ParamStreamInfo info = {};
611     info.server = const_cast<char *>(PIPE_NAME);
612     info.close = nullptr;
613     info.recvMessage = nullptr;
614     info.incomingConnect = nullptr;
615     int ret = ParamServerCreate(nullptr, &info);
616     EXPECT_NE(ret, 0);
617     ret = ParamServerCreate(&serverTask, nullptr);
618     EXPECT_NE(ret, 0);
619     ret = ParamServerCreate(&serverTask, &info);
620     EXPECT_NE(ret, 0);
621 }
622 
623 HWTEST_F(ParamUnitTest, Init_TestStreamTaskFail_001, TestSize.Level0)
624 {
625     ParamTaskPtr client = nullptr;
626     ParamStreamInfo info = {};
627     info.flags = PARAM_TEST_FLAGS;
628     info.server = nullptr;
629     info.close = OnClose;
630     info.recvMessage = ProcessMessage;
631     info.incomingConnect = nullptr;
632 
633     int ret = ParamStreamCreate(&client, nullptr, &info, sizeof(ParamWatcher));
634     EXPECT_NE(ret, 0);
635     ret = ParamStreamCreate(&client, GetParamService()->serverTask, nullptr, sizeof(ParamWatcher));
636     EXPECT_NE(ret, 0);
637     info.close = nullptr;
638     ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
639     EXPECT_NE(ret, 0);
640     info.close = OnClose;
641     info.recvMessage = nullptr;
642     ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
643     EXPECT_NE(ret, 0);
644     ret = ParamStreamCreate(&client, nullptr, nullptr, sizeof(ParamWatcher));
645     EXPECT_NE(ret, 0);
646 
647     void *data = ParamGetTaskUserData(client);
648     EXPECT_EQ(data, nullptr);
649 
650     ret = ParamTaskSendMsg(nullptr, nullptr);
651     EXPECT_NE(ret, 0);
652     ret = ParamTaskSendMsg(GetParamService()->serverTask, nullptr);
653     EXPECT_NE(ret, 0);
654 }
655 
656 HWTEST_F(ParamUnitTest, Init_TestParamCache_001, TestSize.Level0)
657 {
658     const char *value = CachedParameterGet(nullptr);
659     EXPECT_EQ(value, nullptr);
660     const char *name = "test.write.1111111.222222";
661     CachedHandle cacheHandle = CachedParameterCreate(name, "true");
662     EXPECT_NE(cacheHandle, nullptr);
663     value = CachedParameterGet(cacheHandle);
664     EXPECT_EQ(strcmp(value, "true"), 0);
665     uint32_t dataIndex = 0;
666     int ret = WriteParam(name, "false", &dataIndex, 0);
667     EXPECT_EQ(ret, 0);
668     value = CachedParameterGet(cacheHandle);
669     EXPECT_EQ(strcmp(value, "false"), 0);
670     CachedParameterDestroy(cacheHandle);
671 
672     // cache 2, for parameter exist
673     CachedHandle cacheHandle3 = CachedParameterCreate(name, "true");
674     EXPECT_NE(cacheHandle3, nullptr);
675     value = CachedParameterGet(cacheHandle3);
676     EXPECT_EQ(strcmp(value, "false"), 0);
677     ret = WriteParam(name, "2222222", &dataIndex, 0);
678     EXPECT_EQ(ret, 0);
679     int valueChange = 0;
680     value = CachedParameterGetChanged(cacheHandle3, &valueChange);
681     EXPECT_EQ(strcmp(value, "2222222"), 0);
682     EXPECT_EQ(valueChange, 1);
683     CachedParameterGetChanged(cacheHandle3, nullptr);
684     CachedParameterDestroy(cacheHandle3);
685 }
686 #endif
687 }
688