if (from_stdio) {
char *p;
size_t chunk_len = 0;
+ /* -2 : priority byte and tag terminating '\0' */
size_t max_payload = LOGGER_ENTRY_MAX_PAYLOAD - writer->tag_len - 2;
if (writer->owner != current->group_leader) {
if (writer->b_owner != current && writer->b_off)
flush_thread_data(file);
- count = min_t(size_t, iov_iter_count(from), max_payload - 1);
+ /* -1 : leave space for message terminating '\0' */
+ count = min_t(size_t, iov_iter_count(from),
+ max_payload - writer->b_off - 1);
do {
*p++ = '\0';
chunk_len = p - writer->buffer;
} else {
- writer->buffer[count++] = '\0';
- chunk_len = count;
+ writer->buffer[writer->b_off + count++] = '\0';
+ p = &writer->buffer[writer->b_off + count];
+ chunk_len = p - writer->buffer;
+
+ BUG_ON(chunk_len > max_payload);
+ if (chunk_len < max_payload ) {
+ writer->b_off = writer->b_off + count - 1;
+ continue;
+ }
+
}
header.len = chunk_len + writer->tag_len + 2;