qtest: Fix deadloop by running main loop AIO context's timers
qemu_clock_run_timers() only takes care of main_loop_tlg, we shouldn't forget aio timer list groups. Currently, the qemu_clock_deadline_ns_all (a few lines above) counts all the timergroups of this clock type, including aio tlg, but we don't fire them, so they are never cleared, which makes a dead loop. For example, this function hangs when trying to drive throttled block request queue with qtest clock_step. Signed-off-by: Fam Zheng <famz@redhat.com> Acked-by: Paolo Bonzini <pbonzini@redhat.com> Message-id: 1421661103-29153-1-git-send-email-famz@redhat.com Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
This commit is contained in:
		
							parent
							
								
									a7be17bee8
								
							
						
					
					
						commit
						efef88b3d9
					
				
							
								
								
									
										4
									
								
								cpus.c
									
									
									
									
									
								
							
							
						
						
									
										4
									
								
								cpus.c
									
									
									
									
									
								
							@ -361,15 +361,19 @@ static void icount_warp_rt(void *opaque)
 | 
				
			|||||||
void qtest_clock_warp(int64_t dest)
 | 
					void qtest_clock_warp(int64_t dest)
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
    int64_t clock = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
 | 
					    int64_t clock = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
 | 
				
			||||||
 | 
					    AioContext *aio_context;
 | 
				
			||||||
    assert(qtest_enabled());
 | 
					    assert(qtest_enabled());
 | 
				
			||||||
 | 
					    aio_context = qemu_get_aio_context();
 | 
				
			||||||
    while (clock < dest) {
 | 
					    while (clock < dest) {
 | 
				
			||||||
        int64_t deadline = qemu_clock_deadline_ns_all(QEMU_CLOCK_VIRTUAL);
 | 
					        int64_t deadline = qemu_clock_deadline_ns_all(QEMU_CLOCK_VIRTUAL);
 | 
				
			||||||
        int64_t warp = qemu_soonest_timeout(dest - clock, deadline);
 | 
					        int64_t warp = qemu_soonest_timeout(dest - clock, deadline);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        seqlock_write_lock(&timers_state.vm_clock_seqlock);
 | 
					        seqlock_write_lock(&timers_state.vm_clock_seqlock);
 | 
				
			||||||
        timers_state.qemu_icount_bias += warp;
 | 
					        timers_state.qemu_icount_bias += warp;
 | 
				
			||||||
        seqlock_write_unlock(&timers_state.vm_clock_seqlock);
 | 
					        seqlock_write_unlock(&timers_state.vm_clock_seqlock);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        qemu_clock_run_timers(QEMU_CLOCK_VIRTUAL);
 | 
					        qemu_clock_run_timers(QEMU_CLOCK_VIRTUAL);
 | 
				
			||||||
 | 
					        timerlist_run_timers(aio_context->tlg.tl[QEMU_CLOCK_VIRTUAL]);
 | 
				
			||||||
        clock = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
 | 
					        clock = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
    qemu_clock_notify(QEMU_CLOCK_VIRTUAL);
 | 
					    qemu_clock_notify(QEMU_CLOCK_VIRTUAL);
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user