/barrelfish-master/usr/eclipseclp/Kernel/src/ |
H A D | ec_io.h | 49 #define StreamNr(nst) ((nst)->nr) /* int from stream_id */ 51 #define StreamUnit(nst) (nst)->unit 52 #define StreamMode(nst) (nst)->mode 53 #define StreamOutputMode(nst) (nst)->output_mode 54 #define StreamPrintDepth(nst) (nst) [all...] |
H A D | io.c | 51 * StreamBuf(nst) points to a buffer 52 * StreamPtr(nst) points into that buffer (read[/write] position) 53 * StreamSize(nst) is that buffer's size 54 * StreamCnt(nst) is the number of used bytes in that buffer 56 * StreamWBuf(nst) is used for queue streams only because they need to 263 #define Set_Stream(sdid, nst) \ 272 prop->val.wptr = (uword *) stream_tid.copy(nst); \ 275 #define Set_New_Stream(did, nst) \ 277 Set_Stream(did, nst) 279 #define Check_Stream_Owner(nst) \ 499 stream_id nst = StreamId(i); local 562 init_stream(stream_id nst, int unit, int mode, dident name, dident prompt, stream_id prompt_stream, int size) argument 672 _init_fd_stream(stream_id nst, int unit, int mode, dident name, dident prompt, stream_id prompt_stream, int size) argument 697 stream_id nst; local 739 stream_id nst; local 765 stream_id nst; local 798 _free_stream(stream_id nst) argument 861 ec_close_stream(stream_id nst, int options) argument 926 _local_io_close(stream_id nst) argument 987 stream_id nst = StreamId(i); local 1001 stream_id nst = StreamId(i); local 1026 fill_buffer(register stream_id nst) argument 1078 _local_fill_buffer(stream_id nst) argument 1184 _queue_fill_buffer(stream_id nst) argument 1203 _string_fill_buffer(stream_id nst) argument 1220 set_readline(stream_id nst) argument 1257 ec_getch(stream_id nst) argument 1284 ec_ungetch(stream_id nst) argument 1337 ec_getstring(stream_id nst, word n, word *res) argument 1415 _queue_read(stream_id nst, char *s, int count) argument 1452 _queue_content(stream_id nst, char *s) argument 1475 _queue_size(stream_id nst) argument 1486 _string_size(stream_id nst) argument 1505 _string_content(stream_id nst, char *s) argument 1529 stream_id nst = StreamId(qid); local 1540 stream_id nst = StreamId(qid); local 1552 _queue_write(stream_id nst, char *s, int count) argument 1618 _string_write(stream_id nst, char *s, int count) argument 1659 _buffer_write(stream_id nst, char *s, int count) argument 1698 _tty_write(stream_id nst, char *s, int count) argument 1715 _null_write(stream_id nst, char *s, int count) argument 1724 stream_id nst = StreamId(qid); local 1748 ec_outf(stream_id nst, const char *s, int count) argument 1768 ec_outfc(stream_id nst, int c) argument 1790 ec_outfw(stream_id nst, word w) argument 1809 ec_newline(stream_id nst) argument 1825 ec_outfs(stream_id nst, const char *s) argument 1831 ec_flush(stream_id nst) argument 1846 _resize_stream_buffer(stream_id nst, word newsize) argument 1874 _dummy_flush(stream_id nst) argument 1880 _queue_flush(stream_id nst) argument 1888 _buffer_flush(stream_id nst) argument 1901 _local_io_flush_out(stream_id nst) argument 1970 ec_seek_stream(stream_id nst, long int pos, int whence) argument 1977 _dummy_seek(stream_id nst, long int pos, int whence) argument 1984 _illegal_seek(stream_id nst, long int pos, int whence) argument 1990 _string_seek(stream_id nst, long int pos, int whence) argument 2080 _file_seek(stream_id nst, long int pos, int whence) argument 2148 _buffer_seek(stream_id nst, long int pos, int whence) argument 2176 ec_stream_at(stream_id nst, long int *pos) argument 2182 _buffer_at(stream_id nst, long int *pos) argument 2189 _file_at(stream_id nst, long int *pos) argument 2210 _socket_at(stream_id nst, long int *pos) argument 2218 _dummy_at(stream_id nst, long int *pos) argument 2232 _queue_at(stream_id nst, long int *pos) argument 2248 _string_nonempty(stream_id nst) argument 2255 _buffer_nonempty(stream_id nst) argument 2266 _always_at_eof(stream_id nst) argument 2272 _tty_at_eof(stream_id nst) argument 2278 _queue_at_eof(stream_id nst) argument 2284 _string_at_eof(stream_id nst) argument 2290 _buffer_at_eof(stream_id nst) argument 2330 _string_truncate(stream_id nst) argument 2349 _file_truncate(stream_id nst) argument 2384 p_fprintf(stream_id nst, char *fmt, ...) argument 2429 stream_id nst; local 2554 ec_tty_in(stream_id nst) argument 2575 _local_tty_in(stream_id nst) argument 2646 ec_tty_outs(stream_id nst, char *s, int n) argument 2677 ec_tty_out(stream_id nst, int c) argument 2803 ec_is_sigio_stream(stream_id nst, int sock_dir) argument 2812 ec_stream_set_sigio(stream_id nst, int sock_dir) argument 2831 ec_stream_reset_sigio(stream_id nst, int sock_dir) argument 2951 do_io_action(stream_id nst, int action) argument 2990 _dummy_size(stream_id nst) argument 2996 _dummy_content(stream_id nst, char *buf) argument [all...] |
H A D | bip_io.c | 87 #define StreamCanSignal(nst) IsSocket(nst) 93 #define StreamCanSignal(nst) (IsSocket(nst) || IsPipeStream(nst)) 159 #define StreamCanRaiseEvent(nst) (IsQueueStream(nst) || StreamCanSignal(nst)) 453 static void _lose_stream(stream_id nst); 454 static stream_id _copy_stream(stream_id nst); 461 _lose_stream(stream_id nst) argument 487 _copy_stream(stream_id nst) argument 494 _mark_stream(stream_id nst) argument 510 _tostr_stream(stream_id nst, char *buf, int quoted) argument 519 _strsz_stream(stream_id nst, int quoted) argument 562 stream_id nst; local 642 ec_get_stream(const pword pw, stream_id* nst) argument 661 stream_id nst = get_stream_id(v1, t1, 0, &err); local 676 stream_id nst; local 714 stream_id nst; local 763 stream_id nst; local 790 stream_id nst = get_stream_id(vs, ts, SREAD, &res); local 831 stream_id nst = get_stream_id(vs, ts, SWRITE, &res); local 870 stream_id nst = get_stream_id(vs,ts, SWRITE, &res); local 918 stream_id nst; local 1137 stream_id nst; local 1233 stream_id nst; local 1248 stream_id nst = get_stream_id(vs,ts, SREAD, &res); local 1269 stream_id nst = get_stream_id(vs,ts, SWRITE, &res); local 1384 stream_id nst; local 1449 stream_id nst; local 1497 stream_id nst; local 1519 stream_id nst = get_stream_id(vs, ts, 0, &res); local 1851 stream_id nst = get_stream_id(vs, ts, 0, &res); local 2137 stream_id nst = get_stream_id(vs,ts, 0, &res); local 2164 stream_id nst = get_stream_id(vs, ts, 0, &res); local 2190 stream_id nst = get_stream_id(vs, ts, 0, &res); local 2208 stream_id nst = get_stream_id(vs, ts, SREAD, &res); local 2231 stream_id nst = get_stream_id(vs, ts, SREAD, &res); local 2252 stream_id nst = get_stream_id(vs, ts, SREAD, &res); local 2305 stream_id nst = get_stream_id(vstr, tstr, SWRITE, &res); local 2346 stream_id nst = get_stream_id(vs, ts, 0, &res); local 2365 stream_id nst; local 2441 stream_id nst; local 2566 stream_id nst; local 2925 socket_bind(stream_id nst, value vaddr, type taddr) argument 3033 stream_id nst = get_stream_id(v, t, 0, &res); local 3047 socket_connect(stream_id nst, value vaddr, type taddr) argument 3161 stream_id nst = get_stream_id(v, t, 0, &res); local 3175 socket_listen(stream_id nst, value vn, type tn) argument 3189 stream_id nst = get_stream_id(v, t, 0, &res); local 3203 socket_accept(stream_id nst, value vaddr, type taddr, pword p, int sigio) argument 3291 stream_id nst = get_stream_id(v, t, 0, &res); local 3401 _sigio_thread_function(stream_id nst) argument 3442 ec_setup_stream_sigio_thread(stream_id nst) argument 3464 ec_reenable_sigio(stream_id nst, int bytes_wanted, int bytes_read) argument 3500 ec_setup_stream_sigio_thread(stream_id nst) argument 3504 ec_reenable_sigio(stream_id nst, int bytes_wanted, int bytes_read) argument 3537 ec_setup_stream_sigio_thread(stream_id nst) argument 3544 ec_reenable_sigio(stream_id nst, int bytes_wanted, int bytes_read) argument 3608 stream_id nst; local 3865 stream_id nst = get_stream_id(v, t, SREAD, &res); local 4028 stream_id nst = get_stream_id(v, t, 0, &res); local [all...] |
H A D | read.h | 49 Extern int ec_read_term ARGS((stream_id nst, int options, pword *result,
|
H A D | procedure.c | 82 * Check whether the next len characters in stream nst match header[]. 87 _skip_header_if_present(stream_id nst, char *header, int len) argument 91 if (IsTty(nst)) 99 res = ec_getch(nst); 104 ec_ungetch(nst); 130 _read_eco_header(stream_id nst) argument 137 int bufsize = StreamSize(nst); 138 StreamSize(nst) = MAGIC_LEN+1; 141 res = _skip_header_if_present(nst, eco_magic, MAGIC_LEN); 142 StreamSize(nst) 218 ec_load_eco_from_stream(stream_id nst, int options, pword *module) argument [all...] |
H A D | lex.c | 94 #define Find_Matching_Atom(end, nst, pw, stop) 96 static void _find_matching_atom(unsigned char *end, stream_id nst, unsigned char **pw, unsigned char **stop); 97 #define Find_Matching_Atom(end, nst, pw, stop) _find_matching_atom(end, nst, &pw, &stop) 101 #define Extend_Lex_Aux(nst, pw, stop) \ 102 pw = _extend_lex_aux(nst); \ 103 stop = StreamLexAux(nst) + StreamLexSize(nst); 115 static unsigned char *_extend_lex_aux(stream_id nst); 116 static int _skip_blanks(stream_id nst, syntax_des 352 lex_an( stream_id nst, syntax_desc *sd, token_desc *token ) argument 806 _skip_blanks(stream_id nst, syntax_desc *sd, unsigned char **p_pligne, int *p_cc, int *p_ctype) argument 985 _extend_lex_aux(stream_id nst) argument 1134 _find_matching_atom( unsigned char *end, stream_id nst, unsigned char **pw, unsigned char **stop) argument 1313 stream_id nst = get_stream_id(vs,ts, SREAD, &res); local 1510 string_to_number(char *start, pword *result, stream_id nst, syntax_desc *sd) argument [all...] |
H A D | bip_serialize.c | 268 #define Write_String_Or_Ref(nst, strhm, sval) \ 284 res = ec_outf(nst, buf, dest - buf); \ 288 if ((res = ec_outf(nst, buf, dest - buf)) == PSUCCEED) { \ 289 res = ec_outf(nst, StringStart(sval), StringLength(sval)); \ 897 _write_exdr(stream_id nst, pword *pw, t_heap_htable *strhm, int *perr) argument 911 return ec_outfc(nst, '_'); 920 Write_String_Or_Ref(nst, strhm, val); 930 Write_String_Or_Ref(nst, strhm, val); 938 if ((res = ec_outfc(nst, '[')) != PSUCCEED) return res; 940 if ((res = _write_exdr(nst, p 1053 stream_id nst = get_stream_id(vs, ts, SWRITE, &res); local 1094 _read_exdr(stream_id nst, t_heap_htable *strhm, pword *pw) argument 1274 stream_id nst = get_stream_id(vs, ts, SREAD, &res); local [all...] |
H A D | external.h | 181 #define Get_Stream(vs, ts, typ, nst) \ 184 nst = get_stream_id(vs, ts, typ, &res); \ 185 if (nst == 0) \
|
H A D | write.c | 141 _printf_asterisk(word asterisk, pword **list, type arg_type, stream_id nst, char *par), 525 _terminate_term(stream_id nst, int options, syntax_desc *sd) argument 531 if (Symbol(sd->char_class[(unsigned char)StreamLastWritten(nst)])) 533 Write_Char(nst, ' '); 535 Write_Char(nst, '.'); 537 return ec_newline(nst); /* maybe YIELD_ON_FLUSH_REQ */ 539 return ec_outfc(nst, ' '); 543 return ec_newline(nst); /* maybe YIELD_ON_FLUSH_REQ */ 1988 stream_id nst = get_stream_id(vs, ts, SWRITE, &res); local 1998 if (nst 2418 _printf_asterisk(word asterisk, pword **list, type arg_type, stream_id nst, char *par) argument [all...] |
H A D | read.c | 241 stream_id nst; /* stream we are reading from */ member in struct:parse_desc 279 *_alloc_parse_env(int caller, stream_id nst, dident module, type mod_tag); 289 _pread3(value v, type t, stream_id nst, value vm, type tm), 346 (void) lex_an(pd->nst, pd->sd, &pd->token); \ 354 if (pd->token.string == (char*) StreamLexAux(pd->nst)) { \ 362 if (pd->token.string == (char*) StreamLexAux(pd->nst)) { \ 380 if (TokenString(pd) == (char*) StreamLexAux(pd->nst)) { \ 1513 stream_id nst, /* the stream to read from */ 1527 if (StreamMode(nst) & REPROMPT_ONLY) 1528 StreamMode(nst) | 1512 ec_read_term( stream_id nst, int options, pword *result, pword *varlist, int *has_macro, value vm, type tm ) argument 1658 stream_id nst = get_stream_id(vs, ts, SREAD, &status); local 1680 _pread3(value v, type t, stream_id nst, value vm, type tm) argument 1718 stream_id nst = get_stream_id(vs, ts, SREAD, &status); local 1761 stream_id nst = get_stream_id(vs, ts, SREAD, &status); local 1812 _alloc_parse_env(int options, stream_id nst, dident module, type mod_tag) argument [all...] |
H A D | lex.h | 186 Extern char *string_to_number ARGS((char *start, pword *result, stream_id nst, syntax_desc *sd));
|
H A D | emu_par.c | 97 stream_id nst; /* MDT_ADDRESS */ member in struct:io_msg 1670 stream_id nst; local 1691 nst = ((struct io_msg *) msg_data)->nst; 1695 reply = do_io_action(nst, action); 1715 io_rpc(stream_id nst, int action) argument 1727 ((struct io_msg *) msg_data)->nst = nst; 1729 if (amsg_send(nst->aport, msg, MDT_IOREQUEST, 1, 0) != AMSG_OK)
|
H A D | emu_util.c | 578 static _print_code_address(stream_id nst, vmcode *code) argument 583 p_fprintf(nst,"%s/%d+%d", 586 p_fprintf(nst,"<proc unknown>");
|
H A D | bip_control.c | 220 stream_id nst; local 224 nst = get_stream_id(vs, ts, SWRITE, &res); 225 if (nst == NO_STREAM) { 231 profile_stream_ = nst;
|
H A D | printam.c | 59 void print_port(stream_id nst, int port); 1655 print_port(stream_id nst, int port) argument 1657 (void) p_fprintf(nst,"%s%s%s%s%s%s",
|
H A D | embed.h | 255 Extern DLLEXP int p_fprintf ARGS((stream_id nst, char *fmt, ...));
|
H A D | tkeclipse.c | 475 EcStreamClose(ClientData nst, Tcl_Interp *interp) argument
|
H A D | bip_db.c | 378 stream_id nst; local 387 nst = ec_open_file(file, SREAD, &res); 388 if (nst == NO_STREAM) 394 res = ec_load_eco_from_stream(nst, vopt.nint, &mod_pw); 395 (void) ec_close_stream(nst, CLOSE_FORCE);
|
/barrelfish-master/usr/eclipseclp/Eplex/ |
H A D | eplex.c | 433 static void CPXPUBLIC eclipse_out ARGS((void *nst, const char*msg)); 435 static void CPXPUBLIC eclipse_out ARGS((void *nst, char*msg)); 1361 eclipse_out(void * nst, const char * msg) argument 1363 eclipse_out(void * nst, char * msg) 1366 (void) ec_outf((stream_id) nst, msg, strlen(msg)); 1367 (void) ec_flush((stream_id) nst); 1374 stream_id nst; local 1384 err = ec_get_stream(pw, &nst); 1397 CPXdelfuncdest(cpx_env, ch, (void *) nst, eclipse_out); 1400 if (CPXaddfuncdest(cpx_env, ch, (void *) nst, eclipse_ou 1447 stream_id nst; local [all...] |