1067

pending completion

Build # 1067

Build Type

push

travis-ci

Committed by

jmuchemb

Commit Message

<a href="https://github.com/zopefoundation/ZODB/commit/<a class=hub.com/zopefoundation/ZODB/commit/<a class="double-link" href="https://git"><a class=hub.com/zopefoundation/ZODB/commit/<a class="double-link" href="https://git"><a class=hub.com/zopefoundation/ZODB/commit/<a class="double-link" href="https://git"><a class=hub.com/zopefoundation/ZODB/commit/4aa6218584edc7412ed24470977c7b86243c61cf">4aa621858">&lt;a href=&quot;https://github.com/zopefoundation/ZODB/commit/</a><a class="double-link" href="https://github.com/zopefoundation/ZODB/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/zopefoundation/ZODB/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/zopefoundation/ZODB/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/zopefoundation/ZODB/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/zopefoundation/ZODB/commit/4aa6218584edc7412ed24470977c7b86243c61cf">4aa621858</a><a href="https://github.com/zopefoundation/ZODB/commit/4aa6218584edc7412ed24470977c7b86243c61cf">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/zopefoundation/ZODB/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/zopefoundation/ZODB/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/zopefoundation/ZODB/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/zopefoundation/ZODB/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/zopefoundation/ZODB/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/zopefoundation/ZODB/commit/4aa6218584edc7412ed24470977c7b86243c61cf&quot;&gt;4aa621858&lt;/a&gt;&lt;a href=&quot;https://github.com/zopefoundation/ZODB/commit/4aa6218584edc7412ed24470977c7b86243c61cf&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/zopefoundation/ZODB/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/zopefou... (continued)

Run Details

6453 of 8543 relevant lines covered (75.54%)

3.78 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/ZODB/transact.py

##############################################################################
#
# Copyright (c) 2003 Zope Foundation and Contributors.
# All Rights Reserved.
#
# This software is subject to the provisions of the Zope Public License,
# Version 2.1 (ZPL).  A copy of the ZPL should accompany this distribution.
# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
# FOR A PARTICULAR PURPOSE
#
##############################################################################
"""Tools to simplify transactions within applications."""

from ZODB.POSException import ReadConflictError, ConflictError
import transaction

def _commit(note):
    t = transaction.get()
    if note:
        t.note(note)
    t.commit()

def transact(f, note=None, retries=5):
    """Returns transactional version of function argument f.

    Higher-order function that converts a regular function into
    a transactional function.  The transactional function will
    retry up to retries time before giving up.  If note, it will
    be added to the transaction metadata when it commits.

    The retries occur on ConflictErrors.  If some other
    TransactionError occurs, the transaction will not be retried.
    """

    # TODO:  deal with ZEO disconnected errors?

    def g(*args, **kwargs):
        n = retries
        while n:
            n -= 1
            try:
                r = f(*args, **kwargs)
            except ReadConflictError as msg:
                # the only way ReadConflictError can happen here is due to
                # simultaneous pack removing objects revision that f could try
                # to load.
                transaction.abort()
                if not n:
                    raise
                continue
            try:
                _commit(note)
            except ConflictError as msg:
                transaction.abort()
                if not n:
                    raise
                continue
            return r
        raise RuntimeError("couldn't commit transaction")
    return g

1	##############################################################################
2	#
3	# Copyright (c) 2003 Zope Foundation and Contributors.
4	# All Rights Reserved.
5	#
6	# This software is subject to the provisions of the Zope Public License,
7	# Version 2.1 (ZPL). A copy of the ZPL should accompany this distribution.
8	# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
9	# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
10	# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
11	# FOR A PARTICULAR PURPOSE
12	#
13	##############################################################################
14	"""Tools to simplify transactions within applications."""	×
15
16	from ZODB.POSException import ReadConflictError, ConflictError	×
17	import transaction	×
18
19	def _commit(note):	×
20	t = transaction.get()	×
21	if note:	×
22	t.note(note)	×
23	t.commit()	×
24
25	def transact(f, note=None, retries=5):	×
26	"""Returns transactional version of function argument f.
27
28	Higher-order function that converts a regular function into
29	a transactional function. The transactional function will
30	retry up to retries time before giving up. If note, it will
31	be added to the transaction metadata when it commits.
32
33	The retries occur on ConflictErrors. If some other
34	TransactionError occurs, the transaction will not be retried.
35	"""
36
37	# TODO: deal with ZEO disconnected errors?
38
39	def g(args, *kwargs):	×
40	n = retries	×
41	while n:	×
42	n -= 1	×
43	try:	×
44	r = f(args, *kwargs)	×
45	except ReadConflictError as msg:	×
46	# the only way ReadConflictError can happen here is due to
47	# simultaneous pack removing objects revision that f could try
48	# to load.
49	transaction.abort()	×
50	if not n:	×
51	raise	×
52	continue	×
53	try:	×
54	_commit(note)	×
55	except ConflictError as msg:	×
56	transaction.abort()	×
57	if not n:	×
58	raise	×
59	continue	×
60	return r	×
61	raise RuntimeError("couldn't commit transaction")	×
62	return g	×

zopefoundation / ZODB / 1067

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous