mirror of
https://github.com/facebook/sapling.git
synced 2024-10-09 08:18:15 +03:00
fbdb46f5cb
Reviewed By: chadaustin Differential Revision: D17872966 fbshipit-source-id: cd60a364a2146f0dadbeca693b1d4a5d7c97ff63
70 lines
1.6 KiB
C++
70 lines
1.6 KiB
C++
/*
|
|
* Copyright (c) Facebook, Inc. and its affiliates.
|
|
*
|
|
* This software may be used and distributed according to the terms of the
|
|
* GNU General Public License version 2.
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <folly/Synchronized.h>
|
|
#include <folly/futures/Future.h>
|
|
#include <folly/futures/Promise.h>
|
|
#include <chrono>
|
|
#include <condition_variable>
|
|
#include <unordered_map>
|
|
|
|
#include "eden/fs/fuse/Dispatcher.h"
|
|
#include "eden/fs/utils/PathFuncs.h"
|
|
|
|
namespace facebook {
|
|
namespace eden {
|
|
|
|
/**
|
|
* A FUSE Dispatcher implementation for use in unit tests.
|
|
*
|
|
* It allows the test code to generate responses to specific requests on
|
|
* demand.
|
|
*/
|
|
class TestDispatcher : public Dispatcher {
|
|
public:
|
|
/**
|
|
* Data for a pending FUSE_LOOKUP request.
|
|
*/
|
|
struct PendingLookup {
|
|
PendingLookup(InodeNumber parent, PathComponentPiece name)
|
|
: parent(parent), name(name.copy()) {}
|
|
|
|
InodeNumber parent;
|
|
PathComponent name;
|
|
folly::Promise<fuse_entry_out> promise;
|
|
};
|
|
|
|
using Dispatcher::Dispatcher;
|
|
|
|
folly::Future<fuse_entry_out> lookup(
|
|
InodeNumber parent,
|
|
PathComponentPiece name) override;
|
|
|
|
/**
|
|
* Wait for the dispatcher to receive a FUSE_LOOKUP request with the
|
|
* specified request ID.
|
|
*
|
|
* Returns a PendingLookup object that can be used to respond to the request.
|
|
*/
|
|
PendingLookup waitForLookup(
|
|
uint64_t requestId,
|
|
std::chrono::milliseconds timeout = std::chrono::milliseconds(500));
|
|
|
|
private:
|
|
struct State {
|
|
std::unordered_map<uint64_t, PendingLookup> pendingLookups;
|
|
};
|
|
|
|
folly::Synchronized<State, std::mutex> state_;
|
|
std::condition_variable requestReceived_;
|
|
};
|
|
|
|
} // namespace eden
|
|
} // namespace facebook
|