【LittleXi】【MIT6.S081-2020Fall】Lab: locks

news2024/11/19 9:36:25

【MIT6.S081-2020Fall】Lab: locks

【MIT6.S081-2020Fall】Lab: locks
内存分配实验
- 内存分配实验准备
- 实验目的
- 1. 举一个例子说明修改前的**kernel/kalloc.c**中如果没有锁会导致哪些进程间竞争(races)问题
- 2. 说明修改前的kernel/kalloc.c中锁竞争contention问题及其后果
- 3. 解释acquire和release中push_off/pop_off的作用
- 4. 对上页实验内容的实现思路、代码设计、测试结果
- - 实验思路
  - 代码设计
  - 测试结果
- 同步互斥实验目标
- - Q1：关系分析，请写出题目中存在的互斥和同步的关系
  - Q2：上述关系可以抽象为几个进程? 写出伪代码描述和实现思路
  - - 伪代码展示

【MIT6.S081-2020Fall】Lab: locks

内存分配实验

内存分配实验准备

环境配置

commit lab0的代码

git commit -am lab0

切换到lock分支

git fetch

git checkout lock

make clean

make; make qemu并执行kalloctest观察锁竞争情况

实验目的

1. 为每个CPU维护一个空闲页面链表，每个链表都有自己的锁**

→ 不同CPU上的分配和释放可以并行执行

2. 当某个CPU的空闲页面用尽时，需要借用另一CPU的空闲页面**

→ 虽然“借用”时可能引入锁竞争，但这种情况较少发生

完成实验后，需通过kalloctest的3个测试 (测试时间可能较长)

1. 举一个例子说明修改前的kernel/kalloc.c中如果没有锁会导致哪些进程间竞争(races)问题

答：

Double Free问题：如果没有锁来保护释放内存的操作，多个进程可能会同时尝试释放同一块内存。这可能导致内存被释放多次，破坏内存管理的一致性。当后续的内存分配请求发生时，可能会分配到之前已经被释放但未及时回收的内存块，从而导致不可预测的错误和安全问题。
内存泄漏问题：如果没有锁来保护内存分配的操作，多个进程可能会同时尝试分配内存。这可能导致内存分配失败，因为内存池可能在分配之前已经被其他进程用尽。此时，一些进程可能无法获得所需的内存，导致内存泄漏。
数据不一致性问题：如果多个进程同时修改内存池的数据结构，没有适当的锁来同步这些操作，就可能导致数据结构的损坏，从而破坏了内存管理的一致性。
性能问题：没有适当的锁来管理内存池，可能导致竞争条件，降低了系统的性能。竞争条件会导致进程等待或频繁地重试内存分配/释放操作，从而增加了系统的负载和延迟。

2. 说明修改前的kernel/kalloc.c中锁竞争contention问题及其后果

答：

1、修改前的kalloc.c代码中，只有一个内核内存分配器（kmem），这会导致在很多线程想要获取锁，想要CPU 调度分配内存的时候造成拥塞情况，导致大量的线程获取锁失败，使得程序运行效率降低。

3. 解释acquire和release中push_off/pop_off的作用

答：“acquire” 和 “release” 中的 “push_off” 和 “pop_off” 是通常用于实现中断禁用（中断屏蔽）的操作。这些操作通常在多任务操作系统中用于确保获取锁或释放锁的相关代码的原子性执行，以防止并发执行的任务相互干扰。

4. 对上页实验内容的实现思路、代码设计、测试结果

实验思路

1、为每个CPU维护一个空闲页面链表，我们可以通过修改kalloc.c代码中的kmem结构体，修改为长度为NCPU的结构体数组，再init函数中，初始化8个结构体中的锁，进行free操作的时候，注意获取当前CPU的id，然后对对应id的CPU进行释放

实现的核心代码：

struct
{
  struct spinlock lock;
  struct run *freelist;
} kmem[NCPU];

2、当其它CPU空闲的时候，我们怎样借用其它CPU来完成任务呢？我们可以进行一个简单的for循环遍历，当发现这个CPU是空闲的，那么我们就可以借用这个CPU

实现的核心代码

  if (!r)
  {
    for (int j = 0; j < NCPU; j++)
    {
      if (i != j)
      {
        // 尝试获取锁
        acquire(&kmem[j].lock);
        if (kmem[j].freelist)
        {
          // 如果获取到了，那么就分配,并退出
          r = kmem[j].freelist;
          kmem[j].freelist = r->next;
          release(&kmem[j].lock);
          break;
        }
        release(&kmem[j].lock);
      }
    }
  }

代码设计

// Physical memory allocator, for user processes,
// kernel stacks, page-table pages,
// and pipe buffers. Allocates whole 4096-byte pages.

#include "types.h"
#include "param.h"
#include "memlayout.h"
#include "spinlock.h"
#include "riscv.h"
#include "defs.h"

void freerange(void *pa_start, void *pa_end);

extern char end[]; // first address after kernel.
                   // defined by kernel.ld.

struct run
{
  struct run *next;
};

struct
{
  struct spinlock lock;
  struct run *freelist;
} kmem[NCPU];

void kinit()
{
  for (int i = 0; i < 8; i++)
    initlock(&kmem[i].lock, "kmem");
  freerange(end, (void *)PHYSTOP);
}

void freerange(void *pa_start, void *pa_end)
{
  char *p;
  p = (char *)PGROUNDUP((uint64)pa_start);
  for (; p + PGSIZE <= (char *)pa_end; p += PGSIZE)
    kfree(p);
}

// Free the page of physical memory pointed at by pa,
// which normally should have been returned by a
// call to kalloc().  (The exception is when
// initializing the allocator; see kinit above.)
void kfree(void *pa)
{
  struct run *r;

  if (((uint64)pa % PGSIZE) != 0 || (char *)pa < end || (uint64)pa >= PHYSTOP)
    panic("kfree");

  // Fill with junk to catch dangling refs.
  memset(pa, 1, PGSIZE);

  r = (struct run *)pa;

  int i = r_tp();
  push_off();
  acquire(&kmem[i].lock);
  r->next = kmem[i].freelist;
  kmem[i].freelist = r;
  release(&kmem[i].lock);
  pop_off();
}

// Allocate one 4096-byte page of physical memory.
// Returns a pointer that the kernel can use.
// Returns 0 if the memory cannot be allocated.
void *
kalloc(void)
{
  struct run *r;

  push_off();

  int i = r_tp();

  acquire(&kmem[i].lock);
  r = kmem[i].freelist;
  if (r)
    kmem[i].freelist = r->next;
  release(&kmem[i].lock);

  if (!r)
  {
    for (int j = 0; j < NCPU; j++)
    {
      if (i != j)
      {
        // 尝试获取锁
        acquire(&kmem[j].lock);
        if (kmem[j].freelist)
        {
          // 如果获取到了，那么就分配,并退出
          r = kmem[j].freelist;
          kmem[j].freelist = r->next;
          release(&kmem[j].lock);
          break;
        }
        release(&kmem[j].lock);
      }
    }
  }

  pop_off();

  if (r)
    memset((char *)r, 5, PGSIZE); // fill with junk
  return (void *)r;
}