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 3// found in the LICENSE file. 4 5#include "net/base/file_stream.h" 6 7#include "net/base/file_stream_context.h" 8#include "net/base/net_errors.h" 9 10namespace net { 11 12FileStream::FileStream(const scoped_refptr<base::TaskRunner>& task_runner) 13 : context_(new Context(task_runner)) { 14} 15 16FileStream::FileStream(base::File file, 17 const scoped_refptr<base::TaskRunner>& task_runner) 18 : context_(new Context(file.Pass(), task_runner)) { 19} 20 21FileStream::~FileStream() { 22 context_.release()->Orphan(); 23} 24 25int FileStream::Open(const base::FilePath& path, int open_flags, 26 const CompletionCallback& callback) { 27 if (IsOpen()) { 28 DLOG(FATAL) << "File is already open!"; 29 return ERR_UNEXPECTED; 30 } 31 32 DCHECK(open_flags & base::File::FLAG_ASYNC); 33 context_->Open(path, open_flags, callback); 34 return ERR_IO_PENDING; 35} 36 37int FileStream::Close(const CompletionCallback& callback) { 38 context_->Close(callback); 39 return ERR_IO_PENDING; 40} 41 42bool FileStream::IsOpen() const { 43 return context_->file().IsValid(); 44} 45 46int FileStream::Seek(base::File::Whence whence, 47 int64 offset, 48 const Int64CompletionCallback& callback) { 49 if (!IsOpen()) 50 return ERR_UNEXPECTED; 51 52 context_->Seek(whence, offset, callback); 53 return ERR_IO_PENDING; 54} 55 56int FileStream::Read(IOBuffer* buf, 57 int buf_len, 58 const CompletionCallback& callback) { 59 if (!IsOpen()) 60 return ERR_UNEXPECTED; 61 62 // read(..., 0) will return 0, which indicates end-of-file. 63 DCHECK_GT(buf_len, 0); 64 65 return context_->Read(buf, buf_len, callback); 66} 67 68int FileStream::Write(IOBuffer* buf, 69 int buf_len, 70 const CompletionCallback& callback) { 71 if (!IsOpen()) 72 return ERR_UNEXPECTED; 73 74 DCHECK_GE(buf_len, 0); 75 return context_->Write(buf, buf_len, callback); 76} 77 78int FileStream::Flush(const CompletionCallback& callback) { 79 if (!IsOpen()) 80 return ERR_UNEXPECTED; 81 82 context_->Flush(callback); 83 return ERR_IO_PENDING; 84} 85 86const base::File& FileStream::GetFileForTesting() const { 87 return context_->file(); 88} 89 90} // namespace net 91