XRootD
XrdXrootdResponse.hh
Go to the documentation of this file.
1
#ifndef __XROOTD_RESPONSE_H__
2
#define __XROOTD_RESPONSE_H__
3
/******************************************************************************/
4
/* */
5
/* X r d X r o o t d R e s p o n s e . 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 <cstring>
33
#include <unistd.h>
34
#include <sys/uio.h>
35
36
#include "
XProtocol/XProtocol.hh
"
37
#include "
XProtocol/XPtypes.hh
"
38
#include "
XrdXrootd/XrdXrootdReqID.hh
"
39
40
/******************************************************************************/
41
/* x r o o t d _ R e s p o n s e */
42
/******************************************************************************/
43
44
class
XrdLink
;
45
class
XrdOucSFVec
;
46
class
XrdXrootdTransit
;
47
48
class
XrdXrootdResponse
49
{
50
public
:
51
52
const
char
*
ID
() {
return
(
const
char
*)trsid;}
53
54
int
Send
(
void
);
55
int
Send
(
const
char
*msg);
56
int
Send
(
XErrorCode
ecode,
const
char
*msg);
57
int
Send
(
void
*data,
int
dlen);
58
int
Send
(
struct
iovec *,
int
iovcnt,
int
iolen=-1);
59
60
int
Send
(
XResponseType
rcode,
void
*data,
int
dlen);
61
int
Send
(
XResponseType
rcode,
struct
iovec *IOResp,
62
int
iornum,
int
iolen=-1);
63
int
Send
(
XResponseType
rcode,
int
info,
const
char
*data,
int
dsz=-1);
64
65
int
Send
(
int
fdnum,
long
long
offset,
int
dlen);
66
int
Send
(
XrdOucSFVec
*sfvec,
int
sfvnum,
int
dlen);
67
68
int
Send
(
ServerResponseStatus
&,
int
iLen=0);
69
int
Send
(
ServerResponseStatus
&,
int
iLen,
void
*data,
int
dlen);
70
int
Send
(
ServerResponseStatus
&,
int
iLen,
71
struct
iovec *,
int
iovcnt,
int
iolen=-1);
72
73
static
int
Send
(
XrdXrootdReqID
&ReqID,
XResponseType
Status,
74
struct
iovec *IOResp,
int
iornum,
int
iolen);
75
76
inline
void
Set
(
XrdLink
*lp) {Link = lp;}
77
inline
void
Set
(
XrdXrootdTransit
*tp) {Bridge = tp;}
78
void
Set
(
kXR_char
*stream);
79
80
bool
isOurs
() {
return
Bridge == 0;}
81
82
XrdLink
*
theLink
() {
return
Link;}
83
void
StreamID
(
kXR_char
*sid) {sid[0] = Resp.
streamid
[0];
84
sid[1] = Resp.
streamid
[1];
85
}
86
87
XrdXrootdResponse
(
XrdXrootdResponse
&rhs) {
Set
(rhs.Link);
88
Set
(rhs.Bridge);
89
Set
(rhs.Resp.
streamid
);
90
}
91
92
XrdXrootdResponse
() {Link = 0; Bridge = 0; *trsid =
'\0'
;
93
RespIO[0].iov_base = (caddr_t)&Resp;
94
RespIO[0].iov_len =
sizeof
(Resp);
95
}
96
~XrdXrootdResponse
() {}
97
98
XrdXrootdResponse
&
operator =
(
const
XrdXrootdResponse
&rhs)
99
{
Set
(rhs.Link);
100
Set
(rhs.Bridge);
101
Set
((
unsigned
char
*)rhs.Resp.
streamid
);
102
return
*
this
;
103
}
104
105
private
:
106
int
srsComplete(
ServerResponseStatus
&,
int
iLen,
int
dlen=0);
107
108
XrdXrootdTransit
*Bridge;
109
ServerResponseHeader
Resp;
110
XrdLink
*Link;
111
struct
iovec RespIO[3];
112
113
char
trsid[8];
// sizeof() does not work here
114
static
const
char
*TraceID;
115
};
116
#endif
XProtocol.hh
XErrorCode
XErrorCode
Definition:
XProtocol.hh:989
ServerResponseHeader::streamid
kXR_char streamid[2]
Definition:
XProtocol.hh:914
XResponseType
XResponseType
Definition:
XProtocol.hh:898
ServerResponseHeader
Definition:
XProtocol.hh:913
ServerResponseStatus
Definition:
XProtocol.hh:1259
XPtypes.hh
kXR_char
unsigned char kXR_char
Definition:
XPtypes.hh:65
XrdXrootdReqID.hh
XrdLink
Definition:
XrdLink.hh:52
XrdXrootdReqID
Definition:
XrdXrootdReqID.hh:36
XrdXrootdResponse
Definition:
XrdXrootdResponse.hh:49
XrdXrootdResponse::operator=
XrdXrootdResponse & operator=(const XrdXrootdResponse &rhs)
Definition:
XrdXrootdResponse.hh:98
XrdXrootdResponse::StreamID
void StreamID(kXR_char *sid)
Definition:
XrdXrootdResponse.hh:83
XrdXrootdResponse::XrdXrootdResponse
XrdXrootdResponse()
Definition:
XrdXrootdResponse.hh:92
XrdXrootdResponse::Set
void Set(XrdLink *lp)
Definition:
XrdXrootdResponse.hh:76
XrdXrootdResponse::XrdXrootdResponse
XrdXrootdResponse(XrdXrootdResponse &rhs)
Definition:
XrdXrootdResponse.hh:87
XrdXrootdResponse::Send
int Send(void)
Definition:
XrdXrootdResponse.cc:65
XrdXrootdResponse::isOurs
bool isOurs()
Definition:
XrdXrootdResponse.hh:80
XrdXrootdResponse::Set
void Set(XrdXrootdTransit *tp)
Definition:
XrdXrootdResponse.hh:77
XrdXrootdResponse::ID
const char * ID()
Definition:
XrdXrootdResponse.hh:52
XrdXrootdResponse::theLink
XrdLink * theLink()
Definition:
XrdXrootdResponse.hh:82
XrdXrootdResponse::~XrdXrootdResponse
~XrdXrootdResponse()
Definition:
XrdXrootdResponse.hh:96
XrdXrootdTransit
Definition:
XrdXrootdTransit.hh:53
XrdOucSFVec
Definition:
XrdOucSFVec.hh:43
XrdXrootd
XrdXrootdResponse.hh
Generated by
1.9.1