XRootD
Loading...
Searching...
No Matches
XrdBuffer.hh
Go to the documentation of this file.
1#ifndef __XrdBuffer_H__
2#define __XrdBuffer_H__
3/******************************************************************************/
4/* */
5/* X r d B u f f e r . h h */
6/* */
7/* (c) 2004 by the Board of Trustees of the Leland Stanford, Jr., University */
8/* Produced by Andrew Hanushevsky for Stanford University under contract */
9/* DE-AC02-76-SFO0515 with the Department of Energy */
10/* */
11/* This file is part of the XRootD software suite. */
12/* */
13/* XRootD is free software: you can redistribute it and/or modify it under */
14/* the terms of the GNU Lesser General Public License as published by the */
15/* Free Software Foundation, either version 3 of the License, or (at your */
16/* option) any later version. */
17/* */
18/* XRootD is distributed in the hope that it will be useful, but WITHOUT */
19/* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
20/* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
21/* License for more details. */
22/* */
23/* You should have received a copy of the GNU Lesser General Public License */
24/* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
25/* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
26/* */
27/* The copyright holder's institutional names and contributor's names may not */
28/* be used to endorse or promote products derived from this software without */
29/* specific prior written permission of the institution or contributor. */
30/******************************************************************************/
31
32#include <cstdlib>
33#include <unistd.h>
34#include <sys/types.h>
36
37/******************************************************************************/
38/* x r d _ B u f f e r */
39/******************************************************************************/
40
42{
43public:
44
45char * buff; // -> buffer
46int bsize; // size of this buffer
47
48 XrdBuffer(char *bp, int sz, int ix)
49 {buff = bp; bsize = sz; bindex = ix; next = 0;}
50
51 ~XrdBuffer() {if (buff) free(buff);}
52
53 friend class XrdBuffManager;
54 friend class XrdBuffXL;
55private:
56
57int bindex;
58XrdBuffer *next;
59static int pagesz;
60};
61
62/******************************************************************************/
63/* x r d _ B u f f M a n a g e r */
64/******************************************************************************/
65
66#define XRD_BUCKETS 12
67#define XRD_BUSHIFT 10
68
69// There should be only one instance of this class per buffer pool.
70//
72{
73public:
74
75void Init();
76
77XrdBuffer *Obtain(int bsz);
78
79int Recalc(int bsz);
80
81void Release(XrdBuffer *bp);
82
83int MaxSize() {return maxsz;}
84
85void Reshape();
86
87void Set(int maxmem=-1, int minw=-1);
88
89int Stats(char *buff, int blen, int do_sync=0);
90
91 XrdBuffManager(int minrst=20*60);
92
93 ~XrdBuffManager(); // The buffmanager is never deleted
94
95private:
96
97const int slots;
98const int shift;
99const int pagsz;
100const int maxsz;
101
102struct {XrdBuffer *bnext;
103 int numbuf;
104 int numreq;
105 } bucket[XRD_BUCKETS]; // 1K to 1<<(szshift+slots-1)M buffers
106
107int totreq;
108int totbuf;
109long long totalo;
110long long maxalo;
111int minrsw;
112int rsinprog;
113int totadj;
114
115XrdSysCondVar Reshaper;
116static const char *TraceID;
117};
118#endif
#define XRD_BUCKETS
Definition XrdBuffer.hh:66
int Stats(char *buff, int blen, int do_sync=0)
Definition XrdBuffer.cc:323
void Release(XrdBuffer *bp)
Definition XrdBuffer.cc:221
int Recalc(int bsz)
Definition XrdBuffer.cc:195
XrdBuffer * Obtain(int bsz)
Definition XrdBuffer.cc:140
XrdBuffer(char *bp, int sz, int ix)
Definition XrdBuffer.hh:48
char * buff
Definition XrdBuffer.hh:45