From c8199aacaa01a5ef3a13d958a8a46206bd0a6eea Mon Sep 17 00:00:00 2001 From: Michael Brown Date: Sun, 5 Sep 2010 01:16:29 +0100 Subject: [xfer] Add xfer_window_changed() xfer_window_changed() can be used to notify peers that an interface is now ready to accept data. This can potentially be used to eliminate the need for wasteful processes that simply poll xfer_window() until the window becomes non-zero. Signed-off-by: Michael Brown --- src/core/xfer.c | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) (limited to 'src/core') diff --git a/src/core/xfer.c b/src/core/xfer.c index 222af52a..a755d438 100644 --- a/src/core/xfer.c +++ b/src/core/xfer.c @@ -104,6 +104,33 @@ size_t xfer_window ( struct interface *intf ) { return len; } +/** + * Report change of flow control window + * + * @v intf Data transfer interface + * + * Note that this method is used to indicate only unsolicited changes + * in the flow control window. In particular, this method must not be + * called as part of the response to xfer_deliver(), since that could + * easily lead to an infinite loop. Callers of xfer_deliver() should + * assume that the flow control window will have changed without + * generating an xfer_window_changed() message. + */ +void xfer_window_changed ( struct interface *intf ) { + struct interface *dest; + xfer_window_changed_TYPE ( void * ) *op = + intf_get_dest_op ( intf, xfer_window_changed, &dest ); + void *object = intf_object ( dest ); + + if ( op ) { + op ( object ); + } else { + /* Default is to do nothing */ + } + + intf_put ( dest ); +} + /** * Allocate I/O buffer * -- cgit v1.2.3-55-g7522