Home
last modified time | relevance | path

Searched refs:lock_id (Results 1 – 25 of 516) sorted by relevance

12345678910>>...21

/dports/www/py-django-pglocks/django-pglocks-1.0.4/django_pglocks/
H A D__init__.py7 def advisory_lock(lock_id, shared=False, wait=True, using=None): argument
35 if isinstance(lock_id, (list, tuple,)):
36 if len(lock_id) != 2:
39 … if not isinstance(lock_id[0], six.integer_types) or not isinstance(lock_id[1], six.integer_types):
43 elif isinstance(lock_id, six.string_types):
47 pos = crc32(lock_id.encode("utf-8"))
48 lock_id = (2**31 - 1) & pos
50 lock_id -= 2**31
51 elif not isinstance(lock_id, six.integer_types):
56 params = (lock_id[0], lock_id[1],)
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore/
H A Dqueue.go273 AND NOT EXISTS (SELECT 1 FROM replication_queue_job_lock WHERE lock_id = queue.lock_id)
292 RETURNING lock_id
370 AND queue.lock_id = existing.lock_id
390 WHERE job_lock.job_id = to_release.id AND job_lock.lock_id = to_release.lock_id
397 SELECT existing.lock_id
402 WHERE lock_id IN (SELECT lock_id FROM removed_job_lock)
403 GROUP BY lock_id
483 RETURNING job_id, lock_id
495 SELECT existing.lock_id
500 WHERE lock_id IN (SELECT lock_id FROM stale_job_lock)
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore/
H A Dqueue.go269 AND NOT EXISTS (SELECT 1 FROM replication_queue_job_lock WHERE lock_id = queue.lock_id)
288 RETURNING lock_id
366 AND queue.lock_id = existing.lock_id
386 WHERE job_lock.job_id = to_release.id AND job_lock.lock_id = to_release.lock_id
393 SELECT existing.lock_id
398 WHERE lock_id IN (SELECT lock_id FROM removed_job_lock)
399 GROUP BY lock_id
479 RETURNING job_id, lock_id
491 SELECT existing.lock_id
496 WHERE lock_id IN (SELECT lock_id FROM stale_job_lock)
[all …]
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/praefect/datastore/
H A Dqueue.go273 AND NOT EXISTS (SELECT 1 FROM replication_queue_job_lock WHERE lock_id = queue.lock_id)
292 RETURNING lock_id
370 AND queue.lock_id = existing.lock_id
390 WHERE job_lock.job_id = to_release.id AND job_lock.lock_id = to_release.lock_id
397 SELECT existing.lock_id
402 WHERE lock_id IN (SELECT lock_id FROM removed_job_lock)
403 GROUP BY lock_id
483 RETURNING job_id, lock_id
495 SELECT existing.lock_id
500 WHERE lock_id IN (SELECT lock_id FROM stale_job_lock)
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/locks/
H A Dlock_manager.cc42 int64_t lock_id, in Create() argument
51 int64_t lock_id) in LockHandleImpl() argument
80 int64_t lock_id, in Lock() argument
85 lock_id_(lock_id), in Lock()
169 void PreemptLock(int64_t lock_id, in PreemptLock() argument
186 void AddRequest(int64_t lock_id, in AddRequest() argument
343 int64_t lock_id = NextLockId(); in RequestLock() local
367 state.EraseLock(lock_id, origin); in ReleaseLock()
390 int64_t lock_id = ++next_lock_id_; in NextLockId() local
391 DCHECK_GT(lock_id, kPreemptiveLockId); in NextLockId()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/locks/
H A Dlock_manager.cc42 int64_t lock_id, in Create() argument
51 int64_t lock_id) in LockHandleImpl() argument
80 int64_t lock_id, in Lock() argument
85 lock_id_(lock_id), in Lock()
170 void PreemptLock(int64_t lock_id, in PreemptLock() argument
187 void AddRequest(int64_t lock_id, in AddRequest() argument
344 int64_t lock_id = NextLockId(); in RequestLock() local
368 state.EraseLock(lock_id, origin); in ReleaseLock()
391 int64_t lock_id = ++next_lock_id_; in NextLockId() local
392 DCHECK_GT(lock_id, kPreemptiveLockId); in NextLockId()
[all …]
/dports/lang/zig-devel/zig-0.9.0/lib/libc/include/any-macos-any/mach/
H A Dlock_set.h77 int lock_id
89 int lock_id
101 int lock_id
113 int lock_id
125 int lock_id
137 int lock_id
164 int lock_id; member
176 int lock_id; member
188 int lock_id; member
200 int lock_id; member
[all …]
/dports/lang/zig/zig-0.9.0/lib/libc/include/any-macos-any/mach/
H A Dlock_set.h77 int lock_id
89 int lock_id
101 int lock_id
113 int lock_id
125 int lock_id
137 int lock_id
164 int lock_id; member
176 int lock_id; member
188 int lock_id; member
200 int lock_id; member
[all …]
/dports/lang/zig/zig-0.9.0/lib/libc/include/any-macos.12-any/mach/
H A Dlock_set.h78 int lock_id
90 int lock_id
102 int lock_id
114 int lock_id
126 int lock_id
138 int lock_id
165 int lock_id; member
177 int lock_id; member
189 int lock_id; member
201 int lock_id; member
[all …]
/dports/lang/zig-devel/zig-0.9.0/lib/libc/include/any-macos.12-any/mach/
H A Dlock_set.h78 int lock_id
90 int lock_id
102 int lock_id
114 int lock_id
126 int lock_id
138 int lock_id
165 int lock_id; member
177 int lock_id; member
189 int lock_id; member
201 int lock_id; member
[all …]
/dports/www/drupal8/drupal-8.9.20/core/lib/Drupal/Core/Test/
H A DTestDatabase.php130 $lock_id = mt_rand(10000000, 99999999);
131 if ($create_lock && @symlink(__FILE__, $this->getLockFile($lock_id)) === FALSE) {
134 $lock_id = NULL;
136 } while ($lock_id === NULL);
137 return $lock_id;
172 * @param int $lock_id
178 protected function getLockFile($lock_id) { argument
179 return FileSystem::getOsTemporaryDirectory() . '/test_' . $lock_id;
/dports/www/drupal9/drupal-9.2.10/core/lib/Drupal/Core/Test/
H A DTestDatabase.php130 $lock_id = mt_rand(10000000, 99999999);
131 if ($create_lock && @symlink(__FILE__, $this->getLockFile($lock_id)) === FALSE) {
134 $lock_id = NULL;
136 } while ($lock_id === NULL);
137 return $lock_id;
172 * @param int $lock_id
178 protected function getLockFile($lock_id) { argument
179 return FileSystem::getOsTemporaryDirectory() . '/test_' . $lock_id;
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/perfschema/r/
H A Ddata_lock_waits_join.result20 lock_id VARCHAR(200) NOT NULL
22 INSERT INTO t2 (lock_id)
31 ON(dlw.blocking_engine_lock_id = t2.lock_id)
37 lock_id VARCHAR(200) NOT NULL
39 INSERT INTO t3 (lock_id)
43 INSERT INTO t3 (lock_id)
50 ON(dlw.requesting_engine_lock_id = t3.lock_id)
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/services/terraform/
H A Dremote_state_handler_spec.rb68 … subject(:handler) { described_class.new(project, user, name: 'new-state', lock_id: 'abc-abc') }
105 lock_id: lock_id
121 expect(state.reload.lock_xid).to eq lock_id
126 described_class.new(project, user, name: 'new-state', lock_id: '12a-23f').lock!
140 lock_id: lock_id
/dports/sysutils/py-azure-cli/azure-cli-2.29.2/azure/cli/command_modules/resource/
H A D_validators.py173 for lock_id in getattr(namespace, 'ids'):
174 if _parse_lock_id(lock_id).get('resource_group'):
175 raise CLIError('{} is not a valid subscription-level lock id.'.format(lock_id))
180 for lock_id in getattr(namespace, 'ids'):
181 lock_id_dict = _parse_lock_id(lock_id)
183 raise CLIError('{} is not a valid group-level lock id.'.format(lock_id))
191 for lock_id in getattr(namespace, 'ids'):
192 lock_id_dict = _parse_lock_id(lock_id)
197 raise CLIError('{} is not a valid resource-level lock id.'.format(lock_id))
/dports/www/firefox/firefox-99.0/third_party/python/virtualenv/__virtualenv__/filelock-3.0.12-py3-none-any/
H A Dfilelock.py263 lock_id = id(self)
270 … logger().debug('Attempting to acquire lock %s on %s', lock_id, lock_filename)
274 logger().info('Lock %s acquired on %s', lock_id, lock_filename)
277 logger().debug('Timeout on acquiring lock %s on %s', lock_id, lock_filename)
282 lock_id, lock_filename, poll_intervall
312 lock_id = id(self)
315 logger().debug('Attempting to release lock %s on %s', lock_id, lock_filename)
318 logger().info('Lock %s released on %s', lock_id, lock_filename)
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/python/virtualenv/__virtualenv__/filelock-3.0.12-py3-none-any/
H A Dfilelock.py263 lock_id = id(self)
270 … logger().debug('Attempting to acquire lock %s on %s', lock_id, lock_filename)
274 logger().info('Lock %s acquired on %s', lock_id, lock_filename)
277 logger().debug('Timeout on acquiring lock %s on %s', lock_id, lock_filename)
282 lock_id, lock_filename, poll_intervall
312 lock_id = id(self)
315 logger().debug('Attempting to release lock %s on %s', lock_id, lock_filename)
318 logger().info('Lock %s released on %s', lock_id, lock_filename)
/dports/sysutils/py-filelock/filelock-3.0.12/
H A Dfilelock.py263 lock_id = id(self)
270 … logger().debug('Attempting to acquire lock %s on %s', lock_id, lock_filename)
274 logger().info('Lock %s acquired on %s', lock_id, lock_filename)
277 logger().debug('Timeout on acquiring lock %s on %s', lock_id, lock_filename)
282 lock_id, lock_filename, poll_intervall
312 lock_id = id(self)
315 logger().debug('Attempting to release lock %s on %s', lock_id, lock_filename)
318 logger().info('Lock %s released on %s', lock_id, lock_filename)
/dports/www/firefox-esr/firefox-91.8.0/third_party/python/virtualenv/__virtualenv__/filelock-3.0.12-py3-none-any/
H A Dfilelock.py263 lock_id = id(self)
270 … logger().debug('Attempting to acquire lock %s on %s', lock_id, lock_filename)
274 logger().info('Lock %s acquired on %s', lock_id, lock_filename)
277 logger().debug('Timeout on acquiring lock %s on %s', lock_id, lock_filename)
282 lock_id, lock_filename, poll_intervall
312 lock_id = id(self)
315 logger().debug('Attempting to release lock %s on %s', lock_id, lock_filename)
318 logger().info('Lock %s released on %s', lock_id, lock_filename)
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/virtualenv/__virtualenv__/filelock-3.0.12-py3-none-any/
H A Dfilelock.py263 lock_id = id(self)
270 … logger().debug('Attempting to acquire lock %s on %s', lock_id, lock_filename)
274 logger().info('Lock %s acquired on %s', lock_id, lock_filename)
277 logger().debug('Timeout on acquiring lock %s on %s', lock_id, lock_filename)
282 lock_id, lock_filename, poll_intervall
312 lock_id = id(self)
315 logger().debug('Attempting to release lock %s on %s', lock_id, lock_filename)
318 logger().info('Lock %s released on %s', lock_id, lock_filename)
/dports/www/drupal8/drupal-8.9.20/core/tests/Drupal/Tests/Core/Lock/
H A DLockBackendAbstractTest.php55 $lock_id = $this->lock->getLockId();
56 $this->assertIsString($lock_id);
58 $this->assertRegExp('/[\da-f]+\.\d+/', $lock_id);
60 $this->assertSame($lock_id, $this->lock->getLockId());
/dports/www/drupal9/drupal-9.2.10/core/tests/Drupal/Tests/Core/Lock/
H A DLockBackendAbstractTest.php55 $lock_id = $this->lock->getLockId();
56 $this->assertIsString($lock_id);
58 $this->assertMatchesRegularExpression('/[\da-f]+\.\d+/', $lock_id);
60 $this->assertSame($lock_id, $this->lock->getLockId());
/dports/java/eclipse-pydev/eclipse-pydev-8.2.0/plugins/org.python.pydev.core_8.2.0.202102211157/pysrc/pydevd_concurrency_analyser/
H A Dpydevd_concurrency_logger.py78 …essage(event_class, time, name, thread_id, type, event, file, line, frame, lock_id=0, parent=None): argument
90 cmdTextList.append(' lock_id="%s"' % pydevd_xml.make_valid_xml_value(str(lock_id)))
219 … real_method, back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
224 … "release", back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
325 … method_name, frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
334 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
337 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
339 … "release", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
344 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
347 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
[all …]
/dports/devel/py-pydevd/pydevd-1.1.1/pydevd_concurrency_analyser/
H A Dpydevd_concurrency_logger.py88 def send_message(event_class, time, name, thread_id, type, event, file, line, frame, lock_id=0, par… argument
98 cmdTextList.append(' lock_id="%s"' % pydevd_xml.make_valid_xml_value(str(lock_id)))
227 … real_method, back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
232 … "release", back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
318 … method_name, frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
327 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
330 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
332 … "release", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
337 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
340 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
[all …]
/dports/devel/py-debugpy/debugpy-1.5.1/src/debugpy/_vendored/pydevd/pydevd_concurrency_analyser/
H A Dpydevd_concurrency_logger.py78 …essage(event_class, time, name, thread_id, type, event, file, line, frame, lock_id=0, parent=None): argument
90 cmdTextList.append(' lock_id="%s"' % pydevd_xml.make_valid_xml_value(str(lock_id)))
219 … real_method, back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
224 … "release", back.f_code.co_filename, back.f_lineno, back, lock_id=str(id(self_obj)))
325 … method_name, frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
334 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
337 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
339 … "release", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
344 … "acquire_begin", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
347 … "acquire_end", frame.f_code.co_filename, frame.f_lineno, frame, lock_id=str(id(self_obj)))
[all …]

12345678910>>...21