Lines Matching full:writer
98 writer(NULL),
115 PendingOp() : disk_entry(NULL), backend(NULL), writer(NULL), callback(NULL) {}
120 WorkItem* writer;
380 entry->writer = NULL;
391 delete pending_op->writer;
448 MetadataWriter* writer = new MetadataWriter(trans);
450 // The writer will self destruct when done.
451 writer->Write(url, expected_response_time, buf, buf_len);
508 if (pending_op->writer) {
516 pending_op->writer = item.release();
523 pending_op->writer->ClearCallback();
539 DCHECK(pending_op->writer);
603 DCHECK(entry->writer || !entry->readers.empty());
611 if (pending_op->writer) {
618 pending_op->writer = item;
633 DCHECK(!entry->writer);
660 DCHECK(!entry->writer);
734 if (pending_op->writer) {
741 pending_op->writer = item;
760 if (pending_op->writer) {
767 pending_op->writer = item;
793 // We implement a basic reader/writer lock for the disk cache entry. If
794 // there is already a writer, then everyone has to wait for the writer to
801 if (entry->writer || entry->will_process_pending_queue) {
809 entry->writer = trans;
822 if (!entry->writer && !entry->pending_queue.empty())
831 // the writer, there is nothing to cancel.
835 if (entry->writer) {
836 DCHECK(trans == entry->writer);
855 entry->writer = NULL;
880 DCHECK(!entry->writer);
892 DCHECK(entry->writer);
893 DCHECK(entry->writer->mode() == Transaction::READ_WRITE);
896 Transaction* trans = entry->writer;
898 entry->writer = NULL;
913 Transaction* writer = i->second->writer;
914 return writer ? writer->GetWriterLoadState() : LOAD_STATE_WAITING_FOR_CACHE;
964 if (pending_op->writer->Matches(trans)) {
965 pending_op->writer->ClearTransaction();
966 pending_op->writer->ClearEntry();
998 DCHECK(!entry->writer);
1021 WorkItemOperation op = pending_op->writer->operation();
1027 scoped_ptr<WorkItem> item(pending_op->writer);
1040 // The writer transaction is gone.
1110 scoped_ptr<WorkItem> item(pending_op->writer);
1134 pending_op->writer = pending_item;
