linep 361 src/dps8/dps8_fnp2.c struct t_line * linep = &fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 362 src/dps8/dps8_fnp2.c FREE (linep->inBuffer); linep 363 src/dps8/dps8_fnp2.c linep->inSize = linep->inUsed = 0; linep 365 src/dps8/dps8_fnp2.c if (linep->tun_fd > 0) linep 367 src/dps8/dps8_fnp2.c (void)close (linep->tun_fd); linep 368 src/dps8/dps8_fnp2.c linep->tun_fd = 0; linep 434 src/dps8/dps8_fnp2.c struct t_line * linep = & fudp->MState.line[lineno]; linep 435 src/dps8/dps8_fnp2.c linep->waitForMbxDone = true; linep 513 src/dps8/dps8_fnp2.c struct t_line * linep = & fudp->MState.line[lineno]; linep 520 src/dps8/dps8_fnp2.c uint n_chars = min(linep->nPos, 100); linep 535 src/dps8/dps8_fnp2.c linep 537 src/dps8/dps8_fnp2.c linep 538 src/dps8/dps8_fnp2.c linep 540 src/dps8/dps8_fnp2.c linep 550 src/dps8/dps8_fnp2.c linep 551 src/dps8/dps8_fnp2.c linep 553 src/dps8/dps8_fnp2.c linep 562 src/dps8/dps8_fnp2.c if (i < linep->nPos) linep 563 src/dps8/dps8_fnp2.c l_putbits36_9 (& v, 0, linep->buffer [i]); linep 564 src/dps8/dps8_fnp2.c if (i + 1 < linep->nPos) linep 565 src/dps8/dps8_fnp2.c l_putbits36_9 (& v, 9, linep->buffer [i + 1]); linep 566 src/dps8/dps8_fnp2.c if (i + 2 < linep->nPos) linep 567 src/dps8/dps8_fnp2.c l_putbits36_9 (& v, 18, linep->buffer [i + 2]); linep 568 src/dps8/dps8_fnp2.c if (i + 3 < linep->nPos) linep 569 src/dps8/dps8_fnp2.c l_putbits36_9 (& v, 27, linep->buffer [i + 3]); linep 580 src/dps8/dps8_fnp2.c l_putbits36_1 (& data, 17, linep->input_break ? 1 : 0); linep 597 src/dps8/dps8_fnp2.c struct t_line * linep = & fudp->MState.line[lineno]; linep 610 src/dps8/dps8_fnp2.c iom_direct_data_service (iom_unit_idx, chan_num, fsmbx+MYSTERY+0, & linep->lineStatus0, direct_store); linep 611 src/dps8/dps8_fnp2.c iom_direct_data_service (iom_unit_idx, chan_num, fsmbx+MYSTERY+1, & linep->lineStatus1, direct_store); linep 623 src/dps8/dps8_fnp2.c struct t_line * linep = & fudp->MState.line[lineno]; linep 633 src/dps8/dps8_fnp2.c l_putbits36_18 (& data, 0, (word18) linep->nPos); // cmd_data_len XXX linep 645 src/dps8/dps8_fnp2.c l_putbits36_12 (& data, 24, (word12) linep->nPos); linep 655 src/dps8/dps8_fnp2.c l_putbits36_1 (& data, 17, linep->input_break ? 1 : 0); linep 737 src/dps8/dps8_fnp2.c struct t_line * linep = & fudp->MState.line[lineno]; linep 789 src/dps8/dps8_fnp2.c l_putbits36_9 (& data, 27, linep->lineType); // ??? 0 instead of 27 ? linep 823 src/dps8/dps8_fnp2.c static inline bool processInputCharacter (struct t_line * linep, unsigned char kar, linep 827 src/dps8/dps8_fnp2.c if (!linep->is_tun && !linep->line_client) linep 829 src/dps8/dps8_fnp2.c if (! linep->line_client) linep 837 src/dps8/dps8_fnp2.c if (linep->nPos >= sizeof (linep->buffer) - 1) linep 839 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 840 src/dps8/dps8_fnp2.c linep->input_break = false; linep 845 src/dps8/dps8_fnp2.c if (! linep->is_tun) linep 849 src/dps8/dps8_fnp2.c uvClientData * p = linep->line_client->data; linep 853 src/dps8/dps8_fnp2.c if (p && p->telnetp && linep->was_CR && kar == 0) linep 856 src/dps8/dps8_fnp2.c linep->was_CR = false; linep 859 src/dps8/dps8_fnp2.c linep->was_CR = kar == 015; linep 864 src/dps8/dps8_fnp2.c if (linep->service == service_login) linep 866 src/dps8/dps8_fnp2.c if (linep->echoPlex) linep 871 src/dps8/dps8_fnp2.c if (linep->crecho && kar == '\n') linep 873 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "\r\n"); linep 877 src/dps8/dps8_fnp2.c else if (linep->lfecho && kar == '\r') linep 879 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "\r\n"); linep 883 src/dps8/dps8_fnp2.c else if (linep->tabecho && kar == '\t') linep 886 src/dps8/dps8_fnp2.c uint nCol = linep->nPos; linep 891 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) " "); linep 907 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, str); linep 912 src/dps8/dps8_fnp2.c if (linep->breakAll) linep 914 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos ++] = kar; linep 915 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; linep 940 src/dps8/dps8_fnp2.c if (linep->echnego_on) linep 942 src/dps8/dps8_fnp2.c if (linep->echnego_break_table[kar]) linep 955 src/dps8/dps8_fnp2.c linep->echnego_on = false; linep 976 src/dps8/dps8_fnp2.c linep->input_break = false; linep 986 src/dps8/dps8_fnp2.c linep->echnego_unechoed_cnt ++; linep 989 src/dps8/dps8_fnp2.c linep->nPos, linep->echnego_unechoed_cnt); linep 991 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1000 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, str); linep 1009 src/dps8/dps8_fnp2.c linep->echnego_unechoed_cnt = 0; linep 1011 src/dps8/dps8_fnp2.c if (linep->echnego_screen_left) linep 1012 src/dps8/dps8_fnp2.c linep->echnego_screen_left --; linep 1014 src/dps8/dps8_fnp2.c sim_printf ("echnego_screen_left %u\r\n", linep->echnego_screen_left); linep 1017 src/dps8/dps8_fnp2.c if (linep->echnego_screen_left == 0) linep 1030 src/dps8/dps8_fnp2.c linep->echnego_on = false; linep 1046 src/dps8/dps8_fnp2.c linep->input_break = false; linep 1059 src/dps8/dps8_fnp2.c linep->nPos, linep->echnego_unechoed_cnt); linep 1061 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1076 src/dps8/dps8_fnp2.c linep->echnego_unechoed_cnt += linep->nPos; linep 1078 src/dps8/dps8_fnp2.c linep->input_break = true; linep 1079 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1082 src/dps8/dps8_fnp2.c linep->nPos, linep->echnego_unechoed_cnt); linep 1087 src/dps8/dps8_fnp2.c if ((linep-> frame_begin != 0 && linep 1088 src/dps8/dps8_fnp2.c linep-> frame_begin == kar) || linep 1089 src/dps8/dps8_fnp2.c (linep-> frame_end != 0 && linep 1090 src/dps8/dps8_fnp2.c linep-> frame_end == kar)) linep 1094 src/dps8/dps8_fnp2.c linep 1096 src/dps8/dps8_fnp2.c linep 1097 src/dps8/dps8_fnp2.c linep 1104 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos++] = kar; linep 1106 src/dps8/dps8_fnp2.c uint frsz = linep->block_xfer_in_frame_sz; linep 1107 src/dps8/dps8_fnp2.c while ((size_t) linep->nPos < sizeof (linep->buffer) && linep->nPos < frsz) linep 1108 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos++] = 0; linep 1109 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1110 src/dps8/dps8_fnp2.c linep->input_break = true; linep 1126 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos++] = kar; linep 1127 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; linep 1128 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1129 src/dps8/dps8_fnp2.c linep->input_break = true; linep 1136 src/dps8/dps8_fnp2.c if (linep->handleQuit) linep 1138 src/dps8/dps8_fnp2.c linep->line_break=true; linep 1150 src/dps8/dps8_fnp2.c if (linep->nPos > 0) linep 1152 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "\b \b"); linep 1154 src/dps8/dps8_fnp2.c linep->nPos -= 1; // back up buffer pointer linep 1155 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; // remove char from buffer linep 1160 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "\a"); linep 1167 src/dps8/dps8_fnp2.c linep->nPos = 0; linep 1168 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; linep 1169 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "^U\r\n"); linep 1175 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "^R\r\n"); // echo ^R linep 1176 src/dps8/dps8_fnp2.c fnpuv_start_writestr (linep->line_client, linep->buffer); linep 1187 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos++] = kar; linep 1188 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; linep 1194 src/dps8/dps8_fnp2.c ((linep->service == service_autocall || linep 1195 src/dps8/dps8_fnp2.c linep->service == service_slave) && linep 1196 src/dps8/dps8_fnp2.c linep->inUsed >= linep->inSize) || linep 1198 src/dps8/dps8_fnp2.c (size_t) linep->nPos >= sizeof (linep->buffer) - 1 || linep 1201 src/dps8/dps8_fnp2.c linep 1204 src/dps8/dps8_fnp2.c linep 1206 src/dps8/dps8_fnp2.c ((linep->block_xfer_out_frame_sz != 0) linep 1209 src/dps8/dps8_fnp2.c (linep->nPos >= linep->block_xfer_out_frame_sz) linep 1212 src/dps8/dps8_fnp2.c (linep->inputBufferSize != 0 && linep->nPos >= linep->inputBufferSize)) linep 1215 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1216 src/dps8/dps8_fnp2.c linep->input_break = false; linep 1218 src/dps8/dps8_fnp2.c if (linep->service == service_slave || linep->service == service_autocall) linep 1221 src/dps8/dps8_fnp2.c if (linep->is_tun) linep 1222 src/dps8/dps8_fnp2.c linep->input_break = endOfBuffer; linep 1225 src/dps8/dps8_fnp2.c linep->input_break = true; linep 1252 src/dps8/dps8_fnp2.c struct t_line * linep = &fnpData.fnpUnitData[p->fnpno].MState.line[p->lineno]; linep 1253 src/dps8/dps8_fnp2.c if (linep->service != service_3270) linep 1259 src/dps8/dps8_fnp2.c static void fnpProcessBuffer (struct t_line * linep) linep 1263 src/dps8/dps8_fnp2.c if ((! linep->is_tun) && ! linep->line_client) linep 1265 src/dps8/dps8_fnp2.c if (! linep->line_client) linep 1268 src/dps8/dps8_fnp2.c if (linep->inBuffer) linep 1269 src/dps8/dps8_fnp2.c FREE (linep->inBuffer); linep 1270 src/dps8/dps8_fnp2.c linep->inBuffer = NULL; linep 1271 src/dps8/dps8_fnp2.c linep->inSize = 0; linep 1272 src/dps8/dps8_fnp2.c linep->inUsed = 0; linep 1276 src/dps8/dps8_fnp2.c while (linep->inBuffer && linep->inUsed < linep->inSize) linep 1281 src/dps8/dps8_fnp2.c if (linep->nPos >= sizeof (linep->buffer) - 1) linep 1283 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1284 src/dps8/dps8_fnp2.c linep->input_break = false; linep 1287 src/dps8/dps8_fnp2.c unsigned char c = linep->inBuffer [linep->inUsed ++]; linep 1289 src/dps8/dps8_fnp2.c bool eob = linep->inUsed >= linep->inSize; linep 1292 src/dps8/dps8_fnp2.c FREE (linep->inBuffer); linep 1293 src/dps8/dps8_fnp2.c linep->inBuffer = NULL; linep 1294 src/dps8/dps8_fnp2.c linep->inSize = 0; linep 1295 src/dps8/dps8_fnp2.c linep->inUsed = 0; linep 1297 src/dps8/dps8_fnp2.c if (linep->line_client) linep 1298 src/dps8/dps8_fnp2.c fnpuv_read_start (linep->line_client); linep 1300 src/dps8/dps8_fnp2.c if (linep->service == service_3270) linep 1302 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos++] = c; linep 1303 src/dps8/dps8_fnp2.c linep->buffer[linep->nPos] = 0; linep 1306 src/dps8/dps8_fnp2.c if (processInputCharacter (linep, c, eob)) linep 1320 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno]; linep 1323 src/dps8/dps8_fnp2.c if (linep->accept_input) linep 1327 src/dps8/dps8_fnp2.c if (linep->input_reply_pending || linep->input_in_mailbox_pending) linep 1331 src/dps8/dps8_fnp2.c if (!linep->inBuffer) linep 1334 src/dps8/dps8_fnp2.c fnpProcessBuffer (linep); linep 1387 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1388 src/dps8/dps8_fnp2.c if (linep->nPos >= sizeof (linep->buffer) || linep 1389 src/dps8/dps8_fnp2.c len > sizeof (linep->buffer) - linep->nPos) linep 1393 src/dps8/dps8_fnp2.c memcpy (linep->buffer + linep->nPos, msg, len); linep 1394 src/dps8/dps8_fnp2.c linep->nPos += len; linep 1398 src/dps8/dps8_fnp2.c linep 1400 src/dps8/dps8_fnp2.c linep 1403 src/dps8/dps8_fnp2.c linep->force_accept_input = true; linep 1404 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1405 src/dps8/dps8_fnp2.c linep->input_break = brk ? 1 : 0; linep 1441 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1444 src/dps8/dps8_fnp2.c if (linep->accept_input) linep 1446 src/dps8/dps8_fnp2.c if (linep->input_reply_pending || linep->input_in_mailbox_pending) linep 1457 src/dps8/dps8_fnp2.c uint left = linep->sync_msg_size; linep 1460 src/dps8/dps8_fnp2.c if (left > sizeof (linep->buffer)) linep 1461 src/dps8/dps8_fnp2.c left = sizeof (linep->buffer); linep 1463 src/dps8/dps8_fnp2.c unsigned char * bufp = linep->buffer; linep 1501 src/dps8/dps8_fnp2.c linep->input_break = 1; linep 1506 src/dps8/dps8_fnp2.c uint sz = (uint) (bufp - linep->buffer); linep 1509 src/dps8/dps8_fnp2.c linep->force_accept_input = true; linep 1510 src/dps8/dps8_fnp2.c linep->accept_input = 1; linep 1511 src/dps8/dps8_fnp2.c linep->nPos = sz; linep 1528 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1541 src/dps8/dps8_fnp2.c linep->lineStatus0 = 6llu << 18; // IBM3270_WRITE_COMPLETE linep 1542 src/dps8/dps8_fnp2.c linep->lineStatus1 = 0; linep 1543 src/dps8/dps8_fnp2.c linep->sendLineStatus = true; linep 1624 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno]; linep 1628 src/dps8/dps8_fnp2.c if (linep -> line_disconnected > 1) linep 1631 src/dps8/dps8_fnp2.c if (linep->inBuffer && linep->inUsed < linep->inSize) linep 1634 src/dps8/dps8_fnp2.c linep -> line_disconnected = DISC_DELAY; linep 1639 src/dps8/dps8_fnp2.c -- linep -> line_disconnected; linep 1645 src/dps8/dps8_fnp2.c if (linep->waitForMbxDone) linep 1653 src/dps8/dps8_fnp2.c bool do_send_output = linep->send_output == 1 && linep 1654 src/dps8/dps8_fnp2.c ! fnpuv_output_backlogged (linep->line_client); linep 1656 src/dps8/dps8_fnp2.c if (linep -> send_output > 1 || do_send_output) linep 1657 src/dps8/dps8_fnp2.c linep->send_output --; linep 1667 src/dps8/dps8_fnp2.c else if (linep->acu_dial_failure) linep 1670 src/dps8/dps8_fnp2.c linep->acu_dial_failure = false; linep 1682 src/dps8/dps8_fnp2.c else if (linep->listen && linep->accept_new_terminal) linep 1685 src/dps8/dps8_fnp2.c linep->accept_new_terminal = false; linep 1691 src/dps8/dps8_fnp2.c else if (linep -> ack_echnego_init) linep 1694 src/dps8/dps8_fnp2.c linep -> ack_echnego_init = false; linep 1695 src/dps8/dps8_fnp2.c linep -> send_output = SEND_OUTPUT_DELAY; linep 1701 src/dps8/dps8_fnp2.c else if (linep -> ack_echnego_stop) linep 1704 src/dps8/dps8_fnp2.c linep -> ack_echnego_stop = false; linep 1705 src/dps8/dps8_fnp2.c linep -> send_output = SEND_OUTPUT_DELAY; linep 1712 src/dps8/dps8_fnp2.c else if (linep -> line_disconnected == 1) linep 1715 src/dps8/dps8_fnp2.c linep -> line_disconnected = 0; linep 1716 src/dps8/dps8_fnp2.c linep -> listen = false; linep 1720 src/dps8/dps8_fnp2.c else if (linep -> line_disconnected) linep 1723 src/dps8/dps8_fnp2.c linep -> line_disconnected = false; linep 1724 src/dps8/dps8_fnp2.c linep -> listen = false; linep 1731 src/dps8/dps8_fnp2.c else if (linep -> wru_timeout) linep 1734 src/dps8/dps8_fnp2.c linep -> wru_timeout = false; linep 1740 src/dps8/dps8_fnp2.c else if (linep->accept_input && ! linep->waitForMbxDone) //-V560 linep 1744 src/dps8/dps8_fnp2.c if (linep->input_retry_at_ns) linep 1746 src/dps8/dps8_fnp2.c if (!fnpInputRetryDue (linep, uv_hrtime ())) linep 1748 src/dps8/dps8_fnp2.c linep->input_retry_at_ns = 0; linep 1750 src/dps8/dps8_fnp2.c if (linep->accept_input == 1) linep 1756 src/dps8/dps8_fnp2.c if (0 && linep->nPos == 0) linep 1765 src/dps8/dps8_fnp2.c linep 1766 src/dps8/dps8_fnp2.c linep 1767 src/dps8/dps8_fnp2.c linep 1768 src/dps8/dps8_fnp2.c linep 1770 src/dps8/dps8_fnp2.c linep 1785 src/dps8/dps8_fnp2.c linep 1790 src/dps8/dps8_fnp2.c if (linep->force_accept_input || linep->nPos > 100) linep 1792 src/dps8/dps8_fnp2.c linep->input_reply_pending = true; linep 1803 src/dps8/dps8_fnp2.c linep->input_in_mailbox_pending = true; linep 1812 src/dps8/dps8_fnp2.c linep->accept_input --; linep 1819 src/dps8/dps8_fnp2.c else if (linep->line_break) linep 1822 src/dps8/dps8_fnp2.c linep -> line_break = false; linep 1824 src/dps8/dps8_fnp2.c linep -> send_output = SEND_OUTPUT_DELAY; linep 1827 src/dps8/dps8_fnp2.c else if (linep->sendLineStatus) linep 1829 src/dps8/dps8_fnp2.c linep->sendLineStatus = false; linep 2625 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnp_unit_idx].MState.line[lineno]; linep 2626 src/dps8/dps8_fnp2.c if (! linep->listen) linep 2628 src/dps8/dps8_fnp2.c if (linep->service == service_login && linep 2629 src/dps8/dps8_fnp2.c ! linep->line_disconnected && linep 2630 src/dps8/dps8_fnp2.c ! linep->line_client && linep 2775 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 2777 src/dps8/dps8_fnp2.c if (nread <= 0 || !buf || (uint64_t)nread > UINT_MAX - linep->inSize || linep 2778 src/dps8/dps8_fnp2.c (uint64_t)linep->inSize + (uint64_t)nread > FNP_MAX_PENDING_INPUT) linep 2791 src/dps8/dps8_fnp2.c if (linep->inBuffer) linep 2797 src/dps8/dps8_fnp2.c unsigned char * new = realloc (linep->inBuffer, (unsigned long) (linep->inSize + nread)); linep 2804 src/dps8/dps8_fnp2.c memcpy (new + linep->inSize, buf, (unsigned long) nread); linep 2805 src/dps8/dps8_fnp2.c linep->inSize += nread; linep 2806 src/dps8/dps8_fnp2.c linep->inBuffer = new; linep 2810 src/dps8/dps8_fnp2.c linep->inBuffer = malloc ((unsigned long) nread); linep 2811 src/dps8/dps8_fnp2.c if (! linep->inBuffer) linep 2817 src/dps8/dps8_fnp2.c memcpy (linep->inBuffer, buf, (unsigned long) nread); linep 2818 src/dps8/dps8_fnp2.c linep->inSize = (uint) nread; linep 2819 src/dps8/dps8_fnp2.c linep->inUsed = 0; linep 2861 src/dps8/dps8_fnp2.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 2864 src/dps8/dps8_fnp2.c if (! linep->inBuffer) linep 2868 src/dps8/dps8_fnp2.c if (! linep->listen) linep 2870 src/dps8/dps8_fnp2.c if (! linep->inBuffer) linep 2929 src/dps8/dps8_fnp2.c void reset_line (struct t_line * linep) linep 2931 src/dps8/dps8_fnp2.c linep->was_CR = false; linep 2932 src/dps8/dps8_fnp2.c linep->inputBufferSize = 0; linep 2933 src/dps8/dps8_fnp2.c linep->ctrlStrIdx = 0; linep 2934 src/dps8/dps8_fnp2.c linep->breakAll = false; linep 2935 src/dps8/dps8_fnp2.c linep->handleQuit = false; linep 2936 src/dps8/dps8_fnp2.c linep->echoPlex = false; linep 2937 src/dps8/dps8_fnp2.c linep->crecho = false; linep 2938 src/dps8/dps8_fnp2.c linep->lfecho = false; linep 2939 src/dps8/dps8_fnp2.c linep->tabecho = false; linep 2940 src/dps8/dps8_fnp2.c linep->replay = false; linep 2941 src/dps8/dps8_fnp2.c linep->polite = false; linep 2942 src/dps8/dps8_fnp2.c linep->prefixnl = false; linep 2943 src/dps8/dps8_fnp2.c linep->eight_bit_out = false; linep 2944 src/dps8/dps8_fnp2.c linep->eight_bit_in = false; linep 2945 src/dps8/dps8_fnp2.c linep->odd_parity = false; linep 2946 src/dps8/dps8_fnp2.c linep->output_flow_control = false; linep 2947 src/dps8/dps8_fnp2.c linep->input_flow_control = false; linep 2948 src/dps8/dps8_fnp2.c linep->block_xfer_in_frame_sz = 0; linep 2949 src/dps8/dps8_fnp2.c linep->block_xfer_out_frame_sz = 0; linep 2950 src/dps8/dps8_fnp2.c (void)memset (linep->delay_table, 0, sizeof (linep->delay_table)); linep 2951 src/dps8/dps8_fnp2.c linep->inputSuspendLen = 0; linep 2952 src/dps8/dps8_fnp2.c (void)memset (linep->inputSuspendStr, 0, sizeof (linep->inputSuspendStr)); linep 2953 src/dps8/dps8_fnp2.c linep->inputResumeLen = 0; linep 2954 src/dps8/dps8_fnp2.c (void)memset (linep->inputResumeStr, 0, sizeof (linep->inputResumeStr)); linep 2955 src/dps8/dps8_fnp2.c linep->outputSuspendLen = 0; linep 2956 src/dps8/dps8_fnp2.c (void)memset (linep->outputSuspendStr, 0, sizeof (linep->outputSuspendStr)); linep 2957 src/dps8/dps8_fnp2.c linep->outputResumeLen = 0; linep 2958 src/dps8/dps8_fnp2.c (void)memset (linep->outputResumeStr, 0, sizeof (linep->outputResumeStr)); linep 2959 src/dps8/dps8_fnp2.c linep->frame_begin = 0; linep 2960 src/dps8/dps8_fnp2.c linep->frame_end = 0; linep 2961 src/dps8/dps8_fnp2.c (void)memset (linep->echnego_break_table, 0, sizeof (linep->echnego_break_table)); linep 2962 src/dps8/dps8_fnp2.c linep->echnego_sync_ctr = 0; linep 2963 src/dps8/dps8_fnp2.c linep->echnego_screen_left = 0; linep 2964 src/dps8/dps8_fnp2.c linep->echnego_unechoed_cnt = 0; linep 2965 src/dps8/dps8_fnp2.c linep->echnego_on = false; linep 2966 src/dps8/dps8_fnp2.c linep->echnego_synced = false; linep 2967 src/dps8/dps8_fnp2.c linep->line_break = false; linep 183 src/dps8/dps8_fnp2.h static inline bool fnpInputRetryDue (const struct t_line * linep, uint64_t now_ns) linep 185 src/dps8/dps8_fnp2.h return linep->input_retry_at_ns == 0 || now_ns >= linep->input_retry_at_ns; linep 187 src/dps8/dps8_fnp2.h static inline void fnpScheduleInputRetry (struct t_line * linep) linep 189 src/dps8/dps8_fnp2.h if ((!linep->input_reply_pending && !linep->input_in_mailbox_pending) || linep 190 src/dps8/dps8_fnp2.h linep->input_cancelled) linep 192 src/dps8/dps8_fnp2.h linep->accept_input = 1; linep 193 src/dps8/dps8_fnp2.h linep->input_retry_at_ns = uv_hrtime () + FNP_INPUT_RETRY_NS; linep 166 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = & decoded_p->fudp->MState.line[decoded_p->slot_no]; linep 180 src/dps8/dps8_fnp2_iomcmd.c if (linep->line_client && linep->service == service_login) linep 181 src/dps8/dps8_fnp2_iomcmd.c fnpuv_start_writestr (linep->line_client, (unsigned char *) "Multics has disconnected you\r\n"); linep 183 src/dps8/dps8_fnp2_iomcmd.c linep -> line_disconnected = DISC_DELAY; linep 185 src/dps8/dps8_fnp2_iomcmd.c linep -> line_disconnected = true; linep 187 src/dps8/dps8_fnp2_iomcmd.c linep -> listen = false; linep 188 src/dps8/dps8_fnp2_iomcmd.c if (linep->line_client) linep 190 src/dps8/dps8_fnp2_iomcmd.c close_connection ((uv_stream_t *) linep->line_client); linep 212 src/dps8/dps8_fnp2_iomcmd.c linep->lineType = (word9) getbits36_18 (command_data[0], 0); linep 222 src/dps8/dps8_fnp2_iomcmd.c linep->frame_begin = d1; linep 223 src/dps8/dps8_fnp2_iomcmd.c linep->frame_end = d2; linep 413 src/dps8/dps8_fnp2_iomcmd.c linep->sync_msg_size = (uint) getbits36_18 (command_data[0], 0); linep 486 src/dps8/dps8_fnp2_iomcmd.c (void)memset (linep->echnego_break_table, 0, linep 487 src/dps8/dps8_fnp2_iomcmd.c sizeof (linep->echnego_break_table)); linep 491 src/dps8/dps8_fnp2_iomcmd.c (void)memset (linep->echnego_break_table, 1, linep 492 src/dps8/dps8_fnp2_iomcmd.c sizeof (linep->echnego_break_table)); linep 510 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_break_table[offset++] = linep 513 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_break_table[offset++] = linep 524 src/dps8/dps8_fnp2_iomcmd.c linep 549 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_sync_ctr = linep 551 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_screen_left = getbits36_18 (command_data[0], 18); linep 555 src/dps8/dps8_fnp2_iomcmd.c "unechoed cnt %d\r\n", linep->echnego_sync_ctr, linep 556 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_screen_left,linep->echnego_unechoed_cnt); linep 563 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_on = linep 564 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_sync_ctr == linep->echnego_unechoed_cnt; linep 568 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_on ? "on" : "off"); linep 582 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_on = false; linep 584 src/dps8/dps8_fnp2_iomcmd.c linep->ack_echnego_stop = true; linep 603 src/dps8/dps8_fnp2_iomcmd.c linep->echnego_unechoed_cnt = 0; linep 606 src/dps8/dps8_fnp2_iomcmd.c linep->ack_echnego_init = true; linep 624 src/dps8/dps8_fnp2_iomcmd.c linep->inputSuspendStr[0] = getbits36_8 (suspendStr, 10); linep 625 src/dps8/dps8_fnp2_iomcmd.c linep->inputSuspendStr[1] = getbits36_8 (suspendStr, 19); linep 626 src/dps8/dps8_fnp2_iomcmd.c linep->inputSuspendStr[2] = getbits36_8 (suspendStr, 28); linep 634 src/dps8/dps8_fnp2_iomcmd.c linep->inputSuspendLen = suspendLen; linep 637 src/dps8/dps8_fnp2_iomcmd.c linep->inputResumeStr[0] = getbits36_8 (resumeStr, 10); linep 638 src/dps8/dps8_fnp2_iomcmd.c linep->inputResumeStr[1] = getbits36_8 (resumeStr, 19); linep 639 src/dps8/dps8_fnp2_iomcmd.c linep->inputResumeStr[2] = getbits36_8 (resumeStr, 28); linep 647 src/dps8/dps8_fnp2_iomcmd.c linep->inputResumeLen = resumeLen; linep 660 src/dps8/dps8_fnp2_iomcmd.c linep->outputSuspendStr[0] = getbits36_8 (suspendStr, 10); linep 661 src/dps8/dps8_fnp2_iomcmd.c linep->outputSuspendStr[1] = getbits36_8 (suspendStr, 19); linep 662 src/dps8/dps8_fnp2_iomcmd.c linep->outputSuspendStr[2] = getbits36_8 (suspendStr, 28); linep 670 src/dps8/dps8_fnp2_iomcmd.c linep->outputSuspendLen = suspendLen; linep 673 src/dps8/dps8_fnp2_iomcmd.c linep->outputResumeStr[0] = getbits36_8 (resumeStr, 10); linep 674 src/dps8/dps8_fnp2_iomcmd.c linep->outputResumeStr[1] = getbits36_8 (resumeStr, 19); linep 675 src/dps8/dps8_fnp2_iomcmd.c linep->outputResumeStr[2] = getbits36_8 (resumeStr, 28); linep 683 src/dps8/dps8_fnp2_iomcmd.c linep->outputResumeLen = resumeLen; linep 704 src/dps8/dps8_fnp2_iomcmd.c linep->fullDuplex = !! flag; linep 713 src/dps8/dps8_fnp2_iomcmd.c linep->crecho = !! flag; linep 722 src/dps8/dps8_fnp2_iomcmd.c linep->lfecho = !! flag; linep 733 src/dps8/dps8_fnp2_iomcmd.c linep -> send_output = SEND_OUTPUT_DELAY; linep 742 src/dps8/dps8_fnp2_iomcmd.c linep->tabecho = !! flag; linep 753 src/dps8/dps8_fnp2_iomcmd.c linep->listen = !! flag; linep 754 src/dps8/dps8_fnp2_iomcmd.c linep->inputBufferSize = bufsz; linep 756 src/dps8/dps8_fnp2_iomcmd.c if (linep->service == service_undefined) linep 757 src/dps8/dps8_fnp2_iomcmd.c linep->service = service_login; linep 759 src/dps8/dps8_fnp2_iomcmd.c if (linep->service == service_login && linep -> line_client) linep 761 src/dps8/dps8_fnp2_iomcmd.c fnpuv_start_writestr (linep->line_client, linep 762 src/dps8/dps8_fnp2_iomcmd.c linep->listen ? linep 766 src/dps8/dps8_fnp2_iomcmd.c if (linep->service == service_slave && ! linep -> line_client) linep 776 src/dps8/dps8_fnp2_iomcmd.c linep->handleQuit = !! flag; linep 786 src/dps8/dps8_fnp2_iomcmd.c linep->ctrlStrIdx = idx; linep 794 src/dps8/dps8_fnp2_iomcmd.c linep -> wru_timeout = true; linep 803 src/dps8/dps8_fnp2_iomcmd.c linep->echoPlex = !! flag; linep 827 src/dps8/dps8_fnp2_iomcmd.c linep->replay = !! flag; linep 836 src/dps8/dps8_fnp2_iomcmd.c linep->polite = !! flag; linep 846 src/dps8/dps8_fnp2_iomcmd.c linep->block_xfer_out_frame_sz = bufsiz1; linep 847 src/dps8/dps8_fnp2_iomcmd.c linep->block_xfer_in_frame_sz = bufsiz2; linep 863 src/dps8/dps8_fnp2_iomcmd.c linep->inputBufferSize = sz; linep 873 src/dps8/dps8_fnp2_iomcmd.c linep->breakAll = !! flag; linep 882 src/dps8/dps8_fnp2_iomcmd.c linep->prefixnl = !! flag; linep 891 src/dps8/dps8_fnp2_iomcmd.c linep->input_flow_control = !! flag; linep 900 src/dps8/dps8_fnp2_iomcmd.c linep->output_flow_control = !! flag; linep 909 src/dps8/dps8_fnp2_iomcmd.c linep->odd_parity = !! flag; linep 918 src/dps8/dps8_fnp2_iomcmd.c linep->eight_bit_in = !! flag; linep 927 src/dps8/dps8_fnp2_iomcmd.c linep->eight_bit_out = !! flag; linep 975 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[0] = d1; linep 976 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[1] = d2; linep 977 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[2] = d3; linep 978 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[3] = d4; linep 979 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[4] = d5; linep 980 src/dps8/dps8_fnp2_iomcmd.c linep->delay_table[5] = d6; linep 1118 src/dps8/dps8_fnp2_iomcmd.c static void tun_write (struct t_line * linep, uint16_t * data, uint tally) linep 1133 src/dps8/dps8_fnp2_iomcmd.c linep->in_frame = true; linep 1134 src/dps8/dps8_fnp2_iomcmd.c linep->frameLen = 0; linep 1138 src/dps8/dps8_fnp2_iomcmd.c if (! linep->in_frame) linep 1141 src/dps8/dps8_fnp2_iomcmd.c if (linep->frameLen >= 2+1500) linep 1146 src/dps8/dps8_fnp2_iomcmd.c linep->frame[linep->frameLen ++] = (uint8_t) (data [i] & 0xff); linep 1151 src/dps8/dps8_fnp2_iomcmd.c if (linep->frameLen >= 2) linep 1153 src/dps8/dps8_fnp2_iomcmd.c uint16_t target = (uint16_t) ((linep->frame[0] & 0xff) << 8) | (linep->frame[1]); linep 1154 src/dps8/dps8_fnp2_iomcmd.c if (target + 2 >= linep->frameLen) linep 1157 src/dps8/dps8_fnp2_iomcmd.c fnpuv_tun_write (linep); linep 1158 src/dps8/dps8_fnp2_iomcmd.c linep->in_frame = false; linep 1170 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = & decoded_p->fudp->MState.line[decoded_p->slot_no]; linep 1215 src/dps8/dps8_fnp2_iomcmd.c if (linep->is_tun && tally > 0) linep 1217 src/dps8/dps8_fnp2_iomcmd.c tun_write (linep, data9, tally); linep 1221 src/dps8/dps8_fnp2_iomcmd.c if (tally > 0 && linep->line_client) linep 1223 src/dps8/dps8_fnp2_iomcmd.c if (! linep->line_client || ! linep->line_client->data) //-V560 linep 1228 src/dps8/dps8_fnp2_iomcmd.c uvClientData * p = linep->line_client->data; linep 1229 src/dps8/dps8_fnp2_iomcmd.c (* p->write_cb) (linep->line_client, data, tally); linep 1327 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = & decoded_p->fudp->MState.line[decoded_p->slot_no]; linep 1328 src/dps8/dps8_fnp2_iomcmd.c unsigned char * data_p = linep -> buffer; linep 1330 src/dps8/dps8_fnp2_iomcmd.c n_chars = min(n_chars, linep -> nPos); linep 1336 src/dps8/dps8_fnp2_iomcmd.c if (!linep->input_reply_pending || linep->input_cancelled) linep 1338 src/dps8/dps8_fnp2_iomcmd.c if (!linep->input_cancelled) linep 1341 src/dps8/dps8_fnp2_iomcmd.c linep->input_reply_pending = false; linep 1342 src/dps8/dps8_fnp2_iomcmd.c linep->input_cancelled = false; linep 1343 src/dps8/dps8_fnp2_iomcmd.c linep->input_retry_at_ns = 0; linep 1363 src/dps8/dps8_fnp2_iomcmd.c fnpScheduleInputRetry (linep); linep 1375 src/dps8/dps8_fnp2_iomcmd.c { sim_printf ("[%u][FNP emulator: nPos %d long IN: '", decoded_p->slot_no, linep->nPos); linep 1376 src/dps8/dps8_fnp2_iomcmd.c for (uint i = 0; i < linep->nPos; i ++) linep 1378 src/dps8/dps8_fnp2_iomcmd.c if (isgraph (linep->buffer [i])) linep 1379 src/dps8/dps8_fnp2_iomcmd.c sim_printf ("%c", linep->buffer [i]); linep 1381 src/dps8/dps8_fnp2_iomcmd.c sim_printf ("\\%03o", linep->buffer [i]); linep 1416 src/dps8/dps8_fnp2_iomcmd.c l_putbits36_1 (& v, 17, linep->input_break && n_chars == linep->nPos ? 1 : 0); linep 1422 src/dps8/dps8_fnp2_iomcmd.c const bool short_grant = n_chars < linep->nPos; linep 1426 src/dps8/dps8_fnp2_iomcmd.c memmove (linep->buffer, linep->buffer + n_chars, linep 1427 src/dps8/dps8_fnp2_iomcmd.c linep->nPos - n_chars); linep 1428 src/dps8/dps8_fnp2_iomcmd.c linep->nPos -= n_chars; linep 1429 src/dps8/dps8_fnp2_iomcmd.c fnpScheduleInputRetry (linep); linep 1433 src/dps8/dps8_fnp2_iomcmd.c linep->input_break = false; linep 1434 src/dps8/dps8_fnp2_iomcmd.c linep->nPos = 0; linep 1435 src/dps8/dps8_fnp2_iomcmd.c linep->input_retry_at_ns = 0; linep 1437 src/dps8/dps8_fnp2_iomcmd.c linep->input_reply_pending = false; linep 1607 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = &decoded_p->fudp->MState.line[decoded_p->slot_no]; linep 1613 src/dps8/dps8_fnp2_iomcmd.c (linep->input_reply_pending || linep->input_in_mailbox_pending)) linep 1615 src/dps8/dps8_fnp2_iomcmd.c if (linep->input_cancelled) linep 1620 src/dps8/dps8_fnp2_iomcmd.c linep->input_reply_pending = false; linep 1621 src/dps8/dps8_fnp2_iomcmd.c linep->input_in_mailbox_pending = false; linep 1622 src/dps8/dps8_fnp2_iomcmd.c linep->input_cancelled = false; linep 1623 src/dps8/dps8_fnp2_iomcmd.c linep->accept_input = 0; linep 1624 src/dps8/dps8_fnp2_iomcmd.c linep->input_retry_at_ns = 0; linep 1627 src/dps8/dps8_fnp2_iomcmd.c fnpScheduleInputRetry (linep); linep 1755 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = &decoded_p->fudp->MState.line[pending_line]; linep 1759 src/dps8/dps8_fnp2_iomcmd.c if (linep->input_in_mailbox_pending) linep 1761 src/dps8/dps8_fnp2_iomcmd.c linep->input_in_mailbox_pending = false; linep 1762 src/dps8/dps8_fnp2_iomcmd.c if (linep->input_cancelled) linep 1763 src/dps8/dps8_fnp2_iomcmd.c linep->input_cancelled = false; linep 1766 src/dps8/dps8_fnp2_iomcmd.c linep->nPos = 0; linep 1767 src/dps8/dps8_fnp2_iomcmd.c linep->input_break = false; linep 1768 src/dps8/dps8_fnp2_iomcmd.c linep->input_retry_at_ns = 0; linep 1771 src/dps8/dps8_fnp2_iomcmd.c if (linep->line_break && linep->accept_input == 1) linep 1772 src/dps8/dps8_fnp2_iomcmd.c linep->accept_input = 0; linep 1775 src/dps8/dps8_fnp2_iomcmd.c sim_debug (DBG_TRACE, &fnp_dev, "clearing wait; was %d\r\n", linep->waitForMbxDone); linep 1776 src/dps8/dps8_fnp2_iomcmd.c linep->waitForMbxDone = false; linep 2478 src/dps8/dps8_fnp2_iomcmd.c struct t_line * linep = & fudp->MState.line[lineno]; linep 2487 src/dps8/dps8_fnp2_iomcmd.c linep->lineType = line_type; linep 374 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 378 src/dps8/fnpuv.c linep->accept_input = 1; linep 379 src/dps8/fnpuv.c linep->line_break=true; linep 511 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[p->fnpno].MState.line[p->lineno]; linep 512 src/dps8/fnpuv.c if (linep->service == service_3270) linep 527 src/dps8/fnpuv.c linep -> line_disconnected = DISC_DELAY; linep 529 src/dps8/fnpuv.c linep -> line_disconnected = true; linep 531 src/dps8/fnpuv.c linep -> listen = false; linep 532 src/dps8/fnpuv.c if (linep->inBuffer) linep 533 src/dps8/fnpuv.c FREE (linep->inBuffer); linep 534 src/dps8/fnpuv.c linep->inBuffer = NULL; linep 535 src/dps8/fnpuv.c linep->inSize = 0; linep 536 src/dps8/fnpuv.c linep->inUsed = 0; linep 537 src/dps8/fnpuv.c linep->nPos = 0; linep 541 src/dps8/fnpuv.c linep->input_cancelled = linep->input_reply_pending || linep 542 src/dps8/fnpuv.c linep->input_in_mailbox_pending; linep 543 src/dps8/fnpuv.c linep->input_retry_at_ns = 0; linep 544 src/dps8/fnpuv.c linep->accept_input = 0; linep 545 src/dps8/fnpuv.c linep->input_break = false; linep 546 src/dps8/fnpuv.c linep->force_accept_input = false; linep 547 src/dps8/fnpuv.c linep->send_output = 0; linep 549 src/dps8/fnpuv.c if (linep->line_client == (uv_tcp_t *)stream) linep 551 src/dps8/fnpuv.c linep->line_client = NULL; linep 1000 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[p->fnpno].MState.line[p->lineno]; linep 1003 src/dps8/fnpuv.c if (linep->line_client) linep 1012 src/dps8/fnpuv.c linep->line_client = client; linep 1034 src/dps8/fnpuv.c struct t_line * linep = &fnpData.fnpUnitData[q->fnpno].MState.line[q->lineno]; linep 1035 src/dps8/fnpuv.c if (linep->line_client == client) linep 1036 src/dps8/fnpuv.c linep->line_client = NULL; linep 1084 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[p->fnpno].MState.line[p->lineno]; linep 1085 src/dps8/fnpuv.c if (linep->lineType == 0) /* LINE_NONE */ linep 1086 src/dps8/fnpuv.c linep->lineType = 1; /* LINE_ASCII */ linep 1087 src/dps8/fnpuv.c linep->accept_new_terminal = true; linep 1088 src/dps8/fnpuv.c reset_line (linep); linep 1189 src/dps8/fnpuv.c struct t_line * linep = &fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1190 src/dps8/fnpuv.c if (linep->server.data) linep 1191 src/dps8/fnpuv.c close_listener (&linep->server); linep 1231 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[p->fnpno].MState.line[p->lineno]; linep 1232 src/dps8/fnpuv.c if (linep->line_client != client || uv_is_closing ((uv_handle_t *)client)) linep 1239 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1246 src/dps8/fnpuv.c linep->listen = true; linep 1247 src/dps8/fnpuv.c if (linep->lineType == 0) /* LINE_NONE */ linep 1248 src/dps8/fnpuv.c linep->lineType = 1; /* LINE_ASCII */ linep 1249 src/dps8/fnpuv.c linep->accept_new_terminal = true; linep 1250 src/dps8/fnpuv.c linep->was_CR = false; linep 1269 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1296 src/dps8/fnpuv.c if (linep->line_client) linep 1300 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1310 src/dps8/fnpuv.c linep->is_tun = false; linep 1313 src/dps8/fnpuv.c if (linep->tun_fd <= 0) linep 1316 src/dps8/fnpuv.c linep->tun_fd = tun_alloc (a_name); linep 1317 src/dps8/fnpuv.c if (linep->tun_fd < 0) linep 1319 src/dps8/fnpuv.c sim_printf ("\r[FNP emulation: dialout TUN tun_alloc returned %d errno %d]\r\n", linep->tun_fd, errno); linep 1322 src/dps8/fnpuv.c int flags = fcntl (linep->tun_fd, F_GETFL, 0); linep 1329 src/dps8/fnpuv.c int ret = fcntl (linep->tun_fd, F_SETFL, flags); linep 1336 src/dps8/fnpuv.c linep->is_tun = true; linep 1344 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1368 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1379 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1383 src/dps8/fnpuv.c linep->line_client = (uv_tcp_t *) malloc (sizeof (uv_tcp_t)); linep 1384 src/dps8/fnpuv.c if (!linep->line_client) linep 1387 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1390 src/dps8/fnpuv.c int init_rc = uv_tcp_init (fnpData.loop, linep->line_client); linep 1394 src/dps8/fnpuv.c FREE (linep->line_client); linep 1395 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1398 src/dps8/fnpuv.c linep->line_client->data = NULL; linep 1404 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1405 src/dps8/fnpuv.c uv_tcp_t * orphan = linep->line_client; linep 1406 src/dps8/fnpuv.c linep->line_client = NULL; linep 1416 src/dps8/fnpuv.c register_client (linep->line_client, p); linep 1422 src/dps8/fnpuv.c p->telnetp = ltnConnect (linep->line_client); linep 1426 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1427 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); linep 1443 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1444 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); linep 1447 src/dps8/fnpuv.c int rc = uv_tcp_connect (req, linep->line_client, linep 1452 src/dps8/fnpuv.c linep->acu_dial_failure = true; linep 1454 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); linep 1463 src/dps8/fnpuv.c linep 1471 src/dps8/fnpuv.c linep 1472 src/dps8/fnpuv.c linep 1487 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1490 src/dps8/fnpuv.c if (linep->server.data) linep 1493 src/dps8/fnpuv.c if (uv_tcp_init (fnpData.loop, & linep->server) < 0) linep 1505 src/dps8/fnpuv.c linep->server.data = NULL; linep 1506 src/dps8/fnpuv.c close_listener (&linep->server); linep 1517 src/dps8/fnpuv.c linep->server.data = p; linep 1518 src/dps8/fnpuv.c linep->line_client = NULL; linep 1522 src/dps8/fnpuv.c int r = uv_ip4_addr (bind_address, linep->port, & addr); linep 1524 src/dps8/fnpuv.c r = uv_tcp_bind (& linep->server, (const struct sockaddr *) & addr, 0); linep 1526 src/dps8/fnpuv.c r = uv_listen ((uv_stream_t *) & linep->server, DEFAULT_BACKLOG, linep 1530 src/dps8/fnpuv.c sim_printf ("\r[FNP emulation: listen error: %s:%ld: %s]\r\n", bind_address, (long) linep->port, uv_strerror(r)); linep 1531 src/dps8/fnpuv.c close_listener (&linep->server); linep 1534 src/dps8/fnpuv.c sim_printf ("\r[FNP emulation: listening on %s:%ld]\r\n", bind_address, (long) linep->port); linep 1553 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1554 src/dps8/fnpuv.c if (nread <= 0 || !buf || (uint64_t)nread > UINT_MAX - linep->inSize || linep 1555 src/dps8/fnpuv.c (uint64_t)linep->inSize + (uint64_t)nread > 16U * 1024U * 1024U) linep 1560 src/dps8/fnpuv.c if (linep->inBuffer) linep 1562 src/dps8/fnpuv.c unsigned char * new = realloc (linep->inBuffer, (unsigned long) (linep->inSize + nread)); linep 1568 src/dps8/fnpuv.c memcpy (new + linep->inSize, buf, (unsigned long) nread); linep 1569 src/dps8/fnpuv.c linep->inSize += nread; linep 1570 src/dps8/fnpuv.c linep->inBuffer = new; linep 1574 src/dps8/fnpuv.c linep->inBuffer = malloc ((unsigned long) nread); linep 1575 src/dps8/fnpuv.c if (! linep->inBuffer) linep 1580 src/dps8/fnpuv.c memcpy (linep->inBuffer, buf, (unsigned long) nread); linep 1581 src/dps8/fnpuv.c linep->inSize = (uint) nread; linep 1582 src/dps8/fnpuv.c linep->inUsed = 0; linep 1587 src/dps8/fnpuv.c static void fnoTUNProcessLine (int fnpno, int lineno, struct t_line * linep) linep 1591 src/dps8/fnpuv.c ssize_t nread = read (linep->tun_fd, buffer, sizeof (buffer)); linep 1677 src/dps8/fnpuv.c struct t_line * linep = & fnpData.fnpUnitData[fnpno].MState.line[lineno]; linep 1678 src/dps8/fnpuv.c if (linep->is_tun) linep 1679 src/dps8/fnpuv.c fnoTUNProcessLine (fnpno, lineno, linep); linep 75 src/dps8/fnpuv.h void reset_line (struct t_line * linep);