Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit0fdf6c3

Browse files
committed
index: Entries are now using flags internally, instead of reducing the flag information to just the stage ( just to be closer to the git-original )
1 parentac62760 commit0fdf6c3

File tree

4 files changed

+83
-60
lines changed

4 files changed

+83
-60
lines changed

‎lib/git/index/base.py‎

Lines changed: 52 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -9,15 +9,29 @@
99
importtempfile
1010
importos
1111
importsys
12-
importstat
1312
importsubprocess
1413
importglob
1514
fromcStringIOimportStringIO
1615

17-
fromtypimport*
16+
fromstatimport (
17+
S_ISLNK,
18+
S_ISDIR,
19+
S_IFMT,
20+
S_IFDIR,
21+
S_IFLNK,
22+
S_IFREG
23+
)
24+
25+
fromtypimport (
26+
BaseIndexEntry,
27+
IndexEntry,
28+
CE_NAMEMASK,
29+
CE_STAGESHIFT
30+
)
31+
1832
fromutilimport (
1933
TemporaryFileSwap,
20-
clear_cache,
34+
post_clear_cache,
2135
default_index,
2236
pack,
2337
unpack
@@ -75,7 +89,7 @@ class IndexFile(LazyMixin, diff.Diffable, Serializable):
7589
"""
7690
__slots__= ("repo","version","entries","_extension_data","_file_path" )
7791
_VERSION=2# latest version we support
78-
S_IFGITLINK=0160000
92+
S_IFGITLINK=0160000# a submodule
7993

8094
def__init__(self,repo,file_path=None):
8195
"""
@@ -141,12 +155,12 @@ def _read_entry(cls, stream):
141155
mtime=unpack(">8s",stream.read(8))[0]
142156
(dev,ino,mode,uid,gid,size,sha,flags)= \
143157
unpack(">LLLLLL20sH",stream.read(20+4*6+2))
144-
path_size=flags&0x0fff
158+
path_size=flags&CE_NAMEMASK
145159
path=stream.read(path_size)
146160

147161
real_size= ((stream.tell()-beginoffset+8)&~7)
148162
data=stream.read((beginoffset+real_size)-stream.tell())
149-
returnIndexEntry((mode,binascii.hexlify(sha),flags>>12,path,ctime,mtime,dev,ino,uid,gid,size))
163+
returnIndexEntry((mode,binascii.hexlify(sha),flags,path,ctime,mtime,dev,ino,uid,gid,size))
150164

151165
@classmethod
152166
def_read_header(cls,stream):
@@ -198,7 +212,7 @@ def _serialize(self, stream, ignore_tree_extension_data=False):
198212

199213
# body
200214
entries_sorted=self.entries.values()
201-
entries_sorted.sort(key=lambdae: (e[3],e[2]))# use path/stage as sort key
215+
entries_sorted.sort(key=lambdae: (e[3],e.stage))# use path/stage as sort key
202216
forentryinentries_sorted:
203217
self._write_cache_entry(stream,entry)
204218
# END for each entry
@@ -226,17 +240,18 @@ def _serialize(self, stream, ignore_tree_extension_data=False):
226240
def_write_cache_entry(cls,stream,entry):
227241
""" Write an IndexEntry to a stream """
228242
beginoffset=stream.tell()
229-
stream.write(entry[4])# ctime
230-
stream.write(entry[5])# mtime
243+
write=stream.write
244+
write(entry[4])# ctime
245+
write(entry[5])# mtime
231246
path=entry[3]
232-
plen=len(path)&0x0fff# path length
247+
plen=len(path)&CE_NAMEMASK# path length
233248
assertplen==len(path),"Path %s too long to fit into index"%entry[3]
234-
flags=plen|(entry[2]<<12)# stage and path length are 2 byte flags
235-
stream.write(pack(">LLLLLL20sH",entry[6],entry[7],entry[0],
249+
flags=plen|entry[2]
250+
write(pack(">LLLLLL20sH",entry[6],entry[7],entry[0],
236251
entry[8],entry[9],entry[10],binascii.unhexlify(entry[1]),flags))
237-
stream.write(path)
252+
write(path)
238253
real_size= ((stream.tell()-beginoffset+8)&~7)
239-
stream.write("\0"* ((beginoffset+real_size)-stream.tell()))
254+
write("\0"* ((beginoffset+real_size)-stream.tell()))
240255

241256
defwrite(self,file_path=None,ignore_tree_extension_data=False):
242257
"""
@@ -272,7 +287,7 @@ def write(self, file_path = None, ignore_tree_extension_data=False):
272287
iffile_pathisnotNone:
273288
self._file_path=file_path
274289

275-
@clear_cache
290+
@post_clear_cache
276291
@default_index
277292
defmerge_tree(self,rhs,base=None):
278293
"""Merge the given rhs treeish into the current index, possibly taking
@@ -383,24 +398,14 @@ def from_tree(cls, repo, *treeish, **kwargs):
383398
returnindex
384399

385400
@classmethod
386-
def_index_mode_to_tree_index_mode(cls,index_mode):
387-
"""
388-
Cleanup a index_mode value.
389-
This will return a index_mode that can be stored in a tree object.
390-
391-
``index_mode``
392-
Index_mode to clean up.
393-
"""
394-
ifstat.S_ISLNK(index_mode):
395-
returnstat.S_IFLNK
396-
elifstat.S_ISDIR(index_mode):
397-
returnstat.S_IFDIR
398-
elifstat.S_IFMT(index_mode)==cls.S_IFGITLINK:
401+
def_stat_mode_to_index_mode(cls,mode):
402+
"""Convert the given mode from a stat call to the corresponding index mode
403+
and return it"""
404+
ifS_ISLNK(mode):# symlinks
405+
returnS_IFLNK
406+
ifS_ISDIR(mode)orS_IFMT(mode)==cls.S_IFGITLINK:# submodules
399407
returncls.S_IFGITLINK
400-
ret=stat.S_IFREG|0644
401-
ret|= (index_mode&0111)
402-
returnret
403-
408+
returnS_IFREG|644| (mode&0100)# blobs with or without executable bit
404409

405410
# UTILITIES
406411
def_iter_expand_paths(self,paths):
@@ -479,7 +484,9 @@ def iter_blobs(self, predicate = lambda t: True):
479484
only if they match a given list of paths.
480485
"""
481486
forentryinself.entries.itervalues():
482-
mode=self._index_mode_to_tree_index_mode(entry.mode)
487+
# TODO: is it necessary to convert the mode ? We did that when adding
488+
# it to the index, right ?
489+
mode=self._stat_mode_to_index_mode(entry.mode)
483490
blob=Blob(self.repo,entry.sha,mode,entry.path)
484491
blob.size=entry.size
485492
output= (entry.stage,blob)
@@ -636,7 +643,6 @@ def _preprocess_add_items(self, items):
636643
# END for each item
637644
return (paths,entries)
638645

639-
@clear_cache
640646
@default_index
641647
defadd(self,items,force=True,fprogress=lambda*args:None,path_rewriter=None):
642648
"""Add files from the working tree, specific blobs or BaseIndexEntries
@@ -739,7 +745,7 @@ def store_path(filepath):
739745
"""Store file at filepath in the database and return the base index entry"""
740746
st=os.lstat(filepath)# handles non-symlinks as well
741747
stream=None
742-
ifstat.S_ISLNK(st.st_mode):
748+
ifS_ISLNK(st.st_mode):
743749
stream=StringIO(os.readlink(filepath))
744750
else:
745751
stream=open(filepath,'rb')
@@ -759,13 +765,6 @@ def store_path(filepath):
759765
forfilepathinself._iter_expand_paths(paths):
760766
entries_added.append(store_path(filepath))
761767
# END for each filepath
762-
763-
# add the new entries to this instance, and write it
764-
forentryinentries_added:
765-
self.entries[(entry.path,0)]=IndexEntry.from_base(entry)
766-
767-
# finally write the changed index
768-
self.write()
769768
# END path handling
770769

771770

@@ -823,6 +822,14 @@ def store_path(filepath):
823822
self._flush_stdin_and_wait(proc,ignore_stdout=True)
824823
entries_added.extend(entries)
825824
# END if there are base entries
825+
826+
# FINALIZE
827+
# add the new entries to this instance, and write it
828+
forentryinentries_added:
829+
self.entries[(entry.path,0)]=IndexEntry.from_base(entry)
830+
831+
# finally write the changed index
832+
self.write()
826833

827834
returnentries_added
828835

@@ -840,7 +847,7 @@ def _items_to_rela_paths(self, items):
840847
# END for each item
841848
returnpaths
842849

843-
@clear_cache
850+
@post_clear_cache
844851
@default_index
845852
defremove(self,items,working_tree=False,**kwargs):
846853
"""
@@ -893,7 +900,7 @@ def remove(self, items, working_tree=False, **kwargs):
893900
# rm 'path'
894901
return [p[4:-1]forpinremoved_paths ]
895902

896-
@clear_cache
903+
@post_clear_cache
897904
@default_index
898905
defmove(self,items,skip_errors=False,**kwargs):
899906
"""
@@ -1127,7 +1134,7 @@ def handle_stderr(proc, iter_checked_out_files):
11271134
# END paths handling
11281135
assert"Should not reach this point"
11291136

1130-
@clear_cache
1137+
@post_clear_cache
11311138
@default_index
11321139
defreset(self,commit='HEAD',working_tree=False,paths=None,head=False,**kwargs):
11331140
"""

‎lib/git/index/typ.py‎

Lines changed: 25 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,15 @@
77

88
__all__= ('BlobFilter','BaseIndexEntry','IndexEntry')
99

10+
#{ Invariants
11+
CE_NAMEMASK=0x0fff
12+
CE_STAGEMASK=0x3000
13+
CE_EXTENDED=0x4000
14+
CE_VALID=0x8000
15+
CE_STAGESHIFT=12
16+
17+
#} END invariants
18+
1019
classBlobFilter(object):
1120
"""
1221
Predicate to be used by iter_blobs allowing to filter only return blobs which
@@ -64,17 +73,22 @@ def stage(self):
6473
6574
:note: For more information, see http://www.kernel.org/pub/software/scm/git/docs/git-read-tree.html
6675
"""
67-
returnself[2]
76+
return(self[2]&CE_STAGEMASK)>>CE_STAGESHIFT
6877

6978
@property
7079
defpath(self):
7180
""":return: our path relative to the repository working tree root"""
7281
returnself[3]
7382

83+
@property
84+
defflags(self):
85+
""":return: flags stored with this entry"""
86+
returnself[2]
87+
7488
@classmethod
7589
deffrom_blob(cls,blob,stage=0):
7690
""":return: Fully equipped BaseIndexEntry at the given stage"""
77-
returncls((blob.mode,blob.sha,stage,blob.path))
91+
returncls((blob.mode,blob.sha,stage<<CE_STAGESHIFT,blob.path))
7892

7993

8094
classIndexEntry(BaseIndexEntry):
@@ -121,22 +135,24 @@ def gid(self):
121135
defsize(self):
122136
""":return: Uncompressed size of the blob """
123137
returnself[10]
124-
138+
125139
@classmethod
126-
deffrom_base(cls,base):
140+
deffrom_base(cls,base,actual_value=False):
127141
"""
128142
:return:
129143
Minimal entry as created from the given BaseIndexEntry instance.
130144
Missing values will be set to null-like values
131145
132-
:param base: Instance of type BaseIndexEntry"""
146+
:param base: Instance of type BaseIndexEntry
147+
:param actual_value: if set, instead of writing 0 values for fields that
148+
don't exist in the BaseEntry, the actual values will be written in."""
133149
time=pack(">LL",0,0)
134-
returnIndexEntry((base.mode,base.sha,base.stage,base.path,time,time,0,0,0,0,0))
150+
returnIndexEntry((base.mode,base.sha,base.flags,base.path,time,time,0,0,0,0,0))
135151

136152
@classmethod
137-
deffrom_blob(cls,blob):
138-
""":return: Minimal entry resembling the given blobobjecft"""
153+
deffrom_blob(cls,blob,stage=0):
154+
""":return: Minimal entry resembling the given blobobject"""
139155
time=pack(">LL",0,0)
140-
returnIndexEntry((blob.mode,blob.sha,0,blob.path,time,time,0,0,0,0,blob.size))
156+
returnIndexEntry((blob.mode,blob.sha,stage<<CE_STAGESHIFT,blob.path,time,time,0,0,0,0,blob.size))
141157

142158

‎lib/git/index/util.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
importtempfile
44
importos
55

6-
__all__= ('TemporaryFileSwap','clear_cache','default_index' )
6+
__all__= ('TemporaryFileSwap','post_clear_cache','default_index' )
77

88
#{ Aliases
99
pack=struct.pack
@@ -36,7 +36,7 @@ def __del__(self):
3636

3737
#{ Decorators
3838

39-
defclear_cache(func):
39+
defpost_clear_cache(func):
4040
"""Decorator for functions that alter the index using the git command. This would
4141
invalidate our possibly existing entries dictionary which is why it must be
4242
deleted to allow it to be lazily reread later.
@@ -45,14 +45,14 @@ def clear_cache(func):
4545
This decorator will not be required once all functions are implemented
4646
natively which in fact is possible, but probably not feasible performance wise.
4747
"""
48-
defclear_cache_if_not_raised(self,*args,**kwargs):
48+
defpost_clear_cache_if_not_raised(self,*args,**kwargs):
4949
rval=func(self,*args,**kwargs)
5050
self._delete_entries_cache()
5151
returnrval
5252

5353
# END wrapper method
54-
clear_cache_if_not_raised.__name__=func.__name__
55-
returnclear_cache_if_not_raised
54+
post_clear_cache_if_not_raised.__name__=func.__name__
55+
returnpost_clear_cache_if_not_raised
5656

5757
defdefault_index(func):
5858
"""Decorator assuring the wrapped method may only run if we are the default

‎lib/git/objects/tree.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ class Tree(base.IndexObject, diff.Diffable, utils.Traversable, utils.Serializabl
121121
__slots__="_cache"
122122

123123
# actual integer ids for comparison
124-
commit_id=016
124+
commit_id=016# equals stat.S_IFDIR | stat.S_IFLNK - a directory link
125125
blob_id=010
126126
symlink_id=012
127127
tree_id=004

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp