/dports/www/py-django-pglocks/django-pglocks-1.0.4/django_pglocks/ |
H A D | __init__.py | 7 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 D | queue.go | 273 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 D | queue.go | 269 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 D | queue.go | 273 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 D | lock_manager.cc | 42 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 D | lock_manager.cc | 42 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 D | lock_set.h | 77 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 D | lock_set.h | 77 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 D | lock_set.h | 78 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 D | lock_set.h | 78 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 D | TestDatabase.php | 130 $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 D | TestDatabase.php | 130 $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 D | data_lock_waits_join.result | 20 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 D | remote_state_handler_spec.rb | 68 … 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.py | 173 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 D | filelock.py | 263 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 D | filelock.py | 263 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 D | filelock.py | 263 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 D | filelock.py | 263 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 D | filelock.py | 263 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 D | LockBackendAbstractTest.php | 55 $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 D | LockBackendAbstractTest.php | 55 $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 D | pydevd_concurrency_logger.py | 78 …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 D | pydevd_concurrency_logger.py | 88 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 D | pydevd_concurrency_logger.py | 78 …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 …]
|