02 Binder 系列 : Binder Driver 初探(1)

九路
• 阅读 1406

基于Android 6.0的源码剖析,在讲解Binder原理之前,先从kernel的角度来讲解Binder Driver.

    kernel/drivers/ (不同Linux分支路径略有不同)
      - staging/android/binder.c
      - android/binder.c 

一、Binder驱动概述

1.1 概述

Binder驱动是Android专用的,但底层的驱动架构与Linux驱动一样。binder驱动在以misc设备进行注册,作为虚拟字符设备,没有直接操作硬件,只是对设备内存的处理。主要是驱动设备的初始化(binder_init),打开(binder_open),映射(binder_mmap),数据操作(binder_ioctl)。

02 Binder 系列 : Binder Driver 初探(1)

1.2 系统调用

用户态的程序调用Kernel层驱动是需要陷入内核态,进行系统调用(syscall),比如打开Binder驱动方法的调用链为: open-> open() -> binder_open()。 open()为用户空间的方法,open()便是系统调用中相应的处理方法,通过查找,对应调用到内核binder驱动的binder_open()方法,至于其他的从用户态陷入内核态的流程也基本一致。

02 Binder 系列 : Binder Driver 初探(1)

简单说,当用户空间调用open()方法,最终会调用binder驱动的binder_open()方法;mmap()/ioctl()方法也是同理,在BInder系列的后续文章从用户态进入内核态,都依赖于系统调用过程。

二、 Binder核心方法

2.1 binder_init

主要工作是为了注册misc设备

    static int __init binder_init(void)
    {
        int ret;
        //创建名为binder的工作队列
        binder_deferred_workqueue = create_singlethread_workqueue("binder");
        ...

        binder_debugfs_dir_entry_root = debugfs_create_dir("binder", NULL);
        if (binder_debugfs_dir_entry_root)
            binder_debugfs_dir_entry_proc = debugfs_create_dir("proc",
                             binder_debugfs_dir_entry_root);

         // 注册misc设备【见小节2.1.1】
        ret = misc_register(&binder_miscdev);
        if (binder_debugfs_dir_entry_root) {
            ... //在debugfs文件系统中创建一系列的文件
        }
        return ret;
    }

debugfs_create_dir是指在debugfs文件系统中创建一个目录,返回值是指向dentry的指针。当kernel中禁用debugfs的话,返回值是-%ENODEV。默认是禁用的。如果需要打开,在目录/kernel/arch/arm64/configs/下找到目标defconfig文件中添加一行CONFIG_DEBUG_FS=y,再重新编译版本,即可打开debug_fs。

2.1.1 misc_register

注册misc设备,miscdevice结构体,便是前面注册misc设备时传递进去的参数

    static struct miscdevice binder_miscdev = {
        .minor = MISC_DYNAMIC_MINOR, //次设备号 动态分配
        .name = "binder",     //设备名
        .fops = &binder_fops  //设备的文件操作结构,这是file_operations结构
    };

file_operations结构体,指定相应文件操作的方法

    static const struct file_operations binder_fops = {
        .owner = THIS_MODULE,
        .poll = binder_poll,
        .unlocked_ioctl = binder_ioctl,
        .compat_ioctl = binder_ioctl,
        .mmap = binder_mmap,
        .open = binder_open,
        .flush = binder_flush,
        .release = binder_release,
    };

2.2 binder_open

打开binder驱动设备

    static int binder_open(struct inode *nodp, struct file *filp)
    {
        struct binder_proc *proc; // binder进程 【见附录3.1】

        proc = kzalloc(sizeof(*proc), GFP_KERNEL); // 为binder_proc结构体在分配kernel内存空间
        if (proc == NULL)
            return -ENOMEM;
        get_task_struct(current);
        proc->tsk = current;   //将当前线程的task保存到binder进程的tsk
        INIT_LIST_HEAD(&proc->todo); //初始化todo列表
        init_waitqueue_head(&proc->wait); //初始化wait队列
        proc->default_priority = task_nice(current);  //将当前进程的nice值转换为进程优先级

        binder_lock(__func__);   //同步锁,因为binder支持多线程访问
        binder_stats_created(BINDER_STAT_PROC); //BINDER_PROC对象创建数加1
        hlist_add_head(&proc->proc_node, &binder_procs); //将proc_node节点添加到binder_procs为表头的队列
        proc->pid = current->group_leader->pid;
        INIT_LIST_HEAD(&proc->delivered_death); //初始化已分发的死亡通知列表
        filp->private_data = proc;       //file文件指针的private_data变量指向binder_proc数据
        binder_unlock(__func__); //释放同步锁

        return 0;
    }

创建binder_proc对象,并把当前进程等信息保存到binder_proc对象,该对象管理IPC所需的各种信息并拥有其他结构体的根结构体;再把binder_proc对象保存到文件指针filp,以及把binder_proc加入到全局链表binder_procs

02 Binder 系列 : Binder Driver 初探(1)

Binder驱动中通过static HLIST_HEAD(binder_procs);,创建了全局的哈希链表binder_procs,用于保存所有的binder_proc队列,每次新创建的binder_proc对象都会加入binder_procs链表中。

2.3 binder_mmap

binder_mmap(文件描述符,用户虚拟内存空间)

主要功能:首先在内核虚拟地址空间,申请一块与用户虚拟内存相同大小的内存;然后再申请1个page大小的物理内存,再将同一块物理内存分别映射到内核虚拟地址空间和用户虚拟内存空间,从而实现了用户空间的Buffer和内核空间的Buffer同步操作的功能。

    static int binder_mmap(struct file *filp, struct vm_area_struct *vma)
    {
        int ret;
        struct vm_struct *area; //内核虚拟空间
        struct binder_proc *proc = filp->private_data;
        const char *failure_string;
        struct binder_buffer *buffer;  //【见附录3.9】

        if (proc->tsk != current)
            return -EINVAL;

        if ((vma->vm_end - vma->vm_start) > SZ_4M)
            vma->vm_end = vma->vm_start + SZ_4M;  //保证映射内存大小不超过4M

        mutex_lock(&binder_mmap_lock);  //同步锁
        //采用IOREMAP方式,分配一个连续的内核虚拟空间,与进程虚拟空间大小一致
        area = get_vm_area(vma->vm_end - vma->vm_start, VM_IOREMAP);
        if (area == NULL) {
            ret = -ENOMEM;
            failure_string = "get_vm_area";
            goto err_get_vm_area_failed;
        }
        proc->buffer = area->addr; //指向内核虚拟空间的地址
        //地址偏移量 = 用户虚拟地址空间 - 内核虚拟地址空间
        proc->user_buffer_offset = vma->vm_start - (uintptr_t)proc->buffer;
        mutex_unlock(&binder_mmap_lock); //释放锁

        ...
        //分配物理页的指针数组,数组大小为vma的等效page个数;
        proc->pages = kzalloc(sizeof(proc->pages[0]) * ((vma->vm_end - vma->vm_start) / PAGE_SIZE), GFP_KERNEL);
        if (proc->pages == NULL) {
            ret = -ENOMEM;
            failure_string = "alloc page array";
            goto err_alloc_pages_failed;
        }
        proc->buffer_size = vma->vm_end - vma->vm_start;

        vma->vm_ops = &binder_vm_ops;
        vma->vm_private_data = proc;

        //分配物理页面,同时映射到内核空间和进程空间,先分配1个物理页 【见小节2.3.1】
        if (binder_update_page_range(proc, 1, proc->buffer, proc->buffer + PAGE_SIZE, vma)) {
            ret = -ENOMEM;
            failure_string = "alloc small buf";
            goto err_alloc_small_buf_failed;
        }
        buffer = proc->buffer; //binder_buffer对象 指向proc的buffer地址
        INIT_LIST_HEAD(&proc->buffers); //创建进程的buffers链表头
        list_add(&buffer->entry, &proc->buffers); //将binder_buffer地址 加入到所属进程的buffers队列
        buffer->free = 1;
        //将空闲buffer放入proc->free_buffers中
        binder_insert_free_buffer(proc, buffer);
        //异步可用空间大小为buffer总大小的一半。
        proc->free_async_space = proc->buffer_size / 2;
        barrier();
        proc->files = get_files_struct(current);
        proc->vma = vma;
        proc->vma_vm_mm = vma->vm_mm;
        return 0;

        ...// 错误flags跳转处,free释放内存之类的操作
        return ret;
    }

binder_mmap通过加锁,保证一次只有一个进程分配内存,保证多进程间的并发访问。其中user_buffer_offset是虚拟进程地址与虚拟内核地址的差值(该值为负数)。也就是说同一物理地址,当内核地址为kernel_addr,则进程地址为proc_addr = kernel_addr + user_buffer_offset。

2.3.1 binder_update_page_range

  static int binder_update_page_range(struct binder_proc *proc, int allocate,
                void *start, void *end,
                struct vm_area_struct *vma)
    {
      void *page_addr;
      unsigned long user_page_addr;
      struct page **page;
      struct mm_struct *mm; // 内存结构体

      if (vma)
              mm = NULL; //binder_mmap过程vma不为空,其他情况都为空
          else
              mm = get_task_mm(proc->tsk); //获取mm结构体

      if (mm) {
        down_write(&mm->mmap_sem); //获取mm_struct的写信号量
        vma = proc->vma;
      }

      //此处allocate为1,代表分配过程。如果为0则代表释放过程
      if (allocate == 0)
        goto free_range;

      for (page_addr = start; page_addr < end; page_addr += PAGE_SIZE) {
        int ret;
        page = &proc->pages[(page_addr - proc->buffer) / PAGE_SIZE];
        //分配一个page的物理内存
        *page = alloc_page(GFP_KERNEL | __GFP_HIGHMEM | __GFP_ZERO);

        //物理空间映射到虚拟内核空间
        ret = map_kernel_range_noflush((unsigned long)page_addr,
              PAGE_SIZE, PAGE_KERNEL, page);
        flush_cache_vmap((unsigned long)page_addr, (unsigned long)page_addr + PAGE_SIZE);

        user_page_addr = (uintptr_t)page_addr + proc->user_buffer_offset;
        //物理空间映射到虚拟进程空间
        ret = vm_insert_page(vma, user_page_addr, page[0]);
      }

      if (mm) {
        up_write(&mm->mmap_sem); //释放内存的写信号量
        mmput(mm); //减少mm->mm_users计数
      }
      return 0;

    free_range:
      ... //释放内存的流程

      return -ENOMEM;
    }

