client 1917 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, str, client 1925 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, & ch, 1); client 1964 src/dps8/dps8_console.c static void consoleConnectPrompt (uv_tcp_t * client) client 1966 src/dps8/dps8_console.c accessStartWriteStr (client, "password: \r\n"); client 1967 src/dps8/dps8_console.c uv_access * console_access = (uv_access *) client->data; client 1190 src/dps8/dps8_fnp2.c void fnpRecvEOR (uv_tcp_t * client) client 1192 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 1197 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 1297 src/dps8/dps8_fnp2.c void set_3270_write_complete (UNUSED uv_tcp_t * client) client 1481 src/dps8/dps8_fnp2.c if (! stnp->client) client 2458 src/dps8/dps8_fnp2.c void fnpConnectPrompt (uv_tcp_t * client) client 2460 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) PROMPT); client 2478 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ","); client 2482 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) name); client 2486 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ")? "); client 2543 src/dps8/dps8_fnp2.c static void fnp3270Msg (uv_tcp_t * client, unsigned char * msg) client 2560 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, EW, sizeof (EW)); client 2561 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, buf, (ssize_t) l); client 2562 src/dps8/dps8_fnp2.c fnpuv_send_eor (client); client 2565 src/dps8/dps8_fnp2.c void fnp3270ConnectPrompt (uv_tcp_t * client) client 2567 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2575 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 2587 src/dps8/dps8_fnp2.c fnp3270Msg (client, buf); client 2591 src/dps8/dps8_fnp2.c void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2593 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2598 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2649 src/dps8/dps8_fnp2.c fnpuv_read_stop (client); client 2652 src/dps8/dps8_fnp2.c void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2654 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2659 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2681 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 2687 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 2773 src/dps8/dps8_fnp2.c void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2775 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2780 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2787 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *) client); client 2802 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2819 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2820 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2821 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2834 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, str); client 2846 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 2863 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 2864 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2865 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 2883 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\r\n"); client 2895 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "can't parse\r\n"); client 2902 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 2926 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 2930 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 2935 src/dps8/dps8_fnp2.c fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno].line_client = client; client 2950 src/dps8/dps8_fnp2.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 2962 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) buf2); client 2965 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 2967 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 193 src/dps8/dps8_fnp2.h uv_tcp_t * client; client 345 src/dps8/dps8_fnp2.h void fnpConnectPrompt (uv_tcp_t * client); client 346 src/dps8/dps8_fnp2.h void fnp3270ConnectPrompt (uv_tcp_t * client); client 347 src/dps8/dps8_fnp2.h void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 348 src/dps8/dps8_fnp2.h void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 349 src/dps8/dps8_fnp2.h void fnpRecvEOR (uv_tcp_t * client); client 350 src/dps8/dps8_fnp2.h void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 351 src/dps8/dps8_fnp2.h void set_3270_write_complete (uv_tcp_t * client); client 357 src/dps8/dps8_fnp2_iomcmd.c client; client 53 src/dps8/fnptelnet.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 58 src/dps8/fnptelnet.c if (! client || ! client->data) client 63 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 64 src/dps8/fnptelnet.c (* p->read_cb) (client, (ssize_t) event->data.size, (unsigned char *)event->data.buffer); client 72 src/dps8/fnptelnet.c if (! client || ! client->data) client 77 src/dps8/fnptelnet.c uvClientData * p = client->data; client 78 src/dps8/fnptelnet.c (* p->write_actual_cb) (client, (unsigned char *) event->data.buffer, (ssize_t) event->data.size); client 154 src/dps8/fnptelnet.c if (! client || ! client->data) client 159 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 162 src/dps8/fnptelnet.c fnpuv_associated_brk (client); client 169 src/dps8/fnptelnet.c fnpuv_recv_eor (client); client 179 src/dps8/fnptelnet.c if (! client || ! client->data) client 184 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 214 src/dps8/fnptelnet.c void * ltnConnect (uv_tcp_t * client) client 216 src/dps8/fnptelnet.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 238 src/dps8/fnptelnet.c void * ltnConnect3270 (uv_tcp_t * client) client 240 src/dps8/fnptelnet.c void * p = (void *) telnet_init (my_3270telopts, evHandler, 0, client); client 22 src/dps8/fnptelnet.h void * ltnConnect (uv_tcp_t * client); client 23 src/dps8/fnptelnet.h void * ltnConnect3270 (uv_tcp_t * client); client 24 src/dps8/fnptelnet.h void ltnRaw (telnet_t * client); client 26 src/dps8/fnptelnet.h void ltnDialout (telnet_t * client); client 270 src/dps8/fnpuv.c void fnpuv_associated_brk (uv_tcp_t * client) client 272 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 274 src/dps8/fnpuv.c if (! client->data) client 279 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 293 src/dps8/fnpuv.c void fnpuv_associated_readcb (uv_tcp_t * client, client 297 src/dps8/fnpuv.c processLineInput (client, buf, nread); client 300 src/dps8/fnpuv.c void fnpuv_3270_readcb (uv_tcp_t * client, client 304 src/dps8/fnpuv.c process3270Input (client, buf, nread); client 310 src/dps8/fnpuv.c void fnpuv_unassociated_readcb (uv_tcp_t * client, client 315 src/dps8/fnpuv.c processUserInput (client, buf, nread); client 513 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) req->handle; client 515 src/dps8/fnpuv.c set_3270_write_complete (client); client 520 src/dps8/fnpuv.c static void fnpuv_start_write_3270_actual (UNUSED uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 559 src/dps8/fnpuv.c uv_tcp_t * stn_client = fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client; client 598 src/dps8/fnpuv.c void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 600 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 626 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); client 640 src/dps8/fnpuv.c void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 642 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 644 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 655 src/dps8/fnpuv.c void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 657 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || ! client->data) client 659 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 697 src/dps8/fnpuv.c fnpuv_send_eor (client); client 727 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 730 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 732 src/dps8/fnpuv.c if (! client->data) client 737 src/dps8/fnpuv.c uvClientData * p = client->data; client 738 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 741 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 743 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 745 src/dps8/fnpuv.c if (! client->data) client 750 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 756 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 758 src/dps8/fnpuv.c fnpRecvEOR (client); client 765 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 767 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 769 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 776 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 778 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 780 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 796 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 797 src/dps8/fnpuv.c if (!client) client 809 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 810 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 812 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 826 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 833 src/dps8/fnpuv.c linep->line_client = client; client 838 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 839 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 863 src/dps8/fnpuv.c client->data = p; client 873 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 891 src/dps8/fnpuv.c fnpuv_read_start (client); client 893 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1478 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1479 src/dps8/fnpuv.c if (!client) client 1492 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 1493 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1495 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1503 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1509 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1518 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1525 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 1549 src/dps8/fnpuv.c client->data = p; client 1559 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1566 src/dps8/fnpuv.c fnpuv_read_start (client); client 1567 src/dps8/fnpuv.c fnp3270ConnectPrompt (client); client 20 src/dps8/fnpuv.h typedef void (* uv_read_cb_t) (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 21 src/dps8/fnpuv.h typedef void (* uv_write_cb_t) (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 45 src/dps8/fnpuv.h void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t len); client 46 src/dps8/fnpuv.h void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data); client 47 src/dps8/fnpuv.h void fnpuv_send_eor (uv_tcp_t * client); client 48 src/dps8/fnpuv.h void fnpuv_recv_eor (uv_tcp_t * client); client 49 src/dps8/fnpuv.h void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 50 src/dps8/fnpuv.h void fnpuv_associated_brk (uv_tcp_t * client); client 51 src/dps8/fnpuv.h void fnpuv_unassociated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 52 src/dps8/fnpuv.h void fnpuv_associated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 53 src/dps8/fnpuv.h void fnpuv_read_start (uv_tcp_t * client); client 54 src/dps8/fnpuv.h void fnpuv_read_stop (uv_tcp_t * client); client 61 src/dps8/fnpuv.h void fnpuv_3270_readcb (uv_tcp_t * client, client 64 src/dps8/fnpuv.h void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 40 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 672 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 679 src/dps8/uvutil.c if (! access->client) client 715 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 36 src/dps8/uvutil.h void (* connectPrompt) (uv_tcp_t * client); client 37 src/dps8/uvutil.h void (* connected) (uv_tcp_t * client); client 40 src/dps8/uvutil.h uv_tcp_t * client; client 50 src/dps8/uvutil.h void accessStartWriteStr (uv_tcp_t * client, char * data); client 57 src/dps8/uvutil.h void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen);