| /dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/push/ |
| H A D | test_email.py | 377 pushers = self.get_success(
380 pushers = list(pushers)
381 self.assertEqual(len(pushers), 0)
415 pushers = self.get_success(
418 pushers = list(pushers)
430 pushers = self.get_success(
433 pushers = list(pushers)
441 pushers = self.get_success(
444 pushers = list(pushers)
460 pushers = self.get_success(
[all …]
|
| H A D | test_http.py | 140 pushers = self.get_success(
143 pushers = list(pushers)
144 self.assertEqual(len(pushers), 1)
151 pushers = self.get_success(
154 pushers = list(pushers)
155 self.assertEqual(len(pushers), 1)
172 pushers = self.get_success(
175 pushers = list(pushers)
176 self.assertEqual(len(pushers), 1)
194 pushers = self.get_success(
[all …]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/push/ |
| H A D | pusherpool.py | 86 self.pushers: Dict[str, Dict[str, Pusher]] = {}
207 if not self.pushers:
245 if u in self.pushers:
246 for p in self.pushers[u].values():
255 if not self.pushers:
272 if u in self.pushers:
273 for p in self.pushers[u].values():
308 pushers = await self.store.get_all_pushers()
312 await concurrently_execute(self._start_pusher, pushers, 10)
354 byuser = self.pushers.setdefault(pusher_config.user_name, {})
[all …]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/15/ |
| H A D | v15.sql | 22 …device_display_name, pushkey, ts, lang, data, last_token, last_success, failing_since FROM pushers;
23 DROP TABLE pushers;
24 ALTER TABLE pushers2 RENAME TO pushers;
|
| /dports/net-im/spectral/libQuotient-58dfe74390ebdd8ec6611d3b8fecfe7d051ff955/lib/csapi/ |
| H A D | pusher.cpp | 51 QVector<Pusher> pushers; member in GetPushersJob::Private
68 const QVector<GetPushersJob::Pusher>& GetPushersJob::pushers() const in pushers() function in GetPushersJob
70 return d->pushers; in pushers()
76 fromJson(json.value("pushers"_ls), d->pushers); in parseJson()
|
| H A D | pusher.h | 81 const QVector<Pusher>& pushers() const;
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/databases/main/ |
| H A D | pusher.py | 353 pushers = [(row[0], row[1]) for row in txn]
359 values=[pusher_id for pusher_id, token in pushers if token is None],
363 if pushers:
365 txn, "remove_stale_pushers", {"last_pusher": pushers[-1][0]}
368 return len(pushers)
548 pushers = list(await self.get_pushers_by_user_id(user_id))
571 for stream_id, pusher in zip(stream_ids, pushers)
575 async with self._pushers_id_gen.get_next_mult(len(pushers)) as stream_ids:
|
| /dports/multimedia/gstreamer1/gstreamer-1.16.2/tests/check/gst/ |
| H A D | gstpromise.c | 536 struct event_queue *pushers[N_QUEUES]; in GST_START_TEST() local
546 pushers[i] = event_queue_new (); in GST_START_TEST()
547 pushers[i]->user_data = &s_q; in GST_START_TEST()
548 _enqueue_task (pushers[i], (GSourceFunc) _push_random_promise, pushers[i], in GST_START_TEST()
567 event_queue_stop (pushers[i]); in GST_START_TEST()
570 _push_stop_promise (pushers[i]); in GST_START_TEST()
574 event_queue_free (pushers[i]); in GST_START_TEST()
|
| /dports/mail/rspamd-devel/rspamd-93430bb/src/plugins/lua/ |
| H A D | metadata_exporter.lua | 253 local pushers = {
341 pushers.custom = assert(load(val))()
346 pushers[k] = assert(load(v))()
366 if pushers[val] then
373 if pushers[v] then
394 if pushers.custom then
587 elseif not pushers[backend] then
610 pushers[rule.backend](task, formatted, rule, extra)
|
| /dports/mail/rspamd/rspamd-3.1/src/plugins/lua/ |
| H A D | metadata_exporter.lua | 253 local pushers = {
341 pushers.custom = assert(load(val))()
346 pushers[k] = assert(load(v))()
366 if pushers[val] then
373 if pushers[v] then
394 if pushers.custom then
587 elseif not pushers[backend] then
610 pushers[rule.backend](task, formatted, rule, extra)
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/rest/client/ |
| H A D | pusher.py | 49 pushers = await self.hs.get_datastore().get_pushers_by_user_id(user.to_string())
51 filtered_pushers = [p.as_dict() for p in pushers]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/40/ |
| H A D | pushers.sql | 39 ALTER TABLE pushers2 RENAME TO pushers;
|
| /dports/net-p2p/py-vertex/Vertex-0.3.1/vertex/ |
| H A D | q2qclient.py | 291 self.pushers = []
294 self.pushers.append([file(filename), filename, []])
299 self.pushers[-1][-1].append(addr)
307 for sharefile, sharename, sharepeers in self.pushers:
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/12/ |
| H A D | v12.sql | 24 CREATE TABLE IF NOT EXISTS pushers ( table
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/full_schemas/16/ |
| H A D | push.sql | 24 CREATE TABLE IF NOT EXISTS pushers ( table
|
| /dports/games/kevedit/kevedit-0.5.1/docs/ |
| H A D | creature.hlp | 13 !pushers;Pushers
102 :pushers;Pushers:
|
| /dports/net-im/libquotient/libQuotient-0.6.8/lib/csapi/ |
| H A D | pusher.h | 74 QVector<Pusher> pushers() const in pushers() function
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/docs/admin_api/ |
| H A D | user_admin_api.md | 349 - Delete all pushers
945 ## List all pushers
946 Gets information about all pushers for a specific `user_id`.
951 GET /_synapse/admin/v1/users/<user_id>/pushers
961 "pushers": [
989 - `pushers` - An array containing the current pushers for the user
1021 - `total` - integer - Number of pushers.
1024 [Client-Server API Spec on pushers](https://matrix.org/docs/spec/client_server/latest#get-matrix-cl…
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/60/ |
| H A D | 02change_stream_ordering_columns.sql.postgres | 20 ALTER TABLE pushers ALTER COLUMN last_stream_ordering SET DATA TYPE BIGINT;
|
| /dports/net-im/mtxclient/mtxclient-0.6.0/ |
| H A D | CHANGELOG.md | 37 * Support for pushers by vurpo
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/docs/ |
| H A D | replication.md | 20 clients or pushers.
|
| /dports/devel/buildstream/BuildStream-1.2.8/buildstream/data/ |
| H A D | userconfig.yaml | 45 pushers: 4
|
| /dports/net/nng/nng-1.5.2/docs/man/ |
| H A D | nng_pull.7.adoc | 29 In the pipeline pattern, pushers distribute messages to pullers.
|
| H A D | nng_push.7.adoc | 29 In the pipeline pattern, pushers distribute messages to pullers.
|
| /dports/games/vavoom/vavoom-1.33/progs/common/linespec/ |
| H A D | Pusher.vc | 183 // For constant pushers (wind/current) there are 3 situations:
241 // constant pushers p_wind and p_current
|