Compare commits
2 Commits
master
...
vm/virtual
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e047e7aa45 | ||
|
|
b2b3f77a91 |
@@ -38,3 +38,4 @@ test_vm:
|
|||||||
extends: .pintos_tests
|
extends: .pintos_tests
|
||||||
variables:
|
variables:
|
||||||
DIR: vm
|
DIR: vm
|
||||||
|
IGNORE: (tests/vm/pt-grow-stack|tests/vm/pt-grow-pusha|tests/vm/pt-big-stk-obj|tests/vm/pt-overflowstk|tests/vm/pt-write-code2|tests/vm/pt-grow-stk-sc|tests/vm/page-linear|tests/vm/page-parallel|tests/vm/page-merge-seq|tests/vm/page-merge-par|tests/vm/page-merge-stk|tests/vm/page-merge-mm|tests/vm/mmap-over-stk)
|
||||||
|
|||||||
@@ -33,7 +33,6 @@
|
|||||||
#endif
|
#endif
|
||||||
#ifdef VM
|
#ifdef VM
|
||||||
#include "vm/frame.h"
|
#include "vm/frame.h"
|
||||||
#include "vm/page.h"
|
|
||||||
#include "devices/swap.h"
|
#include "devices/swap.h"
|
||||||
#endif
|
#endif
|
||||||
#ifdef FILESYS
|
#ifdef FILESYS
|
||||||
@@ -105,7 +104,6 @@ main (void)
|
|||||||
paging_init ();
|
paging_init ();
|
||||||
#ifdef VM
|
#ifdef VM
|
||||||
frame_init ();
|
frame_init ();
|
||||||
shared_file_pages_init ();
|
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* Segmentation. */
|
/* Segmentation. */
|
||||||
|
|||||||
@@ -265,24 +265,11 @@ thread_create (const char *name, int priority,
|
|||||||
#ifdef USERPROG
|
#ifdef USERPROG
|
||||||
/* Initialize the thread's file descriptor table. */
|
/* Initialize the thread's file descriptor table. */
|
||||||
t->fd_counter = MINIMUM_USER_FD;
|
t->fd_counter = MINIMUM_USER_FD;
|
||||||
bool success = hash_init (&t->open_files, fd_hash, fd_less, NULL);
|
|
||||||
if (success)
|
|
||||||
{
|
|
||||||
success = hash_init (&t->child_results, process_result_hash,
|
|
||||||
process_result_less, t);
|
|
||||||
if (!success)
|
|
||||||
hash_destroy (&t->open_files, NULL);
|
|
||||||
#ifdef VM
|
|
||||||
else
|
|
||||||
{
|
|
||||||
success = init_pages (&t->pages);
|
|
||||||
if (!success)
|
|
||||||
hash_destroy (&t->child_results, NULL);
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!success)
|
if (!hash_init (&t->open_files, fd_hash, fd_less, NULL)
|
||||||
|
|| !hash_init (&t->child_results, process_result_hash,
|
||||||
|
process_result_less, t)
|
||||||
|
|| !hash_init (&t->pages, page_hash, page_less, NULL))
|
||||||
{
|
{
|
||||||
palloc_free_page (t);
|
palloc_free_page (t);
|
||||||
free (t->result);
|
free (t->result);
|
||||||
@@ -736,8 +723,6 @@ init_thread (struct thread *t, const char *name, int nice, int priority,
|
|||||||
t->recent_cpu = recent_cpu;
|
t->recent_cpu = recent_cpu;
|
||||||
t->priority = t->base_priority;
|
t->priority = t->base_priority;
|
||||||
|
|
||||||
lock_init (&t->pages_lock);
|
|
||||||
|
|
||||||
old_level = intr_disable ();
|
old_level = intr_disable ();
|
||||||
list_push_back (&all_list, &t->allelem);
|
list_push_back (&all_list, &t->allelem);
|
||||||
intr_set_level (old_level);
|
intr_set_level (old_level);
|
||||||
|
|||||||
@@ -136,7 +136,6 @@ struct thread
|
|||||||
struct list_elem elem; /* List element. */
|
struct list_elem elem; /* List element. */
|
||||||
|
|
||||||
struct hash pages; /* Table of open user pages. */
|
struct hash pages; /* Table of open user pages. */
|
||||||
struct lock pages_lock; /* Lock for the supplementary page table. */
|
|
||||||
|
|
||||||
/* Memory mapped files for user virtual memory. */
|
/* Memory mapped files for user virtual memory. */
|
||||||
struct hash mmap_files; /* List of memory mapped files. */
|
struct hash mmap_files; /* List of memory mapped files. */
|
||||||
|
|||||||
@@ -3,19 +3,19 @@
|
|||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include "stdbool.h"
|
#include "stdbool.h"
|
||||||
#include "userprog/gdt.h"
|
#include "userprog/gdt.h"
|
||||||
|
#include "userprog/pagedir.h"
|
||||||
|
#include "userprog/process.h"
|
||||||
#include "threads/interrupt.h"
|
#include "threads/interrupt.h"
|
||||||
|
#include "threads/palloc.h"
|
||||||
#include "threads/thread.h"
|
#include "threads/thread.h"
|
||||||
#ifdef VM
|
#include "threads/vaddr.h"
|
||||||
#include "vm/frame.h"
|
#include "vm/frame.h"
|
||||||
#include "vm/page.h"
|
#include "vm/page.h"
|
||||||
#include "devices/swap.h"
|
#include "devices/swap.h"
|
||||||
#include "threads/vaddr.h"
|
|
||||||
#include "userprog/pagedir.h"
|
#include "userprog/pagedir.h"
|
||||||
#endif
|
|
||||||
|
|
||||||
#define MAX_STACK_SIZE (8 * 1024 * 1024) // 8MB
|
#define MAX_STACK_SIZE (8 * 1024 * 1024) // 8MB
|
||||||
#define MAX_STACK_OFFSET 32 // 32 bytes offset below stack pointer (ESP)
|
#define MAX_STACK_OFFSET 32 // 32 bytes offset below stack pointer (ESP)
|
||||||
|
|
||||||
/* Number of page faults processed. */
|
/* Number of page faults processed. */
|
||||||
static long long page_fault_cnt;
|
static long long page_fault_cnt;
|
||||||
|
|
||||||
@@ -181,12 +181,11 @@ page_fault (struct intr_frame *f)
|
|||||||
/* If the page fault occurred in kernel mode, then we intentionally indicate
|
/* If the page fault occurred in kernel mode, then we intentionally indicate
|
||||||
a fault (for get_user() etc). */
|
a fault (for get_user() etc). */
|
||||||
if (!user)
|
if (!user)
|
||||||
{
|
{
|
||||||
f->eip = (void *)f->eax;
|
f->eip = (void *)f->eax;
|
||||||
f->eax = 0xffffffff;
|
f->eax = 0xffffffff;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/* To implement virtual memory, delete the rest of the function
|
/* To implement virtual memory, delete the rest of the function
|
||||||
body, and replace it with code that brings in the page to
|
body, and replace it with code that brings in the page to
|
||||||
@@ -250,36 +249,32 @@ grow_stack (void *upage)
|
|||||||
bool
|
bool
|
||||||
fetch_page (void *upage, bool write)
|
fetch_page (void *upage, bool write)
|
||||||
{
|
{
|
||||||
/* Check if the page is in the supplemental page table. That is, it is a page
|
|
||||||
that is expected to be in memory. */
|
|
||||||
struct page_entry *page = page_get (thread_current (), upage);
|
|
||||||
if (page == NULL)
|
|
||||||
return false;
|
|
||||||
|
|
||||||
/* Check if the non-present user page is in the swap partition.
|
/* Check if the non-present user page is in the swap partition.
|
||||||
If so, swap it back into main memory, updating the PTE for
|
If so, swap it back into main memory, updating the PTE for
|
||||||
the faulted virtual address to point to the newly allocated
|
the faulted virtual address to point to the newly allocated
|
||||||
frame. */
|
frame. */
|
||||||
struct thread *t = thread_current ();
|
struct thread *t = thread_current ();
|
||||||
if (page_in_swap (t, upage))
|
if (page_in_swap (t, upage))
|
||||||
|
{
|
||||||
|
size_t swap_slot = page_get_swap (t, upage);
|
||||||
|
void *kpage = frame_alloc (0, upage, t);
|
||||||
|
swap_in (kpage, swap_slot);
|
||||||
|
|
||||||
|
bool writeable = pagedir_is_writable (t->pagedir, upage);
|
||||||
|
if (pagedir_set_page (t->pagedir, upage, kpage, writeable))
|
||||||
{
|
{
|
||||||
/* NOTE: This code should be refactored and moved into helper functions
|
struct page_entry *page = page_get(upage);
|
||||||
within 'page.c'.*/
|
if (page != NULL)
|
||||||
void *kpage = frame_alloc (0, upage, t);
|
page->frame = kpage;
|
||||||
lock_acquire (&page->lock);
|
return true;
|
||||||
|
|
||||||
size_t swap_slot = page_get_swap (t, upage);
|
|
||||||
swap_in (kpage, swap_slot);
|
|
||||||
|
|
||||||
lock_release (&page->lock);
|
|
||||||
|
|
||||||
bool writeable = pagedir_is_writable (t->pagedir, upage);
|
|
||||||
|
|
||||||
/* TODO: When this returns false we should quit the page fault,
|
|
||||||
but currently we continue and check the stack conditions in the
|
|
||||||
page fault handler. */
|
|
||||||
return pagedir_set_page (t->pagedir, upage, kpage, writeable);
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Check if the page is in the supplemental page table. That is, it is a page
|
||||||
|
that is expected to be in memory. */
|
||||||
|
struct page_entry *page = page_get (upage);
|
||||||
|
if (page == NULL)
|
||||||
|
return false;
|
||||||
|
|
||||||
/* An attempt to write to a non-writeable should fail. */
|
/* An attempt to write to a non-writeable should fail. */
|
||||||
if (write && !page->writable)
|
if (write && !page->writable)
|
||||||
@@ -288,10 +283,8 @@ fetch_page (void *upage, bool write)
|
|||||||
/* Load the page into memory based on the type of data it is expecting. */
|
/* Load the page into memory based on the type of data it is expecting. */
|
||||||
bool success = false;
|
bool success = false;
|
||||||
switch (page->type) {
|
switch (page->type) {
|
||||||
case PAGE_MMAP:
|
case PAGE_FILE:
|
||||||
case PAGE_EXECUTABLE:
|
success = page_load (page, page->writable);
|
||||||
case PAGE_SHARED:
|
|
||||||
success = page_load_file (page);
|
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
return false;
|
return false;
|
||||||
|
|||||||
@@ -2,12 +2,9 @@
|
|||||||
#include <stdbool.h>
|
#include <stdbool.h>
|
||||||
#include <stddef.h>
|
#include <stddef.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include "devices/swap.h"
|
|
||||||
#include "threads/init.h"
|
#include "threads/init.h"
|
||||||
#include "threads/pte.h"
|
#include "threads/pte.h"
|
||||||
#include "threads/palloc.h"
|
#include "threads/palloc.h"
|
||||||
#include "vm/frame.h"
|
|
||||||
#include "vm/page.h"
|
|
||||||
|
|
||||||
static uint32_t *active_pd (void);
|
static uint32_t *active_pd (void);
|
||||||
|
|
||||||
@@ -42,14 +39,8 @@ pagedir_destroy (uint32_t *pd)
|
|||||||
uint32_t *pte;
|
uint32_t *pte;
|
||||||
|
|
||||||
for (pte = pt; pte < pt + PGSIZE / sizeof *pte; pte++)
|
for (pte = pt; pte < pt + PGSIZE / sizeof *pte; pte++)
|
||||||
{
|
if (*pte & PTE_P)
|
||||||
if (page_is_shared_pte (pte))
|
palloc_free_page (pte_get_page (*pte));
|
||||||
continue;
|
|
||||||
else if (page_in_swap_pte (pte))
|
|
||||||
swap_drop (page_get_swap_pte (pte));
|
|
||||||
else if (*pte & PTE_P)
|
|
||||||
frame_free (pte_get_page (*pte));
|
|
||||||
}
|
|
||||||
palloc_free_page (pt);
|
palloc_free_page (pt);
|
||||||
}
|
}
|
||||||
palloc_free_page (pd);
|
palloc_free_page (pd);
|
||||||
|
|||||||
@@ -371,9 +371,7 @@ process_exit (void)
|
|||||||
hash_destroy (&cur->open_files, fd_cleanup);
|
hash_destroy (&cur->open_files, fd_cleanup);
|
||||||
|
|
||||||
/* Clean up the thread's supplemental page table. */
|
/* Clean up the thread's supplemental page table. */
|
||||||
lock_acquire (&cur->pages_lock);
|
|
||||||
hash_destroy (&cur->pages, page_cleanup);
|
hash_destroy (&cur->pages, page_cleanup);
|
||||||
lock_release (&cur->pages_lock);
|
|
||||||
|
|
||||||
/* Close the executable file, implicitly allowing it to be written to. */
|
/* Close the executable file, implicitly allowing it to be written to. */
|
||||||
if (cur->exec_file != NULL)
|
if (cur->exec_file != NULL)
|
||||||
@@ -716,8 +714,8 @@ load_segment (struct file *file, off_t ofs, uint8_t *upage,
|
|||||||
size_t page_zero_bytes = PGSIZE - page_read_bytes;
|
size_t page_zero_bytes = PGSIZE - page_read_bytes;
|
||||||
|
|
||||||
/* Add the page metadata to the SPT to be lazy loaded later on */
|
/* Add the page metadata to the SPT to be lazy loaded later on */
|
||||||
if (page_insert_file (file, ofs, upage, page_read_bytes, page_zero_bytes,
|
if (page_insert (file, ofs, upage, page_read_bytes, page_zero_bytes,
|
||||||
writable, PAGE_EXECUTABLE) == NULL)
|
writable, PAGE_FILE) == NULL)
|
||||||
return false;
|
return false;
|
||||||
|
|
||||||
/* Advance. */
|
/* Advance. */
|
||||||
|
|||||||
@@ -461,9 +461,10 @@ syscall_mmap (int fd, void *addr)
|
|||||||
/* Check and ensure that there is enough space in the user virtual memory to
|
/* Check and ensure that there is enough space in the user virtual memory to
|
||||||
hold the entire file. */
|
hold the entire file. */
|
||||||
for (off_t ofs = 0; ofs < file_size; ofs += PGSIZE)
|
for (off_t ofs = 0; ofs < file_size; ofs += PGSIZE)
|
||||||
if (page_get (thread_current (), addr + ofs) != NULL)
|
{
|
||||||
|
if (page_get (addr + ofs) != NULL)
|
||||||
return MMAP_FAILURE;
|
return MMAP_FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
/* Map the file data into the user virtual memory starting from addr. */
|
/* Map the file data into the user virtual memory starting from addr. */
|
||||||
for (off_t ofs = 0; ofs < file_size; ofs += PGSIZE)
|
for (off_t ofs = 0; ofs < file_size; ofs += PGSIZE)
|
||||||
@@ -471,8 +472,8 @@ syscall_mmap (int fd, void *addr)
|
|||||||
off_t read_bytes = file_size - ofs < PGSIZE ? file_size - ofs : PGSIZE;
|
off_t read_bytes = file_size - ofs < PGSIZE ? file_size - ofs : PGSIZE;
|
||||||
off_t zero_bytes = PGSIZE - read_bytes;
|
off_t zero_bytes = PGSIZE - read_bytes;
|
||||||
|
|
||||||
if (page_insert_file (file, ofs, addr + ofs, read_bytes, zero_bytes, true,
|
if (page_insert (file, ofs, addr + ofs, read_bytes, zero_bytes, true,
|
||||||
PAGE_MMAP) == NULL)
|
PAGE_FILE) == NULL)
|
||||||
return MMAP_FAILURE;
|
return MMAP_FAILURE;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -481,6 +482,7 @@ syscall_mmap (int fd, void *addr)
|
|||||||
if (mmap == NULL)
|
if (mmap == NULL)
|
||||||
return MMAP_FAILURE;
|
return MMAP_FAILURE;
|
||||||
|
|
||||||
|
|
||||||
return mmap->mapping;
|
return mmap->mapping;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
436
src/vm/frame.c
436
src/vm/frame.c
@@ -2,199 +2,142 @@
|
|||||||
#include <hash.h>
|
#include <hash.h>
|
||||||
#include <list.h>
|
#include <list.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
#include <stdio.h>
|
||||||
#include "frame.h"
|
#include "frame.h"
|
||||||
#include "page.h"
|
#include "page.h"
|
||||||
#include "filesys/file.h"
|
|
||||||
#include "threads/malloc.h"
|
#include "threads/malloc.h"
|
||||||
#include "threads/vaddr.h"
|
#include "threads/vaddr.h"
|
||||||
#include "userprog/pagedir.h"
|
#include "userprog/pagedir.h"
|
||||||
#include "userprog/syscall.h"
|
|
||||||
#include "threads/synch.h"
|
#include "threads/synch.h"
|
||||||
|
#include "devices/swap.h"
|
||||||
|
|
||||||
|
struct frame_entry
|
||||||
|
{
|
||||||
|
void *frame;
|
||||||
|
void *upage;
|
||||||
|
struct thread *owner;
|
||||||
|
bool pinned;
|
||||||
|
|
||||||
|
struct hash_elem hash_elem;
|
||||||
|
struct list_elem list_elem;
|
||||||
|
};
|
||||||
|
|
||||||
/* Hash table that maps every active frame's kernel virtual address
|
|
||||||
to its corresponding 'frame_metadata'.*/
|
|
||||||
struct hash frame_table;
|
struct hash frame_table;
|
||||||
|
struct lock frame_lock;
|
||||||
/* Linked list used to represent the circular queue in the 'clock'
|
|
||||||
algorithm for page eviction. Iterating from the element that is
|
|
||||||
currently pointed at by 'next_victim' yields an ordering of the entries
|
|
||||||
from oldest to newest (in terms of when they were added or checked
|
|
||||||
for having been referenced by a process). */
|
|
||||||
struct list lru_list;
|
struct list lru_list;
|
||||||
|
struct list_elem *next_victim;
|
||||||
|
|
||||||
/* The next element in lru_list to be considered for eviction (oldest added
|
hash_hash_func frame_hash;
|
||||||
or referenced page in the circular queue). If this page has has an
|
hash_less_func frame_less;
|
||||||
'accessed' bit of 0 when considering eviction, then it will be the next
|
|
||||||
victim. Otherwise, the next element in the queue is similarly considered. */
|
|
||||||
struct list_elem *next_victim = NULL;
|
|
||||||
|
|
||||||
|
|
||||||
struct frame_metadata
|
|
||||||
{
|
|
||||||
void *frame; /* The kernel virtual address holding the frame. */
|
|
||||||
void *upage; /* The user virtual address pointing to the frame. */
|
|
||||||
struct list owners; /* List of threads that own the frame. */
|
|
||||||
bool pinned; /* Indicates wheter the frame should be
|
|
||||||
considered as an eviction candidate.*/
|
|
||||||
struct hash_elem hash_elem; /* Tracks the position of the frame metadata
|
|
||||||
within 'frame_table', whose key is the
|
|
||||||
kernel virtual address of the frame. */
|
|
||||||
struct list_elem list_elem; /* Tracks the position of the frame metadata
|
|
||||||
within 'lru_list', so a victim can be
|
|
||||||
chosen for eviction. */
|
|
||||||
};
|
|
||||||
|
|
||||||
hash_hash_func frame_metadata_hash;
|
|
||||||
hash_less_func frame_metadata_less;
|
|
||||||
|
|
||||||
|
static struct frame_entry *frame_get (void *frame);
|
||||||
|
static struct frame_entry *get_victim (void);
|
||||||
static struct list_elem *lru_next (struct list_elem *e);
|
static struct list_elem *lru_next (struct list_elem *e);
|
||||||
static struct list_elem *lru_prev (struct list_elem *e);
|
static struct list_elem *lru_prev (struct list_elem *e);
|
||||||
static struct frame_metadata *frame_metadata_get (void *frame);
|
|
||||||
static struct frame_metadata *get_victim (void);
|
|
||||||
static void free_owners (struct list *owners);
|
|
||||||
static struct frame_metadata *frame_metadata_find (void *frame);
|
|
||||||
|
|
||||||
/* Initialize the frame system by initializing the frame (hash) table with
|
|
||||||
the frame_metadata hashing and comparison functions, as well as initializing
|
|
||||||
'lru_list' and its associated synchronisation primitives. */
|
|
||||||
void
|
void
|
||||||
frame_init (void)
|
frame_init (void)
|
||||||
{
|
{
|
||||||
hash_init (&frame_table, frame_metadata_hash, frame_metadata_less, NULL);
|
hash_init (&frame_table, frame_hash, frame_less, NULL);
|
||||||
|
lock_init (&frame_lock);
|
||||||
list_init (&lru_list);
|
list_init (&lru_list);
|
||||||
lock_init (&ftable_lock);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* TODO: Consider synchronisation more closely (i.e. just for hash
|
|
||||||
table). */
|
|
||||||
/* Attempt to allocate a frame for a user process, either by direct
|
|
||||||
allocation of a user page if there is sufficient RAM, or by
|
|
||||||
evicting a currently active page if memory allocated for user
|
|
||||||
processes is fulled and storing it in swap. If swap is full in
|
|
||||||
the former case, panic the kernel. */
|
|
||||||
void *
|
void *
|
||||||
frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
||||||
{
|
{
|
||||||
struct frame_metadata *frame_metadata;
|
lock_acquire (&frame_lock);
|
||||||
|
struct frame_entry *frame_metadata;
|
||||||
flags |= PAL_USER;
|
flags |= PAL_USER;
|
||||||
|
|
||||||
lock_acquire (&ftable_lock);
|
|
||||||
void *frame = palloc_get_page (flags);
|
void *frame = palloc_get_page (flags);
|
||||||
|
|
||||||
/* If a frame couldn't be allocated we must be out of main memory. Thus,
|
|
||||||
obtain a victim page to replace with our page, and swap the victim
|
|
||||||
into disk. */
|
|
||||||
if (frame == NULL)
|
if (frame == NULL)
|
||||||
{
|
{
|
||||||
/* 1. Obtain victim. */
|
if (next_victim == NULL)
|
||||||
if (next_victim == NULL)
|
PANIC ("Couldn't allocate a single page to main memory!\n");
|
||||||
PANIC ("Couldn't allocate a single page to main memory!\n");
|
|
||||||
|
|
||||||
struct frame_metadata *victim = get_victim ();
|
struct frame_entry *victim = get_victim ();
|
||||||
ASSERT (victim != NULL); /* get_victim () should never return null. */
|
ASSERT (victim != NULL); /* get_victim () should never return null. */
|
||||||
|
|
||||||
/* 2. Handle victim page writing based on its type. */
|
/* 2. Swap out victim into disk. */
|
||||||
struct page_entry *victim_page = page_get (thread_current (), victim->upage);
|
/* Mark page as 'not present' and flag the page directory as having
|
||||||
if (victim_page != NULL && victim_page->type == PAGE_MMAP)
|
been modified *before* eviction begins to prevent the owner of the
|
||||||
{
|
victim page from accessing/modifying it mid-eviction. */
|
||||||
/* If it was a memory-mapped file page, we just write it back
|
pagedir_clear_page (victim->owner->pagedir, victim->upage);
|
||||||
to the file if it was dirty. */
|
|
||||||
if (pagedir_is_dirty(owner->pagedir, victim->upage))
|
|
||||||
{
|
|
||||||
lock_acquire (&filesys_lock);
|
|
||||||
file_write_at (victim_page->file, victim->upage,
|
|
||||||
victim_page->read_bytes, victim_page->offset);
|
|
||||||
lock_release (&filesys_lock);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
/* Otherwise, insert the page into swap. */
|
|
||||||
page_insert_swapped (victim->upage, victim->frame, &victim->owners);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Free victim's owners. */
|
// TODO: Lock PTE of victim page for victim process.
|
||||||
free_owners (&victim->owners);
|
|
||||||
|
|
||||||
/* If zero flag is set, zero out the victim page. */
|
size_t swap_slot = swap_out (victim->frame);
|
||||||
if (flags & PAL_ZERO)
|
page_set_swap (victim->owner, victim->upage, swap_slot);
|
||||||
memset (victim->frame, 0, PGSIZE);
|
|
||||||
|
|
||||||
/* 3. Indicate that the new frame's metadata will be stored
|
/* If zero flag is set, zero out the victim page. */
|
||||||
inside the same structure that stored the victim's metadata.frame.c
|
if (flags & PAL_ZERO)
|
||||||
As both the new frame and the victim frame share the same kernel
|
memset (victim->frame, 0, PGSIZE);
|
||||||
virtual address, the hash map need not be updated, and neither
|
|
||||||
the list_elem value as both share the same lru_list position. */
|
|
||||||
frame_metadata = victim;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* If sufficient main memory allows the frame to be directly allocated,
|
/* 3. Indicate that the new frame's metadata will be stored
|
||||||
we must update the frame table with a new entry, and grow lru_list. */
|
inside the same structure that stored the victim's metadata.
|
||||||
|
As both the new frame and the victim frame share the same kernel
|
||||||
|
virtual address, the hash map need not be updated, and neither
|
||||||
|
the list_elem value as both share the same lru_list position. */
|
||||||
|
frame_metadata = victim;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* If sufficient main memory allows the frame to be directly allocated,
|
||||||
|
we must update the frame table with a new entry, and grow lru_list. */
|
||||||
else
|
else
|
||||||
|
{
|
||||||
|
/* Must own lru_lock here, as otherwise there is a race condition
|
||||||
|
with next_victim either being NULL or uninitialized. */
|
||||||
|
frame_metadata = malloc (sizeof (struct frame_entry));
|
||||||
|
frame_metadata->frame = frame;
|
||||||
|
|
||||||
|
/* Newly allocated frames are pushed to the back of the circular queue
|
||||||
|
represented by lru_list. Must explicitly handle the case where the
|
||||||
|
circular queue is empty (when next_victim == NULL). */
|
||||||
|
if (next_victim == NULL)
|
||||||
{
|
{
|
||||||
/* Must own ftable_lock here, as otherwise there is a race condition
|
list_push_back (&lru_list, &frame_metadata->list_elem);
|
||||||
with next_victim either being NULL or uninitialized. */
|
next_victim = &frame_metadata->list_elem;
|
||||||
frame_metadata = malloc (sizeof (struct frame_metadata));
|
}
|
||||||
if (frame_metadata == NULL)
|
else
|
||||||
PANIC ("Couldn't allocate memory for frame metadata!\n");
|
{
|
||||||
frame_metadata->frame = frame;
|
struct list_elem *lru_tail = lru_prev (next_victim);
|
||||||
|
list_insert (lru_tail, &frame_metadata->list_elem);
|
||||||
/* Newly allocated frames are pushed to the back of the circular queue
|
|
||||||
represented by lru_list. Must explicitly handle the case where the
|
|
||||||
circular queue is empty (when next_victim == NULL). */
|
|
||||||
if (next_victim == NULL)
|
|
||||||
{
|
|
||||||
list_push_back (&lru_list, &frame_metadata->list_elem);
|
|
||||||
next_victim = &frame_metadata->list_elem;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
struct list_elem *lru_tail = lru_prev (next_victim);
|
|
||||||
list_insert (lru_tail, &frame_metadata->list_elem);
|
|
||||||
}
|
|
||||||
|
|
||||||
hash_insert (&frame_table, &frame_metadata->hash_elem);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
struct frame_owner *frame_owner = malloc (sizeof (struct frame_owner));
|
hash_insert (&frame_table, &frame_metadata->hash_elem);
|
||||||
if (frame_owner == NULL)
|
}
|
||||||
PANIC ("Couldn't allocate memory for frame owner!\n");
|
|
||||||
frame_owner->owner = owner;
|
|
||||||
list_init (&frame_metadata->owners);
|
|
||||||
list_push_back (&frame_metadata->owners, &frame_owner->elem);
|
|
||||||
frame_metadata->upage = upage;
|
frame_metadata->upage = upage;
|
||||||
|
frame_metadata->owner = owner;
|
||||||
frame_metadata->pinned = false;
|
frame_metadata->pinned = false;
|
||||||
lock_release (&ftable_lock);
|
|
||||||
return frame_metadata->frame;
|
void *frame_addr = frame_metadata->frame;
|
||||||
|
lock_release (&frame_lock);
|
||||||
|
return frame_addr;
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
frame_pin (void *frame)
|
frame_pin (void *frame)
|
||||||
{
|
{
|
||||||
ASSERT (frame != NULL);
|
struct frame_entry *frame_metadata = frame_get (frame);
|
||||||
lock_acquire (&ftable_lock);
|
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_get (frame);
|
|
||||||
if (frame_metadata == NULL)
|
if (frame_metadata == NULL)
|
||||||
PANIC ("Attempted to pin a frame at an unallocated kernel address '%p'\n",
|
PANIC ("Attempted to pin a frame at an unallocated kernel address '%p'\n",
|
||||||
frame);
|
frame);
|
||||||
|
|
||||||
frame_metadata->pinned = true;
|
frame_metadata->pinned = true;
|
||||||
lock_release (&ftable_lock);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
frame_unpin (void *frame)
|
frame_unpin (void *frame)
|
||||||
{
|
{
|
||||||
ASSERT (frame != NULL);
|
struct frame_entry *frame_metadata = frame_get (frame);
|
||||||
lock_acquire (&ftable_lock);
|
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_get (frame);
|
|
||||||
if (frame_metadata == NULL)
|
if (frame_metadata == NULL)
|
||||||
PANIC ("Attempted to unpin a frame at an unallocated kernel address '%p'\n",
|
PANIC ("Attempted to unpin a frame at an unallocated kernel address '%p'\n",
|
||||||
frame);
|
frame);
|
||||||
|
|
||||||
frame_metadata->pinned = false;
|
frame_metadata->pinned = false;
|
||||||
lock_release (&ftable_lock);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Attempt to deallocate a frame for a user process by removing it from the
|
/* Attempt to deallocate a frame for a user process by removing it from the
|
||||||
@@ -202,182 +145,111 @@ frame_unpin (void *frame)
|
|||||||
memory & metadata struct. Panics if the frame isn't active in memory. */
|
memory & metadata struct. Panics if the frame isn't active in memory. */
|
||||||
void
|
void
|
||||||
frame_free (void *frame)
|
frame_free (void *frame)
|
||||||
{
|
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_find (frame);
|
|
||||||
if (frame_metadata == NULL)
|
|
||||||
PANIC ("Attempted to free a frame at kernel address %p, "
|
|
||||||
"but this address is not allocated!\n",
|
|
||||||
frame);
|
|
||||||
|
|
||||||
free_owners (&frame_metadata->owners);
|
|
||||||
lock_acquire (&ftable_lock);
|
|
||||||
hash_delete (&frame_table, &frame_metadata->hash_elem);
|
|
||||||
list_remove (&frame_metadata->list_elem);
|
|
||||||
|
|
||||||
/* If we're freeing the frame marked as the next victim, update
|
|
||||||
next_victim to either be the next least recently used page, or NULL
|
|
||||||
if no pages are loaded in main memory. */
|
|
||||||
if (&frame_metadata->list_elem == next_victim)
|
|
||||||
{
|
|
||||||
if (list_empty (&lru_list))
|
|
||||||
next_victim = NULL;
|
|
||||||
else
|
|
||||||
next_victim = lru_next (next_victim);
|
|
||||||
}
|
|
||||||
lock_release (&ftable_lock);
|
|
||||||
|
|
||||||
free (frame_metadata);
|
|
||||||
palloc_free_page (frame);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Add a thread to a frame's frame_metadata owners list. */
|
|
||||||
bool
|
|
||||||
frame_owner_insert (void *frame, struct thread *owner)
|
|
||||||
{
|
{
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_find (frame);
|
lock_acquire(&frame_lock);
|
||||||
if (frame_metadata == NULL)
|
struct frame_entry key_metadata;
|
||||||
return false;
|
|
||||||
|
|
||||||
struct frame_owner *frame_owner = malloc (sizeof (struct frame_owner));
|
|
||||||
if (frame_owner == NULL)
|
|
||||||
return false;
|
|
||||||
|
|
||||||
frame_owner->owner = owner;
|
|
||||||
list_push_back (&frame_metadata->owners, &frame_owner->elem);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Remove and deallocate a frame owner from the frame_metadata owners list.
|
|
||||||
*/
|
|
||||||
void
|
|
||||||
frame_owner_remove (void *frame, struct thread *owner)
|
|
||||||
{
|
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_find (frame);
|
|
||||||
if (frame_metadata == NULL)
|
|
||||||
PANIC ("Attempted to remove an owner from a frame at kernel "
|
|
||||||
"address %p, but this address is not allocated!\n",
|
|
||||||
frame);
|
|
||||||
|
|
||||||
struct list_elem *oe;
|
|
||||||
for (oe = list_begin (&frame_metadata->owners);
|
|
||||||
oe != list_end (&frame_metadata->owners);)
|
|
||||||
{
|
|
||||||
struct frame_owner *frame_owner
|
|
||||||
= list_entry (oe, struct frame_owner, elem);
|
|
||||||
|
|
||||||
oe = list_next (oe);
|
|
||||||
if (frame_owner->owner == owner)
|
|
||||||
{
|
|
||||||
list_remove (&frame_owner->elem);
|
|
||||||
free (frame_owner);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
NOT_REACHED ();
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Find a frame_metadata entry in the frame table. */
|
|
||||||
static struct frame_metadata *
|
|
||||||
frame_metadata_find (void *frame)
|
|
||||||
{
|
|
||||||
struct frame_metadata key_metadata;
|
|
||||||
key_metadata.frame = frame;
|
key_metadata.frame = frame;
|
||||||
|
|
||||||
struct hash_elem *e = hash_find (&frame_table, &key_metadata.hash_elem);
|
struct hash_elem *e =
|
||||||
|
hash_delete (&frame_table, &key_metadata.hash_elem);
|
||||||
if (e == NULL)
|
if (e == NULL)
|
||||||
return NULL;
|
return;
|
||||||
|
|
||||||
return hash_entry (e, struct frame_metadata, hash_elem);
|
struct frame_entry *frame_metadata =
|
||||||
}
|
hash_entry (e, struct frame_entry, hash_elem);
|
||||||
|
|
||||||
/* A pre-condition for calling this function is that the calling thread
|
struct page_entry *page = page_get (frame_metadata->upage);
|
||||||
owns ftable_lock and that lru_list is non-empty. */
|
if (page != NULL)
|
||||||
static struct frame_metadata *
|
|
||||||
get_victim (void)
|
|
||||||
{
|
{
|
||||||
struct list_elem *ve = next_victim;
|
page->frame = NULL;
|
||||||
struct frame_metadata *frame_metadata;
|
|
||||||
bool found = false;
|
|
||||||
while (!found)
|
|
||||||
{
|
|
||||||
frame_metadata = list_entry (ve, struct frame_metadata, list_elem);
|
|
||||||
ve = lru_next (ve);
|
|
||||||
struct list_elem *oe;
|
|
||||||
|
|
||||||
/* Skip pinned frames */
|
|
||||||
if (frame_metadata->pinned)
|
|
||||||
continue;
|
|
||||||
|
|
||||||
/* Returns once a frame that was not accessed by any owner is found. */
|
|
||||||
found = true;
|
|
||||||
for (oe = list_begin (&frame_metadata->owners);
|
|
||||||
oe != list_end (&frame_metadata->owners); oe = list_next (oe))
|
|
||||||
{
|
|
||||||
struct frame_owner *frame_owner
|
|
||||||
= list_entry (oe, struct frame_owner, elem);
|
|
||||||
uint32_t *pd = frame_owner->owner->pagedir;
|
|
||||||
void *upage = frame_metadata->upage;
|
|
||||||
|
|
||||||
if (pagedir_is_accessed (pd, upage))
|
|
||||||
{
|
|
||||||
found = false;
|
|
||||||
pagedir_set_accessed (pd, upage, false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
next_victim = ve;
|
|
||||||
return frame_metadata;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
list_remove (&frame_metadata->list_elem);
|
||||||
free_owners (struct list *owners)
|
|
||||||
|
/* If we're freeing the frame marked as the next victim, update
|
||||||
|
next_victim to either be the next least recently used page, or NULL
|
||||||
|
if no pages are loaded in main memory. */
|
||||||
|
if (&frame_metadata->list_elem == next_victim)
|
||||||
|
{
|
||||||
|
if (list_empty (&lru_list))
|
||||||
|
next_victim = NULL;
|
||||||
|
else
|
||||||
|
next_victim = lru_next (next_victim);
|
||||||
|
}
|
||||||
|
|
||||||
|
free (frame_metadata);
|
||||||
|
palloc_free_page (frame);
|
||||||
|
|
||||||
|
lock_release (&frame_lock);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* TODO: Account for page aliases when checking accessed bit. */
|
||||||
|
/* A pre-condition for calling this function is that the calling thread
|
||||||
|
owns lru_lock and that lru_list is non-empty. */
|
||||||
|
static struct frame_entry *
|
||||||
|
get_victim (void)
|
||||||
{
|
{
|
||||||
struct list_elem *oe;
|
struct list_elem *e = next_victim;
|
||||||
for (oe = list_begin (owners); oe != list_end (owners);)
|
struct frame_entry *frame_metadata;
|
||||||
{
|
uint32_t *pd;
|
||||||
struct frame_owner *frame_owner
|
void *upage;
|
||||||
= list_entry (oe, struct frame_owner, elem);
|
for (;;)
|
||||||
oe = list_remove (oe);
|
{
|
||||||
free (frame_owner);
|
frame_metadata = list_entry (e, struct frame_entry, list_elem);
|
||||||
}
|
pd = frame_metadata->owner->pagedir;
|
||||||
|
upage = frame_metadata->upage;
|
||||||
|
e = lru_next (e);
|
||||||
|
|
||||||
|
/* Skip pinned frames */
|
||||||
|
if (frame_metadata->pinned)
|
||||||
|
continue;
|
||||||
|
|
||||||
|
if (!pagedir_is_accessed (pd, upage))
|
||||||
|
break;
|
||||||
|
|
||||||
|
pagedir_set_accessed (pd, upage, false);
|
||||||
|
}
|
||||||
|
|
||||||
|
next_victim = e;
|
||||||
|
return frame_metadata;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Hash function for frame metadata, used for storing entries in the
|
/* Hash function for frame metadata, used for storing entries in the
|
||||||
frame table. */
|
frame table. */
|
||||||
unsigned
|
unsigned
|
||||||
frame_metadata_hash (const struct hash_elem *e, void *aux UNUSED)
|
frame_hash (const struct hash_elem *e, void *aux UNUSED)
|
||||||
{
|
{
|
||||||
struct frame_metadata *frame_metadata =
|
struct frame_entry *entry =
|
||||||
hash_entry (e, struct frame_metadata, hash_elem);
|
hash_entry (e, struct frame_entry, hash_elem);
|
||||||
|
|
||||||
return hash_bytes (&frame_metadata->frame, sizeof (frame_metadata->frame));
|
return hash_bytes (&entry->frame, sizeof (entry->frame));
|
||||||
}
|
}
|
||||||
|
|
||||||
/* 'less_func' comparison function for frame metadata, used for comparing
|
/* 'less_func' comparison function for frame metadata, used for comparing
|
||||||
the keys of the frame table. Returns true iff the kernel virtual address
|
the keys of the frame table. Returns true iff the kernel virtual address
|
||||||
of the first frame is less than that of the second frame. */
|
of the first frame is less than that of the second frame. */
|
||||||
bool
|
bool
|
||||||
frame_metadata_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
frame_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
||||||
void *aux UNUSED)
|
void *aux UNUSED)
|
||||||
{
|
{
|
||||||
struct frame_metadata *a =
|
struct frame_entry *a =
|
||||||
hash_entry (a_, struct frame_metadata, hash_elem);
|
hash_entry (a_, struct frame_entry, hash_elem);
|
||||||
struct frame_metadata *b =
|
struct frame_entry *b =
|
||||||
hash_entry (b_, struct frame_metadata, hash_elem);
|
hash_entry (b_, struct frame_entry, hash_elem);
|
||||||
|
|
||||||
return a->frame < b->frame;
|
return a->frame < b->frame;
|
||||||
}
|
}
|
||||||
|
|
||||||
static struct frame_metadata *
|
static struct frame_entry *
|
||||||
frame_metadata_get (void *frame)
|
frame_get (void *frame)
|
||||||
{
|
{
|
||||||
struct frame_metadata key_metadata;
|
struct frame_entry fake_frame;
|
||||||
key_metadata.frame = frame;
|
fake_frame.frame = frame;
|
||||||
|
|
||||||
struct hash_elem *e = hash_find (&frame_table, &key_metadata.hash_elem);
|
struct hash_elem *e = hash_find (&frame_table, &fake_frame.hash_elem);
|
||||||
if (e == NULL) return NULL;
|
if (e == NULL) return NULL;
|
||||||
return hash_entry (e, struct frame_metadata, hash_elem);
|
|
||||||
|
return hash_entry (e, struct frame_entry, hash_elem);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Returns the next recently used element after the one provided, which
|
/* Returns the next recently used element after the one provided, which
|
||||||
|
|||||||
@@ -4,24 +4,10 @@
|
|||||||
#include "threads/thread.h"
|
#include "threads/thread.h"
|
||||||
#include "threads/palloc.h"
|
#include "threads/palloc.h"
|
||||||
|
|
||||||
struct frame_owner
|
|
||||||
{
|
|
||||||
struct thread *owner; /* The thread that owns the frame. */
|
|
||||||
struct list_elem elem; /* List element for the list of owners. */
|
|
||||||
};
|
|
||||||
|
|
||||||
/* Synchronisation variables. */
|
|
||||||
/* Protects access to the frame table and its related components. */
|
|
||||||
struct lock ftable_lock;
|
|
||||||
|
|
||||||
void frame_init (void);
|
void frame_init (void);
|
||||||
|
|
||||||
void *frame_alloc (enum palloc_flags, void *, struct thread *);
|
void *frame_alloc (enum palloc_flags, void *, struct thread *);
|
||||||
void frame_pin (void *frame);
|
void frame_pin (void *frame);
|
||||||
void frame_unpin (void *frame);
|
void frame_unpin (void *frame);
|
||||||
void frame_free (void *frame);
|
void frame_free (void *frame);
|
||||||
|
|
||||||
bool frame_owner_insert (void *frame, struct thread *owner);
|
|
||||||
void frame_owner_remove (void *frame, struct thread *owner);
|
|
||||||
|
|
||||||
#endif /* vm/frame.h */
|
#endif /* vm/frame.h */
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#include "mmap.h"
|
#include "mmap.h"
|
||||||
#include "page.h"
|
#include "page.h"
|
||||||
#include "threads/thread.h"
|
|
||||||
#include "threads/vaddr.h"
|
#include "threads/vaddr.h"
|
||||||
#include "threads/malloc.h"
|
#include "threads/malloc.h"
|
||||||
#include "userprog/syscall.h"
|
#include "userprog/syscall.h"
|
||||||
@@ -67,27 +66,26 @@ mmap_unmap (struct mmap_entry *mmap)
|
|||||||
if necessary. */
|
if necessary. */
|
||||||
off_t length = file_length (mmap->file);
|
off_t length = file_length (mmap->file);
|
||||||
for (off_t ofs = 0; ofs < length; ofs += PGSIZE)
|
for (off_t ofs = 0; ofs < length; ofs += PGSIZE)
|
||||||
|
{
|
||||||
|
void *upage = mmap->upage + ofs;
|
||||||
|
|
||||||
|
/* Get the SPT page entry for this page. */
|
||||||
|
struct page_entry *page = page_get(upage);
|
||||||
|
if (page == NULL)
|
||||||
|
continue;
|
||||||
|
|
||||||
|
/* Write the page back to the file if it is dirty. */
|
||||||
|
if (pagedir_is_dirty (thread_current ()->pagedir, upage))
|
||||||
{
|
{
|
||||||
void *upage = mmap->upage + ofs;
|
lock_acquire (&filesys_lock);
|
||||||
|
file_write_at (mmap->file, upage, page->read_bytes, ofs);
|
||||||
/* Get the SPT page entry for this page. */
|
lock_release (&filesys_lock);
|
||||||
struct page_entry *page = page_get(thread_current (), upage);
|
|
||||||
if (page == NULL)
|
|
||||||
continue;
|
|
||||||
|
|
||||||
/* Write the page back to the file if it is dirty. */
|
|
||||||
if (pagedir_is_dirty (thread_current ()->pagedir, upage))
|
|
||||||
{
|
|
||||||
lock_acquire (&filesys_lock);
|
|
||||||
file_write_at (mmap->file, upage, page->read_bytes, ofs);
|
|
||||||
lock_release (&filesys_lock);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Remove the page from the supplemental page table. */
|
|
||||||
hash_delete (&thread_current ()->pages, &page->elem);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Close the file and free the mmap entry. */
|
/* Remove the page from the supplemental page table. */
|
||||||
|
hash_delete (&thread_current ()->pages, &page->elem);
|
||||||
|
}
|
||||||
|
|
||||||
file_close (mmap->file);
|
file_close (mmap->file);
|
||||||
free (mmap);
|
free (mmap);
|
||||||
}
|
}
|
||||||
|
|||||||
345
src/vm/page.c
345
src/vm/page.c
@@ -1,49 +1,21 @@
|
|||||||
#include "page.h"
|
#include "page.h"
|
||||||
#include <stdint.h>
|
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include "filesys/file.h"
|
#include "filesys/file.h"
|
||||||
#include "threads/pte.h"
|
#include "threads/pte.h"
|
||||||
#include "threads/malloc.h"
|
#include "threads/malloc.h"
|
||||||
#include "threads/palloc.h"
|
#include "threads/palloc.h"
|
||||||
#include "threads/synch.h"
|
|
||||||
#include "devices/swap.h"
|
|
||||||
#include "userprog/process.h"
|
#include "userprog/process.h"
|
||||||
#include "userprog/pagedir.h"
|
#include "userprog/pagedir.h"
|
||||||
#include "vm/frame.h"
|
#include "vm/frame.h"
|
||||||
|
|
||||||
#define SWAP_FLAG_BIT 9
|
#define SWAP_FLAG_BIT 9
|
||||||
#define SHARED_FLAG_BIT 10
|
|
||||||
#define ADDR_START_BIT 12
|
#define ADDR_START_BIT 12
|
||||||
|
|
||||||
struct hash shared_file_pages;
|
|
||||||
struct lock shared_file_pages_lock;
|
|
||||||
|
|
||||||
static unsigned page_hash (const struct hash_elem *e, void *aux UNUSED);
|
|
||||||
static bool page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
|
||||||
void *aux UNUSED);
|
|
||||||
|
|
||||||
static void page_flag_shared (struct thread *owner, void *upage, bool shared);
|
|
||||||
static unsigned shared_file_page_hash (const struct hash_elem *e,
|
|
||||||
void *aux UNUSED);
|
|
||||||
static bool shared_file_page_less (const struct hash_elem *a_,
|
|
||||||
const struct hash_elem *b_,
|
|
||||||
void *aux UNUSED);
|
|
||||||
static struct shared_file_page *shared_file_page_get (struct file *file,
|
|
||||||
void *upage);
|
|
||||||
|
|
||||||
/* Initialise a supplementary page table. */
|
|
||||||
bool
|
|
||||||
init_pages (struct hash *pages)
|
|
||||||
{
|
|
||||||
ASSERT (pages != NULL);
|
|
||||||
return hash_init (pages, page_hash, page_less, NULL);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Hashing function needed for the SPT table. Returns a hash for an entry,
|
/* Hashing function needed for the SPT table. Returns a hash for an entry,
|
||||||
based on its upage. */
|
based on its upage. */
|
||||||
static unsigned
|
unsigned
|
||||||
page_hash (const struct hash_elem *e, void *aux UNUSED)
|
page_hash (const struct hash_elem *e, UNUSED void *aux)
|
||||||
{
|
{
|
||||||
struct page_entry *page = hash_entry (e, struct page_entry, elem);
|
struct page_entry *page = hash_entry (e, struct page_entry, elem);
|
||||||
return hash_ptr (page->upage);
|
return hash_ptr (page->upage);
|
||||||
@@ -51,7 +23,7 @@ page_hash (const struct hash_elem *e, void *aux UNUSED)
|
|||||||
|
|
||||||
/* Comparator function for the SPT table. Compares two entries based on their
|
/* Comparator function for the SPT table. Compares two entries based on their
|
||||||
upages. */
|
upages. */
|
||||||
static bool
|
bool
|
||||||
page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
||||||
void *aux UNUSED)
|
void *aux UNUSED)
|
||||||
{
|
{
|
||||||
@@ -61,121 +33,38 @@ page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
|||||||
return a->upage < b->upage;
|
return a->upage < b->upage;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void page_flag_swap (uint32_t *pte, bool set);
|
/* Allocate and insert a new page entry into the thread's page table. */
|
||||||
static void page_set_swap (struct thread *owner, uint32_t *pte,
|
|
||||||
size_t swap_slot);
|
|
||||||
|
|
||||||
// TODO: Deal with NULL malloc returns
|
|
||||||
/* Swap out 'owner' process's 'upage' stored at 'kpage'. Then, allocate and
|
|
||||||
insert a new page entry into the user process thread's SPT representing
|
|
||||||
this swapped out page. */
|
|
||||||
bool
|
|
||||||
page_insert_swapped (void *upage, void *kpage, struct list *owners)
|
|
||||||
{
|
|
||||||
struct file *exec_file = NULL;
|
|
||||||
struct list_elem *e;
|
|
||||||
for (e = list_begin (owners); e != list_end (owners); e = list_next (e))
|
|
||||||
{
|
|
||||||
struct thread *owner = list_entry (e, struct frame_owner, elem)->owner;
|
|
||||||
uint32_t *pte = lookup_page (owner->pagedir, upage, false);
|
|
||||||
if (exec_file != NULL || page_is_shared_pte (pte))
|
|
||||||
{
|
|
||||||
ASSERT (page_is_shared_pte (pte));
|
|
||||||
pagedir_clear_page (owner->pagedir, upage);
|
|
||||||
exec_file = owner->exec_file;
|
|
||||||
ASSERT (exec_file != NULL);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
ASSERT (list_size (owners) == 1);
|
|
||||||
|
|
||||||
/* 1. Initialize swapped page entry. */
|
|
||||||
struct page_entry *page = page_get (owner, upage);
|
|
||||||
lock_acquire (&owner->pages_lock);
|
|
||||||
if (page == NULL)
|
|
||||||
{
|
|
||||||
page = malloc (sizeof (struct page_entry));
|
|
||||||
if (page == NULL)
|
|
||||||
return NULL;
|
|
||||||
page->upage = upage;
|
|
||||||
lock_init (&page->lock);
|
|
||||||
hash_insert (&owner->pages, &page->elem);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Mark page as 'swapped' and flag the page directory as having
|
|
||||||
been modified *before* eviction begins to prevent the owner of the
|
|
||||||
victim page from accessing/modifying it mid-eviction. */
|
|
||||||
/* TODO: We need to stop the process from destroying pagedir mid-eviction,
|
|
||||||
as this could render the page table entry invalid. */
|
|
||||||
page_flag_swap (pte, true);
|
|
||||||
lock_acquire (&page->lock);
|
|
||||||
pagedir_clear_page (owner->pagedir, upage);
|
|
||||||
|
|
||||||
size_t swap_slot = swap_out (kpage);
|
|
||||||
page_set_swap (owner, pte, swap_slot);
|
|
||||||
|
|
||||||
lock_release (&page->lock);
|
|
||||||
lock_release (&owner->pages_lock);
|
|
||||||
}
|
|
||||||
if (exec_file != NULL)
|
|
||||||
{
|
|
||||||
lock_acquire (&shared_file_pages_lock);
|
|
||||||
struct shared_file_page *sfp = shared_file_page_get (exec_file, upage);
|
|
||||||
sfp->frame = NULL;
|
|
||||||
sfp->swap_slot = swap_out (kpage);
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Allocate and insert a new page entry into the user process thread's
|
|
||||||
SPT representing a file page. */
|
|
||||||
struct page_entry *
|
struct page_entry *
|
||||||
page_insert_file (struct file *file, off_t ofs, void *upage,
|
page_insert (struct file *file, off_t ofs, void *upage, uint32_t read_bytes,
|
||||||
uint32_t read_bytes, uint32_t zero_bytes, bool writable,
|
uint32_t zero_bytes, bool writable, enum page_type type)
|
||||||
enum page_type type)
|
|
||||||
{
|
{
|
||||||
/* If page exists, just update it. */
|
|
||||||
struct page_entry *existing = page_get (thread_current (), upage);
|
|
||||||
if (existing != NULL)
|
|
||||||
{
|
|
||||||
ASSERT (existing->read_bytes == read_bytes);
|
|
||||||
ASSERT (existing->zero_bytes == zero_bytes);
|
|
||||||
existing->writable = existing->writable || writable;
|
|
||||||
return existing;
|
|
||||||
}
|
|
||||||
|
|
||||||
struct page_entry *page = malloc(sizeof (struct page_entry));
|
struct page_entry *page = malloc(sizeof (struct page_entry));
|
||||||
if (page == NULL)
|
if (page == NULL)
|
||||||
return NULL;
|
return NULL;
|
||||||
|
|
||||||
page->type = type;
|
page->upage = upage;
|
||||||
|
page->frame = NULL;
|
||||||
page->file = file;
|
page->file = file;
|
||||||
page->offset = ofs;
|
page->offset = ofs;
|
||||||
page->upage = upage;
|
|
||||||
page->read_bytes = read_bytes;
|
page->read_bytes = read_bytes;
|
||||||
page->zero_bytes = zero_bytes;
|
page->zero_bytes = zero_bytes;
|
||||||
page->writable = writable;
|
page->writable = writable;
|
||||||
lock_init (&page->lock);
|
page->type = type;
|
||||||
|
|
||||||
struct thread *t = thread_current ();
|
hash_insert (&thread_current ()->pages, &page->elem);
|
||||||
lock_acquire (&t->pages_lock);
|
|
||||||
hash_insert (&t->pages, &page->elem);
|
|
||||||
lock_release (&t->pages_lock);
|
|
||||||
return page;
|
return page;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Gets a page_entry from the starting address of the page. Returns NULL if no
|
/* Gets a page_entry from the starting address of the page. Returns NULL if no
|
||||||
such page_entry exists in the hash map.*/
|
such page_entry exists in the hash map.*/
|
||||||
struct page_entry *
|
struct page_entry *
|
||||||
page_get (struct thread *thread, void *upage)
|
page_get (void *upage)
|
||||||
{
|
{
|
||||||
struct page_entry fake_page_entry;
|
struct page_entry fake_page_entry;
|
||||||
fake_page_entry.upage = upage;
|
fake_page_entry.upage = upage;
|
||||||
|
|
||||||
lock_acquire (&thread->pages_lock);
|
|
||||||
struct hash_elem *e
|
struct hash_elem *e
|
||||||
= hash_find (&thread->pages, &fake_page_entry.elem);
|
= hash_find (&thread_current ()->pages, &fake_page_entry.elem);
|
||||||
lock_release (&thread->pages_lock);
|
|
||||||
if (e == NULL)
|
if (e == NULL)
|
||||||
return NULL;
|
return NULL;
|
||||||
|
|
||||||
@@ -183,70 +72,20 @@ page_get (struct thread *thread, void *upage)
|
|||||||
}
|
}
|
||||||
|
|
||||||
bool
|
bool
|
||||||
page_load_file (struct page_entry *page)
|
page_load (struct page_entry *page, bool writable)
|
||||||
{
|
{
|
||||||
/* Allocate a frame for the page. If a frame allocation fails, then
|
/* Allocate a frame for the page. If a frame allocation fails, then
|
||||||
frame_alloc should try to evict a page. If it is still NULL, the OS
|
frame_alloc should try to evict a page. If it is still NULL, the OS
|
||||||
panics as this should not happen if eviction is working correctly. */
|
panics as this should not happen if eviction is working correctly. */
|
||||||
struct thread *t = thread_current ();
|
struct thread *t = thread_current ();
|
||||||
bool shareable = !page->writable && file_compare (page->file, t->exec_file);
|
|
||||||
if (shareable)
|
|
||||||
{
|
|
||||||
lock_acquire (&shared_file_pages_lock);
|
|
||||||
struct shared_file_page *sfp
|
|
||||||
= shared_file_page_get (page->file, page->upage);
|
|
||||||
|
|
||||||
if (sfp != NULL)
|
|
||||||
{
|
|
||||||
/* Frame exists, just install it. */
|
|
||||||
if (sfp->frame != NULL)
|
|
||||||
{
|
|
||||||
if (!install_page (page->upage, sfp->frame, page->writable))
|
|
||||||
{
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
frame_owner_insert (sfp->frame, t);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Otherwise, shared page is in swap. Load it. */
|
|
||||||
else
|
|
||||||
{
|
|
||||||
void *frame = frame_alloc (PAL_USER, page->upage, t);
|
|
||||||
if (frame == NULL)
|
|
||||||
PANIC (
|
|
||||||
"Could not allocate a frame to load page into memory.");
|
|
||||||
swap_in (frame, sfp->swap_slot);
|
|
||||||
|
|
||||||
if (!install_page (page->upage, frame, false))
|
|
||||||
{
|
|
||||||
frame_free (frame);
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
page_flag_shared (t, page->upage, true);
|
|
||||||
if (page->type != PAGE_SHARED)
|
|
||||||
{
|
|
||||||
sfp->ref_count++;
|
|
||||||
page->type = PAGE_SHARED;
|
|
||||||
}
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void *frame = frame_alloc (PAL_USER, page->upage, t);
|
void *frame = frame_alloc (PAL_USER, page->upage, t);
|
||||||
pagedir_set_accessed (t->pagedir, page->upage, true);
|
pagedir_set_accessed (t->pagedir, page->upage, true);
|
||||||
if (frame == NULL)
|
if (frame == NULL)
|
||||||
PANIC ("Could not allocate a frame to load page into memory.");
|
PANIC ("Could not allocate a frame to load page into memory.");
|
||||||
|
|
||||||
/* Map the page to the frame. */
|
/* Map the page to the frame. */
|
||||||
if (!install_page (page->upage, frame, page->writable))
|
if (!install_page (page->upage, frame, writable))
|
||||||
{
|
{
|
||||||
if (shareable)
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
frame_free (frame);
|
frame_free (frame);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -257,8 +96,6 @@ page_load_file (struct page_entry *page)
|
|||||||
file_seek (page->file, page->offset);
|
file_seek (page->file, page->offset);
|
||||||
if (file_read (page->file, frame, page->read_bytes) != (int) page->read_bytes)
|
if (file_read (page->file, frame, page->read_bytes) != (int) page->read_bytes)
|
||||||
{
|
{
|
||||||
if (shareable)
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
frame_free (frame);
|
frame_free (frame);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -266,26 +103,7 @@ page_load_file (struct page_entry *page)
|
|||||||
/* Zero out the remaining bytes in the frame. */
|
/* Zero out the remaining bytes in the frame. */
|
||||||
memset (frame + page->read_bytes, 0, page->zero_bytes);
|
memset (frame + page->read_bytes, 0, page->zero_bytes);
|
||||||
|
|
||||||
/* If file page is read-only, make it shared. */
|
page->frame = frame;
|
||||||
if (shareable)
|
|
||||||
{
|
|
||||||
struct shared_file_page *sfp = malloc (sizeof (struct shared_file_page));
|
|
||||||
if (sfp == NULL)
|
|
||||||
{
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
frame_free (frame);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
sfp->file = page->file;
|
|
||||||
sfp->upage = page->upage;
|
|
||||||
sfp->frame = frame;
|
|
||||||
sfp->swap_slot = 0;
|
|
||||||
sfp->ref_count = 1;
|
|
||||||
hash_insert (&shared_file_pages, &sfp->elem);
|
|
||||||
page_flag_shared (t, page->upage, true);
|
|
||||||
page->type = PAGE_SHARED;
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Mark the page as loaded successfully. */
|
/* Mark the page as loaded successfully. */
|
||||||
return true;
|
return true;
|
||||||
@@ -297,44 +115,21 @@ void
|
|||||||
page_cleanup (struct hash_elem *e, void *aux UNUSED)
|
page_cleanup (struct hash_elem *e, void *aux UNUSED)
|
||||||
{
|
{
|
||||||
struct page_entry *page = hash_entry (e, struct page_entry, elem);
|
struct page_entry *page = hash_entry (e, struct page_entry, elem);
|
||||||
if (page->type == PAGE_SHARED)
|
|
||||||
{
|
if (page->frame != NULL)
|
||||||
lock_acquire (&shared_file_pages_lock);
|
frame_free (page->frame);
|
||||||
struct shared_file_page *sfp
|
|
||||||
= shared_file_page_get (page->file, page->upage);
|
|
||||||
ASSERT (sfp != NULL);
|
|
||||||
if (sfp->frame != NULL)
|
|
||||||
frame_owner_remove (sfp->frame, thread_current ());
|
|
||||||
sfp->ref_count--;
|
|
||||||
if (sfp->ref_count == 0)
|
|
||||||
{
|
|
||||||
hash_delete (&shared_file_pages, &sfp->elem);
|
|
||||||
if (sfp->frame != NULL)
|
|
||||||
frame_free (sfp->frame);
|
|
||||||
else
|
|
||||||
swap_drop (sfp->swap_slot);
|
|
||||||
free (sfp);
|
|
||||||
}
|
|
||||||
lock_release (&shared_file_pages_lock);
|
|
||||||
}
|
|
||||||
free (page);
|
free (page);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Flags the provided page table entry as representing a swapped out page. */
|
/* Updates the 'owner' thread's page table entry for virtual address 'upage'
|
||||||
|
to flag the page as being stored in swap, and stores the specified swap slot
|
||||||
|
value in the entry at the address bits for later retrieval from disk. */
|
||||||
void
|
void
|
||||||
page_flag_swap (uint32_t *pte, bool set)
|
page_set_swap (struct thread *owner, void *upage, size_t swap_slot)
|
||||||
{
|
{
|
||||||
if (set)
|
uint32_t *pte = lookup_page (owner->pagedir, upage, false);
|
||||||
*pte |= (1 << SWAP_FLAG_BIT);
|
|
||||||
else
|
|
||||||
*pte &= ~(1 << SWAP_FLAG_BIT);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Sets the address bits of the page table entry to the provided swap slot
|
|
||||||
value. To be used for later retrieval of the swap slot when page faulting. */
|
|
||||||
static void
|
|
||||||
page_set_swap (struct thread *owner, uint32_t *pte, size_t swap_slot)
|
|
||||||
{
|
|
||||||
/* Store the provided swap slot in the address bits of the page table
|
/* Store the provided swap slot in the address bits of the page table
|
||||||
entry, truncating excess bits. */
|
entry, truncating excess bits. */
|
||||||
*pte |= (1 << SWAP_FLAG_BIT);
|
*pte |= (1 << SWAP_FLAG_BIT);
|
||||||
@@ -350,19 +145,13 @@ bool
|
|||||||
page_in_swap (struct thread *owner, void *upage)
|
page_in_swap (struct thread *owner, void *upage)
|
||||||
{
|
{
|
||||||
uint32_t *pte = lookup_page (owner->pagedir, upage, false);
|
uint32_t *pte = lookup_page (owner->pagedir, upage, false);
|
||||||
return page_in_swap_pte (pte);
|
return pte != NULL &&
|
||||||
}
|
(*pte & (1 << SWAP_FLAG_BIT)) != 0;
|
||||||
|
|
||||||
/* Returns true iff the page table entry is marked to be in the swap disk. */
|
|
||||||
bool
|
|
||||||
page_in_swap_pte (uint32_t *pte)
|
|
||||||
{
|
|
||||||
return pte != NULL && (*pte & (1 << SWAP_FLAG_BIT)) != 0;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Given that the page with user address 'upage' owned by 'owner' is flagged
|
/* Given that the page with user address 'upage' owned by 'owner' is flagged
|
||||||
to be in the swap disk via the owner's page table, returns its stored
|
to be in the swap disk via the owner's page table, returns its stored
|
||||||
swap slot and marks the PTE as not being in swap. */
|
swap slot. Otherwise panics the kernel. */
|
||||||
size_t
|
size_t
|
||||||
page_get_swap (struct thread *owner, void *upage)
|
page_get_swap (struct thread *owner, void *upage)
|
||||||
{
|
{
|
||||||
@@ -372,85 +161,5 @@ page_get_swap (struct thread *owner, void *upage)
|
|||||||
ASSERT ((*pte & PTE_P) == 0);
|
ASSERT ((*pte & PTE_P) == 0);
|
||||||
|
|
||||||
/* Masks the address bits and returns truncated value. */
|
/* Masks the address bits and returns truncated value. */
|
||||||
page_flag_swap (pte, false);
|
|
||||||
return ((*pte & PTE_ADDR) >> ADDR_START_BIT);
|
return ((*pte & PTE_ADDR) >> ADDR_START_BIT);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Returns the swap slot stored in a PTE. */
|
|
||||||
size_t
|
|
||||||
page_get_swap_pte (uint32_t *pte)
|
|
||||||
{
|
|
||||||
ASSERT (pte != NULL);
|
|
||||||
ASSERT ((*pte & PTE_P) == 0);
|
|
||||||
return ((*pte & PTE_ADDR) >> ADDR_START_BIT);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Flags the provided page table entry as representing a shared page. */
|
|
||||||
static void
|
|
||||||
page_flag_shared (struct thread *owner, void *upage, bool shared)
|
|
||||||
{
|
|
||||||
uint32_t *pte = lookup_page (owner->pagedir, upage, false);
|
|
||||||
ASSERT (pte != NULL);
|
|
||||||
|
|
||||||
if (shared)
|
|
||||||
*pte |= (1 << SHARED_FLAG_BIT);
|
|
||||||
else
|
|
||||||
*pte &= ~(1 << SHARED_FLAG_BIT);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Returns true iff the page table entry is marked to be shared. */
|
|
||||||
bool
|
|
||||||
page_is_shared_pte (uint32_t *pte)
|
|
||||||
{
|
|
||||||
return pte != NULL && (*pte & (1 << SHARED_FLAG_BIT)) != 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Initializes the shared file pages hash table. */
|
|
||||||
void
|
|
||||||
shared_file_pages_init ()
|
|
||||||
{
|
|
||||||
if (!hash_init (&shared_file_pages, shared_file_page_hash,
|
|
||||||
shared_file_page_less, NULL))
|
|
||||||
PANIC ("Failed to initialize shared file pages hash table.");
|
|
||||||
lock_init (&shared_file_pages_lock);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Hash function for shared file pages, used for storing entries in the
|
|
||||||
shared file pages table. */
|
|
||||||
static unsigned
|
|
||||||
shared_file_page_hash (const struct hash_elem *e, void *aux UNUSED)
|
|
||||||
{
|
|
||||||
struct shared_file_page *sfp = hash_entry (e, struct shared_file_page, elem);
|
|
||||||
void *inode = file_get_inode (sfp->file);
|
|
||||||
void *upage = sfp->upage;
|
|
||||||
void *bytes[2] = { inode, upage };
|
|
||||||
return hash_bytes (bytes, sizeof (bytes));
|
|
||||||
}
|
|
||||||
|
|
||||||
/* 'less_func' comparison function for shared file pages, used for comparing
|
|
||||||
the keys of the shared file pages table. */
|
|
||||||
static bool
|
|
||||||
shared_file_page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
|
||||||
void *aux UNUSED)
|
|
||||||
{
|
|
||||||
const struct shared_file_page *a
|
|
||||||
= hash_entry (a_, struct shared_file_page, elem);
|
|
||||||
const struct shared_file_page *b
|
|
||||||
= hash_entry (b_, struct shared_file_page, elem);
|
|
||||||
|
|
||||||
return !file_compare (a->file, b->file) || a->upage < b->upage;
|
|
||||||
}
|
|
||||||
|
|
||||||
static struct shared_file_page *
|
|
||||||
shared_file_page_get (struct file *file, void *upage)
|
|
||||||
{
|
|
||||||
struct shared_file_page fake_sfp;
|
|
||||||
fake_sfp.file = file;
|
|
||||||
fake_sfp.upage = upage;
|
|
||||||
|
|
||||||
struct hash_elem *e = hash_find (&shared_file_pages, &fake_sfp.elem);
|
|
||||||
if (e == NULL)
|
|
||||||
return NULL;
|
|
||||||
|
|
||||||
return hash_entry (e, struct shared_file_page, elem);
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -2,25 +2,17 @@
|
|||||||
#define VM_PAGE_H
|
#define VM_PAGE_H
|
||||||
|
|
||||||
#include "threads/thread.h"
|
#include "threads/thread.h"
|
||||||
#include "threads/synch.h"
|
|
||||||
#include "filesys/off_t.h"
|
#include "filesys/off_t.h"
|
||||||
|
|
||||||
enum page_type
|
enum page_type {
|
||||||
{
|
PAGE_FILE,
|
||||||
PAGE_EXECUTABLE,
|
PAGE_EMPTY
|
||||||
PAGE_MMAP,
|
|
||||||
PAGE_SHARED
|
|
||||||
};
|
};
|
||||||
|
|
||||||
struct page_entry
|
struct page_entry {
|
||||||
{
|
|
||||||
enum page_type type; /* Type of Data that should go into the page */
|
enum page_type type; /* Type of Data that should go into the page */
|
||||||
void *upage; /* Start Address of the User Page (Key of hash table). */
|
void *upage; /* Start Address of the User Page (Key of hash table). */
|
||||||
|
void *frame; /* Frame Address where the page is loaded. */
|
||||||
/* Data for swapped pages */
|
|
||||||
struct lock lock; /* Enforces mutual exclusion in accessing the page
|
|
||||||
referenced by the entry between its owning process
|
|
||||||
and any thread performing page eviction. */
|
|
||||||
|
|
||||||
/* File Data */
|
/* File Data */
|
||||||
struct file *file; /* Pointer to the file for executables. */
|
struct file *file; /* Pointer to the file for executables. */
|
||||||
@@ -32,37 +24,18 @@ struct page_entry
|
|||||||
struct hash_elem elem; /* An elem for the hash table. */
|
struct hash_elem elem; /* An elem for the hash table. */
|
||||||
};
|
};
|
||||||
|
|
||||||
struct shared_file_page
|
unsigned page_hash (const struct hash_elem *e, void *aux);
|
||||||
{
|
bool page_less (const struct hash_elem *a_, const struct hash_elem *b_,
|
||||||
struct file *file; /* The shared file page's source file, used for indexing
|
void *aux);
|
||||||
the table. */
|
struct page_entry *page_insert (struct file *file, off_t ofs, void *upage,
|
||||||
void *upage; /* The shared page's upage which is the same across all process
|
uint32_t read_bytes, uint32_t zero_bytes,
|
||||||
using it. Used for indexing the table. */
|
bool writable, enum page_type type);
|
||||||
void *frame; /* Set to the frame address of the page when it is in memory.
|
struct page_entry *page_get (void *upage);
|
||||||
Set to NULL when the page is in swap. */
|
bool page_load (struct page_entry *page, bool writable);
|
||||||
size_t swap_slot; /* Set to the swap_slot of the shared paged if it is
|
|
||||||
currently in swap. Should not be used when frame is not
|
|
||||||
NULL.*/
|
|
||||||
int ref_count; /* Number of processes that are using this shared page. */
|
|
||||||
|
|
||||||
struct hash_elem elem; /* AN elem for the hash table. */
|
|
||||||
};
|
|
||||||
|
|
||||||
bool init_pages (struct hash *pages);
|
|
||||||
bool page_insert_swapped (void *upage, void *kpage, struct list *owners);
|
|
||||||
struct page_entry *page_insert_file (struct file *file, off_t ofs, void *upage,
|
|
||||||
uint32_t read_bytes, uint32_t zero_bytes,
|
|
||||||
bool writable, enum page_type);
|
|
||||||
struct page_entry *page_get (struct thread *thread, void *upage);
|
|
||||||
bool page_load_file (struct page_entry *page);
|
|
||||||
void page_cleanup (struct hash_elem *e, void *aux);
|
void page_cleanup (struct hash_elem *e, void *aux);
|
||||||
|
|
||||||
|
void page_set_swap (struct thread *, void *, size_t);
|
||||||
bool page_in_swap (struct thread *, void *);
|
bool page_in_swap (struct thread *, void *);
|
||||||
bool page_in_swap_pte (uint32_t *pte);
|
size_t page_get_swap (struct thread *, void *);
|
||||||
size_t page_get_swap (struct thread *owner, void *upage);
|
|
||||||
size_t page_get_swap_pte (uint32_t *pte);
|
|
||||||
|
|
||||||
bool page_is_shared_pte (uint32_t *pte);
|
#endif /* vm/frame.h */
|
||||||
void shared_file_pages_init (void);
|
|
||||||
|
|
||||||
#endif
|
|
||||||
|
|||||||
Reference in New Issue
Block a user