mirror of
https://github.com/nextcloud/desktop.git
synced 2024-10-24 13:25:52 +03:00
47fbfbc006
IsMemberOf is called for every file (in the ownCloud directory or not) and with every instance of OCOverlay (we have 5) when displaying a list of files in Explorer. Refactor the code to avoid copying the list of watched directories, as well as creating a wstring from a PWWSTR for files outside watched directories. Also change some calls of begin_with to use isDescendantOf since it properly handles parent paths not ending with a backslash, which could lead to SocketAPI queries for sibling folders with a name that starts with a watched folder name.
70 lines
No EOL
2 KiB
C++
70 lines
No EOL
2 KiB
C++
/**
|
|
* Copyright (c) 2014 ownCloud GmbH. All rights reserved.
|
|
*
|
|
* This library is free software; you can redistribute it and/or modify it under
|
|
* the terms of the GNU Lesser General Public License as published by the Free
|
|
* Software Foundation; version 2.1 of the License
|
|
*
|
|
* This library is distributed in the hope that it will be useful, but WITHOUT
|
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
|
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
|
* details.
|
|
*/
|
|
|
|
#ifndef PATHCHECKER_H
|
|
#define PATHCHECKER_H
|
|
|
|
#include <string>
|
|
#include <vector>
|
|
#include <unordered_map>
|
|
#include <queue>
|
|
#include <thread>
|
|
#include <memory>
|
|
#include <mutex>
|
|
#include <atomic>
|
|
#include <condition_variable>
|
|
|
|
#pragma once
|
|
|
|
class __declspec(dllexport) RemotePathChecker {
|
|
public:
|
|
enum FileState {
|
|
// Order synced with OCOverlay
|
|
StateError = 0,
|
|
StateOk, StateOkSWM,
|
|
StateSync,
|
|
StateWarning,
|
|
StateNone
|
|
};
|
|
RemotePathChecker();
|
|
~RemotePathChecker();
|
|
std::shared_ptr<const std::vector<std::wstring>> WatchedDirectories() const;
|
|
bool IsMonitoredPath(const wchar_t* filePath, int* state);
|
|
|
|
private:
|
|
FileState _StrToFileState(const std::wstring &str);
|
|
std::mutex _mutex;
|
|
std::atomic<bool> _stop;
|
|
|
|
// Everything here is protected by the _mutex
|
|
|
|
/** The list of paths we need to query. The main thread fill this, and the worker thread
|
|
* send that to the socket. */
|
|
std::queue<std::wstring> _pending;
|
|
|
|
std::unordered_map<std::wstring, FileState> _cache;
|
|
// The vector is const since it will be accessed from multiple threads through OCOverlay::IsMemberOf.
|
|
// Each modification needs to be made onto a copy and then atomically replaced in the shared_ptr.
|
|
std::shared_ptr<const std::vector<std::wstring>> _watchedDirectories;
|
|
bool _connected;
|
|
|
|
|
|
// The main thread notifies when there are new items in _pending
|
|
//std::condition_variable _newQueries;
|
|
HANDLE _newQueries;
|
|
|
|
std::thread _thread;
|
|
void workerThreadLoop();
|
|
};
|
|
|
|
#endif |