| 118 |
cache.data_len = header_len + strlen(content); |
cache.data_len = header_len + strlen(content); |
| 119 |
|
|
| 120 |
header_line_cnt = split_data_lines(header, SCREEN_COLS, cache.line_offsets, MAX_SPLIT_FILE_LINES); |
header_line_cnt = split_data_lines(header, SCREEN_COLS, cache.line_offsets, MAX_SPLIT_FILE_LINES); |
| 121 |
|
|
| 122 |
|
if (header_len != cache.line_offsets[header_line_cnt]) |
| 123 |
|
{ |
| 124 |
|
log_std("Header of article(aid=%d) is truncated from %ld to %ld\n", p_article->aid, header_len, cache.line_offsets[header_line_cnt]); |
| 125 |
|
header_len = (size_t)cache.line_offsets[header_line_cnt]; |
| 126 |
|
} |
| 127 |
|
|
| 128 |
cache.line_total = header_line_cnt + |
cache.line_total = header_line_cnt + |
| 129 |
split_data_lines(content, SCREEN_COLS, cache.line_offsets + header_line_cnt, MAX_SPLIT_FILE_LINES - header_line_cnt); |
split_data_lines(content, SCREEN_COLS, cache.line_offsets + header_line_cnt, MAX_SPLIT_FILE_LINES - header_line_cnt); |
| 130 |
if (cache.line_total >= MAX_SPLIT_FILE_LINES) |
|
| 131 |
|
if (cache.data_len - header_len != (size_t)cache.line_offsets[cache.line_total]) |
| 132 |
{ |
{ |
| 133 |
log_error("split_data_lines(%s) truncated over limit lines %d >= %d\n", data_file, cache.line_total, MAX_SPLIT_FILE_LINES); |
log_std("Body of article(aid=%d) is truncated from %ld to %ld\n", |
| 134 |
return -3; |
p_article->aid, cache.data_len - header_len, cache.line_offsets[cache.line_total]); |
| 135 |
|
cache.data_len = header_len + (size_t)(cache.line_offsets[cache.line_total]); |
| 136 |
} |
} |
| 137 |
|
|
| 138 |
for (i = header_line_cnt; i <= cache.line_total; i++) |
for (i = header_line_cnt; i <= cache.line_total; i++) |
| 141 |
} |
} |
| 142 |
|
|
| 143 |
footer_line_cnt = split_data_lines(footer, SCREEN_COLS, cache.line_offsets + cache.line_total, MAX_SPLIT_FILE_LINES - cache.line_total); |
footer_line_cnt = split_data_lines(footer, SCREEN_COLS, cache.line_offsets + cache.line_total, MAX_SPLIT_FILE_LINES - cache.line_total); |
| 144 |
if (cache.line_total + footer_line_cnt >= MAX_SPLIT_FILE_LINES) |
|
| 145 |
|
if (footer_len != cache.line_offsets[cache.line_total + footer_line_cnt]) |
| 146 |
{ |
{ |
| 147 |
log_error("split_data_lines(%s) truncated over limit lines %d >= %d\n", data_file, cache.line_total + footer_line_cnt, MAX_SPLIT_FILE_LINES); |
log_std("Footer of article(aid=%d) is truncated from %ld to %ld\n", |
| 148 |
return -3; |
p_article->aid, footer_len, cache.line_offsets[cache.line_total + footer_line_cnt]); |
| 149 |
|
footer_len = (size_t)(cache.line_offsets[cache.line_total + footer_line_cnt]); |
| 150 |
} |
} |
| 151 |
|
|
| 152 |
for (i = 0; i <= footer_line_cnt; i++) |
for (i = 0; i <= footer_line_cnt; i++) |
| 156 |
|
|
| 157 |
cache.data_len += footer_len; |
cache.data_len += footer_len; |
| 158 |
cache.line_total += footer_line_cnt; |
cache.line_total += footer_line_cnt; |
| 159 |
|
cache.mmap_len = sizeof(cache) - sizeof(long) * (MAX_SPLIT_FILE_LINES - (size_t)(cache.line_total) - 1) + cache.data_len; |
| 160 |
|
|
| 161 |
if (write(fd, &cache, sizeof(cache)) == -1) |
if (write(fd, &cache, cache.mmap_len - cache.data_len) == -1) |
| 162 |
{ |
{ |
| 163 |
log_error("write(%s, cache) error (%d)\n", data_file, errno); |
log_error("write(%s, cache) error (%d)\n", data_file, errno); |
| 164 |
close(fd); |
close(fd); |
| 239 |
return -2; |
return -2; |
| 240 |
} |
} |
| 241 |
|
|
| 242 |
memcpy((void *)p_cache, p_mmap, sizeof(ARTICLE_CACHE)); |
if (((ARTICLE_CACHE *)p_mmap)->mmap_len != mmap_len) |
|
|
|
|
if (sizeof(ARTICLE_CACHE) + p_cache->data_len != mmap_len) |
|
| 243 |
{ |
{ |
| 244 |
log_error("Inconsistent length, cache_len(%ld) + data_len(%ld) != mmap_len(%ld)\n", |
log_error("Inconsistent mmap len of article (cid=%d), %ld != %ld\n", p_article->cid, p_cache->mmap_len, mmap_len); |
|
sizeof(ARTICLE_CACHE), p_cache->data_len, mmap_len); |
|
|
|
|
|
if (munmap(p_mmap, mmap_len) < 0) |
|
|
{ |
|
|
log_error("munmap() error (%d)\n", errno); |
|
|
} |
|
|
|
|
| 245 |
return -3; |
return -3; |
| 246 |
} |
} |
| 247 |
|
|
| 248 |
|
bzero(p_cache, sizeof(*p_cache)); |
| 249 |
|
memcpy((void *)p_cache, p_mmap, (size_t)(((ARTICLE_CACHE *)p_mmap)->mmap_len - ((ARTICLE_CACHE *)p_mmap)->data_len)); |
| 250 |
|
|
| 251 |
p_cache->p_mmap = p_mmap; |
p_cache->p_mmap = p_mmap; |
| 252 |
p_cache->p_data = p_mmap + sizeof(ARTICLE_CACHE); |
p_cache->p_data = p_mmap + (p_cache->mmap_len - p_cache->data_len); |
| 253 |
|
|
| 254 |
return 0; |
return 0; |
| 255 |
} |
} |
| 262 |
return -1; |
return -1; |
| 263 |
} |
} |
| 264 |
|
|
| 265 |
if (munmap(p_cache->p_mmap, sizeof(ARTICLE_CACHE) + p_cache->data_len) < 0) |
if (munmap(p_cache->p_mmap, p_cache->mmap_len) < 0) |
| 266 |
{ |
{ |
| 267 |
log_error("munmap() error (%d)\n", errno); |
log_error("munmap() error (%d)\n", errno); |
| 268 |
return -2; |
return -2; |