首页 最新 热门 推荐

登录

• 首页
• 最新
• 热门
• 推荐

【Linux】一步一步学Linux——last命令(98)

• 23-11-18 12:41
• 4470
• 7321

blog.csdn.net

00. 目录

文章目录

• • 00. 目录
  • 01. 命令概述
  • 02. 命令格式
  • 03. 常用选项
  • 04. 参考示例
  • 05. 总结
  • 06. 附录

01. 命令概述

last命令用于显示用户最近登录信息。单独执行last命令，它会读取/var/log/wtmp的文件，并把该给文件的内容记录的登入系统的用户名单全部显示出来。

last命令的作用是显示近期用户或终端的登录情况，通过查看系统记录的日志文件内容，进而使管理员可以获知谁曾经或者企图连接系统。

执行last命令时，它会读取/var/log目录下名称为wtmp的文件，并把该文件记录的登录系统或终端的用户名单全部显示出来。默认显示wtmp的记录，btmp能显示的更详细，可以显示远程登录，例如ssh登录。

02. 命令格式

last [-R] [-num] [ -n num ] [-adiox] [ -f file ] [name...]  [tty...]
1

03. 常用选项

-a：把从何处登入系统的主机名称或ip地址，显示在最后一行；
-d：将IP地址转换成主机名称；
-f <记录文件>：指定记录文件。
-n <显示列数>或-<显示列数>：设置列出名单的显示列数；
-R：不显示登入系统的主机名称或IP地址；
-x：显示系统关机，重新开机，以及执行等级的改变等信息。
1
2
3
4
5
6

04. 参考示例

4.1 显示近期用户或终端的登录情况

[deng@itcast ~]$ last
deng     pts/2        172.16.0.51      Fri Aug  2 21:54   still logged in   
1
2

第一列: 用户名
第二列: 终端位置

​ pts: 意味着从SSH或TELNET的远程连接用户
​ tty: 意味着直接连接到计算机或者本地连接用户
​ 除了重启，所有状态会在启动时显示
第三列: 登录IP或者内核
​ 0.0或者什么都没有的话：意味着用户通过本地终端连接
​ 重启活动，会显示内核版本
第四列: 开始时间
第五列: 结束时间
​ still log in: 还在登录
​ down: 直到正常关机
​ crash: 直到强制关机
第六列: 持续时间

4.2 简略显示，并指定显示的个数

[deng@itcast ~]$ last -n 5 -R
deng     pts/2        Fri Aug  2 21:54   still logged in   
deng     pts/1        Fri Aug  2 21:49   still logged in   
deng     pts/2        Fri Aug  2 20:30 - 21:04  (00:34)    
deng     pts/1        Fri Aug  2 20:11 - 21:04  (00:52)    
deng     pts/1        Thu Aug  1 22:14 - 19:51  (21:37)    

wtmp begins Thu Nov  8 03:53:52 2018
[deng@itcast ~]$ 
1
2
3
4
5
6
7
8
9

4.3 显示最后一列显示主机IP地址

[deng@itcast ~]$ last -n 5 -a -i
deng     pts/2        Fri Aug  2 21:54   still logged in    172.16.0.51
deng     pts/1        Fri Aug  2 21:49   still logged in    172.16.0.51
deng     pts/2        Fri Aug  2 20:30 - 21:04  (00:34)     192.168.12.194
deng     pts/1        Fri Aug  2 20:11 - 21:04  (00:52)     192.168.12.194
deng     pts/1        Thu Aug  1 22:14 - 19:51  (21:37)     172.16.0.51

wtmp begins Thu Nov  8 03:53:52 2018
[deng@itcast ~]$ 
1
2
3
4
5
6
7
8
9

4.4 显示最近6条登录记录

[deng@itcast ~]$ last -6
deng     pts/2        172.16.0.51      Fri Aug  2 21:54   still logged in   
deng     pts/1        172.16.0.51      Fri Aug  2 21:49   still logged in   
deng     pts/2        192.168.12.194   Fri Aug  2 20:30 - 21:04  (00:34)    
deng     pts/1        192.168.12.194   Fri Aug  2 20:11 - 21:04  (00:52)    
deng     pts/1        172.16.0.51      Thu Aug  1 22:14 - 19:51  (21:37)    
deng     pts/1        192.168.12.178   Thu Aug  1 21:26 - 21:54  (00:27)    

wtmp begins Thu Nov  8 03:53:52 2018
[deng@itcast ~]$ 
1
2
3
4
5
6
7
8
9
10

