forked from mit-pdos/xv6-public
-
Notifications
You must be signed in to change notification settings - Fork 0
/
ide.c
146 lines (120 loc) · 2.88 KB
/
ide.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
// Simple PIO-based (non-DMA) IDE driver code.
#include "types.h"
#include "param.h"
#include "mmu.h"
#include "proc.h"
#include "defs.h"
#include "x86.h"
#include "traps.h"
#include "spinlock.h"
#include "buf.h"
#define IDE_BSY 0x80
#define IDE_DRDY 0x40
#define IDE_DF 0x20
#define IDE_ERR 0x01
#define IDE_CMD_READ 0x20
#define IDE_CMD_WRITE 0x30
// ide_queue points to the buf now being read/written to the disk.
// ide_queue->qnext points to the next buf to be processed.
// You must hold ide_lock while manipulating queue.
static struct spinlock ide_lock;
static struct buf *ide_queue;
static int disk_1_present;
static void ide_start_request();
// Wait for IDE disk to become ready.
static int
ide_wait_ready(int check_error)
{
int r;
while(((r = inb(0x1f7)) & IDE_BSY) || !(r & IDE_DRDY))
;
if(check_error && (r & (IDE_DF|IDE_ERR)) != 0)
return -1;
return 0;
}
void
ide_init(void)
{
int i;
initlock(&ide_lock, "ide");
irq_enable(IRQ_IDE);
ioapic_enable(IRQ_IDE, ncpu - 1);
ide_wait_ready(0);
// Check if disk 1 is present
outb(0x1f6, 0xE0 | (1<<4));
for(i=0; i<1000; i++){
if(inb(0x1f7) != 0){
disk_1_present = 1;
break;
}
}
// Switch back to disk 0.
outb(0x1f6, 0xE0 | (0<<4));
}
// Start the request for b. Caller must hold ide_lock.
static void
ide_start_request(struct buf *b)
{
if(b == 0)
panic("ide_start_request");
ide_wait_ready(0);
outb(0x3f6, 0); // generate interrupt
outb(0x1f2, 1); // number of sectors
outb(0x1f3, b->sector & 0xff);
outb(0x1f4, (b->sector >> 8) & 0xff);
outb(0x1f5, (b->sector >> 16) & 0xff);
outb(0x1f6, 0xE0 | ((b->dev&1)<<4) | ((b->sector>>24)&0x0f));
if(b->flags & B_WRITE){
outb(0x1f7, IDE_CMD_WRITE);
outsl(0x1f0, b->data, 512/4);
}else{
outb(0x1f7, IDE_CMD_READ);
}
}
// Interrupt handler.
void
ide_intr(void)
{
struct buf *b;
acquire(&ide_lock);
if((b = ide_queue) == 0){
cprintf("stray ide interrupt\n");
release(&ide_lock);
return;
}
// Read data if needed.
if((b->flags & B_WRITE) == 0 && ide_wait_ready(1) >= 0)
insl(0x1f0, b->data, 512/4);
// Wake process waiting for this buf.
b->done = 1;
wakeup(b);
// Start disk on next buf in queue.
if((ide_queue = b->qnext) != 0)
ide_start_request(ide_queue);
release(&ide_lock);
}
//PAGEBREAK!
// Queue a disk operation and wait for it to finish.
void
ide_rw(struct buf *b)
{
struct buf **pp;
if(!(b->flags & B_BUSY))
panic("ide_rw: buf not busy");
if(b->dev != 0 && !disk_1_present)
panic("ide disk 1 not present");
acquire(&ide_lock);
// Append b to ide_queue.
b->done = 0;
b->qnext = 0;
for(pp=&ide_queue; *pp; pp=&(*pp)->qnext)
;
*pp = b;
// Start disk if necessary.
if(ide_queue == b)
ide_start_request(b);
// Wait for request to finish.
while(!b->done)
sleep(b, &ide_lock);
release(&ide_lock);
}