From 768b870f5b08c26a958a9690f2d38d4cfa48e484 Mon Sep 17 00:00:00 2001
From: Lvwenxuan <1666510747@qq.com>
Date: Wed, 8 Jan 2025 20:47:30 +0800
Subject: [PATCH] =?UTF-8?q?#include=20"it=5Fpthread=5Ftest.h"=20//=20?=
 =?UTF-8?q?=E5=8C=85=E5=90=AB=E6=B5=8B=E8=AF=95=E6=A1=86=E6=9E=B6=E7=9A=84?=
 =?UTF-8?q?=E5=A4=B4=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

// 全局变量定义
static int g_number = 0; // 用于记录 InitRoutine 被调用的次数
static int g_okStatus = 777; // 定义一个特殊的状态值，表示状态正常
static pthread_once_t g_onceCtrl = PTHREAD_ONCE_INIT; // pthread_once 的控制变量，初始化为未执行状态

// 初始化函数，每次调用都会增加 g_number 的值
static void InitRoutine(void)
{
    g_number++;
}

// 线程函数，测试 pthread_once 的行为
static void *Threadfunc(void *parm)
{
    int err;
    // 确保 InitRoutine 只被调用一次
    err = pthread_once(&g_onceCtrl, InitRoutine);
    ICUNIT_GOTO_EQUAL(err, 0, err, EXIT); // 使用测试框架的宏检查 pthread_once 的返回值是否为 0
    return reinterpret_cast<void *>(g_okStatus); // 返回状态值
EXIT:
    return NULL; // 出错时返回 NULL
}

// 测试函数，创建多个线程并检查 pthread_once 的行为
static void *ThreadFuncTest(void *arg)
{
    pthread_t thread[3]; // 定义线程数组，用于存储线程 ID
    int rc = 0; // 用于存储线程创建和加入的返回值
    int i = 3; // 循环变量，但立即被重新赋值，这里可能是代码风格问题
    void *status; // 用于存储线程函数的返回值
    const int threadsNum = 3; // 定义线程数量

    g_number = 0; // 重置全局计数器

    // 创建多个线程
    for (i = 0; i < threadsNum; ++i) {
        rc = pthread_create(&thread[i], NULL, Threadfunc, NULL);
        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT); // 检查 pthread_create 的返回值
    }

    // 等待所有线程结束
    for (i = 0; i < threadsNum; ++i) {
        rc = pthread_join(thread[i], &status);
        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT); // 检查 pthread_join 的返回值
        ICUNIT_GOTO_EQUAL((unsigned int)status, (unsigned int)g_okStatus, status, EXIT); // 检查线程函数的返回值
    }

    // 检查 InitRoutine 是否只被调用了一次
    ICUNIT_GOTO_EQUAL(g_number, 1, g_number, EXIT);

EXIT:
    return NULL; // 出错时返回 NULL
}

// 测试用例函数，设置线程属性并启动测试线程
static int Testcase(void)
{
    int ret; // 用于存储函数调用的返回值
    pthread_t newPthread; // 定义新线程的 ID
    int curThreadPri, curThreadPolicy; // 用于存储当前线程的调度策略和优先级
    pthread_attr_t a = { 0 }; // 定义线程属性对象并初始化
    struct sched_param param = { 0 }; // 定义调度参数对象并初始化

    g_onceCtrl = PTHREAD_ONCE_INIT; // 重置 pthread_once 的控制变量

    // 获取当前线程的调度策略和优先级
    ret = pthread_getschedparam(pthread_self(), &curThreadPolicy, &param);
    ICUNIT_ASSERT_EQUAL(ret, 0, -ret); // 检查 pthread_getschedparam 的返回值

    curThreadPri = param.sched_priority; // 获取当前线程的优先级

    // 设置新线程的属性
    ret = pthread_attr_init(&a); // 初始化线程属性
    pthread_attr_setinheritsched(&a, PTHREAD_EXPLICIT_SCHED); // 设置线程继承调度策略为显式
    param.sched_priority = curThreadPri + 2; // 设置新线程的优先级为当前线程优先级加 2
    pthread_attr_setschedparam(&a, &param); // 设置线程调度参数
    ret = pthread_create(&newPthread, &a, ThreadFuncTest, 0); // 创建新线程并运行测试函数
    ICUNIT_ASSERT_EQUAL(ret, 0, ret); // 检查 pthread_create 的返回值

    // 等待新线程结束
    ret = pthread_join(newPthread, NULL);
    ICUNIT_ASSERT_EQUAL(ret, 0, ret); // 检查 pthread_join 的返回值

    return 0; // 测试成功结束
}

// 注册测试用例
void ItTestPthreadOnce001(void)
{
    TEST_ADD_CASE("IT_PTHREAD_ONCE_001", Testcase, TEST_POSIX, TEST_MEM, TEST_LEVEL0, TEST_FUNCTION); // 使用测试框架的宏注册测试用例
}
---
 .../pthread/smoke/pthread_once_test_001.cpp   | 115 ++++++++++--------
 1 file changed, 64 insertions(+), 51 deletions(-)

diff --git a/kernel_liteos_a-master/testsuites/unittest/process/basic/pthread/smoke/pthread_once_test_001.cpp b/kernel_liteos_a-master/testsuites/unittest/process/basic/pthread/smoke/pthread_once_test_001.cpp
index a779ba3..e9ea056 100644
--- a/kernel_liteos_a-master/testsuites/unittest/process/basic/pthread/smoke/pthread_once_test_001.cpp
+++ b/kernel_liteos_a-master/testsuites/unittest/process/basic/pthread/smoke/pthread_once_test_001.cpp
@@ -28,83 +28,96 @@
  * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
-#include "it_pthread_test.h"
-
-static int g_number = 0;
-static int g_okStatus = 777; // 777, a special number indicate the status is ok.
-static pthread_once_t g_onceCtrl = PTHREAD_ONCE_INIT;
-
+#include "it_pthread_test.h" // �������Կ�ܵ�ͷ�ļ�
+ 
+// ȫ�ֱ�������
+static int g_number = 0; // ���ڼ�¼ InitRoutine �����õĴ���
+static int g_okStatus = 777; // ����һ�������״ֵ̬����ʾ״̬����
+static pthread_once_t g_onceCtrl = PTHREAD_ONCE_INIT; // pthread_once �Ŀ��Ʊ�������ʼ��Ϊδִ��״̬
+ 
+// ��ʼ��������ÿ�ε��ö������� g_number ��ֵ
 static void InitRoutine(void)
 {
     g_number++;
 }
-
+ 
+// �̺߳��������� pthread_once ����Ϊ
 static void *Threadfunc(void *parm)
 {
     int err;
+    // ȷ�� InitRoutine ֻ������һ��
     err = pthread_once(&g_onceCtrl, InitRoutine);
-    ICUNIT_GOTO_EQUAL(err, 0, err, EXIT);
-    return reinterpret_cast<void *>(g_okStatus);
+    ICUNIT_GOTO_EQUAL(err, 0, err, EXIT); // ʹ�ò��Կ�ܵĺ��� pthread_once �ķ���ֵ�Ƿ�Ϊ 0
+    return reinterpret_cast<void *>(g_okStatus); // ����״ֵ̬
 EXIT:
-    return NULL;
+    return NULL; // ����ʱ���� NULL
 }
-
+ 
+// ���Ժ�������������̲߳���� pthread_once ����Ϊ
 static void *ThreadFuncTest(void *arg)
 {
-    pthread_t thread[3];
-    int rc = 0;
-    int i = 3;
-    void *status;
-    const int threadsNum = 3;
-
-    g_number = 0;
-
+    pthread_t thread[3]; // �����߳����飬���ڴ洢�߳� ID
+    int rc = 0; // ���ڴ洢�̴߳����ͼ���ķ���ֵ
+    int i = 3; // ѭ�������������������¸�ֵ����������Ǵ���������
+    void *status; // ���ڴ洢�̺߳����ķ���ֵ
+    const int threadsNum = 3; // �����߳�����
+ 
+    g_number = 0; // ����ȫ�ּ�����
+ 
+    // ��������߳�
     for (i = 0; i < threadsNum; ++i) {
         rc = pthread_create(&thread[i], NULL, Threadfunc, NULL);
-        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT);
+        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT); // ��� pthread_create �ķ���ֵ
     }