主要工作如下:

02 Binder 系列 : Binder Driver 初探(1)

binder_update_page_range主要完成工作:分配物理空间,将物理空间映射到内核空间,将物理空间映射到进程空间. 另外,不同参数下该方法也可以释放物理页面。

binder_update_page_range的调用时机:

- binder_mmap: 用于分配内存,分配大小为1page, vma不为空;
- binder_alloc_buf:用于分配内存,vma为空;
- binder_free_buf: 用于释放内存,vma为空;
- binder_delete_free_buffer:同样用于释放内存,vma为空。

关于mm_struct结构体,定义在mm_types.h文件:

    struct mm_struct {
      struct vm_area_struct *mmap;  //VMA列表
      struct rb_root mm_rb;
      pgd_t * pgd;
      atomic_t mm_users;      //使用该内存的进程个数
      atomic_t mm_count;      //结构体mm_struct的引用个数
      struct rw_semaphore mmap_sem; //读写信号量,用于同步
      unsigned long flags; 
      ...
    };

下面,再说一说binder_alloc_buf过程

2.3.2 binder_alloc_buf

通过binder_alloc_buf()方法来分配binder_buffer结构体, 只有在binder_transaction过程才需要分配buffer.

    static struct binder_buffer *binder_alloc_buf(struct binder_proc *proc,
                              size_t data_size, size_t offsets_size, int is_async)
    {
        struct rb_node *n = proc->free_buffers.rb_node;
        struct binder_buffer *buffer;
        size_t buffer_size;
        struct rb_node *best_fit = NULL;
        void *has_page_addr;
        void *end_page_addr;
        size_t size;
        if (proc->vma == NULL) {
            return NULL; //虚拟地址空间为空,直接返回
        }
        size = ALIGN(data_size, sizeof(void *)) + ALIGN(offsets_size, sizeof(void *));
        if (size < data_size || size < offsets_size) {
            return NULL; //非法的size
        }
        if (is_async && proc->free_async_space < size + sizeof(struct binder_buffer)) {
            return NULL; // 剩余可用的异步空间,小于所需的大小
        }
        while (n) {  //从binder_buffer的红黑树中查找大小相等的buffer块
            buffer = rb_entry(n, struct binder_buffer, rb_node);
            buffer_size = binder_buffer_size(proc, buffer);
            if (size < buffer_size) {
                best_fit = n;
                n = n->rb_left;
            } else if (size > buffer_size)
                n = n->rb_right;
            else {
                best_fit = n;
                break;
            }
        }
        if (best_fit == NULL) {
            return NULL; //内存分配失败,地址空间为空
        }
        if (n == NULL) {
            buffer = rb_entry(best_fit, struct binder_buffer, rb_node);
            buffer_size = binder_buffer_size(proc, buffer);
        }

        has_page_addr =(void *)(((uintptr_t)buffer->data + buffer_size) & PAGE_MASK);
        if (n == NULL) {
            if (size + sizeof(struct binder_buffer) + 4 >= buffer_size)
                buffer_size = size;
            else
                buffer_size = size + sizeof(struct binder_buffer);
        }
        end_page_addr =     (void *)PAGE_ALIGN((uintptr_t)buffer->data + buffer_size);
        if (end_page_addr > has_page_addr)
            end_page_addr = has_page_addr;
        if (binder_update_page_range(proc, 1,
            (void *)PAGE_ALIGN((uintptr_t)buffer->data), end_page_addr, NULL))
            return NULL;
        rb_erase(best_fit, &proc->free_buffers);
        buffer->free = 0;
        binder_insert_allocated_buffer(proc, buffer);
        if (buffer_size != size) {
            struct binder_buffer *new_buffer = (void *)buffer->data + size;
            list_add(&new_buffer->entry, &buffer->entry);
            new_buffer->free = 1;
            binder_insert_free_buffer(proc, new_buffer);
        }

        buffer->data_size = data_size;
        buffer->offsets_size = offsets_size;
        buffer->async_transaction = is_async;
        if (is_async) {
            proc->free_async_space -= size + sizeof(struct binder_buffer);
        }
        return buffer;
    }

这里介绍的binder_alloc_buf是内存分配函数。除此之外,还有内存释放相关方法:

  • binder_free_buf
  • binder_delete_free_buffer
  • binder_transaction_buffer_release

