Subversion Repositories Kolibri OS

Rev

Rev 4387 | Rev 5013 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
3545 hidnplayr 1
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
2
;;                                                                 ;;
3
;; Copyright (C) KolibriOS team 2004-2013. All rights reserved.    ;;
4
;; Distributed under terms of the GNU General Public License       ;;
5
;;                                                                 ;;
6
;;  Part of the TCP/IP network stack for KolibriOS                 ;;
7
;;                                                                 ;;
8
;;   Written by hidnplayr@kolibrios.org                            ;;
9
;;                                                                 ;;
10
;;    Based on the code of 4.4BSD                                  ;;
11
;;                                                                 ;;
12
;;          GNU GENERAL PUBLIC LICENSE                             ;;
13
;;             Version 2, June 1991                                ;;
14
;;                                                                 ;;
15
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
16
 
4850 mario79 17
$Revision: 4850 $
3545 hidnplayr 18
 
19
; Socket states
20
TCPS_CLOSED             = 0
21
TCPS_LISTEN             = 1
22
TCPS_SYN_SENT           = 2
23
TCPS_SYN_RECEIVED       = 3
24
TCPS_ESTABLISHED        = 4
25
TCPS_CLOSE_WAIT         = 5
26
TCPS_FIN_WAIT_1         = 6
27
TCPS_CLOSING            = 7
28
TCPS_LAST_ACK           = 8
29
TCPS_FIN_WAIT_2         = 9
30
TCPS_TIMED_WAIT         = 10
31
 
32
; Socket Flags
33
TF_ACKNOW               = 1 shl 0     ; ack peer immediately
34
TF_DELACK               = 1 shl 1     ; ack, but try to delay it
35
TF_NODELAY              = 1 shl 2     ; don't delay packets to coalesce
36
TF_NOOPT                = 1 shl 3     ; don't use tcp options
37
TF_SENTFIN              = 1 shl 4     ; have sent FIN
38
TF_REQ_SCALE            = 1 shl 5     ; have/will request window scaling
39
TF_RCVD_SCALE           = 1 shl 6     ; other side has requested scaling
40
TF_REQ_TSTMP            = 1 shl 7     ; have/will request timestamps
41
TF_RCVD_TSTMP           = 1 shl 8     ; a timestamp was received in SYN
42
TF_SACK_PERMIT          = 1 shl 9     ; other side said I could SACK
43
 
44
; Segment flags
45
TH_FIN                  = 1 shl 0
46
TH_SYN                  = 1 shl 1
47
TH_RST                  = 1 shl 2
48
TH_PUSH                 = 1 shl 3
49
TH_ACK                  = 1 shl 4
50
TH_URG                  = 1 shl 5
51
 
52
; Segment header options
53
TCP_OPT_EOL             = 0           ; End of option list.
54
TCP_OPT_NOP             = 1           ; No-Operation.
55
TCP_OPT_MAXSEG          = 2           ; Maximum Segment Size.
56
TCP_OPT_WINDOW          = 3           ; window scale
57
TCP_OPT_SACK_PERMIT     = 4           ; Selective Acknowledgement
58
TCP_OPT_SACK            = 5
59
TCP_OPT_TIMESTAMP       = 8
60
 
61
; Fundamental timer values
62
TCP_time_MSL            = 47          ; max segment lifetime (30s)
63
TCP_time_re_min         = 2           ; min retransmission (1,28s)
64
TCP_time_re_max         = 100         ; max retransmission (64s)
65
TCP_time_pers_min       = 8           ; min persist (5,12s)
66
TCP_time_pers_max       = 94          ; max persist (60,16s)
67
TCP_time_keep_init      = 118         ; connection establishment (75,52s)
68
TCP_time_keep_idle      = 4608        ; idle time before 1st probe (2h)
69
TCP_time_keep_interval  = 118         ; between probes when no response (75,52s)
70
TCP_time_rtt_default    = 5           ; default Round Trip Time (3,2s)
71
TCP_time_srtt_default   = 0           ;
72
TCP_time_max_idle       = 8*TCP_time_keep_interval      ; FIXME
73
 
4030 hidnplayr 74
TCP_time_connect        = 300         ; in 1/100s (default=3s)
75
 
3545 hidnplayr 76
; timer constants
77
TCP_max_rxtshift        = 12          ; max retransmissions waiting for ACK
78
TCP_max_keepcnt         = 8           ; max keepalive probes
79
 
80
;
81
TCP_max_winshift        = 14
82
TCP_max_win             = 65535
83
 
84
TCP_re_xmit_thresh      = 3
85
 
86
TCP_mss_default         = 1480        ; default max segment size
87
 
88
; smoothed round trip time and estimated variance are stored as fixed point numbers,
89
; shifted by the value below.
90
; With these scales, srtt has 3 bits to the right of the binary point, and thus an "alpha"
91
; of .875. rttvar has 2 bits to the right and thus "alpha" of 0.75
92
TCP_RTT_SHIFT           = 3
93
TCP_RTTVAR_SHIFT        = 2
94
 
95
; bits used by tcp_input and tcp_output
96
TCP_BIT_NEEDOUTPUT      = 1 shl 0
97
TCP_BIT_TIMESTAMP       = 1 shl 1
98
TCP_BIT_DROPSOCKET      = 1 shl 2
99
 
100
TCP_BIT_SENDALOT        = 1 shl 0
101
 
102
TCP_PAWS_IDLE           = 24*24*60*60*100       ; 24 days, in 1/100 seconds
103
 
104
TCP_QUEUE_SIZE          = 50
105
 
106
struct  TCP_header
107
 
108
        SourcePort              dw ?
109
        DestinationPort         dw ?
110
        SequenceNumber          dd ?
111
        AckNumber               dd ?
112
        DataOffset              db ?    ; DataOffset[0-3 bits] and Reserved[4-7]
113
        Flags                   db ?    ; Reserved[0-1 bits]|URG|ACK|PSH|RST|SYN|FIN
114
        Window                  dw ?
115
        Checksum                dw ?
116
        UrgentPointer           dw ?
117
 
118
ends
119
 
120
struct  TCP_queue_entry
121
 
122
        ip_ptr          dd ?
123
        segment_ptr     dd ?
124
        segment_size    dd ?
125
        device_ptr      dd ?
126
 
127
        buffer_ptr      dd ?
128
        timestamp       dd ?
129
 
130
ends
131
 
3697 hidnplayr 132
uglobal
3545 hidnplayr 133
align 4
3697 hidnplayr 134
 
3600 hidnplayr 135
        TCP_segments_tx         rd NET_DEVICES_MAX
136
        TCP_segments_rx         rd NET_DEVICES_MAX
137
        TCP_segments_missed     rd NET_DEVICES_MAX
138
        TCP_segments_dumped     rd NET_DEVICES_MAX
139
;        TCP_bytes_rx            rq NET_DEVICES_MAX
140
;        TCP_bytes_tx            rq NET_DEVICES_MAX
3545 hidnplayr 141
        TCP_sequence_num        dd ?
3697 hidnplayr 142
        TCP_queue               rd (TCP_QUEUE_SIZE*sizeof.TCP_queue_entry + sizeof.queue)/4
3545 hidnplayr 143
        TCP_input_event         dd ?
144
endg
145
 
4387 hidnplayr 146
uglobal
147
align 4
3545 hidnplayr 148
 
4387 hidnplayr 149
        TCPS_accepts            dd ?    ; #SYNs received in LISTEN state
150
        TCPS_closed             dd ?    ; #connections closed (includes drops)
151
        TCPS_connattempt        dd ?    ; #connections initiated (calls to connect)
152
        TCPS_conndrops          dd ?    ; #embryonic connections dropped (before SYN received)
153
        TCPS_connects           dd ?    ; #connections established actively or passively
154
        TCPS_delack             dd ?    ; #delayed ACKs sent
155
        TCPS_drops              dd ?    ; #connections dropped (after SYN received)
156
        TCPS_keepdrops          dd ?    ; #connections dropped in keepalive (established or awaiting SYN)
157
        TCPS_keepprobe          dd ?    ; #keepalive probes sent
158
        TCPS_keeptimeo          dd ?    ; #times keepalive timer or connections-establishment timer expire
159
        TCPS_pawsdrop           dd ?    ; #segments dropped due to PAWS
160
        TCPS_pcbcachemiss       dd ?    ; #times PCB cache comparison fails
161
        TCPS_persisttimeo       dd ?    ; #times persist timer expires
162
        TCPS_predack            dd ?    ; #times header prediction correct for ACKs
163
        TCPS_preddat            dd ?    ; #times header prediction correct for data packets
164
        TCPS_rcvackbyte         dd ?    ; #bytes ACKed by received ACKs
165
        TCPS_rcvackpack         dd ?    ; #received ACK packets
166
        TCPS_rcvacktoomuch      dd ?    ; #received ACKs for unsent data
167
        TCPS_rcvafterclose      dd ?    ; #packets received after connection closed
168
        TCPS_rcvbadoff          dd ?    ; #packets received with invalid header length
169
        TCPS_rcvbadsum          dd ?    ; #packets received with checksum errors
170
        TCPS_rcvbyte            dd ?    ; #bytes received in sequence
171
        TCPS_rcvbyteafterwin    dd ?    ; #bytes received beyond advertised window
172
        TCPS_rcvdupack          dd ?    ; #duplicate ACKs received
173
        TCPS_rcvdupbyte         dd ?    ; #bytes receivedin completely duplicate packets