4.5 显示最近15条记录

[deng@itcast ~]$ last -n 15
deng     pts/2        172.16.0.51      Fri Aug  2 21:54   still logged in   
deng     pts/1        172.16.0.51      Fri Aug  2 21:49   still logged in   
deng     pts/2        192.168.12.194   Fri Aug  2 20:30 - 21:04  (00:34)    
deng     pts/1        192.168.12.194   Fri Aug  2 20:11 - 21:04  (00:52)    
deng     pts/1        172.16.0.51      Thu Aug  1 22:14 - 19:51  (21:37)    
deng     pts/1        192.168.12.178   Thu Aug  1 21:26 - 21:54  (00:27)    
deng     pts/3        192.168.12.178   Thu Aug  1 18:30 - 21:26  (02:56)    
deng     pts/2        172.16.0.51      Wed Jul 31 21:54 - 18:32  (20:38)    
deng     pts/1        172.16.0.51      Wed Jul 31 21:54 - 18:32  (20:38)    
deng     pts/1        192.168.12.161   Wed Jul 31 21:27 - 21:47  (00:20)    
deng     pts/1        192.168.12.161   Wed Jul 31 21:25 - 21:27  (00:02)    
deng     pts/1        192.168.12.161   Wed Jul 31 20:18 - 21:24  (01:05)    
deng     pts/2        192.168.12.161   Wed Jul 31 20:01 - 21:47  (01:45)    
deng     pts/1        172.16.0.51      Tue Jul 30 20:14 - 20:05  (23:50)    
deng     pts/1        172.16.0.51      Tue Jul 30 15:05 - 19:49  (04:44)    

wtmp begins Thu Nov  8 03:53:52 2018
[deng@itcast ~]$ 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

4.6 显示最近root用户的5条记录

[deng@itcast ~]$ last -n 5 root
root     pts/5        192.168.21.60    Sun Mar 24 21:17 - 21:18  (00:00)    
root     pts/1        192.168.21.21    Wed Mar  6 09:35 - 09:36  (00:00)    
root     pts/3        192.168.199.151  Fri Dec 28 23:23 - down   (00:43)    
root     pts/2        :0               Fri Dec 28 21:34 - 00:07  (02:32)    
root     pts/1        :0               Fri Dec 28 21:34 - 00:07  (02:33)    

wtmp begins Thu Nov  8 03:53:52 2018
[deng@itcast ~]$ 
1
2
3
4
5
6
7
8
9

4.7 指定记录文件

该文件比较详细，可以显示ssh远程登录的信息

[root@itcast ~]# last -n 8 -f /var/log/btmp
root     pts/1                         Fri Aug  2 21:00    gone - no logout 
root     pts/1                         Thu Aug  1 21:27 - 21:00  (23:33)    

btmp begins Thu Aug  1 21:27:11 2019
[root@itcast ~]# 
1
2
3
4
5
6

4.8 显示完整登录和登出信息

[deng@itcast ~]$ last -F 
1

4.9 关于last几点说明

关于last命令的几点说明:

1. wtmp,btmp,utmp均为二进制文件，不能用cat查看，可用last打开

2. echo > /var/log/wtmp 可清空wtmp记录

Linux系统的三个主要日志子系统

进程日志(acct/pacct: 记录用户命令)

错误日志(/var/log/messages:系统级信息；access-log:记录HTTP/WEB的信息)

连接日志(/var/log/wtmp,/var/log/btmp,/var/run/utmp)

关当前登录用户的信息记录在文件utmp中;

登录进入和退出纪录在文件wtmp中;
最后一次登录文件可以用lastlog命令察看;
数据交换、关机和重起也记录在wtmp文件中;

05. 总结

06. 附录

参考：【Linux】一步一步学Linux系列教程汇总

id="article_content" class="article_content clearfix"> id="content_views" class="markdown_views prism-atom-one-light">

队列（Queue）是一种常用于任务间通信的数据结构。任务能够从队列里面读取消息，当队列中的消息为空时，挂起读取任务；当队列中有新消息时，挂起的读取任务被唤醒并处理新消息。任务也能够往队列里写入消息，当队列已经写满消息时，挂起写入任务；当队列中有空闲消息节点时，挂起的写入任务被唤醒并写入消息。如果将读队列和写队列的超时时间设置为0，则不会挂起任务，接口会直接返回，这就是非阻塞模式。消息队列提供了异步处理机制，允许将一个消息放入队列，但不立即处理。同时队列还有缓冲消息的作用。