这里涉及强弱引用相关函数的操作: | 强/弱引用操作函数 | 功能 | | --- | --- | | binder_inc_ref(ref,0,NULL) | binder_ref->weak++ | | binder_inc_ref(ref,1,NULL) | binder_ref->strong++,或binder_node->internal_strong_refs++ | | binder_dec_ref(&ref,0) | binder_ref->weak-- | | binder_dec_ref(&ref,1) | binder_ref->strong--, 或binder_node->internal_strong_refs-- | | binder_dec_node(node, 0, 0) | binder_node->pending_weak_ref = 0,且binder_node->local_weak_ref-- | | binder_dec_node(node, 1, 0) | binder_node->pending_strong_ref = 0,且binder_node->local_strong_ref-- |

2.4 binder_ioctl

binder_ioctl()函数负责在两个进程间收发IPC数据和IPC reply数据。

ioctl(文件描述符,ioctl命令,数据类型)

(1) 文件描述符,是通过open()方法打开Binder Driver后返回值;

(2) ioctl命令和数据类型是一体的,不同的命令对应不同的数据类型

ioctl命令 数据类型 操作
BINDER_WRITE_READ struct binder_write_read 收发Binder IPC数据
BINDER_SET_MAX_THREADS __u32 设置Binder线程最大个数
BINDER_SET_CONTEXT_MGR __s32 设置Service Manager节点
BINDER_THREAD_EXIT __s32 释放Binder线程
BINDER_VERSION struct binder_version 获取Binder版本信息
BINDER_SET_IDLE_TIMEOUT __s64 没有使用
BINDER_SET_IDLE_PRIORITY __s32 没有使用

这些命令中BINDER_WRITE_READ命令使用率最为频繁,也是ioctl最为核心的命令。

源码:

    static long binder_ioctl(struct file *filp, unsigned int cmd, unsigned long arg)
    {
        int ret;
        struct binder_proc *proc = filp->private_data;
        struct binder_thread *thread;  // binder线程
        unsigned int size = _IOC_SIZE(cmd);
        void __user *ubuf = (void __user *)arg;
        //进入休眠状态,直到中断唤醒
        ret = wait_event_interruptible(binder_user_error_wait, binder_stop_on_user_error < 2);
        if (ret)
            goto err_unlocked;

        binder_lock(__func__);
        //获取binder_thread【见2.4.1】
        thread = binder_get_thread(proc);
        if (thread == NULL) {
            ret = -ENOMEM;
            goto err;
        }

        switch (cmd) {
        case BINDER_WRITE_READ:  //进行binder的读写操作
            ret = binder_ioctl_write_read(filp, cmd, arg, thread); //【见2.4.2】
            if (ret)
                goto err;
            break;
        case BINDER_SET_MAX_THREADS: //设置binder最大支持的线程数
            if (copy_from_user(&proc->max_threads, ubuf, sizeof(proc->max_threads))) {
                ret = -EINVAL;
                goto err;
            }
            break;
        case BINDER_SET_CONTEXT_MGR: //成为binder的上下文管理者,也就是ServiceManager成为守护进程
            ret = binder_ioctl_set_ctx_mgr(filp);
            if (ret)
                goto err;
            break;
        case BINDER_THREAD_EXIT:   //当binder线程退出,释放binder线程
            binder_free_thread(proc, thread);
            thread = NULL;
            break;
        case BINDER_VERSION: {  //获取binder的版本号
            struct binder_version __user *ver = ubuf;

            if (size != sizeof(struct binder_version)) {
                ret = -EINVAL;
                goto err;
            }
            if (put_user(BINDER_CURRENT_PROTOCOL_VERSION,
                     &ver->protocol_version)) {
                ret = -EINVAL;
                goto err;
            }
            break;
        }
        default:
            ret = -EINVAL;
            goto err;
        }
        ret = 0;
    err:
        if (thread)
            thread->looper &= ~BINDER_LOOPER_STATE_NEED_RETURN;
        binder_unlock(__func__);
        wait_event_interruptible(binder_user_error_wait, binder_stop_on_user_error < 2);

    err_unlocked:
        trace_binder_ioctl_done(ret);
        return ret;
    }

执行ioctl过程,便需要加上binder lock.

2.4.1 binder_get_thread

从binder_proc中查找binder_thread,如果当前线程已经加入到proc的线程队列则直接返回,如果不存在则创建binder_thread,并将当前线程添加到当前的proc

    static struct binder_thread *binder_get_thread(struct binder_proc *proc)
    {
        struct binder_thread *thread = NULL;
        struct rb_node *parent = NULL;
        struct rb_node **p = &proc->threads.rb_node;
        while (*p) {  //根据当前进程的pid,从binder_proc中查找相应的binder_thread
            parent = *p;
            thread = rb_entry(parent, struct binder_thread, rb_node);
            if (current->pid < thread->pid)
                p = &(*p)->rb_left;
            else if (current->pid > thread->pid)
                p = &(*p)->rb_right;
            else
                break;
        }
        if (*p == NULL) {
            thread = kzalloc(sizeof(*thread), GFP_KERNEL); //新建binder_thread结构体
            if (thread == NULL)
                return NULL;
            binder_stats_created(BINDER_STAT_THREAD);
            thread->proc = proc;
            thread->pid = current->pid;  //保存当前进程(线程)的pid
            init_waitqueue_head(&thread->wait);
            INIT_LIST_HEAD(&thread->todo);
            rb_link_node(&thread->rb_node, parent, p);
            rb_insert_color(&thread->rb_node, &proc->threads);
            thread->looper |= BINDER_LOOPER_STATE_NEED_RETURN;
            thread->return_error = BR_OK;
            thread->return_error2 = BR_OK;
        }
        return thread;
    }

2.4.2 binder_ioctl_write_read

对于ioctl()方法中,传递进来的命令是cmd = BINDER_WRITE_READ时执行该方法,arg是一个binder_write_read结构体

    static int binder_ioctl_write_read(struct file *filp,
                    unsigned int cmd, unsigned long arg,
                    struct binder_thread *thread)
    {
        int ret = 0;
        struct binder_proc *proc = filp->private_data;
        unsigned int size = _IOC_SIZE(cmd);
        void __user *ubuf = (void __user *)arg;
        struct binder_write_read bwr;

        if (size != sizeof(struct binder_write_read)) {
            ret = -EINVAL;
            goto out;
        }
        if (copy_from_user(&bwr, ubuf, sizeof(bwr))) { //把用户空间数据ubuf拷贝到bwr
            ret = -EFAULT;
            goto out;
        }

        if (bwr.write_size > 0) {
            //当写缓存中有数据,则执行binder写操作
            ret = binder_thread_write(proc, thread,
                          bwr.write_buffer, bwr.write_size, &bwr.write_consumed);
            trace_binder_write_done(ret);
            if (ret < 0) { //当写失败,再将bwr数据写回用户空间,并返回
                bwr.read_consumed = 0;
                if (copy_to_user(ubuf, &bwr, sizeof(bwr)))
                    ret = -EFAULT;
                goto out;
            }
        }
        if (bwr.read_size > 0) {
            //当读缓存中有数据,则执行binder读操作
            ret = binder_thread_read(proc, thread,
                          bwr.read_buffer, bwr.read_size, &bwr.read_consumed,
                          filp->f_flags & O_NONBLOCK);
            trace_binder_read_done(ret);
            if (!list_empty(&proc->todo))
                wake_up_interruptible(&proc->wait); //唤醒等待状态的线程
            if (ret < 0) { //当读失败,再将bwr数据写回用户空间,并返回
                if (copy_to_user(ubuf, &bwr, sizeof(bwr)))
                    ret = -EFAULT;
                goto out;
            }
        }

        if (copy_to_user(ubuf, &bwr, sizeof(bwr))) { //将内核数据bwr拷贝到用户空间ubuf
            ret = -EFAULT;
            goto out;
        }
    out:
        return ret;
    }

对于binder_ioctl_write_read的流程图,如下: 02 Binder 系列 : Binder Driver 初探(1)

流程:

  • 首先,把用户空间数据ubuf拷贝到内核空间bwr;
  • 当bwr写缓存有数据,则执行binder_thread_write;当写失败则将bwr数据写回用户空间并退出;
  • 当bwr读缓存有数据,则执行binder_thread_read;当读失败则再将bwr数据写回用户空间并退出;
  • 最后,把内核数据bwr拷贝到用户空间ubuf。

这里涉及两个核心方法binder_thread_write()和binder_thread_read()方法,在Binder系列的后续文章Binder Driver再探中详细介绍。

2.4 Command使用场景

ioctl命令常见命令的使用场景,其中BINDER_WRITE_READ最为频繁

  • BINDER_WRITE_READ
    • Binder读写交互场景,IPC.talkWithDriver
  • BINDER_SET_CONTEXT_MGR
    • servicemanager进程成为上下文管理者,binder_become_context_manager()
  • BINDER_SET_MAX_THREADS
    • 初始化ProcessState对象,open_driver()
    • 主动调整参数,ProcessState.setThreadPoolMaxThreadCount()
  • BINDER_VERSION
    • 初始化ProcessState对象,open_driver()

2.5 小节

  • binder_init:初始化字符设备;
  • binder_open:打开驱动设备,过程需要持有binder_main_lock同步锁;
  • binder_mmap:申请内存空间,该过程需要持有binder_mmap_lock同步锁;
  • binder_ioctl:执行相应的ioctl操作,该过程需要持有binder_main_lock同步锁;
    • 当处于binder_thread_read过程,read_buffer无数据则释放同步锁,并处于wait_event_freezable过程,等有数据到来则唤醒并尝试持有同步锁。

三、附录

下面列举Binder驱动相关的一些重要结构体

3.0 结构体列表

