| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/sidekiq_middleware/duplicate_jobs/ |
| H A D | duplicate_job.rb | 89 keys: [wal_location_key(connection_name)],
106 … read_wal_locations[connection_name] = multi.lindex(wal_location_key(connection_name), 0)
190 job_wal_locations.keys.each do |connection_name|
191 redis.del(wal_location_key(connection_name))
200 key = existing_wal_location_key(connection_name)
214 def pg_wal_lsn_diff(connection_name) argument
218 job_wal_locations[connection_name],
219 existing_wal_locations[connection_name]
243 def existing_wal_location_key(connection_name) argument
247 def wal_location_key(connection_name) argument
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/database/ |
| H A D | each_database.rb | 8 Gitlab::Database.database_base_models.each_pair do |connection_name, model|
11 with_shared_connection(connection, connection_name) do
12 yield connection, connection_name
19 connection_name = model.connection.pool.db_config.name
21 with_shared_connection(model.connection, connection_name) do
22 yield model, connection_name
29 def with_shared_connection(connection, connection_name) argument
31 … Gitlab::AppLogger.debug(message: 'Switched database connection', connection_name: connection_name)
|
| /dports/devel/py-circuits/circuits-3.2/circuits/node/ |
| H A D | node.py | 64 def add(self, connection_name, hostname, port, **kwargs): argument
115 yield self.call(remote(event, connection_name))
120 '%s_client_%s' % (self.channel, connection_name)
129 connection_name, hostname, port, client_channel, client
138 connection_name, hostname, port, client_channel, client
152 self.__peers[connection_name] = client
163 def get_peer(self, connection_name): argument
172 return self.__peers[connection_name] if connection_name in self.__peers\
176 def __on_remote(self, event, remote_event, connection_name, channel=None): argument
203 node = self.__peers[connection_name]
|
| /dports/graphics/qgis/qgis-3.22.3/tests/src/python/ |
| H A D | test_db_manager_spatialite.py | 73 connection_name = 'testConnect'
78 self.assertTrue(plugin.addConnection(connection_name, uri))
101 connection = createDbPlugin('spatialite', connection_name)
113 connection_name = 'testListLayer'
119 connection = createDbPlugin('spatialite', connection_name)
125 connection_name = 'testListLayer'
159 connection_name = 'testCreateRenameDeleteTable'
230 connection_name = 'testCreateRenameDeleteFields'
275 connection_name = 'testTableDataModel'
383 connection_name = 'testnonspatial'
[all …]
|
| /dports/graphics/qgis-ltr/qgis-3.16.16/tests/src/python/ |
| H A D | test_db_manager_spatialite.py | 73 connection_name = 'testConnect'
78 self.assertTrue(plugin.addConnection(connection_name, uri))
101 connection = createDbPlugin('spatialite', connection_name)
113 connection_name = 'testListLayer'
119 connection = createDbPlugin('spatialite', connection_name)
125 connection_name = 'testListLayer'
159 connection_name = 'testCreateRenameDeleteTable'
230 connection_name = 'testCreateRenameDeleteFields'
275 connection_name = 'testTableDataModel'
391 connection_name = 'testnonspatial'
[all …]
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql96-plperl/postgresql-9.6.24/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-plperl/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in bitor()
64 if (strcmp(connection_name, con->name) == 0) in bitor()
74 ecpg_get_connection(const char *connection_name)
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0))
170 if (!ecpg_init(con, connection_name, lineno)) in CreateDecompressor()
322 connection_name = "DEFAULT"; in SetDecompressorInformation()
329 if (ecpg_get_connection(connection_name)) in SetDecompressorInformation()
333 connection_name); in SetDecompressorInformation()
532 if (connection_name != NULL) in SetDecompressorInformation()
692 if (strcmp(connection_name, "ALL") == 0)
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql10-server/postgresql-10.19/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
532 if (connection_name != NULL) in ECPGconnect()
692 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0))
64 if (strcmp(connection_name, con->name) == 0) in getBranchBlock()
74 ecpg_get_connection(const char *connection_name) in getBranchTerminator()
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in getBranchTerminator()
170 if (!ecpg_init(con, connection_name, lineno)) in comparePHIRelated()
322 connection_name = "DEFAULT";
329 if (ecpg_get_connection(connection_name))
333 connection_name);
532 if (connection_name != NULL)
692 if (strcmp(connection_name, "ALL") == 0)
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/interfaces/ecpg/ecpglib/ |
| H A D | connect.c | 40 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection_nr()
64 if (strcmp(connection_name, con->name) == 0) in ecpg_get_connection_nr()
74 ecpg_get_connection(const char *connection_name) in ecpg_get_connection() argument
78 if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0)) in ecpg_get_connection()
170 if (!ecpg_init(con, connection_name, lineno)) in ECPGsetcommit()
322 connection_name = "DEFAULT"; in ECPGconnect()
329 if (ecpg_get_connection(connection_name)) in ECPGconnect()
333 connection_name); in ECPGconnect()
506 if (connection_name != NULL) in ECPGconnect()
682 if (strcmp(connection_name, "ALL") == 0) in ECPGdisconnect()
[all …]
|