home *** CD-ROM | disk | FTP | other *** search
/ Amiga ISO Collection / AmigaUtilCD1.iso / Fax / AVMA&GPFax-V1,33Sources.LHA / efax.c < prev    next >
Encoding:
C/C++ Source or Header  |  1994-06-19  |  64.3 KB  |  2,184 lines
  1. #define Copyright         "Copyright 1994  Ed Casas"
  2.  
  3. #define Version          "efax v 0.6b"
  4.  
  5. #define EFAXVER "1.04"
  6. static char* versionString = "$VER: EFax (Amiga) " EFAXVER;
  7.  
  8. /*
  9.     Copyright (C) 1994  Ed Casas
  10.  
  11.     This program is free software; you can redistribute it and/or modify
  12.     it under the terms of the GNU General Public License as published by
  13.     the Free Software Foundation; either version 2 of the License, or
  14.     (at your option) any later version.
  15.  
  16.     This program is distributed in the hope that it will be useful,
  17.     but WITHOUT ANY WARRANTY; without even the implied warranty of
  18.     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19.     GNU General Public License for more details.
  20.  
  21.     You should have received a copy of the GNU General Public License
  22.     along with this program; if not, write to the Free Software
  23.     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  24.  
  25.     You may contact the author by e-mail at: edc@ee.ubc.ca,
  26.     or by mail at: 2629 West 3rd Ave, Vancouver, BC, Canada,
  27.     V6K 1M4.
  28.  
  29. */
  30.  
  31. const char *Usage =
  32.   "Usage:\n"
  33.   "  %s [ option ]... [ -r pat | -t num file... ]\n"
  34. "Options:\n"
  35.   "  -p portname load config from avm:servers.cfg\n"
  36.   "  -c cap  set file format or receive capabilites to cap\n"
  37.   "  -d dev  use modem on device dev\n"
  38.   "  -u unit unit number for device\n"
  39.   "  -g cmd  exec \"/bin/sh -c cmd\" for data calls\n"
  40.   "  -i str  send modem command ATstr at start\n"
  41.   "  -l id   set local indetification to id\n"
  42.   "  -o opt  use protocol option opt:\n"
  43.   "      1     use class 1 modem commands\n"
  44.   "      2     use class 2 modem commands\n"
  45.   "      a     if first [data mode] answer attempt fails retry as fax\n"
  46.   "      e     ignore errors in modem initialization commands\n"
  47.   "      r     reverse bit order on receive\n"  
  48.   "      t     reverse bit order on transmit\n"  
  49.   "      x     use XON instead of DC2 to trigger reception\n"
  50.   "      z     add 100 ms to pause before each modem comand (cumulative)\n"
  51.   "  -q ne   ask for retransmission if more than ne errors per page\n"
  52.   "  -s      share (unlock) modem device while waiting for call\n"
  53.   "  -v lvl  print messages of type in string lvl (ewinahcm)\n"
  54.   "  -w      don't answer phone, wait for OK or CONNECT instead\n"
  55.   "  -x fil  use uucp-style lock file fil\n"
  56.   "  -z str  send modem command ATstr when done\n"
  57.   "Commands:\n"
  58.   "  -r      answer and receive fax into files pat.001, pat.002, ... \n"
  59.   "  -t      send fax image files file... to telephone num\n"
  60.   ;
  61.  
  62. #include <ctype.h>        /* ANSI C */
  63. #include <errno.h>
  64. #include <signal.h>    
  65. #include <stdarg.h> 
  66. #include <stdio.h>
  67. #include <stdlib.h>
  68. #include <string.h>
  69. #include <time.h>
  70.  
  71. #include <fcntl.h>        /* UNIX */
  72. #include <sys/types.h>
  73.  
  74. #include <sys/stat.h>        /* required for SYSV (?) */
  75.  
  76. #include "voice.h"
  77. #include "callback_proto.h"
  78. #include "config_proto.h"
  79. #include "faxfile.h"
  80. #include "simplerexx.h"
  81.  
  82. extern long __stack = 10000L; /* max. stack size */
  83.  
  84. extern struct CallBack globalCallBack;
  85. extern int globalAborted;
  86.  
  87. AREXXCONTEXT OutgoingRexx;
  88.  
  89. void setSendSerialParms(void);
  90. void setReceiveSerialParms(void);
  91.  
  92. int verbose = 0;
  93.  
  94. struct faxout
  95. {
  96.     FILE           *fp;
  97.     int        fax_byte;
  98.     int        fax_weight;
  99.     int        pages;
  100.     int        raw;    /* 1: no header, 2: no EndOfPage */
  101.     char           *stdiobuf;
  102. };
  103.  
  104. struct faxout* FaxHandle = 0;
  105.  
  106. typedef struct faxin {
  107.     int     raw;
  108.     FAXHDR     faxhdr;
  109.     FAXHDR     pagehdr;
  110.     int     row;
  111.     int     endoffile;
  112.     int     eols;
  113.     int     rawzeros;
  114.     int     shdata;
  115.     int     shbit;
  116.     int     kludge;
  117.     int     reversebits;
  118.     int     stretch;
  119.     unsigned char  *bitp;
  120.     unsigned char    bitval;
  121.  
  122. } FAXIN;
  123.  
  124. extern FAXIN faxin;
  125.  
  126. /* prototypes */
  127. void releaseResources(void);
  128. void allocateResources(void);
  129. enum ReturnStatus waitForTimeout(int seconds, int microseconds, struct CallBack* cb);
  130. enum ReturnStatus readChar(char* c, int timeout, struct CallBack* cb);
  131. int writeToSerial(char* s, int len);
  132. void unReadChar(void);
  133. void mainError(char*);
  134.  
  135. extern char serialName[];
  136. extern int unitNumber;
  137. int dialTone = 1;
  138. int faxHardwareHandshaking = 1;
  139.  
  140. char portNameToLoad[40];
  141.  
  142. #ifndef FILENAME_MAX
  143. #define FILENAME_MAX 255
  144. #endif
  145.  
  146. #ifndef u_char
  147. #define u_char unsigned char
  148. #endif
  149.  
  150. /* constants... */
  151.  
  152. #define FAXFILE "serial.device"  /* default fax modem device */
  153. #define LOGF     stderr     /* session log written to this stream */
  154.  
  155.                 /* delays/timeouts, in deciseconds */
  156. #define TO_RESET  26        /* timeout for modem reset commands (per Hayes) */
  157. #define T_CMD     1        /* pause before each modem command */
  158. #define TO_A      1200        /* dial/answer (Phase A) - modem may T.O. first */
  159.  
  160. #define TO_DATAF  150        /* software adaptive answer data connect */
  161.  
  162. #define T1 350            /* T.30 T1 - waiting for DIS/DCS before Phase B */
  163. #define T2 60            /* T.30 T2 - waiting for frame in Phase B */
  164. #define T3S 30            /* T.30 response timeout (not T3) */
  165. #define T4 30            /* T.30 T4 - between [re]transmissions of DIS */
  166.  
  167. #define TO_DRAIN 140        /* drain 4k modem buffer at 2400bps (tx) */
  168. #define TO_RTCMD 10        /* return to command mode after DLE-ETX (rx) */
  169. #define TO_FT    31        /* max delay after +F[TR][MH] command */
  170. #define TO_CHAR  51        /* per data character (max FILL length) */
  171. #define TO_ABRT  20        /* max delay after sending abort sequence */
  172.  
  173. #define TO_C2B    450        /* Class 2 DIS to CONNECT:(DCS+TCF+CFR)xretries */
  174. #define TO_C2X    20        /* Class 2 wait for XON: 2/5 of 5s timeout */
  175. #define TO_C2PP   200        /* Class 2 wait for ppr: (ppm+ppr)x3retries + 2 */
  176. #define TO_C2R    600        /* Class 2 receive: (TCF+FTT)x11 retrains + 5 */
  177. #define TO_C2EOR  60        /* Class 2 end of data rx (2 retrans x 3 s) */
  178.  
  179.  
  180. #define CMDBUFSIZE 128      /* longest possible modem command or response */
  181. #define DEFDISLEN 3        /* length of DIS initially transmitted */
  182. #define DEFCAP 1,3,0,2,0,0,0,0    /* default local capabilities */
  183. #define DLE_ETX "\020\003"  /* DLE-ETX (end of data) string */
  184. #define FNAMFT "%m%d%H%M%S" /* strftime() format for default file name */
  185. #define HDBLKFLAG '#'        /* prefix to force HDB (text) lock file style */
  186. #define IDLEN 20        /* length of T.30 identification strings */
  187. #define LOCKPOLLDELAY 15    /* seconds between checks of lock files */
  188. #define MAXDIS 8        /* maximum DIS frames sent without response (T1) */
  189. #define MAXFIFLEN 125        /* max FIF len = MAXFRLEN - (adx+ctl+FCF) - FCS */
  190. #define MAXFRLEN 130        /* max frame length = 3.45s x 300 bps / 8 */
  191. #define MAXGETTY 512        /* maximum length of ``getty'' (-g) command */
  192. #define MAXIOPT  100        /* maximum # of modem initialization commands */
  193. #define MAXLKFILE 16        /* maximum number of lock files */
  194. #define MAXMSGBUF 8192        /* maximum size of message buffer */
  195. #define MAXNULLS 2        /* maximum consecutive received nulls saved */
  196. #define MAXTSTAMP 80        /* maximum length of a time stamp */
  197. #define MAXTRAINERR 0        /* maximum errors allowed in training check data */
  198. #define MAXTRAIN 2        /* maximum training retries at lowest speed */
  199. #define MAXRETRY 3        /* maximum retries of unacknowledged commands */
  200. #define MINWRITE  128       /* minimum bytes per write() to modem */
  201. #define NCAP 8              /* number of fields in a capability string */
  202. #define NTXRETRY  3        /* maximum re-sends per page */
  203. #define RCVBUFSIZE 1024        /* read up to this many bytes at a time from fax */
  204. #define SNDBUFSIZE 1024        /* maximum bytes to write at a time to fax */
  205. #define T4RTCLEN  9        /* end of page mark for T.4 coded images */
  206. #define T4RTC    "\000\020\001\000\020\001\000\020\001"
  207.  
  208. enum  cchar {
  209.   NUL, SOH, STX, ETX, EOT, ENQ, ACK, BEL, BS,  HT,  LF,
  210.   VT,  FF,  CR,  SO,  SI,  DLE, XON, DC2, XOFF,DC4, NAK,
  211.   SYN, ETB, CAN, EM,  SUB, ESC, FS,  GS,  RS,  US } ;
  212.  
  213. const char *prompts[] = {        /* modem responses that are prompts */
  214.   "OOK", "-CONNECT FAX", "CCONNECT", "NNO CARRIER", "EERROR",
  215.   "NNO DIALTONE", "BBUSY", "NNO ANSWER", "E+FCERROR", 0 } ;
  216.  
  217. enum promptcodes {            /* codes for modem prompts */
  218.    BUSY = 'B', CONNECT = 'C', OK = 'O', RING = 'R', NO = 'N',
  219.    ERROR = 'E' } ;
  220.  
  221. enum ttymodes                /* serial port modes */
  222.    { COMMAND, DROPDTR, SEND, ORIGINAL } ;
  223.  
  224.                 /* signals to be caught so can hang up phone */
  225. const int catch [] = { /*SIGHUP,*/ SIGINT, /*SIGQUIT, SIGIOT, SIGSEGV, SIGALRM,
  226.                SIGTERM,*/ SIGFPE, 0 } ;
  227.  
  228. typedef int cap [ NCAP ] ;        /* remote/local capabilities */
  229.  
  230.                                         /* capability fields... */
  231. enum  captype {                   VR, BR, WD, LN, DF, EC, BF, ST } ;
  232. const int capmax [ NCAP ] = {   1,  7,  3,  2,  3,  2,  1,  7 } ;
  233.                     /* & maximum values */
  234.  
  235.                     /* characters per second for br */
  236. const int cps [ 8 ] = { 300, 600, 900, 1200, 1500, 1800, 900, 1200 } ;
  237.  
  238.                     /* next br = fallback [ br ] */
  239. const int fallback [ 8 ] = { 0, 0, 1, 2, 7, 4, 3, 6 } ;
  240.  
  241.                     /* minimum scan time in ms  */
  242. const int delay [ 8 ] = { 0 , 5, 10, 10, 20, 20, 40, 40 } ;
  243.  
  244. /* Table to convert between T.30 DIS/DCS/DTC FIF and Class 2-like
  245.    capability codes. Uses br=6, 7 for V.17 at 7200, 9600. */
  246.  
  247. typedef const struct t30tabstruct
  248. { 
  249.   char *name ; 
  250.   u_char byte, shift, mask ; 
  251.   u_char captodis[8], distocap[16], captodcs[8], dcstocap[16] ; 
  252. } t30tabst ;
  253.  
  254. #define X 0xff                /* invalid values */
  255.  
  256. t30tabst t30tab [ NCAP ] = {
  257.   { "vr", 1, 1, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },     
  258.   { "br", 1, 2, 0x0f, 
  259.       { 0, 4, 12, 12, 13, 13 } ,
  260.       { 0, X, X, X, 1, X, X, X, 3, X, X, X, 3, 5, 3, X } ,
  261.       { 0, 4, 12, 8, 5, 1 } ,
  262.       { 0, 5, 5, X, 1, 4, 4, X, 3, 7, X, X, 2, 6, X, X } } ,
  263.   { "wd", 2, 6, 0x03, { 0, 2, 1 } , { 0, 2, 1, 2 } ,
  264.       { 0, 2, 1 } , { 0, 2, 1, 2 } },
  265.   { "ln", 2, 4, 0x03, { 0, 2, 1 } , { 0, 2, 1, X } ,
  266.       { 0, 2, 1 } , { 0, 2, 1, X } },
  267.   { "df", 1, 0, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },
  268.   { "ec", 3, 4, 0x03, { 0, 2, 2 } , { 0, X, 2, X } , 
  269.       { 0, 3, 2 } , { 0, 0, 2, 1 } }, 
  270.   { "bf", 5, 5, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },
  271.   { "st", 2, 1, 0x07, 
  272.       { 7, 4, 3, 2, 6, 0, 5, 1 } , { 5, 7, 3, 2, 1, 6, 4, 0 } ,
  273.       { 7, 4, X, 2, X, 0, X, 1 } , { 5, 7, 3, 1, X, X, X, 0 } } 
  274. } ;
  275.  
  276.                     /* values of capability fields */
  277. const char *capvaluestr [ NCAP ] [8] = {
  278.   { " 98lpi", "196lpi" } , 
  279.   { " 2400bps", " 4800bps", " 7200bps", " 9600bps", "  12kbps", "14.4kbps",
  280.     "7200bpsV.17", "9600bpsV.17" } ,
  281.   { "8.5\"/215mm", " 10\"/255mm", " 12\"/303mm" } ,
  282.   { "11\"/A4", "14\"/B4", " any  " } ,
  283.   { "1D" , "2D" }, { "   -   ", "ECM-256", "ECM-64 " }, { " - ", "BFT" },
  284.   { "0ms", "5ms", "10/5ms", "10ms", "20/10ms", "20ms", "40/20ms", "40ms" }
  285. } ;
  286.  
  287. /* T.30 control frames */
  288.  
  289. enum frametype {        
  290.  DIS=0x01, CSI,    NSF=0x04,
  291.  CFR=0x21, FTT,
  292.  MCF=0x31, RTN, RTP, PIN, PIP,
  293.  DCS=0x41, TSI,    NSS=0x44,
  294.  CRP=0x58, DCN=0x5f,
  295.  EOM=0x71, MPS, EOP=0x074, PRI_EOM=0x79, PRI_MPS, PRI_EOP=0x7c,
  296.  DTC=0x80, CIG, NSC=0x84
  297.  } ;
  298.  
  299. /* Class 1 commands to [receive=0/transmit=1] [data=0/training=1] for
  300.    [baud rate=BR]. */
  301.  
  302. const char *c1cmd [ 2 ]  [ 2 ] [ 8 ] = { 
  303. { { "+FRM=24", "+FRM=48", "+FRM=72", "+FRM=96", "+FRM=122", "+FRM=146" ,
  304.     "+FRM=74", "+FRM=98" } ,
  305.   { "+FRM=24", "+FRM=48", "+FRM=72", "+FRM=96", "+FRM=121", "+FRM=145" ,
  306.     "+FRM=73", "+FRM=97" } } ,
  307. { { "+FTM=24", "+FTM=48", "+FTM=72", "+FTM=96", "+FTM=122", "+FTM=146" ,
  308.     "+FTM=74", "+FTM=98", } ,
  309.   { "+FTM=24", "+FTM=48", "+FTM=72", "+FTM=96", "+FTM=121", "+FTM=145" ,
  310.     "+FTM=73", "+FTM=97" } }
  311. } ;
  312.  
  313.  
  314. /* World's fastest T.4 decoder.  Implements a tree search.  Each bit of
  315.    each byte is tested using the T4TST(byte,bitmask) macro. This macro
  316.    invokes the macro T4CODE(len) when it detects a valid T.4 code or on the
  317.    first EOL after an invalid code.  The macro's parameter len will be the
  318.    run length, -1 on a normal EOL or -2 for the EOL following an error.  1D
  319.    coding only.
  320.  
  321.    As per T.4, run lengths >63 (make-up codes) should be added to the
  322.    subsequent (terminating) code.  The first run of a line is white and
  323.    colors alternate.
  324.  
  325.    Each node of the tree contains pointers to the next node for a '0' or a
  326.    '1' bit.  NULL pointers indicate terminal nodes in which case, the run
  327.    length (or -1 or -2) is given by the zlen or olen member and the search
  328.    continues with the node given by the znext or onext pointer.
  329.  
  330.    The decoding tree, stored in packed format (LSB to MSB plus guard bit),
  331.    is built by calling mktree() which returns a pointer to the initial
  332.    value of 't4p' to be used by the T4TST macro.
  333.  
  334. */
  335.  
  336. typedef struct dtree { 
  337.   struct dtree *zero, *one, *onext, *znext ; 
  338.   short int zlen, olen ;
  339. } dtree ;
  340.  
  341. #define T4TST(c,m) t4p = ( c & m ) ? \
  342. ( t4p->one  ? t4p->one  : ( T4CODE ( t4p->olen ), t4p->onext ) ) : \
  343. ( t4p->zero ? t4p->zero : ( T4CODE ( t4p->zlen ), t4p->znext ) ) ;
  344.  
  345. #define T4CTST(c) T4TST(c,0x80) ;  T4TST(c,0x40) ; \
  346.                   T4TST(c,0x20) ;  T4TST(c,0x10) ; \
  347.                   T4TST(c,0x08) ;  T4TST(c,0x04) ; \
  348.                   T4TST(c,0x02) ;  T4TST(c,0x01) ;
  349.  
  350. #define T4NODES 228
  351.  
  352. const short int pkdt4tree [] = {
  353.  
  354. 7,1,29,53,243,263,9,1,11,1,13,1,15,1,17,1,19,1,21,1,23,1,25,1,  
  355. 27,1,27,2,-2,31,49,43,33,75,35,37,4,10,121,39,41,173,4,63,4,0,  
  356. 79,45,95,47,93,4,1,71,51,167,4,2,55,61,57,59,4,3,67,69,4,4,63,65,  
  357. 4,5,83,4,6,4,7,2,128,4,8,4,9,87,73,109,4,11,89,77,99,4,12,117,  
  358. 103,81,107,4,13,85,2,64,4,14,4,15,4,16,4,17,119,91,203,4,18,4,19,127,  
  359. 97,131,4,20,129,137,101,143,4,21,123,105,145,4,22,4,23,147,111,155,  
  360. 113,115,4,24,149,151,4,25,153,4,26,4,27,163,4,28,165,209,125,  
  361. 4,29,4,30,4,31,4,32,4,33,4,34,133,135,4,35,4,36,4,37,4,38,139,141,  
  362. 4,39,4,40,4,41,4,42,4,43,4,44,4,45,4,46,4,47,4,48,4,49,4,50,4,51,4,52,  
  363. 4,53,4,54,157,2,192,159,161,4,55,4,56,4,57,4,58,4,59,4,60,4,61,4,62,  
  364. 175,169,181,171,197,2,256,2,320,2,384,2,1664,177,179,185,2,448,2,512,  
  365. 183,191,2,576,189,187,2,640,2,704,2,768,2,832,2,896,193,195,2,960,2,1024,  
  366. 2,1088,2,1152,199,201,2,1216,2,1280,2,1344,2,1408,205,207,2,1472,2,1536,  
  367. 2,1600,2,1728,235,211,213,217,215,223,2,1792,221,219,229,2,1856,2,1920,  
  368. 2,1984,2,2048,225,227,2,2112,2,2176,2,2240,2,2304,231,233,2,2368,2,2432,  
  369. 2,2496,2,2560,237,1,239,1,241,1,241,2,-1,245,261,247,265,249,267,  
  370. 273,251,271,253,255,2,12,281,257,303,259,307,2,0,2,1,2,4,2,3,2,2,  
  371. 2,6,2,5,269,2,7,2,9,2,8,2,10,2,11,291,275,277,279,2,13,283,287,2,14,  
  372. 2,15,299,313,285,383,2,16,289,309,2,17,357,423,293,295,321,297,317,  
  373. 2,18,363,327,301,331,2,19,305,341,2,20,339,2,21,349,333,311,347,2,22,  
  374. 315,351,2,23,361,379,319,389,2,24,323,371,325,367,2,25,397,395,329,  
  375. 2,26,2,27,2,28,2,29,335,337,2,30,2,31,2,32,2,33,2,34,2,35,343,345,  
  376. 2,36,2,37,2,38,2,39,2,40,2,41,2,42,2,43,353,355,2,44,2,45,2,46,2,47,  
  377. 359,393,2,48,2,49,2,50,2,51,365,377,2,52,403,399,369,401,2,53,  
  378. 373,4,64,375,409,2,54,407,405,2,55,381,387,2,56,415,385,391,2,57,2,58,  
  379. 417,2,59,2,60,419,2,61,4,256,2,62,2,63,4,128,4,192,421,4,320,  
  380. 4,384,4,448,4,512,4,576,4,640,4,704,4,768,4,832,4,896,4,960,411,413,  
  381. 4,1024,4,1088,4,1152,4,1216,4,1280,4,1344,4,1408,4,1472,4,1536,4,1600,  
  382. 4,1664,4,1728,449,425,427,431,429,437,4,1792,435,433,443,4,1856,4,1920,  
  383. 4,1984,4,2048,439,441,4,2112,4,2176,4,2240,4,2304,445,447,4,2368,4,2432,  
  384. 4,2496,4,2560,451,1,453,1,455,1,455,2,-1,
  385. -1 } ;
  386.  
  387.  
  388. /* Program options. Not changed except in main(). */
  389.  
  390. cap local = { DEFCAP } ;      /* -c  local capabilities */
  391. char *argv0 = "?" ;          /*     program name (argv[0]) */
  392. char *fnamepat= FNAMFT ;      /* -r  pattern for received file names */
  393. char **fnames = 0 ;          /* -t  files to send */
  394. char *getty = "startbbs %d" ;          /* -g  command for data calls */
  395. char *iopt[ MAXIOPT ] ;          /* -i  modem init commands */
  396. char *zopt[ MAXIOPT ] ;          /* -z  modem reset commands */
  397. char *lkfiles [ MAXLKFILE+1 ] ;      /* -x  lock files  */
  398. char localid  [ IDLEN + 1 ] ;      /* -l  local ID (telephone #) */
  399. char *verb = "ewin" ;          /* -v  verbosity level */
  400. int c1 = 0 ;              /* -o1 use class 1 protocol */
  401. int softadans = 0 ;          /* -oa use software adaptive answer */
  402. int igniniterr=0 ;          /* -oe ignore initialization errors */
  403. int niopt=0 ;              /*     number of init commands */
  404. int nzopt=0 ;              /*     number of reset commands */
  405. int cmdpause = T_CMD ;          /* -oz delay before each init command */
  406. int maxpgerr = 10 ;          /* -q  maximum errors per page */
  407. int nfiles=0 ;              /*     number of files to send */
  408. int share = 0 ;              /* -s  share fax device */
  409. int waitforcall = 0 ;          /* -w  wait for incoming call */
  410. u_char startchar = DC2 ;      /* -ox character to start reception */
  411.  
  412.  
  413.  
  414. /* Bit ordering: serial devices transmit LS bit first.  T.4/T.30 says MS
  415.    bit is sent first. `Normal' order therefore reverses bit order. */
  416.  
  417. u_char                           /* bit reversal lookup tables*/
  418.    reversebits [ 256 ] , normalbits [ 256 ] , 
  419.    *rxbitorder = normalbits , *txbitorder = normalbits ;
  420.  
  421. dtree *t4tree ;                /* T.4 decoding tree */
  422.  
  423. /* fax stream variables (private). */
  424.  
  425. u_char faxobuf [ SNDBUFSIZE ] ,        /* fax output stream. */
  426.   *faxop=faxobuf , *faxoq=faxobuf+SNDBUFSIZE ;
  427.  
  428. int faxdev=-1 ;                /* fax device file descriptor. */
  429.  
  430. /* session state variables. */
  431.  
  432. FILE *file=0 ;                /* current image file  */
  433. cap remote ;                            /* remote capabilities  */ 
  434. cap session ;                        /* session capabilities */
  435. char remoteid [ IDLEN + 10 ] ;        /* ID (tel no) of remote station */
  436. int crate = 19200 ;                /* CONNECT rate */
  437. int datamode=0 ;            /* true if answered in data mode */
  438. int decimate = 0 ;            /* drop 1/2 lines to get 98 lpi */
  439. int good=1 ;                /* page received OK */
  440. int hsc=-1 ;                /* hangup status code (Class 2) */
  441. int minlen = 0 ;            /* pad lines to this many bytes */
  442.  
  443.  
  444. /* Functions... */
  445.  
  446. /* Print time stamp. */
  447.  
  448. void tstamp( void )
  449. {
  450.   static time_t last = 0 , now ;
  451.   char *fmt = 0, tbuf [ MAXTSTAMP ] ;
  452.  
  453.   now = time ( 0 ) ;
  454.  
  455.   if ( now - last >   0 ) fmt = " (%M:%S)" ;
  456.   if ( now - last > 600 ) fmt = " %c" ;
  457.  
  458.   if ( fmt ) {
  459.     strftime ( tbuf , MAXTSTAMP , fmt , localtime( &now ) ) ;
  460.     mainError(tbuf);
  461.     last = now ; 
  462.   }
  463. }
  464.  
  465.  
  466. /* For systems without strerror(3) */
  467.  
  468. char *strerror( int i )       
  469. {
  470.   extern int sys_nerr;
  471.   extern char *sys_errlist[];
  472.   return ( i >= 0 && i < sys_nerr ) ? sys_errlist[i] : "Unknown Error" ;
  473. }
  474.  
  475.  
  476. /* Return string corresponding to character c. */
  477.  
  478. char *cname ( u_char c ) 
  479. {
  480. #define CNAMEFMT "<0x%02x>"
  481. #define CNAMELEN 6+1
  482.   static char *cname [ 256 ] = {        /* character names */
  483.   "<NUL>","<SOH>","<STX>","<ETX>", "<EOT>","<ENQ>","<ACK>","<BEL>",
  484.   "<BS>", "<HT>", "<LF>", "<VT>",  "<FF>", "<CR>", "<SO>", "<SI>", 
  485.   "<DLE>","<XON>","<DC2>","<XOFF>","<DC4>","<NAK>","<SYN>","<ETB>",
  486.   "<CAN>","<EM>", "<SUB>","<ESC>", "<FS>", "<GS>", "<RS>", "<US>" } ;
  487.   static char names[ (127-32)*2 + 129*(CNAMELEN) ], *p=names ;
  488.   static int i=0 ;
  489.     
  490.   if ( ! i ) 
  491.     for ( i=32 ; i<256 ; i++ ) {
  492.       cname [ i ] = p ;
  493.       sprintf ( p, i<127 ? "%c" : CNAMEFMT , i ) ;
  494.       p += strlen ( p ) + 1 ;
  495.     }
  496.  
  497.   return cname [ c ] ;
  498. } 
  499.  
  500. /* Return name of frame of type 'fr'. */
  501.  
  502. const char *frname ( int fr )
  503. {
  504. static struct framenamestruct {  int code ;  const char *name ; } 
  505. framenames [] = {
  506.  {DIS,"DIS"},{CSI,"CSI"},{NSF,"NSF"},{CFR,"CFR"},{FTT,"FTT"},{MCF,"MCF"},
  507.  {RTN,"RTN"},{RTP,"RTP"},{PIN,"PIN"},{PIP,"PIP"},{DCS,"DCS"},{TSI,"TSI"},
  508.  {NSS,"NSS"},{CRP,"CRP"},{DCN,"DCN"},{EOM,"EOM"},{MPS,"MPS"},{EOP,"EOP"},
  509.  {PRI_EOM,"PRI-EOM"},{PRI_MPS,"PRI-MPS"},{PRI_EOP,"PRI-EOP"},
  510.  {DTC,"DTC"},{CIG,"CIG"},{NSC,"NSC"}, {0,0} }, *p ;
  511.  
  512.   for ( p=framenames ; p->code && p->code != fr ; p++ ) ;
  513.   return p->code ? p->name : "UNKNOWN" ;
  514. }
  515.  
  516.  
  517. /* Print a message with a variable number of printf()-type arguments if the
  518.    first character appears in the verb[ose] string.  Other leading
  519.    characters and digits do additional actions: + allows the message to be
  520.    continued on the same line, '-' buffers the message instead of printing
  521.    it, E, and W expand into strings, S prints the error message for the
  522.    most recent system error, 0-4 set the return value, a space is skipped
  523.    and ends prefix.  Returns 0 if no prefix digit. */
  524.  
  525. int msg ( const char *fmt, ... ) 
  526. {
  527.   char debug[128];
  528.   int err=0, dolf=1, flush=1 ;
  529.   char *ps="", *pe="", *pw="" ;
  530.   const char *p ;
  531.   static int atcol1=1 ;
  532.   va_list ap ;
  533.   va_start ( ap, fmt ) ;
  534.  
  535.   for ( p=fmt ; *p ; p++ ) {
  536.     switch ( *p ) {
  537.     case ' ': p++ ; goto print ;
  538.     case 'A': break ;                   /* program args */
  539.     case 'C': break ;                   /* commands/responses */
  540.     case 'M': break ;                   /* modem dialogue */
  541.     case 'N': break ;                   /* negotiation */
  542.     case 'E': pw = "Error: " ; break ;
  543.     case 'H': break ;                   /* HDLC frame data */
  544.     case 'I': break ;                   /* information */
  545.     case '+': dolf = 0 ; break ;
  546.     case '-': flush = 0 ; break ;
  547.     case 'R': break ;                   /* reception errors */
  548.     case 'S': ps = strerror ( errno ) ; break ;
  549.     case 'W': pw = "Warning: " ; break ;
  550.     case '0': case '1': case '2': case '3': case '4': case '5': 
  551.       err = *p - '0' ; break ;
  552.     default: goto print ;
  553.     }
  554.   }
  555.  
  556.   print:  
  557.   if ( strchr ( verb , tolower ( *fmt ) ) ) {
  558.     if ( atcol1 ) {
  559.       sprintf ( debug , "%s: %s%s" , argv0 , pe , pw ) ;
  560.       mainError(debug);
  561.     }
  562.     vsprintf( debug, p , ap ) ;
  563.     mainError(debug);
  564.     mainError(ps);
  565.     if ( ( atcol1 = dolf ) ) {
  566.       tstamp ( ) ; 
  567.     }
  568.   }
  569.  
  570.   va_end ( ap ) ;
  571.   return err ;
  572. }
  573.  
  574.  
  575. /* Unpack the decoding tree. If the LS bit is 1, the entry is a
  576.    pointer to the next node in a code word, else it is a terminal
  577.    node and the value is a pointer to where to continue scanning
  578.    for the next code word and the following value is the run
  579.    length (or -1 or -2). */
  580.  
  581. dtree *unpktree ( void )
  582. {
  583.   static dtree nodes [ T4NODES ], *p ;
  584.   const short int *l ;
  585.   for ( p=nodes, l=pkdt4tree ; *l > 0 ; p++ ) {
  586.     if ( p - nodes >= T4NODES ) {
  587.       /* fprintf ( stderr, "error in T.4 decoding tree\n" ) ; */ break ;
  588.     }
  589.     if ( *l & 1 ) { p->zero = nodes + *l++/2 ; }
  590.     else { p->znext = nodes + *l++/2 ; p->zlen = *l++ ; } ;
  591.     if ( *l & 1 ) { p->one  = nodes + *l++/2 ; } 
  592.     else { p->onext = nodes + *l++/2 ; p->olen = *l++ ; } ;
  593.   }
  594.   return nodes + 1 ;        /* search starts at node 1 (white runs) */
  595. }
  596.  
  597.  
  598. /* millisecond delays (for systems without usleep). */
  599.  
  600. void msleep ( int t )
  601. {
  602.   waitForTimeout(t / 1000, (t % 1000) * 1000, &globalCallBack);
  603. }
  604.  
  605. /* faxgetc returns the next character
  606.    from the fax device or EOF after idle time t. */
  607.  
  608. /* t is in tenths of a second */
  609. /* returns EOF on timeout */
  610. int faxgetc(int t) {
  611.   enum ReturnStatus status;
  612.   char c;
  613.  
  614.   if (t < 0) {
  615.     t = 6000; /* 60 seconds */
  616.     while ((status = readChar(&c, t, &globalCallBack)) == TimedOut);
  617.     return c;
  618.   } else {
  619.     status = readChar(&c, t, &globalCallBack);
  620.     if (status == TimedOut) return(EOF);
  621.     return c;
  622.   }
  623. }
  624.  
  625. /* A function like faxgetc that also removes DLE escapes, detects DLE-ETX
  626.    terminators and fixes bit order. Does not ignore invalid escape
  627.    sequences. Returns the character read, EOF on error/timeout, or -2 on
  628.    DLE-ETX.  */
  629.  
  630. int faxgetdatac ( int t )
  631. {
  632.   int c ;
  633.   return ( c = faxgetc(t) ) == DLE && ( c = faxgetc(t) ) == ETX ? -2 : 
  634.     normalbits [ c & 0xff ] ;
  635. }
  636.  
  637.  
  638. /* Get a modem response into buffer s, storing up to n bytes.  The response
  639.    begins with most recent non-control character and ends with CR/LF.
  640.    Returns s or null if times-out in t deciseconds or on i/o error. Trace
  641.    messages are buffered to reduce possible timing problems. */
  642.  
  643. char *faxgets( char *s , int n , int t )
  644. {
  645.   int c=0, sta=0 ;
  646.   char *p = s ;
  647.  
  648.   while ( sta < 4 ) {
  649.     if ( ( c = faxgetc( t ) ) == EOF ) break ;
  650.     c &= 0x7f ;
  651.     if ( ! sta ) msg ( "M-+ [" ) ; 
  652.     msg ( "M-+ %s" , cname ( c ) ) ;
  653.     switch ( sta ) {
  654.     case 0 :
  655.     case 1 : sta =               ( iscntrl ( c ) ? 1 : (p=s, 2) ) ; break ;
  656.     case 2 : sta = c == CR ? 3 : ( iscntrl ( c ) ? 1 :       2  ) ; break ;
  657.     case 3 : sta = c == LF ? 4 : ( iscntrl ( c ) ? 1 : (p=s, 2) ) ; break ;
  658.     default: msg ( "Ecan't happen (faxgets)" ) ;
  659.     }
  660.     if ( sta == 2 && p < s+n-1 ) *p++ = c ;
  661.   }
  662.  
  663.   *p = 0 ;
  664.   if ( p >= s+n-1 ) msg ( "W- modem response overflow" ) ;
  665.   if ( sta ) msg ( "M- %s]" , c == EOF ? "<timeout>" : "" ) ;
  666.  
  667.   return c == EOF ? 0 : s ;
  668. }
  669.  
  670.  
  671. /* Write the fax output buffer to fax output device. To allow zero-fill
  672.    underflow padding, should be called after writing the EOL zero
  673.    byte. Warns if called with full buffer (presumably called from
  674.    faxputc()). Returns 0 or EOF on error. */
  675.  
  676. int faxflush ( void )
  677. { 
  678.   int n=0 ;
  679.   u_char *p = faxobuf ;
  680.  
  681.   if ( faxop >= faxoq ) msg ("Wfax output buffer overflow") ;
  682.  
  683.   n = writeToSerial(p, faxop - p);
  684.  
  685.   return n >= 0 ? (faxop = faxobuf , 0) : (msg ("ESfax device write:") , EOF) ;
  686. } 
  687.  
  688. /* faxputc() is a macro like putc().  It returns the character written or
  689.    EOF on error. */
  690.  
  691. #define faxputc(c) ( faxop >= faxoq && faxflush() == EOF ? EOF : \
  692.             (u_char) ( *faxop++ = (c) ) )
  693.  
  694. /* faxobytes() returns number of bytes in fax output buffer */
  695.  
  696. #define faxobytes() ( faxop - faxobuf ) 
  697.  
  698.  
  699. /* A function like faxputc but also escapes DLEs and sets proper bit
  700.    order. */
  701.  
  702. int faxputdatac ( u_char c )
  703. {
  704.   int x ;
  705.   x  = normalbits [ c ] ;
  706.   if ( x == DLE ) x = faxputc ( x ) ;
  707.   return x < 0 ? x : faxputc ( x ) ;
  708. }
  709.  
  710.  
  711. /* Send character or string to modem immediately (for commands).  Returns
  712.    like putc() and puts(). */
  713.  
  714. int faxputcnow ( char c ) 
  715. { 
  716.   return faxputc ( c ) < 0 ? EOF : ( faxflush() ? EOF : c ) ; 
  717. }
  718.  
  719. int faxputs ( const char *s )
  720. {
  721.   int n=0 ;
  722.   while ( s && *s && ( n = faxputcnow ( *s++ ) ) != EOF ) ;
  723.   return n ;
  724. }
  725.  
  726. /* Convert capability string to cap[ability]. Returns 0 or 2 on errors. */
  727.  
  728. int str2cap ( char *s, cap c )
  729. {
  730.   int err=0, i=0, n ;
  731.   char *p ;
  732.  
  733.   for ( n=0, p=s ; ! err && *p && i<NCAP ; p++ )
  734.     if ( isdigit ( *p ) ) c [ n++ ] = *p - '0' ;
  735.     else if ( isspace ( *p ) || *p == ',' ) ;
  736.     else err = msg ("E2invalid character (%c) in (%s)", *p , s ) ;
  737.  
  738.   if ( n < NCAP ) msg ( "W0missing value(s) in capability \"%s\"", s ) ;
  739.  
  740.   for ( i=0 ; i<n ; i++ ) 
  741.     if ( c [ i ] > capmax [ i ] || c [ i ] < 0 ) 
  742.       err = msg ( "E2%s = %d is %s", s , t30tab[i].name , c [ i ], 
  743.         c[i]<0 ? "negative" : "too big" ) ;
  744.   
  745.   return err ;
  746. }
  747.  
  748. /* Print cap[ability] 'c' using text values and prefix 's'. */
  749.  
  750. void printcap ( char *s , cap c )
  751. {
  752.   int i ;
  753.   msg ( "N-+ %s" , s ) ;
  754.   for ( i=0 ; i<NCAP ; i++ ) 
  755.     msg ( "N-+  %s" , c[i] > capmax [ i ] || c[i] < 0 ?  "ERROR" :
  756.      capvaluestr [ i ] [ c[i] ] ) ;
  757.   msg ( "N-" , s ) ;
  758. }
  759.  
  760.  
  761. /* Convert a cap[ability] 'c' to a DIS/DCS/DTC FIF 'fif' of 'len' bytes.
  762.    Converts into DIS format if 'isdis' is true, else into DCS/DTC
  763.    format. Returns 0 or 3 on internal error (bad conversion tables). */
  764.  
  765. int mkdis ( cap c , u_char *fif , int len , int isdis ) 
  766. {
  767.   int err=0, i, j, k ;
  768.   t30tabst *p ;
  769.  
  770.   if ( len < 3 || len > 5 ) 
  771.     len = msg ( "W3bad DCS/DIS length (%d) set to 3" , len ) ;
  772.  
  773.   fif[0] = 0 ;
  774.   fif[1] = isdis ? 0xc0 : 0x40 ;
  775.   for ( i=2 ; i<len-1 ; i++ ) fif[i] = 0x01 ;       /* add extension bits */
  776.   fif[i] = 0 ;
  777.  
  778.   for ( i=0 ; p=t30tab+i, i<NCAP ; i++ ) {
  779.  
  780.     j = c [ i ] ;
  781.     if ( j > capmax [ i ] || j < 0 ) {
  782.       j = 0 ;
  783.       err = msg ( "E3mkdis: bad %s = %d set to 0", p->name, j ) ;
  784.     }
  785.     k = ( isdis ? p->captodis : p->captodcs ) [ j ] ;
  786.     if ( k == X ) {
  787.       k = 0 ;
  788.       err = msg ( "E3mkdis: can't happen (invalid %s)", p->name ) ;
  789.     }
  790.     if ( p->byte < len ) fif [ p->byte ] |=  k << p->shift ;
  791.   }
  792.   return err ;
  793. }
  794.  
  795. /* Return length of DIS/DTC FIF (counts extension bits). */
  796.  
  797. int dislen ( u_char *fif )
  798. {
  799.   int n ;
  800.   for ( n=3 ; fif [ n-1 ] & 0x01 ; n++ ) ;
  801.   return n ;
  802. }
  803.  
  804. /* Convert received DIS/DCS/DTC FIF to cap. Returns 0 or 3 on error (bad
  805.    DIS/DCS field). */
  806.  
  807. int mkcap ( u_char *fif, cap c , int dis ) 
  808. {
  809.   int err=0, i, j, k, len ;
  810.   t30tabst *p ;
  811.  
  812.   len = dislen ( fif ) ;
  813.  
  814.   for ( i=0 ; i<NCAP ; i++ ) {
  815.     p=t30tab+i ;
  816.     if ( p->byte >= len ) {
  817.       c [ i ] = 0 ;
  818.     } else {
  819.       j = fif [ p->byte ] >> p->shift & p->mask ;
  820.       k = ( dis ? p->distocap : p->dcstocap ) [ j ] ;
  821.       if ( k == X ) {
  822.     c [ i ] = 0 ;
  823.     err = msg("E3mkcap: bad %s field (%d) set to 0", p->name, j) ;
  824.       } else { 
  825.     c [ i ] = k ;
  826.       }
  827.     }
  828.   }
  829.   return err ;
  830. }
  831.  
  832.  
  833. /* Compute compatible local/remote capabilities. As side effect, sets
  834.    minimum line length and decimation. This routine is used by the sending
  835.    station only (or both in Class 2). Returns 0 if OK or 3 if no compatible
  836.    settings possible. */
  837.  
  838. int mincap ( cap local, cap remote, cap session )
  839. {
  840.   int err=0, i ;
  841.   int msttab[2][8] = { { 0,1,3,3,5,5,7,7 } , { 0,1,1,3,3,5,5,7 } } ;
  842.  
  843.   for ( i=0 ; i<NCAP && i!=ST ; i++ )
  844.     session[i] = remote[i] < local[i] ? remote[i] : local[i] ;
  845.  
  846.   session[ST] = msttab [ session[VR] ] [ remote[ST] ] ;
  847.  
  848.   minlen = (cps[session[BR]] * delay[session[ST]] + 500) / 1000 ;
  849.  
  850.   decimate = local[VR] == 1 && session[VR] == 0 ;
  851.  
  852.   printcap ( "local  ", local ) ;
  853.   printcap ( "remote ", remote ) ;
  854.   printcap ( "session", session ) ;
  855.   msg ( "N- padding to %d bytes/line.%s", minlen, 
  856.        decimate ? " reducing 198->96 lpi." : "" ) ;
  857.  
  858.   if ( local[WD] != session[WD] || local[LN] != session[LN] || 
  859.       local[DF] != session[DF] ) 
  860.     err = msg ("E3can't convert image to remote capabilities" ) ;
  861.  
  862.   return err ;
  863. }
  864.  
  865.  
  866. /* Search for a match to the string s in a null-terminated array of
  867.    possible prefix strings pointed to by p.  The first character of each
  868.    prefix string is skipped.  Returns pointer to the table entry or NULL if
  869.    not found.  */
  870.  
  871. char *strtabmatch ( char **p, char *s )
  872. {
  873.   while ( *p && strncmp ( *p+1 , s , strlen ( *p+1 ) ) ) p++ ;
  874.   return ( ! *p || **p == '-' ) ? NULL : *p ;
  875. }
  876.  
  877.  
  878. /* Send command to modem and check responses.  Collects pending
  879.    (unexpected) responses and then pauses for inter-command delay
  880.    (cmdpause) if t is negative.  Writes command s to modem if s is not
  881.    null.  Reads responses and terminates when a response is one of the
  882.    prompts in responses[] or if times out in t deciseconds.  Notes and
  883.    processes important class 2 responses (FPTS: Page Transfer Status, FHNG:
  884.    HaNGup status, and FDCS: Current Session capabilities).  Repeats command
  885.    if detects a RING response (probable collision). Returns the first
  886.    character of the matching prefix string (e.g. 'O' for OK, 'C' for
  887.    CONNECT, etc.)  or EOF if no such response was received within timeout
  888.    t. */
  889.  
  890. int cmd ( const char *s , int t )
  891. {
  892.   char buf [ CMDBUFSIZE ] , *p = "" ;
  893.   int ppr ;
  894.  
  895.  retry:
  896.  
  897.   while ( s && faxgets ( buf , CMDBUFSIZE , t<0 ? cmdpause : 0 ) )
  898.     msg ( "W- unexpected response \"%s\"", buf ) ;
  899.  
  900.   msg ( s ? "C- command  \"%s\"" : "C- waiting" , s ) ;
  901.  
  902.   if ( s ) { faxputs ( "AT" ) ; faxputs ( s ) ; faxputcnow ( CR ) ; }
  903.  
  904.   while ( t && ( p = faxgets( buf , CMDBUFSIZE , t<0 ? -t : t ) ) ) {
  905.  
  906.     msg ( "C- response \"%s\"" , p ) ;
  907.  
  908.     if ( ! strncmp ( buf, "DATA" , 4 ) ||
  909.     ! strncmp ( buf, "CONNECT DATA" , 12 ) )
  910.       datamode = 1 ;
  911.     if ( ! strncmp ( buf, "+FDCS:", 6 ) && ! str2cap ( buf+6 , session ) ) 
  912.       mincap ( local, session, session ) ; /* set decimation & minlen */
  913.  
  914.     if (strncmp(buf, "+FCSI:", 6) == 0 || strncmp(buf, "+FTSI:", 6) == 0) {
  915.       strcpy(remoteid, buf + 6);
  916.     }
  917.  
  918.     if ( sscanf ( buf , "+FPTS: %d", &ppr ) > 0 ) good = ppr & 1 ;
  919.     sscanf ( buf, "+FHNG: %d", &hsc ) ;
  920.     sscanf ( buf, "CONNECT %d", &crate ) ;
  921.  
  922.     if ( ( p = strtabmatch ( (char**) prompts , buf ) ) ) break ;
  923.  
  924.     if ( ! strncmp ( buf, "RING", 4 ) ) { msleep(100) ; goto retry ; }
  925.   }
  926.  
  927.   return p ? *p : EOF ;
  928. }
  929.  
  930. /* Send command to modem and wait for either of two possible replies after
  931.    testing (and possibly setting) current error status via err pointer. */
  932.  
  933. void ckcmd ( int *err, const char *s, int t, int r1, int r2 )
  934. {
  935.   int c ;
  936.   if ( ! *err )
  937.     if ( ( c = cmd ( s, t ) ) != r1 && c != r2 ) 
  938.       if ( c == EOF ) 
  939.     *err = msg ("E3modem command (%s) timed out", s ? s : "none" ) ;
  940.       else
  941.     *err = msg ("E3wrong response to command (%s)", s ? s : "none" ) ;
  942. }
  943.  
  944. /* Resynchronize modem from an unknown state.  If no immediate response,
  945.    try pulsing DTR low (needs &D{2,3,4}), and cancelling data or fax data
  946.    modes.  In each case, discard any responses for about 2 seconds and then
  947.    try command s.  Returns 0 if OK or 4 if no response.  */
  948.  
  949. int faxsync( char *s )
  950. {
  951.   int err=0, method=0 ;
  952.  
  953.   while ( ! err ) {
  954.     switch ( method++ ) {
  955.     case 0 : 
  956.       break ;
  957.     case 1 : 
  958.       msg ("Isync: dropping DTR -- Unsupported on Amiga") ;
  959.       break ;
  960.     case 2 : 
  961.       msg ("Isync: sending escape") ;
  962.       faxputs ( DLE_ETX ) ; 
  963.       msleep ( 1500 ) ;
  964.       faxputs ( "+++" ) ; 
  965.       break ;
  966.     case 3 :
  967.       err = msg ("E4sync: modem not responding") ;
  968.       continue ;
  969.     }
  970.     flushBuffers();
  971.     if ( cmd ( s , -TO_RESET ) == OK ) break ;
  972.   }
  973.   return err ;
  974. } 
  975.  
  976.  
  977. /* Terminate session.  Makes sure modem is responding, sends modem reset
  978.    commands, resets fax device to original state, removes lock files. */
  979.  
  980. int end_session ( void )
  981. {
  982.   int i, err ;
  983.   err = faxsync ( "Q0V1" ) ;
  984.  
  985.   for ( i=0 ; ! err && i<nzopt ; i++ )
  986.     if ( cmd( zopt[i] , -TO_RESET ) != OK  && ! igniniterr )
  987.       err = msg ("E3modem reset command (%s) failed", zopt[i]) ;
  988.  
  989.   return err ;
  990. } 
  991.     
  992.  
  993. /* signal handler: hang up and exit */
  994.  
  995. void onsig ( int sig ) 
  996. { 
  997.   msg ( "Eterminating on signal %d", sig ) ; 
  998.   end_session ( ) ;
  999.   msg ("Idone, returning 5") ;
  1000.   exit(5) ; 
  1001. } 
  1002.  
  1003. int getResolution(char* fname) {
  1004.   FILE* fp = fopen(fname, "rb");
  1005.   if (fp) {
  1006.     faxin_open_fp(fp, 0, 0);
  1007.     faxin_begin_page(fp);
  1008.     fclose(fp);
  1009.     return faxin.faxhdr.info.hires;
  1010.   }
  1011.   return 0;
  1012. }
  1013.  
  1014.  
  1015. /* Initialize session.  Try locking and opening fax device until opened or
  1016.    get error. Then set tty modes, register signal handler, setup modem. */
  1017.  
  1018. int begin_session ( char *faxfile )
  1019. {
  1020.   char txcmd[50];
  1021.   int i , err=0;
  1022.  
  1023.   if ( ! err ) msg ( "Iopened %s on fd %d", faxfile, faxdev ) ;
  1024.  
  1025.   for ( i=0 ; ! err && catch [ i ] ; i++ ) 
  1026.     if ( signal ( catch [ i ] , onsig ) == SIG_ERR ) 
  1027.       err = msg ( "ES2can't set signal %d handler:", catch [ i ] ) ;
  1028.   
  1029.   if ( !err ) err = faxsync("Q0V1") ;
  1030.  
  1031.   for ( i=0 ; ! err && i<niopt ; i++ )
  1032.     if ( cmd( iopt[i] , -TO_RESET ) != OK && ! igniniterr )
  1033.       err = msg ("E3modem initialization command (%s) failed", iopt[i]) ;
  1034.  
  1035.   if (nfiles) {
  1036.     /* we are transmitting */
  1037.     local[VR] = getResolution(fnames[0]);
  1038.   }
  1039.  
  1040.   if (!c1) {
  1041.     sprintf(txcmd, "+FDCC=%d,%d,%d,%d,%d,%d,%d,%d", local[VR], local[BR], local[WD], local[LN], local[DF], local[EC], local[BF], local[ST]);
  1042.  
  1043.     if (cmd(txcmd, -TO_RESET) != OK && ! igniniterr)
  1044.       err = msg("E3fax capability setup (%s) failed", txcmd);
  1045.   }
  1046.  
  1047.   return err ;
  1048. }
  1049.  
  1050.  
  1051. /* Position `file' to start of page p (1...nfiles).  Assumes global
  1052.    variables 'fnames' and 'nfiles,' have been initialized.  This function
  1053.    looks ahead to see if there are more pages and if they are of a
  1054.    different format.  Eventually will handle multi-page files with embedded
  1055.    format information (e.g. TIFF-F).  Sets ppm to MPS if more pages to be
  1056.    sent with same format, EOM if more pages with different format, EOP if
  1057.    no more pages. Returns 0 if OK, 2 on errors.  Currently sets ppm to MPS
  1058.    or EOP only.  */
  1059.  
  1060. int rdpage ( int p , int *ppm )
  1061. {
  1062.   int err=0 ;
  1063.  
  1064.   if ( file && fclose ( file ) ) msg ("ES2file close:") ; 
  1065.  
  1066.   if ( p <= nfiles && p > 0 ) {
  1067.     if ( ( file = fopen ( fnames[p-1] , "rb" ) ) ) {
  1068.       msg ( "Iopened \"%s\" (p %d/%d)", fnames[p-1] , p, nfiles ) ;
  1069.       *ppm = p >= nfiles ? EOP : MPS ;
  1070.       faxin_open_fp(file, 0, 0);
  1071.       faxin_begin_page(file);
  1072.     } else {
  1073.       err = msg ("ES2 file open\n%s:", fnames[p-1]) ;
  1074.     }
  1075.   } else {
  1076.     err = msg ("E2 bad page number (%d)", p ) ;
  1077.   }
  1078.  
  1079.   return err ;
  1080. }
  1081.  
  1082. /* Same as rdpage() but creates new file name and opens `file' for
  1083.    writing. If page is -1 removes the most recently opened file. Assumes
  1084.    'fnampat' contains the strftime(3) pattern to be used for generating
  1085.    file names. Returns 0 if OK, 2 on errors. */
  1086.  
  1087. int wrpage ( int p )
  1088. {
  1089.   int err=0 ;
  1090.   static char fname [ FILENAME_MAX + 1 ] , base [ FILENAME_MAX + 1 ] ;
  1091.   time_t t ;
  1092.  
  1093.   t = time(0)  ;
  1094.   if ( ! *base ) strftime( base, FILENAME_MAX, fnamepat, localtime ( &t ) ) ;
  1095.  
  1096. //  if ( file && fclose ( file ) ) msg ("ES2file close:") ; 
  1097.   if ( file ) {
  1098.     faxout_end_page(FaxHandle);
  1099.     faxout_close(FaxHandle);
  1100.     msg("ES2file close:");
  1101.   }
  1102.  
  1103.   if ( p == -1 ) {
  1104.     if ( remove ( fname ) )
  1105.       err = msg ( "ES2deleting file %s", fname ) ; 
  1106.     else
  1107.       msg ( "Iremoved %s", fname ) ; 
  1108.   } else {
  1109.     if ( *fname ) msg ( "Ireceived -> %s", fname ) ;
  1110.     sprintf ( fname, "%.*s.%03d", FILENAME_MAX - 5, base, p ) ;
  1111.     FaxHandle = faxout_open(fname, 0);
  1112.     if (FaxHandle) {
  1113.       file = FaxHandle->fp;
  1114.       err = 0;
  1115.     } else err = msg ("ES2opening file\n%s:", fname) ;
  1116.  
  1117.     if ( ! err ) msg ( "Iopened file %s", fname ) ;
  1118.   }
  1119.   return err ;
  1120. }
  1121.  
  1122.  
  1123. /* Send data for one page. Enable serial port flow control.  Read
  1124.    characters from file and pad lines if necessary.  Bit-reverse characters
  1125.    and escape DLE before storing in buffer.  Flush buffer if enough
  1126.    characters stored.  Append RTC if needed.  Send DLE-ETX and return
  1127.    serial port to command mode when done. Returns 0 if OK, non-0 on
  1128.    errors. */
  1129.  
  1130. int send_data( void )
  1131. {
  1132.   int done=0, err=0;
  1133.   int lastc=0, c ;
  1134.   int eol=0, len=0, llen=0, eolcnt=0, rtc=0, skip=0 ;
  1135.   int bytes=0, pad=0, linec=0, lines=0 ;
  1136.   int i, noise=0 ;
  1137.   time_t start, dt ;
  1138.   dtree *t4p = t4tree ;
  1139.  
  1140.   done = err = 0; 
  1141.   start = time(0) ;
  1142.  
  1143.   while ( ! done ) {
  1144.  
  1145.     if ( ( c = getc ( file ) ) != EOF ) {
  1146.  
  1147. #define T4CODE(l) ( l < 0 ? (eol=l,llen=len,len=0) : (len+=l) ) 
  1148.       T4CTST(c) ;
  1149. #undef T4CODE
  1150.  
  1151.       if ( eol ) {
  1152.     if ( ! llen ) {
  1153.       if ( ++eolcnt >= 6 ) done = rtc = 1 ; 
  1154.     } else {
  1155.       eolcnt=0 ;
  1156.     }
  1157.     if ( eol == -2 ) 
  1158.       msg ("W- image error (line %d)", lines ) ;
  1159.     if ( ! skip ) {
  1160.       lines++ ; 
  1161.       while ( ( linec < minlen || lastc ) ) { 
  1162.         faxputc ( lastc = 0 ) ; 
  1163.         linec++ ; 
  1164.         pad++ ; 
  1165.       }
  1166.       linec = 0 ;
  1167.     }
  1168.     if ( decimate ) {
  1169.       if ( skip ) {
  1170.         skip = 0 ;
  1171.       } else {
  1172.         faxputc ( lastc = 0 ) ; /* force enough zeroes for next EOL */
  1173.         pad++ ; 
  1174.         skip = 1 ;
  1175.       }
  1176.     }
  1177.     if ( faxobytes() > MINWRITE ) { 
  1178.       if ( faxflush() ) done=err=2 ;  
  1179.     }
  1180.     eol=0 ;
  1181.       }
  1182.       if ( ! skip || ! llen ) {
  1183.     faxputc ( lastc = txbitorder [ c ] ) ; 
  1184.     linec ++ ;
  1185.     bytes++ ;
  1186.     if ( lastc == DLE ) { faxputc ( lastc = DLE ) ; linec++ ; pad++ ; }
  1187.       }    
  1188.     } else {
  1189.       done = 1 ;
  1190.       if ( ferror ( file ) ) err = msg ("ES2file read:") ;
  1191.     }
  1192.   }
  1193.  
  1194.   if ( ! err && ! rtc ) {
  1195.     for ( i=0 ; i<T4RTCLEN ; i++ ) faxputdatac ( (T4RTC)[i] ) ;
  1196.     msg ( "I- added RTC (%d bytes)" , T4RTCLEN ) ;
  1197.     pad += T4RTCLEN ;
  1198.   } 
  1199.  
  1200.   for ( ; ( c = faxgetc ( 0 ) ) != EOF ; noise++ ) 
  1201.     msg ( "W-+%s" , cname ( c ) ) ; 
  1202.   if ( noise ) msg ("W- : %d byte(s) received while sending", noise ) ;
  1203.     
  1204.   faxputs ( DLE_ETX ) ;        /* and faxflush() */
  1205.  
  1206.   ckcmd ( &err, 0, TO_DRAIN, OK, 0 ) ;
  1207.  
  1208.   dt = time(0) - start ;
  1209.   msg ("Isent %d lines  %d+%d bytes  %d s  %d bps" , 
  1210.        lines, bytes, pad, (int) dt, ((bytes+pad)*8)/dt ) ;
  1211.  
  1212.   return err ;
  1213. }
  1214.  
  1215.  
  1216. /* Receive data. Get characters from the modem and check for
  1217.    errors/EOF.  Remove long runs of zeroes (T.4 FILL). If in DLE
  1218.    escape check for DLE, end of data or protocol violation.
  1219.    Otherwise, test for DLE & write the character out.  Check that
  1220.    the output file is still OK.  If not, send one CANcel
  1221.    character and wait for protocol to complete.  */
  1222.  
  1223. int receive_data ( void )
  1224. {
  1225.   int done=0, err=0, nulls=0, c ;
  1226.   int bytes=0, lines=0, nerr=0 ;
  1227.   int eol=0, eolcnt=0, len=0, llen=0, lastlen=0, rtc=0 ;
  1228.   dtree *t4p = t4tree ;
  1229.  
  1230.   faxout_begin_page(FaxHandle, session[VR] /* VR */, 1 /* dirty */);
  1231.  
  1232.   while ( ! done ) {
  1233.  
  1234.     if ( ( c = faxgetc( TO_CHAR ) ) == DLE ) {
  1235.       if ( ( c = faxgetc( TO_CHAR ) ) == ETX ) done = 1 ;
  1236.       else if ( c != DLE ) {
  1237.     msg ( "W- \"%s\" received after DLE", cname ( c ) ) ;
  1238.     continue ;
  1239.       }
  1240.     }    
  1241.     if ( c == EOF ) {
  1242.       done = err = msg ("E3fax device read timeout") ;
  1243.       continue ;
  1244.     } 
  1245.     if ( c == 0 ) {
  1246.       if ( ++nulls > MAXNULLS ) {
  1247.     continue ;
  1248.       }
  1249.     } else {
  1250.       nulls = 0 ;
  1251.     }
  1252.     if ( ! done && ! rtc ) {
  1253.       c = rxbitorder[c];
  1254.       putc ( c, file ) ;
  1255.       bytes++ ;
  1256.     }
  1257. #define T4CODE(l) ( l<0 ? (eol=l, llen=len, len=0) : (len+=l) ) 
  1258.       T4CTST(c) ;
  1259. #undef T4CODE
  1260.     if ( eol ) {
  1261.       lines++ ;
  1262.       if ( ( ( llen != lastlen ) && llen && lastlen && lines > 3 ) ) {
  1263.     nerr++ ;
  1264.     msg ("R-+ (%d:%d)", lines, llen ) ;
  1265.       }
  1266.       lastlen = llen ;
  1267.       if ( ! llen ) {
  1268.     if ( ++eolcnt >= 6 ) rtc = 1 ; 
  1269.       } else {
  1270.     eolcnt=0 ;
  1271.       }
  1272.       eol=0 ; 
  1273.     }
  1274.  
  1275.     if ( ! err && ferror ( file ) ) {
  1276.       err = msg ("ES2fax file write:") ;
  1277.       faxputcnow ( CAN ) ;
  1278.       msg ("Wreceive CANcelled") ;
  1279.     } 
  1280.  
  1281.   } /* while */
  1282.   
  1283.   if ( nerr ) msg ("R-  : reception errors" ) ;
  1284.   nerr /= 2 ;
  1285.   if ( nerr ) msg ("W- %d reception errors", nerr ) ;
  1286.  
  1287.   ckcmd ( &err, 0, TO_C2EOR, ( c1 ? NO : OK ) , 0 ) ;
  1288.   
  1289.   if ( ! err && ! rtc ) {
  1290.     fwrite ( T4RTC , sizeof ( u_char ) , T4RTCLEN , file ) ;
  1291.     msg ( "I- added RTC (%d bytes)" , T4RTCLEN ) ;
  1292.   }
  1293.  
  1294.   msg ( "I- received %d lines, %d bytes, %d errors", lines, bytes, nerr ) ;
  1295.  
  1296.   good = nerr < maxpgerr ;
  1297.   return err ;
  1298. }
  1299.  
  1300.  
  1301. /* Send training check sequence of n zeroes.  Returns 0 or 2 on error. */
  1302.  
  1303. int puttrain ( const char *s , int n )
  1304. {
  1305.   int i, err=0 ;
  1306.  
  1307.   ckcmd ( &err, s , TO_FT , CONNECT, 0 ) ;
  1308.  
  1309.   if ( ! err ) {
  1310.  
  1311.     for ( i=0 ; ! err && i < n ; i++ ) {
  1312.       faxputc ( 0 ) ;
  1313.       if ( ! ( i & 63 ) ) faxflush ( ) ;
  1314.     }
  1315.     faxputc ( 1 ) ;  /* disable zero-fill padding */
  1316.     faxputs ( DLE_ETX ) ;
  1317.  
  1318.     msg ( "I- sent TCF (%d bytes)", n ) ;
  1319.  
  1320.     ckcmd ( &err, 0, TO_DRAIN, OK, 0 ) ;
  1321.   }
  1322.  
  1323.   return err ;
  1324. }
  1325.  
  1326. /* Checks n bytes of received training check sequence. Skips first n/16
  1327.    bytes.  Returns 0 if OK or ignoring training errors, 1 if too many
  1328.    errors/not enough data, or 3 on other errors. */
  1329.  
  1330. int gettrain ( const char *s , int n ) 
  1331. { 
  1332.   int err=0, c, i, errcnt=0, skip=n/16 ;
  1333.  
  1334.   ckcmd ( &err, s , TO_FT , CONNECT, 0 ) ;
  1335.   
  1336.   for ( i=0 ; ! err && ( c = faxgetdatac ( TO_CHAR ) ) >= 0 ; i++ )
  1337.     if ( c != 0 && i >= skip && i < n+skip ) errcnt++ ;
  1338.   
  1339.   ckcmd ( &err, 0, TO_RTCMD, NO, 0 ) ;
  1340.   
  1341.   if ( !err )
  1342.     msg ( "I- received TCF (%s: %d error(s) in %d/%d bytes)", 
  1343.      ( err = i<n || errcnt>MAXTRAINERR ) ? "failed" : "passed" , 
  1344.      errcnt, n, i ) ;
  1345.  
  1346.   return err ;
  1347. }
  1348.  
  1349. /* Log sent/received HDLC frame.  Display of these messages is delayed to
  1350.    avoid possible timing problems. */
  1351.  
  1352. void logfr ( const char *s , const char *nm , u_char *p , int n )
  1353. {
  1354.   int i=0 ;
  1355.   msg ( "I- %s %s", s, nm ) ;
  1356.   msg ( n > 10 ? "H- %s %d bytes:" : "H-+ %s %d bytes:" , s, n ) ;
  1357.   for ( i=0 ; i<n ; i++ ) {
  1358.     msg ( "H-+  %02x" , p[i] & 0xff ) ;
  1359.     if ( ( i&0xf ) == 0xf && i != n-1 ) msg ( "H-" ) ;
  1360.   }
  1361.   msg ( "H-") ;
  1362. }
  1363.  
  1364. /* Send HDLC control frame of type type.  Extra bits are OR'ed to the frame
  1365.    type (FCF) if this frame follows a previous one (no +FTH required) or if
  1366.    more frames will follow.  Sets up flag, address, and fax control field
  1367.    (FCF) bytes in `buf'.  Sends these plus `len` additional bytes.
  1368.    Terminates with DLE-ETX and checks response.  Returns 0 if OK, 2 or 3 on
  1369.    error. */
  1370.  
  1371. #define MORE_FR  0x100 
  1372. #define SUB_FR 0x200 
  1373.  
  1374. int putframe ( int type, u_char *buf , int len )
  1375. {
  1376.   int err=0, i ;
  1377.  
  1378.   buf [ 0 ] = 0xff ;
  1379.   buf [ 1 ] = type & MORE_FR ? 0xc0 : 0xc8 ;
  1380.   buf [ 2 ] = type & 0xff ;
  1381.  
  1382.   if ( ! ( type & SUB_FR ) )
  1383.     ckcmd ( &err, "+FTH=3" , TO_FT, CONNECT, 0 ) ;
  1384.  
  1385.   if ( ! err ) {
  1386.     for ( i=0 ; ! err && i< len+3 ; i++ )  faxputdatac ( buf [ i ] ) ;
  1387.     faxputs ( DLE_ETX ) ;
  1388.  
  1389.     ckcmd ( &err, 0, TO_DRAIN, type & MORE_FR ? CONNECT : OK , 0 ) ;
  1390.     if ( ! err ) 
  1391.       logfr ( "sent", frname(type & 0x7f), buf, len+3 ) ;
  1392.   }
  1393.  
  1394.   return err ;
  1395. }
  1396.  
  1397.  
  1398. /* Read HDLC frame and store it in buffer buf of size n.  Skips
  1399.    issuing +FRH command on pass==0.  Returns length of frame if
  1400.    OK, EOF on timeout, -3 if any errors as per T.30 5.4.2 (too
  1401.    long, FCS error) */
  1402.  
  1403. int getframe ( int pass , u_char *buf , int n , int t )
  1404. {
  1405.   int err=0, c, i=0 ;
  1406.  
  1407.   if ( pass && ( c = cmd ( "+FRH=3" , t ) ) != CONNECT ) 
  1408.     err = ( c == EOF ) ? -EOF : msg ( "E3get frame command failed") ;
  1409.   
  1410.   if ( err == -EOF ) { faxputc ( CAN ) ; cmd ( "" , TO_ABRT ) ; }
  1411.  
  1412.   if ( ! err ) {
  1413.     for ( i=0 ; ( c = faxgetdatac ( pass ? TO_CHAR : t ) ) >= 0  ; i++ )
  1414.       if ( i < n ) buf[ i ] = c ;
  1415.     if ( c == EOF ) 
  1416.       err = i ? msg ( "E3timed out reading frame data") : EOF ;
  1417.     if ( i >= n ) err = msg ( "E3frame too long (%d bytes)", i ) ;
  1418.   } 
  1419.  
  1420.  
  1421.   ckcmd ( &err, 0, TO_RTCMD, OK, CONNECT ) ;
  1422.  
  1423.   return err ? -err : ( i < n ? i : n ) ;
  1424. }
  1425.  
  1426. /* Reverse bit and byte order of ID strings as per T.30 5.3.6.2.4-6 */
  1427.  
  1428. void revcpy ( u_char *from , u_char *to )
  1429. {
  1430.   int i, j ;
  1431.   for ( i=0, j=IDLEN-1 ; i<IDLEN ; i++, j-- ) 
  1432.     to [ i ] = normalbits [ from [ j ] & 0xff ] ;
  1433. }
  1434.  
  1435. /* Handle procedure interrupt requests (just print message for now).
  1436.    Returns 0. */
  1437.  
  1438. int pr_int( void )
  1439. {
  1440.   return msg ("W0procedure interrupt request ignored" ) ;
  1441. }
  1442.  
  1443.  
  1444. /* Class 1 send.  Each received frame elicits an appropriate reply.
  1445.    Optional or unrecognized frames are ignored.  Terminates by sending DCN
  1446.    after receiving MCF after EOP or on error.  Timeouts, bad frames or CRP
  1447.    repeat last command up to MAXRETRY times.  On training check failures
  1448.    the speed (remote capability br) is reduced. The lowest speed is retried
  1449.    MAXTRAIN times.  Page transmission failures are retried NTXRETRY
  1450.    times. */
  1451.  
  1452.  
  1453. enum replies
  1454. { NONE=0x100, DCS1, DCS2, TXDATA, PPM, DONE, BADFR, TIMEOUT, SENDDIS } ;
  1455.  
  1456. int c1send ( int started ) 
  1457. { 
  1458.   int err=0, done=0, pass=started, page=1, frame=NONE, reply=DONE ;
  1459.   int frlen, rxdislen=0, disbit=0 ;
  1460.   int cmdtry=0, pagetry=0, traintry=0 ;
  1461.   int ppm=EOP ;
  1462.   u_char buf [ MAXFRLEN ] , *fif=buf+3 ;
  1463.  
  1464.   for ( pass=started ; ! done ; pass++ ) {
  1465.  
  1466.     if ( err ) {
  1467.       frame = NONE ;
  1468.     } else {
  1469.       frlen = getframe ( pass, buf, MAXFRLEN, started ? T3S : T1 ) ;
  1470.       if ( frlen < 3 ) {
  1471.     frame = CRP ;
  1472.       } else {
  1473.     frame = buf [ 2 ] & 0x7f ;
  1474.     logfr ( "received" , frname(frame), buf , frlen ) ;
  1475.     cmdtry = 0 ;
  1476.       }
  1477.     }
  1478.  
  1479.     switch ( frame ) {
  1480.       
  1481.     case CRP:
  1482.       if ( !started || cmdtry++ >= MAXRETRY ) 
  1483.     err = msg ( "E3 no response from remote" ) ;
  1484.       break ;
  1485.  
  1486.     case NSF:
  1487.       reply = NONE ;
  1488.       break ;
  1489.  
  1490.     case CSI:
  1491.       revcpy ( fif , (u_char*) remoteid ) ;
  1492.       msg ( "I- remote ID=\"%*.*s\"" , IDLEN, IDLEN, remoteid ) ;
  1493.       reply = NONE ;
  1494.       break ;
  1495.  
  1496.     case DIS:
  1497.       started = 1 ;
  1498.       disbit = 0x80 ;
  1499.       rxdislen = dislen ( fif ) ;
  1500.       mkcap ( fif , remote , 1 ) ;
  1501.       reply = DCS1 ;
  1502.       break ;
  1503.  
  1504.     case CFR:
  1505.       reply = TXDATA ;
  1506.       break ;
  1507.  
  1508.     case FTT:
  1509.       if ( (remote[BR] = fallback[session[BR]]) > 0 || traintry++ < MAXTRAIN ) 
  1510.     reply = DCS2 ; 
  1511.       else
  1512.     err = msg ( "E1failed to train") ; 
  1513.       break ;
  1514.  
  1515.     case PIP: 
  1516.       pr_int ( ) ; 
  1517.     case RTP:
  1518.     case MCF:
  1519.       page++ ;
  1520.       pagetry=0 ;
  1521.       if ( ppm == MPS && frame == MCF ) reply = TXDATA ;
  1522.       else if ( ppm == EOP ) done = 1 ;
  1523.       else reply = DCS2 ; 
  1524.       break ;
  1525.  
  1526.     case PIN: 
  1527.       pr_int ( ) ;
  1528.     case RTN:
  1529.       if ( pagetry++ < NTXRETRY ) reply = DCS2 ;
  1530.       else err = msg( "E1too many page send retries" ) ;
  1531.       break ;
  1532.  
  1533.     case DCN:
  1534.       err = msg ( "E3remote disconnected") ;
  1535.       break ;
  1536.  
  1537.     case NONE:
  1538.       break ;
  1539.  
  1540.     default:
  1541.       break ;
  1542.  
  1543.     } /* switch ( frame ) */
  1544.  
  1545.     switch ( err || done ? DONE : reply ) {
  1546.  
  1547.     case  DCS1:
  1548.       revcpy ( (u_char*) localid , fif ) ;
  1549.       err = putframe ( TSI + MORE_FR + disbit , buf, IDLEN ) ;      
  1550.                                /* fall through */
  1551.     case DCS2:
  1552.       mincap ( local, remote, session ) ;
  1553.       mkdis ( session , fif , rxdislen , 0 ) ;
  1554.       if ( !err ) err = 
  1555.     putframe ( DCS + (reply==DCS1 ? SUB_FR : 0) + disbit, buf, rxdislen ) ;
  1556.       ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;
  1557.       if ( !err ) err = 
  1558.     puttrain ( c1cmd [1][1][session[BR]] , (int)(1.65 * cps [ session[BR] ]) ) ;
  1559.       reply = DCS2 ;
  1560.       break ;
  1561.  
  1562.     case TXDATA:
  1563.       if ( !err ) err = rdpage ( page, &ppm ) ;
  1564.       ckcmd ( &err,  c1cmd [1][0][session[BR]] , TO_FT, CONNECT, 0 ) ;
  1565.       if ( !err ) err = send_data ( ) ;
  1566.       ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;      
  1567.                                /* fall through */
  1568.     case  PPM:
  1569.       if ( !err ) err =    putframe ( ppm + disbit, buf, 0 ) ;
  1570.       reply = PPM ;
  1571.       break ;
  1572.  
  1573.     case DONE:
  1574.       putframe ( DCN + disbit, buf, 0 ) ; 
  1575.       done = 1 ;
  1576.       break ;
  1577.  
  1578.     case NONE:
  1579.       break ;
  1580.  
  1581.     default:
  1582.       err = msg ( "E3can't happen(reply)" ) ;
  1583.       break ;
  1584.  
  1585.     } /* switch ( reply ) */
  1586.  
  1587.   } /* for ( ! done ) */
  1588.  
  1589.   return err ;
  1590. }
  1591.  
  1592.  
  1593. /* Class 1 receive.  Sends DIS until gets a DCS or times out.  Sends ppr
  1594.   after ppm and receives data after DCS or MPS. Note: TCF (training check
  1595.   data) is received 75 +/- 20 ms after DCS so there should be no lengthy
  1596.   processing between DCS and gettrain(). */
  1597.  
  1598. int c1receive ( int started ) 
  1599. { 
  1600.   int err=0, done=0, page=1, pass, frame, frlen ;
  1601.   u_char buf[MAXFRLEN], *fif=buf+3 ;
  1602.  
  1603.   err = wrpage ( page ) ;
  1604.  
  1605.   for ( pass=started ; ! err && ! done ; pass++ ) {
  1606.  
  1607.     if ( pass > 0 ) {
  1608.       frlen = getframe(pass, buf, MAXFRLEN, started ? T2 : T4 ) ;
  1609.       if ( frlen == EOF ) {
  1610.     frame = started ? TIMEOUT : ( pass < MAXDIS ? SENDDIS : TIMEOUT ) ;
  1611.       } else if ( frlen < 3 ) {
  1612.     frame = started ? NONE : ( pass < MAXDIS ? SENDDIS : NONE ) ;
  1613.       } else {
  1614.     frame = buf [ 2 ] & 0x7f ;
  1615.     logfr ( "received" , frname(frame), buf , frlen ) ;
  1616.       }
  1617.     } else {
  1618.       frame=SENDDIS ;
  1619.     }
  1620.  
  1621.     switch ( frame ) {
  1622.       
  1623.     case SENDDIS:
  1624.       revcpy ( (u_char*) localid, fif ) ;
  1625.       if ( !err ) err = 
  1626.     putframe ( CSI + MORE_FR + ( pass ? 0 : SUB_FR ), buf, IDLEN ) ;
  1627.       mkdis ( local , fif , DEFDISLEN , 1 ) ;
  1628.       if ( !err ) err = 
  1629.     putframe ( DIS + SUB_FR , buf, DEFDISLEN ) ;
  1630.       break ;
  1631.       
  1632.     case TIMEOUT:
  1633.       done = err = msg ( "E3timed out waiting for sender" ) ;
  1634.       break; 
  1635.  
  1636.     case BADFR :
  1637.       msg ( "W bad frame" ) ;
  1638.       break ;
  1639.  
  1640.     case TSI: ;
  1641.       revcpy ( fif , (u_char*) remoteid ) ;
  1642.       msg ( "I- remote ID=\"%*.*s\"" , IDLEN, IDLEN, remoteid ) ;
  1643.       break ;
  1644.       
  1645.     case DCS: ;
  1646.       started = 1 ;
  1647.       mkcap ( fif , session  , 0 ) ;
  1648.       printcap ( "session" , session ) ;
  1649.       if ( gettrain ( c1cmd [0][1][session[BR]], cps[session[BR]] ) == 0 ) {
  1650.     if ( !err ) err = putframe ( CFR, buf, 0 ) ;
  1651.     if ( !err ) goto getdata ;
  1652.       } else {
  1653.     if ( !err ) err = putframe ( FTT, buf, 0 ) ;
  1654.       }
  1655.       break ;
  1656.  
  1657.     case PRI_EOM:
  1658.     case PRI_MPS:
  1659.     case PRI_EOP:
  1660.       pr_int() ;
  1661.  
  1662.     case EOM:
  1663.     case MPS:
  1664.     case EOP:
  1665.       err = wrpage ( ++page ) ;    
  1666.       if ( ! err )
  1667.     if ( good ) err = putframe ( MCF, buf, 0 ) ;
  1668.     else        err = putframe ( RTN, buf, 0 ) ;
  1669.       if ( ! err && good && ( frame == MPS || frame == PRI_MPS ) ) 
  1670.     goto getdata ; 
  1671.       if ( ! err && good && (frame == EOM || frame == PRI_EOM ) ) {
  1672.     pass=started=0 ;
  1673.     ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;
  1674.       }
  1675.       break ;
  1676.  
  1677.     getdata:
  1678.       ckcmd ( &err, c1cmd [0][0][session[BR]] , TO_FT, CONNECT, 0 ) ;
  1679.       if ( !err ) err = receive_data (  ) ;
  1680.       break ;
  1681.       
  1682.     case DCN:
  1683.       done = 1 ;
  1684.       break;
  1685.  
  1686.     } /* switch */
  1687.     
  1688.   } /* do */
  1689.  
  1690.   wrpage ( -1 ) ;        /* remove last file */
  1691.   return err ;
  1692. }
  1693.  
  1694. /* Class 2 fax transmission.  Retries each page up to NTXRETRY times.
  1695.    Transmission begins after DC2 or XON is received.  Sends the data and
  1696.    sends appropriate post-page message.  Checks for 'good' status set in
  1697.    cmd() by +FPTS: responses. */
  1698.  
  1699. int c2send ( void )
  1700. {
  1701.   int c, page, err=0, done=0, try, ppm=0, noise=0 ;
  1702.   char txcmd[50];
  1703.  
  1704.   for ( page=1 ; !err && ! done ; page++ ) {
  1705.  
  1706.     for ( try=good=0 ; !err && !good && try<NTXRETRY ; try++ ) {
  1707.  
  1708.       err = rdpage ( page , &ppm ) ;
  1709.  
  1710. /*
  1711.       local[VR] = faxin.faxhdr.info.hires;
  1712.       sprintf(txcmd, "+FDT=%d,%d,%d,%d", session[DF], local[VR], session[WD], session[LN]);
  1713. */
  1714.       sprintf(txcmd, "+FDT");
  1715.       ckcmd ( &err, txcmd , TO_C2B , CONNECT, 0 ) ;
  1716.   
  1717.       if ( ! err ) 
  1718.     while ( !err && ( c = faxgetc ( TO_C2X ) ) != XON && c != DC2 )
  1719.       if ( c == EOF ) {
  1720.         msg ( "Wno XON/DC2 received after CONNECT") ;
  1721.         break;
  1722.       } else {
  1723.         msg ( "W+%s", cname ( c ) ) ;
  1724.         noise++ ;
  1725.       }
  1726.  
  1727.       if ( noise ) {
  1728.     msg ( "Wreceived (%d) characters while waiting to send", noise ) ;
  1729.     noise = 0 ;
  1730.       }
  1731.  
  1732.       if ( ! err ) err = send_data ( ) ;
  1733.  
  1734.       good = 1 ; /* assume good if no +FPTS: */
  1735.       ckcmd ( &err, ppm == EOP ? "+FET=2" : "+FET=0" , TO_C2PP, OK, 0 ) ;
  1736.  
  1737.       if ( hsc > 0 ) err = msg ( "E2abnormal termination (code %d)", hsc ) ;
  1738.     }
  1739.     if ( ppm == EOP ) done = 1 ;
  1740.     if ( try >= NTXRETRY ) {
  1741.       err = msg ( "E2too many page send retries" ) ;
  1742.       cmd ( "+FK", T3S ) ;
  1743.     }
  1744.   } 
  1745.   return err ; 
  1746. }
  1747.  
  1748. /* Class 2 fax reception.  Send fax data receive command.  If
  1749.    response is OK, then no more pages are coming.  If it's
  1750.    CONNECT receive the data for one page.  Returns 0 or >= 2 for
  1751.    errors.  */
  1752.  
  1753. int c2receive ( void )
  1754. {
  1755.   int err=0, page=1, done=0, c ;
  1756.  
  1757.   err = wrpage ( page ) ;
  1758.  
  1759.   while ( ! err && ! done && hsc < 0 ) {
  1760.     if ( ( c = cmd ( "+FDR" , TO_C2R ) ) == CONNECT ) {
  1761.       faxputcnow ( startchar ) ;
  1762.       err = receive_data ( ) ;
  1763.       ckcmd ( &err, good ? "+FPTS=1" : "+FPTS=2", T3S , OK, 0 ) ;
  1764.       if ( ! err ) err = wrpage ( ++page ) ;
  1765.     } else {
  1766.       if ( c == OK ) { wrpage ( -1 ) ; done = 1 ; } 
  1767.       else err = msg ( "E3receive (+FDR) command failed") ;
  1768.     }
  1769.   } 
  1770.   if ( hsc > 0 ) err = msg ( "E2abnormal call termination (code %d)", hsc ) ;
  1771.  
  1772.   return err ;
  1773. }
  1774.  
  1775. /* Dial a number and send a fax. */
  1776.  
  1777. int send ( char *tel , char *faxfile )
  1778. {
  1779.   char c, s [ 128 ] ;
  1780.   int err=0 ;
  1781.  
  1782.   msg ( "Idialing %.127s", tel ) ;
  1783.   if (dialTone)
  1784.     sprintf ( s , "DT%.127s" , tel ) ;
  1785.   else
  1786.     sprintf ( s , "D%.127s" , tel ) ;
  1787.  
  1788.   err = begin_session ( faxfile ) ;
  1789.  
  1790.   if ( ! err ) {
  1791.     if ( ( ( c = cmd ( s , TO_A ) ) == ( c1 ? CONNECT : OK ) ) && hsc < 0 ) 
  1792.       msg ( "Iconnected" ) ; 
  1793.     else if ( c ==  BUSY ) 
  1794.       err = msg ( "W1number is busy" ) ; 
  1795.     else if ( c == EOF ) {
  1796.       err = msg ( "E2aborted manually" ) ;
  1797.     } else 
  1798.       err = msg ( "E2can't establish session" ) ;
  1799.   }
  1800.  
  1801.   if ( ! err ) 
  1802.     err = c1 ? c1send ( 0 ) : c2send ( ) ;
  1803.  
  1804.   if ( err != 1 && err < 4 ) end_session( ) ;
  1805.  
  1806.   return err ;
  1807. }
  1808.  
  1809.  
  1810. /* Receive a fax.  Open modem device and initialize it.  Remove locks if
  1811.    sharing device with outgoing calls.  If waiting for call, wait for modem
  1812.    activity, else answer phone.  Figure out what mode we answered in and
  1813.    handle call appropriately.  Re-lock if necessary. Then exec *getty or
  1814.    run class 1 or class 2 reception routines. Modems prompt as follows
  1815.    after answering: Class 0: CONNECT nnn for data; Class 1: FAX + CONNECT
  1816.    for fax, DATA + CONNECT nnn for data, just CONNECT for fax if +FAE=0;
  1817.    Class 2: CONNECT (data) or OK (fax). ("+FCON" and "CONNECT FAX" are 
  1818.    status messages, not prompts). */
  1819.  
  1820. int receive ( char *faxfile )
  1821. {
  1822.   enum connectmode { NONE, DATAMODE, FAXMODE } ; 
  1823.   enum connectmode mode=NONE ;
  1824.   int c=0, err ;
  1825.  
  1826.   if ( ( err = begin_session ( faxfile ) ) == 0 ) {
  1827.  
  1828.     if ( ! err && waitforcall ) {
  1829.       char ch;
  1830.  
  1831.       msg ( "Iwaiting for activity on %s", faxfile ) ;
  1832.       while (readChar(&ch, 6000, &globalCallBack) == TimedOut);
  1833.       unReadChar();
  1834.       msg ( "Iactivity detected at ") ;
  1835.     }
  1836.   
  1837.     if ( ! err && share ) {
  1838.       msleep ( 200 ) ;        /* let other programs lock port  */
  1839.     }
  1840.  
  1841.     if ( ! err && softadans && *getty ) {
  1842.       if ( cmd ( ( waitforcall ? 0 : "A" ) , TO_DATAF ) == CONNECT ) 
  1843.     mode = DATAMODE ;
  1844.       else {
  1845.     int i ; /* abort data answer mode & set fax mode to try again */
  1846.     for ( i=0 ; i<3 ; i++ ) 
  1847.       if ( cmd ( c1 ? "+FCLASS=1" : "+FCLASS=2" , -TO_RESET ) == OK )
  1848.         break ; 
  1849.       }
  1850.     }
  1851.     if ( ! err && mode == NONE ) {
  1852.       c = cmd ( ! waitforcall || ( softadans && *getty ) ? "A" : 0 , TO_A ) ;
  1853.       if (c == EOF) {
  1854.     err = msg ( "E2aborted manually" ) ;
  1855.       } else {
  1856.     if ( c1 )
  1857.       mode = ( c == CONNECT ) ? ( datamode ? DATAMODE : FAXMODE ) : NONE ;
  1858.     else
  1859.       mode = ( c == CONNECT ) ? DATAMODE : ( c == OK ? FAXMODE : NONE ) ;
  1860.       }
  1861.     }
  1862.   
  1863.     if ( err || hsc >= 0 ) mode = NONE ;
  1864.  
  1865.     if ( ! err )
  1866.       switch ( mode ) {
  1867.       case DATAMODE : {
  1868.         void* lastSent = 0;
  1869.         char buf [ MAXGETTY ] ;
  1870.     msg ( "Idata call answered") ;
  1871.     sprintf ( buf , getty , crate );
  1872.     msg ( "ISending ARexx \"%s\"" , buf ) ;
  1873.     lastSent = SendARexxMsg(OutgoingRexx, buf, FALSE);
  1874.     while (1) {
  1875.       Wait(ARexxSignal(OutgoingRexx));
  1876.       if (lastSent == GetReplyARexxMsg(OutgoingRexx)) break;
  1877.     }
  1878.     
  1879.     return 0;
  1880.     break ; }
  1881.       case FAXMODE :
  1882.     msg ( "Ifax call answered") ;
  1883.     break ;
  1884.       case NONE:
  1885.     err = msg ( "E3unable to answer call") ;
  1886.     break ;
  1887.       }
  1888.  
  1889.     setReceiveSerialParms();
  1890.  
  1891.     if ( ! err ) err = c1 ? c1receive ( 0 ) : c2receive ( ) ;
  1892.  
  1893.     setSendSerialParms();
  1894.  
  1895.     if ( err != 1 && err < 4 ) end_session( ) ;   /* if not locked */
  1896.   }
  1897.   
  1898.   return err  ;
  1899. }
  1900.  
  1901.  
  1902. /* Simple (one option per argument) version of getopt(3). */
  1903.  
  1904. int optind = 1 ;
  1905. char *optarg ;
  1906.  
  1907. int nextopt( int argc, char **argv, char *args )
  1908. {
  1909.   char *a, *p ;
  1910.  
  1911.   if ( optind >= argc || *(a = argv[optind]) != '-' ) return -1 ;
  1912.   optind++ ;
  1913.  
  1914.   if ( ! *(a+1) || ! ( p = strchr ( args , *(a+1) ) ) )
  1915.     return msg ( "Eunknown option (%s)" , a ) , '?' ; 
  1916.  
  1917.   if ( *(p+1) != ':' ) optarg = 0 ;
  1918.   else
  1919.     if ( *(a+2) ) optarg = a+2 ;
  1920.     else
  1921.       if ( optind >= argc ) return msg ( "Eno argument for (%s)", a ) , '?' ;
  1922.       else optarg = argv [ optind++ ] ;
  1923.   return *(a+1) ;
  1924. }
  1925.  
  1926. char modemSetup[6][50];
  1927. char modemReset[5][50];
  1928. char idInit[50];
  1929. char debugVerbosity[15];
  1930. char capInit[CMDBUFSIZE];
  1931.  
  1932. void processConfig(char* var, char* value) {
  1933.   static int foundPortName = 0;
  1934.   static int inPortConfig = 0;
  1935.   int d;
  1936.   
  1937.   if (stricmp(var, "PORT") == 0) {
  1938.     if (stricmp(value, portNameToLoad) == 0 && foundPortName == 0) {
  1939.       foundPortName = 1;
  1940.       inPortConfig = 1;
  1941.     }
  1942.   }
  1943.  
  1944.   if (inPortConfig == 1) {
  1945.     if (stricmp(var, "SERIALNAME") == 0) {
  1946.       strcpy(serialName, value);
  1947.     } else if (stricmp(var, "UNITNUMBER") == 0) {
  1948.       sscanf(value, "%d", &unitNumber);
  1949.     } else if (stricmp(var, "FAXCLASS") == 0) {
  1950.       if (stricmp(value, "CLASS 1") == 0) {
  1951.     strcpy(modemSetup[0], "+FCLASS=1");
  1952.     c1 = 1;
  1953.       } else if (stricmp(value, "CLASS 2") == 0) {
  1954.     strcpy(modemSetup[0], "+FCLASS=2");
  1955.     c1 = 0;
  1956.       }
  1957.       iopt[niopt++] = modemSetup[0];
  1958.     } else if (stricmp(var, "FAXID") == 0) {
  1959.       sprintf ( localid, "%*.*s", IDLEN, IDLEN, value ) ;
  1960.       sprintf ( idInit , "+FLID=\"%.*s\"" , CMDBUFSIZE-9, localid ) ;
  1961.       if ( !c1 ) { iopt[niopt++] = idInit; }
  1962.     } else if (stricmp(var, "REVERSETXBITORDER") == 0) {
  1963.       sscanf(value, "%d", &d);
  1964.       if (d) txbitorder = reversebits;
  1965.     } else if (stricmp(var, "REVERSERXBITORDER") == 0) {
  1966.       sscanf(value, "%d", &d);
  1967.       if (d) {
  1968.     rxbitorder = reversebits;
  1969.     msg("Ireversed rx bit order");
  1970.       }
  1971.     } else if (stricmp(var, "STARTRXWITHXON") == 0) {
  1972.       sscanf(value, "%d", &d);
  1973.       if (d)
  1974.     startchar = XON;
  1975.       else
  1976.     startchar = DC2;
  1977.     } else if (stricmp(var, "FAXHARDWAREHANDSHAKING") == 0) {
  1978.       sscanf(value, "%d", &faxHardwareHandshaking);
  1979.     } else if (stricmp(var, "COMMANDPAUSE") == 0) {
  1980.       sscanf(value, "%d", &d);
  1981.       for ( ; d > 0; d--) cmdpause += T_CMD;
  1982.     } else if (stricmp(var, "MAXPAGEERRORS") == 0) {
  1983.       sscanf(value, "%d", &maxpgerr);
  1984.     } else if (stricmp(var, "DIALTONE") == 0) {
  1985.       sscanf(value, "%d", &dialTone);
  1986.     } else if (stricmp(var, "DEBUGVERBOSITY") == 0) {
  1987.       strcpy(debugVerbosity, value);
  1988.       verb = debugVerbosity;
  1989.     } else if (stricmp(var, "FAXCAPABILITY") == 0) {
  1990.       str2cap(value, local);
  1991. /*
  1992.       sprintf ( capInit , "+FDCC=%.*s" , CMDBUFSIZE-7, value ) ;
  1993.       if ( !c1 ) {
  1994.     iopt[niopt++] = capInit;
  1995.       }
  1996. */
  1997.     } else if (stricmp(var, "FAXSETUP1") == 0) {
  1998.       strcpy(modemSetup[1], value);
  1999.       if (strcmp(modemSetup[1], "") != 0)
  2000.     iopt[niopt++] = modemSetup[1];
  2001.     } else if (stricmp(var, "FAXSETUP2") == 0) {
  2002.       strcpy(modemSetup[2], value);
  2003.       if (strcmp(modemSetup[2], "") != 0)
  2004.     iopt[niopt++] = modemSetup[2];
  2005.     } else if (stricmp(var, "FAXSETUP3") == 0) {
  2006.       strcpy(modemSetup[3], value);
  2007.       if (strcmp(modemSetup[3], "") != 0)
  2008.     iopt[niopt++] = modemSetup[3];
  2009.     } else if (stricmp(var, "FAXSETUP4") == 0) {
  2010.       strcpy(modemSetup[4], value);
  2011.       if (strcmp(modemSetup[4], "") != 0)
  2012.     iopt[niopt++] = modemSetup[4];
  2013.     } else if (stricmp(var, "FAXSETUP5") == 0) {
  2014.       strcpy(modemSetup[5], value);
  2015.       if (strcmp(modemSetup[5], "") != 0)
  2016.     iopt[niopt++] = modemSetup[5];
  2017.     } else if (stricmp(var, "FAXRESET1") == 0) {
  2018.       strcpy(modemReset[0], value);
  2019.       if (strcmp(modemReset[0], "") != 0)
  2020.     zopt[nzopt++] = modemReset[0];
  2021.     } else if (stricmp(var, "FAXRESET2") == 0) {
  2022.       strcpy(modemReset[1], value);
  2023.       if (strcmp(modemReset[1], "") != 0)
  2024.     zopt[nzopt++] = modemReset[1];
  2025.     } else if (stricmp(var, "FAXRESET3") == 0) {
  2026.       strcpy(modemReset[2], value);
  2027.       if (strcmp(modemReset[2], "") != 0)
  2028.     zopt[nzopt++] = modemReset[2];
  2029.     } else if (stricmp(var, "FAXRESET4") == 0) {
  2030.       strcpy(modemReset[3], value);
  2031.       if (strcmp(modemReset[3], "") != 0)
  2032.     zopt[nzopt++] = modemReset[3];
  2033.     } else if (stricmp(var, "FAXRESET5") == 0) {
  2034.       if (strcmp(modemReset[4], "") != 0)
  2035.     strcpy(modemReset[4], value);
  2036.       zopt[nzopt++] = modemReset[4];
  2037.     } else if (stricmp(var, "ENDRECORD") == 0) {
  2038.       inPortConfig = 0;
  2039.     } else if (stricmp(var, "STARTRECORD") == 0) {
  2040.       inPortConfig = 0;
  2041.     } else {
  2042.     }
  2043.   }
  2044. }
  2045.  
  2046.  
  2047.  
  2048. /* Fax send/receive program for Class 1 or 2 fax modems. Initialize
  2049.    character name, bit reversal and T.4 decoding tables and process
  2050.    arguments.  Returns 0 on success, 1 if number busy or device locked, 2
  2051.    for errors, 3 for protocol errors, 4 if no modem response, 5 on fatal
  2052.    signal. */
  2053.  
  2054. int main( int argc, char **argv)
  2055. {
  2056.   int i, err=0 , c, nlocks=0 ;
  2057.   char *faxfile = FAXFILE ;
  2058.   char capinit [ CMDBUFSIZE ] , idinit [ CMDBUFSIZE ] ;
  2059. //  char msgbuf [ MAXMSGBUF ] ;
  2060.   char tmp[200];
  2061.   void* lastSent = 0;
  2062.  
  2063.   argv0 = argv[0] ;
  2064.  
  2065. //  setvbuf ( LOGF , msgbuf , _IOFBF , MAXMSGBUF ) ;
  2066.  
  2067.   msg ( "I " Version "  starts ") ;
  2068.   msg ( "I " Copyright "  (compiled "__DATE__ " " __TIME__ ")" ) ;
  2069.  
  2070.   argv0 = strrchr ( argv0 , '/' )  ;
  2071.   if ( ! argv0 ) argv0 = argv[0] ; else argv0++ ;
  2072.  
  2073.   cname ( 0 ) ;
  2074.   for ( i=0 ; i<256 ; i++ ) normalbits [ reversebits [ i ] = i ] = 
  2075.     ( i& 1 ? 128:0 ) | ( i& 2 ? 64:0 ) | ( i& 4 ? 32:0 ) | ( i&  8 ? 16:0 ) |
  2076.     ( i&16 ?   8:0 ) | ( i&32 ?  4:0 ) | ( i&64 ?  2:0 ) | ( i&128 ?  1:0 ) ;
  2077.   t4tree = unpktree( ) ;
  2078.  
  2079.   while (!err && (c=nextopt(argc,argv,"p:c:d:g:i:l:o:q:r:st:v:wx:z:T") ) != -1) {
  2080.     switch (c) {
  2081.     case 'c': 
  2082.       err = str2cap ( optarg , local ) ;
  2083.       sprintf ( capinit , "+FDCC=%.*s" , CMDBUFSIZE-7, optarg ) ;
  2084.       if ( !err && !c1 ) { optarg = capinit ; goto addopt ; }
  2085.       break ;
  2086.     case 'l': 
  2087.       if ( strlen ( optarg ) > IDLEN ) 
  2088.     msg("Wlocal ID truncated to 20 characters" ) ;
  2089.       sprintf ( localid, "%*.*s", IDLEN, IDLEN, optarg ) ;
  2090.       sprintf ( idinit , "+FLID=\"%.*s\"" , CMDBUFSIZE-9, localid ) ;
  2091.       if ( !c1 ) { optarg = idinit ; goto addopt ; }
  2092.       break ;
  2093.     case 'i': 
  2094.     addopt:
  2095.       if ( niopt < MAXIOPT ) iopt [ niopt++ ] = optarg ;
  2096.       else err = msg ( "E2too many modem init commands"); 
  2097.       break ;
  2098.     case 'z': 
  2099.       if ( nzopt < MAXIOPT ) zopt [ nzopt++ ] = optarg ;
  2100.       else err = msg ( "E2too many modem reset commands"); 
  2101.       break ;
  2102.     case 'd': faxfile = optarg ; break ;
  2103.     case 'g': getty = optarg ; break ;
  2104.     case 'p': strcpy(portNameToLoad, optarg);
  2105.       loadConfig("avm:servers.cfg", processConfig);
  2106.       break;
  2107.     case 'o': 
  2108.       for ( ; *optarg ; optarg++ ) 
  2109.     switch ( *optarg ) {
  2110.     case '1' : c1 = 1 ; break ;
  2111.     case '2' : c1 = 0 ; break ;
  2112.     case 'a' : softadans = 1 ;  break ;
  2113.     case 'e' : igniniterr = igniniterr ? 0 : 1 ;  break ;
  2114.     case 'r' : rxbitorder = reversebits ; break ;
  2115.     case 't' : txbitorder = reversebits ; break ;
  2116.     case 'x' : startchar = XON ; break ;
  2117.     case 'z' : cmdpause += T_CMD ; break ;
  2118.      default : msg ( "Wunrecognized protocol option (%c)", *optarg ) ; 
  2119.     }
  2120.       break ;
  2121.     case 'q':
  2122.       if ( sscanf ( optarg , "%d", &maxpgerr ) != 1 )
  2123.     err=msg ("E2can't read quality (-q) argument (%s)", optarg ) ;
  2124.       break;
  2125.     case 'r': 
  2126.       fnamepat = optarg ;
  2127.  
  2128.       atexit(releaseResources);
  2129.       allocateResources();
  2130.   
  2131.       err = receive ( faxfile ) ; 
  2132.       sprintf(tmp, "call setclip(upper('%s.faxid'), '%s')", portNameToLoad, remoteid);
  2133.       //fprintf(stderr, tmp);
  2134.  
  2135.       lastSent = SendARexxMsg(OutgoingRexx, tmp, TRUE);
  2136.       while (1) {
  2137.     Wait(ARexxSignal(OutgoingRexx));
  2138.     if (lastSent == GetReplyARexxMsg(OutgoingRexx)) break;
  2139.       }
  2140.  
  2141.       break;
  2142.     case 's': share = 1 ; break;
  2143.     case 't': 
  2144.       fnames = argv + optind ;
  2145.       nfiles = argc - optind ;
  2146.  
  2147.       atexit(releaseResources);
  2148.       allocateResources();
  2149.  
  2150.       if (stricmp(optarg, "MAN!") == 0)
  2151.     err = send ( "", faxfile);
  2152.       else
  2153.     err = send ( optarg , faxfile ) ; 
  2154.  
  2155.       sprintf(tmp, "call setclip(upper('%s.faxid'), '%s')", portNameToLoad, remoteid);
  2156.       //fprintf(stderr, tmp);
  2157.  
  2158.       lastSent = SendARexxMsg(OutgoingRexx, tmp, TRUE);
  2159.       while (1) {
  2160.     Wait(ARexxSignal(OutgoingRexx));
  2161.     if (lastSent == GetReplyARexxMsg(OutgoingRexx)) break;
  2162.       }
  2163.       break;
  2164.     case 'v': 
  2165.       verb = optarg ;
  2166.       if ( strchr ( verb , 'a' ) )
  2167.       for ( i=0 ; i<argc ; i++ ) msg ( "Iargv[%d]=%s", i, argv[i]) ; 
  2168.       break ;
  2169.     case 'w': waitforcall = 1 ; break ;
  2170.     case 'x': 
  2171.       if ( nlocks < MAXLKFILE ) lkfiles [ nlocks++ ] = optarg ; 
  2172.       else err = msg ( "E2too many lock files" ) ; 
  2173.       break ;
  2174.     case 'T':
  2175.       if ( ( err = begin_session ( faxfile ) ) == 0) end_session( ) ;
  2176.       break;
  2177.     default : if (stderr) fprintf ( stderr, Usage, argv0 ) ; err = 2 ; break ;
  2178.     }
  2179.   }
  2180.  
  2181.   msg ( "Idone, returning %d", err ) ;
  2182.   exit(err);
  2183. }
  2184.