序号 结构体 名称 解释
1 binder_proc binder进程 每个进程调用open()打开binder驱动都会创建该结构体,用于管理IPC所需的各种信息
2 binder_thread binder线程 对应于上层的binder线程
3 binder_node binder实体 对应于BBinder对象,记录BBinder的进程、指针、引用计数等
4 binder_ref binder引用 对应于BpBinder对象,记录BpBinder的引用计数、死亡通知、BBinder指针等
5 binder_ref_death binder死亡引用 记录binder死亡的引用信息
6 binder_write_read binder读写 记录buffer中读和写的数据信息
7 binder_transaction_data binder事务数据 记录传输数据内容,比如发送方pid/uid,RPC数据
8 flat_binder_object binder扁平对象 Binder对象在两个进程间传递的扁平结构
9 binder_buffer binder内存 调用mmap()创建用于Binder传输数据的缓存区
10 binder_transaction binder事务 记录传输事务的发送方和接收方线程、进程等
11 binder_work binder工作 记录binder工作类型
12 binder_state binder状态

6~9 用于数据传输相关,其中binder_write_read,binder_transaction_data进程空间和内核空间是通用的。

BWR核心数据图表

02 Binder 系列 : Binder Driver 初探(1)

binder_write_read是整个Binder IPC过程,最为核心的数据结构之一。

3.1 binder_proc

binder_proc结构体:用于管理IPC所需的各种信息,拥有其他结构体的结构体。

类型 成员变量 解释
struct hlist_node proc_node 进程节点
struct rb_root threads binder_thread红黑树的根节点
struct rb_root nodes binder_node红黑树的根节点
struct rb_root refs_by_desc binder_ref红黑树的根节点(以handle为key)
struct rb_root refs_by_node binder_ref红黑树的根节点(以ptr为key)
int pid 相应进程id
struct vm_area_struct * vma 指向进程虚拟地址空间的指针
struct mm_struct * vma_vm_mm 相应进程的内存结构体
struct task_struct * tsk 相应进程的task结构体
struct files_struct * files 相应进程的文件结构体
struct hlist_node deferred_work_node
int deferred_work
void * buffer 内核空间的起始地址
ptrdiff_t user_buffer_offset 内核空间与用户空间的地址偏移量
struct list_head buffers 所有的buffer
struct rb_root free_buffers 空闲的buffer
struct rb_root allocated_buffers 已分配的buffer
size_t free_async_space 异步的可用空闲空间大小
struct page ** pages 指向物理内存页指针的指针
size_t buffer_size 映射的内核空间大小
uint32_t buffer_free 可用内存总大小
struct list_head todo 进程将要做的事
wait_queue_head_t wait 等待队列
struct binder_stats stats binder统计信息
struct list_head delivered_death 已分发的死亡通知
int max_threads 最大线程数
int requested_threads 请求的线程数
int requested_threads_started 已启动的请求线程数
int ready_threads 准备就绪的线程个数
long default_priority 默认优先级
struct dentry * debugfs_entry
* free_buffers:记录所有空闲的buffer,记录以buffer_size为key的binder_buffer的红黑树结构
* allocated_buffers:记录所有已分配的buffer,记录以buffer_size为key的binder_buffer的红黑树结构
* buffers: 所有buffer(包含空闲的和已分配的buffer)的按地址由从低到高都连入到buffers链表中
* ready_threads: 准备就绪的线程个数,往往是指进入binder_thread_read(),处于休眠等待状态的线程个数;ready_threads线程个数越多,代表系统越空闲。
* requested_threads_started:是指系统已经启动的线程个数,在方法binder_thread_write()中,执行一次BC_REGISTER_LOOPER,则requested_threads_started++,requested_threads--;上限为max_threads.BC_REGISTER_LOOPER次数与requested_threads_started个数应该相等;
* requested_threads:请求的线程个数,在方法binder_thread_read()中,当同时满足requested_threads_started小于最大线程数,没有ready_threads线程,且requested_threads=0,则执行requested_threads++。可见requested_threads取值要么为0,要么为1.

3.2 binder_thread

binder_thread结构体代表当前binder操作所在的线程

类型 成员变量 解释
struct binder_proc * proc 线程所属的进程
struct rb_node rb_node
int pid 线程pid
int looper looper的状态
struct binder_transaction * transaction_stack 线程正在处理的事务
struct list_head todo 将要处理的链表
uint32_t return_error write失败后,返回的错误码
uint32_t return_error2 write失败后,返回的错误码2
wait_queue_head_t wait 等待队列的队头
struct binder_stats stats binder线程的统计信息

looper的状态如下:

    enum {
        BINDER_LOOPER_STATE_REGISTERED  = 0x01, // 创建注册线程BC_REGISTER_LOOPER
        BINDER_LOOPER_STATE_ENTERED     = 0x02, // 创建主线程BC_ENTER_LOOPER
        BINDER_LOOPER_STATE_EXITED      = 0x04, // 已退出
        BINDER_LOOPER_STATE_INVALID     = 0x08, // 非法
        BINDER_LOOPER_STATE_WAITING     = 0x10, // 等待中
        BINDER_LOOPER_STATE_NEED_RETURN = 0x20, // 需要返回
    };

binder_thread_write()过程:

  • 收到 BC_REGISTER_LOOPER,则线程状态为BINDER_LOOPER_STATE_REGISTERED;
  • 收到 BC_ENTER_LOOPER,则线程状态为 BINDER_LOOPER_STATE_ENTERED;
  • 收到 BC_EXIT_LOOPER, 则线程状态为BINDER_LOOPER_STATE_EXITED;

