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 275 src/dps8/fnpuv.c void fnpuv_associated_brk (uv_tcp_t * client) client 277 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 279 src/dps8/fnpuv.c if (! client->data) client 284 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 298 src/dps8/fnpuv.c void fnpuv_associated_readcb (uv_tcp_t * client, client 302 src/dps8/fnpuv.c processLineInput (client, buf, nread); client 305 src/dps8/fnpuv.c void fnpuv_3270_readcb (uv_tcp_t * client, client 309 src/dps8/fnpuv.c process3270Input (client, buf, nread); client 315 src/dps8/fnpuv.c void fnpuv_unassociated_readcb (uv_tcp_t * client, client 320 src/dps8/fnpuv.c processUserInput (client, buf, nread); client 511 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) req->handle; client 513 src/dps8/fnpuv.c set_3270_write_complete (client); client 518 src/dps8/fnpuv.c static void fnpuv_start_write_3270_actual (UNUSED uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 536 src/dps8/fnpuv.c uv_tcp_t * stn_client = fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client; client 575 src/dps8/fnpuv.c void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 577 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 603 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); client 617 src/dps8/fnpuv.c void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 619 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 621 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 632 src/dps8/fnpuv.c void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 634 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || ! client->data) client 636 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 652 src/dps8/fnpuv.c fnpuv_send_eor (client); client 685 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 688 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 690 src/dps8/fnpuv.c if (! client->data) client 695 src/dps8/fnpuv.c uvClientData * p = client->data; client 696 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 699 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 701 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 703 src/dps8/fnpuv.c if (! client->data) client 708 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 714 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 716 src/dps8/fnpuv.c fnpRecvEOR (client); client 723 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 725 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 727 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 734 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 736 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 738 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 754 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 755 src/dps8/fnpuv.c if (!client) client 767 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 768 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 770 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 784 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 791 src/dps8/fnpuv.c linep->line_client = client; client 796 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 797 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 821 src/dps8/fnpuv.c client->data = p; client 831 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 849 src/dps8/fnpuv.c fnpuv_read_start (client); client 851 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1382 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1383 src/dps8/fnpuv.c if (!client) client 1396 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 1397 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1399 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1407 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1413 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1422 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1429 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 1453 src/dps8/fnpuv.c client->data = p; client 1463 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1470 src/dps8/fnpuv.c fnpuv_read_start (client); client 1471 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 45 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 145 src/dps8/uvutil.c static void accessReadStart (uv_tcp_t * client) client 147 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 149 src/dps8/uvutil.c uv_read_start ((uv_stream_t *) client, alloc_buffer, accessReadCallback); client 154 src/dps8/uvutil.c static void accessStartWriteActual (uv_tcp_t * client, char * data, client 157 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 183 src/dps8/uvutil.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, client 194 src/dps8/uvutil.c void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen) client 196 src/dps8/uvutil.c if ((client == NULL) || uv_is_closing ((uv_handle_t *) client)) client 198 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 202 src/dps8/uvutil.c accessStartWriteActual (client, data, (ssize_t) datalen); client 208 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 214 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 217 src/dps8/uvutil.c void accessStartWriteStr (uv_tcp_t * client, char * data) client 219 src/dps8/uvutil.c accessStartWrite (client, data, (ssize_t) strlen (data)); client 254 src/dps8/uvutil.c access->connectPrompt (access->client); client 297 src/dps8/uvutil.c access->connectPrompt (access->client); client 335 src/dps8/uvutil.c access->connectPrompt (access->client); client 341 src/dps8/uvutil.c access->connected (access->client); client 362 src/dps8/uvutil.c access->client = NULL; client 417 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 421 src/dps8/uvutil.c uv_access * access = (uv_access *) client->data; client 431 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 437 src/dps8/uvutil.c accessTelnetReadCallback (client, (ssize_t) event->data.size, client 444 src/dps8/uvutil.c accessStartWriteActual (client, (char *) event->data.buffer, client 526 src/dps8/uvutil.c static void * accessTelnetConnect (uv_tcp_t * client) client 528 src/dps8/uvutil.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 559 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 560 src/dps8/uvutil.c if (!client) client 572 src/dps8/uvutil.c uv_tcp_init (access->loop, client); client 573 src/dps8/uvutil.c client->data = server->data; client 574 src/dps8/uvutil.c if (uv_accept (server, (uv_stream_t *) client) == 0) client 577 src/dps8/uvutil.c if (access->client) client 583 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *) access->client); client 585 src/dps8/uvutil.c access->client = client; client 586 src/dps8/uvutil.c uv_tcp_nodelay (client, 1); client 589 src/dps8/uvutil.c int ret = uv_tcp_getpeername (access->client, & name, & namelen); client 602 src/dps8/uvutil.c access->telnetp = accessTelnetConnect (access->client); client 616 src/dps8/uvutil.c access->connected (access->client); client 618 src/dps8/uvutil.c access->connectPrompt (access->client); client 619 src/dps8/uvutil.c accessReadStart (access->client); client 623 src/dps8/uvutil.c uv_close ((uv_handle_t *) client, accessCloseCallback); client 675 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 682 src/dps8/uvutil.c if (! access->client) client 718 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);