* Copyright 2012 Haiku, Inc. All rights reserved.
* Distributed under the terms of the MIT License.
*
* Authors:
* Paweł Dziepak, pdziepak@quarnos.org
*/
#ifndef NFS4SERVER_H
#define NFS4SERVER_H
#include <util/AutoLock.h>
#include "ReplyBuilder.h"
#include "RequestInterpreter.h"
#include "RPCServer.h"
class FileSystem;
struct OpenFileCookie;
class NFS4Server : public RPC::ProgramData {
public:
NFS4Server(RPC::Server* serv);
virtual ~NFS4Server();
uint64 ServerRebooted(uint64 clientId);
status_t FileSystemMigrated();
void AddFileSystem(FileSystem* fs);
void RemoveFileSystem(FileSystem* fs);
inline void IncUsage();
inline void DecUsage();
uint64 ClientId(uint64 prevId = 0, bool forceNew = false);
inline uint32 LeaseTime();
virtual status_t ProcessCallback(RPC::CallbackRequest* request,
Connection* connection);
status_t CallbackRecall(RequestInterpreter* request,
ReplyBuilder* reply);
status_t RecallAll();
status_t CallbackGetAttr(RequestInterpreter* request,
ReplyBuilder* reply);
private:
status_t _GetLeaseTime();
status_t _StartRenewing();
status_t _Renewal();
static status_t _RenewalThreadStart(void* ptr);
thread_id fThread;
bool fThreadCancel;
sem_id fWaitCancel;
mutex fThreadStartLock;
uint32 fLeaseTime;
uint64 fClientId;
time_t fClientIdLastUse;
mutex fClientIdLock;
uint32 fUseCount;
DoublyLinkedList<FileSystem> fFileSystems;
mutex fFSLock;
RPC::Server* fServer;
};
inline void
NFS4Server::IncUsage()
{
MutexLocker _(fFSLock);
fUseCount++;
_StartRenewing();
fClientIdLastUse = time(NULL);
}
inline void
NFS4Server::DecUsage()
{
MutexLocker _(fFSLock);
fClientIdLastUse = time(NULL);
fUseCount--;
}
inline uint32
NFS4Server::LeaseTime()
{
if (fLeaseTime == 0)
_GetLeaseTime();
return fLeaseTime;
}
#endif
