Lines Matching refs:offset

41 			char * offset;
81 offset = tc->mem->ptr + tc->offset;
82 toSend = tc->mem->used - 1 - tc->offset;
84 chunks[i].iov_base = offset;
129 tc->offset += chunks[i].iov_len;
141 tc->offset += r;
169 abs_offset = c->file.start + c->offset;
182 abs_offset == (off_t)(c->file.mmap.offset + c->file.mmap.length)) {
212 c->file.mmap.offset += we_want_to_mmap;
215 c->file.mmap.offset = 0;
217 while (c->file.mmap.offset + we_want_to_mmap < c->file.start) {
218 c->file.mmap.offset += we_want_to_mmap;
223 we_want_to_send = c->file.length - c->offset;
224 to_mmap = (c->file.start + c->file.length) - c->file.mmap.offset;
227 if (abs_offset + we_want_to_send > c->file.mmap.offset + we_want_to_mmap) {
228 we_want_to_send = (c->file.mmap.offset + we_want_to_mmap) - abs_offset;
243 …->file.mmap.start = mmap(NULL, to_mmap, PROT_READ, MAP_SHARED, c->file.fd, c->file.mmap.offset))) {
272 toSend = (c->file.mmap.offset + c->file.mmap.length) - (abs_offset);
280 c->file.mmap.offset);
292 if ((r = mtcp_write(srv->mctx, fd, start + (abs_offset - c->file.mmap.offset), toSend)) < 0) {
309 c->offset += r;
313 if (c->offset == c->file.length) {
354 char * offset; in network_write_chunkqueue_mtcp_writev() local
363 offset = c->mem->ptr + c->offset; in network_write_chunkqueue_mtcp_writev()
364 toSend = c->mem->used - 1 - c->offset; in network_write_chunkqueue_mtcp_writev()
368 if ((r = send(fd, offset, toSend, 0)) < 0) { in network_write_chunkqueue_mtcp_writev()
375 if ((r = mtcp_write(srv->mctx, fd, offset, toSend)) < 0) { in network_write_chunkqueue_mtcp_writev()
393 c->offset += r; in network_write_chunkqueue_mtcp_writev()
397 if (c->offset == (off_t)c->mem->used - 1) { in network_write_chunkqueue_mtcp_writev()
408 off_t offset; in network_write_chunkqueue_mtcp_writev() local
419 offset = c->file.start + c->offset; in network_write_chunkqueue_mtcp_writev()
420 toSend = c->file.length - c->offset; in network_write_chunkqueue_mtcp_writev()
424 if (offset > sce->st.st_size) { in network_write_chunkqueue_mtcp_writev()
447 if ((r = write(fd, p + offset, toSend)) <= 0) { in network_write_chunkqueue_mtcp_writev()
470 lseek(ifd, offset, SEEK_SET); in network_write_chunkqueue_mtcp_writev()
506 c->offset += r; in network_write_chunkqueue_mtcp_writev()
510 if (c->offset == c->file.length) { in network_write_chunkqueue_mtcp_writev()