其他3个状态的时机:

  • BINDER_LOOPER_STATE_WAITING:
    • 当停留在binder_thread_read()的wait_event_xxx过程, 则设置该状态;
  • BINDER_LOOPER_STATE_NEED_RETURN:
    • binder_get_thread()过程, 根据binder_proc查询不到当前线程所对应的binder_thread,会新建binder_thread对象;
    • binder_deferred_flush()过程;
  • BINDER_LOOPER_STATE_INVALID:
    • 当binder_thread创建过程状态不正确时会设置.

3.3 binder_node

binder_node代表一个binder实体

类型 成员变量 解释
int debug_id 节点创建时分配,具有全局唯一性,用于调试使用
struct binder_work work
struct rb_node rb_node binder节点正常使用,union
struct hlist_node dead_node binder节点已销毁,union
struct binder_proc * proc binder所在的进程
struct hlist_head refs 所有指向该节点的binder引用队列
int internal_strong_refs
int local_weak_refs
int local_strong_refs
binder_uintptr_t ptr 指向用户空间binder_node的指针
binder_uintptr_t cookie 附件数据
unsigned has_strong_ref 占位1bit
unsigned pending_strong_ref 占位1bit
unsigned has_weak_ref 占位1bit
unsigned pending_weak_ref 占位1bit
unsigned has_async_transaction 占位1bit
unsigned accept_fds 占位1bit
unsigned min_priority 占位8bit,最小优先级
struct list_head async_todo 异步todo队列

binder_node有一个联合类型:

    union {
            struct rb_node rb_node;
            struct hlist_node dead_node;
        };

当Binder对象已销毁,但还存在该Binder节点引用,则采用dead_node,并加入到全局列表binder_dead_nodes;否则使用rb_node节点。

另外:

  • binder_node.ptr对应于flat_binder_object.binder;
  • binder_node.cookie对应于flat_binder_object.cookie。

3.4 binder_ref

类型 成员变量 解释
int debug_id 用于调试使用
struct rb_node rb_node_desc 以desc为索引的红黑树
struct rb_node rb_node_node 以node为索引的红黑树
struct hlist_node node_entry
struct binder_proc * proc binder进程
struct binder_node * node binder节点
uint32_t desc handle
int strong 强引用次数
int weak 弱引用次数
struct binder_ref_death * death 当应用注册死亡通知时,此域不为空

binder引用的查询方式如下:

  • node + proc => ref (transaction)
  • desc + proc => ref (transaction, inc/dec ref)
  • node => refs + procs (proc exit)

3.5 binder_ref_death

    struct binder_ref_death {
        struct binder_work work;
        binder_uintptr_t cookie;
    };

cookie只是死亡通知的BpBinder代理对象的指针

3.6 binder_write_read

用户空间程序和Binder驱动程序交互基本都是通过BINDER_WRITE_READ命令,来进行数据的读写操作。

类型 成员变量 解释
binder_size_t write_size write_buffer的总字节数
binder_size_t write_consumed write_buffer已消费的字节数
binder_uintptr_t write_buffer 写缓冲数据的指针
binder_size_t read_size read_buffer的总字节数
binder_size_t read_consumed read_buffer已消费的字节数
binder_uintptr_t read_buffer 读缓存数据的指针
* write_buffer变量:用于发送IPC(或IPC reply)数据,即传递经由Binder Driver的数据时使用。
* read_buffer 变量:用于接收来自Binder Driver的数据,即Binder Driver在接收IPC(或IPC reply)数据后,保存到read_buffer,再传递到用户空间;
write_buffer和read_buffer都是包含Binder协议命令和binder_transaction_data结构体。

| | | | * copy_from_user()将用户空间IPC数据拷贝到内核态binder_write_read结构体; | | | | * copy_to_user()将用内核态binder_write_read结构体数据拷贝到用户空间;

3.7 binder_transaction_data

当BINDER_WRITE_READ命令的目标是本地Binder node时,target使用ptr,否则使用handle。只有当这是Binder node时,cookie才有意义,表示附加数据,由进程自己解释。

    struct binder_transaction_data {
        union {
            __u32    handle;       //binder_ref(即handle)
            binder_uintptr_t ptr;     //Binder_node的内存地址
        } target;  //RPC目标
        binder_uintptr_t    cookie;    //BBinder指针
        __u32        code;        //RPC代码,代表Client与Server双方约定的命令码

        __u32            flags; //标志位,比如TF_ONE_WAY代表异步,即不等待Server端回复
        pid_t        sender_pid;  //发送端进程的pid
        uid_t        sender_euid; //发送端进程的uid
        binder_size_t    data_size;    //data数据的总大小
        binder_size_t    offsets_size; //IPC对象的大小

        union {
            struct {
                binder_uintptr_t    buffer; //数据区起始地址
                binder_uintptr_t    offsets; //数据区IPC对象偏移量
            } ptr;
            __u8    buf[8];
        } data;   //RPC数据
    };
  • target: 对于BpBinder则使用handle,对于BBinder则使用ptr,故使用union数据类型来表示;
  • code: 比如注册服务过程code为ADD_SERVICE_TRANSACTION,又比如获取服务code为CHECK_SERVICE_TRANSACTION
  • data:代表整个数据区,其中data.ptr指向的是传递给Binder驱动的数据区的起始地址,data.offsets指的是数据区中IPC数据地址的偏移量。
  • cookie: 记录着BBinder指针。

