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
|
struct sockaddr;
typedef int socklen_t;
#ifndef SOCKET_H
#define SOCKET_H
#include <fs/fifo.h>
#include <fs/vfs.h>
#include <lib/buffered_write.h>
#include <lib/list.h>
#include <lib/relist.h>
#include <lib/ringbuffer.h>
#include <lib/stack.h>
#include <stddef.h>
#include <typedefs.h>
#define AF_UNIX 0
#define AF_INET 1
#define AF_LOCAL AF_UNIX
#define INADDR_ANY 0
#define MSG_WAITALL 1
void gen_ipv4(ipv4_t *ip, u8 i1, u8 i2, u8 i3, u8 i4);
struct TcpListen {
u32 ip;
u16 port;
struct stack incoming_connections;
};
struct UdpConnection {
u16 incoming_port;
u32 incoming_ip;
u32 outgoing_ip;
u16 outgoing_port;
int dead;
struct ringbuffer incoming_buffer;
};
struct TcpConnection {
int state;
u16 incoming_port;
u32 incoming_ip;
u32 outgoing_ip;
u16 outgoing_port;
struct ringbuffer incoming_buffer;
struct ringbuffer outgoing_buffer;
int no_delay;
u32 current_window_size;
u32 window_size;
u32 sent_ack;
u32 recieved_ack;
u32 max_seg;
u32 rcv_wnd;
u32 rcv_nxt;
u32 rcv_adv;
int should_send_ack;
u32 snd_una;
u32 snd_nxt;
u32 snd_max;
u32 snd_wnd;
struct relist incoming_connections;
};
struct TcpConnection *tcp_find_connection(ipv4_t src_ip, u16 src_port,
ipv4_t dst_ip, u16 dst_port);
struct TcpConnection *tcp_connect_to_listen(ipv4_t src_ip, u16 src_port,
ipv4_t dst_ip, u16 dst_port);
struct UdpConnection *udp_find_connection(ipv4_t src_ip, u16 src_port,
u16 dst_port);
typedef struct {
vfs_fd_t *ptr_socket_fd;
FIFO_FILE *fifo_file;
int domain;
int type;
int protocol;
void *child;
// UNIX socket
char *path;
vfs_fd_t *incoming_fd;
void *object;
} SOCKET;
typedef struct {
char *path;
SOCKET *s;
} OPEN_UNIX_SOCKET;
typedef struct {
u32 address;
u16 port;
SOCKET *s;
} OPEN_INET_SOCKET;
typedef u32 in_addr_t;
typedef u16 in_port_t;
typedef unsigned int sa_family_t;
struct sockaddr {
sa_family_t sa_family; /* Address family */
char *sa_data; /* Socket address */
};
struct sockaddr_in {
sa_family_t sin_family;
union {
u32 s_addr;
u8 a[4];
} sin_addr;
u16 sin_port;
};
struct sockaddr_un {
sa_family_t sun_family; /* Address family */
char *sun_path; /* Socket pathname */
};
OPEN_INET_SOCKET *find_open_udp_port(u16 port);
OPEN_INET_SOCKET *find_open_tcp_port(u16 port);
int uds_open(const char *path);
int socket(int domain, int type, int protocol);
int accept(int socket, struct sockaddr *address, socklen_t *address_len);
int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
struct INCOMING_TCP_CONNECTION *
handle_incoming_tcp_connection(u8 ip[4], u16 n_port, u16 dst_port);
struct INCOMING_TCP_CONNECTION *get_incoming_tcp_connection(u8 ip[4],
u16 n_port);
int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
void global_socket_init(void);
u16 tcp_get_free_port(void);
int setsockopt(int socket, int level, int option_name, const void *option_value,
socklen_t option_len);
void tcp_remove_connection(struct TcpConnection *con);
void tcp_flush_acks(void);
void tcp_flush_buffers(void);
void tcp_strip_connection(struct TcpConnection *con);
#endif
|