本文通过分析鸿蒙轻内核队列模块的源码，掌握队列使用上的差异。本文中所涉及的源码，以OpenHarmony LiteOS-M内核为例，均可以在开源站点https://gitee.com/openharmony/kernel_liteos_m 获取。

---

接下来，我们看下队列的结构体，队列初始化，队列常用操作的源代码。

1、队列结构体定义和常用宏定义

1.1 队列结构体定义

在文件kernel\include\los_queue.h中定义队列控制块结构体为LosQueueCB，结构体源代码如下。队列状态.queueState取值OS_QUEUE_UNUSED、OS_QUEUE_INUSED，其他结构体成员见注释部分。

typedef struct {
    UINT8 *queue;      /**< 队列内存空间的指针 */
    UINT16 queueState; /**< 队列的使用状态 */
    UINT16 queueLen;   /**< 队列长度，即消息数量 */
    UINT16 queueSize;  /**< 消息节点大小 */
    UINT16 queueID;    /**< 队列编号  */
    UINT16 queueHead;  /**< 消息头节点位置 */
    UINT16 queueTail;  /**< 消息尾节点位置 */
    UINT16 readWriteableCnt[OS_READWRITE_LEN]; /**< 2维数组，可读、可写的消息数量, 0:可读, 1:可写 */
    LOS_DL_LIST readWriteList[OS_READWRITE_LEN]; /**< 2维双向链表数组，阻塞读、写任务的双向链表, 0:读链表, 1:写链表 */
    LOS_DL_LIST memList; /**< 内存节点双向链表 */
} LosQueueCB;
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}">

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12

1.2 队列常用宏定义

系统支持创建多少队列是根据开发板情况使用宏LOSCFG_BASE_IPC_QUEUE_LIMIT定义的，每一个队列queueID是queueID类型的，取值为[0,LOSCFG_BASE_IPC_QUEUE_LIMIT)，表示队列池中各个队列的编号。

⑴处的宏从队列池中获取指定队列编号QueueID对应的队列控制块。⑵处根据双向链表节点readWriteList[OS_QUEUE_WRITE]获取队列控制块内存地址。

⑴    #define GET_QUEUE_HANDLE(QueueID) (((LosQueueCB *)g_allQueue) + (QueueID))

⑵    #define GET_QUEUE_LIST(ptr) LOS_DL_LIST_ENTRY(ptr, LosQueueCB, readWriteList[OS_QUEUE_WRITE])
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}">

• 1
• 2
• 3

另外，队列中还提供了比较重要的队列读取消息操作相关的枚举和宏。枚举QueueReadWrite区分队列的读和写，枚举QueueHeadTail区分队列的首和尾，枚举QueuePointOrNot区分读写消息时是使用值还是指针。

队列的操作类型使用3比特位的数字来表示，见宏OS_QUEUE_OPERATE_TYPE的定义，其中高1位表示读写数值还是读写指针地址，中1位表示队首还是队尾，低1位表示读取还是写入。枚举和宏的定义如下：

typedef enum {
    OS_QUEUE_READ,
    OS_QUEUE_WRITE
} QueueReadWrite;

typedef enum {
    OS_QUEUE_HEAD,
    OS_QUEUE_TAIL
} QueueHeadTail;

typedef enum {
    OS_QUEUE_NOT_POINT,
    OS_QUEUE_POINT
} QueuePointOrNot;

#define OS_QUEUE_OPERATE_TYPE(ReadOrWrite, HeadOrTail, PointOrNot)  \
                (((UINT32)(PointOrNot) << 2) | ((UINT32)(HeadOrTail) << 1) | (ReadOrWrite))
#define OS_QUEUE_READ_WRITE_GET(type) ((type) & (0x01))
#define OS_QUEUE_READ_HEAD     (OS_QUEUE_READ | (OS_QUEUE_HEAD << 1))
#define OS_QUEUE_READ_TAIL     (OS_QUEUE_READ | (OS_QUEUE_TAIL << 1))
#define OS_QUEUE_WRITE_HEAD    (OS_QUEUE_WRITE | (OS_QUEUE_HEAD << 1))
#define OS_QUEUE_WRITE_TAIL    (OS_QUEUE_WRITE | (OS_QUEUE_TAIL << 1))
#define OS_QUEUE_OPERATE_GET(type) ((type) & (0x03))
#define OS_QUEUE_IS_POINT(type)    ((type) & (0x04))
#define OS_QUEUE_IS_READ(type)     (OS_QUEUE_READ_WRITE_GET(type) == OS_QUEUE_READ)
#define OS_QUEUE_IS_WRITE(type)    (OS_QUEUE_READ_WRITE_GET(type) == OS_QUEUE_WRITE)
#define OS_READWRITE_LEN           2
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}">

