47 lines
1.1 KiB
C
47 lines
1.1 KiB
C
#include <stdint.h>
|
|
#include "proc/proc.h"
|
|
#include "dlmalloc/malloc.h"
|
|
#include "ipc/pipe/pipe.h"
|
|
#include "kprintf.h"
|
|
#include "rbuf/rbuf.h"
|
|
#include "ps2kbproc.h"
|
|
|
|
Proc *PS2KBPROC = NULL;
|
|
Ps2KbFastBuf PS2KB_BUF;
|
|
|
|
|
|
void ps2kbproc_init(Proc *proc) {
|
|
PS2KBPROC = proc;
|
|
|
|
PS2KBPROC->bcast_pipes.list = NULL;
|
|
|
|
PS2KB_BUF.rbuf.buffer = dlmalloc(IPC_PIPE_MAX);
|
|
PS2KB_BUF.rbuf.cap = IPC_PIPE_MAX;
|
|
spinlock_init(&PS2KB_BUF.spinlock);
|
|
}
|
|
|
|
void ps2kbproc_fn(void) {
|
|
for (;;) {
|
|
int32_t kbchr;
|
|
uint8_t *buf = (uint8_t *)&kbchr;
|
|
size_t i = 0;
|
|
spinlock_acquire(&PS2KB_BUF.spinlock);
|
|
for (; i < sizeof(kbchr); i++) {
|
|
if (rbuf_pop(&PS2KB_BUF.rbuf, &buf[i]) < 0) {
|
|
break;
|
|
}
|
|
}
|
|
spinlock_release(&PS2KB_BUF.spinlock);
|
|
if (i > 0) {
|
|
spinlock_acquire(&PS2KBPROC->bcast_pipes.spinlock);
|
|
IpcPipe *head = PS2KBPROC->bcast_pipes.list;
|
|
while (head != NULL) {
|
|
ipc_pipewrite(head, (uint8_t *)&kbchr, sizeof(kbchr));
|
|
head = head->next;
|
|
}
|
|
spinlock_release(&PS2KBPROC->bcast_pipes.spinlock);
|
|
}
|
|
}
|
|
}
|
|
|