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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
/*
* Copyright 1999-2006 University of Chicago
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef GLOBUS_DONT_DOCUMENT_INTERNAL
/**
* @file globus_i_gram_protocol.h
* @brief GRAM Protocol Internals
*/
#include "globus_common.h"
#include "globus_gram_protocol.h"
#include "globus_io.h"
#ifdef __cplusplus
extern "C" {
#endif
/* Strings used in protocol framing, packing, unframing, and unpacking */
#define CRLF "\015\012"
#define GLOBUS_GRAM_HTTP_REQUEST_LINE \
"POST %s HTTP/1.1" CRLF
#define GLOBUS_GRAM_HTTP_HOST_LINE \
"Host: %s" CRLF
#define GLOBUS_GRAM_HTTP_CONTENT_TYPE_LINE \
"Content-Type: application/x-globus-gram" CRLF
#define GLOBUS_GRAM_HTTP_CONTENT_LENGTH_LINE \
"Content-Length: %ld" CRLF
#define GLOBUS_GRAM_HTTP_REPLY_LINE \
"HTTP/1.1 %3d %s" CRLF
#define GLOBUS_GRAM_HTTP_PARSE_REPLY_LINE \
"HTTP/1.1 %3d %[^" CRLF "]" CRLF
#define GLOBUS_GRAM_HTTP_CONNECTION_LINE \
"Connection: Close" CRLF
#define GLOBUS_GRAM_HTTP_PACK_PROTOCOL_VERSION_LINE \
"protocol-version: %d" CRLF
#define GLOBUS_GRAM_HTTP_PACK_JOB_STATE_MASK_LINE \
"job-state-mask: %d" CRLF
#define GLOBUS_GRAM_HTTP_PACK_CALLBACK_URL_LINE \
"callback-url: %s" CRLF
#define GLOBUS_GRAM_HTTP_PACK_STATUS_LINE \
"status: %d" CRLF
#define GLOBUS_GRAM_HTTP_PACK_FAILURE_CODE_LINE \
"failure-code: %d" CRLF
#define GLOBUS_GRAM_HTTP_PACK_JOB_FAILURE_CODE_LINE \
"job-failure-code: %d" CRLF
#define GLOBUS_GRAM_HTTP_PACK_JOB_MANAGER_URL_LINE \
"job-manager-url: %s" CRLF
#define GLOBUS_GRAM_HTTP_PACK_CLIENT_REQUEST_LINE \
"%s" CRLF
#define GLOBUS_GRAM_ATTR_PROTOCOL_VERSION "protocol-version"
#define GLOBUS_GRAM_ATTR_JOB_STATE_MASK "job-state-mask"
#define GLOBUS_GRAM_ATTR_CALLBACK_URL "callback-url"
#define GLOBUS_GRAM_ATTR_RSL "rsl"
#define GLOBUS_GRAM_ATTR_STATUS "status"
#define GLOBUS_GRAM_ATTR_JOB_MANAGER_URL "job-manager-url"
#define GLOBUS_GRAM_ATTR_FAILURE_CODE "failure-code"
typedef enum
{
GLOBUS_GRAM_PROTOCOL_REQUEST,
GLOBUS_GRAM_PROTOCOL_REPLY
}
globus_gram_protocol_read_type_t;
typedef struct
{
unsigned short port;
globus_bool_t allow_attach;
globus_io_handle_t * handle;
globus_gram_protocol_callback_t callback;
void * callback_arg;
volatile int connection_count;
globus_cond_t cond;
globus_bool_t listen_registered;
}
globus_i_gram_protocol_listener_t;
typedef struct
{
globus_bool_t got_header;
globus_bool_t accepting;
globus_byte_t * buf;
globus_size_t bufsize;
globus_gram_protocol_read_type_t read_type;
globus_size_t payload_length;
globus_size_t n_read;
globus_gram_protocol_callback_t callback;
void * callback_arg;
globus_byte_t * replybuf;
globus_size_t replybufsize;
globus_io_handle_t * io_handle;
globus_gram_protocol_handle_t handle;
globus_i_gram_protocol_listener_t * listener;
int rc;
char * uri;
/* added for delegation support */
globus_bool_t keep_open;
globus_size_t token_length;
globus_gram_protocol_delegation_callback_t
delegation_callback;
OM_uint32 delegation_major_status;
OM_uint32 delegation_minor_status;
void * delegation_arg;
gss_cred_id_t delegation_cred;
gss_OID_set delegation_restriction_oids;
gss_buffer_set_t delegation_restriction_buffers;
OM_uint32 delegation_req_flags;
OM_uint32 delegation_time_req;
gss_buffer_desc delegation_input_token;
gss_buffer_desc delegation_output_token;
/* added for gram authz callout support */
gss_ctx_id_t context;
}
globus_i_gram_protocol_connection_t;
int
globus_i_gram_protocol_callback_disallow(
globus_i_gram_protocol_listener_t * listener);
void
globus_i_gram_protocol_error_hack_replace_message(
int error_code,
const char * message);
void
globus_i_gram_protocol_error_destroy(
void * arg);
extern globus_mutex_t globus_i_gram_protocol_mutex;
extern globus_cond_t globus_i_gram_protocol_cond;
extern globus_list_t * globus_i_gram_protocol_listeners;
extern globus_list_t * globus_i_gram_protocol_connections;
extern globus_list_t * globus_i_gram_protocol_old_creds;
extern globus_bool_t globus_i_gram_protocol_shutdown_called;
extern globus_io_attr_t globus_i_gram_protocol_default_attr;
extern int globus_i_gram_protocol_num_connects;
extern int globus_i_gram_protocol_max_concurrency;
extern globus_gram_protocol_handle_t globus_i_gram_protocol_handle;
extern globus_thread_key_t globus_i_gram_protocol_error_key;
#ifdef __cplusplus
}
#endif
#endif /* GLOBUS_DONT_DOCUMENT_INTERNAL */
|
