Pipelet: implement _update_upstream_query() to propagate upstream query updates
Socket_IO_Crossover: implement xs_query messages to propagate upstream query updates