Lines Matching refs:msg
77 struct hvlog_msg *msg; /* pointer to msg */ member
121 struct hvlog_msg *msg[2]; in hvlog_read_dev() local
125 msg[0] = dev->msg; in hvlog_read_dev()
126 msg[1] = &dev->latched_msg; in hvlog_read_dev()
128 memset(msg[0], 0, sizeof(struct hvlog_msg) + LOG_MSG_SIZE); in hvlog_read_dev()
135 memcpy(&msg[0]->raw[msg[0]->len], dev->entry_latch, in hvlog_read_dev()
138 memcpy(msg[0], msg[1], sizeof(struct hvlog_msg)); in hvlog_read_dev()
141 read(dev->fd, &msg[0]->raw[msg[0]->len], in hvlog_read_dev()
147 p = strstr(&msg[0]->raw[msg[0]->len], "][seq="); in hvlog_read_dev()
150 msg[msg_num]->seq = strtoull(p, NULL, 10); in hvlog_read_dev()
151 if ((errno == ERANGE && (msg[msg_num]->seq == ULLONG_MAX)) in hvlog_read_dev()
152 || (errno != 0 && msg[msg_num]->seq == 0)) { in hvlog_read_dev()
165 &msg[0]->raw[msg[0]->len], in hvlog_read_dev()
175 memset(msg[0], 0, sizeof(struct hvlog_msg) in hvlog_read_dev()
180 len = strnlen(&msg[0]->raw[msg[0]->len], LOG_MSG_SIZE); in hvlog_read_dev()
181 msg[0]->len += len; in hvlog_read_dev()
183 msg[0]->len < LOG_MSG_SIZE - LOG_ELEMENT_SIZE); in hvlog_read_dev()
185 if (!msg[0]->len) in hvlog_read_dev()
188 msg[0]->raw[msg[0]->len] = '\n'; in hvlog_read_dev()
189 msg[0]->raw[msg[0]->len + 1] = 0; in hvlog_read_dev()
190 msg[0]->len++; in hvlog_read_dev()
192 return msg[0]; in hvlog_read_dev()
212 dev->msg = calloc(1, sizeof(struct hvlog_msg) + LOG_MSG_SIZE); in hvlog_open_dev()
213 if (!dev->msg) { in hvlog_open_dev()
233 if (dev->msg) in hvlog_close_dev()
234 free(dev->msg); in hvlog_close_dev()
244 struct hvlog_msg *msg; /* clean it after use */ member
257 if (data[i].msg) in hvlog_dev_read_msg()
262 data[i].msg = hvlog_read_dev(data[i].dev); in hvlog_dev_read_msg()
263 if (data[i].msg) in hvlog_dev_read_msg()
274 struct hvlog_msg *msg; in get_min_seq_msg() local
277 if (!data[i].msg) in get_min_seq_msg()
282 min_seq = data[i].msg->seq; in get_min_seq_msg()
286 if (data[i].msg->seq > min_seq) in get_min_seq_msg()
289 min_seq = data[i].msg->seq; in get_min_seq_msg()
295 msg = data[index_min].msg; in get_min_seq_msg()
296 data[index_min].msg = NULL; in get_min_seq_msg()
298 return msg; in get_min_seq_msg()
351 struct hvlog_msg *msg; in cur_read_func() local
357 msg = get_min_seq_msg(cur, cur_cnt); in cur_read_func()
358 if (!msg) { in cur_read_func()
364 if (last_seq + 1 < msg->seq) { in cur_read_func()
374 last_seq = msg->seq; in cur_read_func()
376 write_log_file(&cur_log, msg->raw, msg->len); in cur_read_func()
493 struct hvlog_msg *msg; in main() local
540 cur[i].msg = NULL; in main()
555 last[i].msg = NULL; in main()
573 msg = get_min_seq_msg(last, cur_cnt); in main()
574 if (!msg) in main()
576 write_log_file(&last_log, msg->raw, msg->len); in main()