class="hide-preCode-box">

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27

2、队列初始化

队列在内核中默认开启，用户可以通过宏LOSCFG_BASE_IPC_QUEUE进行关闭。开启队列的情况下，在系统启动时，在kernel\src\los_init.c中调用OsQueueInit()进行队列模块初始化。下面，我们分析下队列初始化的代码。

⑴为队列申请内存，如果申请失败，则返回错误。⑵初始化双向循环链表g_freeQueueList，维护未使用的队列。⑶循环每一个队列进行初始化，为每一个队列节点指定索引queueID，并把队列节点插入未使用队列双向链表g_freeQueueList。代码上可以看出，挂在未使用队列双向链表上的节点是每个队列控制块的写阻塞任务链表节点.readWriteList[OS_QUEUE_WRITE]。

LITE_OS_SEC_TEXT_INIT UINT32 OsQueueInit(VOID)
{
    LosQueueCB *queueNode = NULL;
    UINT16 index;

    if (LOSCFG_BASE_IPC_QUEUE_LIMIT == 0) {
        return LOS_ERRNO_QUEUE_MAXNUM_ZERO;
    }

⑴  g_allQueue = (LosQueueCB *)LOS_MemAlloc(m_aucSysMem0, LOSCFG_BASE_IPC_QUEUE_LIMIT * sizeof(LosQueueCB));
    if (g_allQueue == NULL) {
        return LOS_ERRNO_QUEUE_NO_MEMORY;
    }

    (VOID)memset_s(g_allQueue, LOSCFG_BASE_IPC_QUEUE_LIMIT * sizeof(LosQueueCB),
                   0, LOSCFG_BASE_IPC_QUEUE_LIMIT * sizeof(LosQueueCB));

⑵  LOS_ListInit(&g_freeQueueList);
⑶  for (index = 0; index < LOSCFG_BASE_IPC_QUEUE_LIMIT; index++) {
        queueNode = ((LosQueueCB *)g_allQueue) + index;
        queueNode->queueID = index;
        LOS_ListTailInsert(&g_freeQueueList, &queueNode->readWriteList[OS_QUEUE_WRITE]);
    }

    return LOS_OK;
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}">

class="hide-preCode-box">

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26

3、队列常用操作

3.1 队列创建

创建队列函数是LOS_QueueCreate()，先看看该函数的参数：queueName是队列名称，实际上并没有使用。len是队列中消息的数量，queueID是队列编号，flags保留未使用。maxMsgSize是队列中每条消息的最大大小。

我们分析下创建队列的代码。⑴处对参数进行校验，队列编码不能为空，队列消息长度不能太大，队列消息数量和队列消息大小不能为0。⑵处计算消息的实际最大大小msgSize，即maxMsgSize + sizeof(UINT32)消息最大大小再加4个字节，在消息的最后4个字节用来保存消息的实际长度。然后调用⑶处函数LOS_MemAlloc()为对队列动态申请内存，如果内存申请失败，则返回错误码。

⑷处判断g_freeQueueList是否为空，如果没有可以使用的队列，释放前文申请的内存。⑸处如果g_freeQueueList不为空，则获取第一个可用的队列节点，接着从双向链表g_freeQueueList中删除，然后调用宏GET_QUEUE_LIST获取LosQueueCB *queueCB，初始化创建的队列信息，包含队列的长度.queueLen、消息大小.queueSize，队列内存空间.queue，消息状态.queueState，可读的数量.readWriteableCnt[OS_QUEUE_READ]为0，可写的数量readWriteableCnt[OS_QUEUE_WRITE]为队列消息长度len，队列头位置.queueHead和尾位置.queueTail为0。

⑹初始化双向链表.readWriteList[OS_QUEUE_READ]，阻塞在这个队列上的读消息任务会挂在这个链表上。初始化双向链表.readWriteList[OS_QUEUE_WRITE]，阻塞在这个队列上的写消息任务会挂在这个链表上。初始化双向链表.memList。⑺赋值给输出参数*queueID，后续程序使用这个队列编号对队列进行其他操作。

