Lines Matching refs:msg
122 static void time_travel_handle_message(struct um_timetravel_msg *msg, in time_travel_handle_message() argument
146 ARRAY_SIZE(fd), msg, sizeof(*msg)); in time_travel_handle_message()
147 if (ret == sizeof(*msg)) { in time_travel_handle_message()
149 msg->time & UM_TIMETRAVEL_START_ACK_ID); in time_travel_handle_message()
154 ret = os_read_file(time_travel_ext_fd, msg, sizeof(*msg)); in time_travel_handle_message()
159 if (ret != sizeof(*msg)) in time_travel_handle_message()
162 switch (msg->op) { in time_travel_handle_message()
165 (unsigned long long)msg->op); in time_travel_handle_message()
170 time_travel_set_time(msg->time); in time_travel_handle_message()
184 _time_travel_ext_free_until = msg->time; in time_travel_handle_message()
187 bc_message = msg->time; in time_travel_handle_message()
192 resp.seq = msg->seq; in time_travel_handle_message()
200 struct um_timetravel_msg msg = { in time_travel_ext_req() local
223 os_write_file(time_travel_ext_fd, &msg, sizeof(msg)); in time_travel_ext_req()
226 if (msg.op == UM_TIMETRAVEL_WAIT && time_travel_shm) in time_travel_ext_req()
229 while (msg.op != UM_TIMETRAVEL_ACK) in time_travel_ext_req()
230 time_travel_handle_message(&msg, in time_travel_ext_req()
235 if (msg.seq != mseq) in time_travel_ext_req()
237 msg.op, msg.seq, mseq, msg.time); in time_travel_ext_req()
240 time_travel_set_time(msg.time); in time_travel_ext_req()
244 return msg.time; in time_travel_ext_req()
256 struct um_timetravel_msg msg; in __time_travel_wait_readable() local
259 time_travel_handle_message(&msg, TTMH_READ); in __time_travel_wait_readable()
348 struct um_timetravel_msg msg = { in time_travel_ext_wait() local
366 while (msg.op != UM_TIMETRAVEL_RUN) in time_travel_ext_wait()
367 time_travel_handle_message(&msg, idle ? TTMH_IDLE : TTMH_POLL); in time_travel_ext_wait()