Searched refs:nst (Results 1 - 19 of 19) sorted by relevance

/barrelfish-master/usr/eclipseclp/Kernel/src/
H A Dec_io.h49 #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 Dio.c51 * 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 Dbip_io.c87 #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 Dread.h49 Extern int ec_read_term ARGS((stream_id nst, int options, pword *result,
H A Dprocedure.c82 * 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 Dlex.c94 #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 Dbip_serialize.c268 #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 Dexternal.h181 #define Get_Stream(vs, ts, typ, nst) \
184 nst = get_stream_id(vs, ts, typ, &res); \
185 if (nst == 0) \
H A Dwrite.c141 _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 Dread.c241 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 Dlex.h186 Extern char *string_to_number ARGS((char *start, pword *result, stream_id nst, syntax_desc *sd));
H A Demu_par.c97 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 Demu_util.c578 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 Dbip_control.c220 stream_id nst; local
224 nst = get_stream_id(vs, ts, SWRITE, &res);
225 if (nst == NO_STREAM) {
231 profile_stream_ = nst;
H A Dprintam.c59 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 Dembed.h255 Extern DLLEXP int p_fprintf ARGS((stream_id nst, char *fmt, ...));
H A Dtkeclipse.c475 EcStreamClose(ClientData nst, Tcl_Interp *interp) argument
H A Dbip_db.c378 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 Deplex.c433 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...]

Completed in 111 milliseconds