LITE_OS_SEC_TEXT_INIT UINT32 LOS_QueueCreate(CHAR *queueName,
                                             UINT16 len,
                                             UINT32 *queueID,
                                             UINT32 flags,
                                             UINT16 maxMsgSize)
{
    LosQueueCB *queueCB = NULL;
    UINT32 intSave;
    LOS_DL_LIST *unusedQueue = NULL;
    UINT8 *queue = NULL;
    UINT16 msgSize;

    (VOID)queueName;
    (VOID)flags;

⑴  if (queueID == NULL) {
        return LOS_ERRNO_QUEUE_CREAT_PTR_NULL;
    }

    if (maxMsgSize > (OS_NULL_SHORT - sizeof(UINT32))) {
        return LOS_ERRNO_QUEUE_SIZE_TOO_BIG;
    }

    if ((len == 0) || (maxMsgSize == 0)) {
        return LOS_ERRNO_QUEUE_PARA_ISZERO;
    }
⑵  msgSize = maxMsgSize + sizeof(UINT32);

    /* Memory allocation is time-consuming, to shorten the time of disable interrupt,
       move the memory allocation to here. */
⑶  queue = (UINT8 *)LOS_MemAlloc(m_aucSysMem0, len * msgSize);
    if (queue == NULL) {
        return LOS_ERRNO_QUEUE_CREATE_NO_MEMORY;
    }

    intSave = LOS_IntLock();
⑷  if (LOS_ListEmpty(&g_freeQueueList)) {
        LOS_IntRestore(intSave);
        (VOID)LOS_MemFree(m_aucSysMem0, queue);
        return LOS_ERRNO_QUEUE_CB_UNAVAILABLE;
    }

⑸  unusedQueue = LOS_DL_LIST_FIRST(&(g_freeQueueList));
    LOS_ListDelete(unusedQueue);
    queueCB = (GET_QUEUE_LIST(unusedQueue));
    queueCB->queueLen = len;
    queueCB->queueSize = msgSize;
    queueCB->queue = queue;
    queueCB->queueState = OS_QUEUE_INUSED;
    queueCB->readWriteableCnt[OS_QUEUE_READ] = 0;
    queueCB->readWriteableCnt[OS_QUEUE_WRITE] = len;
    queueCB->queueHead = 0;
    queueCB->queueTail = 0;
⑹  LOS_ListInit(&queueCB->readWriteList[OS_QUEUE_READ]);
    LOS_ListInit(&queueCB->readWriteList[OS_QUEUE_WRITE]);
    LOS_ListInit(&queueCB->memList);
    LOS_IntRestore(intSave);

⑺  *queueID = queueCB->queueID;

    OsHookCall(LOS_HOOK_TYPE_QUEUE_CREATE, queueCB);

    return LOS_OK;
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}"> class="hide-preCode-box">
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

3.2 队列删除

我们可以使用函数LOS_QueueDelete(UINT32 queueID)来删除队列，下面通过分析源码看看如何删除队列的。

⑴处判断队列queueID是否超过LOSCFG_BASE_IPC_QUEUE_LIMIT，如果超过则返回错误码。如果队列编号没有问题，获取队列控制块LosQueueCB *queueCB。⑵处判断要删除的队列处于未使用状态，则跳转到错误标签QUEUE_END进行处理。⑶如果队列的阻塞读、阻塞写任务列表不为空，或内存节点链表不为空，则不允许删除，跳转到错误标签进行处理。⑷处检验队列的可读、可写数量是否出错。

⑸处使用指针UINT8 *queue保存队列的内存空间，⑹处把.queue置空，把.queueState设置为未使用OS_QUEUE_UNUSED，并把队列节点插入未使用队列双向链表g_freeQueueList。接下来会需要调用⑺处函数LOS_MemFree()释放队列内存空间。

