~ubuntu-branches/ubuntu/utopic/gridengine/utopic

int cl_com_cached_gethostbyname(const char *hostname, char **unique_hostname, struct in_addr *copy_addr,struct hostent **he_copy, int* system_error_value);

int cl_com_cached_gethostbyaddr( struct in_addr *addr, char **unique_hostname,struct hostent **he_copy,int* system_error_val );

char* cl_com_get_h_error_string(int h_error);

int cl_com_compare_hosts(const char* host1, const char* host2);

int cl_com_set_resolve_method(cl_host_resolve_method_t method, char* local_domain_name);

int cl_com_free_handle_statistic(cl_com_handle_statistic_t** statistic);

int cl_com_free_hostent(cl_com_hostent_t **hostent_p); /* CR check */

int cl_com_free_hostspec(cl_com_host_spec_t **hostspec);

int cl_com_print_host_info(cl_com_hostent_t *hostent_p ); /* CR check */

int cl_com_create_debug_client_setup(cl_debug_client_setup_t** new_setup,

cl_debug_client_t dc_mode,

cl_bool_t dc_dump_flag,

int dc_app_log_level);

int cl_com_free_debug_client_setup(cl_debug_client_setup_t** new_setup);

int cl_com_create_ssl_setup(cl_ssl_setup_t** new_setup,

cl_ssl_cert_mode_t ssl_cert_mode,

cl_ssl_method_t ssl_method,

char* ssl_CA_cert_pem_file,

100

char* ssl_CA_key_pem_file,

101

char* ssl_cert_pem_file,

102

char* ssl_key_pem_file,

103

char* ssl_rand_file,

104

char* ssl_reconnect_file,

105

char* ssl_crl_file,

106

unsigned long ssl_refresh_time,

107

char* ssl_password,

108

cl_ssl_verify_func_t ssl_verify_func);

109

110

int cl_com_dup_ssl_setup(cl_ssl_setup_t** new_setup, cl_ssl_setup_t* source);

111

int cl_com_free_ssl_setup(cl_ssl_setup_t** del_setup);

112

113

const char* cl_com_get_framework_type(cl_com_connection_t* connection); /* CR check */

114

const char* cl_com_get_connection_type(cl_com_connection_t* connection); /* CR check */

115

const char* cl_com_get_service_handler_flag(cl_com_connection_t* connection); /* CR check */

116

const char* cl_com_get_data_write_flag(cl_com_connection_t* connection); /* CR check */

117

const char* cl_com_get_data_read_flag(cl_com_connection_t* connection); /* CR check */

118

const char* cl_com_get_connection_state(cl_com_connection_t* connection); /* CR check */

119

const char* cl_com_get_connection_sub_state(cl_com_connection_t* connection);

120

const char* cl_com_get_data_flow_type(cl_com_connection_t* connection); /* CR check */

121

122

/* This can be called by an signal handler to trigger abort of communications */

123

void cl_com_ignore_timeouts(cl_bool_t flag);

124

cl_bool_t cl_com_get_ignore_timeouts_flag(void);

125

126

127

/* message functions */

128

int cl_com_setup_message(cl_com_message_t** message, cl_com_connection_t* connection, cl_byte_t* data,unsigned long size, cl_xml_ack_type_t ack_type, unsigned long response_id, unsigned long tag); /* *message must be zero */

129

int cl_com_create_message(cl_com_message_t** message);

130

int cl_com_free_message(cl_com_message_t** message);

131

132

int cl_com_create_connection(cl_com_connection_t** connection);

133

134

int cl_com_free_connection(cl_com_connection_t** connection);

135

use cl_com_close_connection();

136

137

138

/* after this line are the main functions used by lib user */

139

/* ======================================================= */

140

141

142

int cl_com_connection_complete_accept(cl_com_connection_t* connection,

143

long timeout);

144

145

int cl_com_connection_complete_shutdown(cl_com_connection_t* connection);

146

147

148

int cl_com_open_connection(cl_com_connection_t* connection,

149

int timeout,

150

cl_com_endpoint_t* remote_endpoint,

151

cl_com_endpoint_t* local_endpoint); /* CR check */

152

153

int cl_com_close_connection(cl_com_connection_t** connection); /* CR check */

154

155

int cl_com_read_GMSH(cl_com_connection_t* connection, unsigned long *only_one_read);

156

int cl_com_read(cl_com_connection_t* connection, cl_byte_t* message, unsigned long size, unsigned long* only_one_read);

157

int cl_com_write(cl_com_connection_t* connection, cl_byte_t* message, unsigned long size, unsigned long *only_one_write);

158

159

160

161

/* This functions need service connection pointer = cl_com_connection_request_handler_setup */

162

/* ======================================================================================== */

163

164

int cl_com_connection_get_connect_port(cl_com_connection_t* connection, int* port);

165

int cl_com_connection_set_connect_port(cl_com_connection_t* connection, int port);

166

167

int cl_com_connection_get_service_port(cl_com_connection_t* connection, int* port);

168

int cl_com_connection_get_fd(cl_com_connection_t* connection, int* fd);

169

int cl_com_connection_get_client_socket_in_port(cl_com_connection_t* connection, int* port);

170

171

172

/* setup service */

173

int cl_com_connection_request_handler_setup(cl_com_connection_t* connection,

174

cl_com_endpoint_t* local_endpoint );

175

176

/* check for new service connection clients */

177

int cl_com_connection_request_handler(cl_com_connection_t* connection,

178

cl_com_connection_t** new_connection);

179

/* cleanup service */

180

int cl_com_connection_request_handler_cleanup(cl_com_connection_t* connection);

181

182

/* check open connection list for new messages */

183

int cl_com_open_connection_request_handler(cl_com_handle_t* handle,

184

int timeout_val_sec,

185

int timeout_val_usec,

186

cl_select_method_t select_mode );

187

188

int cl_com_connection_complete_request(cl_raw_list_t* connection_list, cl_connection_list_elem_t* elem, long timeout, cl_select_method_t select_mode );

189

190

191

#endif /* __CL_COMMUNICATION_H */

192

Older »