]>
git.ipfire.org Git - thirdparty/squid.git/blob - src/comm.h
4 #include "comm/IoCallback.h"
6 #include "StoreIOBuffer.h"
13 bool comm_iocallbackpending(void); /* inline candidate */
15 int commSetNonBlocking(int fd
);
16 int commUnsetNonBlocking(int fd
);
17 void commSetCloseOnExec(int fd
);
18 void commSetTcpKeepalive(int fd
, int idle
, int interval
, int timeout
);
19 void _comm_close(int fd
, char const *file
, int line
);
20 #define comm_close(x) (_comm_close((x), __FILE__, __LINE__))
21 void old_comm_reset_close(int fd
);
22 void comm_reset_close(const Comm::ConnectionPointer
&conn
);
24 void comm_lingering_close(int fd
);
27 int comm_connect_addr(int sock
, const Ip::Address
&addr
);
31 int comm_open(int, int, Ip::Address
&, int, const char *note
);
32 int comm_open_uds(int sock_type
, int proto
, struct sockaddr_un
* addr
, int flags
);
33 /// update Comm state after getting a comm_open() FD from another process
34 void comm_import_opened(const Comm::ConnectionPointer
&, const char *note
, struct addrinfo
*AI
);
37 * Open a port specially bound for listening or sending through a specific port.
38 * This is a wrapper providing IPv4/IPv6 failover around comm_openex().
39 * Please use for all listening sockets and bind() outbound sockets.
41 * It will open a socket bound for:
42 * - IPv4 if IPv6 is disabled or address is IPv4-native.
43 * - IPv6 if address is IPv6-native
44 * - IPv6 dual-stack mode if able to open [::]
46 * When an open performs failover it update the given address to feedback
47 * the new IPv4-only status of the socket. Further displays of the IP
48 * (in debugs or cachemgr) will occur in Native IPv4 format.
49 * A reconfigure is needed to reset the stored IP in most cases and attempt a port re-open.
51 int comm_open_listener(int sock_type
, int proto
, Ip::Address
&addr
, int flags
, const char *note
);
52 void comm_open_listener(int sock_type
, int proto
, Comm::ConnectionPointer
&conn
, const char *note
);
54 int comm_openex(int, int, Ip::Address
&, int, const char *);
55 unsigned short comm_local_port(int fd
);
57 int comm_udp_sendto(int sock
, const Ip::Address
&to
, const void *buf
, int buflen
);
58 void commCallCloseHandlers(int fd
);
60 /// clear a timeout handler by FD number
61 void commUnsetFdTimeout(int fd
);
64 * Set or clear the timeout for some action on an active connection.
65 * API to replace commSetTimeout() when a Comm::ConnectionPointer is available.
67 int commSetConnTimeout(const Comm::ConnectionPointer
&conn
, int seconds
, AsyncCall::Pointer
&callback
);
68 int commUnsetConnTimeout(const Comm::ConnectionPointer
&conn
);
71 void commCloseAllSockets(void);
72 void checkTimeouts(void);
74 void comm_add_close_handler(int fd
, CLCB
*, void *);
75 void comm_add_close_handler(int fd
, AsyncCall::Pointer
&);
76 void comm_remove_close_handler(int fd
, CLCB
*, void *);
77 void comm_remove_close_handler(int fd
, AsyncCall::Pointer
&);
79 int comm_udp_recvfrom(int fd
, void *buf
, size_t len
, int flags
, Ip::Address
&from
);
80 int comm_udp_recv(int fd
, void *buf
, size_t len
, int flags
);
81 ssize_t
comm_udp_send(int s
, const void *buf
, size_t len
, int flags
);
82 bool comm_has_incomplete_write(int);
84 /** The read channel has closed and the caller does not expect more data
85 * but needs to detect connection aborts. The current detection method uses
86 * 0-length reads: We read until the error occurs or the writer closes
87 * the connection. If there is a read error, we close the connection.
89 void commStartHalfClosedMonitor(int fd
);
90 bool commHasHalfClosedMonitor(int fd
);
91 // XXX: remove these wrappers which minimize client_side.cc changes in a commit
92 inline void commMarkHalfClosed(int fd
) { commStartHalfClosedMonitor(fd
); }
93 inline bool commIsHalfClosed(int fd
) { return commHasHalfClosedMonitor(fd
); }
95 /* A comm engine that calls comm_select */
97 class CommSelectEngine
: public AsyncEngine
101 virtual int checkEvents(int timeout
);