LITE_OS_SEC_TEXT_INIT UINT32 LOS_QueueDelete(UINT32 queueID)
{
    LosQueueCB *queueCB = NULL;
    UINT8 *queue = NULL;
    UINT32 intSave;
    UINT32 ret;

⑴  if (queueID >= LOSCFG_BASE_IPC_QUEUE_LIMIT) {
        return LOS_ERRNO_QUEUE_NOT_FOUND;
    }

    intSave = LOS_IntLock();
    queueCB = (LosQueueCB *)GET_QUEUE_HANDLE(queueID);
⑵  if (queueCB->queueState == OS_QUEUE_UNUSED) {
        ret = LOS_ERRNO_QUEUE_NOT_CREATE;
        goto QUEUE_END;
    }

⑶  if (!LOS_ListEmpty(&queueCB->readWriteList[OS_QUEUE_READ])) {
        ret = LOS_ERRNO_QUEUE_IN_TSKUSE;
        goto QUEUE_END;
    }

    if (!LOS_ListEmpty(&queueCB->readWriteList[OS_QUEUE_WRITE])) {
        ret = LOS_ERRNO_QUEUE_IN_TSKUSE;
        goto QUEUE_END;
    }

    if (!LOS_ListEmpty(&queueCB->memList)) {
        ret = LOS_ERRNO_QUEUE_IN_TSKUSE;
        goto QUEUE_END;
    }

⑷  if ((queueCB->readWriteableCnt[OS_QUEUE_WRITE] + queueCB->readWriteableCnt[OS_QUEUE_READ]) !=
        queueCB->queueLen) {
        ret = LOS_ERRNO_QUEUE_IN_TSKWRITE;
        goto QUEUE_END;
    }

⑸  queue = queueCB->queue;
⑹  queueCB->queue = (UINT8 *)NULL;
    queueCB->queueState = OS_QUEUE_UNUSED;
    LOS_ListAdd(&g_freeQueueList, &queueCB->readWriteList[OS_QUEUE_WRITE]);
    LOS_IntRestore(intSave);

    OsHookCall(LOS_HOOK_TYPE_QUEUE_DELETE, queueCB);

⑺  ret = LOS_MemFree(m_aucSysMem0, (VOID *)queue);
    return ret;

QUEUE_END:
    LOS_IntRestore(intSave);
    return ret;
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}"> class="hide-preCode-box">
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

下面就来看看队列的读写，有2点需要注意：

• 队首、队尾的读写

只支持队首读取，不能队尾读取，否则就不算队列了。除了正常的队尾写消息外，还提供插队机制，支持从队首写入。

• 队列消息数据内容

往队列中写入的消息的类型有2种，即支持按地址写入和按值写入（带拷贝）。按哪种类型写入，就需要配对的按相应的类型去读取。

队列读取接口的类别，归纳如下：

3.3 队列读取

我们知道有2个队列读取方法，按指针地址读取的函数LOS_QueueRead()和按消息数值读取的函数LOS_QueueReadCopy()。我们先看下函数LOS_QueueRead()，该函数的参数有4个，队列编号queueID，存放读取到的消息的缓冲区地址*bufferAddr，存放读取到的消息的缓冲区大小bufferSize，读队列消息的等待超时时间timeOut。代码如下，我们分析下代码。

⑴处校验传入参数，队列编号不能超出限制，传入的指针不能为空，缓冲大小不能为0。如果timeout不为零，不能在中断中读取队列。⑵处操作类型表示队首读取消息指针，然后调用函数OsQueueOperate()进一步操作队列。

LITE_OS_SEC_TEXT UINT32 LOS_QueueRead(UINT32 queueID, VOID *bufferAddr, UINT32 bufferSize, UINT32 timeOut)
{
    UINT32 ret;
    UINT32 operateType;

⑴  ret = OsQueueReadParameterCheck(queueID, bufferAddr, &bufferSize, timeOut);
    if (ret != LOS_OK) {
        return ret;
    }

⑵  operateType = OS_QUEUE_OPERATE_TYPE(OS_QUEUE_READ, OS_QUEUE_HEAD, OS_QUEUE_POINT);

    OsHookCall(LOS_HOOK_TYPE_QUEUE_READ, (LosQueueCB *)GET_QUEUE_HANDLE(queueID));

    return OsQueueOperate(queueID, operateType, bufferAddr, &bufferSize, timeOut);
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}"> class="hide-preCode-box">
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

我们进一步分析下函数OsQueueOperate()，这是是比较通用的封装，读取，写入都会调用这个函数，我们以读取队列为例分析这个函数。⑴处获取队列的操作类型，为读取操作。⑵处先调用函数OsQueueOperateParamCheck()进行参数校验，校验队列是使用中的队列，并对读写消息大小进行校验。⑶处如果可读数量为0，无法读取时，如果是零等待则返回错误码。如果当前锁任务调度，跳出函数执行。否则，执行⑷把当前任务放入队列的读取消息阻塞队列，然后触发任务调度，后续的代码暂时不再执行。如果可读的数量不为0，可以继续读取时，执行⑹处代码把可读数量减1，然后继续执行⑺处代码读取队列。

