mirror of
https://github.com/SmallPond/MIT6.828_OS.git
synced 2026-02-03 11:03:16 +08:00
54 lines
995 B
C
54 lines
995 B
C
#include "ns.h"
|
|
#include <kern/e1000.h>
|
|
|
|
|
|
extern union Nsipc nsipcbuf;
|
|
|
|
|
|
void
|
|
sleep(int msec)
|
|
{
|
|
unsigned now = sys_time_msec();
|
|
unsigned end = now + msec;
|
|
|
|
if ((int)now < 0 && (int)now > -MAXERROR)
|
|
panic("sys_time_msec: %e", (int)now);
|
|
if (end < now)
|
|
panic("sleep: wrap");
|
|
|
|
while (sys_time_msec() < end)
|
|
sys_yield();
|
|
}
|
|
|
|
|
|
|
|
|
|
void
|
|
input(envid_t ns_envid)
|
|
{
|
|
binaryname = "ns_input";
|
|
|
|
// LAB 6: Your code here:
|
|
// - read a packet from the device driver
|
|
// - send it to the network server
|
|
// Hint: When you IPC a page to the network server, it will be
|
|
// reading from it for a while, so don't immediately receive
|
|
// another packet in to the same physical page.
|
|
size_t len;
|
|
char rev_buf[RX_PACKET_SIZE];
|
|
size_t i = 0;
|
|
while(1) {
|
|
// 阻塞式读
|
|
while ( sys_pkt_try_receive(rev_buf, &len) < 0) {
|
|
sys_yield();
|
|
}
|
|
memcpy(nsipcbuf.pkt.jp_data, rev_buf, len);
|
|
nsipcbuf.pkt.jp_len = len;
|
|
|
|
ipc_send(ns_envid, NSREQ_INPUT, &nsipcbuf, PTE_P|PTE_U);
|
|
sleep(50);
|
|
}
|
|
|
|
}
|
|
|