Skip to content

Commit 8115b1b

Browse files
Reorder API for clarit
1 parent 35c3c11 commit 8115b1b

File tree

1 file changed

+13
-12
lines changed

1 file changed

+13
-12
lines changed

ddtrace/profiling/collector/_lock.py

Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -69,12 +69,24 @@ def __init__(
6969
self._self_acquired_at: int = 0
7070
self._self_name: Optional[str] = None
7171

72+
def acquire(self, *args: Any, **kwargs: Any) -> Any:
73+
return self._acquire(self.__wrapped__.acquire, *args, **kwargs)
74+
75+
def release(self, *args: Any, **kwargs: Any) -> Any:
76+
return self._release(self.__wrapped__.release, *args, **kwargs)
77+
7278
def __aenter__(self, *args: Any, **kwargs: Any) -> Any:
7379
return self._acquire(self.__wrapped__.__aenter__, *args, **kwargs)
7480

7581
def __aexit__(self, *args: Any, **kwargs: Any) -> Any:
7682
return self._release(self.__wrapped__.__aexit__, *args, **kwargs)
7783

84+
def __enter__(self, *args: Any, **kwargs: Any) -> Any:
85+
return self._acquire(self.__wrapped__.__enter__, *args, **kwargs)
86+
87+
def __exit__(self, *args: Any, **kwargs: Any) -> None:
88+
self._release(self.__wrapped__.__exit__, *args, **kwargs)
89+
7890
def _acquire(self, inner_func: Callable[..., Any], *args: Any, **kwargs: Any) -> Any:
7991
if not self._self_capture_sampler.capture():
8092
return inner_func(*args, **kwargs)
@@ -130,9 +142,6 @@ def _acquire(self, inner_func: Callable[..., Any], *args: Any, **kwargs: Any) ->
130142
except Exception:
131143
pass # nosec
132144

133-
def acquire(self, *args: Any, **kwargs: Any) -> Any:
134-
return self._acquire(self.__wrapped__.acquire, *args, **kwargs)
135-
136145
def _release(self, inner_func: Callable[..., Any], *args: Any, **kwargs: Any) -> None:
137146
# The underlying threading.Lock class is implemented using C code, and
138147
# it doesn't have the __dict__ attribute. So we can't do
@@ -151,6 +160,7 @@ def _release(self, inner_func: Callable[..., Any], *args: Any, **kwargs: Any) ->
151160
except AttributeError:
152161
# We just ignore the error, if the attribute is not found.
153162
pass
163+
154164
try:
155165
return inner_func(*args, **kwargs)
156166
finally:
@@ -196,15 +206,6 @@ def _release(self, inner_func: Callable[..., Any], *args: Any, **kwargs: Any) ->
196206
handle.push_frame(ddframe.function_name, ddframe.file_name, 0, ddframe.lineno)
197207
handle.flush_sample()
198208

199-
def release(self, *args: Any, **kwargs: Any) -> Any:
200-
return self._release(self.__wrapped__.release, *args, **kwargs)
201-
202-
def __enter__(self, *args: Any, **kwargs: Any) -> Any:
203-
return self._acquire(self.__wrapped__.__enter__, *args, **kwargs)
204-
205-
def __exit__(self, *args: Any, **kwargs: Any) -> None:
206-
self._release(self.__wrapped__.__exit__, *args, **kwargs)
207-
208209
def _find_self_name(self, var_dict: Dict[str, Any]) -> Optional[str]:
209210
for name, value in var_dict.items():
210211
if name.startswith("__") or isinstance(value, ModuleType):

0 commit comments

Comments
 (0)