Commit 1076d339 authored by Pavan Balaji's avatar Pavan Balaji
Browse files

[svn-r5472] Use a consistent naming convention everywhere as a part of the overall

maintenance cleanup. Tools functionality is all HYDT_, utilities are
all HYDU_ and the rest are HYD_.
parent b5597a47
......@@ -104,9 +104,9 @@ for hydra_bss_name in ${hydra_bss_names}; do
fi
hydra_bss_makefiles="$hydra_bss_makefiles bootstrap/${hydra_bss_name}/Makefile"
hydra_bss_init_decl="${hydra_bss_init_decl}
HYD_Status HYD_BSCI_${hydra_bss_name}_init(void);"
HYD_status HYDT_bsci_${hydra_bss_name}_init(void);"
hydra_bss_name_array="${hydra_bss_name_array} \"${hydra_bss_name}\", "
hydra_bss_init_array="${hydra_bss_init_array} HYD_BSCI_${hydra_bss_name}_init, "
hydra_bss_init_array="${hydra_bss_init_array} HYDT_bsci_${hydra_bss_name}_init, "
case "$hydra_bss_name" in
ssh)
......@@ -161,9 +161,9 @@ for hydra_css_name in ${hydra_css_names}; do
fi
hydra_css_makefiles="$hydra_css_makefiles css/${hydra_css_name}/Makefile"
hydra_css_init_decl="${hydra_css_init_decl}
HYD_Status HYD_CSSI_${hydra_css_name}_init(void);"
HYD_status HYD_cssi_${hydra_css_name}_init(void);"
hydra_css_name_array="${hydra_css_name_array} \"${hydra_css_name}\", "
hydra_css_init_array="${hydra_css_init_array} HYD_CSSI_${hydra_css_name}_init, "
hydra_css_init_array="${hydra_css_init_array} HYD_cssi_${hydra_css_name}_init, "
case "$hydra_css_name" in
dummy)
......@@ -206,9 +206,9 @@ for hydra_rmk_name in ${hydra_rmk_names}; do
fi
hydra_rmk_makefiles="$hydra_rmk_makefiles rmk/${hydra_rmk_name}/Makefile"
hydra_rmk_init_decl="${hydra_rmk_init_decl}
HYD_Status HYD_RMKI_${hydra_rmk_name}_init(void);"
HYD_status HYD_rmki_${hydra_rmk_name}_init(void);"
hydra_rmk_name_array="${hydra_rmk_name_array} \"${hydra_rmk_name}\", "
hydra_rmk_init_array="${hydra_rmk_init_array} HYD_RMKI_${hydra_rmk_name}_init, "
hydra_rmk_init_array="${hydra_rmk_init_array} HYD_rmki_${hydra_rmk_name}_init, "
case "$hydra_rmk_name" in
dummy)
......
......@@ -7,17 +7,17 @@
#ifndef CSSI_H_INCLUDED
#define CSSI_H_INCLUDED
struct HYD_CSSI_fns {
HYD_Status(*init) (void);
HYD_Status(*query_string) (char *str);
HYD_Status(*finalize) (void);
struct HYD_cssi_fns {
HYD_status(*init) (void);
HYD_status(*query_string) (char *str);
HYD_status(*finalize) (void);
};
extern struct HYD_CSSI_fns HYD_CSSI_fns;
extern struct HYD_cssi_fns HYD_cssi_fns;
HYD_Status HYD_CSSI_init(char *css);
HYD_Status HYD_CSSI_query_string(char *str);
HYD_Status HYD_CSSI_finalize(void);
HYD_status HYD_cssi_init(char *css);
HYD_status HYD_cssi_query_string(char *str);
HYD_status HYD_cssi_finalize(void);
/* Each communication sub-system has to expose an initialization function */
@hydra_css_init_decl@
......
......@@ -9,7 +9,7 @@
#include "hydra_base.h"
HYD_Status HYD_CSSD_none_query_string(char *str);
HYD_Status HYD_CSSD_none_finalize(void);
HYD_status HYD_cssd_none_query_string(char *str);
HYD_status HYD_cssd_none_finalize(void);
#endif /* NONE_H_INCLUDED */
......@@ -8,9 +8,9 @@
#include "cssi.h"
#include "none.h"
HYD_Status HYD_CSSD_none_finalize(void)
HYD_status HYD_cssd_none_finalize(void)
{
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
......
......@@ -8,14 +8,14 @@
#include "cssi.h"
#include "none.h"
HYD_Status HYD_CSSI_none_init(void)
HYD_status HYD_cssi_none_init(void)
{
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
HYD_CSSI_fns.query_string = HYD_CSSD_none_query_string;
HYD_CSSI_fns.finalize = HYD_CSSD_none_finalize;
HYD_cssi_fns.query_string = HYD_cssd_none_query_string;
HYD_cssi_fns.finalize = HYD_cssd_none_finalize;
HYDU_FUNC_EXIT();
......
......@@ -8,9 +8,9 @@
#include "cssi.h"
#include "none.h"
HYD_Status HYD_CSSD_none_query_string(char *str)
HYD_status HYD_cssd_none_query_string(char *str)
{
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
......
......@@ -7,13 +7,13 @@
#include "hydra_utils.h"
#include "cssi.h"
HYD_Status HYD_CSSI_finalize(void)
HYD_status HYD_cssi_finalize(void)
{
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
status = HYD_CSSI_fns.finalize();
status = HYD_cssi_fns.finalize();
HYDU_FUNC_EXIT();
......
......@@ -7,34 +7,34 @@
#include "hydra_utils.h"
#include "cssi.h"
struct HYD_CSSI_fns HYD_CSSI_fns = { 0 };
struct HYD_cssi_fns HYD_cssi_fns = { 0 };
const char *HYD_CSSI_comp_array[] = { @hydra_css_name_array@ };
HYD_Status(*HYD_CSSI_comp_init[])(void) = { @hydra_css_init_array@ };
const char *HYD_cssi_comp_array[] = { @hydra_css_name_array@ };
HYD_status(*HYD_cssi_comp_init[])(void) = { @hydra_css_init_array@ };
HYD_Status HYD_CSSI_init(char *css)
HYD_status HYD_cssi_init(char *css)
{
int i;
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
for (i = 0; HYD_CSSI_comp_array[i]; i++) {
if (!strcmp(css, HYD_CSSI_comp_array[i])) {
status = (*HYD_CSSI_comp_init[i])();
for (i = 0; HYD_cssi_comp_array[i]; i++) {
if (!strcmp(css, HYD_cssi_comp_array[i])) {
status = (*HYD_cssi_comp_init[i])();
break;
}
}
if (HYD_CSSI_comp_array[i] == NULL)
if (HYD_cssi_comp_array[i] == NULL)
HYDU_ERR_SETANDJUMP1(status, HYD_INTERNAL_ERROR,
"unrecognized communication sub-system: %s\n", css);
/* These functions are mandatory */
if (HYD_CSSI_fns.query_string == NULL)
if (HYD_cssi_fns.query_string == NULL)
HYDU_ERR_SETANDJUMP(status, HYD_INTERNAL_ERROR,
"mandatory communication sub-system function undefined\n");
if (HYD_CSSI_fns.finalize == NULL)
if (HYD_cssi_fns.finalize == NULL)
HYDU_ERR_SETANDJUMP(status, HYD_INTERNAL_ERROR,
"mandatory communication sub-system function undefined\n");
......
......@@ -7,13 +7,13 @@
#include "hydra_utils.h"
#include "cssi.h"
HYD_Status HYD_CSSI_query_string(char *str)
HYD_status HYD_cssi_query_string(char *str)
{
HYD_Status status = HYD_SUCCESS;
HYD_status status = HYD_SUCCESS;
HYDU_FUNC_ENTER();
status = HYD_CSSI_fns.query_string(str);
status = HYD_cssi_fns.query_string(str);
HYDU_FUNC_EXIT();
......
......@@ -11,8 +11,8 @@
#include "hydra_base.h"
#include "hydra_utils.h"
struct HYD_Handle_ {
struct HYD_User_global user_global;
struct HYD_handle {
struct HYD_user_global user_global;
char *base_path;
int proxy_port;
......@@ -28,20 +28,20 @@ struct HYD_Handle_ {
int ranks_per_proc;
HYD_Status(*stdin_cb) (int fd, HYD_Event_t events, void *userp);
HYD_Status(*stdout_cb) (int fd, HYD_Event_t events, void *userp);
HYD_Status(*stderr_cb) (int fd, HYD_Event_t events, void *userp);
HYD_status(*stdin_cb) (int fd, HYD_event_t events, void *userp);
HYD_status(*stdout_cb) (int fd, HYD_event_t events, void *userp);
HYD_status(*stderr_cb) (int fd, HYD_event_t events, void *userp);
/* Start time and timeout. These are filled in by the launcher,
* but are utilized by the demux engine and the boot-strap server
* to decide how long we need to wait for. */
HYD_Time start;
HYD_Time timeout;
HYD_time start;
HYD_time timeout;
struct HYD_Proxy *proxy_list;
struct HYD_proxy *proxy_list;
int global_core_count;
struct HYD_Exec_info *exec_info_list;
struct HYD_exec_info *exec_info_list;
int global_process_count;
/* Random parameters used for internal code */
......@@ -51,8 +51,6 @@ struct HYD_Handle_ {
int stdin_buf_count;
};
typedef struct HYD_Handle_ HYD_Handle;
extern HYD_Handle HYD_handle;
extern struct HYD_handle HYD_handle;
#endif /* HYDRA_H_INCLUDED */
......@@ -112,7 +112,7 @@ typedef enum {
HYD_SOCK_ERROR,
HYD_INVALID_PARAM,
HYD_INTERNAL_ERROR
} HYD_Status;
} HYD_status;
/* Proxy type */
typedef enum {
......@@ -124,7 +124,7 @@ typedef enum {
HYD_LAUNCH_BOOT_FOREGROUND,
HYD_LAUNCH_SHUTDOWN,
HYD_LAUNCH_PERSISTENT
} HYD_Launch_mode_t;
} HYD_launch_mode_t;
#if defined(HAVE_PUTENV) && defined(NEEDS_PUTENV_DECL)
extern int putenv(char *string);
......@@ -134,46 +134,46 @@ extern int putenv(char *string);
int gethostname(char *name, size_t len);
#endif
typedef unsigned short HYD_Event_t;
typedef unsigned short HYD_event_t;
/* Environment information */
typedef struct HYD_Env {
typedef struct HYD_env {
char *env_name;
char *env_value;
struct HYD_Env *next;
} HYD_Env_t;
struct HYD_env *next;
} HYD_env_t;
typedef enum HYD_Env_overwrite {
typedef enum HYD_env_overwrite {
HYD_ENV_OVERWRITE_TRUE,
HYD_ENV_OVERWRITE_FALSE
} HYD_Env_overwrite_t;
} HYD_env_overwrite_t;
typedef enum {
HYD_ENV_PROP_UNSET,
HYD_ENV_PROP_ALL,
HYD_ENV_PROP_NONE,
HYD_ENV_PROP_LIST
} HYD_Env_prop_t;
} HYD_env_prop_t;
struct HYD_Env_global {
HYD_Env_t *system;
HYD_Env_t *user;
HYD_Env_t *inherited;
struct HYD_env_global {
HYD_env_t *system;
HYD_env_t *user;
HYD_env_t *inherited;
char *prop;
};
/* Executables on a proxy */
struct HYD_Proxy_exec {
struct HYD_proxy_exec {
char *exec[HYD_NUM_TMP_STRINGS];
int proc_count;
HYD_Env_t *user_env;
HYD_env_t *user_env;
char *env_prop;
struct HYD_Proxy_exec *next;
struct HYD_proxy_exec *next;
};
/* Proxy information */
struct HYD_Proxy {
struct HYD_proxy {
char *hostname;
char **exec_launch_info;
......@@ -189,27 +189,27 @@ struct HYD_Proxy {
int proxy_core_count;
int proxy_process_count;
struct HYD_Proxy_exec *exec_list;
struct HYD_proxy_exec *exec_list;
int *exit_status;
int control_fd;
struct HYD_Proxy *next;
struct HYD_proxy *next;
};
struct HYD_Exec_info {
struct HYD_exec_info {
int process_count;
char *exec[HYD_NUM_TMP_STRINGS];
/* Local environment */
HYD_Env_t *user_env;
HYD_env_t *user_env;
char *env_prop;
struct HYD_Exec_info *next;
struct HYD_exec_info *next;
};
/* Global user parameters */
struct HYD_User_global {
struct HYD_user_global {
/* Bootstrap server */
char *bootstrap;
char *bootstrap_exec;
......@@ -227,8 +227,8 @@ struct HYD_User_global {
int enablex;
int debug;
char *wdir;
HYD_Launch_mode_t launch_mode;
struct HYD_Env_global global_env;
HYD_launch_mode_t launch_mode;
struct HYD_env_global global_env;
};
#endif /* HYDRA_BASE_H_INCLUDED */
......@@ -10,15 +10,15 @@
#include "hydra_base.h"
/* bind */
HYD_Status HYDU_bind_init(char *binding, char *bindlib);
void HYDU_bind_finalize(void);
HYD_Status HYDU_bind_process(int core);
int HYDU_bind_get_core_id(int id);
HYD_status HYDT_bind_init(char *binding, char *bindlib);
void HYDT_bind_finalize(void);
HYD_status HYDT_bind_process(int core);
int HYDT_bind_get_core_id(int id);
/* checkpointing */
HYD_Status HYDU_ckpoint_init(char *ckpointlib, char *ckpoint_prefix);
HYD_Status HYDU_ckpoint_suspend(void);
HYD_Status HYDU_ckpoint_restart(HYD_Env_t * envlist, int num_ranks, int ranks[], int *in,
HYD_status HYDT_ckpoint_init(char *ckpointlib, char *ckpoint_prefix);
HYD_status HYDT_ckpoint_suspend(void);
HYD_status HYDT_ckpoint_restart(HYD_env_t * envlist, int num_ranks, int ranks[], int *in,
int *out, int *err);
#endif /* HYDRA_TOOLS_H_INCLUDED */
......@@ -19,23 +19,23 @@
#endif
#if !defined COMPILER_ACCEPTS_VA_ARGS
#define HYDU_Error_printf printf
#define HYDU_error_printf printf
#elif defined __FILE__ && defined HYDU_FUNC
#define HYDU_Error_printf(...) \
#define HYDU_error_printf(...) \
{ \
HYDU_dump_prefix(stderr); \
HYDU_dump_noprefix(stderr, "%s (%s:%d): ", __func__, __FILE__, __LINE__); \
HYDU_dump_noprefix(stderr, __VA_ARGS__); \
}
#elif defined __FILE__
#define HYDU_Error_printf(...) \
#define HYDU_error_printf(...) \
{ \
HYDU_dump_prefix(stderr); \
HYDU_dump_noprefix(stderr, "%s (%d): ", __FILE__, __LINE__); \
HYDU_dump_noprefix(stderr, __VA_ARGS__); \
}
#else
#define HYDU_Error_printf(...) \
#define HYDU_error_printf(...) \
{ \
HYDU_dump_prefix(stderr); \
HYDU_dump_noprefix(stderr, __VA_ARGS__); \
......@@ -46,7 +46,7 @@
{ \
if (status != HYD_SUCCESS && status != HYD_GRACEFUL_ABORT) { \
if (strlen(message)) \
HYDU_Error_printf(message); \
HYDU_error_printf(message); \
goto fn_fail; \
} \
else if (status == HYD_GRACEFUL_ABORT) { \
......@@ -59,7 +59,7 @@
status = error; \
if (status != HYD_SUCCESS && status != HYD_GRACEFUL_ABORT) { \
if (strlen(message)) \
HYDU_Error_printf(message); \
HYDU_error_printf(message); \
goto fn_fail; \
} \
else if (status == HYD_GRACEFUL_ABORT) { \
......@@ -84,7 +84,7 @@
status = error; \
if (status != HYD_SUCCESS && status != HYD_GRACEFUL_ABORT) { \
if (strlen(message)) \
HYDU_Error_printf(message, arg1); \
HYDU_error_printf(message, arg1); \
goto fn_fail; \
} \
else if (status == HYD_GRACEFUL_ABORT) { \
......@@ -97,7 +97,7 @@
status = error; \
if (status != HYD_SUCCESS && status != HYD_GRACEFUL_ABORT) { \
if (strlen(message)) \
HYDU_Error_printf(message, arg1, arg2); \
HYDU_error_printf(message, arg1, arg2); \
goto fn_fail; \
} \
else if (status == HYD_GRACEFUL_ABORT) { \
......@@ -106,9 +106,9 @@
}
#if defined ENABLE_WARNINGS
#define HYDU_Warn_printf HYDU_Error_printf
#define HYDU_warn_printf HYDU_error_printf
#else
#define HYDU_Warn_printf(...) {}
#define HYDU_warn_printf(...) {}
#endif /* ENABLE_WARNINGS */
/* We need to add more information in here later */
......@@ -122,60 +122,60 @@
/* alloc */
void HYDU_init_user_global(struct HYD_User_global *user_global);
void HYDU_init_global_env(struct HYD_Env_global *global_env);
HYD_Status HYDU_alloc_proxy(struct HYD_Proxy **proxy);
HYD_Status HYDU_alloc_exec_info(struct HYD_Exec_info **exec_info);
void HYDU_free_exec_info_list(struct HYD_Exec_info *exec_info_list);
void HYDU_free_proxy_list(struct HYD_Proxy *proxy_list);
HYD_Status HYDU_alloc_proxy_exec(struct HYD_Proxy_exec **exec);
void HYDU_init_user_global(struct HYD_user_global *user_global);
void HYDU_init_global_env(struct HYD_env_global *global_env);
HYD_status HYDU_alloc_proxy(struct HYD_proxy **proxy);
HYD_status HYDU_alloc_exec_info(struct HYD_exec_info **exec_info);
void HYDU_free_exec_info_list(struct HYD_exec_info *exec_info_list);
void HYDU_free_proxy_list(struct HYD_proxy *proxy_list);
HYD_status HYDU_alloc_proxy_exec(struct HYD_proxy_exec **exec);
/* args */
HYD_Status HYDU_find_in_path(const char *execname, char **path);
HYD_status HYDU_find_in_path(const char *execname, char **path);
char *HYDU_getcwd(void);
HYD_Status HYDU_get_base_path(const char *execname, char *wdir, char **path);
HYD_Status HYDU_parse_hostfile(char *hostfile,
HYD_Status(*process_token) (char *token, int newline));
HYD_status HYDU_get_base_path(const char *execname, char *wdir, char **path);
HYD_status HYDU_parse_hostfile(char *hostfile,
HYD_status(*process_token) (char *token, int newline));
/* debug */
HYD_Status HYDU_dbg_init(const char *str);
HYD_status HYDU_dbg_init(const char *str);
void HYDU_dump_prefix(FILE * fp);
void HYDU_dump_noprefix(FILE * fp, const char *str, ...);
void HYDU_dump(FILE * fp, const char *str, ...);
/* env */
HYD_Status HYDU_env_to_str(HYD_Env_t * env, char **str);
HYD_Status HYDU_str_to_env(char *str, HYD_Env_t ** env);
HYD_Status HYDU_list_inherited_env(HYD_Env_t ** env_list);
HYD_Env_t *HYDU_env_list_dup(HYD_Env_t * env);
HYD_Status HYDU_env_create(HYD_Env_t ** env, const char *env_name, char *env_value);
HYD_Status HYDU_env_free(HYD_Env_t * env);
HYD_Status HYDU_env_free_list(HYD_Env_t * env);
HYD_Env_t *HYDU_env_lookup(char *env_name, HYD_Env_t * env_list);
HYD_Status HYDU_append_env_to_list(HYD_Env_t env, HYD_Env_t ** env_list);
HYD_Status HYDU_putenv(HYD_Env_t * env, HYD_Env_overwrite_t overwrite);
HYD_Status HYDU_putenv_list(HYD_Env_t * env_list, HYD_Env_overwrite_t overwrite);
HYD_Status HYDU_comma_list_to_env_list(char *str, HYD_Env_t ** env_list);
HYD_status HYDU_env_to_str(HYD_env_t * env, char **str);
HYD_status HYDU_str_to_env(char *str, HYD_env_t ** env);
HYD_status HYDU_list_inherited_env(HYD_env_t ** env_list);
HYD_env_t *HYDU_env_list_dup(HYD_env_t * env);
HYD_status HYDU_env_create(HYD_env_t ** env, const char *env_name, char *env_value);
HYD_status HYDU_env_free(HYD_env_t * env);
HYD_status HYDU_env_free_list(HYD_env_t * env);
HYD_env_t *HYDU_env_lookup(char *env_name, HYD_env_t * env_list);
HYD_status HYDU_append_env_to_list(HYD_env_t env, HYD_env_t ** env_list);
HYD_status HYDU_putenv(HYD_env_t * env, HYD_env_overwrite_t overwrite);
HYD_status HYDU_putenv_list(HYD_env_t * env_list, HYD_env_overwrite_t overwrite);
HYD_status HYDU_comma_list_to_env_list(char *str, HYD_env_t ** env_list);
/* launch */
#if defined HAVE_THREAD_SUPPORT
struct HYD_Thread_context {
struct HYD_thread_context {
pthread_t thread;
};
#endif /* HAVE_THREAD_SUPPORT */
HYD_Status HYDU_create_process(char **client_arg, HYD_Env_t * env_list,
HYD_status HYDU_create_process(char **client_arg, HYD_env_t * env_list,
int *in, int *out, int *err, int *pid, int core);
HYD_Status HYDU_fork_and_exit(int core);
HYD_status HYDU_fork_and_exit(int core);
#if defined HAVE_THREAD_SUPPORT
HYD_Status HYDU_create_thread(void *(*func) (void *), void *args,
struct HYD_Thread_context *ctxt);
HYD_Status HYDU_join_thread(struct HYD_Thread_context ctxt);
HYD_status HYDU_create_thread(void *(*func) (void *), void *args,
struct HYD_thread_context *ctxt);
HYD_status HYDU_join_thread(struct HYD_thread_context ctxt);
#endif /* HAVE_THREAD_SUPPORT */
/* others */
HYD_Status HYDU_merge_proxy_segment(char *name, int start_pid, int core_count,
struct HYD_Proxy **proxy_list);
HYD_status HYDU_merge_proxy_segment(char *name, int start_pid, int core_count,
struct HYD_proxy **proxy_list);
int HYDU_local_to_global_id(int local_id, int start_pid, int core_count,
int global_core_count);
......@@ -194,27 +194,27 @@ int HYDU_local_to_global_id(int local_id, int start_pid, int core_count,
extern char *strsignal(int);
#endif
HYD_Status HYDU_set_signal(int signum, void (*handler) (int));
HYD_Status HYDU_set_common_signals(void (*handler) (int));
HYD_status HYDU_set_signal(int signum, void (*handler) (int));
HYD_status HYDU_set_common_signals(void (*handler) (int));
/* Sock utilities */
enum HYDU_sock_comm_flag {
HYDU_SOCK_COMM_MSGWAIT = 0x01
};
HYD_Status HYDU_sock_listen(int *listen_fd, char *port_range, uint16_t * port);
HYD_Status HYDU_sock_connect(const char *host, uint16_t port, int *fd);
HYD_Status HYDU_sock_accept(int listen_fd, int *fd);
HYD_Status HYDU_sock_readline(int fd, char *buf, int maxlen, int *linelen);
HYD_Status HYDU_sock_writeline(int fd, const char *buf, int maxsize);
HYD_Status HYDU_sock_read(int fd, void *buf, int maxlen, int *count,
HYD_status HYDU_sock_listen(int *listen_fd, char *port_range, uint16_t * port);
HYD_status HYDU_sock_connect(const char *host, uint16_t port, int *fd);
HYD_status HYDU_sock_accept(int listen_fd, int *fd);
HYD_status HYDU_sock_readline(int fd, char *buf, int maxlen, int *linelen);
HYD_status HYDU_sock_writeline(int fd, const char *buf, int maxsize);
HYD_status HYDU_sock_read(int fd, void *buf, int maxlen, int *count,
enum HYDU_sock_comm_flag flag);
HYD_Status HYDU_sock_write(int fd, const void *buf, int maxsize);
HYD_Status HYDU_sock_trywrite(int fd, const void *buf, int maxsize);
HYD_Status HYDU_sock_set_nonblock(int fd);
HYD_Status HYDU_sock_set_cloexec(int fd);
HYD_Status HYDU_sock_stdout_cb(int fd, HYD_Event_t events, int stdout_fd, int *closed);
HYD_Status HYDU_sock_stdin_cb(int fd, HYD_Event_t events, int stdin_fd, char *buf,
HYD_status HYDU_sock_write(int fd, const void *buf, int maxsize);
HYD_status HYDU_sock_trywrite(int fd, const void *buf, int maxsize);
HYD_status HYDU_sock_set_nonblock(int fd);
HYD_status HYDU_sock_set_cloexec(int fd);
HYD_status HYDU_sock_stdout_cb(int fd, HYD_event_t events, int stdout_fd, int *closed);
HYD_status HYDU_sock_stdin_cb(int fd, HYD_event_t events, int stdin_fd, char *buf,
int *buf_count, int *buf_offset, int *closed);
/* Memory utilities */
......@@ -264,24 +264,24 @@ HYD_Status HYDU_sock_stdin_cb(int fd, HYD_Event_t events, int stdin_fd, char *bu
} \
}