等读取队列阻塞超时，或者队列可以读取后，继续执行⑸处的代码。如果是发生超时，队列还不能读取，更改任务状态，跳出函数执行。如果队列可以读取了，继续执行⑺处代码读取队列。⑻处在成功读取队列后，如果有任务阻塞在写入队列，则获取阻塞链表中的第一个任务resumedTask，然后调用唤醒函数OsSchedTaskWake()把待恢复的任务放入就绪队列，触发一次任务调度。如果无阻塞任务，则把可写入的数量加1。

UINT32 OsQueueOperate(UINT32 queueID, UINT32 operateType, VOID *bufferAddr, UINT32 *bufferSize, UINT32 timeOut)
{
    LosQueueCB *queueCB = NULL;
    LosTaskCB *resumedTask = NULL;
    UINT32 ret;
⑴  UINT32 readWrite = OS_QUEUE_READ_WRITE_GET(operateType);
    UINT32 readWriteTmp = !readWrite;

    UINT32 intSave = LOS_IntLock();

    queueCB = (LosQueueCB *)GET_QUEUE_HANDLE(queueID);
⑵  ret = OsQueueOperateParamCheck(queueCB, operateType, bufferSize);
    if (ret != LOS_OK) {
        goto QUEUE_END;
    }

⑶  if (queueCB->readWriteableCnt[readWrite] == 0) {
        if (timeOut == LOS_NO_WAIT) {
            ret = OS_QUEUE_IS_READ(operateType) ? LOS_ERRNO_QUEUE_ISEMPTY : LOS_ERRNO_QUEUE_ISFULL;
            goto QUEUE_END;
        }

        if (g_losTaskLock) {
            ret = LOS_ERRNO_QUEUE_PEND_IN_LOCK;
            goto QUEUE_END;
        }

        LosTaskCB *runTsk = (LosTaskCB *)g_losTask.runTask;
⑷      OsSchedTaskWait(&queueCB->readWriteList[readWrite], timeOut);
        LOS_IntRestore(intSave);
        LOS_Schedule();

        intSave = LOS_IntLock();
⑸      if (runTsk->taskStatus & OS_TASK_STATUS_TIMEOUT) {
            runTsk->taskStatus &= ~OS_TASK_STATUS_TIMEOUT;
            ret = LOS_ERRNO_QUEUE_TIMEOUT;
            goto QUEUE_END;
        }
    } else {
⑹       queueCB->readWriteableCnt[readWrite]--;
    }

⑺   OsQueueBufferOperate(queueCB, operateType, bufferAddr, bufferSize);

⑻  if (!LOS_ListEmpty(&queueCB->readWriteList[readWriteTmp])) {
        resumedTask = OS_TCB_FROM_PENDLIST(LOS_DL_LIST_FIRST(&queueCB->readWriteList[readWriteTmp]));
        OsSchedTaskWake(resumedTask);
        LOS_IntRestore(intSave);
        LOS_Schedule();
        return LOS_OK;
    } else {
⑼      queueCB->readWriteableCnt[readWriteTmp]++;
    }

QUEUE_END:
    LOS_IntRestore(intSave);
    return ret;
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}"> class="hide-preCode-box">
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

我们再继续看下函数OsQueueBufferOperate()是具体如何读取队列的。⑴处switch-case语句根据操作类型获取操作位置。对于⑵头部读取的情况，先获取读取位置queuePosition。然后，如果当前头节点位置.queueHead加1等于队列消息长度，头节点位置.queueHead设置为0，否则加1。对于⑶头部写入的情况，如果当前头节点位置.queueHead等于0，头节点位置.queueHead设置为队列消息长度减1即queueCB->queueLen - 1，否则头节点位置.queueHead减1即可。然后，获取要写入的位置queuePosition。对于⑷尾部写入的情况，先获取写入位置queuePosition。然后，如果当前尾节点位置.queueTail加1等于队列消息长度，尾节点位置.queueTail设置为0，否则加1。

⑸处基于获取的队列读取位置获取队列消息节点queueNode。⑹处判断操作类型如果是按指针读写消息，直接读取消息节点的数据写入指针对应的缓冲区*(UINT32 *)bufferAddr，或直接把指针对应的缓冲区*(UINT32 *)bufferAddr数据写入消息节点即可。我们接着看如何按数数据读写消息，⑺处代码用于读取数据消息。每个消息节点的后4个字节保存的是消息的长度，首先获取消息的长度msgDataSize，然后把消息内容读取到bufferAddr。再看看⑻处如何写入队列消息，首先把消息内容写入到queueNode，然后再把消息长度的内容写入到queueNode + queueCB->queueSize - sizeof(UINT32)，就是每个消息节点的后4字节。

