op-worker

• 

  Michał Wrzeszcz 01 Jul 2022 239b30c6510ccf0f2f429dc5c48ecf04d192549a

  Merge pull request #3349 in VFS/op-worker from feature/VFS-9255-oneprovider-side-support-for-onclient-subscription-race-fix to develop
  * commit '908acdb5f7083a678247cd06293cfc4a1dfce0b1':
    VFS-9255 Update deps
    VFS-9255 Rename fslogic_uuid to fslogic_file_id
    VFS-9255 Improve code style
    VFS-9247 Fix event manager guid_to_provider cache
    VFS-9247 Fix unsubscribe
    VFS-9247 Handle sync subscriptions
    VFS-9247 Handle sync subscriptions
    VFS-9247 Sync events subscriptions
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 30 Jun 2022 908acdb5f7083a678247cd06293cfc4a1dfce0b1 m

  VFS-9255 Update deps

  • rebar.config (version 908acdb5f7083a678247cd06293cfc4a1dfce0b1) (diffs)
  • rebar.lock (version 908acdb5f7083a678247cd06293cfc4a1dfce0b1) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 30 Jun 2022 3d05699f8cf23d7f04bc01763ecc3a063cb0b7bd m

  Merge remote-tracking branch 'origin/develop' into feature/VFS-9255-oneprovider-side-support-for-onclient-subscription-race-fix
  # Conflicts:
  #        test_distributed/suites/api/file/api_file_stream_test_SUITE.erl
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 24 Jun 2022 3a528211947d055a9c555885a6456af03ceed1e3 m

  VFS-9255 Rename fslogic_uuid to fslogic_file_id

  • src/graph_sync/server/gui_translators/file_gui_gs_translator.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/graph_sync/server/gui_translators/space_gui_gs_translator.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/http/rest/handlers/changes_stream_handler.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/http/rest/rest_handler.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/http/rest/translators/space_rest_translator.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/interface/mi_archives.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/interface/mi_atm.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/interface/mi_datasets.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/interface/mi_transfers.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/middleware_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/plugins/file_middleware_plugin.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/middleware/plugins/space/handlers/space_oz_middleware_handler.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/archive/archivisation_tree.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/dataset/dataset_eff_cache.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/dataset/dataset_path.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/file_popularity.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/files_to_chown.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/handles/file_handles.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/location/file_location.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/custom_metadata.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/file_meta.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/file_meta_hardlinks.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/file_meta_model.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/file_meta_symlinks.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/file/metadata/times.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/qos/file_qos.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/datastore/models/transfer/transferred_file.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/dbsync/dbsync_events.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/dir_stats_collector/dir_stats_collector.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/dir_stats_collector/space_initialization/dir_stats_collections_initialization_traverse.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/events/event_manager.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/events/event_type.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/events/subscription_type.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/caches/paths_cache.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/context/file_ctx.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/context/file_partial_ctx.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/deletion/fslogic_delete.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/deletion/trash.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/file_tree/file_tree.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/operations/attr_req.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/operations/storage_req.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/operations/symlink_req.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/replication/replica_synchronizer.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/utils/fslogic_file_id.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/utils/fslogic_times.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/fslogic/utils/fslogic_uuid.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/harvesting/harvesting_stream.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/logical_file_manager/event/lfm_event_controller.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/logical_file_manager/utils/lfm_file_key.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/monitoring/rrd_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/qos/qos_status/qos_reconciliation_status.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/qos/qos_traverse.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/space/space_unsupport.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/space/unsupport_cleanup_traverse.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/storage/driver/storage_driver.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/storage/file/storage_file_id.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/storage/import/storage_import_deletion.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/storage/import/storage_import_engine.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/modules/storage/luma/luma.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/test_utils/initializer.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/test_utils/lfm_proxy.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/test_utils/multinode_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • src/tree_processing/effective_value.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/api/transfer_api_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/client_events_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/dir_stats_collector_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/file_deletion_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/file_meta_stress_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/fslogic_req_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/harvesting_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/include/storage_files_test_SUITE.hrl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/lfm_attrs_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/lfm_files_posix_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/lfm_files_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/model_file_meta_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/model_file_meta_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/multi_provider_file_ops_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/multi_provider_hardlinks_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/multi_provider_rest_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/node_failure_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/quota_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/replication_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/single_node_failure_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/space_unsupport_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/storage_cleanup_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/storage_files_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/storage_import_deletion_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/storage_import_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/storage_req_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/dataset/api_archive_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/dataset/api_dataset_tree_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/file/api_file_crud_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/file/api_file_ls_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/file/api_file_stream_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/api/file/api_file_upload_rest_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/archive_model_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/archive_sequential_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/archive_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/archive_tests_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/dataset_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/dataset/datasets_structure_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/permissions/permissions_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/qos/qos_multi_provider_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/qos/qos_test_base.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/session/session_offline_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/trash/trash_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/suites/trash/tree_deletion_traverse_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/tmp_db_error_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/transfers_restart_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/utils/api/api_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/utils/atm/atm_store_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/utils/file/onenv_file_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/utils/lfm_test_utils.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/utils/transfers/transfers_test_mechanism.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
  • test_distributed/view_test_SUITE.erl (version 3a528211947d055a9c555885a6456af03ceed1e3) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 23 Jun 2022 ce6c57419432c81f1be8b7815428c50455c1ad86 m

  VFS-9255 Improve code style

  • src/modules/communication/sequencer/sequencer.erl (version ce6c57419432c81f1be8b7815428c50455c1ad86) (diffs)
  • src/modules/events/event_router.erl (version ce6c57419432c81f1be8b7815428c50455c1ad86) (diffs)
  • test_distributed/client_events_test_SUITE.erl (version ce6c57419432c81f1be8b7815428c50455c1ad86) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 09 Jun 2022 4e32a372ca6b1cd703856a7a1898dc22268e0aba m

  Merge remote-tracking branch 'origin/develop' into feature/VFS-9255-oneprovider-side-support-for-onclient-subscription-race-fix
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 09 Jun 2022 f01cd4a03b5fd4ab21500ecf35dd887a39646fcc m

  VFS-9247 Fix event manager guid_to_provider cache

  • src/modules/events/event_manager.erl (version f01cd4a03b5fd4ab21500ecf35dd887a39646fcc) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 09 Jun 2022 5b5a121ec141a6ebde3f0ee9b95c86e454a4abfa m

  VFS-9247 Fix unsubscribe

  • src/modules/events/event_manager.erl (version 5b5a121ec141a6ebde3f0ee9b95c86e454a4abfa) (diffs)
  • src/modules/session/session_manager.erl (version 5b5a121ec141a6ebde3f0ee9b95c86e454a4abfa) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 12 May 2022 2ff2dd53ce0acf8af747cfbcaf8a4ee872f352c0 m

  Merge remote-tracking branch 'origin/develop' into feature/VFS-9255-oneprovider-side-support-for-onclient-subscription-race-fix
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 22 Apr 2022 b7e837a3c053f70160be098d05ef8e8b9f87c601 m

  Merge remote-tracking branch 'origin/develop' into feature/VFS-9255-oneprovider-side-support-for-onclient-subscription-race-fix
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 21 Apr 2022 42eed263101b8c896b50a6b58f648e1eecee0045 m

  VFS-9247 Handle sync subscriptions

  • include/modules/events/types.hrl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/communication/protocol/clproto_translator.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/communication/sequencer/sequencer.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/events/event_manager.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/events/event_type.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/events/subscription_type.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/fslogic/operations/attr_req.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/fslogic/operations/file_req.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/fslogic/operations/truncate_req.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/logical_file_manager/event/lfm_event_controller.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • src/modules/logical_file_manager/lfm_submodules/lfm_files.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
  • test_distributed/client_events_test_SUITE.erl (version 42eed263101b8c896b50a6b58f648e1eecee0045) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 21 Apr 2022 1d5cb99bd00d7b80602d1da868c16b27695002dd m

  VFS-9247 Handle sync subscriptions

  • src/modules/events/event_manager.erl (version 1d5cb99bd00d7b80602d1da868c16b27695002dd) (diffs)
  • src/modules/events/event_router.erl (version 1d5cb99bd00d7b80602d1da868c16b27695002dd) (diffs)
  • test_distributed/client_events_test_SUITE.erl (version 1d5cb99bd00d7b80602d1da868c16b27695002dd) (diffs)
  • test_distributed/client_events_test_SUITE_data/env_desc.json (version 1d5cb99bd00d7b80602d1da868c16b27695002dd) (diffs)
  • test_distributed/utils/fuse_test_utils.erl (version 1d5cb99bd00d7b80602d1da868c16b27695002dd) (diffs)
• 

  Michal Wrzeszcz <michalwrzeszcz@gmail.com> 06 Apr 2022 af828bdf020aa8132bf20ea718d2f892b9b1007d m

  VFS-9247 Sync events subscriptions

  • src/modules/events/event_stream.erl (version af828bdf020aa8132bf20ea718d2f892b9b1007d) (diffs)