Mercurial > traipse_dev

comparison upmana/mercurial/changelog.py @ 121:496dbf12a6cb alpha

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Traipse Alpha 'OpenRPG' {091030-00} Traipse is a distribution of OpenRPG that is designed to be easy to setup and go. Traipse also makes it easy for developers to work on code without fear of sacrifice. 'Ornery-Orc' continues the trend of 'Grumpy' and adds fixes to the code. 'Ornery-Orc's main goal is to offer more advanced features and enhance the productivity of the user. Update Summary (Cleaning up for Beta): Adds Bookmarks (Alpha) with cool Smiley Star and Plus Symbol images! Changes made to the map for increased portability. SnowDog has changes planned in Core, though. Added an initial push to the BCG. Not much to see, just shows off how it is re-writing Main code. Fix to remote admin commands Minor fix to texted based server, works in /System/ folder Some Core changes to gametree to correctly disply Pretty Print, thanks David! Fix to Splitter Nodes not being created. Added images to Plugin Control panel for Autostart feature Fix to massive amounts of images loading; from Core fix to gsclient so with_statement imports Added 'boot' command to remote admin Prep work in Pass tool for remote admin rankings and different passwords, ei, Server, Admin, Moderator, etc. Remote Admin Commands more organized, more prep work. Added Confirmation window for sent nodes. Minor changes to allow for portability to an OpenSUSE linux OS (hopefully without breaking) {091028} Made changes to gametree to start working with Element Tree, mostly from Core Minor changes to Map to start working with Element Tree, from Core Preliminary changes to map efficiency, from FlexiRPG Miniatures Layer pop up box allows users to turn off Mini labels, from FlexiRPG Changes to main.py to start working with Element Tree {091029} Changes made to server to start working with Element Tree. Changes made to Meta Server Lib. Prepping test work for a multi meta network page. Minor bug fixed with mini to gametree Zoom Mouse plugin added. {091030} Getting ready for Beta. Server needs debugging so Alpha remains bugged. Plugin UI code cleaned. Auto start works with a graphic, pop-up asks to enable or disable plugin. Update Manager now has a partially working Status Bar. Status Bar captures terminal text, so Merc out put is visible. Manifest.xml file, will be renamed, is now much cleaner. Debug Console has a clear button and a Report Bug button. Prep work for a Term2Win class in Debug Console. Known: Current Alpha fails in Windows.
author sirebral
date Fri, 30 Oct 2009 22:21:40 -0500
parents
children
comparison
equal deleted inserted replaced
120:d86e762a994f 121:496dbf12a6cb
1 # changelog.py - changelog class for mercurial
2 #
3 # Copyright 2005-2007 Matt Mackall <mpm@selenic.com>
4 #
5 # This software may be used and distributed according to the terms of the
6 # GNU General Public License version 2, incorporated herein by reference.
7
8 from node import bin, hex, nullid
9 from i18n import _
10 import util, error, revlog, encoding
11
12 def _string_escape(text):
13 """
14 >>> d = {'nl': chr(10), 'bs': chr(92), 'cr': chr(13), 'nul': chr(0)}
15 >>> s = "ab%(nl)scd%(bs)s%(bs)sn%(nul)sab%(cr)scd%(bs)s%(nl)s" % d
16 >>> s
17 'ab\\ncd\\\\\\\\n\\x00ab\\rcd\\\\\\n'
18 >>> res = _string_escape(s)
19 >>> s == res.decode('string_escape')
20 True
21 """
22 # subset of the string_escape codec
23 text = text.replace('\\', '\\\\').replace('\n', '\\n').replace('\r', '\\r')
24 return text.replace('\0', '\\0')
25
26 def decodeextra(text):
27 extra = {}
28 for l in text.split('\0'):
29 if l:
30 k, v = l.decode('string_escape').split(':', 1)
31 extra[k] = v
32 return extra
33
34 def encodeextra(d):
35 # keys must be sorted to produce a deterministic changelog entry
36 items = [_string_escape('%s:%s' % (k, d[k])) for k in sorted(d)]
37 return "\0".join(items)
38
39 class appender(object):
40 '''the changelog index must be updated last on disk, so we use this class
41 to delay writes to it'''
42 def __init__(self, fp, buf):
43 self.data = buf
44 self.fp = fp
45 self.offset = fp.tell()
46 self.size = util.fstat(fp).st_size
47
48 def end(self):
49 return self.size + len("".join(self.data))
50 def tell(self):
51 return self.offset
52 def flush(self):
53 pass
54 def close(self):
55 self.fp.close()
56
57 def seek(self, offset, whence=0):
58 '''virtual file offset spans real file and data'''
59 if whence == 0:
60 self.offset = offset
61 elif whence == 1:
62 self.offset += offset
63 elif whence == 2:
64 self.offset = self.end() + offset
65 if self.offset < self.size:
66 self.fp.seek(self.offset)
67
68 def read(self, count=-1):
69 '''only trick here is reads that span real file and data'''
70 ret = ""
71 if self.offset < self.size:
72 s = self.fp.read(count)
73 ret = s
74 self.offset += len(s)
75 if count > 0:
76 count -= len(s)
77 if count != 0:
78 doff = self.offset - self.size
79 self.data.insert(0, "".join(self.data))
80 del self.data[1:]
81 s = self.data[0][doff:doff+count]
82 self.offset += len(s)
83 ret += s
84 return ret
85
86 def write(self, s):
87 self.data.append(str(s))
88 self.offset += len(s)
89
90 class changelog(revlog.revlog):
91 def __init__(self, opener):
92 self._realopener = opener
93 self._delayed = False
94 revlog.revlog.__init__(self, self._delayopener, "00changelog.i")
95
96 def delayupdate(self):
97 "delay visibility of index updates to other readers"
98 self._delayed = True
99 self._delaycount = len(self)
100 self._delaybuf = []
101 self._delayname = None
102
103 def finalize(self, tr):
104 "finalize index updates"
105 self._delayed = False
106 # move redirected index data back into place
107 if self._delayname:
108 util.rename(self._delayname + ".a", self._delayname)
109 elif self._delaybuf:
110 fp = self.opener(self.indexfile, 'a')
111 fp.write("".join(self._delaybuf))
112 fp.close()
113 self._delaybuf = []
114 # split when we're done
115 self.checkinlinesize(tr)
116
117 def _delayopener(self, name, mode='r'):
118 fp = self._realopener(name, mode)
119 # only divert the index
120 if not self._delayed or not name == self.indexfile:
121 return fp
122 # if we're doing an initial clone, divert to another file
123 if self._delaycount == 0:
124 self._delayname = fp.name
125 if not len(self):
126 # make sure to truncate the file
127 mode = mode.replace('a', 'w')
128 return self._realopener(name + ".a", mode)
129 # otherwise, divert to memory
130 return appender(fp, self._delaybuf)
131
132 def readpending(self, file):
133 r = revlog.revlog(self.opener, file)
134 self.index = r.index
135 self.nodemap = r.nodemap
136 self._chunkcache = r._chunkcache
137
138 def writepending(self):
139 "create a file containing the unfinalized state for pretxnchangegroup"
140 if self._delaybuf:
141 # make a temporary copy of the index
142 fp1 = self._realopener(self.indexfile)
143 fp2 = self._realopener(self.indexfile + ".a", "w")
144 fp2.write(fp1.read())
145 # add pending data
146 fp2.write("".join(self._delaybuf))
147 fp2.close()
148 # switch modes so finalize can simply rename
149 self._delaybuf = []
150 self._delayname = fp1.name
151
152 if self._delayname:
153 return True
154
155 return False
156
157 def checkinlinesize(self, tr, fp=None):
158 if self.opener == self._delayopener:
159 return
160 return revlog.revlog.checkinlinesize(self, tr, fp)
161
162 def read(self, node):
163 """
164 format used:
165 nodeid\n : manifest node in ascii
166 user\n : user, no \n or \r allowed
167 time tz extra\n : date (time is int or float, timezone is int)
168 : extra is metadatas, encoded and separated by '\0'
169 : older versions ignore it
170 files\n\n : files modified by the cset, no \n or \r allowed
171 (.*) : comment (free text, ideally utf-8)
172
173 changelog v0 doesn't use extra
174 """
175 text = self.revision(node)
176 if not text:
177 return (nullid, "", (0, 0), [], "", {'branch': 'default'})
178 last = text.index("\n\n")
179 desc = encoding.tolocal(text[last + 2:])
180 l = text[:last].split('\n')
181 manifest = bin(l[0])
182 user = encoding.tolocal(l[1])
183
184 extra_data = l[2].split(' ', 2)
185 if len(extra_data) != 3:
186 time = float(extra_data.pop(0))
187 try:
188 # various tools did silly things with the time zone field.
189 timezone = int(extra_data[0])
190 except:
191 timezone = 0
192 extra = {}
193 else:
194 time, timezone, extra = extra_data
195 time, timezone = float(time), int(timezone)
196 extra = decodeextra(extra)
197 if not extra.get('branch'):
198 extra['branch'] = 'default'
199 files = l[3:]
200 return (manifest, user, (time, timezone), files, desc, extra)
201
202 def add(self, manifest, files, desc, transaction, p1, p2,
203 user, date=None, extra={}):
204 user = user.strip()
205 # An empty username or a username with a "\n" will make the
206 # revision text contain two "\n\n" sequences -> corrupt
207 # repository since read cannot unpack the revision.
208 if not user:
209 raise error.RevlogError(_("empty username"))
210 if "\n" in user:
211 raise error.RevlogError(_("username %s contains a newline")
212 % repr(user))
213
214 # strip trailing whitespace and leading and trailing empty lines
215 desc = '\n'.join([l.rstrip() for l in desc.splitlines()]).strip('\n')
216
217 user, desc = encoding.fromlocal(user), encoding.fromlocal(desc)
218
219 if date:
220 parseddate = "%d %d" % util.parsedate(date)
221 else:
222 parseddate = "%d %d" % util.makedate()
223 if extra and extra.get("branch") in ("default", ""):
224 del extra["branch"]
225 if extra:
226 extra = encodeextra(extra)
227 parseddate = "%s %s" % (parseddate, extra)
228 l = [hex(manifest), user, parseddate] + sorted(files) + ["", desc]
229 text = "\n".join(l)
230 return self.addrevision(text, transaction, len(self), p1, p2)