equal
deleted
inserted
replaced
224 |
224 |
225 error: |
225 error: |
226 return -1; |
226 return -1; |
227 } |
227 } |
228 |
228 |
|
229 int cache_req_pull (struct cache_req *req, int fd, size_t *size) { |
|
230 if (req->op->state != OP_STATE_READ && req->op->state != OP_STATE_WRITE) |
|
231 ERROR("req is not readable"); |
|
232 |
|
233 return cache_op_pull(req->op, fd, &req->read_offset, size); |
|
234 |
|
235 error: |
|
236 return -1; |
|
237 } |
|
238 |
229 int cache_req_done (struct cache_req *req) { |
239 int cache_req_done (struct cache_req *req) { |
230 if (req->op->state != OP_STATE_WRITE || !req->is_write) |
240 if (req->op->state != OP_STATE_WRITE || !req->is_write) |
231 ERROR("req not in write mode"); |
241 ERROR("req not in write mode"); |
232 |
242 |
233 return cache_op_done(req->op); |
243 return cache_op_done(req->op); |