1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/**
* @file lllfsthread.h
* @brief LLLFSThread base class
*
* Copyright (c) 2000-2007, Linden Research, Inc.
*
* The source code in this file ("Source Code") is provided by Linden Lab
* to you under the terms of the GNU General Public License, version 2.0
* ("GPL"), unless you have obtained a separate licensing agreement
* ("Other License"), formally executed by you and Linden Lab. Terms of
* the GPL can be found in doc/GPL-license.txt in this distribution, or
* online at http://secondlife.com/developers/opensource/gplv2
*
* There are special exceptions to the terms and conditions of the GPL as
* it is applied to this Source Code. View the full text of the exception
* in the file doc/FLOSS-exception.txt in this software distribution, or
* online at http://secondlife.com/developers/opensource/flossexception
*
* By copying, modifying or distributing this software, you acknowledge
* that you have read and understood your obligations described above,
* and agree to abide by those obligations.
*
* ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
* WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
* COMPLETENESS OR PERFORMANCE.
*/
#ifndef LL_LLLFSTHREAD_H
#define LL_LLLFSTHREAD_H
#include <queue>
#include <string>
#include <map>
#include <set>
#include "llapr.h"
#include "llqueuedthread.h"
//============================================================================
// Threaded Local File System
//============================================================================
class LLLFSThread : public LLQueuedThread
{
//------------------------------------------------------------------------
public:
enum operation_t {
FILE_READ,
FILE_WRITE,
FILE_RENAME,
FILE_REMOVE
};
//------------------------------------------------------------------------
public:
class Request : public QueuedRequest
{
protected:
~Request() {}; // use deleteRequest()
public:
Request(handle_t handle, U32 priority, U32 flags,
operation_t op, const LLString& filename,
U8* buffer, S32 offset, S32 numbytes);
S32 getBytes()
{
return mBytes;
}
S32 getBytesRead()
{
return mBytesRead;
}
S32 getOperation()
{
return mOperation;
}
U8* getBuffer()
{
return mBuffer;
}
const LLString& getFilename()
{
return mFileName;
}
/*virtual*/ void finishRequest();
/*virtual*/ void deleteRequest();
bool processIO();
private:
operation_t mOperation;
LLString mFileName;
U8* mBuffer; // dest for reads, source for writes, new UUID for rename
S32 mOffset; // offset into file, -1 = append (WRITE only)
S32 mBytes; // bytes to read from file, -1 = all
S32 mBytesRead; // bytes read from file
};
//------------------------------------------------------------------------
public:
LLLFSThread(bool threaded = TRUE, bool runalways = TRUE);
~LLLFSThread();
// Return a Request handle
handle_t read(const LLString& filename,
U8* buffer, S32 offset, S32 numbytes, U32 pri=PRIORITY_NORMAL, U32 flags = 0);
handle_t write(const LLString& filename,
U8* buffer, S32 offset, S32 numbytes, U32 flags = 0);
handle_t rename(const LLString& filename, const LLString& newname, U32 flags = 0);
handle_t remove(const LLString& filename, U32 flags = 0);
// Return number of bytes read
S32 readImmediate(const LLString& filename,
U8* buffer, S32 offset, S32 numbytes);
S32 writeImmediate(const LLString& filename,
U8* buffer, S32 offset, S32 numbytes);
static void initClass(bool local_is_threaded = TRUE, bool run_always = TRUE); // Setup sLocal
static S32 updateClass(U32 ms_elapsed);
static void cleanupClass(); // Delete sLocal
protected:
/*virtual*/ bool processRequest(QueuedRequest* req);
public:
static LLLFSThread* sLocal; // Default local file thread
};
//============================================================================
#endif // LL_LLLFSTHREAD_H
|