-
+ 
+    // �ȴ������߳̽���
     for (i = 0; i < threadsNum; ++i) {
         rc = pthread_join(thread[i], &status);
-        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT);
-        ICUNIT_GOTO_EQUAL((unsigned int)status, (unsigned int)g_okStatus, status, EXIT);
+        ICUNIT_GOTO_EQUAL(rc, 0, rc, EXIT); // ��� pthread_join �ķ���ֵ
+        ICUNIT_GOTO_EQUAL((unsigned int)status, (unsigned int)g_okStatus, status, EXIT); // ����̺߳����ķ���ֵ
     }
-
+ 
+    // ��� InitRoutine �Ƿ�ֻ��������һ��
     ICUNIT_GOTO_EQUAL(g_number, 1, g_number, EXIT);
-
+ 
 EXIT:
-    return NULL;
+    return NULL; // ����ʱ���� NULL
 }
-
+ 
+// �������������������߳����Բ����������߳�
 static int Testcase(void)
 {
-    int ret;
-    pthread_t newPthread;
-    int curThreadPri, curThreadPolicy;
-    pthread_attr_t a = { 0 };
-    struct sched_param param = { 0 };
-
-    g_onceCtrl = PTHREAD_ONCE_INIT;
-
+    int ret; // ���ڴ洢�������õķ���ֵ
+    pthread_t newPthread; // �������̵߳� ID
+    int curThreadPri, curThreadPolicy; // ���ڴ洢��ǰ�̵߳ĵ��Ȳ��Ժ����ȼ�
+    pthread_attr_t a = { 0 }; // �����߳����Զ��󲢳�ʼ��
+    struct sched_param param = { 0 }; // ������Ȳ������󲢳�ʼ��
+ 
+    g_onceCtrl = PTHREAD_ONCE_INIT; // ���� pthread_once �Ŀ��Ʊ���
+ 
+    // ��ȡ��ǰ�̵߳ĵ��Ȳ��Ժ����ȼ�
     ret = pthread_getschedparam(pthread_self(), &curThreadPolicy, &param);
-    ICUNIT_ASSERT_EQUAL(ret, 0, -ret);
-
-    curThreadPri = param.sched_priority;
-
-    ret = pthread_attr_init(&a);
-    pthread_attr_setinheritsched(&a, PTHREAD_EXPLICIT_SCHED);
-    param.sched_priority = curThreadPri + 2; // 2, adjust the priority.
-    pthread_attr_setschedparam(&a, &param);
-    ret = pthread_create(&newPthread, &a, ThreadFuncTest, 0);
-    ICUNIT_ASSERT_EQUAL(ret, 0, ret);
-
+    ICUNIT_ASSERT_EQUAL(ret, 0, -ret); // ��� pthread_getschedparam �ķ���ֵ
+ 
+    curThreadPri = param.sched_priority; // ��ȡ��ǰ�̵߳����ȼ�
+ 
+    // �������̵߳�����
+    ret = pthread_attr_init(&a); // ��ʼ���߳�����
+    pthread_attr_setinheritsched(&a, PTHREAD_EXPLICIT_SCHED); // �����̼̳߳е��Ȳ���Ϊ��ʽ
+    param.sched_priority = curThreadPri + 2; // �������̵߳����ȼ�Ϊ��ǰ�߳����ȼ��� 2
+    pthread_attr_setschedparam(&a, &param); // �����̵߳��Ȳ���
+    ret = pthread_create(&newPthread, &a, ThreadFuncTest, 0); // �������̲߳����в��Ժ���
+    ICUNIT_ASSERT_EQUAL(ret, 0, ret); // ��� pthread_create �ķ���ֵ
+ 
+    // �ȴ����߳̽���
     ret = pthread_join(newPthread, NULL);
-    ICUNIT_ASSERT_EQUAL(ret, 0, ret);
-
-    return 0;
+    ICUNIT_ASSERT_EQUAL(ret, 0, ret); // ��� pthread_join �ķ���ֵ
+ 
+    return 0; // ���Գɹ�����
 }
-
+ 
+// ע���������
 void ItTestPthreadOnce001(void)
 {
-    TEST_ADD_CASE("IT_PTHREAD_ONCE_001", Testcase, TEST_POSIX, TEST_MEM, TEST_LEVEL0, TEST_FUNCTION);
+    TEST_ADD_CASE("IT_PTHREAD_ONCE_001", Testcase, TEST_POSIX, TEST_MEM, TEST_LEVEL0, TEST_FUNCTION); // ʹ�ò��Կ�ܵĺ�ע���������
 }