mirror of
https://github.com/facebook/sapling.git
synced 2024-10-05 14:28:17 +03:00
324071beee
Summary: For restart for NFS we now have the pieces to transfer nfs mounts. The last piece of restart is transferring the mountd socket. This extracts the socket from the current mountd and provides it to the takeover server, as well as implements reading the mountd socket from the takeover client and starting the mountd with this server socket. Reviewed By: xavierd Differential Revision: D31802786 fbshipit-source-id: 1727ea0913bfe1dcb02fdbe27c8cc3b9d62a8464
113 lines
3.0 KiB
C++
113 lines
3.0 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
|
|
|
|
#ifndef _WIN32
|
|
|
|
#include <tuple>
|
|
#include "eden/fs/nfs/Mountd.h"
|
|
#include "eden/fs/nfs/Nfsd3.h"
|
|
#include "eden/fs/utils/CaseSensitivity.h"
|
|
|
|
namespace folly {
|
|
class Executor;
|
|
}
|
|
|
|
namespace facebook::eden {
|
|
|
|
class Notifications;
|
|
class ProcessNameCache;
|
|
|
|
class NfsServer {
|
|
public:
|
|
/**
|
|
* Create a new NFS server.
|
|
*
|
|
* This will handle the lifetime of the various programs involved in the NFS
|
|
* protocol including mountd and nfsd. The requests will be serviced by a
|
|
* blocking thread pool initialized with numServicingThreads and
|
|
* maxInflightRequests.
|
|
*
|
|
* One mountd program will be created per NfsServer, while one nfsd program
|
|
* will be created per-mount point, this allows nfsd program to be only aware
|
|
* of its own mount point which greatly simplifies it.
|
|
*/
|
|
NfsServer(
|
|
folly::EventBase* evb,
|
|
uint64_t numServicingThreads,
|
|
uint64_t maxInflightRequests);
|
|
|
|
/**
|
|
* Bind the NfsServer to the passed in socket.
|
|
*
|
|
* See Mountd::initialize for the meaning of registerMountdWithRpcbind.
|
|
*/
|
|
void initialize(folly::SocketAddress addr, bool registerMountdWithRpcbind);
|
|
void initialize(folly::File&& socket);
|
|
|
|
/**
|
|
* Return value of registerMount.
|
|
*/
|
|
struct NfsMountInfo {
|
|
std::unique_ptr<Nfsd3> nfsd;
|
|
folly::SocketAddress mountdAddr;
|
|
};
|
|
|
|
/**
|
|
* Register a path as the root of a mount point.
|
|
*
|
|
* This will create an nfs program for that mount point and register it with
|
|
* the mountd program.
|
|
*
|
|
* @return: the created nfsd program as well as a tuple that holds the TCP
|
|
* port number that mountd and nfsd are listening to.
|
|
*/
|
|
NfsServer::NfsMountInfo registerMount(
|
|
AbsolutePathPiece path,
|
|
InodeNumber rootIno,
|
|
std::unique_ptr<NfsDispatcher> dispatcher,
|
|
const folly::Logger* straceLogger,
|
|
std::shared_ptr<ProcessNameCache> processNameCache,
|
|
std::shared_ptr<FsEventLogger> fsEventLogger,
|
|
folly::Duration requestTimeout,
|
|
Notifications* FOLLY_NULLABLE notifications,
|
|
CaseSensitivity caseSensitive,
|
|
uint32_t iosize);
|
|
|
|
/**
|
|
* Unregister the mount point matching the path.
|
|
*
|
|
* The nfs program will also be destroyed, and thus it is expected that
|
|
* EdenFS has unmounted this mount point before calling this function.
|
|
*/
|
|
void unregisterMount(AbsolutePathPiece path);
|
|
|
|
/**
|
|
* Return the EventBase that the various NFS programs are running on.
|
|
*/
|
|
folly::EventBase* getEventBase() const {
|
|
return evb_;
|
|
}
|
|
|
|
folly::SemiFuture<folly::File> takeoverStop();
|
|
|
|
NfsServer(const NfsServer&) = delete;
|
|
NfsServer(NfsServer&&) = delete;
|
|
NfsServer& operator=(const NfsServer&) = delete;
|
|
NfsServer& operator=(NfsServer&&) = delete;
|
|
|
|
private:
|
|
folly::EventBase* evb_;
|
|
std::shared_ptr<folly::Executor> threadPool_;
|
|
Mountd mountd_;
|
|
};
|
|
|
|
} // namespace facebook::eden
|
|
|
|
#endif
|