X7ROOT File Manager
Current Path:
/usr/include/mysql/server/private
usr
/
include
/
mysql
/
server
/
private
/
ðŸ“
..
📄
aligned.h
(1.11 KB)
📄
aria_backup.h
(1.51 KB)
📄
assume_aligned.h
(2.29 KB)
ðŸ“
atomic
📄
authors.h
(9.9 KB)
📄
backup.h
(1.66 KB)
📄
bounded_queue.h
(5.95 KB)
📄
client_settings.h
(1.89 KB)
📄
compat56.h
(2.23 KB)
📄
config.h
(14.23 KB)
📄
contributors.h
(4.76 KB)
📄
create_options.h
(4.42 KB)
📄
create_tmp_table.h
(2.74 KB)
📄
cset_narrowing.h
(3.88 KB)
📄
custom_conf.h
(1.06 KB)
📄
datadict.h
(1.66 KB)
📄
ddl_log.h
(12.39 KB)
📄
debug.h
(1.21 KB)
📄
debug_sync.h
(2 KB)
📄
derived_handler.h
(2.32 KB)
📄
derror.h
(980 B)
📄
des_key_file.h
(1.21 KB)
📄
discover.h
(1.53 KB)
📄
dur_prop.h
(1.06 KB)
📄
embedded_priv.h
(1.69 KB)
📄
event_data_objects.h
(4.09 KB)
📄
event_db_repository.h
(3.56 KB)
📄
event_parse_data.h
(2.83 KB)
📄
event_queue.h
(3.36 KB)
📄
event_scheduler.h
(3.21 KB)
📄
events.h
(4.59 KB)
📄
field.h
(215.25 KB)
📄
field_comp.h
(1.15 KB)
📄
filesort.h
(7.11 KB)
📄
filesort_utils.h
(8 KB)
📄
ft_global.h
(3.04 KB)
📄
gcalc_slicescan.h
(16.87 KB)
📄
gcalc_tools.h
(11.62 KB)
📄
grant.h
(2.69 KB)
📄
group_by_handler.h
(3.45 KB)
📄
gstream.h
(2.38 KB)
📄
ha_handler_stats.h
(2.28 KB)
📄
ha_partition.h
(62.9 KB)
📄
ha_sequence.h
(6.1 KB)
📄
handle_connections_win.h
(884 B)
📄
handler.h
(196.46 KB)
📄
hash.h
(4.34 KB)
📄
hash_filo.h
(5.55 KB)
📄
heap.h
(9.26 KB)
📄
hostname.h
(5.29 KB)
📄
ilist.h
(6.88 KB)
📄
init.h
(852 B)
📄
innodb_priv.h
(1.29 KB)
📄
item.h
(272.64 KB)
📄
item_cmpfunc.h
(131.86 KB)
📄
item_create.h
(11.23 KB)
📄
item_func.h
(133.45 KB)
📄
item_geofunc.h
(37.99 KB)
📄
item_jsonfunc.h
(21.99 KB)
📄
item_row.h
(5.1 KB)
📄
item_strfunc.h
(70.55 KB)
📄
item_subselect.h
(57.77 KB)
📄
item_sum.h
(70.59 KB)
📄
item_timefunc.h
(63.1 KB)
📄
item_vers.h
(4.23 KB)
📄
item_windowfunc.h
(33.51 KB)
📄
item_xmlfunc.h
(4.5 KB)
📄
json_table.h
(9.28 KB)
📄
key.h
(2.08 KB)
📄
keycaches.h
(1.95 KB)
📄
lex.h
(29.13 KB)
📄
lex_string.h
(3.97 KB)
📄
lex_symbol.h
(1.29 KB)
📄
lf.h
(6.31 KB)
📄
lock.h
(2.15 KB)
📄
log.h
(45 KB)
📄
log_event.h
(182.04 KB)
📄
log_event_data_type.h
(1.85 KB)
📄
log_event_old.h
(19.37 KB)
📄
log_slow.h
(2.38 KB)
📄
maria.h
(5.73 KB)
📄
mariadb.h
(1.25 KB)
📄
mdl.h
(37.57 KB)
📄
mem_root_array.h
(6.94 KB)
📄
message.h
(1.17 KB)
📄
multi_range_read.h
(22.64 KB)
📄
my_alarm.h
(2.37 KB)
📄
my_apc.h
(4.64 KB)
📄
my_atomic.h
(7.11 KB)
📄
my_atomic_wrapper.h
(2.98 KB)
📄
my_base.h
(26.57 KB)
📄
my_bit.h
(6.05 KB)
📄
my_bitmap.h
(5.74 KB)
📄
my_check_opt.h
(2.56 KB)
📄
my_compare.h
(10.93 KB)
📄
my_counter.h
(1.68 KB)
📄
my_cpu.h
(4.74 KB)
📄
my_crypt.h
(904 B)
📄
my_decimal.h
(14.15 KB)
📄
my_default.h
(1.84 KB)
📄
my_handler_errors.h
(4.77 KB)
📄
my_json_writer.h
(17.95 KB)
📄
my_libwrap.h
(1.16 KB)
📄
my_md5.h
(1.45 KB)
📄
my_minidump.h
(848 B)
📄
my_nosys.h
(1.4 KB)
📄
my_rdtsc.h
(8.23 KB)
📄
my_rnd.h
(1.04 KB)
📄
my_service_manager.h
(2 KB)
📄
my_stack_alloc.h
(6.34 KB)
📄
my_stacktrace.h
(3.14 KB)
📄
my_time.h
(10.22 KB)
📄
my_tree.h
(3.9 KB)
📄
my_uctype.h
(67.9 KB)
📄
my_user.h
(1.1 KB)
📄
myisam.h
(17.1 KB)
📄
myisamchk.h
(4.61 KB)
📄
myisammrg.h
(4.78 KB)
📄
myisampack.h
(14.58 KB)
📄
mysqld.h
(39.55 KB)
📄
mysqld_default_groups.h
(204 B)
📄
mysqld_suffix.h
(1.17 KB)
📄
mysys_err.h
(2.95 KB)
📄
opt_range.h
(58.19 KB)
📄
opt_subselect.h
(14.21 KB)
📄
opt_trace.h
(8.29 KB)
📄
opt_trace_context.h
(3.21 KB)
📄
parse_file.h
(4.28 KB)
📄
partition_element.h
(5.09 KB)
📄
partition_info.h
(18.85 KB)
📄
password.h
(1.14 KB)
📄
pfs_file_provider.h
(3.08 KB)
📄
pfs_idle_provider.h
(1.35 KB)
📄
pfs_memory_provider.h
(1.59 KB)
📄
pfs_metadata_provider.h
(1.85 KB)
📄
pfs_socket_provider.h
(2.21 KB)
📄
pfs_stage_provider.h
(1.52 KB)
📄
pfs_statement_provider.h
(4.25 KB)
📄
pfs_table_provider.h
(2.56 KB)
📄
pfs_thread_provider.h
(5.43 KB)
📄
pfs_transaction_provider.h
(2.78 KB)
📄
privilege.h
(27.97 KB)
📄
probes_mysql.h
(973 B)
📄
probes_mysql_dtrace.h
(32.23 KB)
📄
probes_mysql_nodtrace.h
(4.89 KB)
📄
procedure.h
(6.63 KB)
📄
protocol.h
(12.2 KB)
📄
proxy_protocol.h
(548 B)
📄
queues.h
(3.4 KB)
📄
records.h
(3.07 KB)
📄
repl_failsafe.h
(1.55 KB)
📄
replication.h
(15.73 KB)
📄
rijndael.h
(1.67 KB)
📄
rowid_filter.h
(15.11 KB)
📄
rpl_constants.h
(3.28 KB)
📄
rpl_filter.h
(4.43 KB)
📄
rpl_gtid.h
(13.36 KB)
📄
rpl_injector.h
(9.4 KB)
📄
rpl_mi.h
(14.64 KB)
📄
rpl_parallel.h
(17.05 KB)
📄
rpl_record.h
(1.55 KB)
📄
rpl_record_old.h
(1.37 KB)
📄
rpl_reporting.h
(3.63 KB)
📄
rpl_rli.h
(31.98 KB)
📄
rpl_tblmap.h
(3.1 KB)
📄
rpl_utility.h
(9.4 KB)
📄
scheduler.h
(3.12 KB)
📄
scope.h
(4.29 KB)
📄
select_handler.h
(2.18 KB)
📄
semisync.h
(2.23 KB)
📄
semisync_master.h
(24.96 KB)
📄
semisync_master_ack_receiver.h
(8.5 KB)
📄
semisync_slave.h
(3.65 KB)
📄
service_versions.h
(2 KB)
📄
session_tracker.h
(13.94 KB)
📄
set_var.h
(16.16 KB)
📄
slave.h
(11.99 KB)
📄
socketpair.h
(842 B)
📄
source_revision.h
(67 B)
📄
sp.h
(22.06 KB)
📄
sp_cache.h
(2 KB)
📄
sp_head.h
(63 KB)
📄
sp_pcontext.h
(24.31 KB)
📄
sp_rcontext.h
(14 KB)
📄
span.h
(3.84 KB)
📄
spatial.h
(21.78 KB)
📄
sql_acl.h
(13.8 KB)
📄
sql_admin.h
(2.85 KB)
📄
sql_alloc.h
(1.69 KB)
📄
sql_alter.h
(14.92 KB)
📄
sql_analyse.h
(10.86 KB)
📄
sql_analyze_stmt.h
(12.38 KB)
📄
sql_array.h
(6.71 KB)
📄
sql_audit.h
(13.62 KB)
📄
sql_base.h
(25.27 KB)
📄
sql_basic_types.h
(9.3 KB)
📄
sql_binlog.h
(895 B)
📄
sql_bitmap.h
(7.66 KB)
📄
sql_bootstrap.h
(1.77 KB)
📄
sql_cache.h
(21.17 KB)
📄
sql_callback.h
(1.51 KB)
📄
sql_class.h
(261.11 KB)
📄
sql_cmd.h
(9.2 KB)
📄
sql_connect.h
(3.99 KB)
📄
sql_const.h
(10.96 KB)
📄
sql_crypt.h
(1.4 KB)
📄
sql_cte.h
(16.15 KB)
📄
sql_cursor.h
(2.26 KB)
📄
sql_db.h
(2.38 KB)
📄
sql_debug.h
(5.51 KB)
📄
sql_delete.h
(1.31 KB)
📄
sql_derived.h
(1.26 KB)
📄
sql_digest.h
(3.73 KB)
📄
sql_digest_stream.h
(1.53 KB)
📄
sql_do.h
(954 B)
📄
sql_error.h
(38.66 KB)
📄
sql_explain.h
(28.34 KB)
📄
sql_expression_cache.h
(4.26 KB)
📄
sql_get_diagnostics.h
(7.68 KB)
📄
sql_handler.h
(2.84 KB)
📄
sql_help.h
(995 B)
📄
sql_hset.h
(3.32 KB)
📄
sql_i_s.h
(8.04 KB)
📄
sql_insert.h
(2.59 KB)
📄
sql_join_cache.h
(47.53 KB)
📄
sql_lex.h
(168.5 KB)
📄
sql_lifo_buffer.h
(9.45 KB)
📄
sql_limit.h
(3.11 KB)
📄
sql_list.h
(21.93 KB)
📄
sql_load.h
(1.25 KB)
📄
sql_locale.h
(2.64 KB)
📄
sql_manager.h
(960 B)
📄
sql_mode.h
(6.58 KB)
📄
sql_parse.h
(8.43 KB)
📄
sql_partition.h
(11.79 KB)
📄
sql_partition_admin.h
(5.8 KB)
📄
sql_plist.h
(7.55 KB)
📄
sql_plugin.h
(7.37 KB)
📄
sql_plugin_compat.h
(2.18 KB)
📄
sql_prepare.h
(11.14 KB)
📄
sql_priv.h
(18.16 KB)
📄
sql_profile.h
(7.63 KB)
📄
sql_reload.h
(1.01 KB)
📄
sql_rename.h
(982 B)
📄
sql_repl.h
(2.97 KB)
📄
sql_schema.h
(3.23 KB)
📄
sql_select.h
(86.81 KB)
📄
sql_sequence.h
(5.06 KB)
📄
sql_servers.h
(1.74 KB)
📄
sql_show.h
(9.39 KB)
📄
sql_signal.h
(3.28 KB)
📄
sql_sort.h
(21.45 KB)
📄
sql_statistics.h
(12.16 KB)
📄
sql_string.h
(38.84 KB)
📄
sql_table.h
(9.39 KB)
📄
sql_tablespace.h
(956 B)
📄
sql_test.h
(1.55 KB)
📄
sql_time.h
(8.18 KB)
📄
sql_trigger.h
(12.04 KB)
📄
sql_truncate.h
(2.03 KB)
📄
sql_tvc.h
(2.36 KB)
📄
sql_type.h
(288.51 KB)
📄
sql_type_fixedbin.h
(62.81 KB)
📄
sql_type_fixedbin_storage.h
(5.34 KB)
📄
sql_type_geom.h
(18.64 KB)
📄
sql_type_int.h
(9.77 KB)
📄
sql_type_json.h
(6.01 KB)
📄
sql_type_real.h
(1.23 KB)
📄
sql_type_string.h
(1.59 KB)
📄
sql_udf.h
(4.74 KB)
📄
sql_union.h
(1.04 KB)
📄
sql_update.h
(1.88 KB)
📄
sql_view.h
(2.41 KB)
📄
sql_window.h
(6.65 KB)
📄
ssl_compat.h
(3.07 KB)
📄
strfunc.h
(2.22 KB)
📄
structs.h
(25.76 KB)
📄
sys_vars_shared.h
(2.67 KB)
📄
t_ctype.h
(5.51 KB)
📄
table.h
(113.03 KB)
📄
table_cache.h
(4.13 KB)
📄
thr_alarm.h
(2.86 KB)
📄
thr_lock.h
(7.18 KB)
📄
thr_malloc.h
(1.17 KB)
📄
thr_timer.h
(1.53 KB)
📄
thread_cache.h
(5.77 KB)
📄
threadpool.h
(4.7 KB)
📄
threadpool_generic.h
(3.88 KB)
📄
threadpool_winsockets.h
(2.24 KB)
📄
transaction.h
(1.43 KB)
📄
tzfile.h
(4.9 KB)
📄
tztime.h
(3.32 KB)
📄
uniques.h
(4.12 KB)
📄
unireg.h
(7.54 KB)
📄
vers_string.h
(2.47 KB)
📄
violite.h
(9.85 KB)
📄
waiting_threads.h
(4.43 KB)
📄
welcome_copyright_notice.h
(1.19 KB)
📄
win_tzname_data.h
(6.35 KB)
📄
winservice.h
(1.17 KB)
📄
wqueue.h
(1.53 KB)
📄
wsrep.h
(3.23 KB)
📄
wsrep_applier.h
(2.64 KB)
📄
wsrep_binlog.h
(3.36 KB)
📄
wsrep_client_service.h
(2.5 KB)
📄
wsrep_client_state.h
(1.53 KB)
📄
wsrep_condition_variable.h
(1.45 KB)
📄
wsrep_high_priority_service.h
(4.8 KB)
📄
wsrep_mutex.h
(1.19 KB)
📄
wsrep_mysqld.h
(20.64 KB)
📄
wsrep_mysqld_c.h
(1.2 KB)
📄
wsrep_on.h
(1.68 KB)
📄
wsrep_priv.h
(1.6 KB)
📄
wsrep_schema.h
(4.83 KB)
📄
wsrep_server_service.h
(3.55 KB)
📄
wsrep_server_state.h
(2.23 KB)
📄
wsrep_sst.h
(3.86 KB)
📄
wsrep_storage_service.h
(1.77 KB)
📄
wsrep_thd.h
(10.9 KB)
📄
wsrep_trans_observer.h
(17.69 KB)
📄
wsrep_types.h
(997 B)
📄
wsrep_utils.h
(9.07 KB)
📄
wsrep_var.h
(4.5 KB)
📄
wsrep_xid.h
(1.51 KB)
📄
xa.h
(1.8 KB)
Editing: violite.h
/* Copyright (c) 2000, 2012, Oracle and/or its affiliates. Copyright (c) 2012, 2020, MariaDB Corporation. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; version 2 of the License. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */ /* * Vio Lite. * Purpose: include file for Vio that will work with C and C++ */ #ifndef vio_violite_h_ #define vio_violite_h_ #include "my_net.h" /* needed because of struct in_addr */ #include <mysql/psi/mysql_socket.h> /* Simple vio interface in C; The functions are implemented in violite.c */ #ifdef __cplusplus extern "C" { #endif /* __cplusplus */ #ifdef __cplusplus typedef struct st_vio Vio; #endif /* __cplusplus */ enum enum_vio_type { VIO_CLOSED, VIO_TYPE_TCPIP, VIO_TYPE_SOCKET, VIO_TYPE_NAMEDPIPE, VIO_TYPE_SSL /* see also vio_type_names[] */ }; enum enum_vio_state { VIO_STATE_NOT_INITIALIZED, VIO_STATE_ACTIVE, VIO_STATE_SHUTDOWN, VIO_STATE_CLOSED }; #define FIRST_VIO_TYPE VIO_CLOSED #define LAST_VIO_TYPE VIO_TYPE_SSL /** VIO I/O events. */ enum enum_vio_io_event { VIO_IO_EVENT_READ, VIO_IO_EVENT_WRITE, VIO_IO_EVENT_CONNECT }; struct vio_keepalive_opts { int interval; int idle; int probes; }; #define VIO_TLSv1_0 1 #define VIO_TLSv1_1 2 #define VIO_TLSv1_2 4 #define VIO_TLSv1_3 8 #define VIO_LOCALHOST 1U /* a localhost connection */ #define VIO_BUFFERED_READ 2U /* use buffered read */ #define VIO_READ_BUFFER_SIZE 16384U /* size of read buffer */ #define VIO_DESCRIPTION_SIZE 30 /* size of description */ Vio* vio_new(my_socket sd, enum enum_vio_type type, uint flags); Vio* mysql_socket_vio_new(MYSQL_SOCKET mysql_socket, enum enum_vio_type type, uint flags); #ifdef _WIN32 Vio* vio_new_win32pipe(HANDLE hPipe); #else #define HANDLE void * #endif /* _WIN32 */ void vio_delete(Vio* vio); int vio_close(Vio* vio); my_bool vio_reset(Vio* vio, enum enum_vio_type type, my_socket sd, void *ssl, uint flags); size_t vio_read(Vio *vio, uchar * buf, size_t size); size_t vio_read_buff(Vio *vio, uchar * buf, size_t size); size_t vio_write(Vio *vio, const uchar * buf, size_t size); int vio_blocking(Vio *vio, my_bool onoff, my_bool *old_mode); my_bool vio_is_blocking(Vio *vio); /* setsockopt TCP_NODELAY at IPPROTO_TCP level, when possible */ int vio_nodelay(Vio *vio, my_bool on); int vio_fastsend(Vio *vio); /* setsockopt SO_KEEPALIVE at SOL_SOCKET level, when possible */ int vio_keepalive(Vio *vio, my_bool onoff); int vio_set_keepalive_options(Vio * vio, const struct vio_keepalive_opts *opts); /* Whenever we should retry the last read/write operation. */ my_bool vio_should_retry(Vio *vio); /* Check that operation was timed out */ my_bool vio_was_timeout(Vio *vio); /* Short text description of the socket for those, who are curious.. */ const char* vio_description(Vio *vio); /* Return the type of the connection */ enum enum_vio_type vio_type(Vio* vio); /* Return last error number */ int vio_errno(Vio*vio); /* Get socket number */ my_socket vio_fd(Vio*vio); /* Remote peer's address and name in text form */ my_bool vio_peer_addr(Vio *vio, char *buf, uint16 *port, size_t buflen); /* Wait for an I/O event notification. */ int vio_io_wait(Vio *vio, enum enum_vio_io_event event, int timeout); my_bool vio_is_connected(Vio *vio); ssize_t vio_pending(Vio *vio); /* Set timeout for a network operation. */ extern int vio_timeout(Vio *vio, uint which, int timeout_sec); extern void vio_set_wait_callback(void (*before_wait)(void), void (*after_wait)(void)); /* Connect to a peer. */ my_bool vio_socket_connect(Vio *vio, struct sockaddr *addr, socklen_t len, int timeout); void vio_get_normalized_ip(const struct sockaddr *src, size_t src_length, struct sockaddr *dst); my_bool vio_get_normalized_ip_string(const struct sockaddr *addr, size_t addr_length, char *ip_string, size_t ip_string_size); my_bool vio_is_no_name_error(int err_code); int vio_getnameinfo(const struct sockaddr *sa, char *hostname, size_t hostname_size, char *port, size_t port_size, int flags); #ifdef HAVE_OPENSSL /* apple deprecated openssl in MacOSX Lion */ #ifdef __APPLE__ #pragma GCC diagnostic ignored "-Wdeprecated-declarations" #endif #define HEADER_DES_LOCL_H dummy_something #define YASSL_MYSQL_COMPATIBLE #ifndef YASSL_PREFIX #define YASSL_PREFIX #endif /* Set yaSSL to use same type as MySQL do for socket handles */ typedef my_socket YASSL_SOCKET_T; #define YASSL_SOCKET_T_DEFINED #define template _template /* bug in WolfSSL 4.4.0, see also my_crypt.cc */ #include <openssl/ssl.h> #undef template #include <openssl/err.h> #ifdef DEPRECATED #undef DEPRECATED #endif enum enum_ssl_init_error { SSL_INITERR_NOERROR= 0, SSL_INITERR_CERT, SSL_INITERR_KEY, SSL_INITERR_NOMATCH, SSL_INITERR_BAD_PATHS, SSL_INITERR_CIPHERS, SSL_INITERR_MEMFAIL, SSL_INITERR_DH, SSL_INITERR_PROTOCOL, SSL_INITERR_LASTERR }; const char* sslGetErrString(enum enum_ssl_init_error err); struct st_VioSSLFd { SSL_CTX *ssl_context; }; int sslaccept(struct st_VioSSLFd*, Vio *, long timeout, unsigned long *errptr); int sslconnect(struct st_VioSSLFd*, Vio *, long timeout, unsigned long *errptr); void vio_check_ssl_init(); struct st_VioSSLFd *new_VioSSLConnectorFd(const char *key_file, const char *cert_file, const char *ca_file, const char *ca_path, const char *cipher, enum enum_ssl_init_error *error, const char *crl_file, const char *crl_path); struct st_VioSSLFd *new_VioSSLAcceptorFd(const char *key_file, const char *cert_file, const char *ca_file,const char *ca_path, const char *cipher, enum enum_ssl_init_error *error, const char *crl_file, const char *crl_path, ulonglong tls_version); void free_vio_ssl_acceptor_fd(struct st_VioSSLFd *fd); #endif /* HAVE_OPENSSL */ void vio_end(void); const char *vio_type_name(enum enum_vio_type vio_type, size_t *len); #ifdef __cplusplus } #endif #if !defined(DONT_MAP_VIO) #define vio_delete(vio) (vio)->viodelete(vio) #define vio_errno(vio) (vio)->vioerrno(vio) #define vio_read(vio, buf, size) ((vio)->read)(vio,buf,size) #define vio_write(vio, buf, size) ((vio)->write)(vio, buf, size) #define vio_blocking(vio, set_blocking_mode, old_mode)\ (vio)->vioblocking(vio, set_blocking_mode, old_mode) #define vio_is_blocking(vio) (vio)->is_blocking(vio) #define vio_fastsend(vio) (vio)->fastsend(vio) #define vio_keepalive(vio, set_keep_alive) (vio)->viokeepalive(vio, set_keep_alive) #define vio_should_retry(vio) (vio)->should_retry(vio) #define vio_was_timeout(vio) (vio)->was_timeout(vio) #define vio_close(vio) ((vio)->vioclose)(vio) #define vio_shutdown(vio,how) ((vio)->shutdown)(vio,how) #define vio_peer_addr(vio, buf, prt, buflen) (vio)->peer_addr(vio, buf, prt, buflen) #define vio_io_wait(vio, event, timeout) (vio)->io_wait(vio, event, timeout) #define vio_is_connected(vio) (vio)->is_connected(vio) #endif /* !defined(DONT_MAP_VIO) */ #ifdef _WIN32 /* shutdown(2) flags */ #ifndef SHUT_RD #define SHUT_RD SD_RECEIVE #endif #endif /* This enumerator is used in parser - should be always visible */ enum SSL_type { SSL_TYPE_NOT_SPECIFIED= -1, SSL_TYPE_NONE, SSL_TYPE_ANY, SSL_TYPE_X509, SSL_TYPE_SPECIFIED }; /* HFTODO - hide this if we don't want client in embedded server */ /* This structure is for every connection on both sides */ struct st_vio { MYSQL_SOCKET mysql_socket; /* Instrumented socket */ my_bool localhost; /* Are we from localhost? */ int fcntl_mode; /* Buffered fcntl(sd,F_GETFL) */ struct sockaddr_storage local; /* Local internet address */ struct sockaddr_storage remote; /* Remote internet address */ enum enum_vio_type type; /* Type of connection */ enum enum_vio_state state; /* State of the connection */ const char *desc; /* String description */ char *read_buffer; /* buffer for vio_read_buff */ char *read_pos; /* start of unfetched data in the read buffer */ char *read_end; /* end of unfetched data */ int read_timeout; /* Timeout value (ms) for read ops. */ int write_timeout; /* Timeout value (ms) for write ops. */ /* function pointers. They are similar for socket/SSL/whatever */ void (*viodelete)(Vio*); int (*vioerrno)(Vio*); size_t (*read)(Vio*, uchar *, size_t); size_t (*write)(Vio*, const uchar *, size_t); int (*timeout)(Vio*, uint, my_bool); int (*vioblocking)(Vio*, my_bool, my_bool *); my_bool (*is_blocking)(Vio*); int (*viokeepalive)(Vio*, my_bool); int (*fastsend)(Vio*); my_bool (*peer_addr)(Vio*, char *, uint16*, size_t); void (*in_addr)(Vio*, struct sockaddr_storage*); my_bool (*should_retry)(Vio*); my_bool (*was_timeout)(Vio*); int (*vioclose)(Vio*); my_bool (*is_connected)(Vio*); int (*shutdown)(Vio *, int); my_bool (*has_data) (Vio*); int (*io_wait)(Vio*, enum enum_vio_io_event, int); my_bool (*connect)(Vio*, struct sockaddr *, socklen_t, int); #ifdef HAVE_OPENSSL void *ssl_arg; #endif #ifdef _WIN32 HANDLE hPipe; OVERLAPPED overlapped; int shutdown_flag; void *tp_ctx; /* threadpool context */ #endif }; #endif /* vio_violite_h_ */
Upload File
Create Folder