3.8 flat_binder_object

flat_binder_object结构体代表Binder对象在两个进程间传递的扁平结构。

类型 成员变量 解释
__u32 type 类型
__u32 flags 记录优先级、文件描述符许可
binder_uintptr_t binder (union)当传递的是binder_node时使用,指向binder_node在应用程序的地址
__u32 handle (union)当传递的是binder_ref时使用,存放Binder在进程中的引用号
binder_uintptr_t cookie 只对binder_node有效,存放binder_node的额外数据

此处的类型type的可能取值来自于enum,成员如下: | 成员变量 | 解释 | | --- | --- | | BINDER_TYPE_BINDER | binder_node的强引用 | | BINDER_TYPE_WEAK_BINDER | binder_node的弱引用 | | BINDER_TYPE_HANDLE | binder_ref强引用 | | BINDER_TYPE_WEAK_HANDLE | binder_ref弱引用 | | BINDER_TYPE_FD | binder文件描述符 |

说明:

  • 当type等于BINDER_TYPE_BINDER或BINDER_TYPE_WEAK_BINDER类型时,
    代表Server进程向ServiceManager进程注册服务,则创建binder_node对象;
  • 当type等于BINDER_TYPE_HANDLE或BINDER_TYPE_WEAK_HEANDLE类型时,
    代表Client进程向Server进程请求代理,则创建binder_ref对象;
  • 当type等于BINDER_TYPE_FD类型时,
    代表进程向另一个进程发送文件描述符,只打开文件,则无需创建任何对象。

3.9 binder_buffer

每一次Binder传输数据时,都会先从Binder内存缓存区中分配一个binder_buffer来存储传输数据。

类型 成员变量 解释
struct list_head entry buffer实体的地址
struct rb_node rb_node buffer实体的地址
unsigned free 标记是否是空闲buffer,占位1bit
unsigned allow_user_free 是否允许用户释放,占位1bit
unsigned async_transaction 占位1bit
unsigned debug_id 占位29bit
struct binder_transaction * transaction 该缓存区的需要处理的事务
struct binder_node * target_node 该缓存区所需处理的Binder实体
size_t data_size 数据大小
size_t offsets_size 数据偏移量
uint8_t data[0] 数据地址

每一个binder_buffer分为空闲和已分配的,通过free标记来区分。空闲和已分配的binder_buffer通过各自的成员变量rb_node分别连入binder_proc的free_buffers(红黑树)和allocated_buffers(红黑树)。

3.10 binder_transaction

类型 成员变量 解释
int debug_id 用于调试
struct binder_work work binder工作类型
struct binder_thread * from 发送端线程
struct binder_transaction * from_parent 上一个事务
struct binder_proc * to_proc 接收端进程
struct binder_thread * to_thread 接收端线程
struct binder_transaction * to_parent 下一个事务
unsigned need_reply 是否需要回复
struct binder_buffer * buffer 数据buffer
unsigned int code 通信方法,比如startService
unsigned int flags 标志,比如是否oneway
long priority 优先级
long saved_priority 保存的优先级
kuid_t sender_euid 发送端uid

执行binder_transaction()过程创建的结构体

  • debug_id:是一个全局静态变量,每当创建一个binder_transactionbinder_nodebinder_ref对象,则++debug_id
  • from与to_thread是一对,分别是发送端线程和接收端线程;
  • from_parent与to_parent是一对,分别是上一个和下一个binder_transaction,组成一个链表。
    • 执行binder_transaction()方法过程,当非oneway的BC_TRANSACTION时,则设置当前事务t->from_parent等于当前线程的transaction_stack;
    • 执行binder_thread_read()方法过程,当非oneway的BR_TRANSACTION时,则设置当前事务t->to_parent等于当前线程的transaction_stack;

3.11 binder_work

    struct binder_work {
        struct list_head entry;
        enum {
            BINDER_WORK_TRANSACTION = 1, 
            BINDER_WORK_TRANSACTION_COMPLETE,
            BINDER_WORK_NODE, 
            BINDER_WORK_DEAD_BINDER, 
            BINDER_WORK_DEAD_BINDER_AND_CLEAR, 
            BINDER_WORK_CLEAR_DEATH_NOTIFICATION,
        } type;
    };

binder_work.type设置时机:

  • binder_transaction()
  • binder_thread_write()
  • binder_new_node()

3.12 binder_state

类型 成员变量 解释
int fd 文件描述符
void * mapped 映射到进程空间的起始地址
size_t mapsize 内存空间的映射大小
点赞
收藏
评论区
推荐文章

暂无数据