| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/glean-core/src/upload/ |
| H A D | mod.rs | 57 if UPLOAD_MANAGER.set(Mutex::new(upload_manager)).is_err() { in setup_upload_manager()
67 *lock = upload_manager; in setup_upload_manager()
408 match upload_manager.get_upload_task(false) { in test_returns_ping_request_when_there_is_one()
433 match upload_manager.get_upload_task(false) { in test_returns_as_many_ping_requests_as_there_are()
460 drop(upload_manager.clear_ping_queue()); in test_clearing_the_queue_works_correctly()
487 drop(glean.upload_manager.clear_ping_queue()); in test_clearing_the_queue_doesnt_clear_deletion_request_pings()
645 match upload_manager.get_upload_task(false) { in test_processes_correctly_server_error_upload_response()
717 upload_manager.enqueue_ping(doc1, &path1, json!({})); in new_pings_are_added_while_upload_in_progress()
720 let req = match upload_manager.get_upload_task(false) { in new_pings_are_added_while_upload_in_progress()
727 upload_manager.enqueue_ping(doc2, &path2, json!({})); in new_pings_are_added_while_upload_in_progress()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/glean-core/src/upload/ |
| H A D | mod.rs | 255 upload_manager in no_policy()
261 upload_manager in no_policy()
266 upload_manager in no_policy()
1158 upload_manager in maximum_of_recoverable_errors_is_enforced_for_uploading_window()
1218 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1240 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1248 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1288 upload_manager in number_quota_is_enforced_when_enqueueing_cached_pings()
1361 upload_manager in size_and_count_quota_work_together_size_first()
1435 upload_manager in size_and_count_quota_work_together_count_first()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/glean-core/src/upload/ |
| H A D | mod.rs | 255 upload_manager in no_policy()
261 upload_manager in no_policy()
266 upload_manager in no_policy()
1158 upload_manager in maximum_of_recoverable_errors_is_enforced_for_uploading_window()
1218 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1240 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1248 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1288 upload_manager in number_quota_is_enforced_when_enqueueing_cached_pings()
1361 upload_manager in size_and_count_quota_work_together_size_first()
1435 upload_manager in size_and_count_quota_work_together_count_first()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/glean-core/src/upload/ |
| H A D | mod.rs | 255 upload_manager in no_policy()
261 upload_manager in no_policy()
266 upload_manager in no_policy()
1158 upload_manager in maximum_of_recoverable_errors_is_enforced_for_uploading_window()
1218 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1240 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1248 upload_manager in quota_is_enforced_when_enqueueing_cached_pings()
1288 upload_manager in number_quota_is_enforced_when_enqueueing_cached_pings()
1361 upload_manager in size_and_count_quota_work_together_size_first()
1435 upload_manager in size_and_count_quota_work_together_count_first()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/glean-core/src/ |
| H A D | lib.rs | 194 upload_manager: PingUploadManager, field
217 upload_manager.set_rate_limiter( in new_for_subprocess()
224 let _scanning_thread = upload_manager.scan_pending_pings_directories(); in new_for_subprocess()
238 upload_manager, in new_for_subprocess()
304 let _scanning_thread = glean.upload_manager.scan_pending_pings_directories(); in new()
330 glean.upload_manager = PingUploadManager::no_policy(data_path); in with_options()
479 let _lock = self.upload_manager.clear_ping_queue(); in clear_metrics()
584 self.upload_manager.get_upload_task(self, self.log_pings()) in get_upload_task()
594 self.upload_manager in process_ping_upload_response()
676 self.upload_manager.enqueue_ping( in submit_ping()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/glean-core/src/ |
| H A D | lib.rs | 194 upload_manager: PingUploadManager, field
217 upload_manager.set_rate_limiter( in new_for_subprocess()
224 let _scanning_thread = upload_manager.scan_pending_pings_directories(); in new_for_subprocess()
238 upload_manager, in new_for_subprocess()
311 let _scanning_thread = glean.upload_manager.scan_pending_pings_directories(); in new()
337 glean.upload_manager = PingUploadManager::no_policy(data_path); in with_options()
486 let _lock = self.upload_manager.clear_ping_queue(); in clear_metrics()
591 self.upload_manager.get_upload_task(self, self.log_pings()) in get_upload_task()
601 self.upload_manager in process_ping_upload_response()
683 self.upload_manager.enqueue_ping( in submit_ping()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/glean-core/src/ |
| H A D | lib.rs | 194 upload_manager: PingUploadManager, field
217 upload_manager.set_rate_limiter( in new_for_subprocess()
224 let _scanning_thread = upload_manager.scan_pending_pings_directories(); in new_for_subprocess()
238 upload_manager, in new_for_subprocess()
311 let _scanning_thread = glean.upload_manager.scan_pending_pings_directories(); in new()
337 glean.upload_manager = PingUploadManager::no_policy(data_path); in with_options()
486 let _lock = self.upload_manager.clear_ping_queue(); in clear_metrics()
591 self.upload_manager.get_upload_task(self, self.log_pings()) in get_upload_task()
601 self.upload_manager in process_ping_upload_response()
683 self.upload_manager.enqueue_ping( in submit_ping()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/glean/src/ |
| H A D | lib.rs | 83 upload_manager: net::UploadManager, field
218 let upload_manager = net::UploadManager::new( in initialize() localVariable
229 upload_manager, in initialize()
308 state.upload_manager.trigger_upload(); in initialize()
326 state.upload_manager.trigger_upload(); in initialize()
499 state.upload_manager.trigger_upload(); in set_upload_enabled()
584 state.upload_manager.trigger_upload(); in submit_ping_by_name_sync()
624 state.upload_manager.trigger_upload(); in handle_client_active()
653 state.upload_manager.trigger_upload(); in handle_client_inactive()
694 state.upload_manager.test_wait_for_upload(); in destroy_glean()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/glean/src/ |
| H A D | lib.rs | 83 upload_manager: net::UploadManager, field
219 let upload_manager = net::UploadManager::new( in initialize_internal() localVariable
230 upload_manager, in initialize_internal()
309 state.upload_manager.trigger_upload(); in initialize_internal()
327 state.upload_manager.trigger_upload(); in initialize_internal()
487 state.upload_manager.trigger_upload(); in set_upload_enabled()
572 state.upload_manager.trigger_upload(); in submit_ping_by_name_sync()
612 state.upload_manager.trigger_upload(); in handle_client_active()
641 state.upload_manager.trigger_upload(); in handle_client_inactive()
681 state.upload_manager.test_wait_for_upload(); in destroy_glean()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/glean/src/ |
| H A D | lib.rs | 83 upload_manager: net::UploadManager, field
219 let upload_manager = net::UploadManager::new( in initialize_internal() localVariable
230 upload_manager, in initialize_internal()
309 state.upload_manager.trigger_upload(); in initialize_internal()
327 state.upload_manager.trigger_upload(); in initialize_internal()
487 state.upload_manager.trigger_upload(); in set_upload_enabled()
572 state.upload_manager.trigger_upload(); in submit_ping_by_name_sync()
612 state.upload_manager.trigger_upload(); in handle_client_active()
641 state.upload_manager.trigger_upload(); in handle_client_inactive()
681 state.upload_manager.test_wait_for_upload(); in destroy_glean()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/glean-core/src/ |
| H A D | lib.rs | 175 upload_manager: PingUploadManager, field
199 upload_manager: PingUploadManager::new(&cfg.data_path, false), in new()
381 let _lock = self.upload_manager.clear_ping_queue(); in clear_metrics()
478 self.upload_manager.get_upload_task(log_ping) in get_upload_task()
488 self.upload_manager in process_ping_upload_response()
562 self.upload_manager in submit_ping()
|
| /dports/devel/py-b2sdk/b2sdk-1.12.0/b2sdk/transfer/ |
| H A D | __init__.py | 13 from .outbound.upload_manager import UploadManager
|
| /dports/devel/py-oci/oci-2.53.1/src/oci/object_storage/ |
| H A D | __init__.py | 11 from .transfer.upload_manager import UploadManager
|
| /dports/www/moodle310/moodle/lib/ |
| H A D | uploadlib.php | 38 class upload_manager { class
|
| /dports/www/moodle311/moodle/lib/ |
| H A D | uploadlib.php | 38 class upload_manager { class
|
| /dports/www/moodle39/moodle/lib/ |
| H A D | uploadlib.php | 38 class upload_manager { class
|
| /dports/devel/py-b2sdk/b2sdk-1.12.0/b2sdk/transfer/emerge/ |
| H A D | executor.py | 571 return execution.services.upload_manager.upload_file(
612 return execution.services.upload_manager.upload_part(
|
| /dports/devel/py-b2sdk/b2sdk-1.12.0/test/unit/v0/ |
| H A D | test_bucket.py | 223 self.api.services.upload_manager.upload_part(
226 self.api.services.upload_manager.upload_part(
229 self.api.services.upload_manager.upload_part(
248 self.bucket.api.services.upload_manager.upload_part(
|
| /dports/devel/py-b2sdk/b2sdk-1.12.0/b2sdk/ |
| H A D | api.py | 66 self.upload_manager = UploadManager(self, max_upload_workers=max_upload_workers)
|
| /dports/devel/py-b2sdk/b2sdk-1.12.0/test/unit/bucket/ |
| H A D | test_bucket.py | 253 self.api.services.upload_manager.upload_part(
256 self.api.services.upload_manager.upload_part(
259 self.api.services.upload_manager.upload_part(
279 self.api.services.upload_manager.upload_part(
|