client 1939 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, str, client 1947 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, & ch, 1); client 1986 src/dps8/dps8_console.c static void consoleConnectPrompt (uv_tcp_t * client) client 1988 src/dps8/dps8_console.c accessStartWriteStr (client, "password: \r\n"); client 1989 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 2545 src/dps8/dps8_fnp2.c void fnpConnectPrompt (uv_tcp_t * client) client 2547 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) PROMPT); client 2565 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ","); client 2569 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) name); client 2573 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ")? "); client 2630 src/dps8/dps8_fnp2.c static void fnp3270Msg (uv_tcp_t * client, unsigned char * msg) client 2648 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, EW, sizeof (EW)); client 2649 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, buf, (ssize_t) l); client 2650 src/dps8/dps8_fnp2.c fnpuv_send_eor (client); client 2653 src/dps8/dps8_fnp2.c void fnp3270ConnectPrompt (uv_tcp_t * client) client 2655 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2663 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 2676 src/dps8/dps8_fnp2.c fnp3270Msg (client, buf); client 2680 src/dps8/dps8_fnp2.c void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2682 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2687 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2738 src/dps8/dps8_fnp2.c fnpuv_read_stop (client); client 2741 src/dps8/dps8_fnp2.c void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2746 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2751 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2773 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 2779 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 2867 src/dps8/dps8_fnp2.c void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2869 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2874 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2881 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *) client); client 2896 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2913 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2914 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2915 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2928 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, str); client 2940 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2957 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2958 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2959 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2977 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\r\n"); client 2989 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "can't parse\r\n"); client 2996 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3020 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3024 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 3029 src/dps8/dps8_fnp2.c fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno].line_client = client; client 3044 src/dps8/dps8_fnp2.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 3056 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) buf2); client 3059 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 3061 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 273 src/dps8/fnpuv.c void fnpuv_associated_brk (uv_tcp_t * client) client 275 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 277 src/dps8/fnpuv.c if (! client->data) client 282 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 296 src/dps8/fnpuv.c void fnpuv_associated_readcb (uv_tcp_t * client, client 300 src/dps8/fnpuv.c processLineInput (client, buf, nread); client 303 src/dps8/fnpuv.c void fnpuv_3270_readcb (uv_tcp_t * client, client 307 src/dps8/fnpuv.c process3270Input (client, buf, nread); client 313 src/dps8/fnpuv.c void fnpuv_unassociated_readcb (uv_tcp_t * client, client 318 src/dps8/fnpuv.c processUserInput (client, buf, nread); client 509 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) req->handle; client 511 src/dps8/fnpuv.c set_3270_write_complete (client); client 516 src/dps8/fnpuv.c static void fnpuv_start_write_3270_actual (UNUSED uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 534 src/dps8/fnpuv.c uv_tcp_t * stn_client = fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client; client 573 src/dps8/fnpuv.c void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 575 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 601 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); client 615 src/dps8/fnpuv.c void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 617 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 619 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 630 src/dps8/fnpuv.c void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 632 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || ! client->data) client 634 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 650 src/dps8/fnpuv.c fnpuv_send_eor (client); client 683 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 686 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 688 src/dps8/fnpuv.c if (! client->data) client 693 src/dps8/fnpuv.c uvClientData * p = client->data; client 694 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 697 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 699 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 701 src/dps8/fnpuv.c if (! client->data) client 706 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 712 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 714 src/dps8/fnpuv.c fnpRecvEOR (client); client 721 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 723 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 725 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 732 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 734 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 736 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 752 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 753 src/dps8/fnpuv.c if (!client) client 765 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 766 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 768 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 782 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 789 src/dps8/fnpuv.c linep->line_client = client; client 794 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 795 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 819 src/dps8/fnpuv.c client->data = p; client 829 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 847 src/dps8/fnpuv.c fnpuv_read_start (client); client 849 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1380 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1381 src/dps8/fnpuv.c if (!client) client 1394 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 1395 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1397 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1405 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1411 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1420 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1427 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 1451 src/dps8/fnpuv.c client->data = p; client 1461 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1468 src/dps8/fnpuv.c fnpuv_read_start (client); client 1469 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 43 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 143 src/dps8/uvutil.c static void accessReadStart (uv_tcp_t * client) client 145 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 147 src/dps8/uvutil.c uv_read_start ((uv_stream_t *) client, alloc_buffer, accessReadCallback); client 152 src/dps8/uvutil.c static void accessStartWriteActual (uv_tcp_t * client, char * data, client 155 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 181 src/dps8/uvutil.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, client 192 src/dps8/uvutil.c void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen) client 194 src/dps8/uvutil.c if ((client == NULL) || uv_is_closing ((uv_handle_t *) client)) client 196 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 200 src/dps8/uvutil.c accessStartWriteActual (client, data, (ssize_t) datalen); client 206 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 212 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 215 src/dps8/uvutil.c void accessStartWriteStr (uv_tcp_t * client, char * data) client 217 src/dps8/uvutil.c accessStartWrite (client, data, (ssize_t) strlen (data)); client 252 src/dps8/uvutil.c access->connectPrompt (access->client); client 295 src/dps8/uvutil.c access->connectPrompt (access->client); client 333 src/dps8/uvutil.c access->connectPrompt (access->client); client 339 src/dps8/uvutil.c access->connected (access->client); client 360 src/dps8/uvutil.c access->client = NULL; client 415 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 419 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 429 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 435 src/dps8/uvutil.c accessTelnetReadCallback (client, (ssize_t) event->data.size, client 442 src/dps8/uvutil.c accessStartWriteActual (client, (char *) event->data.buffer, client 524 src/dps8/uvutil.c static void * accessTelnetConnect (uv_tcp_t * client) client 526 src/dps8/uvutil.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 557 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 558 src/dps8/uvutil.c if (!client) client 570 src/dps8/uvutil.c uv_tcp_init (access->loop, client); client 571 src/dps8/uvutil.c client->data = server->data; client 572 src/dps8/uvutil.c if (uv_accept (server, (uv_stream_t *) client) == 0) client 575 src/dps8/uvutil.c if (access->client) client 581 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *) access->client); client 583 src/dps8/uvutil.c access->client = client; client 584 src/dps8/uvutil.c uv_tcp_nodelay (client, 1); client 587 src/dps8/uvutil.c int ret = uv_tcp_getpeername (access->client, & name, & namelen); client 600 src/dps8/uvutil.c access->telnetp = accessTelnetConnect (access->client); client 614 src/dps8/uvutil.c access->connected (access->client); client 616 src/dps8/uvutil.c access->connectPrompt (access->client); client 617 src/dps8/uvutil.c accessReadStart (access->client); client 621 src/dps8/uvutil.c uv_close ((uv_handle_t *) client, accessCloseCallback); client 673 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 680 src/dps8/uvutil.c if (! access->client) client 716 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);