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 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 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 679 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 682 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 684 src/dps8/fnpuv.c if (! client->data) client 689 src/dps8/fnpuv.c uvClientData * p = client->data; client 690 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 693 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 695 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 697 src/dps8/fnpuv.c if (! client->data) client 702 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 708 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 710 src/dps8/fnpuv.c fnpRecvEOR (client); client 717 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 719 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 721 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 728 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 730 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 732 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 748 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 749 src/dps8/fnpuv.c if (!client) client 761 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 762 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 764 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 778 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 785 src/dps8/fnpuv.c linep->line_client = client; client 790 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 791 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 815 src/dps8/fnpuv.c client->data = p; client 825 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 843 src/dps8/fnpuv.c fnpuv_read_start (client); client 845 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1376 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1377 src/dps8/fnpuv.c if (!client) client 1390 src/dps8/fnpuv.c uv_tcp_init (fnpData.loop, client); client 1391 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1393 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1401 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1407 src/dps8/fnpuv.c uv_close ((uv_handle_t *) client, fuv_close_cb); client 1416 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1423 src/dps8/fnpuv.c int ret = uv_tcp_getpeername (client, & name, & namelen); client 1447 src/dps8/fnpuv.c client->data = p; client 1457 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1464 src/dps8/fnpuv.c fnpuv_read_start (client); client 1465 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);