Whamcloud - gitweb
ebaa4f9d82a37144a183d71cc4f75f5fd35bd4b5
[fs/lustre-release.git] / libcfs / include / libcfs / winnt / winnt-tcpip.h
1 /* -*- mode: c; c-basic-offset: 4; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=4:tabstop=4:
3  *
4  * GPL HEADER START
5  *
6  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
7  *
8  * This program is free software; you can redistribute it and/or modify
9  * it under the terms of the GNU General Public License version 2 only,
10  * as published by the Free Software Foundation.
11  *
12  * This program is distributed in the hope that it will be useful, but
13  * WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * General Public License version 2 for more details (a copy is included
16  * in the LICENSE file that accompanied this code).
17  *
18  * You should have received a copy of the GNU General Public License
19  * version 2 along with this program; If not, see
20  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
21  *
22  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
23  * CA 95054 USA or visit www.sun.com if you need additional information or
24  * have any questions.
25  *
26  * GPL HEADER END
27  */
28 /*
29  * Copyright  2008 Sun Microsystems, Inc. All rights reserved
30  * Use is subject to license terms.
31  */
32 /*
33  * This file is part of Lustre, http://www.lustre.org/
34  * Lustre is a trademark of Sun Microsystems, Inc.
35  */
36
37 #ifndef __LIBCFS_WINNT_TCPIP_H__
38 #define __LIBCFS_WINNT_TCPIP_H__
39
40 #ifndef __LIBCFS_LIBCFS_H__
41 #error Do not #include this file directly. #include <libcfs/libcfs.h> instead
42 #endif
43
44
45 #ifdef __KERNEL__
46
47 //
48 //  ks definitions
49 //
50
51 // iovec is defined in libcfs: winnt_prim.h 
52 // lnetkiov_t is defined in lnet/types.h
53
54 typedef struct socket ks_tconn_t, cfs_socket_t;
55
56 // completion notification callback routine
57
58 typedef VOID (*ks_schedule_cb)(struct socket*, int);
59
60 #define SOCK_ERROR(s)          ((s->kstc_state >= ksts_disconnected) ? ECONNRESET : 0)
61 #define SOCK_TEST_NOSPACE(s)   (1)
62
63 //
64 // tdinal definitions
65 //
66
67
68 #if DBG
69 #define KsPrint(X)     KsPrintf X
70 #else
71 #define KsPrint(X)
72 #endif
73
74
75 //
76 // Socket Addresses Related ...
77 //
78
79 #define     INADDR_ANY          (ULONG)0x00000000
80 #define     INADDR_LOOPBACK     (ULONG)0x7f000001
81 #define     INADDR_BROADCAST    (ULONG)0xffffffff
82 #define     INADDR_NONE         (ULONG)0xffffffff
83
84 /*
85  *  TCP / IP options
86  */
87
88 #define     SOL_TCP             6
89 #define     SOL_UD              17
90
91
92 #define TL_INSTANCE             0
93
94 #define TCP_SOCKET_NODELAY      1 //  disabling "Nagle"
95 #define TCP_SOCKET_KEEPALIVE    2
96 #define TCP_SOCKET_OOBINLINE    3
97 #define TCP_SOCKET_BSDURGENT    4
98 #define TCP_SOCKET_ATMARK       5
99 #define TCP_SOCKET_WINDOW       6
100
101
102 /* Flags we can use with send/ and recv. 
103    Added those for 1003.1g not all are supported yet
104  */
105  
106 #define MSG_OOB         1
107 #define MSG_PEEK        2
108 #define MSG_DONTROUTE   4
109 #define MSG_TRYHARD     4       /* Synonym for MSG_DONTROUTE for DECnet */
110 #define MSG_CTRUNC      8
111 #define MSG_PROBE       0x10    /* Do not send. Only probe path f.e. for MTU */
112 #define MSG_TRUNC       0x20
113 #define MSG_DONTWAIT    0x40    /* Nonblocking io                */
114 #define MSG_EOR         0x80    /* End of record */
115 #define MSG_WAITALL     0x100   /* Wait for a full request */
116 #define MSG_FIN         0x200
117 #define MSG_SYN         0x400
118 #define MSG_CONFIRM     0x800   /* Confirm path validity */
119 #define MSG_RST         0x1000
120 #define MSG_ERRQUEUE    0x2000  /* Fetch message from error queue */
121 #define MSG_NOSIGNAL    0x4000  /* Do not generate SIGPIPE */
122 #define MSG_MORE        0x8000  /* Sender will send more */
123
124 #define MSG_EOF         MSG_FIN
125
126
127 //
128 // Maximum TRANSPORT_ADDRESS Length
129 //
130 // it must >= FIELD_OFFSET(TRANSPORT_ADDRESS, Address->Address)
131 //            + TDI_ADDRESS_LENGTH_IP
132 //
133 // I define it a little large and 16 bytes aligned to avoid possible overflow.
134 //
135
136 #define MAX_ADDRESS_LENGTH              (0x30)
137
138
139 //
140 // Maximum Listers Children Sockets
141 //
142
143 #define MAX_CHILD_LISTENERS             (4)
144
145 //
146 // Maximum EA Information Length
147 //
148
149 #define EA_MAX_LENGTH                   ( sizeof(FILE_FULL_EA_INFORMATION) - 1 + \
150                                           TDI_TRANSPORT_ADDRESS_LENGTH + 1 + \
151                                           MAX_ADDRESS_LENGTH )
152
153
154 #define UDP_DEVICE_NAME L"\\Device\\Udp"
155 #define TCP_DEVICE_NAME L"\\Device\\Tcp"
156
157
158 /*
159  * TSDU definitions
160  */
161
162 #define TDINAL_TSDU_DEFAULT_SIZE  (0x10000)
163
164 #define KS_TSDU_MAGIC       'KSTD'
165
166 #define KS_TSDU_ATTACHED    0x00000001  // Attached to the socket receive tsdu list
167
168 typedef struct _KS_TSDU {
169
170     ULONG               Magic;          /* magic */
171     ULONG               Flags;          /* flags */
172
173     struct list_head    Link;           /* link list */
174
175     ULONG               TotalLength;    /* total size of KS_TSDU */
176     ULONG               StartOffset;    /* offset of the first Tsdu unit */
177     ULONG               LastOffset;     /* end offset of the last Tsdu unit */
178
179 /*
180     union {
181         KS_TSDU_DAT[];
182         KS_TSDU_BUF[];
183         KS_TSDU_MDL[];
184     }
185 */
186
187 } KS_TSDU, *PKS_TSDU;
188
189 #define TSDU_TYPE_BUF   ((USHORT)0x5401)
190 #define TSDU_TYPE_DAT   ((USHORT)0x5402)
191 #define TSDU_TYPE_MDL   ((USHORT)0x5403)
192
193 #define KS_TSDU_COMM_PARTIAL         0x0001
194
195 typedef struct _KS_TSDU_BUF {
196
197     USHORT              TsduType;
198     USHORT              TsduFlags;
199
200     ULONG               DataLength;
201     ULONG               StartOffset;
202
203     PVOID               UserBuffer;
204     PMDL                Mdl;         /* mdl */
205 } KS_TSDU_BUF, *PKS_TSDU_BUF;
206
207 typedef struct _KS_TSDU_DAT {
208
209     USHORT              TsduType;
210     USHORT              TsduFlags;
211
212     ULONG               DataLength;
213     ULONG               StartOffset;
214
215     ULONG               TotalLength;
216     PMDL                Mdl;        /* mdl */
217
218     UCHAR               Data[0];
219
220 } KS_TSDU_DAT, *PKS_TSDU_DAT;
221
222 #define KS_QWORD_ALIGN(x)      (((x) + 0x07) & 0xFFFFFFF8)
223 #define KS_TSDU_STRU_SIZE(Len) (KS_QWORD_ALIGN((Len) + FIELD_OFFSET(KS_TSDU_DAT, Data[0])))
224
225 typedef struct _KS_TSDU_MDL {
226     USHORT              TsduType;      /* TSDU_TYPE_MDL */
227     USHORT              TsduFlags;     /* */
228
229     ULONG               DataLength;    /* total valid data length */
230     ULONG               BaseOffset;    /* payload offset in Tsdu */
231     ULONG               StartOffset;   /* offset in payload */
232
233     PVOID               Descriptor;    /* tdi descriptor for receiving */
234     PMDL                Mdl;
235 } KS_TSDU_MDL, *PKS_TSDU_MDL;
236
237 typedef struct ks_engine_mgr {
238     spinlock_t              lock;
239     int                     stop;
240     event_t                 exit;
241     event_t                 start;
242     struct list_head        list;
243 } ks_engine_mgr_t;
244
245 typedef struct ks_engine_slot {
246     ks_tconn_t *            tconn;
247     void *                  tsdumgr;
248     struct list_head        link;
249     int                     queued;
250     ks_engine_mgr_t *       emgr;
251 } ks_engine_slot_t;
252
253 typedef struct _KS_TSDUMGR {
254     struct list_head        TsduList;
255     ULONG                   NumOfTsdu;
256     ULONG                   TotalBytes;
257     KEVENT                  Event;
258     spinlock_t              Lock;
259     ks_engine_slot_t        Slot;
260     ULONG                   Payload;
261     int                     Busy:1;
262     int                     OOB:1;
263 } KS_TSDUMGR, *PKS_TSDUMGR;
264
265 #define ks_lock_tsdumgr(mgr)   spin_lock(&((mgr)->Lock))
266 #define ks_unlock_tsdumgr(mgr) spin_unlock(&((mgr)->Lock))
267
268 typedef struct _KS_CHAIN {
269     KS_TSDUMGR          Normal;      /* normal queue */
270     KS_TSDUMGR          Expedited;   /* OOB/expedited queue */
271 } KS_CHAIN, *PKS_CHAIN;
272
273
274 #define KS_CAN_SCHED(TM) ((TM)->TotalBytes >= ((TM)->Payload >> 2))
275
276 //
277 // Handler Settings Indictor 
278 //
279
280 #define TDI_EVENT_MAXIMUM_HANDLER (TDI_EVENT_ERROR_EX + 1)
281
282
283 typedef struct _KS_EVENT_HANDLERS {
284     BOOLEAN     IsActive[TDI_EVENT_MAXIMUM_HANDLER];
285     PVOID       Handler [TDI_EVENT_MAXIMUM_HANDLER];
286 } KS_EVENT_HANDLERS, *PKS_EVENT_HANDLERS;
287
288 #define SetEventHandler(ha, ht, hr) do {        \
289             ha.IsActive[ht] = TRUE;             \
290             ha.Handler[ht] = (PVOID) (hr);      \
291         } while(0)
292
293 //
294 // KSock Internal Structures
295 //
296
297 typedef struct _KS_ADDRESS {
298
299     union {
300         TRANSPORT_ADDRESS   Tdi;
301         UCHAR               Pading[MAX_ADDRESS_LENGTH];
302     };
303
304     HANDLE                  Handle;
305     PFILE_OBJECT            FileObject;
306
307 } KS_ADDRESS, *PKS_ADDRESS;
308
309 //
310 // Structures for Disconnect Workitem
311 //
312
313 typedef struct _KS_DISCONNECT_WORKITEM {
314
315     WORK_QUEUE_ITEM         WorkItem;       // Workitem to perform disconnection
316     ks_tconn_t *            tconn;          // tdi connecton
317     ULONG                   Flags;          // connection broken/discnnection flags
318     KEVENT                  Event;          // sync event
319
320 } KS_DISCONNECT_WORKITEM, *PKS_DISCONNECT_WORKITEM;
321
322
323 typedef struct _KS_CONNECTION {
324
325     HANDLE                      Handle;     // Handle of the tdi connection
326     PFILE_OBJECT                FileObject; // FileObject if the conn object
327
328     PTRANSPORT_ADDRESS          Remote;     // the ConnectionInfo of this connection
329     PTDI_CONNECTION_INFORMATION ConnectionInfo;
330
331     ULONG                       nagle;      // Tcp options 
332
333 } KS_CONNECTION, *PKS_CONNECTION;
334
335
336 //
337 // type definitions
338 //
339
340 typedef MDL                         ks_mdl_t;
341 typedef UNICODE_STRING              ks_unicode_name_t;
342 typedef WORK_QUEUE_ITEM             ks_workitem_t;
343
344
345 typedef KS_CHAIN                    ks_chain_t;
346 typedef KS_ADDRESS                  ks_tdi_addr_t;
347 typedef KS_CONNECTION               ks_tconn_info_t;
348 typedef KS_DISCONNECT_WORKITEM      ks_disconnect_t;
349
350
351 //
352 // Structures for transmission done Workitem
353 //
354
355 typedef struct ks_backlogs {
356
357         struct list_head    list;   /* list to link the backlog connections */
358         int                 num;    /* number of backlogs in the list */
359
360 } ks_backlogs_t;
361
362
363 typedef struct ks_daemon {
364
365     ks_tconn_t *            tconn;         /* the listener connection object */
366     unsigned short          nbacklogs;     /* number of listening backlog conns */
367     unsigned short          port;          /* listening port number */ 
368     int                     shutdown;      /* daemon threads is to exit */
369     struct list_head        list;          /* to be attached into ks_nal_data_t */
370
371 } ks_daemon_t;
372
373 typedef enum {
374
375     kstt_sender = 0,    // normal sending connection type, it's active connection, while
376                         // child tconn is for passive connection.
377
378     kstt_listener,      // listener daemon type, it just acts as a daemon, and it does
379                         // not have real connection. It manages children tcons to accept
380                         // or refuse the connecting request from remote peers.
381
382     kstt_child,         // accepted child connection type, it's parent must be Listener
383
384     kstt_lasttype
385
386 } ks_tconn_type_t;
387
388 typedef enum {
389
390     ksts_uninited = 0,  // tconn is just allocated (zero values), not initialized yet
391
392     ksts_inited,        // tconn structure initialized: so it now can be identified as
393                         // a sender, listener or a child
394
395     ksts_bind,          // tconn is bound: the local address object (ip/port) is created.
396                         // after being bound, we must call ksocknal_put_tconn to release
397                         // the tconn objects, it's not safe just to free the memory of tconn.
398
399     ksts_associated,    // the connection object is created and associated with the address
400                         // object. so it's ready for connection. only for child and sender.
401
402     ksts_connecting,    // only used by child tconn: in the ConnectEvent handler routine,
403                         // it indicts the child tconn is busy to be connected to the peer.
404
405     ksts_connected,     // the connection is built already: for sender and child
406
407     ksts_listening,     // listener daemon is working, only for listener tconn
408
409     ksts_disconnected,  // disconnected by user
410     ksts_aborted,       // un-exptected broken status
411
412     ksts_last           // total number of tconn statuses
413
414 } ks_tconn_state_t;
415
416 #define KS_TCONN_MAGIC              'KSTM'
417
418 #define KS_TCONN_HANDLERS_SET       0x00000001  // Conection handlers are set.
419 #define KS_TCONN_DISCONNECT_BUSY    0x00010000  // Disconnect Workitem is queued ...
420 #define KS_TCONN_DESTROY_BUSY       0x00020000  // Destory Workitem is queued ...
421
422 #define KS_TCONN_DAEMON_STARTED     0x00100000  // indict the daemon is started,
423                                                 // only valid for listener
424 struct socket {
425
426         ulong                       kstc_magic;      /* Magic & Flags */
427         ulong                       kstc_flags;
428
429         spinlock_t                  kstc_lock;       /* serialise lock*/
430         void *                      kstc_conn;       /* ks_conn_t */
431
432         ks_tconn_type_t             kstc_type;           /* tdi connection Type */
433         ks_tconn_state_t            kstc_state;      /* tdi connection state flag */
434
435         ks_unicode_name_t           kstc_dev;        /* tcp transport device name */
436
437         ks_tdi_addr_t               kstc_addr;       /* local address handlers / Objects */
438
439         atomic_t                    kstc_refcount;   /* reference count of ks_tconn_t */
440
441         struct list_head            kstc_list;       /* linked to global ksocknal_data */
442
443         union {
444
445             struct {
446                 int                 nbacklog;         /* total number of backlog tdi connections */
447                 ks_backlogs_t       kstc_listening;   /* listeing backlog child connections */
448                 ks_backlogs_t       kstc_accepted;    /* connected backlog child connections */
449                 event_t             kstc_accept_event;   /* Signaled by AcceptedHander, 
450                                                             ksocknal_wait_accpeted_conns waits on */
451                 event_t             kstc_destroy_event;  /* Signaled when accepted child is released */
452             } listener; 
453
454             struct  {
455                 ks_tconn_info_t     kstc_info;      /* Connection Info if Connected */
456                 ks_chain_t          kstc_recv;      /* tsdu engine for data receiving */
457                 ks_chain_t          kstc_send;      /* tsdu engine for data sending */
458
459                 int                 kstc_queued;    /* Attached to Parent->ChildList ... */
460                 int                 kstc_queueno;   /* 0: Attached to Listening list 
461                                                        1: Attached to Accepted list */
462
463                 int                 kstc_busy;      /* referred by ConnectEventCallback ? */
464                 int                 kstc_accepted;  /* the connection is built ready ? */
465
466                 struct list_head    kstc_link;      /* linked to parent tdi connection */
467                 ks_tconn_t   *      kstc_parent;    /* pointers to it's listener parent */
468             } child;
469
470             struct {
471                 ks_tconn_info_t     kstc_info;      /* Connection Info if Connected */
472                 ks_chain_t          kstc_recv;      /* tsdu engine for data receiving */
473                 ks_chain_t          kstc_send;      /* tsdu engine for data sending */
474             } sender; 
475         };
476
477         ulong                       kstc_snd_wnd;   /* Sending window size */
478         ulong                       kstc_rcv_wnd;   /* Recving window size */
479
480         ks_workitem_t               kstc_destroy;    /* tconn destruction workitem */
481         ks_disconnect_t             kstc_disconnect; /* connection disconnect workitem */
482
483         ks_schedule_cb              kstc_sched_cb;   /* notification callback routine of completion */
484 };
485
486 #define SOCK_WMEM_QUEUED(sock) (0)
487 #define TDINAL_WINDOW_DEFAULT_SIZE  (0x100000)
488 #define TDINAL_MAX_TSDU_QUEUE_SIZE  (0x200000)
489
490 struct _KS_UDP_COMPLETION_CONTEXT;
491 struct _KS_TCP_COMPLETION_CONTEXT;
492
493
494 typedef
495 NTSTATUS
496 (*PKS_UDP_COMPLETION_ROUTINE) (
497     IN PIRP     Irp,
498     IN struct _KS_UDP_COMPLETION_CONTEXT
499                 *UdpContext
500     );
501
502
503 typedef
504 NTSTATUS
505 (*PKS_TCP_COMPLETION_ROUTINE) (
506     IN PIRP     Irp,
507     IN struct _KS_TCP_COMPLETION_CONTEXT
508                 *TcpContext
509     );
510
511 //
512 // Udp Irp Completion Context
513 //
514
515 typedef struct _KS_UDP_COMPLETION_CONTEXT {
516
517     PKEVENT                             Event;
518     union {
519         PFILE_OBJECT                    AddressObject;
520         ks_tconn_t *                    tconn;
521     };
522
523     PKS_UDP_COMPLETION_ROUTINE          CompletionRoutine;
524     PVOID                               CompletionContext;
525
526 } KS_UDP_COMPLETION_CONTEXT, *PKS_UDP_COMPLETION_CONTEXT;
527
528
529 //
530 // Tcp Irp Completion Context (used by tcp data recv/send)
531 //
532
533 #define KS_TCP_CONTEXT_MAGIC 'CCTK'
534
535 typedef struct _KS_TCP_COMPLETION_CONTEXT {
536     PKEVENT                             Event;      // Event to be waited on by Irp caller ...
537     ks_tconn_t *                        tconn;      // the tdi connection
538     PKS_TCP_COMPLETION_ROUTINE          CompletionRoutine;
539     PVOID                               CompletionContext;
540     PKS_TSDUMGR                         TsduMgr;    // Tsdu buffer manager
541     ULONG                               Length;     // Payload length in KsTsdu queue
542     PCHAR                               Buffer;     // User allocated buffer
543     ULONG                               Magic;      // Magic key
544 } KS_TCP_COMPLETION_CONTEXT, *PKS_TCP_COMPLETION_CONTEXT;
545
546 typedef KS_TCP_COMPLETION_CONTEXT  ks_tdi_tx_t, ks_tdi_rx_t;
547
548
549 /*
550  * tdi extensions
551  */
552
553 #define IOCTL_TCP_QUERY_INFORMATION_EX        \
554                         CTL_CODE(FILE_DEVICE_NETWORK, 0, METHOD_NEITHER, FILE_ANY_ACCESS)
555 #define IOCTL_TCP_SET_INFORMATION_EX        \
556                         CTL_CODE(FILE_DEVICE_NETWORK, 1, METHOD_BUFFERED, FILE_WRITE_ACCESS)
557
558
559 #define TcpBuildSetInformationEx(Irp, DevObj, FileObj, CompRoutine, Contxt, Buffer, BufferLen)\
560     {                                                                        \
561         PIO_STACK_LOCATION _IRPSP;                                           \
562         if ( CompRoutine != NULL) {                                          \
563             IoSetCompletionRoutine( Irp, CompRoutine, Contxt, TRUE, TRUE, TRUE);\
564         } else {                                                             \
565             IoSetCompletionRoutine( Irp, NULL, NULL, FALSE, FALSE, FALSE);   \
566         }                                                                    \
567         _IRPSP = IoGetNextIrpStackLocation (Irp);                            \
568         _IRPSP->MajorFunction = IRP_MJ_DEVICE_CONTROL;                       \
569         _IRPSP->DeviceObject = DevObj;                                       \
570         _IRPSP->FileObject = FileObj;                                        \
571         _IRPSP->Parameters.DeviceIoControl.OutputBufferLength = 0;           \
572         _IRPSP->Parameters.DeviceIoControl.InputBufferLength = BufferLen;    \
573         _IRPSP->Parameters.DeviceIoControl.IoControlCode = IOCTL_TCP_SET_INFORMATION_EX;  \
574         Irp->AssociatedIrp.SystemBuffer = Buffer;                            \
575     }
576
577
578 #define TcpBuildQueryInformationEx(Irp, DevObj, FileObj, CompRoutine, Contxt, InBuffer, InLength, OutBuffer, OutLength)\
579     {                                                                        \
580         PIO_STACK_LOCATION _IRPSP;                                           \
581         if ( CompRoutine != NULL) {                                          \
582             IoSetCompletionRoutine( Irp, CompRoutine, Contxt, TRUE, TRUE, TRUE);\
583         } else {                                                             \
584             IoSetCompletionRoutine( Irp, NULL, NULL, FALSE, FALSE, FALSE);   \
585         }                                                                    \
586         _IRPSP = IoGetNextIrpStackLocation (Irp);                            \
587         _IRPSP->MajorFunction = IRP_MJ_DEVICE_CONTROL;                       \
588         _IRPSP->DeviceObject = DevObj;                                       \
589         _IRPSP->FileObject = FileObj;                                        \
590         _IRPSP->Parameters.DeviceIoControl.OutputBufferLength = OutLength;           \
591         _IRPSP->Parameters.DeviceIoControl.InputBufferLength = InLength;    \
592         _IRPSP->Parameters.DeviceIoControl.IoControlCode = IOCTL_TCP_QUERY_INFORMATION_EX;  \
593         _IRPSP->Parameters.DeviceIoControl.Type3InputBuffer = InBuffer;    \
594         Irp->UserBuffer = OutBuffer;                            \
595     }
596
597 typedef struct ks_addr_slot {
598     LIST_ENTRY      link;
599     int             up;
600     char            iface[40];
601     __u32           ip_addr;
602     __u32           netmask;
603     UNICODE_STRING  devname;
604     WCHAR           buffer[1];
605 } ks_addr_slot_t;
606
607 typedef struct {
608
609     /*
610      * Tdi client information
611      */
612
613     UNICODE_STRING    ksnd_client_name; /* tdi client module name */
614     HANDLE            ksnd_pnp_handle;  /* the handle for pnp changes */
615
616     spinlock_t        ksnd_addrs_lock;  /* serialize ip address list access */
617     LIST_ENTRY        ksnd_addrs_list;  /* list of the ip addresses */
618     int               ksnd_naddrs;      /* number of the ip addresses */
619
620     /*
621      *  Tdilnd internal defintions
622      */
623
624     int               ksnd_init;            /* initialisation state */
625
626     TDI_PROVIDER_INFO ksnd_provider;        /* tdi tcp/ip provider's information */
627
628     spinlock_t        ksnd_tconn_lock;      /* tdi connections access serialise */
629
630     int               ksnd_ntconns;         /* number of tconns attached in list */
631     struct list_head  ksnd_tconns;          /* tdi connections list */
632     cfs_mem_cache_t * ksnd_tconn_slab;      /* slabs for ks_tconn_t allocations */
633     event_t           ksnd_tconn_exit;      /* exit event to be signaled by the last tconn */
634
635     spinlock_t        ksnd_tsdu_lock;       /* tsdu access serialise */
636         
637     int               ksnd_ntsdus;          /* number of tsdu buffers allocated */
638     ulong             ksnd_tsdu_size;       /* the size of a signel tsdu buffer */
639     cfs_mem_cache_t * ksnd_tsdu_slab;       /* slab cache for tsdu buffer allocation */
640
641     int               ksnd_nfreetsdus;      /* number of tsdu buffers in the freed list */
642     struct list_head  ksnd_freetsdus;       /* List of the freed Tsdu buffer. */
643
644     int               ksnd_engine_nums;     /* number of tcp sending engine threads */
645     ks_engine_mgr_t * ksnd_engine_mgr;      /* tcp sending engine structure */
646
647 } ks_tdi_data_t;
648
649 int
650 ks_init_tdi_data();
651
652 void
653 ks_fini_tdi_data();
654
655
656 int
657 ks_query_local_ipaddr(
658     ks_tconn_t *     tconn
659     );
660
661 void
662 ks_get_tconn(
663     ks_tconn_t * tconn
664     );
665
666 void
667 ks_put_tconn(
668     ks_tconn_t * tconn
669     );
670
671 void
672 ks_abort_tconn(
673   ks_tconn_t *     tconn
674     );
675 int
676 ks_disconnect_tconn(
677     ks_tconn_t *    tconn,
678     ulong           flags
679     );
680
681 void
682 ks_destroy_tconn(
683     ks_tconn_t *     tconn
684     );
685
686 NTSTATUS
687 KsLockUserBuffer (
688     IN PVOID            UserBuffer,
689     IN BOOLEAN          bPaged,
690     IN ULONG            Length,
691     IN LOCK_OPERATION   Operation,
692     OUT PMDL *          pMdl
693     );
694
695 VOID
696 KsReleaseMdl (IN PMDL   Mdl,
697               IN int    Paged );
698
699 void
700 KsQueueTdiEngine(ks_tconn_t * tconn, PKS_TSDUMGR);
701
702 void
703 KsRemoveTdiEngine(PKS_TSDUMGR);
704
705 NTSTATUS
706 ks_set_tcp_option (
707     ks_tconn_t *    tconn,
708     ULONG           ID,
709     PVOID           OptionValue,
710     ULONG           Length
711     );
712
713 int
714 ks_get_tcp_option (
715     ks_tconn_t *        tconn,
716     ULONG               ID,
717     PVOID               OptionValue,
718     PULONG              Length
719     );
720
721 #endif /* __KERNEL__ */
722 #endif /* __LIBCFS_WINNT_TCPIP_H__ */
723
724 /*
725  * Local variables:
726  * c-indentation-style: "K&R"
727  * c-basic-offset: 8
728  * tab-width: 8
729  * fill-column: 80
730  * scroll-step: 1
731  * End:
732  */