mirror of
https://github.com/reactos/reactos.git
synced 2024-12-29 10:35:28 +00:00
91b013d387
This fixes netstat not having any state when enumerating connections. Basically, now, our netstat produces stuff like: https://twitter.com/HeisSpiter/status/1065871999266955264
220 lines
6 KiB
C
220 lines
6 KiB
C
/*
|
|
* COPYRIGHT: See COPYING in the top level directory
|
|
* PROJECT: ReactOS TCP/IP protocol driver
|
|
* FILE: include/tcp.h
|
|
* PURPOSE: Transmission Control Protocol definitions
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
typedef VOID
|
|
(*PTCP_COMPLETION_ROUTINE)( PVOID Context, NTSTATUS Status, ULONG Count );
|
|
|
|
/* TCPv4 header structure */
|
|
#include <pshpack1.h>
|
|
typedef struct TCPv4_HEADER {
|
|
USHORT SourcePort; /* Source port */
|
|
USHORT DestinationPort; /* Destination port */
|
|
ULONG SequenceNumber; /* Sequence number */
|
|
ULONG AckNumber; /* Acknowledgement number */
|
|
UCHAR DataOffset; /* Data offset; 32-bit words (leftmost 4 bits) */
|
|
UCHAR Flags; /* Control bits (rightmost 6 bits) */
|
|
USHORT Window; /* Maximum acceptable receive window */
|
|
USHORT Checksum; /* Checksum of segment */
|
|
USHORT Urgent; /* Pointer to urgent data */
|
|
} TCPv4_HEADER, *PTCPv4_HEADER;
|
|
|
|
#define TCPOPT_END_OF_LIST 0x0
|
|
#define TCPOPT_NO_OPERATION 0x1
|
|
#define TCPOPT_MAX_SEG_SIZE 0x2
|
|
|
|
#define TCPOPTLEN_MAX_SEG_SIZE 0x4
|
|
|
|
/* Data offset; 32-bit words (leftmost 4 bits); convert to bytes */
|
|
#define TCP_DATA_OFFSET(DataOffset)(((DataOffset) & 0xF0) >> (4-2))
|
|
|
|
|
|
/* TCPv4 pseudo header */
|
|
typedef struct TCPv4_PSEUDO_HEADER {
|
|
ULONG SourceAddress; /* Source address */
|
|
ULONG DestinationAddress; /* Destination address */
|
|
UCHAR Zero; /* Reserved */
|
|
UCHAR Protocol; /* Protocol */
|
|
USHORT TCPLength; /* Size of TCP segment */
|
|
} TCPv4_PSEUDO_HEADER, *PTCPv4_PSEUDO_HEADER;
|
|
#include <poppack.h>
|
|
|
|
typedef struct _SLEEPING_THREAD {
|
|
LIST_ENTRY Entry;
|
|
PVOID SleepToken;
|
|
KEVENT Event;
|
|
} SLEEPING_THREAD, *PSLEEPING_THREAD;
|
|
|
|
typedef struct _CLIENT_DATA {
|
|
BOOLEAN Unlocked;
|
|
KSPIN_LOCK Lock;
|
|
KIRQL OldIrql;
|
|
} CLIENT_DATA, *PCLIENT_DATA;
|
|
|
|
/* Retransmission timeout constants */
|
|
|
|
/* Lower bound for retransmission timeout in TCP timer ticks */
|
|
#define TCP_MIN_RETRANSMISSION_TIMEOUT 1*1000 /* 1 tick */
|
|
|
|
/* Upper bound for retransmission timeout in TCP timer ticks */
|
|
#define TCP_MAX_RETRANSMISSION_TIMEOUT 1*60*1000 /* 1 tick */
|
|
|
|
/* Smoothing factor */
|
|
#define TCP_ALPHA_RETRANSMISSION_TIMEOUT(x)(((x)*8)/10) /* 0.8 */
|
|
|
|
/* Delay variance factor */
|
|
#define TCP_BETA_RETRANSMISSION_TIMEOUT(x)(((x)*16)/10) /* 1.6 */
|
|
|
|
#define SEL_CONNECT 1
|
|
#define SEL_FIN 2
|
|
#define SEL_RST 4
|
|
#define SEL_ABRT 8
|
|
#define SEL_READ 16
|
|
#define SEL_WRITE 32
|
|
#define SEL_ACCEPT 64
|
|
#define SEL_OOB 128
|
|
#define SEL_ERROR 256
|
|
#define SEL_FINOUT 512
|
|
|
|
#define FREAD 0x0001
|
|
#define FWRITE 0x0002
|
|
|
|
/* Datagram/segment send request flags */
|
|
|
|
#define SRF_URG TCP_URG
|
|
#define SRF_ACK TCP_ACK
|
|
#define SRF_PSH TCP_PSH
|
|
#define SRF_RST TCP_RST
|
|
#define SRF_SYN TCP_SYN
|
|
#define SRF_FIN TCP_FIN
|
|
|
|
extern LONG TCP_IPIdentification;
|
|
extern CLIENT_DATA ClientInfo;
|
|
|
|
/* accept.c */
|
|
NTSTATUS TCPCheckPeerForAccept(PVOID Context,
|
|
PTDI_REQUEST_KERNEL Request);
|
|
NTSTATUS TCPListen( PCONNECTION_ENDPOINT Connection, UINT Backlog );
|
|
BOOLEAN TCPAbortListenForSocket( PCONNECTION_ENDPOINT Listener,
|
|
PCONNECTION_ENDPOINT Connection );
|
|
NTSTATUS TCPAccept
|
|
( PTDI_REQUEST Request,
|
|
PCONNECTION_ENDPOINT Listener,
|
|
PCONNECTION_ENDPOINT Connection,
|
|
PTCP_COMPLETION_ROUTINE Complete,
|
|
PVOID Context );
|
|
|
|
/* tcp.c */
|
|
PCONNECTION_ENDPOINT TCPAllocateConnectionEndpoint( PVOID ClientContext );
|
|
VOID TCPFreeConnectionEndpoint( PCONNECTION_ENDPOINT Connection );
|
|
|
|
NTSTATUS TCPSocket( PCONNECTION_ENDPOINT Connection,
|
|
UINT Family, UINT Type, UINT Proto );
|
|
|
|
VOID HandleSignalledConnection(PCONNECTION_ENDPOINT Connection);
|
|
|
|
PTCP_SEGMENT TCPCreateSegment(
|
|
PIP_PACKET IPPacket,
|
|
PTCPv4_HEADER TCPHeader,
|
|
ULONG SegmentLength);
|
|
|
|
VOID TCPFreeSegment(
|
|
PTCP_SEGMENT Segment);
|
|
|
|
VOID TCPAddSegment(
|
|
PCONNECTION_ENDPOINT Connection,
|
|
PTCP_SEGMENT Segment,
|
|
PULONG Acknowledged);
|
|
|
|
NTSTATUS TCPConnect(
|
|
PCONNECTION_ENDPOINT Connection,
|
|
PTDI_CONNECTION_INFORMATION ConnInfo,
|
|
PTDI_CONNECTION_INFORMATION ReturnInfo,
|
|
PTCP_COMPLETION_ROUTINE Complete,
|
|
PVOID Context);
|
|
|
|
NTSTATUS TCPDisconnect(
|
|
PCONNECTION_ENDPOINT Connection,
|
|
UINT Flags,
|
|
PLARGE_INTEGER Timeout,
|
|
PTDI_CONNECTION_INFORMATION ConnInfo,
|
|
PTDI_CONNECTION_INFORMATION ReturnInfo,
|
|
PTCP_COMPLETION_ROUTINE Complete,
|
|
PVOID Context);
|
|
|
|
NTSTATUS TCPReceiveData(
|
|
PCONNECTION_ENDPOINT Connection,
|
|
PNDIS_BUFFER Buffer,
|
|
ULONG ReceiveLength,
|
|
PULONG BytesReceived,
|
|
ULONG ReceiveFlags,
|
|
PTCP_COMPLETION_ROUTINE Complete,
|
|
PVOID Context);
|
|
|
|
NTSTATUS TCPSendData(
|
|
PCONNECTION_ENDPOINT Connection,
|
|
PCHAR Buffer,
|
|
ULONG DataSize,
|
|
PULONG DataUsed,
|
|
ULONG Flags,
|
|
PTCP_COMPLETION_ROUTINE Complete,
|
|
PVOID Context);
|
|
|
|
NTSTATUS TCPClose( PCONNECTION_ENDPOINT Connection );
|
|
|
|
NTSTATUS TCPTranslateError( const INT8 err );
|
|
|
|
UINT TCPAllocatePort( const UINT HintPort );
|
|
|
|
VOID TCPFreePort( const UINT Port );
|
|
|
|
NTSTATUS TCPGetSockAddress
|
|
( PCONNECTION_ENDPOINT Connection,
|
|
PTRANSPORT_ADDRESS TransportAddress,
|
|
BOOLEAN RemoteAddress );
|
|
|
|
NTSTATUS TCPStartup(
|
|
VOID);
|
|
|
|
NTSTATUS TCPShutdown(
|
|
VOID);
|
|
|
|
BOOLEAN TCPRemoveIRP( PCONNECTION_ENDPOINT Connection, PIRP Irp );
|
|
|
|
NTSTATUS TCPSetNoDelay(PCONNECTION_ENDPOINT Connection, BOOLEAN Set);
|
|
|
|
VOID
|
|
TCPUpdateInterfaceLinkStatus(PIP_INTERFACE IF);
|
|
|
|
VOID
|
|
TCPUpdateInterfaceIPInformation(PIP_INTERFACE IF);
|
|
|
|
VOID
|
|
FlushListenQueue(PCONNECTION_ENDPOINT Connection, const NTSTATUS Status);
|
|
|
|
VOID
|
|
FlushConnectQueue(PCONNECTION_ENDPOINT Connection, const NTSTATUS Status);
|
|
|
|
VOID
|
|
FlushReceiveQueue(PCONNECTION_ENDPOINT Connection, const NTSTATUS Status, const BOOLEAN interlocked);
|
|
|
|
VOID
|
|
FlushSendQueue(PCONNECTION_ENDPOINT Connection, const NTSTATUS Status, const BOOLEAN interlocked);
|
|
|
|
VOID
|
|
FlushShutdownQueue(PCONNECTION_ENDPOINT Connection, const NTSTATUS Status, const BOOLEAN interlocked);
|
|
|
|
VOID
|
|
FlushAllQueues(PCONNECTION_ENDPOINT Connection, NTSTATUS Status);
|
|
|
|
VOID CompleteBucket(PCONNECTION_ENDPOINT Connection, PTDI_BUCKET Bucket, const BOOLEAN Synchronous);
|
|
|
|
void
|
|
LibTCPDumpPcb(PVOID SocketContext);
|
|
|
|
NTSTATUS TCPGetSocketStatus(PCONNECTION_ENDPOINT Connection, PULONG State);
|