/*
 * Copyright 2001-2009, Ingo Weinhold, ingo_weinhold@gmx.de.
 * Distributed under the terms of the MIT License.
 */
#ifndef USERLAND_FS_REQUEST_THREAD_H
#define USERLAND_FS_REQUEST_THREAD_H

#include "RequestPort.h"

namespace UserlandFS {

class FileSystem;
class RequestThread;
class Volume;

#define REQUEST_THREAD_CONTEXT_FS_DATA_SIZE     256

// RequestThreadContext
class RequestThreadContext {
public:
                                                                RequestThreadContext(Volume* volume,
                                                                        KernelRequest* request);
                                                                ~RequestThreadContext();

                        RequestThread*          GetThread() const;
                        Volume*                         GetVolume() const;
                        KernelRequest*          GetRequest() const      { return fRequest; }
                        void*                           GetFSData()             { return fFSData; }

private:
                        RequestThreadContext*   fPreviousContext;
                        RequestThread*          fThread;
                        Volume*                         fVolume;
                        KernelRequest*          fRequest;
                        uint8                           fFSData[REQUEST_THREAD_CONTEXT_FS_DATA_SIZE];
};

// RequestThread
class RequestThread {
public:
                                                                RequestThread();
                                                                ~RequestThread();

                        status_t                        Init(FileSystem* fileSystem);
                        void                            Run();
                        void                            PrepareTermination();
                        void                            Terminate();

                        const Port::Info*       GetPortInfo() const;
                        FileSystem*                     GetFileSystem() const;
                        RequestPort*            GetPort() const;
                        RequestThreadContext*   GetContext() const;

        static  RequestThread*          GetCurrentThread();

private:
                        void                            SetContext(RequestThreadContext* context);

private:
        static  int32                           _ThreadEntry(void* data);
                        int32                           _ThreadLoop();

private:
                        friend class RequestThreadContext;

                        thread_id                       fThread;
                        FileSystem*                     fFileSystem;
                        RequestPort*            fPort;
                        RequestThreadContext* fContext;
                        bool                            fTerminating;
};

}       // namespace UserlandFS

using UserlandFS::RequestThreadContext;
using UserlandFS::RequestThread;

#endif  // USERLAND_FS_REQUEST_THREAD_H