. - mu - Soul of a tiny new machine. More thorough tests → More comprehensible and rewrite-friendly software → More resilient society.

diff options

author	Kartik Agaram <vc@akkartik.com>	2021-06-26 09:20:32 -0700
committer	Kartik Agaram <vc@akkartik.com>	2021-06-26 09:20:32 -0700
commit	dc5a0acf3feea227d03a98cedf427d2aef462320 (patch)
tree	ee6eff6dfc02b88063b51b7d413f03a91566403f /html/shell/cell.mu.html
parent	f7a7db83eff079d0494ded92fd73403d23a55538 (diff)
download	mu-dc5a0acf3feea227d03a98cedf427d2aef462320.tar.gz

Switch html rendering to my current colorscheme with a little less blue,
for night browsing.

Diffstat (limited to 'html/shell/cell.mu.html')

-rw-r--r--

html/shell/cell.mu.html

1 files changed, 7 insertions, 7 deletions

#include "list.h" #include "pipe.h" #include "fs.h" #include "alloc.h" #include "fifobuffer.h" static List* gPipeList = NULL; static FileSystemNode* gPipesRoot = NULL; static FileSystemDirent gDirent; typedef struct Pipe { char name[32]; FifoBuffer* buffer; FileSystemNode* fsNode; List* accessingThreads; } Pipe; static BOOL pipes_open(File *file, uint32 flags); static FileSystemDirent *pipes_readdir(FileSystemNode *node, uint32 index); static FileSystemNode *pipes_finddir(FileSystemNode *node, char *name); void initializePipes() { gPipeList = List_Create(); gPipesRoot = getFileSystemNode("/system/pipes"); if (NULL == gPipesRoot) { WARNING("/system/pipes not found!!"); } else { gPipesRoot->open = pipes_open; gPipesRoot->finddir = pipes_finddir; gPipesRoot->readdir = pipes_readdir; } } static BOOL pipes_open(File *file, uint32 flags) { return TRUE; } static FileSystemDirent *pipes_readdir(FileSystemNode *node, uint32 index) { int counter = 0; List_Foreach (n, gPipeList) { Pipe* p = (Pipe*)n->data; if (counter == index) { strcpy(gDirent.name, p->name); gDirent.fileType = FT_Pipe; return &gDirent; } ++counter; } return NULL; } static FileSystemNode *pipes_finddir(FileSystemNode *node, char *name) { List_Foreach (n, gPipeList) { Pipe* p = (Pipe*)n->data; if (strcmp(name, p->name) == 0) { return p->fsNode; } } return NULL; } static BOOL pipe_open(File *file, uint32 flags) { beginCriticalSection(); Pipe* pipe = file->node->privateNodeData; List_Append(pipe->accessingThreads, file->thread); endCriticalSection(); return TRUE; } static void pipe_close(File *file) { beginCriticalSection(); Pipe* pipe = file->node->privateNodeData; List_RemoveFirstOccurrence(pipe->accessingThreads, file->thread); endCriticalSection(); } static void blockAccessingThreads(Pipe* pipe) { disableInterrupts(); List_Foreach (n, pipe->accessingThreads) { Thread* reader = n->data; reader->state = TS_WAITIO; reader->state_privateData = pipe; } enableInterrupts(); halt(); } static void wakeupAccessingThreads(Pipe* pipe) { beginCriticalSection(); List_Foreach (n, pipe->accessingThreads) { Thread* reader = n->data; if (reader->state == TS_WAITIO) { if (reader->state_privateData == pipe) { reader->state = TS_RUN; } } } endCriticalSection(); } static int32 pipe_read(File *file, uint32 size, uint8 *buffer) { if (0 == size || NULL == buffer) { return -1; } Pipe* pipe = file->node->privateNodeData; uint32 used = 0; while ((used = FifoBuffer_getSize(pipe->buffer)) < size) { blockAccessingThreads(pipe); } disableInterrupts(); int32 readBytes = FifoBuffer_dequeue(pipe->buffer, buffer, size); wakeupAccessingThreads(pipe); return readBytes; } static int32 pipe_write(File *file, uint32 size, uint8 *buffer) { if (0 == size || NULL == buffer) { return -1; } Pipe* pipe = file->node->privateNodeData; uint32 free = 0; while ((free = FifoBuffer_getFree(pipe->buffer)) < size) { blockAccessingThreads(pipe); } disableInterrupts(); int32 bytesWritten = FifoBuffer_enqueue(pipe->buffer, buffer, size); wakeupAccessingThreads(pipe); return bytesWritten; } BOOL createPipe(const char* name, uint32 bufferSize) { List_Foreach (n, gPipeList) { Pipe* p = (Pipe*)n->data; if (strcmp(name, p->name) == 0) { return FALSE; } } Pipe* pipe = (Pipe*)kmalloc(sizeof(Pipe)); memset((uint8*)pipe, 0, sizeof(Pipe)); strcpy(pipe->name, name); pipe->buffer = FifoBuffer_create(bufferSize); pipe->accessingThreads = List_Create(); pipe->fsNode = (FileSystemNode*)kmalloc(sizeof(FileSystemNode)); memset((uint8*)pipe->fsNode, 0, sizeof(FileSystemNode)); pipe->fsNode->privateNodeData = pipe; pipe->fsNode->open = pipe_open; pipe->fsNode->close = pipe_close; pipe->fsNode->read = pipe_read; pipe->fsNode->write = pipe_write; List_Append(gPipeList, pipe); return TRUE; } BOOL destroyPipe(const char* name) { List_Foreach (n, gPipeList) { Pipe* p = (Pipe*)n->data; if (strcmp(name, p->name) == 0) { List_RemoveFirstOccurrence(gPipeList, p); FifoBuffer_destroy(p->buffer); List_Destroy(p->accessingThreads); kfree(p->fsNode); kfree(p); return TRUE; } } return FALSE; } BOOL existsPipe(const char* name) { List_Foreach (n, gPipeList) { Pipe* p = (Pipe*)n->data; if (strcmp(name, p->name) == 0) { return TRUE; } } return FALSE; }


context:
space:
mode: