Compare commits
7 Commits
bad-synch
...
vm/merged/
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
be696ec528 | ||
|
|
7f058ffc90 | ||
|
c1bc70adad
|
|||
|
|
22f3b0950f | ||
|
f64b92bbfa
|
|||
|
|
3d6e30119b | ||
|
4104d2c852
|
@@ -38,4 +38,3 @@ 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)
|
|
||||||
|
|||||||
@@ -289,7 +289,7 @@ fetch_page (void *upage, bool write)
|
|||||||
bool success = false;
|
bool success = false;
|
||||||
switch (page->type) {
|
switch (page->type) {
|
||||||
case PAGE_MMAP:
|
case PAGE_MMAP:
|
||||||
case PAGE_FILE:
|
case PAGE_EXECUTABLE:
|
||||||
case PAGE_SHARED:
|
case PAGE_SHARED:
|
||||||
success = page_load_file (page);
|
success = page_load_file (page);
|
||||||
break;
|
break;
|
||||||
|
|||||||
@@ -6,7 +6,6 @@
|
|||||||
#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 "threads/synch.h"
|
|
||||||
#include "vm/frame.h"
|
#include "vm/frame.h"
|
||||||
#include "vm/page.h"
|
#include "vm/page.h"
|
||||||
|
|
||||||
@@ -36,7 +35,6 @@ pagedir_destroy (uint32_t *pd)
|
|||||||
return;
|
return;
|
||||||
|
|
||||||
ASSERT (pd != init_page_dir);
|
ASSERT (pd != init_page_dir);
|
||||||
lock_acquire (&lru_lock);
|
|
||||||
for (pde = pd; pde < pd + pd_no (PHYS_BASE); pde++)
|
for (pde = pd; pde < pd + pd_no (PHYS_BASE); pde++)
|
||||||
if (*pde & PTE_P)
|
if (*pde & PTE_P)
|
||||||
{
|
{
|
||||||
@@ -55,7 +53,6 @@ pagedir_destroy (uint32_t *pd)
|
|||||||
palloc_free_page (pt);
|
palloc_free_page (pt);
|
||||||
}
|
}
|
||||||
palloc_free_page (pd);
|
palloc_free_page (pd);
|
||||||
lock_release (&lru_lock);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Returns the address of the page table entry for virtual
|
/* Returns the address of the page table entry for virtual
|
||||||
|
|||||||
@@ -715,7 +715,7 @@ load_segment (struct file *file, off_t ofs, uint8_t *upage,
|
|||||||
|
|
||||||
/* 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 (file, ofs, upage, page_read_bytes, page_zero_bytes,
|
||||||
writable, PAGE_FILE) == NULL)
|
writable, PAGE_EXECUTABLE) == NULL)
|
||||||
return false;
|
return false;
|
||||||
|
|
||||||
/* Advance. */
|
/* Advance. */
|
||||||
|
|||||||
@@ -461,10 +461,9 @@ 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 (thread_current (), 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)
|
||||||
@@ -473,7 +472,7 @@ syscall_mmap (int fd, void *addr)
|
|||||||
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 (file, ofs, addr + ofs, read_bytes, zero_bytes, true,
|
||||||
PAGE_FILE) == NULL)
|
PAGE_MMAP) == NULL)
|
||||||
return MMAP_FAILURE;
|
return MMAP_FAILURE;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -482,7 +481,6 @@ syscall_mmap (int fd, void *addr)
|
|||||||
if (mmap == NULL)
|
if (mmap == NULL)
|
||||||
return MMAP_FAILURE;
|
return MMAP_FAILURE;
|
||||||
|
|
||||||
|
|
||||||
return mmap->mapping;
|
return mmap->mapping;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -40,8 +40,8 @@ struct frame_metadata
|
|||||||
within 'frame_table', whose key is the
|
within 'frame_table', whose key is the
|
||||||
kernel virtual address of the frame. */
|
kernel virtual address of the frame. */
|
||||||
struct list_elem list_elem; /* Tracks the position of the frame metadata
|
struct list_elem list_elem; /* Tracks the position of the frame metadata
|
||||||
in either the 'active' or 'inactive' list,
|
within 'lru_list', so a victim can be
|
||||||
so a victim can be chosen for eviction. */
|
chosen for eviction. */
|
||||||
};
|
};
|
||||||
|
|
||||||
hash_hash_func frame_metadata_hash;
|
hash_hash_func frame_metadata_hash;
|
||||||
@@ -63,7 +63,7 @@ frame_init (void)
|
|||||||
hash_init (&frame_table, frame_metadata_hash, frame_metadata_less, NULL);
|
hash_init (&frame_table, frame_metadata_hash, frame_metadata_less, NULL);
|
||||||
|
|
||||||
list_init (&lru_list);
|
list_init (&lru_list);
|
||||||
lock_init (&lru_lock);
|
lock_init (&ftable_lock);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* TODO: Consider synchronisation more closely (i.e. just for hash
|
/* TODO: Consider synchronisation more closely (i.e. just for hash
|
||||||
@@ -79,7 +79,7 @@ frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
|||||||
struct frame_metadata *frame_metadata;
|
struct frame_metadata *frame_metadata;
|
||||||
flags |= PAL_USER;
|
flags |= PAL_USER;
|
||||||
|
|
||||||
lock_acquire (&lru_lock);
|
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,
|
/* If a frame couldn't be allocated we must be out of main memory. Thus,
|
||||||
@@ -122,7 +122,7 @@ frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
|||||||
memset (victim->frame, 0, PGSIZE);
|
memset (victim->frame, 0, PGSIZE);
|
||||||
|
|
||||||
/* 3. Indicate that the new frame's metadata will be stored
|
/* 3. Indicate that the new frame's metadata will be stored
|
||||||
inside the same structure that stored the victim's metadata.
|
inside the same structure that stored the victim's metadata.frame.c
|
||||||
As both the new frame and the victim frame share the same kernel
|
As both the new frame and the victim frame share the same kernel
|
||||||
virtual address, the hash map need not be updated, and neither
|
virtual address, the hash map need not be updated, and neither
|
||||||
the list_elem value as both share the same lru_list position. */
|
the list_elem value as both share the same lru_list position. */
|
||||||
@@ -133,7 +133,7 @@ frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
|||||||
we must update the frame table with a new entry, and grow lru_list. */
|
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
|
/* Must own ftable_lock here, as otherwise there is a race condition
|
||||||
with next_victim either being NULL or uninitialized. */
|
with next_victim either being NULL or uninitialized. */
|
||||||
frame_metadata = malloc (sizeof (struct frame_metadata));
|
frame_metadata = malloc (sizeof (struct frame_metadata));
|
||||||
if (frame_metadata == NULL)
|
if (frame_metadata == NULL)
|
||||||
@@ -165,7 +165,7 @@ frame_alloc (enum palloc_flags flags, void *upage, struct thread *owner)
|
|||||||
list_push_back (&frame_metadata->owners, &frame_owner->elem);
|
list_push_back (&frame_metadata->owners, &frame_owner->elem);
|
||||||
frame_metadata->upage = upage;
|
frame_metadata->upage = upage;
|
||||||
frame_metadata->pinned = false;
|
frame_metadata->pinned = false;
|
||||||
lock_release (&lru_lock);
|
lock_release (&ftable_lock);
|
||||||
return frame_metadata->frame;
|
return frame_metadata->frame;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -173,28 +173,28 @@ void
|
|||||||
frame_pin (void *frame)
|
frame_pin (void *frame)
|
||||||
{
|
{
|
||||||
ASSERT (frame != NULL);
|
ASSERT (frame != NULL);
|
||||||
lock_acquire (&lru_lock);
|
lock_acquire (&ftable_lock);
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_get (frame);
|
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 (&lru_lock);
|
lock_release (&ftable_lock);
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
frame_unpin (void *frame)
|
frame_unpin (void *frame)
|
||||||
{
|
{
|
||||||
ASSERT (frame != NULL);
|
ASSERT (frame != NULL);
|
||||||
lock_acquire (&lru_lock);
|
lock_acquire (&ftable_lock);
|
||||||
struct frame_metadata *frame_metadata = frame_metadata_get (frame);
|
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 (&lru_lock);
|
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
|
||||||
@@ -209,13 +209,8 @@ frame_free (void *frame)
|
|||||||
"but this address is not allocated!\n",
|
"but this address is not allocated!\n",
|
||||||
frame);
|
frame);
|
||||||
|
|
||||||
bool lock_held = lock_held_by_current_thread (&lru_lock);
|
|
||||||
|
|
||||||
free_owners (&frame_metadata->owners);
|
free_owners (&frame_metadata->owners);
|
||||||
|
lock_acquire (&ftable_lock);
|
||||||
if (!lock_held)
|
|
||||||
lock_acquire (&lru_lock);
|
|
||||||
|
|
||||||
hash_delete (&frame_table, &frame_metadata->hash_elem);
|
hash_delete (&frame_table, &frame_metadata->hash_elem);
|
||||||
list_remove (&frame_metadata->list_elem);
|
list_remove (&frame_metadata->list_elem);
|
||||||
|
|
||||||
@@ -229,9 +224,7 @@ frame_free (void *frame)
|
|||||||
else
|
else
|
||||||
next_victim = lru_next (next_victim);
|
next_victim = lru_next (next_victim);
|
||||||
}
|
}
|
||||||
|
lock_release (&ftable_lock);
|
||||||
if (!lock_held)
|
|
||||||
lock_release (&lru_lock);
|
|
||||||
|
|
||||||
free (frame_metadata);
|
free (frame_metadata);
|
||||||
palloc_free_page (frame);
|
palloc_free_page (frame);
|
||||||
@@ -294,9 +287,8 @@ frame_metadata_find (void *frame)
|
|||||||
return hash_entry (e, struct frame_metadata, hash_elem);
|
return hash_entry (e, struct frame_metadata, hash_elem);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* TODO: Account for page aliases when checking accessed bit. */
|
|
||||||
/* A pre-condition for calling this function is that the calling thread
|
/* A pre-condition for calling this function is that the calling thread
|
||||||
owns lru_lock and that lru_list is non-empty. */
|
owns ftable_lock and that lru_list is non-empty. */
|
||||||
static struct frame_metadata *
|
static struct frame_metadata *
|
||||||
get_victim (void)
|
get_victim (void)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -11,8 +11,9 @@ struct frame_owner
|
|||||||
};
|
};
|
||||||
|
|
||||||
/* Synchronisation variables. */
|
/* Synchronisation variables. */
|
||||||
/* Protects access to 'lru_list'. */
|
/* Protects access to the frame table and its related components. */
|
||||||
struct lock lru_lock;
|
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 *);
|
||||||
|
|||||||
@@ -198,11 +198,7 @@ page_load_file (struct page_entry *page)
|
|||||||
lock_release (&shared_file_pages_lock);
|
lock_release (&shared_file_pages_lock);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
/* First time adding the shared page, so add thread as owner. */
|
frame_owner_insert (sfp->frame, t);
|
||||||
if (page->type != PAGE_SHARED)
|
|
||||||
{
|
|
||||||
frame_owner_insert (sfp->frame, t);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
/* Shared page is in swap. Load it. */
|
/* Shared page is in swap. Load it. */
|
||||||
else
|
else
|
||||||
|
|||||||
@@ -7,9 +7,8 @@
|
|||||||
|
|
||||||
enum page_type
|
enum page_type
|
||||||
{
|
{
|
||||||
PAGE_FILE,
|
PAGE_EXECUTABLE,
|
||||||
PAGE_MMAP,
|
PAGE_MMAP,
|
||||||
PAGE_EMPTY,
|
|
||||||
PAGE_SHARED
|
PAGE_SHARED
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -35,13 +34,18 @@ struct page_entry
|
|||||||
|
|
||||||
struct shared_file_page
|
struct shared_file_page
|
||||||
{
|
{
|
||||||
struct file *file;
|
struct file *file; /* The shared file page's source file, used for indexing
|
||||||
void *upage;
|
the table. */
|
||||||
void *frame;
|
void *upage; /* The shared page's upage which is the same across all process
|
||||||
size_t swap_slot;
|
using it. Used for indexing the table. */
|
||||||
int ref_count;
|
void *frame; /* Set to the frame address of the page when it is in memory.
|
||||||
|
Set to NULL when the page is in swap. */
|
||||||
|
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;
|
struct hash_elem elem; /* AN elem for the hash table. */
|
||||||
};
|
};
|
||||||
|
|
||||||
bool init_pages (struct hash *pages);
|
bool init_pages (struct hash *pages);
|
||||||
|
|||||||
Reference in New Issue
Block a user