src/dps8/fnpuv.h

/* */
   1 /*
   2  * vim: filetype=c:tabstop=4:ai:expandtab
   3  * SPDX-License-Identifier: ICU
   4  * scspell-id: 34c5cd04-f62f-11ec-b27c-80ee73e9b8e7
   5  *
   6  * ---------------------------------------------------------------------------
   7  *
   8  * Copyright (c) 2016 Charles Anthony
   9  * Copyright (c) 2021-2025 The DPS8M Development Team
  10  *
  11  * This software is made available under the terms of the ICU License.
  12  * See the LICENSE.md file at the top-level directory of this distribution.
  13  *
  14  * ---------------------------------------------------------------------------
  15  */
  16 
  17 typedef void (* uv_read_cb_t)  (uv_tcp_t * client, ssize_t nread, unsigned char * buf);
  18 typedef void (* uv_write_cb_t) (uv_tcp_t * client, unsigned char * data, ssize_t datalen);
  19 struct uvClientData_s
  20   {
  21     // All live FNP sockets, including clients not yet associated with a line.
  22     uv_tcp_t * client;
  23     struct uvClientData_s * next;
  24     struct uvClientData_s * prev;
  25     bool assoc;
  26     // Pending dial-in line-selection sessions are capped and expire; once
  27     // assigned to a Multics line, neither restriction applies.
  28     bool selection_pending;
  29     uint64_t selection_deadline_ns;
  30     char selection_peer[128];
  31     uint fnpno;
  32     uint lineno;
  33     /* telnet_t */ void * telnetp;
  34     uv_read_cb_t  read_cb;
  35     uv_write_cb_t write_cb;
  36     uv_write_cb_t write_actual_cb;
  37     // Work buffer for processLineInput
  38     char buffer [1024];
  39     size_t nPos;
  40     // 3270
  41     char * ttype;
  42     uint stationNo;
  43   };
  44 
  45 typedef struct uvClientData_s uvClientData;
  46 
  47 int fnpuvInit (int telnet_port, char * telnet_address);
  48 int fnpuv3270Init (int telnet3270_port);
  49 void fnpuv3270Poll (bool start);
  50 void fnpuvProcessEvent (void);
  51 void fnpuvExit (void);
  52 void fnpuv_start_write (uv_tcp_t * client, unsigned char * data, ssize_t len);
  53 void fnpuv_start_writestr (uv_tcp_t * client, unsigned char * data);
  54 void fnpuv_send_eor (uv_tcp_t * client);
  55 void fnpuv_recv_eor (uv_tcp_t * client);
  56 void fnpuv_start_write_actual (uv_tcp_t * client, unsigned char * data, ssize_t datalen);
  57 void fnpuv_associated_brk (uv_tcp_t * client);
  58 void fnpuv_unassociated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf);
  59 void fnpuv_associated_readcb (uv_tcp_t * client, ssize_t nread, unsigned char * buf);
  60 void fnpuv_read_start (uv_tcp_t * client);
  61 void fnpuv_read_stop (uv_tcp_t * client);
  62 bool fnpuv_output_backlogged (uv_tcp_t * client);
  63 const char * fnpuv_peer_name (uv_tcp_t * client, char * text, size_t len);
  64 void fnpuv_complete_selection (uvClientData * p);
  65 void fnpuv_dial_out (uint fnpno, uint lineno, word36 d1, word36 d2, word36 d3);
  66 void fnpuv_open_slave (uint fnpno, uint lineno);
  67 void close_connection (uv_stream_t* stream);
  68 #if defined(TUN)
  69 void fnpTUNProcessEvent (void);
  70 #endif /* if defined(TUN) */
  71 void fnpuv_3270_readcb (uv_tcp_t * client,
  72                            ssize_t nread,
  73                            unsigned char * buf);
  74 void fnpuv_start_3270_write (uv_tcp_t * client, unsigned char * data, ssize_t datalen);
  75 void reset_line (struct t_line * linep);
/* */
root/src/dps8/fnpuv.h

INCLUDED FROM
