client 1926 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, str, client 1934 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, & ch, 1); client 1973 src/dps8/dps8_console.c static void consoleConnectPrompt (uv_tcp_t * client) client 1975 src/dps8/dps8_console.c accessStartWriteStr (client, "password: \r\n"); client 1976 src/dps8/dps8_console.c uv_access * console_access = (uv_access *) client->data; client 1216 src/dps8/dps8_fnp2.c void fnpRecvEOR (uv_tcp_t * client) client 1218 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 1223 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 1323 src/dps8/dps8_fnp2.c void set_3270_write_complete (UNUSED uv_tcp_t * client) client 1516 src/dps8/dps8_fnp2.c if (! stnp->client) client 2544 src/dps8/dps8_fnp2.c void fnpConnectPrompt (uv_tcp_t * client) client 2546 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) PROMPT); client 2564 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ","); client 2568 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) name); client 2572 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ")? "); client 2629 src/dps8/dps8_fnp2.c static void fnp3270Msg (uv_tcp_t * client, unsigned char * msg) client 2646 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, EW, sizeof (EW)); client 2647 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, buf, (ssize_t) l); client 2648 src/dps8/dps8_fnp2.c fnpuv_send_eor (client); client 2651 src/dps8/dps8_fnp2.c void fnp3270ConnectPrompt (uv_tcp_t * client) client 2653 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2661 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 2674 src/dps8/dps8_fnp2.c fnp3270Msg (client, buf); client 2678 src/dps8/dps8_fnp2.c void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2680 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2685 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2736 src/dps8/dps8_fnp2.c fnpuv_read_stop (client); client 2739 src/dps8/dps8_fnp2.c void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2744 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2749 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2771 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 2777 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 2865 src/dps8/dps8_fnp2.c void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2867 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2872 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2879 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *) client); client 2894 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2911 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2912 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2913 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2926 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, str); client 2938 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2955 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2956 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2957 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2975 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\r\n"); client 2987 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "can't parse\r\n"); client 2994 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3018 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3022 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 3027 src/dps8/dps8_fnp2.c fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno].line_client = client; client 3042 src/dps8/dps8_fnp2.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 3054 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) buf2); client 3057 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 3059 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 190 src/dps8/dps8_fnp2.h uv_tcp_t * client; client 342 src/dps8/dps8_fnp2.h void fnpConnectPrompt (uv_tcp_t * client); client 343 src/dps8/dps8_fnp2.h void fnp3270ConnectPrompt (uv_tcp_t * client); client 344 src/dps8/dps8_fnp2.h void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 345 src/dps8/dps8_fnp2.h void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 346 src/dps8/dps8_fnp2.h void fnpRecvEOR (uv_tcp_t * client); client 347 src/dps8/dps8_fnp2.h void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 348 src/dps8/dps8_fnp2.h void set_3270_write_complete (uv_tcp_t * client); client 364 src/dps8/dps8_fnp2_iomcmd.c client; client 50 src/dps8/fnptelnet.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 55 src/dps8/fnptelnet.c if (! client || ! client->data) client 60 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 61 src/dps8/fnptelnet.c (* p->read_cb) (client, (ssize_t) event->data.size, (unsigned char *)event->data.buffer); client 69 src/dps8/fnptelnet.c if (! client || ! client->data) client 74 src/dps8/fnptelnet.c uvClientData * p = client->data; client 75 src/dps8/fnptelnet.c (* p->write_actual_cb) (client, (unsigned char *) event->data.buffer, (ssize_t) event->data.size); client 151 src/dps8/fnptelnet.c if (! client || ! client->data) client 156 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 159 src/dps8/fnptelnet.c fnpuv_associated_brk (client); client 166 src/dps8/fnptelnet.c fnpuv_recv_eor (client); client 176 src/dps8/fnptelnet.c if (! client || ! client->data) client 181 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 211 src/dps8/fnptelnet.c void * ltnConnect (uv_tcp_t * client) client 213 src/dps8/fnptelnet.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 235 src/dps8/fnptelnet.c void * ltnConnect3270 (uv_tcp_t * client) client 237 src/dps8/fnptelnet.c void * p = (void *) telnet_init (my_3270telopts, evHandler, 0, client); client 19 src/dps8/fnptelnet.h void * ltnConnect (uv_tcp_t * client); client 20 src/dps8/fnptelnet.h void * ltnConnect3270 (uv_tcp_t * client); client 21 src/dps8/fnptelnet.h void ltnRaw (telnet_t * client); client 23 src/dps8/fnptelnet.h void ltnDialout (telnet_t * client); client 269 src/dps8/fnpuv.c void fnpuv_associated_brk (uv_tcp_t * client) client 271 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 273 src/dps8/fnpuv.c if (! client->data) client 278 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 292 src/dps8/fnpuv.c void fnpuv_associated_readcb (uv_tcp_t * client, client 296 src/dps8/fnpuv.c processLineInput (client, buf, nread); client 299 src/dps8/fnpuv.c void fnpuv_3270_readcb (uv_tcp_t * client, client 303 src/dps8/fnpuv.c process3270Input (client, buf, nread); client 309 src/dps8/fnpuv.c void fnpuv_unassociated_readcb (uv_tcp_t * client, client 314 src/dps8/fnpuv.c processUserInput (client, buf, nread); client 505 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) req->handle; client 507 src/dps8/fnpuv.c set_3270_write_complete (client); client 512 src/dps8/fnpuv.c static void fnpuv_start_write_3270_actual (UNUSED uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 530 src/dps8/fnpuv.c uv_tcp_t * stn_client = fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client; client 569 src/dps8/fnpuv.c void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 571 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 597 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); client 611 src/dps8/fnpuv.c void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 613 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 615 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 626 src/dps8/fnpuv.c void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 628 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || ! client->data) client 630 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 646 src/dps8/fnpuv.c fnpuv_send_eor (client); client 676 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 679 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 681 src/dps8/fnpuv.c if (! client->data) client 686 src/dps8/fnpuv.c uvClientData * p = client->data; client 687 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 690 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 692 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 694 src/dps8/fnpuv.c if (! client->data) client 699 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 705 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 707 src/dps8/fnpuv.c fnpRecvEOR (client); client 714 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 716 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 718 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 725 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 727 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 729 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 745 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 746 src/dps8/fnpuv.c if (!client) client 758 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 759 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 761 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 775 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 782 src/dps8/fnpuv.c linep->line_client = client; client 787 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 788 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 812 src/dps8/fnpuv.c client->data = p; client 822 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 840 src/dps8/fnpuv.c fnpuv_read_start (client); client 842 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1373 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1374 src/dps8/fnpuv.c if (!client) client 1387 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 1388 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1390 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1398 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1404 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1413 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1420 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 1444 src/dps8/fnpuv.c client->data = p; client 1454 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1461 src/dps8/fnpuv.c fnpuv_read_start (client); client 1462 src/dps8/fnpuv.c fnp3270ConnectPrompt (client); client 17 src/dps8/fnpuv.h typedef void (* uv_read_cb_t) (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 18 src/dps8/fnpuv.h typedef void (* uv_write_cb_t) (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 42 src/dps8/fnpuv.h void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t len); client 43 src/dps8/fnpuv.h void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data); client 44 src/dps8/fnpuv.h void fnpuv_send_eor (uv_tcp_t * client); client 45 src/dps8/fnpuv.h void fnpuv_recv_eor (uv_tcp_t * client); client 46 src/dps8/fnpuv.h void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 47 src/dps8/fnpuv.h void fnpuv_associated_brk (uv_tcp_t * client); client 48 src/dps8/fnpuv.h void fnpuv_unassociated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 49 src/dps8/fnpuv.h void fnpuv_associated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 50 src/dps8/fnpuv.h void fnpuv_read_start (uv_tcp_t * client); client 51 src/dps8/fnpuv.h void fnpuv_read_stop (uv_tcp_t * client); client 58 src/dps8/fnpuv.h void fnpuv_3270_readcb (uv_tcp_t * client, client 61 src/dps8/fnpuv.h void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 39 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 139 src/dps8/uvutil.c static void accessReadStart (uv_tcp_t * client) client 141 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 143 src/dps8/uvutil.c uv_read_start ((uv_stream_t *) client, alloc_buffer, accessReadCallback); client 148 src/dps8/uvutil.c static void accessStartWriteActual (uv_tcp_t * client, char * data, client 151 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 177 src/dps8/uvutil.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, client 188 src/dps8/uvutil.c void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen) client 190 src/dps8/uvutil.c if ((client == NULL) || uv_is_closing ((uv_handle_t *) client)) client 192 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 196 src/dps8/uvutil.c accessStartWriteActual (client, data, (ssize_t) datalen); client 202 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 208 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 211 src/dps8/uvutil.c void accessStartWriteStr (uv_tcp_t * client, char * data) client 213 src/dps8/uvutil.c accessStartWrite (client, data, (ssize_t) strlen (data)); client 248 src/dps8/uvutil.c access->connectPrompt (access->client); client 291 src/dps8/uvutil.c access->connectPrompt (access->client); client 329 src/dps8/uvutil.c access->connectPrompt (access->client); client 335 src/dps8/uvutil.c access->connected (access->client); client 356 src/dps8/uvutil.c access->client = NULL; client 411 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 415 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 425 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 431 src/dps8/uvutil.c accessTelnetReadCallback (client, (ssize_t) event->data.size, client 438 src/dps8/uvutil.c accessStartWriteActual (client, (char *) event->data.buffer, client 520 src/dps8/uvutil.c static void * accessTelnetConnect (uv_tcp_t * client) client 522 src/dps8/uvutil.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 553 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 554 src/dps8/uvutil.c if (!client) client 566 src/dps8/uvutil.c uv_tcp_init (access->loop, client); client 567 src/dps8/uvutil.c client->data = server->data; client 568 src/dps8/uvutil.c if (uv_accept (server, (uv_stream_t *) client) == 0) client 571 src/dps8/uvutil.c if (access->client) client 577 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *) access->client); client 579 src/dps8/uvutil.c access->client = client; client 580 src/dps8/uvutil.c uv_tcp_nodelay (client, 1); client 583 src/dps8/uvutil.c int ret = uv_tcp_getpeername (access->client, & name, & namelen); client 596 src/dps8/uvutil.c access->telnetp = accessTelnetConnect (access->client); client 610 src/dps8/uvutil.c access->connected (access->client); client 612 src/dps8/uvutil.c access->connectPrompt (access->client); client 613 src/dps8/uvutil.c accessReadStart (access->client); client 617 src/dps8/uvutil.c uv_close ((uv_handle_t *) client, accessCloseCallback); client 669 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 676 src/dps8/uvutil.c if (! access->client) client 712 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 33 src/dps8/uvutil.h void (* connectPrompt) (uv_tcp_t * client); client 34 src/dps8/uvutil.h void (* connected) (uv_tcp_t * client); client 37 src/dps8/uvutil.h uv_tcp_t * client; client 47 src/dps8/uvutil.h void accessStartWriteStr (uv_tcp_t * client, char * data); client 54 src/dps8/uvutil.h void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen);