WebSVN – HelenOS – Diff – //branches/network/uspace/srv/net/tl/tcp/tcp.h

 #ifndef __NET_TCP_H__
 #define __NET_TCP_H__
 #include <fibril_sync.h>
+#include "../../structures/packet/packet.h"
+#include "../../include/device.h"
 #include "../../socket/socket_core.h"
+#include "../tl_common.h"
 /** Type definition of the TCP global data.
  *  @see tcp_globals
  */
 typedef struct tcp_globals  tcp_globals_t;
+/** Type definition of the TCP socket specific data.
+ *  @see tcp_socket_data
+ */
+typedef struct tcp_socket_data  tcp_socket_data_t;
+/** Type definition of the TCP socket specific data pointer.
+ *  @see tcp_socket_data
+ */
+typedef tcp_socket_data_t * tcp_socket_data_ref;
+/** Type definition of the TCP operation data.
+ *  @see tcp_operation
+ */
+typedef struct tcp_operation    tcp_operation_t;
+/** Type definition of the TCP operation data pointer.
+ *  @see tcp_operation
+ */
+typedef tcp_operation_t *   tcp_operation_ref;
+/** TCP socket state type definition.
+ *  @see tcp_socket_state
+ */
+typedef enum tcp_socket_state   tcp_socket_state_t;
+/** Device packet dimensions.
+ *  Maps devices to the packet dimensions.
+ *  @see device.h
+ */
+DEVICE_MAP_DECLARE( packet_dimensions, packet_dimension_t );
+/** TCP socket state.
+ */
+enum tcp_socket_state{
+    /** Initial.
+     *  Not connected or bound.
+     */
+    TCP_SOCKET_INITIAL,
+    /** Listening.
+     *  Awaiting a connection request from another TCP layer.
+     *  When SYN is received a new bound socket in the TCP_SOCKET_SYN_RECEIVED state should be created.
+     */
+    TCP_SOCKET_LISTEN,
+    /** Connecting issued.
+     *  A~SYN has been sent, and TCP is awaiting the response SYN.
+     *  Should continue to the TCP_SOCKET_ESTABLISHED state.
+     */
+    TCP_SOCKET_SYN_SENT,
+    /** Connecting received.
+     *  A~SYN has been received, a~SYN has been sent, and TCP is awaiting an ACK.
+     *  Should continue to the TCP_SOCKET_ESTABLISHED state.
+     */
+    TCP_SOCKET_SYN_RECEIVED,
+    /** Connected.
+     *  The three-way handshake has been completed.
+     */
+    TCP_SOCKET_ESTABLISHED,
+    /** Closing started.
+     *  The local application has issued a~CLOSE.
+     *  TCP has sent a~FIN, and is awaiting an ACK or a~FIN.
+     *  Should continue to the TCP_SOCKET_FIN_WAIT_2 state when an ACK is received.
+     *  Should continue to the TCP_SOCKET_CLOSING state when a~FIN is received.
+     */
+    TCP_SOCKET_FIN_WAIT_1,
+    /** Closing confirmed.
+     *  A~FIN has been sent, and an ACK received.
+     *  TCP is awaiting a~FIN from the remote TCP layer.
+     *  Should continue to the TCP_SOCKET_CLOSING state.
+     */
+    TCP_SOCKET_FIN_WAIT_2,
+    /** Closing.
+     *  A FIN has been sent, a FIN has been received, and an ACK has been sent.
+     *  TCP is awaiting an ACK for the FIN that was sent.
+     *  Should continue to the TCP_SOCKET_TIME_WAIT state.
+     */
+    TCP_SOCKET_CLOSING,
+    /** Closing received.
+     *  TCP has received a~FIN, and has sent an ACK.
+     *  It is awaiting a~close request from the local application before sending a~FIN.
+     *  Should continue to the TCP_SOCKET_SOCKET_LAST_ACK state.
+     */
+    TCP_SOCKET_CLOSE_WAIT,
+    /**
+     *  A~FIN has been received, and an ACK and a~FIN have been sent.
+     *  TCP is awaiting an ACK.
+     *  Should continue to the TCP_SOCKET_TIME_WAIT state.
+     */
+    TCP_SOCKET_LAST_ACK,
+    /** Closing finished.
+     *  FINs have been received and ACK’d, and TCP is waiting two MSLs to remove the connection from the table.
+     */
+    TCP_SOCKET_TIME_WAIT,
+    /** Closed.
+     *  Imaginary, this indicates that a~connection has been removed from the connection table.
+     */
+    TCP_SOCKET_CLOSED
+};
+/** TCP operation data.
+ */
+struct tcp_operation{
+    /** Operation result.
+     */
+    int                 result;
+    /** Safety lock.
+     */
+    fibril_mutex_t      mutex;
+    /** Operation result signaling.
+     */
+    fibril_condvar_t    condvar;
+};
+/** TCP socket specific data.
+ */
+struct tcp_socket_data{
+    /** TCP socket state.
+     */
+    tcp_socket_state_t  state;
+    /** Data fragment size.
+     *  Sending optimalization.
+     */
+    size_t          data_fragment_size;
+    /** Device identifier.
+     */
+    device_id_t     device_id;
+    /** Listening backlog.
+     *  The maximal number of connected but not yet accepted sockets.
+     */
+    int             backlog;
+//  /** Segment size.
+//   */
+//  size_t          segment_size;
+    /** Parent listening socket identifier.
+     *  Set if this socket is an accepted one.
+     */
+    int             listening_socket_id;
+    /** Treshold size in bytes.
+     */
+    size_t          treshold;
+    /** Window size in bytes.
+     */
+    size_t          window;
+    /** Acknowledgement timeout.
+     */
+    suseconds_t     timeout;
+    /** Last acknowledged byte.
+     */
+    uint32_t        acknowledged;
+    /** Next incoming sequence number.
+     */
+    uint32_t        next_incoming;
+    /** Incoming FIN.
+     */
+    uint32_t        fin_incoming;
+    /** Next outgoing sequence number.
+     */
+    uint32_t        next_outgoing;
+    /** Last outgoing sequence number.
+     */
+    uint32_t        last_outgoing;
+    /** Outgoing FIN.
+     */
+    uint32_t        fin_outgoing;
+    /** Expected sequence number by the remote host.
+     *  The sequence number the other host expects.
+     *  The notification is sent only upon a packet reecival.
+     */
+    uint32_t        expected;
+    /** Expected sequence number counter.
+     *  Counts the number of received notifications for the same sequence number.
+     */
+    int             expected_count;
+    /** Incoming packet queue.
+     *  Packets are buffered until received in the right order.
+     *  The packets are excluded after successfully read.
+     *  Packets are sorted by their starting byte.
+     *  Packets metric is set as their data length.
+     */
+    packet_t        incoming;
+    /** Outgoing packet queue.
+     *  Packets are buffered until acknowledged by the remote host in the right order.
+     *  The packets are excluded after acknowledged.
+     *  Packets are sorted by their starting byte.
+     *  Packets metric is set as their data length.
+     */
+    packet_t        outgoing;
+    /** IP pseudo header.
+     */
+    ip_pseudo_header_ref    pseudo_header;
+    /** IP pseudo header length.
+     */
+    size_t          headerlen;
+    /** Remote host address.
+     */
+    struct sockaddr *   addr;
+    /** Remote host address length.
+     */
+    socklen_t           addrlen;
+    /** Remote host port.
+     */
+    uint16_t            dest_port;
+    /** Parent local sockets.
+     */
+    socket_cores_ref    local_sockets;
+    /** Local sockets safety lock.
+     *  May be locked for writing while holding the global lock for reading when changing the local sockets only.
+     *  The global lock may to be locked only before locking the local lock.
+     *  The global lock may be locked more weakly than the local lock.
+     *  The global lock may be released before releasing the local lock.
+     *  @see tcp_globals:lock
+     */
+    fibril_rwlock_t *   local_lock;
+    /** Pending operation data.
+     */
+    tcp_operation_t     operation;
+    /** Timeouts in a row counter.
+     *  If TCP_MAX_TIMEOUTS is reached, the connection is lost.
+     */
+    int                 timeout_count;
+};
 /** TCP global data.
  */
 struct  tcp_globals{
     /** Networking module phone.
      */
      */
     int             last_used_port;
     /** Active sockets.
      */
     socket_ports_t  sockets;
+    /** Device packet dimensions.
+     */
+    packet_dimensions_t dimensions;
     /** Safety lock.
+     *  Write lock is used only for adding or removing socket ports.
      */
     fibril_rwlock_t lock;
 };
 #endif

Subversion Repositories HelenOS

(root)//branches/network/uspace/srv/net/tl/tcp/tcp.h – Rev 4707 → 4742