Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-07-15 08:47:35 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Issue #236 - Added C functions for single-byte I/O

Browse source
This commit is contained in:
Justin Ethier 2017-12-18 17:27:53 -05:00
parent 05d9e7e204
commit 4b8c53c088
2 changed files with 61 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
include/cyclone/runtime.h
View file

@ -267,6 +267,9 @@ object Cyc_io_close_output_port(void *data, object port);
object Cyc_io_flush_output_port(void *data, object port);
object Cyc_io_read_char(void *data, object cont, object port);
object Cyc_io_peek_char(void *data, object cont, object port);
object Cyc_write_u8(void *data, object c, object port);
object Cyc_io_read_u8(void *data, object cont, object port);
object Cyc_io_peek_u8(void *data, object cont, object port);
object Cyc_io_read_line(void *data, object cont, object port);
void Cyc_io_read_token(void *data, object cont, object port);
/**@}*/

58
runtime.c
View file

@ -1113,6 +1113,21 @@ object Cyc_write_char(void *data, object c, object port)
return quote_void;
}
object Cyc_write_u8(void *data, object c, object port)
{
Cyc_check_port(data, port);
if (obj_is_char(c)) {
FILE *fp = ((port_type *) port)->fp;
if (fp){
char_type unbox = obj_obj2char(c);
fprintf(fp, "%c", unbox);
}
} else {
Cyc_rt_raise2(data, "Argument is not a character", c);
}
return quote_void;
}
/* Fast versions of member and assoc */
object memberp(void *data, object x, list l)
{
@ -6401,6 +6416,29 @@ object Cyc_io_peek_char(void *data, object cont, object port)
return Cyc_EOF;
}
object Cyc_io_peek_u8(void *data, object cont, object port)
{
FILE *stream;
port_type *p;
int c;
Cyc_check_port(data, port);
{
p = (port_type *)port;
stream = ((port_type *) port)->fp;
if (stream == NULL) {
Cyc_rt_raise2(data, "Unable to read from closed port: ", port);
}
set_thread_blocked(data, cont);
if (p->mem_buf_len == 0 || p->mem_buf_len == p->buf_idx) {
_read_next_char(data, cont, p);
}
c = p->mem_buf[p->buf_idx];
return_thread_runnable(data, (c != EOF) ? obj_char2obj(c) : Cyc_EOF);
}
return Cyc_EOF;
}
// TODO: full requirements are:
//
// Returns #t if a character is ready on the textual input
@ -6442,6 +6480,26 @@ object Cyc_io_read_char(void *data, object cont, object port)
return Cyc_EOF;
}
object Cyc_io_read_u8(void *data, object cont, object port)
{
port_type *p = (port_type *)port;
Cyc_check_port(data, port);
if (p->fp == NULL) {
Cyc_rt_raise2(data, "Unable to read from closed port: ", port);
}
{
char_type codepoint;
int c;
set_thread_blocked(data, cont);
_read_next_char(data, cont, p);
c = p->mem_buf[p->buf_idx++];
codepoint = (char_type) c;
p->col_num++;
return_thread_runnable(data, (c != EOF) ? obj_char2obj(codepoint) : Cyc_EOF);
}
return Cyc_EOF;
}
/* TODO: this function needs some work, but approximates what is needed */
object Cyc_io_read_line(void *data, object cont, object port)
{