client 1961 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, str, client 1969 src/dps8/dps8_console.c accessStartWrite (csp->console_access.client, & ch, 1); client 2008 src/dps8/dps8_console.c static void consoleConnectPrompt (uv_tcp_t * client) client 2010 src/dps8/dps8_console.c accessStartWriteStr (client, "password: \r\n"); client 1235 src/dps8/dps8_fnp2.c void fnpRecvEOR (uv_tcp_t * client) client 1237 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 1242 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 1250 src/dps8/dps8_fnp2.c if (fnpData.ibm3270ctlr[ASSUME0].stations[p->stationNo].client != client) client 1363 src/dps8/dps8_fnp2.c void set_3270_write_complete (UNUSED uv_tcp_t * client) client 1568 src/dps8/dps8_fnp2.c if (! stnp->client) client 2614 src/dps8/dps8_fnp2.c void fnpConnectPrompt (uv_tcp_t * client) client 2616 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) PROMPT); client 2634 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ","); client 2638 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) name); client 2642 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) ")? "); client 2699 src/dps8/dps8_fnp2.c static void fnp3270Msg (uv_tcp_t * client, unsigned char * msg) client 2717 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, EW, sizeof (EW)); client 2718 src/dps8/dps8_fnp2.c fnpuv_start_3270_write (client, buf, (ssize_t) l); client 2719 src/dps8/dps8_fnp2.c fnpuv_send_eor (client); client 2722 src/dps8/dps8_fnp2.c void fnp3270ConnectPrompt (uv_tcp_t * client) client 2724 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2732 src/dps8/dps8_fnp2.c uvClientData * p = client->data; client 2749 src/dps8/dps8_fnp2.c fnp3270Msg (client, buf); client 2753 src/dps8/dps8_fnp2.c void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2755 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2760 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2781 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2801 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2814 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2823 src/dps8/dps8_fnp2.c fnpuv_read_stop (client); client 2826 src/dps8/dps8_fnp2.c void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2831 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2836 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2850 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2865 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 2871 src/dps8/dps8_fnp2.c fnp3270Msg (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 2887 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2900 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2913 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); client 2970 src/dps8/dps8_fnp2.c void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread) client 2972 src/dps8/dps8_fnp2.c if (! client || ! client->data) client 2977 src/dps8/dps8_fnp2.c uvClientData * p = (uvClientData *) client->data; client 2984 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *) client); client 2999 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 3016 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 3017 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 3018 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 3031 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, str); client 3043 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\b \b"); client 3060 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "^R\r\n"); // echo ^R client 3061 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 3062 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) p->buffer); client 3085 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "\r\n"); client 3097 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "can't parse\r\n"); client 3104 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3128 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "not available\r\n"); client 3132 src/dps8/dps8_fnp2.c fnpConnectPrompt (client); client 3137 src/dps8/dps8_fnp2.c fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno].line_client = client; client 3152 src/dps8/dps8_fnp2.c const char * name = fnpuv_peer_name (client, peer, sizeof (peer)); client 3163 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) buf2); client 3166 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not accepting calls\r\n"); client 3168 src/dps8/dps8_fnp2.c fnpuv_start_writestr (client, (unsigned char *) "Multics is not listening to this line\r\n"); client 216 src/dps8/dps8_fnp2.h uv_tcp_t * client; client 368 src/dps8/dps8_fnp2.h void fnpConnectPrompt (uv_tcp_t * client); client 369 src/dps8/dps8_fnp2.h void fnp3270ConnectPrompt (uv_tcp_t * client); client 370 src/dps8/dps8_fnp2.h void processUserInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 371 src/dps8/dps8_fnp2.h void processLineInput (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 372 src/dps8/dps8_fnp2.h void fnpRecvEOR (uv_tcp_t * client); client 373 src/dps8/dps8_fnp2.h void process3270Input (uv_tcp_t * client, unsigned char * buf, ssize_t nread); client 374 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 63 src/dps8/fnptelnet.c if (! client || ! client->data) client 70 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 71 src/dps8/fnptelnet.c (* p->read_cb) (client, (ssize_t) event->data.size, (unsigned char *)event->data.buffer); client 79 src/dps8/fnptelnet.c if (! client || ! client->data) client 86 src/dps8/fnptelnet.c uvClientData * p = client->data; client 87 src/dps8/fnptelnet.c (* p->write_actual_cb) (client, (unsigned char *) event->data.buffer, (ssize_t) event->data.size); client 173 src/dps8/fnptelnet.c if (! client || ! client->data) client 180 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 183 src/dps8/fnptelnet.c fnpuv_associated_brk (client); client 192 src/dps8/fnptelnet.c fnpuv_recv_eor (client); client 205 src/dps8/fnptelnet.c if (! client || ! client->data) client 212 src/dps8/fnptelnet.c uvClientData * p = (uvClientData *) client->data; client 247 src/dps8/fnptelnet.c void * ltnConnect (uv_tcp_t * client) client 249 src/dps8/fnptelnet.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 271 src/dps8/fnptelnet.c void * ltnConnect3270 (uv_tcp_t * client) client 273 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 265 src/dps8/fnpuv.c static void register_client (uv_tcp_t * client, uvClientData * p) client 267 src/dps8/fnpuv.c p->client = client; client 272 src/dps8/fnpuv.c client->data = p; client 340 src/dps8/fnpuv.c static void fnpuv_cap_send_buffer (uv_tcp_t * client) client 343 src/dps8/fnpuv.c int rc = uv_send_buffer_size ((uv_handle_t *) client, & size); client 352 src/dps8/fnpuv.c bool fnpuv_output_backlogged (uv_tcp_t * client) client 354 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 356 src/dps8/fnpuv.c return uv_stream_get_write_queue_size ((uv_stream_t *) client) > client 360 src/dps8/fnpuv.c void fnpuv_associated_brk (uv_tcp_t * client) client 362 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 364 src/dps8/fnpuv.c if (! client->data) client 369 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 385 src/dps8/fnpuv.c void fnpuv_associated_readcb (uv_tcp_t * client, client 389 src/dps8/fnpuv.c processLineInput (client, buf, nread); client 392 src/dps8/fnpuv.c void fnpuv_3270_readcb (uv_tcp_t * client, client 396 src/dps8/fnpuv.c process3270Input (client, buf, nread); client 402 src/dps8/fnpuv.c void fnpuv_unassociated_readcb (uv_tcp_t * client, client 407 src/dps8/fnpuv.c processUserInput (client, buf, nread); client 427 src/dps8/fnpuv.c static void close_unassociated_socket (uv_tcp_t * client) client 429 src/dps8/fnpuv.c if (!uv_is_closing ((uv_handle_t *)client)) client 432 src/dps8/fnpuv.c uv_close ((uv_handle_t *)client, fuv_close_cb); client 460 src/dps8/fnpuv.c const char * fnpuv_peer_name (uv_tcp_t * client, char * text, size_t len) client 464 src/dps8/fnpuv.c if (!client || !text || !len || client 465 src/dps8/fnpuv.c uv_tcp_getpeername (client, (struct sockaddr *)&addr, &addrlen) < 0) client 563 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[p->stationNo].client == (uv_tcp_t *)stream) client 567 src/dps8/fnpuv.c stnp->client = NULL; client 699 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) req->handle; client 701 src/dps8/fnpuv.c set_3270_write_complete (client); client 706 src/dps8/fnpuv.c static void fnpuv_start_write_3270_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 708 src/dps8/fnpuv.c if (!client || uv_is_closing ((uv_handle_t *)client) || !data || client 727 src/dps8/fnpuv.c uv_tcp_t * stn_client = fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client; client 769 src/dps8/fnpuv.c void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 771 src/dps8/fnpuv.c if (!client || uv_is_closing ((uv_handle_t *)client) || !data || client 796 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); client 815 src/dps8/fnpuv.c void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 817 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || client 820 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 831 src/dps8/fnpuv.c void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen) client 833 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client) || ! client->data || client 836 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 852 src/dps8/fnpuv.c fnpuv_send_eor (client); client 885 src/dps8/fnpuv.c void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data) client 888 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 890 src/dps8/fnpuv.c if (! client->data) client 895 src/dps8/fnpuv.c uvClientData * p = client->data; client 897 src/dps8/fnpuv.c (* p->write_cb) (client, data, (ssize_t) strlen ((char *) data)); client 900 src/dps8/fnpuv.c void fnpuv_send_eor (uv_tcp_t * client) client 902 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 904 src/dps8/fnpuv.c if (! client->data) client 909 src/dps8/fnpuv.c uvClientData * p = (uvClientData *) client->data; client 915 src/dps8/fnpuv.c void fnpuv_recv_eor (uv_tcp_t * client) client 917 src/dps8/fnpuv.c fnpRecvEOR (client); client 924 src/dps8/fnpuv.c void fnpuv_read_start (uv_tcp_t * client) client 926 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 928 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); client 935 src/dps8/fnpuv.c void fnpuv_read_stop (uv_tcp_t * client) client 937 src/dps8/fnpuv.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 939 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); client 955 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 956 src/dps8/fnpuv.c if (!client) client 961 src/dps8/fnpuv.c int init_rc = uv_tcp_init (fnpData.loop, client); client 965 src/dps8/fnpuv.c FREE (client); client 968 src/dps8/fnpuv.c client->data = NULL; client 969 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 971 src/dps8/fnpuv.c close_unassociated_socket (client); client 974 src/dps8/fnpuv.c fnpuv_cap_send_buffer (client); client 982 src/dps8/fnpuv.c (void)fnpuv_peer_name (client, selecting_peer, sizeof (selecting_peer)); client 990 src/dps8/fnpuv.c close_unassociated_socket (client); client 1005 src/dps8/fnpuv.c close_unassociated_socket (client); client 1012 src/dps8/fnpuv.c linep->line_client = client; client 1015 src/dps8/fnpuv.c uv_tcp_nodelay (client,1); client 1017 src/dps8/fnpuv.c const char *name = fnpuv_peer_name (client, peer, sizeof (peer)); client 1035 src/dps8/fnpuv.c if (linep->line_client == client) client 1038 src/dps8/fnpuv.c close_unassociated_socket (client); client 1041 src/dps8/fnpuv.c register_client (client, p); client 1059 src/dps8/fnpuv.c p->telnetp = ltnConnect (client); client 1064 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); client 1078 src/dps8/fnpuv.c fnpuv_read_start (client); client 1080 src/dps8/fnpuv.c fnpConnectPrompt (client); client 1164 src/dps8/fnpuv.c !uv_is_closing ((uv_handle_t *)p->client)) client 1165 src/dps8/fnpuv.c close_connection ((uv_stream_t *)p->client); client 1195 src/dps8/fnpuv.c if (!uv_is_closing ((uv_handle_t *)p->client)) client 1196 src/dps8/fnpuv.c close_connection ((uv_stream_t *)p->client); client 1222 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *)server->handle; client 1223 src/dps8/fnpuv.c uvClientData * p = (uvClientData *)client->data; client 1232 src/dps8/fnpuv.c if (linep->line_client != client || uv_is_closing ((uv_handle_t *)client)) client 1240 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); client 1244 src/dps8/fnpuv.c fnpuv_cap_send_buffer (client); client 1245 src/dps8/fnpuv.c fnpuv_read_start (client); client 1704 src/dps8/fnpuv.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1705 src/dps8/fnpuv.c if (!client) client 1711 src/dps8/fnpuv.c int init_rc = uv_tcp_init (fnpData.loop, client); client 1715 src/dps8/fnpuv.c FREE (client); client 1718 src/dps8/fnpuv.c client->data = NULL; client 1719 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) client 1721 src/dps8/fnpuv.c close_unassociated_socket (client); client 1729 src/dps8/fnpuv.c if (fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client == NULL) client 1735 src/dps8/fnpuv.c close_unassociated_socket (client); client 1744 src/dps8/fnpuv.c close_unassociated_socket (client); client 1750 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = client; client 1756 src/dps8/fnpuv.c const char *name = fnpuv_peer_name (client, peer, sizeof (peer)); client 1770 src/dps8/fnpuv.c fnpData.ibm3270ctlr[ASSUME0].stations[stn_no].client = NULL; client 1771 src/dps8/fnpuv.c close_unassociated_socket (client); client 1774 src/dps8/fnpuv.c register_client (client, p); client 1784 src/dps8/fnpuv.c p->telnetp = ltnConnect3270 (client); client 1789 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); client 1792 src/dps8/fnpuv.c fnpuv_read_start (client); client 1793 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 22 src/dps8/fnpuv.h uv_tcp_t * client; client 52 src/dps8/fnpuv.h void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t len); client 53 src/dps8/fnpuv.h void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data); client 54 src/dps8/fnpuv.h void fnpuv_send_eor (uv_tcp_t * client); client 55 src/dps8/fnpuv.h void fnpuv_recv_eor (uv_tcp_t * client); client 56 src/dps8/fnpuv.h void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 57 src/dps8/fnpuv.h void fnpuv_associated_brk (uv_tcp_t * client); client 58 src/dps8/fnpuv.h void fnpuv_unassociated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 59 src/dps8/fnpuv.h void fnpuv_associated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf); client 60 src/dps8/fnpuv.h void fnpuv_read_start (uv_tcp_t * client); client 61 src/dps8/fnpuv.h void fnpuv_read_stop (uv_tcp_t * client); client 62 src/dps8/fnpuv.h bool fnpuv_output_backlogged (uv_tcp_t * client); client 63 src/dps8/fnpuv.h const char * fnpuv_peer_name (uv_tcp_t * client, char * text, size_t len); client 71 src/dps8/fnpuv.h void fnpuv_3270_readcb (uv_tcp_t * client, client 74 src/dps8/fnpuv.h void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen); client 60 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 85 src/dps8/uvutil.c uv_tcp_t * client; client 164 src/dps8/uvutil.c static bool accessGetPeer (uv_tcp_t * client, access_peer * peer) client 168 src/dps8/uvutil.c if (uv_tcp_getpeername (client, (struct sockaddr *)&address, &len) != 0) client 252 src/dps8/uvutil.c uv_access * accessForClient (uv_tcp_t * client) client 254 src/dps8/uvutil.c if (!client || !client->data) client 256 src/dps8/uvutil.c access_client * session = (access_client *)client->data; client 359 src/dps8/uvutil.c static void accessReadStart (uv_tcp_t * client) client 361 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client)) client 363 src/dps8/uvutil.c uv_read_start ((uv_stream_t *) client, alloc_buffer, accessReadCallback); client 368 src/dps8/uvutil.c static void accessStartWriteActual (uv_tcp_t * client, char * data, client 371 src/dps8/uvutil.c if (! client || uv_is_closing ((uv_handle_t *) client) || client 374 src/dps8/uvutil.c access_client * session = (access_client *)client->data; client 377 src/dps8/uvutil.c size_t queued = uv_stream_get_write_queue_size ((uv_stream_t *)client); client 382 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 408 src/dps8/uvutil.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, client 424 src/dps8/uvutil.c void accessStartWrite (uv_tcp_t * client, char * data, ssize_t datalen) client 426 src/dps8/uvutil.c if ((client == NULL) || uv_is_closing ((uv_handle_t *) client)) client 428 src/dps8/uvutil.c access_client * session = (access_client *)client->data; client 435 src/dps8/uvutil.c accessStartWriteActual (client, data, (ssize_t) datalen); client 438 src/dps8/uvutil.c static void accessPutCharForce (uv_tcp_t * client, char ch) client 441 src/dps8/uvutil.c accessStartWrite (client, & ch, 1); client 444 src/dps8/uvutil.c static void accessPutStrForce (uv_tcp_t * client, char * str) client 447 src/dps8/uvutil.c accessStartWrite (client, str, (ssize_t) l); client 450 src/dps8/uvutil.c void accessStartWriteStr (uv_tcp_t * client, char * data) client 453 src/dps8/uvutil.c accessStartWrite (client, data, (ssize_t) strlen (data)); client 460 src/dps8/uvutil.c uv_tcp_t * client = session->client; client 474 src/dps8/uvutil.c accessPutStrForce (client, "\b \b"); client 496 src/dps8/uvutil.c accessPutCharForce (client, '*'); client 508 src/dps8/uvutil.c accessPutStrForce (client, "\b \b"); client 540 src/dps8/uvutil.c accessPutStrForce (client, "\r\n"); client 550 src/dps8/uvutil.c accessPutStrForce (client, "\r[OPC emulation: ACCESS GRANTED]\r\n"); client 556 src/dps8/uvutil.c accessPutStrForce (client, tbuffer); client 563 src/dps8/uvutil.c accessPutStrForce (client, tbuffer); client 569 src/dps8/uvutil.c accessPutStrForce (client, "\r[OPC emulation: "); client 570 src/dps8/uvutil.c accessPutStrForce (client, buffer); client 571 src/dps8/uvutil.c accessPutStrForce (client, " failed attempt(s) since last successful login]\r\n"); client 580 src/dps8/uvutil.c access->connected (client); client 587 src/dps8/uvutil.c accessPutStrForce (client, "[OPC emulation: ACCESS DENIED]\r\n"); client 594 src/dps8/uvutil.c accessPutStrForce (client, "\rMultics has disconnected you\r\n"); client 665 src/dps8/uvutil.c if (access && access->client == (uv_tcp_t *)stream) client 667 src/dps8/uvutil.c access->client = NULL; client 685 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); client 693 src/dps8/uvutil.c (void)uv_read_stop ((uv_stream_t *)session->client); client 698 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); client 711 src/dps8/uvutil.c uv_tcp_t * client = old->client; client 724 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)oldest->client); client 727 src/dps8/uvutil.c (void)uv_read_stop ((uv_stream_t *)client); client 734 src/dps8/uvutil.c accessPutStrForce (client, "\r[OPC emulation: BUMPED]\r\n"); client 735 src/dps8/uvutil.c accessPutStrForce (client, "\rMultics has disconnected you\r\n"); client 742 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 749 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 752 src/dps8/uvutil.c if (uv_shutdown (req, (uv_stream_t *)client, client 756 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 763 src/dps8/uvutil.c uv_tcp_t * old = access->client; client 774 src/dps8/uvutil.c access->client = session->client; client 776 src/dps8/uvutil.c if (old && old != session->client) client 790 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); client 812 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); client 824 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); client 837 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); client 852 src/dps8/uvutil.c static void accessTelnetReadCallback (uv_tcp_t * client, client 856 src/dps8/uvutil.c access_client * session = (access_client *)client->data; client 860 src/dps8/uvutil.c session->owner->client == client) client 869 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) user_data; client 882 src/dps8/uvutil.c accessTelnetReadCallback (client, (ssize_t) event->data.size, client 889 src/dps8/uvutil.c accessStartWriteActual (client, (char *) event->data.buffer, client 989 src/dps8/uvutil.c static void * accessTelnetConnect (uv_tcp_t * client) client 991 src/dps8/uvutil.c void * p = (void *) telnet_init (my_telopts, evHandler, 0, client); client 1029 src/dps8/uvutil.c uv_tcp_t * client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); client 1030 src/dps8/uvutil.c if (!client) client 1035 src/dps8/uvutil.c int init_rc = uv_tcp_init (access->loop, client); client 1039 src/dps8/uvutil.c FREE (client); client 1042 src/dps8/uvutil.c client->data = NULL; client 1043 src/dps8/uvutil.c if (uv_accept (server, (uv_stream_t *) client) == 0) client 1048 src/dps8/uvutil.c uv_close ((uv_handle_t *)client, accessCloseCallback); client 1052 src/dps8/uvutil.c session->client = client; client 1055 src/dps8/uvutil.c client->data = session; client 1056 src/dps8/uvutil.c if (!accessGetPeer (client, &session->peer)) client 1058 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 1069 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 1076 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 1092 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 1097 src/dps8/uvutil.c (void)uv_tcp_nodelay (client, 1); client 1107 src/dps8/uvutil.c session->telnetp = accessTelnetConnect (client); client 1111 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); client 1121 src/dps8/uvutil.c access->connected (client); client 1124 src/dps8/uvutil.c access->connectPrompt (client); client 1126 src/dps8/uvutil.c accessReadStart (client); client 1130 src/dps8/uvutil.c uv_close ((uv_handle_t *) client, accessCloseCallback); client 1191 src/dps8/uvutil.c accessStartWrite (access->client, & ch, 1); client 1198 src/dps8/uvutil.c if (! access->client) client 1234 src/dps8/uvutil.c accessStartWrite (access->client, str, (ssize_t) l); client 31 src/dps8/uvutil.h void (* connectPrompt) (uv_tcp_t * client); client 32 src/dps8/uvutil.h void (* connected) (uv_tcp_t * client); client 35 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); client 56 src/dps8/uvutil.h uv_access * accessForClient (uv_tcp_t * client);