17#if !defined(GLOBUS_XIO_DRIVER_H)
18#define GLOBUS_XIO_DRIVER_H 1
20#include "globus_common.h"
21#include "globus_xio_load.h"
22#include "globus_common.h"
23#include "globus_xio_types.h"
24#include "globus_xio.h"
25#include "globus_xio_util.h"
35#define GlobusIXIOAttrGetDS(_out_ds, _in_attr, _in_driver) \
39 globus_i_xio_attr_t * _attr; \
40 globus_xio_driver_t _driver; \
41 globus_i_xio_attr_ent_t * _entry; \
45 _driver = (_in_driver); \
47 if(_in_attr == NULL) \
53 _entry = _attr->entry; \
54 for(_ctr = 0; _ctr < _attr->ndx && _ds == NULL; _ctr++) \
56 if(_entry[_ctr].driver == _driver) \
58 _ds = _entry[_ctr].driver_data; \
274 globus_xio_operation_t op,
275 globus_result_t result,
302 globus_xio_operation_t op,
303 globus_result_t result,
304 globus_size_t nbytes,
308typedef globus_result_t
309(*globus_xio_driver_push_driver_t)(
310 globus_xio_driver_t driver,
311 globus_xio_stack_t stack);
314globus_xio_driver_attr_cntl(
315 globus_xio_operation_t op,
316 globus_xio_driver_t driver,
321globus_xio_driver_data_descriptor_cntl(
322 globus_xio_operation_t op,
323 globus_xio_driver_t driver,
338 globus_xio_driver_handle_t handle,
339 globus_xio_driver_t driver,
346typedef globus_result_t
347(*globus_xio_driver_get_driver_t)(
348 globus_xio_driver_t * out_driver);
357typedef globus_result_t
359 void ** out_driver_attr);
368typedef globus_result_t
380typedef globus_result_t
403typedef globus_result_t
434typedef globus_result_t
437 const globus_xio_contact_t * contact_info,
438 globus_xio_operation_t op);
466globus_xio_driver_pass_server_init(
467 globus_xio_operation_t op,
468 const globus_xio_contact_t * contact_info,
469 void * driver_server);
482typedef globus_result_t
484 void * driver_server);
506typedef globus_result_t
508 void * driver_server,
509 globus_xio_operation_t op);
512globus_xio_driver_pass_accept(
513 globus_xio_operation_t op,
521(*globus_xio_driver_cancel_callback_t)(
522 globus_xio_operation_t op,
524 globus_xio_error_type_t reason);
547 globus_xio_operation_t op,
549 globus_result_t result);
568typedef globus_result_t
570 void * driver_server,
578typedef globus_result_t
579(*globus_xio_driver_link_cntl_t)(
594typedef globus_result_t
630typedef globus_result_t
632 const globus_xio_contact_t * contact_info,
635 globus_xio_operation_t op);
641typedef globus_result_t
643 const globus_xio_contact_t * contact_info,
646 globus_xio_operation_t op);
678 globus_xio_operation_t op,
679 const globus_xio_contact_t * contact_info,
704 void * driver_handle,
705 globus_xio_operation_t op,
706 globus_result_t result);
731 globus_xio_operation_t * operation,
732 globus_xio_driver_handle_t handle);
738globus_xio_driver_operation_destroy(
739 globus_xio_operation_t operation);
745globus_xio_driver_operation_cancel(
746 globus_xio_driver_handle_t handle,
747 globus_xio_operation_t operation);
759 globus_xio_operation_t operation);
772typedef globus_result_t
780globus_xio_driver_merge_handle(
781 globus_xio_operation_t op,
782 globus_xio_driver_handle_t handle);
806typedef globus_result_t
808 void * driver_specific_handle,
810 globus_xio_operation_t op);
830 globus_xio_operation_t op,
832 void * callback_arg);
851 globus_xio_operation_t op,
852 globus_result_t result);
880typedef globus_result_t
882 void * driver_specific_handle,
883 const globus_xio_iovec_t * iovec,
885 globus_xio_operation_t op);
920 globus_xio_operation_t op,
921 globus_xio_iovec_t * iovec,
923 globus_size_t wait_for,
946 globus_xio_operation_t op,
947 globus_result_t result,
948 globus_size_t nread);
976 globus_xio_operation_t op);
1002 globus_xio_operation_t op);
1030typedef globus_result_t
1032 void * driver_specific_handle,
1033 const globus_xio_iovec_t * iovec,
1035 globus_xio_operation_t op);
1071 globus_xio_operation_t op,
1072 globus_xio_iovec_t * iovec,
1074 globus_size_t wait_for,
1097 globus_xio_operation_t op,
1098 globus_result_t result,
1099 globus_size_t nwritten);
1127 globus_xio_operation_t top_op,
1128 globus_xio_operation_t bottom_op);
1193globus_xio_driver_init(
1194 globus_xio_driver_t * driver,
1195 const char * driver_name,
1202globus_xio_driver_get_user_data(
1203 globus_xio_driver_t in_driver,
1204 void ** out_user_data);
1207globus_xio_operation_attr_cntl(
1208 globus_xio_operation_t op,
1209 globus_xio_attr_cmd_t cmd,
1216globus_xio_driver_destroy(
1217 globus_xio_driver_t driver);
1223globus_xio_driver_set_transport(
1224 globus_xio_driver_t driver,
1235globus_xio_driver_set_transform(
1236 globus_xio_driver_t driver,
1242 globus_xio_driver_push_driver_t push_driver_func);
1248globus_xio_driver_set_server(
1249 globus_xio_driver_t driver,
1254 globus_xio_driver_link_cntl_t link_cntl_func,
1259 globus_xio_driver_t driver,
1265globus_xio_driver_set_attr(
1266 globus_xio_driver_t driver,
1276globus_xio_operation_block_timeout(
1277 globus_xio_operation_t op);
1280globus_xio_operation_unblock_timeout(
1281 globus_xio_operation_t op);
1284globus_xio_operation_refresh_timeout(
1285 globus_xio_operation_t op);
1289globus_xio_operation_enable_cancel(
1290 globus_xio_operation_t op,
1291 globus_xio_driver_cancel_callback_t cb,
1295globus_xio_operation_disable_cancel(
1296 globus_xio_operation_t op);
1299globus_xio_operation_is_canceled(
1300 globus_xio_operation_t op);
1303globus_xio_operation_get_wait_for(
1304 globus_xio_operation_t op);
1307globus_xio_operation_get_driver_specific(
1308 globus_xio_operation_t op);
1311globus_xio_operation_get_user_driver(
1312 globus_xio_operation_t op);
1315globus_xio_operation_get_transport_user_driver(
1316 globus_xio_operation_t op);
1319globus_xio_driver_handle_t
1320globus_xio_operation_get_driver_handle(
1321 globus_xio_operation_t op);
1327globus_xio_driver_handle_t
1328globus_xio_operation_get_driver_self_handle(
1329 globus_xio_operation_t op);
1332globus_xio_operation_get_data_descriptor(
1333 globus_xio_operation_t op,
1334 globus_bool_t force_create);
1337globus_xio_operation_copy_stack(
1338 globus_xio_operation_t op,
1339 globus_xio_stack_t * stack);
1345typedef globus_result_t
1346(*globus_xio_string_cntl_parse_func_t)(
1356typedef struct globus_xio_string_cntl_table_s
1360 globus_xio_string_cntl_parse_func_t parse_func;
1361} globus_xio_string_cntl_table_t;
1419 globus_xio_driver_t driver,
1420 globus_xio_string_cntl_table_t * table);
1428 globus_xio_driver_t driver,
1429 globus_xio_string_cntl_table_t * table);
1510globus_xio_string_cntl_formated_off(
1518globus_xio_string_cntl_formated_int(
1526globus_xio_string_cntl_string_list(
void globus_xio_driver_finished_read(globus_xio_operation_t op, globus_result_t result, globus_size_t nread)
Definition globus_xio_pass.c:1118
globus_result_t(* globus_xio_driver_transform_open_t)(const globus_xio_contact_t *contact_info, void *driver_link, void *driver_attr, globus_xio_operation_t op)
Open a handle.
Definition globus_xio_driver.h:631
void(* globus_xio_driver_callback_t)(globus_xio_operation_t op, globus_result_t result, void *user_arg)
Open and Close Callback Signature.
Definition globus_xio_driver.h:273
globus_result_t(* globus_xio_driver_transport_open_t)(const globus_xio_contact_t *contact_info, void *driver_link, void *driver_attr, globus_xio_operation_t op)
Definition globus_xio_driver.h:642
globus_result_t globus_xio_driver_pass_close(globus_xio_operation_t op, globus_xio_driver_callback_t cb, void *callback_arg)
Pass the close operation down the driver stack.
Definition globus_xio_pass.c:394
void globus_xio_driver_finished_open(void *driver_handle, globus_xio_operation_t op, globus_result_t result)
Definition globus_xio_pass.c:156
globus_result_t(* globus_xio_driver_attr_init_t)(void **out_driver_attr)
Definition globus_xio_driver.h:358
void globus_xio_driver_finished_close(globus_xio_operation_t op, globus_result_t result)
Definition globus_xio_pass.c:535
globus_result_t globus_xio_driver_pass_write(globus_xio_operation_t op, globus_xio_iovec_t *iovec, int iovec_count, globus_size_t wait_for, globus_xio_driver_data_callback_t cb, void *user_arg)
Definition globus_xio_pass.c:608
globus_result_t(* globus_xio_driver_server_cntl_t)(void *driver_server, int cmd, va_list ap)
Definition globus_xio_driver.h:569
void globus_xio_driver_set_eof_received(globus_xio_operation_t op)
Definition globus_xio_driver.c:1848
globus_result_t(* globus_xio_driver_server_accept_t)(void *driver_server, globus_xio_operation_t op)
Definition globus_xio_driver.h:507
globus_result_t(* globus_xio_driver_attr_copy_t)(void **dst, void *src)
Definition globus_xio_driver.h:369
globus_result_t globus_xio_driver_pass_read(globus_xio_operation_t op, globus_xio_iovec_t *iovec, int iovec_count, globus_size_t wait_for, globus_xio_driver_data_callback_t cb, void *user_arg)
Definition globus_xio_pass.c:931
globus_result_t(* globus_xio_driver_attr_destroy_t)(void *driver_attr)
Definition globus_xio_driver.h:381
void globus_xio_driver_finished_accept(globus_xio_operation_t op, void *driver_link, globus_result_t result)
Definition globus_xio_pass.c:1601
globus_result_t(* globus_xio_driver_attr_cntl_t)(void *driver_attr, int cmd, va_list ap)
Definition globus_xio_driver.h:404
globus_bool_t globus_xio_driver_eof_received(globus_xio_operation_t op)
Definition globus_xio_driver.c:1883
globus_result_t(* globus_xio_driver_close_t)(void *driver_specific_handle, void *driver_attr, globus_xio_operation_t op)
Close a handle.
Definition globus_xio_driver.h:807
globus_bool_t globus_xio_driver_operation_is_blocking(globus_xio_operation_t operation)
Definition globus_xio_driver.c:2321
globus_result_t globus_xio_driver_merge_operation(globus_xio_operation_t top_op, globus_xio_operation_t bottom_op)
globus_result_t(* globus_xio_driver_read_t)(void *driver_specific_handle, const globus_xio_iovec_t *iovec, int iovec_count, globus_xio_operation_t op)
Definition globus_xio_driver.h:881
globus_result_t globus_xio_driver_set_server_pre_init(globus_xio_driver_t driver, globus_xio_driver_server_init_t server_pre_init_func)
Server Pre-Init.
Definition globus_xio_driver.c:2109
globus_result_t globus_xio_driver_pass_open(globus_xio_operation_t op, const globus_xio_contact_t *contact_info, globus_xio_driver_callback_t cb, void *user_arg)
Definition globus_xio_pass.c:27
globus_result_t(* globus_xio_driver_write_t)(void *driver_specific_handle, const globus_xio_iovec_t *iovec, int iovec_count, globus_xio_operation_t op)
Definition globus_xio_driver.h:1031
globus_result_t(* globus_xio_driver_server_init_t)(void *driver_attr, const globus_xio_contact_t *contact_info, globus_xio_operation_t op)
Definition globus_xio_driver.h:435
globus_result_t globus_xio_driver_operation_create(globus_xio_operation_t *operation, globus_xio_driver_handle_t handle)
Definition globus_xio_driver.c:1043
globus_result_t(* globus_xio_driver_server_destroy_t)(void *driver_server)
Definition globus_xio_driver.h:483
void(* globus_xio_driver_data_callback_t)(globus_xio_operation_t op, globus_result_t result, globus_size_t nbytes, void *user_arg)
Definition globus_xio_driver.h:301
globus_result_t globus_xio_driver_handle_cntl(globus_xio_driver_handle_t handle, globus_xio_driver_t driver, int cmd,...)
Definition globus_xio_driver.c:1743
globus_result_t(* globus_xio_driver_link_destroy_t)(void *driver_link)
Definition globus_xio_driver.h:595
void globus_xio_driver_finished_write(globus_xio_operation_t op, globus_result_t result, globus_size_t nwritten)
Definition globus_xio_pass.c:757
globus_result_t(* globus_xio_driver_handle_cntl_t)(void *handle, int cmd, va_list ap)
Definition globus_xio_driver.h:773
globus_result_t globus_xio_string_cntl_int_int(void *attr, const char *key, const char *val, int cmd, globus_xio_driver_attr_cntl_t cntl_func)
Definition globus_xio_attr.c:1351
globus_result_t globus_xio_string_cntl_bool(void *attr, const char *key, const char *val, int cmd, globus_xio_driver_attr_cntl_t cntl_func)
Definition globus_xio_attr.c:1447
globus_result_t globus_xio_string_cntl_float(void *attr, const char *key, const char *val, int cmd, globus_xio_driver_attr_cntl_t cntl_func)
Definition globus_xio_attr.c:1400
globus_result_t globus_xio_string_cntl_int(void *attr, const char *key, const char *val, int cmd, globus_xio_driver_attr_cntl_t cntl_func)
Definition globus_xio_attr.c:1323
globus_result_t globus_xio_driver_string_cntl_set_table(globus_xio_driver_t driver, globus_xio_string_cntl_table_t *table)
Definition globus_xio_driver.c:2171
globus_result_t globus_xio_string_cntl_string(void *attr, const char *key, const char *val, int cmd, globus_xio_driver_attr_cntl_t cntl_func)
Definition globus_xio_attr.c:1428
globus_result_t globus_xio_string_cntl_bouncer(globus_xio_driver_attr_cntl_t cntl_func, void *attr, int cmd,...)
Definition globus_xio_attr.c:1190
globus_result_t globus_xio_driver_handle_string_cntl_set_table(globus_xio_driver_t driver, globus_xio_string_cntl_table_t *table)
Definition globus_xio_driver.c:2201