ia64/xen-unstable

changeset 7297:b7dce4fe2488

No need to gate xenstored reading requests from a
connection on whether there are pending replies/watches.
Signed-off-by: Keir Fraser <keir@xensource.com>
author kaf24@firebug.cl.cam.ac.uk
date Mon Oct 10 11:37:10 2005 +0100 (2005-10-10)
parents b67873a9e3ac
children 1ac39c7a0435
files tools/xenstore/xenstored_core.c tools/xenstore/xenstored_domain.c tools/xenstore/xenstored_transaction.c
line diff
     1.1 --- a/tools/xenstore/xenstored_core.c	Sun Oct 09 23:53:03 2005 +0100
     1.2 +++ b/tools/xenstore/xenstored_core.c	Mon Oct 10 11:37:10 2005 +0100
     1.3 @@ -324,8 +324,7 @@ static int initialize_set(fd_set *inset,
     1.4  	list_for_each_entry(i, &connections, list) {
     1.5  		if (i->domain)
     1.6  			continue;
     1.7 -		if (list_empty(&i->out_list))
     1.8 -			FD_SET(i->fd, inset);
     1.9 +		FD_SET(i->fd, inset);
    1.10  		if (!list_empty(&i->out_list))
    1.11  			FD_SET(i->fd, outset);
    1.12  		if (i->fd > max)
     2.1 --- a/tools/xenstore/xenstored_domain.c	Sun Oct 09 23:53:03 2005 +0100
     2.2 +++ b/tools/xenstore/xenstored_domain.c	Mon Oct 10 11:37:10 2005 +0100
     2.3 @@ -276,8 +276,7 @@ void handle_event(void)
     2.4  
     2.5  bool domain_can_read(struct connection *conn)
     2.6  {
     2.7 -	return (list_empty(&conn->out_list) &&
     2.8 -                buffer_has_input(conn->domain->input));
     2.9 +	return buffer_has_input(conn->domain->input);
    2.10  }
    2.11  
    2.12  bool domain_can_write(struct connection *conn)
     3.1 --- a/tools/xenstore/xenstored_transaction.c	Sun Oct 09 23:53:03 2005 +0100
     3.2 +++ b/tools/xenstore/xenstored_transaction.c	Mon Oct 10 11:37:10 2005 +0100
     3.3 @@ -154,9 +154,9 @@ void do_transaction_end(struct connectio
     3.4  		return;
     3.5  	}
     3.6  
     3.7 -	/* Set to NULL so fire_watches sends events, tdb_context works. */
     3.8  	trans = conn->transaction;
     3.9  	conn->transaction = NULL;
    3.10 +
    3.11  	/* Attach transaction to arg for auto-cleanup */
    3.12  	talloc_steal(arg, trans);
    3.13