mirror of
https://github.com/ElementsProject/lightning.git
synced 2025-01-18 21:35:11 +01:00
ccan: update to get io_sock_shutdown
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
This commit is contained in:
parent
d51fb5207a
commit
ea73e49f2c
@ -1,3 +1,3 @@
|
||||
CCAN imported from http://ccodearchive.net.
|
||||
|
||||
CCAN version: init-2523-gb15b3673
|
||||
CCAN version: init-2524-g609670cc
|
||||
|
@ -529,6 +529,18 @@ bool io_plan_out_started(const struct io_conn *conn)
|
||||
return conn->plan[IO_OUT].status == IO_POLLING_STARTED;
|
||||
}
|
||||
|
||||
/* Despite being a TCP expert, I missed the full extent of this
|
||||
* problem. The legendary ZmnSCPxj implemented it (with the URL
|
||||
* pointing to the explanation), and I imitate that here. */
|
||||
struct io_plan *io_sock_shutdown(struct io_conn *conn)
|
||||
{
|
||||
if (shutdown(io_conn_fd(conn), SHUT_WR) != 0)
|
||||
return io_close(conn);
|
||||
|
||||
/* And leave unset .*/
|
||||
return &conn->plan[IO_IN];
|
||||
}
|
||||
|
||||
bool io_flush_sync(struct io_conn *conn)
|
||||
{
|
||||
struct io_plan *plan = &conn->plan[IO_OUT];
|
||||
|
@ -389,6 +389,40 @@ struct io_plan *io_out_always_(struct io_conn *conn,
|
||||
void *),
|
||||
void *arg);
|
||||
|
||||
/**
|
||||
* io_sock_shutdown - start socket close process (flushes TCP sockets).
|
||||
* @conn: the connection the plan is for
|
||||
*
|
||||
* Simply closing a TCP socket can lose data; unfortunately you should
|
||||
* shutdown(SHUT_WR) and wait for the other side to see this and close.
|
||||
* Of course, you also need to set a timer, in case it doesn't (you may
|
||||
* already have some responsiveness timer, of course).
|
||||
*
|
||||
* On error, is equivalent to io_close().
|
||||
*
|
||||
* Example:
|
||||
* #include <ccan/timer/timer.h>
|
||||
*
|
||||
* // Timer infra needs wrapper to contain extra data.
|
||||
* struct timeout_timer {
|
||||
* struct timer t;
|
||||
* struct io_conn *conn;
|
||||
* };
|
||||
* static struct timers timers;
|
||||
*
|
||||
* static struct io_plan *flush_and_close(struct io_conn *conn)
|
||||
* {
|
||||
* struct timeout_timer *timeout;
|
||||
* // Freed if conn closes normally.
|
||||
* timeout = tal(conn, struct timeout_timer);
|
||||
* timeout->conn = conn;
|
||||
* timeout->t = conn;
|
||||
* timer_addrel(&timers, &timeout->t, time_from_sec(5));
|
||||
* return io_sock_shutdown(conn);
|
||||
* }
|
||||
*/
|
||||
struct io_plan *io_sock_shutdown(struct io_conn *conn);
|
||||
|
||||
/**
|
||||
* io_connect - create an asynchronous connection to a listening socket.
|
||||
* @conn: the connection that plan is for.
|
||||
|
Loading…
Reference in New Issue
Block a user