webkit/fileapi/syncable/local_file_sync_status.cc - Issue 15806012: Move webkit/fileapi/syncable/* code to webkit/browser/fileapi (final!)

Side by Side Diff: webkit/fileapi/syncable/local_file_sync_status.cc

Issue 15806012: Move webkit/fileapi/syncable/* code to webkit/browser/fileapi (final!) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src

Patch Set: Created 7 years, 6 months 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 | Annotate | Revision Log

OLD	NEW
	(Empty)
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 "webkit/fileapi/syncable/local_file_sync_status.h"

6

7 #include "base/logging.h"

8

9 using fileapi::FileSystemURL;

10 using fileapi::FileSystemURLSet;

11

12 namespace sync_file_system {

13

14 LocalFileSyncStatus::LocalFileSyncStatus() {}

15

16 LocalFileSyncStatus::~LocalFileSyncStatus() {}

17

18 void LocalFileSyncStatus::StartWriting(const FileSystemURL& url) {

19 DCHECK(CalledOnValidThread());

20 DCHECK(!IsChildOrParentSyncing(url));

21 writing_[url]++;

22 }

23

24 void LocalFileSyncStatus::EndWriting(const FileSystemURL& url) {

25 DCHECK(CalledOnValidThread());

26 int count = --writing_[url];

27 if (count == 0) {

28 writing_.erase(url);

29 FOR_EACH_OBSERVER(Observer, observer_list_, OnSyncEnabled(url));

30 }

31 }

32

33 void LocalFileSyncStatus::StartSyncing(const FileSystemURL& url) {

34 DCHECK(CalledOnValidThread());

35 DCHECK(!IsChildOrParentWriting(url));

36 DCHECK(!IsChildOrParentSyncing(url));

37 syncing_.insert(url);

38 }

39

40 void LocalFileSyncStatus::EndSyncing(const FileSystemURL& url) {

41 DCHECK(CalledOnValidThread());

42 syncing_.erase(url);

43 FOR_EACH_OBSERVER(Observer, observer_list_, OnWriteEnabled(url));

44 }

45

46 bool LocalFileSyncStatus::IsWriting(const FileSystemURL& url) const {

47 DCHECK(CalledOnValidThread());

48 return IsChildOrParentWriting(url);

49 }

50

51 bool LocalFileSyncStatus::IsWritable(const FileSystemURL& url) const {

52 DCHECK(CalledOnValidThread());

53 return !IsChildOrParentSyncing(url);

54 }

55

56 bool LocalFileSyncStatus::IsSyncable(const FileSystemURL& url) const {

57 DCHECK(CalledOnValidThread());

58 return !IsChildOrParentSyncing(url) && !IsChildOrParentWriting(url);

59 }

60

61 void LocalFileSyncStatus::AddObserver(Observer* observer) {

62 DCHECK(CalledOnValidThread());

63 observer_list_.AddObserver(observer);

64 }

65

66 void LocalFileSyncStatus::RemoveObserver(Observer* observer) {

67 DCHECK(CalledOnValidThread());

68 observer_list_.RemoveObserver(observer);

69 }

70

71 bool LocalFileSyncStatus::IsChildOrParentWriting(

72 const FileSystemURL& url) const {

73 DCHECK(CalledOnValidThread());

74 URLCountMap::const_iterator upper = writing_.upper_bound(url);

75 URLCountMap::const_reverse_iterator rupper(upper);

76 if (upper != writing_.end() && url.IsParent(upper->first))

77 return true;

78 if (rupper != writing_.rend() &&

79 (rupper->first == url \|\| rupper->first.IsParent(url)))

80 return true;

81 return false;

82 }

83

84 bool LocalFileSyncStatus::IsChildOrParentSyncing(

85 const FileSystemURL& url) const {

86 DCHECK(CalledOnValidThread());

87 FileSystemURLSet::const_iterator upper = syncing_.upper_bound(url);

88 FileSystemURLSet::const_reverse_iterator rupper(upper);

89 if (upper != syncing_.end() && url.IsParent(*upper))

90 return true;

91 if (rupper != syncing_.rend() &&

92 (*rupper == url \|\| rupper->IsParent(url)))

93 return true;

94 return false;

95 }

96

97 } // namespace sync_file_system

OLD	NEW

« no previous file with comments | « webkit/fileapi/syncable/local_file_sync_status.h ('k') | webkit/fileapi/syncable/local_file_sync_status_unittest.cc » ('j') | no next file with comments »