-
Notifications
You must be signed in to change notification settings - Fork 71
/
Copy pathcomm3705.c
2307 lines (2074 loc) · 77.7 KB
/
comm3705.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
/* COMM3705.C (c) Copyright Roger Bowler, 2008-2012 */
/* (c) Copyright MHP, 2007 (see below) */
/* Hercules 3705 communications controller */
/* running NCP */
/* */
/* Released under "The Q Public License Version 1" */
/* (http://www.hercules-390.org/herclic.html) as modifications to */
/* Hercules. */
/***********************************************************************/
/* */
/* comm3705.c - (C) Copyright 2007 by MHP <ikj1234i at yahoo dot com> */
/* */
/* Loosely based on commadpt.c by Ivan Warren */
/* */
/* This module appears to the "host" as a 3705 communications */
/* controller running NCP. It does not attempt to provide an emulated */
/* execution environment for native 3705 code. */
/* */
/* Experimental release 0.02 Oct. 15, 2007 */
/* */
/* A very minimalistic SNA engine is implemented. All received SNA */
/* requests are responded to with a positive response. Also, there's */
/* enough code to enable a single SNA session to logon in LU1 (TTY) */
/* mode. */
/* */
/* FID1 is the only SNA header type supported. */
/* */
/* A large amount of required SNA functionality is not present in this */
/* release. There are no "state machines", "layers", "services", */
/* chaining*, pacing, brackets, etc.etc.etc. There are */
/* probably more bugs than working functions... Enjoy ;-) */
/* */
/* A better implementation might be to separate the SNA functions out */
/* into an independent process, with communications over a full-duplex */
/* TCP/IP socket... We might also get rid of all the magic constants...*/
/* */
/* New in release 0.02 - */
/* - VTAM switched (dial) support */
/* - New remote NCP capability */
/* - SNA 3270 (LU2) support (*with RU chaining) */
/* - fixes for some bugs in 0.01 */
/* New in release 0.03 - */
/* - don't process TTY lines until CR received */
/* New in release 0.04 - */
/* - make debug messages optional */
/* */
/* 73 DE KA1RBI */
/***********************************************************************/
#include "hstdinc.h"
#include "hercules.h"
#include "devtype.h"
#include "opcode.h"
#include "parser.h"
#include "comm3705.h"
#if defined(WIN32) && defined(OPTION_DYNAMIC_LOAD) && !defined(HDL_USE_LIBTOOL) && !defined(_MSVC_)
SYSBLK *psysblk;
#define sysblk (*psysblk)
#endif
#if !defined(min)
#define min(a,b) (((a) <= (b)) ? (a) : (b))
#endif
static void make_sna_requests2(COMMADPT*);
static void make_sna_requests3(COMMADPT*);
static void make_sna_requests4(COMMADPT*, int, BYTE);
static void make_sna_requests5(COMMADPT*);
static unsigned char R010201[3] = {0x01, 0x02, 0x01};
static unsigned char R010202[3] = {0x01, 0x02, 0x02};
static unsigned char R010203[3] = {0x01, 0x02, 0x03};
static unsigned char R010204[3] = {0x01, 0x02, 0x04};
static unsigned char R010205[3] = {0x01, 0x02, 0x05};
static unsigned char R01020A[3] = {0x01, 0x02, 0x0A};
static unsigned char R01020B[3] = {0x01, 0x02, 0x0B};
static unsigned char R01020F[3] = {0x01, 0x02, 0x0F};
static unsigned char R010211[3] = {0x01, 0x02, 0x11};
static unsigned char R010216[3] = {0x01, 0x02, 0x16};
static unsigned char R010217[3] = {0x01, 0x02, 0x17};
static unsigned char R010219[3] = {0x01, 0x02, 0x19};
static unsigned char R01021A[3] = {0x01, 0x02, 0x1A};
static unsigned char R01021B[3] = {0x01, 0x02, 0x1B};
static unsigned char R010280[3] = {0x01, 0x02, 0x80};
static unsigned char R010281[3] = {0x01, 0x02, 0x81};
static unsigned char R010284[3] = {0x01, 0x02, 0x84};
#define BUFPD 0x1C
static BYTE commadpt_immed_command[256]=
{ 0,0,0,1,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0};
/*---------------------------------------------------------------*/
/* PARSER TABLES */
/*---------------------------------------------------------------*/
static PARSER ptab[]={
{"lport", PARSER_STR_TYPE},
{"lhost", PARSER_STR_TYPE},
{"rport", PARSER_STR_TYPE},
{"rhost", PARSER_STR_TYPE},
{"dial", PARSER_STR_TYPE},
{"rto", PARSER_STR_TYPE},
{"pto", PARSER_STR_TYPE},
{"eto", PARSER_STR_TYPE},
{"switched",PARSER_STR_TYPE},
{"lnctl", PARSER_STR_TYPE},
{"debug", PARSER_STR_TYPE},
{"emu3791", PARSER_STR_TYPE},
{NULL,NULL}
};
enum {
COMMADPT_KW_LPORT=1,
COMMADPT_KW_LHOST,
COMMADPT_KW_RPORT,
COMMADPT_KW_RHOST,
COMMADPT_KW_DIAL,
COMMADPT_KW_READTO,
COMMADPT_KW_POLLTO,
COMMADPT_KW_ENABLETO,
COMMADPT_KW_SWITCHED,
COMMADPT_KW_LNCTL,
COMMADPT_KW_DEBUG,
COMMADPT_KW_EMU3791
} comm3705_kw;
//////////////////////////////////////////////////////////////////////
// some code copied from console.c
static HOST_INFO cons_hostinfo; /* Host info for this system */
/*-------------------------------------------------------------------*/
/* Telnet command definitions */
/*-------------------------------------------------------------------*/
#define BINARY 0 /* Binary Transmission */
#define IS 0 /* Used by terminal-type negotiation */
#define SEND 1 /* Used by terminal-type negotiation */
#define ECHO_OPTION 1 /* Echo option */
#define SUPPRESS_GA 3 /* Suppress go-ahead option */
#define TIMING_MARK 6 /* Timing mark option */
#define TERMINAL_TYPE 24 /* Terminal type option */
#define NAWS 31 /* Negotiate About Window Size */
#define EOR 25 /* End of record option */
#define EOR_MARK 239 /* End of record marker */
#define SE 240 /* End of subnegotiation parameters */
#define NOP 241 /* No operation */
#define DATA_MARK 242 /* The data stream portion of a Synch.
This should always be accompanied
by a TCP Urgent notification */
#define BRK 243 /* Break character */
#define IP 244 /* Interrupt Process */
#define AO 245 /* Abort Output */
#define AYT 246 /* Are You There */
#define EC 247 /* Erase character */
#define EL 248 /* Erase Line */
#define GA 249 /* Go ahead */
#define SB 250 /* Subnegotiation of indicated option */
#define WILL 251 /* Indicates the desire to begin
performing, or confirmation that
you are now performing, the
indicated option */
#define WONT 252 /* Indicates the refusal to perform,
or continue performing, the
indicated option */
#define DO 253 /* Indicates the request that the
other party perform, or
confirmation that you are expecting
the other party to perform, the
indicated option */
#define DONT 254 /* Indicates the demand that the
other party stop performing,
or confirmation that you are no
longer expecting the other party
to perform, the indicated option */
#define IAC 255 /* Interpret as Command */
/*-------------------------------------------------------------------*/
/* 3270 definitions */
/*-------------------------------------------------------------------*/
/* 3270 remote commands */
#define R3270_EAU 0x6F /* Erase All Unprotected */
#define R3270_EW 0xF5 /* Erase/Write */
#define R3270_EWA 0x7E /* Erase/Write Alternate */
#define R3270_RB 0xF2 /* Read Buffer */
#define R3270_RM 0xF6 /* Read Modified */
#define R3270_RMA 0x6E /* Read Modified All */
#define R3270_WRT 0xF1 /* Write */
#define R3270_WSF 0xF3 /* Write Structured Field */
/* 3270 orders */
#define O3270_SBA 0x11 /* Set Buffer Address */
#define O3270_SF 0x1D /* Start Field */
#define O3270_SFE 0x29 /* Start Field Extended */
#define O3270_SA 0x28 /* Set Attribute */
#define O3270_IC 0x13 /* Insert Cursor */
#define O3270_MF 0x2C /* Modify Field */
#define O3270_PT 0x05 /* Program Tab */
#define O3270_RA 0x3C /* Repeat to Address */
#define O3270_EUA 0x12 /* Erase Unprotected to Addr */
#define O3270_GE 0x08 /* Graphic Escape */
/* Inbound structured fields */
#define SF3270_AID 0x88 /* Aid value of inbound SF */
#define SF3270_3270DS 0x80 /* SFID of 3270 datastream SF*/
/*-------------------------------------------------------------------*/
/* Internal macro definitions */
/*-------------------------------------------------------------------*/
/* DEBUG_LVL: 0 = none
1 = status
2 = headers
3 = buffers
*/
#define DEBUG_LVL 0
#if DEBUG_LVL == 0
#define TNSDEBUG1 1 ? ((void)0) : logmsg
#define TNSDEBUG2 1 ? ((void)0) : logmsg
#define TNSDEBUG3 1 ? ((void)0) : logmsg
#endif
#if DEBUG_LVL == 1
#define TNSDEBUG1 logmsg
#define TNSDEBUG2 1 ? ((void)0) : logmsg
#define TNSDEBUG3 1 ? ((void)0) : logmsg
#endif
#if DEBUG_LVL == 2
#define TNSDEBUG1 logmsg
#define TNSDEBUG2 logmsg
#define TNSDEBUG3 1 ? ((void)0) : logmsg
#endif
#if DEBUG_LVL == 3
#define TNSDEBUG1 logmsg
#define TNSDEBUG2 logmsg
#define TNSDEBUG3 logmsg
#endif
#define BUFLEN_3270 65536 /* 3270 Send/Receive buffer */
#define BUFLEN_1052 150 /* 1052 Send/Receive buffer */
#undef FIX_QWS_BUG_FOR_MCS_CONSOLES
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO TRACE THE CONTENTS OF AN ASCII MESSAGE PACKET */
/*-------------------------------------------------------------------*/
#if DEBUG_LVL == 3
static void
packet_trace( BYTE* pAddr, int iLen )
{
int offset;
unsigned int i;
u_char c = '\0';
u_char e = '\0';
u_char print_ascii[17];
u_char print_ebcdic[17];
u_char print_line[64];
u_char tmp[32];
for( offset = 0; offset < iLen; )
{
memset( print_ascii, 0, sizeof( print_ascii ) );
memset( print_ebcdic, 0, sizeof( print_ebcdic ) );
memset( print_line, 0, sizeof( print_line ) );
sprintf(print_line, "+%4.4X ", offset );
for( i = 0; i < 16; i++ )
{
c = *pAddr++;
if( offset < iLen )
{
sprintf( tmp, "%2.2X", c );
strlcat( print_line, tmp, sizeof( print_line ));
print_ebcdic[i] = print_ascii[i] = '.';
e = guest_to_host( c );
if( isprint( e ) )
print_ebcdic[i] = e;
if( isprint( c ) )
print_ascii[i] = c;
}
else
{
strlcat( print_line, " ", sizeof( print_line ));
}
offset++;
if( ( offset & 3 ) == 0 )
{
strlcat( print_line, " ", sizeof( print_line ));
}
}
logmsg( "%s %s %s\n", print_line, print_ascii, print_ebcdic );
}
} /* end function packet_trace */
#else
#define packet_trace( _addr, _len)
#endif
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO DOUBLE UP ANY IAC BYTES IN THE DATA STREAM */
/* Returns the new length after inserting extra IAC bytes */
/*-------------------------------------------------------------------*/
static int
double_up_iac (BYTE *buf, int len)
{
int m, n, x, newlen;
/* Count the number of IAC bytes in the data */
for (x=0, n=0; n < len; n++)
if (buf[n] == IAC) x++;
/* Exit if nothing to do */
if (x == 0) return len;
/* Insert extra IAC bytes backwards from the end of the buffer */
newlen = len + x;
TNSDEBUG3("console: DBG002: %d IAC bytes added, newlen=%d\n",
x, newlen);
for (n=newlen, m=len; n > m; ) {
buf[--n] = buf[--m];
if (buf[n] == IAC) buf[--n] = IAC;
}
packet_trace (buf, newlen);
return newlen;
} /* end function double_up_iac */
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO SEND A DATA PACKET TO THE CLIENT */
/*-------------------------------------------------------------------*/
static int
send_packet (int csock, BYTE *buf, int len, char *caption)
{
int rc; /* Return code */
if (caption != NULL) {
TNSDEBUG2("console: DBG003: Sending %s\n", caption);
packet_trace (buf, len);
}
rc = send (csock, buf, len, 0);
if (rc < 0) {
WRMSG(HHC01034, "E", "send()", strerror(HSO_errno));
return -1;
} /* end if(rc) */
return 0;
} /* end function send_packet */
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO RECEIVE A DATA PACKET FROM THE CLIENT */
/* This subroutine receives bytes from the client. It stops when */
/* the receive buffer is full, or when the last two bytes received */
/* consist of the IAC character followed by a specified delimiter. */
/* If zero bytes are received, this means the client has closed the */
/* connection, and this is treated as an error. */
/* Input: */
/* csock is the socket number */
/* buf points to area to receive data */
/* reqlen is the number of bytes requested */
/* delim is the delimiter character (0=no delimiter) */
/* Output: */
/* buf is updated with data received */
/* The return value is the number of bytes received, or */
/* -1 if an error occurred. */
/*-------------------------------------------------------------------*/
static int
recv_packet (int csock, BYTE *buf, int reqlen, BYTE delim)
{
int rc=0; /* Return code */
int rcvlen=0; /* Length of data received */
while (rcvlen < reqlen) {
rc = recv (csock, buf + rcvlen, reqlen - rcvlen, 0);
if (rc < 0) {
WRMSG(HHC01034, "E", "recv()", strerror(HSO_errno));
return -1;
}
if (rc == 0) {
TNSDEBUG1("console: DBG004: Connection closed by client\n");
return -1;
}
rcvlen += rc;
if (delim != '\0' && rcvlen >= 2
&& buf[rcvlen-2] == IAC && buf[rcvlen-1] == delim)
break;
}
TNSDEBUG2("console: DBG005: Packet received length=%d\n", rcvlen);
packet_trace (buf, rcvlen);
return rcvlen;
} /* end function recv_packet */
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO RECEIVE A PACKET AND COMPARE WITH EXPECTED VALUE */
/*-------------------------------------------------------------------*/
static int
expect (int csock, BYTE *expected, int len, char *caption)
{
int rc; /* Return code */
BYTE buf[512]; /* Receive buffer */
#if defined( OPTION_MVS_TELNET_WORKAROUND )
/* TCP/IP for MVS returns the server sequence rather then the
client sequence during bin negotiation. Jan Jaeger, 19/06/00 */
static BYTE do_bin[] = { IAC, DO, BINARY, IAC, WILL, BINARY };
static BYTE will_bin[] = { IAC, WILL, BINARY, IAC, DO, BINARY };
#endif // defined( OPTION_MVS_TELNET_WORKAROUND )
UNREFERENCED(caption);
rc = recv_packet (csock, buf, len, 0);
if (rc < 0)
return -1;
#if defined( OPTION_MVS_TELNET_WORKAROUND )
/* BYPASS TCP/IP FOR MVS WHICH DOES NOT COMPLY TO RFC1576 */
if (1
&& memcmp(buf, expected, len) != 0
&& !(len == sizeof(will_bin)
&& memcmp(expected, will_bin, len) == 0
&& memcmp(buf, do_bin, len) == 0)
)
#else
if (memcmp(buf, expected, len) != 0)
#endif // defined( OPTION_MVS_TELNET_WORKAROUND )
{
TNSDEBUG2("console: DBG006: Expected %s\n", caption);
return -1;
}
TNSDEBUG2("console: DBG007: Received %s\n", caption);
return 0;
} /* end function expect */
/*-------------------------------------------------------------------*/
/* SUBROUTINE TO NEGOTIATE TELNET PARAMETERS */
/* This subroutine negotiates the terminal type with the client */
/* and uses the terminal type to determine whether the client */
/* is to be supported as a 3270 display console or as a 1052/3215 */
/* printer-keyboard console. */
/* */
/* Valid display terminal types are "IBM-NNNN", "IBM-NNNN-M", and */
/* "IBM-NNNN-M-E", where NNNN is 3270, 3277, 3278, 3279, 3178, 3179, */
/* or 3180, M indicates the screen size (2=25x80, 3=32x80, 4=43x80, */
/* 5=27x132, X=determined by Read Partition Query command), and */
/* -E is an optional suffix indicating that the terminal supports */
/* extended attributes. Displays are negotiated into tn3270 mode. */
/* An optional device number suffix (example: IBM-3270@01F) may */
/* be specified to request allocation to a specific device number. */
/* Valid 3270 printer type is "IBM-3287-1" */
/* */
/* Terminal types whose first four characters are not "IBM-" are */
/* handled as printer-keyboard consoles using telnet line mode. */
/* */
/* Input: */
/* csock Socket number for client connection */
/* Output: */
/* class D=3270 display console, K=printer-keyboard console */
/* P=3270 printer */
/* model 3270 model indicator (2,3,4,5,X) */
/* extatr 3270 extended attributes (Y,N) */
/* devn Requested device number, or FFFF=any device number */
/* Return value: */
/* 0=negotiation successful, -1=negotiation error */
/*-------------------------------------------------------------------*/
static int
negotiate(int csock, BYTE *class, BYTE *model, BYTE *extatr, U16 *devn,char *group)
{
int rc; /* Return code */
char *termtype; /* Pointer to terminal type */
char *s; /* String pointer */
BYTE c; /* Trailing character */
U16 devnum; /* Requested device number */
BYTE buf[512]; /* Telnet negotiation buffer */
static BYTE do_term[] = { IAC, DO, TERMINAL_TYPE };
static BYTE will_term[] = { IAC, WILL, TERMINAL_TYPE };
static BYTE req_type[] = { IAC, SB, TERMINAL_TYPE, SEND, IAC, SE };
static BYTE type_is[] = { IAC, SB, TERMINAL_TYPE, IS };
static BYTE do_eor[] = { IAC, DO, EOR, IAC, WILL, EOR };
static BYTE will_eor[] = { IAC, WILL, EOR, IAC, DO, EOR };
static BYTE do_bin[] = { IAC, DO, BINARY, IAC, WILL, BINARY };
static BYTE will_bin[] = { IAC, WILL, BINARY, IAC, DO, BINARY };
#if 0
static BYTE do_tmark[] = { IAC, DO, TIMING_MARK };
static BYTE will_tmark[] = { IAC, WILL, TIMING_MARK };
static BYTE wont_sga[] = { IAC, WONT, SUPPRESS_GA };
static BYTE dont_sga[] = { IAC, DONT, SUPPRESS_GA };
#endif
static BYTE wont_echo[] = { IAC, WONT, ECHO_OPTION };
static BYTE dont_echo[] = { IAC, DONT, ECHO_OPTION };
static BYTE will_naws[] = { IAC, WILL, NAWS };
/* Perform terminal-type negotiation */
rc = send_packet (csock, do_term, sizeof(do_term),
"IAC DO TERMINAL_TYPE");
if (rc < 0) return -1;
rc = expect (csock, will_term, sizeof(will_term),
"IAC WILL TERMINAL_TYPE");
if (rc < 0) return -1;
/* Request terminal type */
rc = send_packet (csock, req_type, sizeof(req_type),
"IAC SB TERMINAL_TYPE SEND IAC SE");
if (rc < 0) return -1;
rc = recv_packet (csock, buf, sizeof(buf)-2, SE);
if (rc < 0) return -1;
/* Ignore Negotiate About Window Size */
if (rc >= (int)sizeof(will_naws) &&
memcmp (buf, will_naws, sizeof(will_naws)) == 0)
{
memmove(buf, &buf[sizeof(will_naws)], (rc - sizeof(will_naws)));
rc -= sizeof(will_naws);
}
if (rc < (int)(sizeof(type_is) + 2)
|| memcmp(buf, type_is, sizeof(type_is)) != 0
|| buf[rc-2] != IAC || buf[rc-1] != SE) {
TNSDEBUG2("console: DBG008: Expected IAC SB TERMINAL_TYPE IS\n");
return -1;
}
buf[rc-2] = '\0';
termtype = (char *)(buf + sizeof(type_is));
TNSDEBUG2("console: DBG009: Received IAC SB TERMINAL_TYPE IS %s IAC SE\n",
termtype);
/* Check terminal type string for device name suffix */
s = strchr (termtype, '@');
if(s!=NULL)
{
if(strlen(s)<16)
{
strlcpy(group,&s[1],16);
}
}
else
{
group[0]=0;
}
if (s != NULL && sscanf (s, "@%hx%c", &devnum,&c) == 1)
{
*devn = devnum;
group[0]=0;
}
else
{
*devn = 0xFFFF;
}
/* Test for non-display terminal type */
if (memcmp(termtype, "IBM-", 4) != 0)
{
#if 0
/* Perform line mode negotiation */
rc = send_packet (csock, do_tmark, sizeof(do_tmark),
"IAC DO TIMING_MARK");
if (rc < 0) return -1;
rc = expect (csock, will_tmark, sizeof(will_tmark),
"IAC WILL TIMING_MARK");
if (rc < 0) return 0;
rc = send_packet (csock, wont_sga, sizeof(wont_sga),
"IAC WONT SUPPRESS_GA");
if (rc < 0) return -1;
rc = expect (csock, dont_sga, sizeof(dont_sga),
"IAC DONT SUPPRESS_GA");
if (rc < 0) return -1;
#endif
if (memcmp(termtype, "ANSI", 4) == 0)
{
rc = send_packet (csock, wont_echo, sizeof(wont_echo),
"IAC WONT ECHO");
if (rc < 0) return -1;
rc = expect (csock, dont_echo, sizeof(dont_echo),
"IAC DONT ECHO");
if (rc < 0) return -1;
}
/* Return printer-keyboard terminal class */
*class = 'K';
*model = '-';
*extatr = '-';
return 0;
}
/* Determine display terminal model */
if (memcmp(termtype+4,"DYNAMIC",7) == 0) {
*model = 'X';
*extatr = 'Y';
} else {
if (!(memcmp(termtype+4, "3277", 4) == 0
|| memcmp(termtype+4, "3270", 4) == 0
|| memcmp(termtype+4, "3178", 4) == 0
|| memcmp(termtype+4, "3278", 4) == 0
|| memcmp(termtype+4, "3179", 4) == 0
|| memcmp(termtype+4, "3180", 4) == 0
|| memcmp(termtype+4, "3287", 4) == 0
|| memcmp(termtype+4, "3279", 4) == 0))
return -1;
*model = '2';
*extatr = 'N';
if (termtype[8]=='-') {
if (termtype[9] < '1' || termtype[9] > '5')
return -1;
*model = termtype[9];
if (memcmp(termtype+4, "328",3) == 0) *model = '2';
if (memcmp(termtype+10, "-E", 2) == 0)
*extatr = 'Y';
}
}
/* Perform end-of-record negotiation */
rc = send_packet (csock, do_eor, sizeof(do_eor),
"IAC DO EOR IAC WILL EOR");
if (rc < 0) return -1;
rc = expect (csock, will_eor, sizeof(will_eor),
"IAC WILL EOR IAC DO EOR");
if (rc < 0) return -1;
/* Perform binary negotiation */
rc = send_packet (csock, do_bin, sizeof(do_bin),
"IAC DO BINARY IAC WILL BINARY");
if (rc < 0) return -1;
rc = expect (csock, will_bin, sizeof(will_bin),
"IAC WILL BINARY IAC DO BINARY");
if (rc < 0) return -1;
/* Return display terminal class */
if (memcmp(termtype+4,"3287",4)==0) *class='P';
else *class = 'D';
return 0;
} /* end function negotiate */
/*-------------------------------------------------------------------*/
/* NEW CLIENT CONNECTION */
/*-------------------------------------------------------------------*/
static int
connect_client (int *csockp)
/* returns 1 if 3270, else 0 */
{
int rc; /* Return code */
size_t len; /* Data length */
int csock; /* Socket for conversation */
struct sockaddr_in client; /* Client address structure */
socklen_t namelen; /* Length of client structure*/
char *clientip; /* Addr of client ip address */
U16 devnum; /* Requested device number */
BYTE class; /* D=3270, P=3287, K=3215/1052 */
BYTE model; /* 3270 model (2,3,4,5,X) */
BYTE extended; /* Extended attributes (Y,N) */
char buf[256]; /* Message buffer */
char conmsg[256]; /* Connection message */
char devmsg[25]; /* Device message */
char hostmsg[256]; /* Host ID message */
char num_procs[16]; /* #of processors string */
char group[16]; /* Console group */
/* Load the socket address from the thread parameter */
csock = *csockp;
/* Obtain the client's IP address */
namelen = sizeof(client);
rc = getpeername (csock, (struct sockaddr *)&client, &namelen);
/* Log the client's IP address and hostname */
clientip = strdup(inet_ntoa(client.sin_addr));
#if 0
// The following isn't really needed and hangs under unusual
// network configuration settings and thus has been removed.
{
struct hostent* pHE; /* Addr of hostent structure */
char* clientname; /* Addr of client hostname */
pHE = gethostbyaddr ((unsigned char*)(&client.sin_addr),
sizeof(client.sin_addr), AF_INET);
if (pHE != NULL && pHE->h_name != NULL
&& pHE->h_name[0] != '\0') {
clientname = (char*) pHE->h_name;
} else {
clientname = "host name unknown";
}
TNSDEBUG1("console: DBG018: Received connection from %s (%s)\n",
clientip, clientname);
}
#else
TNSDEBUG1("console: DBG018: Received connection from %s\n",
clientip );
#endif
/* Negotiate telnet parameters */
rc = negotiate (csock, &class, &model, &extended, &devnum, group);
if (rc != 0)
{
close_socket (csock);
if (clientip) free(clientip);
return 0;
}
/* Build connection message for client */
if ( cons_hostinfo.num_procs > 1 )
snprintf( num_procs, sizeof(num_procs)-1, "MP=%d", cons_hostinfo.num_procs );
else
strlcpy( num_procs, "UP", sizeof(num_procs) );
snprintf
(
hostmsg, sizeof(hostmsg),
"running on %s (%s-%s.%s %s %s)"
,cons_hostinfo.nodename
,cons_hostinfo.sysname
,cons_hostinfo.release
,cons_hostinfo.version
,cons_hostinfo.machine
,num_procs
);
snprintf (conmsg, sizeof(conmsg)-1,
"Hercules version %s built on %s %s",
VERSION, __DATE__, __TIME__);
{
snprintf (devmsg, sizeof(devmsg)-1, "Connected to device %4.4X",
0);
}
WRMSG(HHC01018, "I", 0, 0, clientip, 0x3270);
/* Send connection message to client */
if (class != 'K')
{
len = snprintf (buf, sizeof(buf)-1,
"\xF5\x40\x11\x40\x40\x1D\x60%s"
"\x11\xC1\x50\x1D\x60%s"
"\x11\xC2\x60\x1D\x60%s",
prt_host_to_guest( (BYTE*) conmsg, (BYTE*) conmsg, strlen( conmsg )),
prt_host_to_guest( (BYTE*) hostmsg, (BYTE*) hostmsg, strlen( hostmsg )),
prt_host_to_guest( (BYTE*) devmsg, (BYTE*) devmsg, strlen( devmsg )));
if (len < sizeof(buf))
{
buf[len++] = IAC;
}
else
{
ASSERT(FALSE);
}
if (len < sizeof(buf))
{
buf[len++] = EOR_MARK;
}
else
{
ASSERT(FALSE);
}
}
else
{
len = snprintf (buf, sizeof(buf)-1, "%s\r\n%s\r\n%s\r\n",
conmsg, hostmsg, devmsg);
}
if (class != 'P') /* do not write connection resp on 3287 */
{
rc = send_packet (csock, (BYTE *)buf, (int)len, "CONNECTION RESPONSE");
}
return (class == 'D') ? 1 : 0; /* return 1 if 3270 */
} /* end function connect_client */
static void logdump(char *txt,DEVBLK *dev,BYTE *bfr,size_t sz)
{
char buf[128];
char byte[5];
size_t i;
if(!dev->ccwtrace)
{
return;
}
WRMSG(HHC01048,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,txt);
WRMSG(HHC01049,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,txt,(u_int)sz,(u_int)sz);
buf[0] = 0;
for(i=0;i<sz;i++)
{
if(i%16==0)
{
if(i!=0)
{
WRMSG(HHC01050,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,txt,buf);
buf[0] = 0;
}
MSGBUF(buf, ": %04X:", (unsigned) i);
}
if(i%4==0 && i)
{
strlcat(buf, " ", sizeof(buf));
}
MSGBUF(byte, "%02X", bfr[i]);
strlcat(buf, byte, sizeof(buf));
}
WRMSG(HHC01050,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,txt,buf);
buf[0] = 0;
for(i=0;i<sz;i++)
{
if(i%16==0)
{
if(i!=0)
{
WRMSG(HHC01051,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,buf);
buf[0] = 0;
}
}
MSGBUF(byte, "%c",(bfr[i] & 0x7f) < 0x20 ? '.' : (bfr[i] & 0x7f));
strlcat(buf, byte, sizeof(buf));
}
WRMSG(HHC01051,"D",SSID_TO_LCSS(dev->ssid),dev->devnum,buf);
}
static void put_bufpool(void ** anchor, BYTE * ele) {
void ** elep = anchor;
for (;;) {
if (!*elep) break;
elep = *elep;
}
*elep = ele;
*(void**)ele = 0;
}
static BYTE * get_bufpool(void ** anchor) {
void ** elep = *anchor;
if (elep) {
*anchor = *elep;
} else {
*anchor = 0;
}
return (BYTE*)elep;
}
static void init_bufpool(COMMADPT *ca) {
BYTE * areap;
int i1;
int numbufs = 64;
int bufsize = 256+16+4;
ca->poolarea = (BYTE*)calloc (numbufs, bufsize);
if (!ca->poolarea) {
return;
}
areap = ca->poolarea;
for (i1 = 0; i1 < numbufs; i1++) {
put_bufpool(&ca->freeq, areap);
areap += (bufsize);
}
}
static void free_bufpool(COMMADPT *ca) {
ca->sendq = 0;
ca->freeq = 0;
if (ca->poolarea) {
free(ca->poolarea);
ca->poolarea = 0;
}
}
/*-------------------------------------------------------------------*/
/* Free all private structures and buffers */
/*-------------------------------------------------------------------*/
static void commadpt_clean_device(DEVBLK *dev)
{
if(dev->commadpt!=NULL)
{
free(dev->commadpt);
dev->commadpt=NULL;
if(dev->ccwtrace)
{
WRMSG(HHC01052,"D",
SSID_TO_LCSS(dev->ssid),
dev->devnum,"control block freed");
}
}
else
{
if(dev->ccwtrace)
{
WRMSG(HHC01052,"D",
SSID_TO_LCSS(dev->ssid),
dev->devnum,"control block not freed: not allocated");
}
}
return;
}
/*-------------------------------------------------------------------*/
/* Allocate initial private structures */
/*-------------------------------------------------------------------*/
static int commadpt_alloc_device(DEVBLK *dev)
{
dev->commadpt=malloc(sizeof(COMMADPT));
if(dev->commadpt==NULL)
{
char buf[40];
MSGBUF(buf, "malloc(%d)", (int)sizeof(COMMADPT));
WRMSG(HHC01000, "E", SSID_TO_LCSS(dev->ssid), dev->devnum, buf, strerror(errno));
return -1;
}
memset(dev->commadpt,0,sizeof(COMMADPT));
dev->commadpt->dev=dev;
return 0;
}
/*-------------------------------------------------------------------*/
/* Parsing utilities */
/*-------------------------------------------------------------------*/
/*-------------------------------------------------------------------*/
/* commadpt_getport : returns a port number or -1 */
/*-------------------------------------------------------------------*/
static int commadpt_getport(char *txt)
{
int pno;
struct servent *se;
pno=atoi(txt);
if(pno==0)
{
se=getservbyname(txt,"tcp");
if(se==NULL)
{
return -1;
}
pno=se->s_port;
}
return(pno);
}
/*-------------------------------------------------------------------*/
/* commadpt_getaddr : set an in_addr_t if ok, else return -1 */
/*-------------------------------------------------------------------*/
static int commadpt_getaddr(in_addr_t *ia,char *txt)
{
struct hostent *he;
he=gethostbyname(txt);
if(he==NULL)
{
return(-1);
}
memcpy(ia,he->h_addr_list[0],4);
return(0);