static INLINE VOID OsQueueBufferOperate(LosQueueCB *queueCB, UINT32 operateType,
                                                                VOID *bufferAddr, UINT32 *bufferSize)
{
    UINT8 *queueNode = NULL;
    UINT32 msgDataSize;
    UINT16 queuePosion;
    errno_t rc;

    /* get the queue position */
⑴  switch (OS_QUEUE_OPERATE_GET(operateType)) {
        case OS_QUEUE_READ_HEAD:
⑵          queuePosion = queueCB->queueHead;
            ((queueCB->queueHead + 1) == queueCB->queueLen) ? (queueCB->queueHead = 0) : (queueCB->queueHead++);
            break;

        case OS_QUEUE_WRITE_HEAD:
⑶          (queueCB->queueHead == 0) ? (queueCB->queueHead = (queueCB->queueLen - 1)) : (--queueCB->queueHead);
            queuePosion = queueCB->queueHead;
            break;

        case OS_QUEUE_WRITE_TAIL:
⑷          queuePosion = queueCB->queueTail;
            ((queueCB->queueTail + 1) == queueCB->queueLen) ? (queueCB->queueTail = 0) : (queueCB->queueTail++);
            break;

        default:
            PRINT_ERR("invalid queue operate type!\n");
            return;
    }

⑸  queueNode = &(queueCB->queue[(queuePosion * (queueCB->queueSize))]);

⑹  if (OS_QUEUE_IS_POINT(operateType)) {
      if (OS_QUEUE_IS_READ(operateType)) {
            *(UINT32 *)bufferAddr = *(UINT32 *)(VOID *)queueNode;
        } else {
            *(UINT32 *)(VOID *)queueNode = *(UINT32 *)bufferAddr;  // change to pp when calling OsQueueOperate
        }
    } else {
⑺      if (OS_QUEUE_IS_READ(operateType)) {
            msgDataSize = *((UINT32 *)(UINTPTR)((queueNode + queueCB->queueSize) - sizeof(UINT32)));
            rc = memcpy_s((VOID *)bufferAddr, *bufferSize, (VOID *)queueNode, msgDataSize);
            if (rc != EOK) {
                PRINT_ERR("%s[%d] memcpy failed, error type = %u\n", __FUNCTION__, __LINE__, rc);
                return;
            }

            *bufferSize = msgDataSize;
        } else {
⑻          *((UINT32 *)(UINTPTR)((queueNode + queueCB->queueSize) - sizeof(UINT32))) = *bufferSize;
            rc = memcpy_s((VOID *)queueNode, queueCB->queueSize, (VOID *)bufferAddr, *bufferSize);
            if (rc != EOK) {
                PRINT_ERR("%s[%d] memcpy failed, error type = %u\n", __FUNCTION__, __LINE__, rc);
                return;
            }
        }
    }
}
 class="hljs-button signin active" data-title="登录复制" data-report-click="{"spm":"1001.2101.3001.4334"}"> class="hide-preCode-box">
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

3.4 队列写入

我们知道，有4个队列写入方法，2个队尾写入，2个队首写入，分别包含按指针地址写入消息和按数值写入消息。LOS_QueueWrite()会调用LOS_QueueWriteCopy()，LOS_QueueWriteHead()会调用LOS_QueueWriteHeadCopy()，然后指定不同的操作类型后，会进一步调用前文已经分析过的函数OsQueueOperate()。

小结

本文带领大家一起剖析了鸿蒙轻内核的队列模块的源代码，包含队列的结构体、队列池初始化、队列创建删除、读写消息等。

如果大家想更加深入的学习 OpenHarmony 开发的内容，不妨可以参考以下相关学习文档进行学习，助你快速提升自己：

OpenHarmony 开发环境搭建：https://qr18.cn/CgxrRy

《OpenHarmony源码解析》：https://qr18.cn/CgxrRy

• 搭建开发环境
• Windows 开发环境的搭建
• Ubuntu 开发环境搭建
• Linux 与 Windows 之间的文件共享
• ……
  

系统架构分析：https://qr18.cn/CgxrRy

• 构建子系统
• 启动流程
• 子系统
• 分布式任务调度子系统
• 分布式通信子系统
• 驱动子系统
• ……

OpenHarmony 设备开发学习手册：https://qr18.cn/CgxrRy

OpenHarmony面试题（内含参考答案）：https://qr18.cn/CgxrRy

发表评论

登录后才能发表评论和回复 注册

/ 登录

提交评论

评论记录：

未查询到任何数据！

回复评论：

×

关闭 提交评论