Lines Matching refs:errh

755 …kqueue_get_append_newtempfile(chunkqueue * const restrict cq, log_error_st * const restrict errh) {  in chunkqueue_get_append_newtempfile()  argument
778 log_perror(errh, __FILE__, __LINE__, in chunkqueue_get_append_newtempfile()
790 …hunkqueue_get_append_tempfile(chunkqueue * const restrict cq, log_error_st * const restrict errh) { in chunkqueue_get_append_tempfile() argument
810 log_perror(errh, __FILE__, __LINE__, in chunkqueue_get_append_tempfile()
815 return chunkqueue_get_append_newtempfile(cq, errh); in chunkqueue_get_append_tempfile()
819 static int chunkqueue_append_tempfile_err(chunkqueue * const cq, log_error_st * const restrict errh… in chunkqueue_append_tempfile_err() argument
826 log_perror(errh, __FILE__, __LINE__, in chunkqueue_append_tempfile_err()
838 log_perror(errh, __FILE__, __LINE__, in chunkqueue_append_tempfile_err()
848 …int chunkqueue_to_tempfiles(chunkqueue * const restrict dest, log_error_st * const restrict errh) { in chunkqueue_to_tempfiles() argument
858 if (0 == chunkqueue_steal_with_tempfiles(dest, &src, cqlen, errh)) in chunkqueue_to_tempfiles()
867 …* const restrict dest, const char * restrict mem, size_t len, log_error_st * const restrict errh) { in chunkqueue_append_mem_to_tempfile() argument
874 && 0 != chunkqueue_to_tempfiles(dest, errh)) { in chunkqueue_append_mem_to_tempfile()
884 dst_c = chunkqueue_get_append_tempfile(dest, errh); in chunkqueue_append_mem_to_tempfile()
910 } else if (!chunkqueue_append_tempfile_err(dest, errh, dst_c)) { in chunkqueue_append_mem_to_tempfile()
926 …partial(chunkqueue * const dest, chunk * const c, ssize_t wr, log_error_st * const restrict errh) { in chunkqueue_append_cqmem_to_tempfile_partial() argument
938 return (0 == chunkqueue_to_tempfiles(dest, errh)) ? 0 : -1; in chunkqueue_append_cqmem_to_tempfile_partial()
941 …st restrict dest, chunkqueue * const restrict src, off_t len, log_error_st * const restrict errh) { in chunkqueue_append_cqmem_to_tempfile() argument
963 if (0 != chunkqueue_to_tempfiles(dest, errh)) in chunkqueue_append_cqmem_to_tempfile()
985 c = chunkqueue_get_append_tempfile(dest, errh); in chunkqueue_append_cqmem_to_tempfile()
1005 chunkqueue_append_cqmem_to_tempfile_partial(dest,c,wr,errh); in chunkqueue_append_cqmem_to_tempfile()
1012 else if (chunkqueue_append_tempfile_err(dest, errh, c)) in chunkqueue_append_cqmem_to_tempfile()
1024 …unkqueue * const restrict cq, const int fd, unsigned int len, log_error_st * const restrict errh) { in chunkqueue_append_drain_pipe_tempfile() argument
1037 if (0 != chunkqueue_append_mem_to_tempfile(cq, buf, (size_t)rd, errh)) in chunkqueue_append_drain_pipe_tempfile()
1053 …unkqueue * const restrict cq, const int fd, unsigned int len, log_error_st * const restrict errh) { in chunkqueue_append_splice_pipe_tempfile() argument
1058 int rc = chunkqueue_to_tempfiles(cq, errh); in chunkqueue_append_splice_pipe_tempfile()
1065 chunk * const c = chunkqueue_get_append_tempfile(cq, errh); in chunkqueue_append_splice_pipe_tempfile()
1101 wr = chunkqueue_append_drain_pipe_tempfile(cq, fd, len, errh); in chunkqueue_append_splice_pipe_tempfile()
1104 if (!chunkqueue_append_tempfile_err(cq, errh, c)) in chunkqueue_append_splice_pipe_tempfile()
1146 …unkqueue * const restrict cq, const int fd, unsigned int len, log_error_st * const restrict errh) { in chunkqueue_append_splice_sock_tempfile() argument
1160 wr = chunkqueue_append_splice_pipe_tempfile(cq, pipes[0], len, errh); in chunkqueue_append_splice_sock_tempfile()
1168 …st restrict dest, chunkqueue * const restrict src, off_t len, log_error_st * const restrict errh) { in chunkqueue_steal_with_tempfiles() argument
1179 clen = chunkqueue_append_cqmem_to_tempfile(dest, src, len, errh); in chunkqueue_steal_with_tempfiles()
1204 clen, errh)) in chunkqueue_steal_with_tempfiles()
1334 static int chunk_open_file_chunk(chunk * const restrict c, log_error_st * const restrict errh) { in chunk_open_file_chunk() argument
1338 log_perror(errh, __FILE__, __LINE__, "open failed: %s",c->mem->ptr); in chunk_open_file_chunk()
1348 log_perror(errh, __FILE__, __LINE__, "fstat failed"); in chunk_open_file_chunk()
1354 log_error(errh, __FILE__, __LINE__, "file shrunk: %s", c->mem->ptr); in chunk_open_file_chunk()
1361 int chunkqueue_open_file_chunk(chunkqueue * const restrict cq, log_error_st * const restrict errh) { in chunkqueue_open_file_chunk() argument
1362 return chunk_open_file_chunk(cq->first, errh); in chunkqueue_open_file_chunk()
1381 …queue_write_chunk_file_intermed (const int fd, chunk * const restrict c, log_error_st * const errh) in chunkqueue_write_chunk_file_intermed() argument
1388 if (0 != chunkqueue_peek_data(&cq, &data, &dlen, errh) && 0 == dlen) in chunkqueue_write_chunk_file_intermed()
1401 chunkqueue_write_chunk_file (const int fd, chunk * const restrict c, log_error_st * const errh) in chunkqueue_write_chunk_file() argument
1406 if (0 != chunk_open_file_chunk(c, errh)) in chunkqueue_write_chunk_file()
1425 chunkqueue_chunk_file_view(c, len, errh); in chunkqueue_write_chunk_file()
1433 return chunkqueue_write_chunk_file_intermed(fd, c, errh); in chunkqueue_write_chunk_file()
1447 …ueue_write_chunk (const int fd, chunkqueue * const restrict cq, log_error_st * const restrict errh) in chunkqueue_write_chunk() argument
1455 return chunkqueue_write_chunk_file(fd, c, errh); in chunkqueue_write_chunk()
1464 …te_chunk_to_pipe (const int fd, chunkqueue * const restrict cq, log_error_st * const restrict errh) in chunkqueue_write_chunk_to_pipe() argument
1472 return (0 == chunk_open_file_chunk(c, errh)) in chunkqueue_write_chunk_to_pipe()
1477 return chunkqueue_write_chunk(fd, cq, errh); in chunkqueue_write_chunk_to_pipe()
1554 log_error_st * const errh) in chunkqueue_peek_data() argument
1579 if (c->file.fd >= 0 || 0 == chunk_open_file_chunk(c, errh)) { in chunkqueue_peek_data()
1602 ? chunkqueue_chunk_file_view(c, len, errh) in chunkqueue_peek_data()
1610 log_error(errh, __FILE__, __LINE__, in chunkqueue_peek_data()
1628 log_perror(errh, __FILE__, __LINE__, "read(\"%s\")", in chunkqueue_peek_data()
1662 log_error_st * const errh) in chunkqueue_read_data() argument
1666 if (chunkqueue_peek_data(cq, &ptr, &len, errh) < 0 || len != dlen) in chunkqueue_read_data()
1675 chunkqueue_read_squash (chunkqueue * const restrict cq, log_error_st * const restrict errh) in chunkqueue_read_squash() argument
1689 int rc = chunkqueue_peek_data(cq, &data, &dlen, errh); in chunkqueue_read_squash()
1705 chunkqueue_chunk_file_viewadj (chunk * const c, off_t n, log_error_st * restrict errh) in chunkqueue_chunk_file_viewadj() argument
1718 if (c->file.fd < 0 && 0 != chunk_open_file_chunk(c, errh)) { in chunkqueue_chunk_file_viewadj()