Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(555)

Side by Side Diff: net/disk_cache/blockfile/in_flight_backend_io.h

Issue 1535363003: Switch to standard integer types in net/. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: stddef Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/disk_cache/blockfile/file_ios.cc ('k') | net/disk_cache/blockfile/in_flight_backend_io.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_ 5 #ifndef NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_
6 #define NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_ 6 #define NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_
7 7
8 #include <stdint.h>
9
8 #include <list> 10 #include <list>
9 #include <string> 11 #include <string>
10 12
13 #include "base/macros.h"
11 #include "base/memory/ref_counted.h" 14 #include "base/memory/ref_counted.h"
12 #include "base/single_thread_task_runner.h" 15 #include "base/single_thread_task_runner.h"
13 #include "base/time/time.h" 16 #include "base/time/time.h"
14 #include "net/base/completion_callback.h" 17 #include "net/base/completion_callback.h"
15 #include "net/base/io_buffer.h" 18 #include "net/base/io_buffer.h"
16 #include "net/disk_cache/blockfile/in_flight_io.h" 19 #include "net/disk_cache/blockfile/in_flight_io.h"
17 #include "net/disk_cache/blockfile/rankings.h" 20 #include "net/disk_cache/blockfile/rankings.h"
18 21
19 namespace disk_cache { 22 namespace disk_cache {
20 23
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
61 void EndEnumeration(scoped_ptr<Rankings::Iterator> iterator); 64 void EndEnumeration(scoped_ptr<Rankings::Iterator> iterator);
62 void OnExternalCacheHit(const std::string& key); 65 void OnExternalCacheHit(const std::string& key);
63 void CloseEntryImpl(EntryImpl* entry); 66 void CloseEntryImpl(EntryImpl* entry);
64 void DoomEntryImpl(EntryImpl* entry); 67 void DoomEntryImpl(EntryImpl* entry);
65 void FlushQueue(); // Dummy operation. 68 void FlushQueue(); // Dummy operation.
66 void RunTask(const base::Closure& task); 69 void RunTask(const base::Closure& task);
67 void ReadData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf, 70 void ReadData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf,
68 int buf_len); 71 int buf_len);
69 void WriteData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf, 72 void WriteData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf,
70 int buf_len, bool truncate); 73 int buf_len, bool truncate);
71 void ReadSparseData(EntryImpl* entry, int64 offset, net::IOBuffer* buf, 74 void ReadSparseData(EntryImpl* entry,
75 int64_t offset,
76 net::IOBuffer* buf,
72 int buf_len); 77 int buf_len);
73 void WriteSparseData(EntryImpl* entry, int64 offset, net::IOBuffer* buf, 78 void WriteSparseData(EntryImpl* entry,
79 int64_t offset,
80 net::IOBuffer* buf,
74 int buf_len); 81 int buf_len);
75 void GetAvailableRange(EntryImpl* entry, int64 offset, int len, int64* start); 82 void GetAvailableRange(EntryImpl* entry,
83 int64_t offset,
84 int len,
85 int64_t* start);
76 void CancelSparseIO(EntryImpl* entry); 86 void CancelSparseIO(EntryImpl* entry);
77 void ReadyForSparseIO(EntryImpl* entry); 87 void ReadyForSparseIO(EntryImpl* entry);
78 88
79 private: 89 private:
80 // There are two types of operations to proxy: regular backend operations are 90 // There are two types of operations to proxy: regular backend operations are
81 // executed sequentially (queued by the message loop). On the other hand, 91 // executed sequentially (queued by the message loop). On the other hand,
82 // operations targeted to a given entry can be long lived and support multiple 92 // operations targeted to a given entry can be long lived and support multiple
83 // simultaneous users (multiple reads or writes to the same entry), and they 93 // simultaneous users (multiple reads or writes to the same entry), and they
84 // are subject to throttling, so we keep an explicit queue. 94 // are subject to throttling, so we keep an explicit queue.
85 enum Operation { 95 enum Operation {
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
130 base::Time initial_time_; 140 base::Time initial_time_;
131 base::Time end_time_; 141 base::Time end_time_;
132 Rankings::Iterator* iterator_; 142 Rankings::Iterator* iterator_;
133 scoped_ptr<Rankings::Iterator> scoped_iterator_; 143 scoped_ptr<Rankings::Iterator> scoped_iterator_;
134 EntryImpl* entry_; 144 EntryImpl* entry_;
135 int index_; 145 int index_;
136 int offset_; 146 int offset_;
137 scoped_refptr<net::IOBuffer> buf_; 147 scoped_refptr<net::IOBuffer> buf_;
138 int buf_len_; 148 int buf_len_;
139 bool truncate_; 149 bool truncate_;
140 int64 offset64_; 150 int64_t offset64_;
141 int64* start_; 151 int64_t* start_;
142 base::TimeTicks start_time_; 152 base::TimeTicks start_time_;
143 base::Closure task_; 153 base::Closure task_;
144 154
145 DISALLOW_COPY_AND_ASSIGN(BackendIO); 155 DISALLOW_COPY_AND_ASSIGN(BackendIO);
146 }; 156 };
147 157
148 // The specialized controller that keeps track of current operations. 158 // The specialized controller that keeps track of current operations.
149 class InFlightBackendIO : public InFlightIO { 159 class InFlightBackendIO : public InFlightIO {
150 public: 160 public:
151 InFlightBackendIO( 161 InFlightBackendIO(
(...skipping 23 matching lines...) Expand all
175 void CloseEntryImpl(EntryImpl* entry); 185 void CloseEntryImpl(EntryImpl* entry);
176 void DoomEntryImpl(EntryImpl* entry); 186 void DoomEntryImpl(EntryImpl* entry);
177 void FlushQueue(const net::CompletionCallback& callback); 187 void FlushQueue(const net::CompletionCallback& callback);
178 void RunTask(const base::Closure& task, 188 void RunTask(const base::Closure& task,
179 const net::CompletionCallback& callback); 189 const net::CompletionCallback& callback);
180 void ReadData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf, 190 void ReadData(EntryImpl* entry, int index, int offset, net::IOBuffer* buf,
181 int buf_len, const net::CompletionCallback& callback); 191 int buf_len, const net::CompletionCallback& callback);
182 void WriteData( 192 void WriteData(
183 EntryImpl* entry, int index, int offset, net::IOBuffer* buf, 193 EntryImpl* entry, int index, int offset, net::IOBuffer* buf,
184 int buf_len, bool truncate, const net::CompletionCallback& callback); 194 int buf_len, bool truncate, const net::CompletionCallback& callback);
185 void ReadSparseData(EntryImpl* entry, int64 offset, net::IOBuffer* buf, 195 void ReadSparseData(EntryImpl* entry,
186 int buf_len, const net::CompletionCallback& callback); 196 int64_t offset,
187 void WriteSparseData(EntryImpl* entry, int64 offset, net::IOBuffer* buf, 197 net::IOBuffer* buf,
188 int buf_len, const net::CompletionCallback& callback); 198 int buf_len,
189 void GetAvailableRange(EntryImpl* entry, int64 offset, int len, int64* start, 199 const net::CompletionCallback& callback);
200 void WriteSparseData(EntryImpl* entry,
201 int64_t offset,
202 net::IOBuffer* buf,
203 int buf_len,
204 const net::CompletionCallback& callback);
205 void GetAvailableRange(EntryImpl* entry,
206 int64_t offset,
207 int len,
208 int64_t* start,
190 const net::CompletionCallback& callback); 209 const net::CompletionCallback& callback);
191 void CancelSparseIO(EntryImpl* entry); 210 void CancelSparseIO(EntryImpl* entry);
192 void ReadyForSparseIO(EntryImpl* entry, 211 void ReadyForSparseIO(EntryImpl* entry,
193 const net::CompletionCallback& callback); 212 const net::CompletionCallback& callback);
194 213
195 // Blocks until all operations are cancelled or completed. 214 // Blocks until all operations are cancelled or completed.
196 void WaitForPendingIO(); 215 void WaitForPendingIO();
197 216
198 scoped_refptr<base::SingleThreadTaskRunner> background_thread() { 217 scoped_refptr<base::SingleThreadTaskRunner> background_thread() {
199 return background_thread_; 218 return background_thread_;
(...skipping 15 matching lines...) Expand all
215 BackendImpl* backend_; 234 BackendImpl* backend_;
216 scoped_refptr<base::SingleThreadTaskRunner> background_thread_; 235 scoped_refptr<base::SingleThreadTaskRunner> background_thread_;
217 base::WeakPtrFactory<InFlightBackendIO> ptr_factory_; 236 base::WeakPtrFactory<InFlightBackendIO> ptr_factory_;
218 237
219 DISALLOW_COPY_AND_ASSIGN(InFlightBackendIO); 238 DISALLOW_COPY_AND_ASSIGN(InFlightBackendIO);
220 }; 239 };
221 240
222 } // namespace disk_cache 241 } // namespace disk_cache
223 242
224 #endif // NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_ 243 #endif // NET_DISK_CACHE_BLOCKFILE_IN_FLIGHT_BACKEND_IO_H_
OLDNEW
« no previous file with comments | « net/disk_cache/blockfile/file_ios.cc ('k') | net/disk_cache/blockfile/in_flight_backend_io.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698