stream 564 src/dps8/dps8_mgp.c static void ncp_stop_reading_if_full(uv_stream_t *stream) { stream 567 src/dps8/dps8_mgp.c int rc = uv_read_stop(stream); stream 573 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)stream, ncp_close_cb); stream 581 src/dps8/dps8_mgp.c static void ncp_read_cb(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf); stream 600 src/dps8/dps8_mgp.c static void ncp_read_cb(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) { stream 603 src/dps8/dps8_mgp.c ncp_stop_reading_if_full(stream); stream 611 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)stream, ncp_close_cb); stream 617 src/dps8/dps8_mgp.c ncp_stop_reading_if_full(stream); stream 558 src/dps8/dps8_net.c static void net_stop_reading_if_full(uv_stream_t* stream) { stream 561 src/dps8/dps8_net.c int rc = uv_read_stop(stream); stream 567 src/dps8/dps8_net.c uv_close((uv_handle_t*)stream, net_close_cb); stream 575 src/dps8/dps8_net.c static void net_read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); stream 594 src/dps8/dps8_net.c static void net_read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { stream 597 src/dps8/dps8_net.c net_stop_reading_if_full(stream); stream 606 src/dps8/dps8_net.c uv_close((uv_handle_t*)stream, net_close_cb); stream 612 src/dps8/dps8_net.c net_stop_reading_if_full(stream); stream 128 src/dps8/dps8_sys.c static void fprint_addr(FILE *stream, DEVICE *dptr, t_addr addr); stream 4774 src/dps8/dps8_sys.c static void fprint_addr (FILE * stream, UNUSED DEVICE * dptr, t_addr simh_addr) stream 4776 src/dps8/dps8_sys.c (void)fprintf(stream, "%06o", simh_addr); stream 410 src/dps8/fnpuv.c static void fuv_close_cb (uv_handle_t * stream) stream 414 src/dps8/fnpuv.c uvClientData * p = (uvClientData *)stream->data; stream 423 src/dps8/fnpuv.c FREE (stream); stream 490 src/dps8/fnpuv.c void close_connection (uv_stream_t* stream) stream 492 src/dps8/fnpuv.c if (! stream || uv_is_closing ((uv_handle_t *)stream)) stream 497 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) stream->data; stream 500 src/dps8/fnpuv.c const char *rname = fnpuv_peer_name ((uv_tcp_t *)stream, ip, sizeof (ip)); stream 549 src/dps8/fnpuv.c if (linep->line_client == (uv_tcp_t *)stream) stream 563 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[p->stationNo].client == (uv_tcp_t *)stream) stream 579 src/dps8/fnpuv.c (void)uv_read_stop (stream); stream 580 src/dps8/fnpuv.c close_unassociated_socket ((uv_tcp_t *)stream); stream 589 src/dps8/fnpuv.c static void fuv_read_cb (uv_stream_t* stream, stream 597 src/dps8/fnpuv.c close_connection (stream); stream 602 src/dps8/fnpuv.c if (! stream || uv_is_closing ((uv_handle_t *)stream)) stream 607 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) stream->data; stream 618 src/dps8/fnpuv.c (* p->read_cb) ((uv_tcp_t *) stream, nread, (unsigned char *) buf->base); stream 623 src/dps8/fnpuv.c stream 627 src/dps8/fnpuv.c stream 67 src/dps8/fnpuv.h void close_connection (uv_stream_t* stream); stream 326 src/dps8/uvutil.c static void accessReadCallback (uv_stream_t* stream, stream 330 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; stream 335 src/dps8/uvutil.c accessCloseConnection (stream); stream 345 src/dps8/uvutil.c accessTelnetReadCallback ((uv_tcp_t *) stream, stream 625 src/dps8/uvutil.c static void accessCloseCallback (uv_handle_t * stream) stream 627 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; stream 636 src/dps8/uvutil.c FREE (stream); stream 639 src/dps8/uvutil.c void accessCloseConnection (uv_stream_t* stream) stream 641 src/dps8/uvutil.c if (!stream || uv_is_closing ((uv_handle_t *)stream)) stream 643 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; stream 665 src/dps8/uvutil.c if (access && access->client == (uv_tcp_t *)stream) stream 672 src/dps8/uvutil.c (void)uv_read_stop (stream); stream 678 src/dps8/uvutil.c uv_close ((uv_handle_t *) stream, accessCloseCallback); stream 703 src/dps8/uvutil.c uv_stream_t * stream = req->handle; stream 704 src/dps8/uvutil.c if (!uv_is_closing ((uv_handle_t *)stream)) stream 705 src/dps8/uvutil.c accessCloseConnection (stream); stream 55 src/dps8/uvutil.h void accessCloseConnection (uv_stream_t* stream); stream 39 src/libsir/include/sir/console.h bool _sir_write_stdio(FILE* stream, const char* message); stream 36 src/libsir/src/sirconsole.c bool _sir_write_stdio(FILE* stream, const char* message) { stream 37 src/libsir/src/sirconsole.c return (EOF != fputs(message, stream)) ? true : _sir_handleerr(errno); stream 326 src/punutil/miniz.c mz_stream stream; stream 327 src/punutil/miniz.c memset(&stream, 0, sizeof(stream)); stream 333 src/punutil/miniz.c stream.next_in = pSource; stream 334 src/punutil/miniz.c stream.avail_in = (mz_uint32)source_len; stream 335 src/punutil/miniz.c stream.next_out = pDest; stream 336 src/punutil/miniz.c stream.avail_out = (mz_uint32)*pDest_len; stream 338 src/punutil/miniz.c status = mz_deflateInit(&stream, level); stream 342 src/punutil/miniz.c status = mz_deflate(&stream, MZ_FINISH); stream 345 src/punutil/miniz.c mz_deflateEnd(&stream); stream 349 src/punutil/miniz.c *pDest_len = stream.total_out; stream 350 src/punutil/miniz.c return mz_deflateEnd(&stream); stream 568 src/punutil/miniz.c mz_stream stream; stream 570 src/punutil/miniz.c memset(&stream, 0, sizeof(stream)); stream 576 src/punutil/miniz.c stream.next_in = pSource; stream 577 src/punutil/miniz.c stream.avail_in = (mz_uint32)*pSource_len; stream 578 src/punutil/miniz.c stream.next_out = pDest; stream 579 src/punutil/miniz.c stream.avail_out = (mz_uint32)*pDest_len; stream 581 src/punutil/miniz.c status = mz_inflateInit(&stream); stream 585 src/punutil/miniz.c status = mz_inflate(&stream, MZ_FINISH); stream 586 src/punutil/miniz.c *pSource_len = *pSource_len - stream.avail_in; stream 589 src/punutil/miniz.c mz_inflateEnd(&stream); stream 590 src/punutil/miniz.c return ((status == MZ_BUF_ERROR) && (!stream.avail_in)) ? MZ_DATA_ERROR : status; stream 592 src/punutil/miniz.c *pDest_len = stream.total_out; stream 594 src/punutil/miniz.c return mz_inflateEnd(&stream); stream 284 src/simh/scp.c char* (*sim_vm_read) (char *ptr, int32 size, FILE *stream) = NULL; stream 364 src/simh/scp.c char *read_line (char *ptr, int32 size, FILE *stream); stream 365 src/simh/scp.c char *read_line_p (const char *prompt, char *ptr, int32 size, FILE *stream); stream 388 src/simh/scp.c void fprint_fields (FILE *stream, t_value before, t_value after, BITFIELD* bitdefs); stream 7531 src/simh/scp.c char *read_line (char *cptr, int32 size, FILE *stream) stream 7533 src/simh/scp.c return read_line_p (NULL, cptr, size, stream); stream 7548 src/simh/scp.c char *read_line_p (const char *prompt, char *cptr, int32 size, FILE *stream) stream 7567 src/simh/scp.c cptr = fgets (cptr, size, stream); /* get cmd line */ stream 7570 src/simh/scp.c else cptr = fgets (cptr, size, stream); /* get cmd line */ stream 7573 src/simh/scp.c clearerr (stream); /* clear error */ stream 8813 src/simh/scp.c t_stat fprint_val (FILE *stream, t_value val, uint32 radix, stream 8818 src/simh/scp.c if (!stream) stream 8823 src/simh/scp.c if (Fprintf (stream, "%s", dbuf) < 0) stream 10434 src/simh/scp.c void fprint_fields (FILE *stream, t_value before, t_value after, BITFIELD* bitdefs) stream 10449 src/simh/scp.c (void)Fprintf(stream, "%s%c ", bitdefs[i].name, debug_bstates[off]); stream 10461 src/simh/scp.c (void)Fprintf(stream, "%s=%s%s ", bitdefs[i].name, delta, bitdefs[i].valuenames[value]); stream 10464 src/simh/scp.c (void)Fprintf(stream, "%s=%s", bitdefs[i].name, delta); stream 10465 src/simh/scp.c (void)Fprintf(stream, bitdefs[i].format, value); stream 10466 src/simh/scp.c (void)Fprintf(stream, " "); stream 10469 src/simh/scp.c (void)Fprintf(stream, "%s=%s0x%X ", bitdefs[i].name, delta, value); stream 158 src/simh/scp.h t_stat fprint_val (FILE *stream, t_value val, uint32 rdx, uint32 wid, uint32 fmt); stream 162 src/simh/scp.h char *read_line (char *cptr, int32 size, FILE *stream); stream 286 src/simh/scp.h extern char *(*sim_vm_read) (char *ptr, int32 size, FILE *stream);