174
        TCPS_rcvduppack         dd ?    ; #packets received with completely duplicate bytes
175
        TCPS_rcvoobyte          dd ?    ; #out-of-order bytes received
176
        TCPS_rcvoopack          dd ?    ; #out-of-order packets received
177
        TCPS_rcvpack            dd ?    ; #packets received in sequence
178
        TCPS_rcvpackafterwin    dd ?    ; #packets with some data beyond advertised window
179
        TCPS_rcvpartdupbyte     dd ?    ; #duplicate bytes in part-duplicate packets
180
        TCPS_rcvpartduppack     dd ?    ; #packets with some duplicate data
181
        TCPS_rcvshort           dd ?    ; #packets received too short
182
        TCPS_rcvtotal           dd ?    ; #total packets received
183
        TCPS_rcvwinprobe        dd ?    ; #window probe packets received
184
        TCPS_rcvwinupd          dd ?    ; #received window update packets
185
        TCPS_rexmttimeo         dd ?    ; #retransmission timeouts
186
        TCPS_rttupdated         dd ?    ; #times RTT estimators updated
187
        TCPS_segstimed          dd ?    ; #segments for which TCP tried to measure RTT
188
        TCPS_sndacks            dd ?    ; #ACK-only packets sent (data length = 0)
189
        TCPS_sndbyte            dd ?    ; #data bytes sent
190
        TCPS_sndctrl            dd ?    ; #control (SYN, FIN, RST) packets sent (data length = 0)
191
        TCPS_sndpack            dd ?    ; #data packets sent (data length > 0)
192
        TCPS_sndprobe           dd ?    ; #window probes sent (1 byte of data forced by persist timer)
193
        TCPS_sndrexmitbyte      dd ?    ; #data bytes retransmitted
194
        TCPS_sndrexmitpack      dd ?    ; #data packets retransmitted
195
        TCPS_sndtotal           dd ?    ; total #packets sent
196
        TCPS_sndurg             dd ?    ; #packets sent with URG-only (data length=0)
197
        TCPS_sndwinup           dd ?    ; #window update-only packets sent (data length=0)
198
        TCPS_timeoutdrop        dd ?    ; #connections dropped in retransmission timeout
199
 
200
endg
201
 
202
 
3545 hidnplayr 203
;-----------------------------------------------------------------
204
;
205
; TCP_init
206
;
207
;  This function resets all TCP variables
208
;
209
;-----------------------------------------------------------------
210
macro   TCP_init {
211
 
212
        xor     eax, eax
213
        mov     edi, TCP_segments_tx
3600 hidnplayr 214
        mov     ecx, (6*NET_DEVICES_MAX)
3711 clevermous 215
        rep stosd
3545 hidnplayr 216
 
217
        pseudo_random   eax
218
        mov     [TCP_sequence_num], eax
219
 
220
        init_queue TCP_queue
221
 
3598 clevermous 222
        movi    ebx, 1
3545 hidnplayr 223
        mov     ecx, TCP_process_input
224
        call    new_sys_threads
3697 hidnplayr 225
        test    eax, eax
226
        jns     @f
227
        DEBUGF  DEBUG_NETWORK_ERROR,'K : cannot create kernel thread for TCP, error %d\n', eax
228
  @@:
3545 hidnplayr 229
 
230
}
231
 
232
 
233
include 'tcp_timer.inc'
234
include 'tcp_subr.inc'
235
include 'tcp_usreq.inc'
236
include 'tcp_input.inc'
237
include 'tcp_output.inc'
238
 
239
 
240
;---------------------------------------------------------------------------
241
;
242
; TCP_API
243
;
244
; This function is called by system function 76
245
;
246
; IN:  subfunction number in bl
247
;      device number in bh
248
;      ecx, edx, .. depends on subfunction
249
;
250
; OUT:
251
;
252
;---------------------------------------------------------------------------
253
align 4
254
TCP_api:
255
 
256
        movzx   eax, bh
257
        shl     eax, 2
258
 
259
        test    bl, bl
260
        jz      .packets_tx     ; 0
261
        dec     bl
262
        jz      .packets_rx     ; 1
263
        dec     bl
264
        jz      .packets_missed ; 2
265
        dec     bl
266
        jz      .packets_dumped ; 3
267
 
268
  .error:
269
        mov     eax, -1
270
        ret
271
 
272
  .packets_tx:
273
        mov     eax, [TCP_segments_tx + eax]
274
        ret
275
 
276
  .packets_rx:
277
        mov     eax, [TCP_segments_rx + eax]
278
        ret
279
 
280
  .packets_missed:
281
        mov     eax, [TCP_segments_missed + eax]
282
        ret
283
 
284
  .packets_dumped:
285
        mov     eax, [TCP_segments_dumped + eax]
286
        ret