Commit cc5c7041 authored by John Ogness's avatar John Ogness Committed by Petr Mladek

printk: ringbuffer: clear initial reserved fields

prb_reserve() will set some meta data values and leave others
uninitialized (or rather, containing the values of the previous
wrap). Simplify the API by always clearing out all the fields.
Only the sequence number is filled in. The caller is now
responsible for filling in the rest of the meta data fields.
In particular, for correctly filling in text and dict lengths.
Signed-off-by: default avatarJohn Ogness <john.ogness@linutronix.de>
Reviewed-by: default avatarPetr Mladek <pmladek@suse.com>
Signed-off-by: default avatarPetr Mladek <pmladek@suse.com>
Link: https://lore.kernel.org/r/20200914123354.832-4-john.ogness@linutronix.de
parent e3bc0401
...@@ -520,8 +520,11 @@ static int log_store(u32 caller_id, int facility, int level, ...@@ -520,8 +520,11 @@ static int log_store(u32 caller_id, int facility, int level,
memcpy(&r.text_buf[0], text, text_len); memcpy(&r.text_buf[0], text, text_len);
if (trunc_msg_len) if (trunc_msg_len)
memcpy(&r.text_buf[text_len], trunc_msg, trunc_msg_len); memcpy(&r.text_buf[text_len], trunc_msg, trunc_msg_len);
if (r.dict_buf) r.info->text_len = text_len + trunc_msg_len;
if (r.dict_buf) {
memcpy(&r.dict_buf[0], dict, dict_len); memcpy(&r.dict_buf[0], dict, dict_len);
r.info->dict_len = dict_len;
}
r.info->facility = facility; r.info->facility = facility;
r.info->level = level & 7; r.info->level = level & 7;
r.info->flags = flags & 0x1f; r.info->flags = flags & 0x1f;
...@@ -1069,10 +1072,11 @@ static unsigned int __init add_to_rb(struct printk_ringbuffer *rb, ...@@ -1069,10 +1072,11 @@ static unsigned int __init add_to_rb(struct printk_ringbuffer *rb,
if (!prb_reserve(&e, rb, &dest_r)) if (!prb_reserve(&e, rb, &dest_r))
return 0; return 0;
memcpy(&dest_r.text_buf[0], &r->text_buf[0], dest_r.text_buf_size); memcpy(&dest_r.text_buf[0], &r->text_buf[0], r->info->text_len);
dest_r.info->text_len = r->info->text_len;
if (dest_r.dict_buf) { if (dest_r.dict_buf) {
memcpy(&dest_r.dict_buf[0], &r->dict_buf[0], memcpy(&dest_r.dict_buf[0], &r->dict_buf[0], r->info->dict_len);
dest_r.dict_buf_size); dest_r.info->dict_len = r->info->dict_len;
} }
dest_r.info->facility = r->info->facility; dest_r.info->facility = r->info->facility;
dest_r.info->level = r->info->level; dest_r.info->level = r->info->level;
......
...@@ -146,10 +146,13 @@ ...@@ -146,10 +146,13 @@
* *
* if (prb_reserve(&e, &test_rb, &r)) { * if (prb_reserve(&e, &test_rb, &r)) {
* snprintf(r.text_buf, r.text_buf_size, "%s", textstr); * snprintf(r.text_buf, r.text_buf_size, "%s", textstr);
* r.info->text_len = strlen(textstr);
* *
* // dictionary allocation may have failed * // dictionary allocation may have failed
* if (r.dict_buf) * if (r.dict_buf) {
* snprintf(r.dict_buf, r.dict_buf_size, "%s", dictstr); * snprintf(r.dict_buf, r.dict_buf_size, "%s", dictstr);
* r.info->dict_len = strlen(dictstr);
* }
* *
* r.info->ts_nsec = local_clock(); * r.info->ts_nsec = local_clock();
* *
...@@ -1142,9 +1145,9 @@ static const char *get_data(struct prb_data_ring *data_ring, ...@@ -1142,9 +1145,9 @@ static const char *get_data(struct prb_data_ring *data_ring,
* @dict_buf_size is set to 0. Writers must check this before writing to * @dict_buf_size is set to 0. Writers must check this before writing to
* dictionary space. * dictionary space.
* *
* @info->text_len and @info->dict_len will already be set to @text_buf_size * Important: @info->text_len and @info->dict_len need to be set correctly by
* and @dict_buf_size, respectively. If dictionary space reservation fails, * the writer in order for data to be readable and/or extended.
* @info->dict_len is set to 0. * Their values are initialized to 0.
*/ */
bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb, bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb,
struct printk_record *r) struct printk_record *r)
...@@ -1152,6 +1155,7 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb, ...@@ -1152,6 +1155,7 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb,
struct prb_desc_ring *desc_ring = &rb->desc_ring; struct prb_desc_ring *desc_ring = &rb->desc_ring;
struct prb_desc *d; struct prb_desc *d;
unsigned long id; unsigned long id;
u64 seq;
if (!data_check_size(&rb->text_data_ring, r->text_buf_size)) if (!data_check_size(&rb->text_data_ring, r->text_buf_size))
goto fail; goto fail;
...@@ -1176,6 +1180,14 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb, ...@@ -1176,6 +1180,14 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb,
d = to_desc(desc_ring, id); d = to_desc(desc_ring, id);
/*
* All @info fields (except @seq) are cleared and must be filled in
* by the writer. Save @seq before clearing because it is used to
* determine the new sequence number.
*/
seq = d->info.seq;
memset(&d->info, 0, sizeof(d->info));
/* /*
* Set the @e fields here so that prb_commit() can be used if * Set the @e fields here so that prb_commit() can be used if
* text data allocation fails. * text data allocation fails.
...@@ -1194,17 +1206,15 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb, ...@@ -1194,17 +1206,15 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb,
* See the "Bootstrap" comment block in printk_ringbuffer.h for * See the "Bootstrap" comment block in printk_ringbuffer.h for
* details about how the initializer bootstraps the descriptors. * details about how the initializer bootstraps the descriptors.
*/ */
if (d->info.seq == 0 && DESC_INDEX(desc_ring, id) != 0) if (seq == 0 && DESC_INDEX(desc_ring, id) != 0)
d->info.seq = DESC_INDEX(desc_ring, id); d->info.seq = DESC_INDEX(desc_ring, id);
else else
d->info.seq += DESCS_COUNT(desc_ring); d->info.seq = seq + DESCS_COUNT(desc_ring);
r->text_buf = data_alloc(rb, &rb->text_data_ring, r->text_buf_size, r->text_buf = data_alloc(rb, &rb->text_data_ring, r->text_buf_size,
&d->text_blk_lpos, id); &d->text_blk_lpos, id);
/* If text data allocation fails, a data-less record is committed. */ /* If text data allocation fails, a data-less record is committed. */
if (r->text_buf_size && !r->text_buf) { if (r->text_buf_size && !r->text_buf) {
d->info.text_len = 0;
d->info.dict_len = 0;
prb_commit(e); prb_commit(e);
/* prb_commit() re-enabled interrupts. */ /* prb_commit() re-enabled interrupts. */
goto fail; goto fail;
...@@ -1221,10 +1231,6 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb, ...@@ -1221,10 +1231,6 @@ bool prb_reserve(struct prb_reserved_entry *e, struct printk_ringbuffer *rb,
r->info = &d->info; r->info = &d->info;
/* Set default values for the sizes. */
d->info.text_len = r->text_buf_size;
d->info.dict_len = r->dict_buf_size;
/* Record full text space used by record. */ /* Record full text space used by record. */
e->text_space = space_used(&rb->text_data_ring, &d->text_blk_lpos); e->text_space = space_used(&rb->text_data_ring, &d->text_blk_lpos);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment