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
|
#ifndef __SGE_GDI2_H
#define __SGE_GDI2_H
/*___INFO__MARK_BEGIN__*/
/*************************************************************************
*
* The Contents of this file are made available subject to the terms of
* the Sun Industry Standards Source License Version 1.2
*
* Sun Microsystems Inc., March, 2001
*
*
* Sun Industry Standards Source License Version 1.2
* =================================================
* The contents of this file are subject to the Sun Industry Standards
* Source License Version 1.2 (the "License"); You may not use this file
* except in compliance with the License. You may obtain a copy of the
* License at http://gridengine.sunsource.net/Gridengine_SISSL_license.html
*
* Software provided under this License is provided on an "AS IS" basis,
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
* See the License for the specific provisions governing your rights and
* obligations concerning the Software.
*
* The Initial Developer of the Original Code is: Sun Microsystems, Inc.
*
* Copyright: 2001 by Sun Microsystems, Inc.
*
* All Rights Reserved.
*
************************************************************************/
/*___INFO__MARK_END__*/
#include "cull/cull_list.h"
#include "gdi/sge_gdi_ctx.h"
#include "sgeobj/sge_conf.h"
#ifdef __cplusplus
extern "C" {
#endif
enum {
TAG_NONE = 0, /* usable e.g. as delimiter in a tag array */
TAG_OLD_REQUEST,
TAG_GDI_REQUEST,
TAG_ACK_REQUEST,
TAG_REPORT_REQUEST,
TAG_FINISH_REQUEST,
TAG_JOB_EXECUTION,
TAG_SLAVE_ALLOW,
TAG_CHANGE_TICKET,
TAG_SIGJOB,
TAG_SIGQUEUE,
TAG_KILL_EXECD,
TAG_NEW_FEATURES, /*12*/
TAG_GET_NEW_CONF,
TAG_JOB_REPORT, /* cull based job reports */
TAG_TASK_EXIT,
TAG_TASK_TID,
TAG_EVENT_CLIENT_EXIT,
TAG_FULL_LOAD_REPORT
#ifdef KERBEROS
,TAG_AUTH_FAILURE
#endif
};
typedef struct {
char snd_host[CL_MAXHOSTLEN]; /* sender hostname; NULL -> all */
char snd_name[CL_MAXHOSTLEN]; /* sender name (aka 'commproc'); NULL -> all */
u_short snd_id; /* sender identifier; 0 -> all */
int tag; /* message tag; TAG_NONE -> all */
u_long32 request_mid; /* message id of request */
sge_pack_buffer buf; /* message buffer */
} struct_msg_t;
lList
*sge_gdi2(sge_gdi_ctx_class_t *ctx, u_long32 target, u_long32 cmd,
lList **lpp, lCondition *cp, lEnumeration *enp, bool use_euid_egid);
int
sge_gdi2_multi(sge_gdi_ctx_class_t *ctx, lList **alpp, int mode,
u_long32 target, u_long32 cmd, lList **lp,
lCondition *cp, lEnumeration *enp, bool use_euid_egid, state_gdi_multi *state, bool do_copy);
bool
sge_gdi2_is_done(sge_gdi_ctx_class_t* ctx, lList **alpp, state_gdi_multi *state);
bool
sge_gdi2_wait(sge_gdi_ctx_class_t* ctx, lList **alpp, lList **malpp,
state_gdi_multi *state);
int sge_gdi2_get_any_request(sge_gdi_ctx_class_t *ctx, char *rhost, char *commproc, u_short *id, sge_pack_buffer *pb,
int *tag, int synchron, u_long32 for_request_mid, u_long32* mid);
int sge_gdi2_send_any_request(sge_gdi_ctx_class_t *ctx, int synchron, u_long32 *mid,
const char *rhost, const char *commproc, int id,
sge_pack_buffer *pb,
int tag, u_long32 response_id, lList **alpp);
lList *gdi2_kill(sge_gdi_ctx_class_t *thiz, lList *id_list, const char *cell, u_long32 option_flags, u_long32 action_flag);
lList *gdi2_tsm( sge_gdi_ctx_class_t *thiz, const char *schedd_name, const char *cell);
bool sge_gdi2_check_permission(sge_gdi_ctx_class_t *ctx, lList **alpp, int option);
bool sge_gdi2_get_mapping_name(sge_gdi_ctx_class_t *ctx, const char *requestedHost,
char *buf, int buflen);
int gdi2_send_message_pb(sge_gdi_ctx_class_t *ctx,
int synchron, const char *tocomproc, int toid,
const char *tohost, int tag, sge_pack_buffer *pb,
u_long32 *mid);
int gdi2_receive_message(sge_gdi_ctx_class_t *ctx,
char *fromcommproc, u_short *fromid, char *fromhost,
int *tag, char **buffer, u_long32 *buflen, int synchron);
int gdi2_get_configuration(sge_gdi_ctx_class_t *ctx, const char *config_name,
lListElem **gepp, lListElem **lepp );
int gdi2_get_merged_configuration(sge_gdi_ctx_class_t *ctx,
lList **conf_list);
int gdi2_wait_for_conf(sge_gdi_ctx_class_t *ctx, lList **conf_list);
int report_list_send(sge_gdi_ctx_class_t *ctx,
const lList *rlp, const char *rhost,
const char *commproc, int id,
int synchron);
int sge_gdi2_shutdown(void **context);
/*
** commlib handler functions
*/
#include "comm/lists/cl_list_types.h"
const char* sge_dump_message_tag(unsigned long tag);
typedef enum sge_gdi_stored_com_error_type {
SGE_COM_ACCESS_DENIED = 101,
SGE_COM_ENDPOINT_NOT_UNIQUE,
SGE_COM_WAS_COMMUNICATION_ERROR
} sge_gdi_stored_com_error_t;
bool sge_get_com_error_flag(u_long32 progid, sge_gdi_stored_com_error_t error_type, bool reset_error_flag);
void general_communication_error(const cl_application_error_list_elem_t* commlib_error);
int gdi_log_flush_func(cl_raw_list_t* list_p);
#ifdef DEBUG_CLIENT_SUPPORT
void gdi_rmon_print_callback_function(const char *progname,
const char *message,
unsigned long traceid,
unsigned long pid,
unsigned long thread_id);
#endif
bool gdi2_send_multi_sync(sge_gdi_ctx_class_t* ctx, lList **alpp,
state_gdi_multi *state);
bool
sge_gdi_extract_answer(lList **alpp, u_long32 cmd, u_long32 target, int id,
lList *mal, lList **olpp);
void gdi2_default_exit_func(void **ref_ctx, int i);
#ifdef __cplusplus
}
#endif
#endif
|
