MySQL 9.2.0
Source Code Documentation
my_sys.h
Go to the documentation of this file.
1/* Copyright (c) 2000, 2024, Oracle and/or its affiliates.
2
3 This program is free software; you can redistribute it and/or modify
4 it under the terms of the GNU General Public License, version 2.0,
5 as published by the Free Software Foundation.
6
7 This program is designed to work with certain software (including
8 but not limited to OpenSSL) that is licensed under separate terms,
9 as designated in a particular file or component or in included license
10 documentation. The authors of MySQL hereby grant you an additional
11 permission to link the program and your derivative works with the
12 separately licensed software that they have either included with
13 the program or referenced in the documentation.
14
15 This program is distributed in the hope that it will be useful,
16 but WITHOUT ANY WARRANTY; without even the implied warranty of
17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 GNU General Public License, version 2.0, for more details.
19
20 You should have received a copy of the GNU General Public License
21 along with this program; if not, write to the Free Software
22 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
23
24#ifndef _my_sys_h
25#define _my_sys_h
26
27/**
28 @defgroup MYSYS Mysys - low level utilities for MySQL
29 @ingroup Runtime_Environment
30 @{
31 @file include/my_sys.h Common header for many mysys elements.
32 @note Many mysys implementation files now have their own header file.
33*/
34
35#include "my_config.h"
36
37#ifdef HAVE_ALLOCA_H
38#include <alloca.h>
39#endif
40#include <limits.h>
41#ifdef _WIN32
42#include <malloc.h>
43#endif
44#ifdef HAVE_UNISTD_H
45#include <unistd.h>
46#endif
47#include <stdarg.h>
48#include <stdio.h>
49#ifdef HAVE_SYS_SELECT_H
50#include <sys/select.h>
51#endif
52#include <sys/types.h>
53#include <time.h>
54
55#include <atomic> // error_handler_hook
56#include <cstring>
57#include <string>
58
59#include "my_compiler.h"
60#include "my_compress.h"
61#include "my_inttypes.h"
62#include "mysql/my_loglevel.h"
63
64/* HAVE_PSI_*_INTERFACE */
65#include "my_psi_config.h" /* IWYU pragma: keep */
66
67#include "my_sharedlib.h"
78#include "string_with_len.h"
79
81
82struct CHARSET_INFO;
84
104struct MEM_ROOT;
105
106#define MY_INIT(name) \
107 { \
108 my_progname = name; \
109 my_init(); \
110 }
111
112/**
113 Max length of an error message generated by mysys utilities.
114 Some mysys functions produce error messages. These mostly go
115 to stderr.
116 This constant defines the size of the buffer used to format
117 the message. It should be kept in sync with MYSQL_ERRMSG_SIZE,
118 since sometimes mysys errors are stored in the server diagnostics
119 area, and we would like to avoid unexpected truncation.
120*/
121#define MYSYS_ERRMSG_SIZE (512)
122#define MYSYS_STRERROR_SIZE (128)
123
124#define MY_FILE_ERROR ((size_t)-1)
125
126/* General bitmaps for my_func's */
127// 1 used to be MY_FFNF which has been removed
128#define MY_FNABP 2 /* Fatal if not all bytes read/written */
129#define MY_NABP 4 /* Error if not all bytes read/written */
130#define MY_FAE 8 /* Fatal if any error */
131#define MY_WME 16 /* Write message on error */
132#define MY_WAIT_IF_FULL 32 /* Wait and try again if disk full error */
133#define MY_IGNORE_BADFD 32 /* my_sync: ignore 'bad descriptor' errors */
134#define MY_REPORT_WAITING_IF_FULL 64 /* my_write: set status as waiting */
135#define MY_FULL_IO 512 /* For my_read - loop intil I/O is complete */
136#define MY_DONT_CHECK_FILESIZE 128 /* Option to init_io_cache() */
137#define MY_LINK_WARNING 32 /* my_redel() gives warning if links */
138#define MY_COPYTIME 64 /* my_redel() copies time */
139#define MY_DELETE_OLD 256 /* my_create_with_symlink() */
140#define MY_RESOLVE_LINK 128 /* my_realpath(); Only resolve links */
141#define MY_HOLD_ORIGINAL_MODES 128 /* my_copy() holds to file modes */
142#define MY_SEEK_NOT_DONE 32 /* my_lock may have to do a seek */
143#define MY_DONT_WAIT 64 /* my_lock() don't wait if can't lock */
144#define MY_ZEROFILL 32 /* my_malloc(), fill array with zero */
145#define MY_ALLOW_ZERO_PTR 64 /* my_realloc() ; zero ptr -> malloc */
146#define MY_FREE_ON_ERROR 128 /* my_realloc() ; Free old ptr on error */
147#define MY_HOLD_ON_ERROR 256 /* my_realloc() ; Return old ptr on error */
148#define MY_DONT_OVERWRITE_FILE 1024 /* my_copy: Don't overwrite file */
149#define MY_SYNC 4096 /* my_copy(): sync dst file */
150
151#define MYF_RW MYF(MY_WME + MY_NABP) /* For my_read & my_write */
152
153#define MY_CHECK_ERROR 1 /* Params to my_end; Check open-close */
154#define MY_GIVE_INFO 2 /* Give time info about process*/
155#define MY_DONT_FREE_DBUG 4 /* Do not call DBUG_END() in my_end() */
156
157/* Flags for my_error() */
158#define ME_BELL 4 /* DEPRECATED: Ring bell then printing message */
159#define ME_ERRORLOG 64 /* Write the error message to error log */
160#define ME_FATALERROR 1024 /* Fatal statement error */
161
162/* Bits in last argument to fn_format */
163#define MY_REPLACE_DIR 1 /* replace dir in name with 'dir' */
164#define MY_REPLACE_EXT 2 /* replace extension with 'ext' */
165#define MY_UNPACK_FILENAME 4 /* Unpack name (~ -> home) */
166/* 8 Unused. Previously used for MY_PACK_FILENAME. */
167#define MY_RESOLVE_SYMLINKS 16 /* Resolve all symbolic links */
168#define MY_RETURN_REAL_PATH 32 /* return full path for file */
169#define MY_SAFE_PATH 64 /* Return NULL if too long path */
170#define MY_RELATIVE_PATH 128 /* name is relative to 'dir' */
171#define MY_APPEND_EXT 256 /* add 'ext' as additional extension*/
172
173/* My seek flags */
174#define MY_SEEK_SET 0
175#define MY_SEEK_CUR 1
176#define MY_SEEK_END 2
177
178/* Some constants */
179#define MY_WAIT_FOR_USER_TO_FIX_PANIC 60 /* in seconds */
180#define MY_WAIT_GIVE_USER_A_MESSAGE 10 /* Every 10 times of prev */
181#define MIN_COMPRESS_LENGTH 50 /* Don't compress small bl. */
182#define DFLT_INIT_HITS 3
183
184/* Internal error numbers (for assembler functions) */
185#define MY_ERRNO_EDOM 33
186#define MY_ERRNO_ERANGE 34
187
188/* defines when allocating data */
189extern void *my_multi_malloc(PSI_memory_key key, myf flags, ...);
190
191/*
192 Switch to my_malloc() if the memory block to be allocated is bigger than
193 max_alloca_sz.
194*/
196#define my_safe_alloca(size, max_alloca_sz) \
197 ((size <= max_alloca_sz) ? my_alloca(size) \
198 : my_malloc(key_memory_max_alloca, size, MYF(0)))
199#define my_safe_afree(ptr, size, max_alloca_sz) \
200 if (size > max_alloca_sz) my_free(ptr)
201
202#if defined(ENABLED_DEBUG_SYNC)
203using DebugSyncCallbackFp = void (*)(const char *, size_t);
204extern DebugSyncCallbackFp debug_sync_C_callback_ptr;
205
206#define DEBUG_SYNC_C(_sync_point_name_) \
207 do { \
208 if (debug_sync_C_callback_ptr != NULL) \
209 (*debug_sync_C_callback_ptr)(STRING_WITH_LEN(_sync_point_name_)); \
210 } while (0)
211#else
212#define DEBUG_SYNC_C(_sync_point_name_)
213#endif /* defined(ENABLED_DEBUG_SYNC) */
214
215#ifdef HAVE_LINUX_LARGE_PAGES
216extern uint my_get_large_page_size(void);
217#else
218#define my_get_large_page_size() (0)
219#endif /* HAVE_LINUX_LARGE_PAGES */
220
221#define my_alloca(SZ) alloca((size_t)(SZ))
222
223extern char *home_dir; /* Home directory for user */
224extern const char *my_progname; /* program-name (printed in errors) */
225
226using ErrorHandlerFunctionPointer = void (*)(uint, const char *, myf);
227extern std::atomic<ErrorHandlerFunctionPointer> error_handler_hook;
228extern void (*local_message_hook)(enum loglevel ll, uint ecode, va_list args);
229
231
232/*
233 Hooks for reporting execution stage information. The server implementation
234 of these will also set THD::current_cond/current_mutex.
235 By having hooks, we avoid direct dependencies on server code.
236*/
237extern void (*enter_cond_hook)(void *opaque_thd, mysql_cond_t *cond,
238 mysql_mutex_t *mutex,
239 const PSI_stage_info *stage,
240 PSI_stage_info *old_stage,
241 const char *src_function, const char *src_file,
242 int src_line);
243
244extern void (*exit_cond_hook)(void *opaque_thd, const PSI_stage_info *stage,
245 const char *src_function, const char *src_file,
246 int src_line);
247
248extern void (*enter_stage_hook)(void *opaque_thd,
249 const PSI_stage_info *new_stage,
250 PSI_stage_info *old_stage,
251 const char *src_function, const char *src_file,
252 int src_line);
253
254/*
255 Hook for setting THD waiting_for_disk_space flag.
256*/
257extern void (*set_waiting_for_disk_space_hook)(void *opaque_thd, bool waiting);
258/*
259 Hook for checking if the thread has been killed.
260*/
261extern int (*is_killed_hook)(const void *opaque_thd);
262
263/* charsets */
264#define MY_ALL_CHARSETS_SIZE 2048
268
269/* statistics */
270extern ulong my_tmp_file_created;
271extern ulong my_file_opened;
272extern ulong my_stream_opened;
273extern ulong my_file_total_opened;
274extern bool my_init_done;
275
276extern MYSQL_PLUGIN_IMPORT int my_umask; /* Default creation mask */
277extern int my_umask_dir;
278
281
282extern const char *charsets_dir;
283
288 SEQ_READ_APPEND /* sequential read or append */,
293
295 FLUSH_KEEP, /* flush block and keep it in the cache */
296 FLUSH_RELEASE, /* flush block and remove it from the cache */
297 FLUSH_IGNORE_CHANGED, /* remove block from the cache */
298 /*
299 As my_disable_flush_pagecache_blocks is always 0, the following option
300 is strictly equivalent to FLUSH_KEEP
301 */
304
305struct MY_TMPDIR {
306 char **list{nullptr};
307 uint cur{0}, max{0};
309};
310
312 char *str;
314};
315
316struct IO_CACHE;
317typedef int (*IO_CACHE_CALLBACK)(IO_CACHE *);
318
320 mysql_mutex_t mutex; /* To sync on reads into buffer. */
321 mysql_cond_t cond; /* To wait for signals. */
322 mysql_cond_t cond_writer; /* For a synchronized writer. */
323 /* Offset in file corresponding to the first byte of buffer. */
325 /* If a synchronized write cache is the source of the data. */
327 uchar *buffer; /* The read buffer. */
328 uchar *read_end; /* Behind last valid byte of buffer. */
329 int running_threads; /* threads not in lock. */
330 int total_threads; /* threads sharing the cache. */
331 int error; /* Last error. */
332};
333
334class Stream_cipher;
335struct IO_CACHE /* Used when caching files */
336{
337 /* Offset in file corresponding to the first byte of uchar* buffer. */
339 /*
340 The offset of end of file for READ_CACHE and WRITE_CACHE.
341 For SEQ_READ_APPEND it the maximum of the actual end of file and
342 the position represented by read_end.
343 */
345 /* Points to current read position in the buffer */
346 uchar *read_pos{nullptr};
347 /* the non-inclusive boundary in the buffer for the currently valid read */
348 uchar *read_end{nullptr};
349 uchar *buffer{nullptr}; /* The read buffer */
350 /* Used in ASYNC_IO */
352
353 /* Only used in WRITE caches and in SEQ_READ_APPEND to buffer writes */
355 /*
356 Only used in SEQ_READ_APPEND, and points to the current read position
357 in the write buffer. Note that reads in SEQ_READ_APPEND caches can
358 happen from both read buffer (uchar* buffer) and write buffer
359 (uchar* write_buffer).
360 */
362 /* Points to current write position in the write buffer */
363 uchar *write_pos{nullptr};
364 /* The non-inclusive boundary of the valid write area */
365 uchar *write_end{nullptr};
366
367 /*
368 Current_pos and current_end are convenience variables used by
369 my_b_tell() and other routines that need to know the current offset
370 current_pos points to &write_pos, and current_end to &write_end in a
371 WRITE_CACHE, and &read_pos and &read_end respectively otherwise
372 */
373 uchar **current_pos{nullptr}, **current_end{nullptr};
374
375 /*
376 The lock is for append buffer used in SEQ_READ_APPEND cache
377 need mutex copying from append buffer to read buffer.
378 */
380 /*
381 The following is used when several threads are reading the
382 same file in parallel. They are synchronized on disk
383 accesses reading the cached part of the file asynchronously.
384 It should be set to NULL to disable the feature. Only
385 READ_CACHE mode is supported.
386 */
388
389 /*
390 A caller will use my_b_read() macro to read from the cache
391 if the data is already in cache, it will be simply copied with
392 memcpy() and internal variables will be accordinging updated with
393 no functions invoked. However, if the data is not fully in the cache,
394 my_b_read() will call read_function to fetch the data. read_function
395 must never be invoked directly.
396 */
397 int (*read_function)(IO_CACHE *, uchar *, size_t){nullptr};
398 /*
399 Same idea as in the case of read_function, except my_b_write() needs to
400 be replaced with my_b_append() for a SEQ_READ_APPEND cache
401 */
402 int (*write_function)(IO_CACHE *, const uchar *, size_t){nullptr};
403 /*
404 Specifies the type of the cache. Depending on the type of the cache
405 certain operations might not be available and yield unpredictable
406 results. Details to be documented later
407 */
409 /*
410 Callbacks when the actual read I/O happens. These were added and
411 are currently used for binary logging of LOAD DATA INFILE - when a
412 block is read from the file, we create a block create/append event, and
413 when IO_CACHE is closed, we create an end event. These functions could,
414 of course be used for other things
415 */
419 /*
420 Counts the number of times, when we were forced to use disk. We use it to
421 increase the binlog_cache_disk_use and binlog_stmt_cache_disk_use status
422 variables.
423 */
424 ulong disk_writes{0};
425 void *arg{nullptr}; /* for use by pre/post_read */
426 char *file_name{nullptr}; /* if used with 'open_cached_file' */
427 char *dir{nullptr}, *prefix{nullptr};
428 File file{-1}; /* file descriptor */
429 PSI_file_key file_key{PSI_NOT_INSTRUMENTED}; /* instrumented file key */
430
431 /*
432 seek_not_done is set by my_b_seek() to inform the upcoming read/write
433 operation that a seek needs to be performed prior to the actual I/O
434 error is 0 if the cache operation was successful, -1 if there was a
435 "hard" error, and the actual number of I/O-ed bytes if the read/write was
436 partial.
437 */
438 bool seek_not_done{false};
439 int error{0};
440 /* buffer_length is memory size allocated for buffer or write_buffer */
441 size_t buffer_length{0};
442 /* read_length is the same as buffer_length except when we use async io */
443 size_t read_length{0};
444 myf myflags{0}; /* Flags used to my_read/my_write */
445 /*
446 alloced_buffer is 1 if the buffer was allocated by init_io_cache() and
447 0 if it was supplied by the user.
448 Currently READ_NET is the only one that will use a buffer allocated
449 somewhere else
450 */
451 bool alloced_buffer{false};
452 // This is an encryptor for encrypting the temporary file of the IO cache.
454 // This is a decryptor for decrypting the temporary file of the IO cache.
456 // Synchronize flushed buffer with disk.
457 bool disk_sync{false};
458 // Delay in milliseconds after disk synchronization of the flushed buffer.
459 // Requires disk_sync = true.
461};
462
463typedef int (*qsort2_cmp)(const void *, const void *, const void *);
464
465/*
466 Subset of struct stat fields filled by stat/lstat/fstat that uniquely
467 identify a file
468*/
470 dev_t st_dev;
471 ino_t st_ino;
472};
473
474typedef void (*my_error_reporter)(enum loglevel level, uint ecode, ...);
475typedef void (*my_error_vreporter)(enum loglevel level, uint ecode, va_list);
476
478
479/* defines for mf_iocache */
481
482/* Test if buffer is inited */
483inline void my_b_clear(IO_CACHE *info) { info->buffer = nullptr; }
484
485inline bool my_b_inited(const IO_CACHE *info) {
486 return info->buffer != nullptr;
487}
488
489constexpr int my_b_EOF = INT_MIN;
490
491inline int my_b_read(IO_CACHE *info, uchar *buffer, size_t count) {
492 assert(info->type != WRITE_CACHE);
493 if (info->read_pos + count <= info->read_end) {
494 memcpy(buffer, info->read_pos, count);
495 info->read_pos += count;
496 return 0;
497 }
498 return (*info->read_function)(info, buffer, count);
499}
500
501inline int my_b_write(IO_CACHE *info, const uchar *buffer, size_t count) {
502 assert(info->type != READ_CACHE);
503 if (info->write_pos + count <= info->write_end) {
504 memcpy(info->write_pos, buffer, count);
505 info->write_pos += count;
506 return 0;
507 }
508 return (*info->write_function)(info, buffer, count);
509}
510
511extern int _my_b_get(IO_CACHE *info);
512
513inline int my_b_get(IO_CACHE *info) {
514 if (info->read_pos != info->read_end) {
515 info->read_pos++;
516 return info->read_pos[-1];
517 }
518 return _my_b_get(info);
519}
520
521inline my_off_t my_b_tell(const IO_CACHE *info) {
522 return info->pos_in_file + *info->current_pos - info->request_pos;
523}
524
526 return info->request_pos;
527}
528
529inline size_t my_b_get_bytes_in_buffer(const IO_CACHE *info) {
530 return info->read_end - my_b_get_buffer_start(info);
531}
532
534 return info->pos_in_file;
535}
536
537/* tell write offset in the SEQ_APPEND cache */
538int my_b_copy_to_file(IO_CACHE *cache, FILE *file);
539
540inline size_t my_b_bytes_in_cache(const IO_CACHE *info) {
541 return *info->current_end - *info->current_pos;
542}
543
544/*
545 How much overhead does malloc have. The code often allocates
546 something like 1024-MALLOC_OVERHEAD bytes
547*/
548#define MALLOC_OVERHEAD 8
549
550/* Typical record cache */
551#define RECORD_CACHE_SIZE (uint)(64 * 1024 - MALLOC_OVERHEAD)
552
553/** struct for once_alloc (block) */
554struct USED_MEM {
555 USED_MEM *next; /**< Next block in use */
556 unsigned int left; /**< memory left in block */
557 unsigned int size; /**< size of block */
558};
559
560/* Prototypes for mysys and my_func functions */
561
563 char *to, size_t to_length,
564 const char *from, size_t length);
565
566extern int my_copy(const char *from, const char *to, myf MyFlags);
567extern int my_delete(const char *name, myf MyFlags);
568extern int my_getwd(char *buf, size_t size, myf MyFlags);
569extern int my_setwd(const char *dir, myf MyFlags);
570extern void *my_once_alloc(size_t Size, myf MyFlags);
571extern void my_once_free(void);
572extern char *my_once_strdup(const char *src, myf myflags);
573extern void *my_once_memdup(const void *src, size_t len, myf myflags);
574extern File my_open(const char *filename, int Flags, myf MyFlags);
575
576extern File my_create(const char *FileName, int CreateFlags, int AccessFlags,
577 myf MyFlags);
578extern int my_close(File fd, myf MyFlags);
579extern int my_mkdir(const char *dir, int Flags, myf MyFlags);
580extern int my_readlink(char *to, const char *filename, myf MyFlags);
581extern int my_is_symlink(const char *filename, ST_FILE_ID *file_id);
582extern bool my_rm_dir_w_symlink(const char *directory_path, bool send_error,
583 bool send_intermediate_errors,
584 bool &directory_deletion_failed);
585extern int my_realpath(char *to, const char *filename, myf MyFlags);
586extern int my_is_same_file(File file, const ST_FILE_ID *file_id);
587extern File my_create_with_symlink(const char *linkname, const char *filename,
588 int createflags, int access_flags,
589 myf MyFlags);
590extern int my_delete_with_symlink(const char *name, myf MyFlags);
591extern int my_rename_with_symlink(const char *from, const char *to,
592 myf MyFlags);
593#ifndef _WIN32
594extern int my_symlink(const char *content, const char *linkname, myf MyFlags);
595#endif
596extern size_t my_read(File Filedes, uchar *Buffer, size_t Count, myf MyFlags);
597extern size_t my_pread(File Filedes, uchar *Buffer, size_t Count,
598 my_off_t offset, myf MyFlags);
599extern int my_rename(const char *from, const char *to, myf MyFlags);
600extern my_off_t my_seek(File fd, my_off_t pos, int whence, myf MyFlags);
601extern my_off_t my_tell(File fd, myf MyFlags);
602extern size_t my_write(File Filedes, const uchar *Buffer, size_t Count,
603 myf MyFlags);
604extern size_t my_pwrite(File Filedes, const uchar *Buffer, size_t Count,
605 my_off_t offset, myf MyFlags);
606extern size_t my_fread(FILE *stream, uchar *Buffer, size_t Count, myf MyFlags);
607extern size_t my_fwrite(FILE *stream, const uchar *Buffer, size_t Count,
608 myf MyFlags);
609extern my_off_t my_fseek(FILE *stream, my_off_t pos, int whence);
610extern my_off_t my_ftell(FILE *stream);
611
612/* implemented in my_syslog.c */
613
614// Maximum size of message that will be logged.
615#define MAX_SYSLOG_MESSAGE_SIZE 1024
616
617extern int my_openlog(const char *eventSourceName, int option, int facility);
618extern int my_closelog();
619extern int my_syslog(const CHARSET_INFO *cs, enum loglevel level,
620 const char *msg);
621
622#ifdef _WIN32
623extern int my_access(const char *path, int amode);
624#else
625#define my_access access
626#endif
627
628extern int check_if_legal_filename(const char *path);
629extern int check_if_legal_tablename(const char *path);
630
631#ifdef _WIN32
632extern bool is_filename_allowed(const char *name, size_t length,
633 bool allow_current_dir);
634#else /* _WIN32 */
635#define is_filename_allowed(name, length, allow_cwd) (true)
636#endif /* _WIN32 */
637
638#ifdef _WIN32
639extern int nt_share_delete(const char *name, myf MyFlags);
640#define my_delete_allow_opened(fname, flags) nt_share_delete((fname), (flags))
641#else
642#define my_delete_allow_opened(fname, flags) my_delete((fname), (flags))
643#endif
644
645#ifdef _WIN32
646/* Windows-only functions (CRT equivalents)*/
647extern HANDLE my_get_osfhandle(File fd);
648extern void my_osmaperr(unsigned long last_error);
649#endif
650
651extern const char *get_global_errmsg(int nr);
652extern void wait_for_free_space(const char *filename, int errors);
653extern FILE *my_fopen(const char *filename, int Flags, myf MyFlags);
654extern FILE *my_fdopen(File fd, const char *filename, int Flags, myf MyFlags);
655extern FILE *my_freopen(const char *filename, const char *mode, FILE *stream);
656extern int my_fclose(FILE *stream, myf MyFlags);
657extern File my_fileno(FILE *stream);
658extern int my_chsize(File fd, my_off_t newlength, int filler, myf MyFlags);
659extern int my_fallocator(File fd, my_off_t newlength, int filler, myf MyFlags);
660extern void thr_set_sync_wait_callback(void (*before_sync)(void),
661 void (*after_sync)(void));
662extern int my_sync(File fd, myf my_flags);
663extern char *my_strerror(char *buf, size_t len, int errnum);
664extern const char *my_get_err_msg(int nr);
665extern void my_error(int nr, myf MyFlags, ...);
666extern void my_printf_error(uint my_err, const char *format, myf MyFlags, ...)
667 MY_ATTRIBUTE((format(printf, 2, 4)));
668extern void my_printv_error(uint error, const char *format, myf MyFlags,
669 va_list ap) MY_ATTRIBUTE((format(printf, 2, 0)));
670extern int my_error_register(const char *(*get_errmsg)(int), int first,
671 int last);
672extern bool my_error_unregister(int first, int last);
673extern void my_message(uint my_err, const char *str, myf MyFlags);
674extern void my_message_stderr(uint my_err, const char *str, myf MyFlags);
675void my_message_local_stderr(enum loglevel, uint ecode, va_list args);
676extern void my_message_local(enum loglevel ll, uint ecode, ...);
677
678/**
679 Convenience wrapper for OS error messages which report
680 errno/my_errno with %d followed by strerror as %s, as the last
681 conversions in the error message.
682
683 The OS error message (my_errno) is formatted in a stack buffer and
684 the errno value and a pointer to the buffer is added to the end of
685 the parameter pack passed to my_error().
686
687 @param errno_val errno/my_errno number.
688 @param ppck parameter pack of additional arguments to pass to my_error().
689 */
690template <class... Ts>
691inline void MyOsError(int errno_val, Ts... ppck) {
692 char errbuf[MYSYS_STRERROR_SIZE];
693 my_error(ppck..., errno_val, my_strerror(errbuf, sizeof(errbuf), errno_val));
694}
695
696extern bool my_init(void);
697extern void my_end(int infoflag);
698extern const char *my_filename(File fd);
699extern MY_MODE get_file_perm(ulong perm_flags);
700extern bool my_chmod(const char *filename, ulong perm_flags, myf my_flags);
701
702extern bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist);
703extern char *my_tmpdir(MY_TMPDIR *tmpdir);
704extern void free_tmpdir(MY_TMPDIR *tmpdir);
705
706extern size_t dirname_part(char *to, const char *name, size_t *to_res_length);
707extern size_t dirname_length(const char *name);
708ALWAYS_INLINE const char *base_name(const char *A) {
709 return A + dirname_length(A);
710}
711extern int test_if_hard_path(const char *dir_name);
712extern bool has_path(const char *name);
713extern char *convert_dirname(char *to, const char *from, const char *from_end);
714extern void to_unix_path(char *name);
715extern char *fn_ext(char *name);
716extern const char *fn_ext(const char *name);
717extern char *fn_same(char *toname, const char *name, int flag);
718extern char *fn_format(char *to, const char *name, const char *dir,
719 const char *form, uint flag);
720extern size_t strlength(const char *str);
721extern size_t normalize_dirname(char *to, const char *from);
722extern size_t unpack_dirname(char *to, const char *from);
723extern size_t cleanup_dirname(char *to, const char *from);
724extern size_t system_filename(char *to, const char *from);
725extern size_t unpack_filename(char *to, const char *from);
726extern char *intern_filename(char *to, const char *from);
727extern char *my_path(char *to, const char *progname,
728 const char *own_pathname_part);
729extern char *my_load_path(char *to, const char *path,
730 const char *own_path_prefix);
731extern bool array_append_string_unique(const char *str, const char **array,
732 size_t size);
733
734void my_store_ptr(uchar *buff, size_t pack_length, my_off_t pos);
735my_off_t my_get_ptr(uchar *ptr, size_t pack_length);
736extern int init_io_cache_ext(IO_CACHE *info, File file, size_t cachesize,
737 enum cache_type type, my_off_t seek_offset,
738 bool use_async_io, myf cache_myflags,
739 PSI_file_key file_key);
740extern int init_io_cache(IO_CACHE *info, File file, size_t cachesize,
741 enum cache_type type, my_off_t seek_offset,
742 bool use_async_io, myf cache_myflags);
743extern bool reinit_io_cache(IO_CACHE *info, enum cache_type type,
744 my_off_t seek_offset, bool use_async_io,
745 bool clear_cache);
746extern void setup_io_cache(IO_CACHE *info);
747extern int _my_b_read(IO_CACHE *info, uchar *Buffer, size_t Count);
748extern int _my_b_read_r(IO_CACHE *info, uchar *Buffer, size_t Count);
749extern void init_io_cache_share(IO_CACHE *read_cache, IO_CACHE_SHARE *cshare,
750 IO_CACHE *write_cache, uint num_threads);
751extern void remove_io_thread(IO_CACHE *info);
752extern int _my_b_seq_read(IO_CACHE *info, uchar *Buffer, size_t Count);
753extern int _my_b_net_read(IO_CACHE *info, uchar *Buffer, size_t Count);
754extern int _my_b_write(IO_CACHE *info, const uchar *Buffer, size_t Count);
755extern int my_b_append(IO_CACHE *info, const uchar *Buffer, size_t Count);
756extern int my_b_safe_write(IO_CACHE *info, const uchar *Buffer, size_t Count);
757
758extern int my_block_write(IO_CACHE *info, const uchar *Buffer, size_t Count,
759 my_off_t pos);
760extern int my_b_flush_io_cache(IO_CACHE *info, int need_append_buffer_lock);
761
762#define flush_io_cache(info) my_b_flush_io_cache((info), 1)
763
764extern int end_io_cache(IO_CACHE *info);
765extern size_t my_b_fill(IO_CACHE *info);
766extern void my_b_seek(IO_CACHE *info, my_off_t pos);
767extern size_t my_b_gets(IO_CACHE *info, char *to, size_t max_length);
768extern my_off_t my_b_filelength(IO_CACHE *info);
769extern size_t my_b_printf(IO_CACHE *info, const char *fmt, ...)
770 MY_ATTRIBUTE((format(printf, 2, 3)));
771extern size_t my_b_vprintf(IO_CACHE *info, const char *fmt, va_list ap);
772extern bool open_cached_file(IO_CACHE *cache, const char *dir,
773 const char *prefix, size_t cache_size,
774 myf cache_myflags);
775extern bool real_open_cached_file(IO_CACHE *cache);
776extern void close_cached_file(IO_CACHE *cache);
777
779#ifdef WIN32
780// Maximum temporary filename length is 3 chars for prefix + 16 chars for base
781// 32 encoded UUID (excluding MAC address)
782const size_t MY_MAX_TEMP_FILENAME_LEN = 19;
783#endif
784File create_temp_file(char *to, const char *dir, const char *pfx, int mode,
785 UnlinkOrKeepFile unlink_or_keep, myf MyFlags);
786
787extern bool init_dynamic_string(DYNAMIC_STRING *str, const char *init_str,
788 size_t init_alloc);
789extern bool dynstr_append(DYNAMIC_STRING *str, const char *append);
790bool dynstr_append_mem(DYNAMIC_STRING *str, const char *append, size_t length);
791extern bool dynstr_append_os_quoted(DYNAMIC_STRING *str, const char *append,
792 ...);
793extern bool dynstr_append_quoted(DYNAMIC_STRING *str, const char *quote_str,
794 const uint quote_len, const char *append, ...);
795extern bool dynstr_set(DYNAMIC_STRING *str, const char *init_str);
796extern bool dynstr_realloc(DYNAMIC_STRING *str, size_t additional_size);
797extern bool dynstr_trunc(DYNAMIC_STRING *str, size_t n);
798extern void dynstr_free(DYNAMIC_STRING *str);
799#define alloc_root_inited(A) ((A)->inited())
800extern void *multi_alloc_root(MEM_ROOT *mem_root, ...);
801extern char *strdup_root(MEM_ROOT *root, const char *str);
802extern char *safe_strdup_root(MEM_ROOT *root, const char *str);
803extern char *strmake_root(MEM_ROOT *root, const char *str, size_t len);
804extern void *memdup_root(MEM_ROOT *root, const void *str, size_t len);
805extern bool my_compress(mysql_compress_context *, uchar *, size_t *, size_t *);
806extern bool my_uncompress(mysql_compress_context *, uchar *, size_t, size_t *);
808 const uchar *packet, size_t *len,
809 size_t *complen);
810
811extern uint my_set_max_open_files(uint files);
812
813extern bool my_gethwaddr(uchar *to);
814
815#ifdef HAVE_SYS_MMAN_H
816#include <sys/mman.h>
817
818#ifndef MAP_NOSYNC
819#define MAP_NOSYNC 0
820#endif
821
822/*
823 Not defined in FreeBSD 11.
824 Was never implemented in FreeBSD, so we just set it to 0.
825*/
826#ifndef MAP_NORESERVE
827#define MAP_NORESERVE 0
828#endif
829
830#ifdef HAVE_MMAP64
831#define my_mmap(a, b, c, d, e, f) mmap64(a, b, c, d, e, f)
832#else
833#define my_mmap(a, b, c, d, e, f) mmap(a, b, c, d, e, f)
834#endif
835#define my_munmap(a, b) munmap((a), (b))
836
837#else
838/* not a complete set of mmap() flags, but only those that nesessary */
839#define PROT_READ 1
840#define PROT_WRITE 2
841#define MAP_NORESERVE 0
842#define MAP_SHARED 0x0001
843#define MAP_PRIVATE 0x0002
844#define MAP_NOSYNC 0x0800
845#define MAP_FAILED ((void *)-1)
846#define MS_SYNC 0x0000
847
848void *my_mmap(void *, size_t, int, int, int, my_off_t);
849int my_munmap(void *, size_t);
850#endif
851
852/* my_getpagesize */
853static inline int my_getpagesize() {
854#ifndef _WIN32
855 return getpagesize();
856#else
857 SYSTEM_INFO si;
858 GetSystemInfo(&si);
859 return (int)si.dwPageSize;
860#endif
861}
862
863int my_msync(int, void *, size_t, int);
864
865/* character sets */
866extern uint get_charset_number(const char *cs_name, uint cs_flags);
867extern uint get_collation_number(const char *name);
868extern const char *get_collation_name(uint charset_number);
869
870extern CHARSET_INFO *get_charset(uint cs_number, myf flags);
874extern CHARSET_INFO *get_charset_by_csname(const char *cs_name, uint cs_flags,
875 myf my_flags);
876extern CHARSET_INFO *my_charset_get_by_name(const char *name, uint cs_flags,
877 myf my_flags, MY_CHARSET_ERRMSG *);
878extern bool resolve_charset(const char *cs_name, const CHARSET_INFO *default_cs,
879 const CHARSET_INFO **cs);
880extern bool resolve_collation(const char *cl_name,
881 const CHARSET_INFO *default_cl,
882 const CHARSET_INFO **cl);
883extern char *get_charsets_dir(char *buf);
884
885extern void charset_uninit();
886#ifdef _WIN32
887/* File system character set */
888extern CHARSET_INFO *fs_character_set(void);
889
890extern bool have_tcpip; /* Is set if tcpip is used */
891
892/* implemented in my_windac.c */
893
894int my_security_attr_create(SECURITY_ATTRIBUTES **psa, const char **perror,
895 DWORD owner_rights, DWORD everybody_rights);
896
897void my_security_attr_free(SECURITY_ATTRIBUTES *sa);
898
899/* implemented in my_conio.c */
900bool my_win_is_console(FILE *file);
901char *my_win_console_readline(const CHARSET_INFO *cs, char *mbbuf,
902 size_t mbbufsize, size_t *nread);
903void my_win_console_write(const CHARSET_INFO *cs, const char *data,
904 size_t datalen);
905void my_win_console_fputs(const CHARSET_INFO *cs, const char *data);
906void my_win_console_putc(const CHARSET_INFO *cs, int c);
907void my_win_console_vfprintf(const CHARSET_INFO *cs, const char *fmt,
908 va_list args);
909int my_win_translate_command_line_args(const CHARSET_INFO *cs, int *ac,
910 char ***av);
911#endif /* _WIN32 */
912
913#ifdef HAVE_PSI_INTERFACE
914void my_init_mysys_psi_keys(void);
915
917extern void set_psi_cond_service(void *psi);
919extern void set_psi_data_lock_service(void *psi);
921extern void set_psi_error_service(void *psi);
923extern void set_psi_file_service(void *psi);
925extern void set_psi_idle_service(void *psi);
927extern void set_psi_mdl_service(void *psi);
929extern void set_psi_memory_service(void *psi);
931extern void set_psi_metric_service(void *psi);
933extern void set_psi_logs_client_service(void *psi);
935extern void set_psi_mutex_service(void *psi);
937extern void set_psi_rwlock_service(void *psi);
939extern void set_psi_socket_service(void *psi);
941extern void set_psi_stage_service(void *psi);
943extern void set_psi_statement_service(void *psi);
945extern void set_psi_system_service(void *psi);
947extern void set_psi_table_service(void *psi);
949extern void set_psi_thread_service(void *psi);
951extern void set_psi_transaction_service(void *psi);
953extern void set_psi_tls_channel_service(void *psi);
954#endif /* HAVE_PSI_INTERFACE */
955
956/* Total physical memory available */
957[[nodiscard]] extern unsigned long long my_physical_memory();
958
959/* Compares versions and determine if clone is allowed */
960[[nodiscard]] extern bool are_versions_clone_compatible(std::string ver1,
961 std::string ver2);
962
963/**
964 @} (end of group MYSYS)
965*/
966
967// True if the temporary file of binlog cache is encrypted.
968#ifndef NDEBUG
970#endif
971
972/**
973 This is a wrapper around mysql_file_seek. Seek to a position in the
974 temporary file of a binlog cache, and set the encryption/decryption
975 stream offset if binlog_encryption is on.
976
977 @param cache The handler of a binlog cache to seek.
978 @param pos The expected position (absolute or relative)
979 @param whence A direction parameter and one of
980 {SEEK_SET, SEEK_CUR, SEEK_END}
981 @param flags The bitmap of different flags
982 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
983 MY_DONT_CHECK_FILESIZE and so on.
984
985 @retval The new position in the file, or MY_FILEPOS_ERROR on error.
986*/
988 myf flags);
989/**
990 This is a wrapper around mysql_file_read. Read data from the temporary
991 file of a binlog cache, and take care of decrypting the data if
992 binlog_encryption is on.
993
994
995 @param cache The handler of a binlog cache to read.
996 @param[out] buffer The memory buffer to write to.
997 @param count The length of data in the temporary file to be read in bytes.
998 @param flags The bitmap of different flags
999 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
1000 MY_DONT_CHECK_FILESIZE and so on.
1001
1002 @retval The length of bytes to be read, or MY_FILE_ERROR on error.
1003*/
1004size_t mysql_encryption_file_read(IO_CACHE *cache, uchar *buffer, size_t count,
1005 myf flags);
1006/**
1007 This is a wrapper around mysql_file_write. Write data in buffer to the
1008 temporary file of a binlog cache, and take care of encrypting the data
1009 if binlog_encryption is on.
1010
1011 @param cache The handler of a binlog cache to write.
1012 @param buffer The memory buffer to write from.
1013 @param count The length of data in buffer to be written in bytes.
1014 @param flags The bitmap of different flags
1015 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
1016 MY_DONT_CHECK_FILESIZE and so on
1017
1018 @return The number of bytes written
1019*/
1020size_t mysql_encryption_file_write(IO_CACHE *cache, const uchar *buffer,
1021 size_t count, myf flags);
1022#endif /* _my_sys_h */
User-specified callback interface for collation parser/initializer.
Definition: m_ctype.h:189
This abstract class represents the interface of a replication logs encryption cipher that can be used...
Definition: stream_cipher.h:82
static MEM_ROOT mem_root
Definition: client_plugin.cc:114
my_off_t my_b_tell(const IO_CACHE *info)
Definition: my_sys.h:521
char * my_strerror(char *buf, size_t len, int errnum)
Get a string describing a system or handler error.
Definition: my_error.cc:110
void set_psi_file_service(void *psi)
Definition: psi_noop.cc:446
PSI_file_key key_file_io_cache
Definition: mf_iocache.cc:93
void(* my_error_vreporter)(enum loglevel level, uint ecode, va_list)
Definition: my_sys.h:475
MYSQL_PLUGIN_IMPORT PSI_thread_bootstrap * psi_thread_hook
Definition: psi_noop.cc:249
CHARSET_INFO * get_charset_by_name(const char *collation_name, myf flags)
Definition: charset.cc:294
int my_sync(File fd, myf my_flags)
Definition: my_sync.cc:85
int _my_b_read_r(IO_CACHE *info, uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:924
size_t normalize_dirname(char *to, const char *from)
Convert a directory name to a format which can be compared as strings.
Definition: mf_pack.cc:203
void my_message_local_stderr(enum loglevel, uint ecode, va_list args)
Issue a message locally (i.e.
Definition: my_error.cc:444
ulong my_tmp_file_created
Definition: my_static.cc:86
void charset_uninit()
Definition: charset.cc:430
my_error_vreporter my_charset_error_reporter
Definition: charset.cc:123
cache_type
Definition: my_sys.h:284
int check_if_legal_filename(const char *path)
void my_message(uint my_err, const char *str, myf MyFlags)
Print an error message.
Definition: my_error.cc:311
uchar * my_compress_alloc(mysql_compress_context *comp_ctx, const uchar *packet, size_t *len, size_t *complen)
Definition: my_compress.cc:295
void set_psi_mdl_service(void *psi)
Definition: psi_noop.cc:590
int my_chsize(File fd, my_off_t newlength, int filler, myf MyFlags)
Change size of file.
Definition: my_chsize.cc:66
MYSQL_PLUGIN_IMPORT const CHARSET_INFO * all_charsets[MY_ALL_CHARSETS_SIZE]
Definition: charset.cc:180
void remove_io_thread(IO_CACHE *info)
Definition: mf_iocache.cc:672
PSI_memory_key key_memory_max_alloca
Definition: my_static.cc:66
void my_error(int nr, myf MyFlags,...)
Fill in and print a previously registered error message.
Definition: my_error.cc:216
int my_delete_with_symlink(const char *name, myf MyFlags)
Definition: my_symlink2.cc:127
std::atomic< ErrorHandlerFunctionPointer > error_handler_hook
Definition: my_static.cc:168
#define my_access
Definition: my_sys.h:625
const char * my_get_err_msg(int nr)
Get an error format string from one of the my_error_register()ed sets.
Definition: my_error.cc:184
size_t my_b_get_bytes_in_buffer(const IO_CACHE *info)
Definition: my_sys.h:529
my_off_t my_b_get_pos_in_file(const IO_CACHE *info)
Definition: my_sys.h:533
void set_psi_tls_channel_service(void *psi)
Definition: psi_noop.cc:1014
void set_psi_mutex_service(void *psi)
Definition: psi_noop.cc:283
void * my_multi_malloc(PSI_memory_key key, myf flags,...)
Definition: mulalloc.cc:59
void my_printf_error(uint my_err, const char *format, myf MyFlags,...)
Print an error message.
Definition: my_error.cc:265
size_t my_b_gets(IO_CACHE *info, char *to, size_t max_length)
Definition: mf_iocache2.cc:190
bool my_compress(mysql_compress_context *, uchar *, size_t *, size_t *)
This replaces the packet with a compressed packet.
Definition: my_compress.cc:280
char * strmake_root(MEM_ROOT *root, const char *str, size_t len)
Definition: my_alloc.cc:287
#define MYSYS_STRERROR_SIZE
Definition: my_sys.h:122
ulong my_default_record_cache_size
Definition: my_static.cc:162
MYSQL_PLUGIN_IMPORT PSI_stage_bootstrap * psi_stage_hook
Definition: psi_noop.cc:631
MYSQL_PLUGIN_IMPORT PSI_metric_bootstrap * psi_metric_hook
Definition: psi_noop.cc:1037
int _my_b_net_read(IO_CACHE *info, uchar *Buffer, size_t Count)
Read buffered from the net.
Definition: mf_iocache.cc:61
unsigned long long my_physical_memory()
Definition: my_system.cc:46
my_off_t my_get_ptr(uchar *ptr, size_t pack_length)
Definition: ptr_cmp.cc:76
void set_psi_system_service(void *psi)
Definition: psi_noop.cc:995
size_t dirname_part(char *to, const char *name, size_t *to_res_length)
Gives directory part of filename.
Definition: mf_dirname.cc:164
bool dynstr_append_mem(DYNAMIC_STRING *str, const char *append, size_t length)
Definition: my_string.cc:99
bool init_dynamic_string(DYNAMIC_STRING *str, const char *init_str, size_t init_alloc)
Definition: my_string.cc:46
int my_rename(const char *from, const char *to, myf MyFlags)
Definition: my_rename.cc:47
void(* exit_cond_hook)(void *opaque_thd, const PSI_stage_info *stage, const char *src_function, const char *src_file, int src_line)
Definition: my_static.cc:206
int test_if_hard_path(const char *dir_name)
Definition: my_getwd.cc:137
void init_io_cache_share(IO_CACHE *read_cache, IO_CACHE_SHARE *cshare, IO_CACHE *write_cache, uint num_threads)
Definition: mf_iocache.cc:621
int my_block_write(IO_CACHE *info, const uchar *Buffer, size_t Count, my_off_t pos)
Definition: mf_iocache.cc:1377
int my_fallocator(File fd, my_off_t newlength, int filler, myf MyFlags)
Change size of the specified file.
Definition: my_fallocator.cc:71
MYSQL_PLUGIN_IMPORT PSI_transaction_bootstrap * psi_transaction_hook
Definition: psi_noop.cc:907
MYSQL_PLUGIN_IMPORT ulong my_thread_stack_size
Definition: my_init.cc:96
CHARSET_INFO * get_charset(uint cs_number, myf flags)
Definition: charset.cc:231
File my_create(const char *FileName, int CreateFlags, int AccessFlags, myf MyFlags)
Create a new file.
Definition: my_create.cc:64
void set_psi_memory_service(void *psi)
Definition: psi_noop.cc:962
int my_setwd(const char *dir, myf MyFlags)
Definition: my_getwd.cc:106
int my_b_append(IO_CACHE *info, const uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1321
size_t my_read(File Filedes, uchar *Buffer, size_t Count, myf MyFlags)
Read a chunk of bytes from a file with retry's if needed If flag MY_FULL_IO is set then keep reading ...
Definition: my_read.cc:73
void close_cached_file(IO_CACHE *cache)
Definition: mf_cache.cc:87
int my_error_register(const char *(*get_errmsg)(int), int first, int last)
Register error messages for use with my_error().
Definition: my_error.cc:333
File my_fileno(FILE *stream)
Portable fileno() wrapper.
Definition: my_fstream.cc:181
char * my_once_strdup(const char *src, myf myflags)
Definition: my_once.cc:100
MYSQL_PLUGIN_IMPORT PSI_error_bootstrap * psi_error_hook
Definition: psi_noop.cc:920
my_off_t my_fseek(FILE *stream, my_off_t pos, int whence)
Seek to position in FILE stream.
Definition: my_fstream.cc:157
my_off_t my_seek(File fd, my_off_t pos, int whence, myf MyFlags)
Seek to a position in a file.
Definition: my_seek.cc:69
File my_open(const char *filename, int Flags, myf MyFlags)
Open a file.
Definition: my_open.cc:66
char * strdup_root(MEM_ROOT *root, const char *str)
Definition: my_alloc.cc:279
size_t my_b_printf(IO_CACHE *info, const char *fmt,...)
Simple printf version.
Definition: mf_iocache2.cc:237
size_t strlength(const char *str)
Calculate the length of str not including any trailing ' '-bytes.
Definition: mf_format.cc:156
File create_temp_file(char *to, const char *dir, const char *pfx, int mode, UnlinkOrKeepFile unlink_or_keep, myf MyFlags)
Definition: mf_tempfile.cc:220
void my_b_seek(IO_CACHE *info, my_off_t pos)
Definition: mf_iocache2.cc:94
my_off_t my_b_filelength(IO_CACHE *info)
Definition: mf_iocache2.cc:219
my_off_t my_ftell(FILE *stream)
Portable ftell() wrapper.
Definition: my_fstream.cc:166
ulong my_file_opened
Definition: my_static.cc:89
int check_if_legal_tablename(const char *path)
Definition: my_access.cc:159
char * convert_dirname(char *to, const char *from, const char *from_end)
Convert directory name to use under this system.
Definition: mf_dirname.cc:207
bool my_error_unregister(int first, int last)
Unregister formerly registered error messages.
Definition: my_error.cc:379
my_off_t my_tell(File fd, myf MyFlags)
Definition: my_seek.cc:94
int init_io_cache_ext(IO_CACHE *info, File file, size_t cachesize, enum cache_type type, my_off_t seek_offset, bool use_async_io, myf cache_myflags, PSI_file_key file_key)
Definition: mf_iocache.cc:177
#define MY_ALL_CHARSETS_SIZE
Definition: my_sys.h:264
bool dynstr_trunc(DYNAMIC_STRING *str, size_t n)
Definition: my_string.cc:116
void(*)(uint, const char *, myf) ErrorHandlerFunctionPointer
Definition: my_sys.h:226
bool my_rm_dir_w_symlink(const char *directory_path, bool send_error, bool send_intermediate_errors, bool &directory_deletion_failed)
Deletes the specified directory.
Definition: my_rm_dir_w_symlink.cc:62
int my_getwd(char *buf, size_t size, myf MyFlags)
Definition: my_getwd.cc:78
char * my_tmpdir(MY_TMPDIR *tmpdir)
Definition: mf_tempdir.cc:105
int _my_b_seq_read(IO_CACHE *info, uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1085
char * fn_same(char *toname, const char *name, int flag)
Definition: mf_same.cc:46
void to_unix_path(char *name)
Convert filename to unix style filename.
Definition: mf_unixpath.cc:44
void * memdup_root(MEM_ROOT *root, const void *str, size_t len)
Definition: my_alloc.cc:296
void set_psi_socket_service(void *psi)
Definition: psi_noop.cc:492
void set_psi_table_service(void *psi)
Definition: psi_noop.cc:550
void dynstr_free(DYNAMIC_STRING *str)
Definition: my_string.cc:188
int(* qsort2_cmp)(const void *, const void *, const void *)
Definition: my_sys.h:463
#define my_mmap(a, b, c, d, e, f)
Definition: my_sys.h:831
char * get_charsets_dir(char *buf)
Definition: charset.cc:161
uint my_get_large_page_size(void)
Definition: my_largepage.cc:49
int my_closelog()
Closes/de-registers the system logging handle.
Definition: my_syslog.cc:326
void my_b_clear(IO_CACHE *info)
Definition: my_sys.h:483
void set_psi_logs_client_service(void *psi)
Definition: psi_noop.cc:1065
MYSQL_PLUGIN_IMPORT PSI_tls_channel_bootstrap * psi_tls_channel_hook
Definition: psi_noop.cc:1011
bool dynstr_set(DYNAMIC_STRING *str, const char *init_str)
Definition: my_string.cc:62
bool my_b_inited(const IO_CACHE *info)
Definition: my_sys.h:485
void set_psi_error_service(void *psi)
Definition: psi_noop.cc:923
size_t my_pread(File Filedes, uchar *Buffer, size_t Count, my_off_t offset, myf MyFlags)
Read a chunk of bytes from a file from a given position.
Definition: my_pread.cc:79
size_t unpack_filename(char *to, const char *from)
Fix filename so it can be used by open, create.
Definition: mf_pack.cc:325
MYSQL_PLUGIN_IMPORT PSI_memory_bootstrap * psi_memory_hook
Definition: psi_noop.cc:959
MYSQL_PLUGIN_IMPORT CHARSET_INFO * default_charset_info
Definition: charset.cc:181
size_t system_filename(char *to, const char *from)
Convert filename (unix standard) to system standard Used before system command's like open(),...
Definition: mf_pack.cc:357
int my_delete(const char *name, myf MyFlags)
Definition: my_delete.cc:46
#define is_filename_allowed(name, length, allow_cwd)
Definition: my_sys.h:635
const char * get_global_errmsg(int nr)
Definition: errors.cc:177
bool resolve_collation(const char *cl_name, const CHARSET_INFO *default_cl, const CHARSET_INFO **cl)
Resolve collation by the collation name (utf8_general_ci, ...).
Definition: charset.cc:393
const char * my_filename(File fd)
Get filename of file.
Definition: my_file.cc:247
bool my_enable_symlinks
Definition: my_sys.h:280
MYSQL_PLUGIN_IMPORT PSI_table_bootstrap * psi_table_hook
Definition: psi_noop.cc:547
void my_printv_error(uint error, const char *format, myf MyFlags, va_list ap)
Print an error message.
Definition: my_error.cc:290
int my_symlink(const char *content, const char *linkname, myf MyFlags)
Definition: my_symlink.cc:99
void free_tmpdir(MY_TMPDIR *tmpdir)
Definition: mf_tempdir.cc:115
int my_b_get(IO_CACHE *info)
Definition: my_sys.h:513
bool dynstr_append(DYNAMIC_STRING *str, const char *append)
Definition: my_string.cc:95
int my_is_symlink(const char *filename, ST_FILE_ID *file_id)
Definition: my_symlink.cc:116
bool resolve_charset(const char *cs_name, const CHARSET_INFO *default_cs, const CHARSET_INFO **cs)
Resolve character set by the character set name (utf8, latin1, ...).
Definition: charset.cc:365
void MyOsError(int errno_val, Ts... ppck)
Convenience wrapper for OS error messages which report errno/my_errno with d followed by strerror as ...
Definition: my_sys.h:691
int my_b_safe_write(IO_CACHE *info, const uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1360
bool my_init(void)
Initialize my_sys functions, resources and variables.
Definition: my_init.cc:134
void my_message_local(enum loglevel ll, uint ecode,...)
Issue a message locally (i.e.
Definition: my_error.cc:474
size_t cleanup_dirname(char *to, const char *from)
Remove unwanted chars from dirname.
Definition: mf_pack.cc:79
size_t my_b_vprintf(IO_CACHE *info, const char *fmt, va_list ap)
Implementation of my_b_printf.
Definition: mf_iocache2.cc:255
bool array_append_string_unique(const char *str, const char **array, size_t size)
Append str to array, or move to the end if it already exists.
Definition: mf_arr_appstr.cc:51
void(* local_message_hook)(enum loglevel ll, uint ecode, va_list args)
Definition: my_static.cc:170
void set_psi_idle_service(void *psi)
Definition: psi_noop.cc:609
int my_rename_with_symlink(const char *from, const char *to, myf MyFlags)
Definition: my_symlink2.cc:154
void * my_once_alloc(size_t Size, myf MyFlags)
Definition: my_once.cc:62
int my_b_write(IO_CACHE *info, const uchar *buffer, size_t count)
Definition: my_sys.h:501
void * my_once_memdup(const void *src, size_t len, myf myflags)
Definition: my_once.cc:107
bool are_versions_clone_compatible(std::string ver1, std::string ver2)
Compares versions and determine if clone is allowed.
Definition: my_version.cc:112
int(* IO_CACHE_CALLBACK)(IO_CACHE *)
Definition: my_sys.h:317
size_t my_b_bytes_in_cache(const IO_CACHE *info)
Definition: my_sys.h:540
FILE * my_fdopen(File fd, const char *filename, int Flags, myf MyFlags)
Make a stream out of a file handle.
Definition: my_fopen.cc:217
uint my_set_max_open_files(uint files)
Sets the OS limit on the number of open files (if supported).
Definition: my_file.cc:269
File my_create_with_symlink(const char *linkname, const char *filename, int createflags, int access_flags, myf MyFlags)
Definition: my_symlink2.cc:54
char * fn_format(char *to, const char *name, const char *dir, const char *form, uint flag)
Formats a filename with possible replace of directory of extension Function can handle the case where...
Definition: mf_format.cc:73
const char * my_progname
Definition: my_static.cc:83
MYSQL_PLUGIN_IMPORT PSI_statement_bootstrap * psi_statement_hook
Definition: psi_noop.cc:840
int my_is_same_file(File file, const ST_FILE_ID *file_id)
Return non-zero if the file descriptor and a previously lstat-ed file identified by file_id point to ...
Definition: my_symlink.cc:186
size_t my_fwrite(FILE *stream, const uchar *Buffer, size_t Count, myf MyFlags)
Write a chunk of bytes to a FILE stream.
Definition: my_fstream.cc:103
uint get_charset_number(const char *cs_name, uint cs_flags)
Definition: charset.cc:205
bool dynstr_append_quoted(DYNAMIC_STRING *str, const char *quote_str, const uint quote_len, const char *append,...)
Definition: my_string.cc:179
void setup_io_cache(IO_CACHE *info)
Definition: mf_iocache.cc:118
size_t my_write(File Filedes, const uchar *Buffer, size_t Count, myf MyFlags)
Write a chunk of bytes to a file.
Definition: my_write.cc:79
int my_copy(const char *from, const char *to, myf MyFlags)
Definition: my_copy.cc:79
int my_close(File fd, myf MyFlags)
Close a file.
Definition: my_open.cc:99
MYSQL_PLUGIN_IMPORT PSI_idle_bootstrap * psi_idle_hook
Definition: psi_noop.cc:606
bool my_uncompress(mysql_compress_context *, uchar *, size_t, size_t *)
Uncompress packet.
Definition: my_compress.cc:324
UnlinkOrKeepFile
Definition: my_sys.h:778
int my_umask_dir
Definition: my_static.cc:159
ulong my_stream_opened
Definition: my_static.cc:88
void my_init_mysys_psi_keys(void)
Definition: my_init.cc:577
MY_MODE get_file_perm(ulong perm_flags)
Definition: my_chmod.cc:53
#define my_munmap(a, b)
Definition: my_sys.h:835
int _my_b_read(IO_CACHE *info, uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:425
bool dynstr_append_os_quoted(DYNAMIC_STRING *str, const char *append,...)
Definition: my_string.cc:164
MYSQL_PLUGIN_IMPORT PSI_file_bootstrap * psi_file_hook
Definition: psi_noop.cc:443
MYSQL_PLUGIN_IMPORT PSI_data_lock_bootstrap * psi_data_lock_hook
Definition: psi_noop.cc:979
int my_msync(int, void *, size_t, int)
Definition: my_mmap.cc:51
size_t my_fread(FILE *stream, uchar *Buffer, size_t Count, myf MyFlags)
Read a chunk of bytes from a FILE stream.
Definition: my_fstream.cc:73
int my_b_read(IO_CACHE *info, uchar *buffer, size_t count)
Definition: my_sys.h:491
int my_b_copy_to_file(IO_CACHE *cache, FILE *file)
Definition: mf_iocache2.cc:72
size_t unpack_dirname(char *to, const char *from)
Fixes a directory name so that can be used by open().
Definition: mf_pack.cc:253
ulong my_file_total_opened
Definition: my_static.cc:90
int my_openlog(const char *eventSourceName, int option, int facility)
Opens/Registers a new handle for system logging.
Definition: my_syslog.cc:284
void(* set_waiting_for_disk_space_hook)(void *opaque_thd, bool waiting)
Definition: my_static.cc:212
CHARSET_INFO * get_charset_by_csname(const char *cs_name, uint cs_flags, myf my_flags)
Definition: charset.cc:343
MYSQL_PLUGIN_IMPORT PSI_rwlock_bootstrap * psi_rwlock_hook
Definition: psi_noop.cc:324
int end_io_cache(IO_CACHE *info)
Definition: mf_iocache.cc:1521
size_t dirname_length(const char *name)
Get the string length of the directory part of name, including the last FN_LIBCHAR.
Definition: mf_dirname.cc:62
void set_psi_data_lock_service(void *psi)
Definition: psi_noop.cc:982
MYSQL_PLUGIN_IMPORT PSI_cond_bootstrap * psi_cond_hook
Definition: psi_noop.cc:356
bool has_path(const char *name)
Definition: my_getwd.cc:160
MYSQL_PLUGIN_IMPORT PSI_logs_client_bootstrap * psi_logs_client_hook
Definition: psi_noop.cc:1062
size_t escape_string_for_mysql(const CHARSET_INFO *charset_info, char *to, size_t to_length, const char *from, size_t length)
Definition: escape_string.cc:58
CHARSET_INFO * my_collation_get_by_name(const char *collation_name, myf flags, MY_CHARSET_ERRMSG *)
Find collation by name: extended version of get_charset_by_name() to return error messages to the cal...
Definition: charset.cc:273
void set_psi_cond_service(void *psi)
Definition: psi_noop.cc:359
void * multi_alloc_root(MEM_ROOT *mem_root,...)
Definition: my_alloc.cc:251
char * intern_filename(char *to, const char *from)
Fix a filename to intern (UNIX format).
Definition: mf_pack.cc:377
int _my_b_get(IO_CACHE *info)
Definition: mf_iocache.cc:1221
void my_store_ptr(uchar *buff, size_t pack_length, my_off_t pos)
Definition: ptr_cmp.cc:44
bool my_init_done
Definition: my_init.cc:95
void set_psi_rwlock_service(void *psi)
Definition: psi_noop.cc:327
const char * get_collation_name(uint charset_number)
Definition: charset.cc:218
constexpr int my_b_EOF
Definition: my_sys.h:489
int init_io_cache(IO_CACHE *info, File file, size_t cachesize, enum cache_type type, my_off_t seek_offset, bool use_async_io, myf cache_myflags)
Definition: mf_iocache.cc:313
void(* enter_cond_hook)(void *opaque_thd, mysql_cond_t *cond, mysql_mutex_t *mutex, const PSI_stage_info *stage, PSI_stage_info *old_stage, const char *src_function, const char *src_file, int src_line)
Definition: my_static.cc:202
MYSQL_PLUGIN_IMPORT int my_umask
Definition: my_static.cc:159
bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist)
Definition: mf_tempdir.cc:51
bool my_gethwaddr(uchar *to)
Definition: my_gethwaddr.cc:238
uint get_collation_number(const char *name)
Definition: charset.cc:199
int my_b_flush_io_cache(IO_CACHE *info, int need_append_buffer_lock)
Definition: mf_iocache.cc:1432
int _my_b_write(IO_CACHE *info, const uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1240
char * safe_strdup_root(MEM_ROOT *root, const char *str)
Definition: my_alloc.cc:283
int my_realpath(char *to, const char *filename, myf MyFlags)
Definition: my_symlink.cc:139
bool my_disable_locking
Definition: my_static.cc:226
CHARSET_INFO * my_charset_get_by_name(const char *name, uint cs_flags, myf my_flags, MY_CHARSET_ERRMSG *)
Find character set by name: extended version of get_charset_by_csname() to return error messages to t...
Definition: charset.cc:309
bool real_open_cached_file(IO_CACHE *cache)
Definition: mf_cache.cc:75
int(* is_killed_hook)(const void *opaque_thd)
Definition: my_static.cc:215
int my_syslog(const CHARSET_INFO *cs, enum loglevel level, const char *msg)
Sends message to the system logger.
Definition: my_syslog.cc:95
void set_psi_thread_service(void *psi)
Definition: psi_noop.cc:252
MYSQL_PLUGIN_IMPORT PSI_socket_bootstrap * psi_socket_hook
Definition: psi_noop.cc:489
void my_end(int infoflag)
Definition: my_init.cc:177
bool dynstr_realloc(DYNAMIC_STRING *str, size_t additional_size)
Definition: my_string.cc:81
char * home_dir
Definition: my_static.cc:82
bool reinit_io_cache(IO_CACHE *info, enum cache_type type, my_off_t seek_offset, bool use_async_io, bool clear_cache)
Definition: mf_iocache.cc:329
ALWAYS_INLINE const char * base_name(const char *A)
Definition: my_sys.h:708
void my_message_stderr(uint my_err, const char *str, myf MyFlags)
Print an error message on stderr.
Definition: my_mess.cc:60
FILE * my_freopen(const char *filename, const char *mode, FILE *stream)
Change the file associated with a file stream.
Definition: my_fopen.cc:156
FILE * my_fopen(const char *filename, int Flags, myf MyFlags)
Open a file as stream.
Definition: my_fopen.cc:109
uchar * my_b_get_buffer_start(const IO_CACHE *info)
Definition: my_sys.h:525
bool my_chmod(const char *filename, ulong perm_flags, myf my_flags)
Definition: my_chmod.cc:89
int my_mkdir(const char *dir, int Flags, myf MyFlags)
Definition: my_mkdir.cc:45
size_t my_pwrite(File Filedes, const uchar *Buffer, size_t Count, my_off_t offset, myf MyFlags)
Write a chunk of bytes to a file at a given position.
Definition: my_pread.cc:141
void set_psi_stage_service(void *psi)
Definition: psi_noop.cc:634
void set_psi_metric_service(void *psi)
Definition: psi_noop.cc:1040
MYSQL_PLUGIN_IMPORT PSI_system_bootstrap * psi_system_hook
Definition: psi_noop.cc:992
MYSQL_PLUGIN_IMPORT PSI_mdl_bootstrap * psi_mdl_hook
Definition: psi_noop.cc:587
bool open_cached_file(IO_CACHE *cache, const char *dir, const char *prefix, size_t cache_size, myf cache_myflags)
Definition: mf_cache.cc:53
int my_fclose(FILE *stream, myf MyFlags)
Close a stream.
Definition: my_fopen.cc:175
void set_psi_statement_service(void *psi)
Definition: psi_noop.cc:843
void set_psi_transaction_service(void *psi)
Definition: psi_noop.cc:910
void my_once_free(void)
Definition: my_once.cc:120
size_t my_b_fill(IO_CACHE *info)
Definition: mf_iocache2.cc:148
const char * charsets_dir
Definition: charset.cc:127
char * my_path(char *to, const char *progname, const char *own_pathname_part)
Definition: mf_path.cc:64
MYSQL_PLUGIN_IMPORT PSI_mutex_bootstrap * psi_mutex_hook
Definition: psi_noop.cc:280
void(* my_error_reporter)(enum loglevel level, uint ecode,...)
Definition: my_sys.h:474
char * my_load_path(char *to, const char *path, const char *own_path_prefix)
Returns full load-path for a file.
Definition: mf_loadpath.cc:64
void wait_for_free_space(const char *filename, int errors)
Definition: errors.cc:154
void thr_set_sync_wait_callback(void(*before_sync)(void), void(*after_sync)(void))
Definition: my_sync.cc:56
int my_readlink(char *to, const char *filename, myf MyFlags)
Definition: my_symlink.cc:67
static int my_getpagesize()
Definition: my_sys.h:853
char * fn_ext(char *name)
Definition: mf_fn_ext.cc:72
void(* enter_stage_hook)(void *opaque_thd, const PSI_stage_info *new_stage, PSI_stage_info *old_stage, const char *src_function, const char *src_file, int src_line)
Definition: my_static.cc:209
flush_type
Definition: my_sys.h:294
@ SEQ_READ_APPEND
Definition: my_sys.h:288
@ TYPE_NOT_SET
Definition: my_sys.h:285
@ READ_NET
Definition: my_sys.h:290
@ WRITE_CACHE
Definition: my_sys.h:287
@ WRITE_NET
Definition: my_sys.h:291
@ READ_CACHE
Definition: my_sys.h:286
@ READ_FIFO
Definition: my_sys.h:289
@ UNLINK_FILE
Definition: my_sys.h:778
@ KEEP_FILE
Definition: my_sys.h:778
@ FLUSH_KEEP
Definition: my_sys.h:295
@ FLUSH_RELEASE
Definition: my_sys.h:296
@ FLUSH_FORCE_WRITE
Definition: my_sys.h:302
@ FLUSH_IGNORE_CHANGED
Definition: my_sys.h:297
unsigned int PSI_file_key
Instrumented file key.
Definition: psi_file_bits.h:48
unsigned int PSI_memory_key
Instrumented memory key.
Definition: psi_memory_bits.h:49
static int flags[50]
Definition: hp_test1.cc:40
static int flag
Definition: hp_test1.cc:40
static const char * whence(const Item_field *cached_field)
Get the name of the cached field of an Item_cache_json instance.
Definition: item.cc:10039
Header for compiler-dependent features.
#define ALWAYS_INLINE
Definition: my_compiler.h:99
Some integer typedefs for easier portability.
int myf
Definition: my_inttypes.h:94
ulonglong my_off_t
Definition: my_inttypes.h:72
unsigned char uchar
Definition: my_inttypes.h:52
Types to make file and socket I/O compatible.
mode_t MY_MODE
Definition: my_io_bits.h:59
int File
Definition: my_io_bits.h:51
Definition of the global "loglevel" enumeration.
loglevel
Definition: my_loglevel.h:41
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
Functions related to handling of plugins and other dynamically loaded libraries.
#define MYSQL_PLUGIN_IMPORT
Definition: my_sharedlib.h:71
size_t mysql_encryption_file_write(IO_CACHE *cache, const uchar *buffer, size_t count, myf flags)
This is a wrapper around mysql_file_write.
Definition: mf_iocache.cc:1657
my_off_t mysql_encryption_file_seek(IO_CACHE *cache, my_off_t pos, int whence, myf flags)
This is a wrapper around mysql_file_seek.
Definition: mf_iocache.cc:1642
bool binlog_cache_temporary_file_is_encrypted
(end of group MYSYS)
Definition: mf_iocache.cc:95
size_t mysql_encryption_file_read(IO_CACHE *cache, uchar *buffer, size_t count, myf flags)
This is a wrapper around mysql_file_read.
Definition: mf_iocache.cc:1649
void my_osmaperr(unsigned long oserrno)
Definition: my_winerr.cc:124
HANDLE my_get_osfhandle(File fd)
Return the Windows HANDLE for a file descriptor obtained from RegisterHandle().
Definition: my_winfile.cc:410
static int count
Definition: myisam_ftdump.cc:45
static const CHARSET_INFO * charset_info
Definition: mysql.cc:246
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
void error(const char *format,...)
static char * path
Definition: mysqldump.cc:149
char * collation_name
Definition: audit_api_message_emit.cc:185
std::string str(const mysqlrouter::ConfigGenerator::Options::Endpoint &ep)
Definition: config_generator.cc:1117
std::string format(const routing_guidelines::Session_info &session_info, bool extended_session_info)
Definition: dest_metadata_cache.cc:170
Definition: buf0block_hint.cc:30
const std::string FILE("FILE")
Definition: commit_order_queue.h:34
std::string dir
Double write files location.
Definition: buf0dblwr.cc:77
Definition: os0file.h:89
bool length(const dd::Spatial_reference_system *srs, const Geometry *g1, double *length, bool *null) noexcept
Computes the length of linestrings and multilinestrings.
Definition: length.cc:76
size_t size(const char *const c)
Definition: base64.h:46
int last_error()
get last socket error.
Definition: socket_error.h:82
mutable_buffer buffer(void *p, size_t n) noexcept
Definition: buffer.h:418
mode
Definition: file_handle.h:61
const char * filename
Definition: pfs_example_component_population.cc:67
Performance schema instrumentation interface.
Performance schema instrumentation interface.
Performance schema instrumentation interface.
Performance schema instrumentation interface.
required string key
Definition: replication_asynchronous_connection_failover.proto:60
required string type
Definition: replication_group_member_actions.proto:34
case opt name
Definition: sslopt-case.h:29
Definition: m_ctype.h:421
Definition: my_sys.h:311
char * str
Definition: my_sys.h:312
size_t length
Definition: my_sys.h:313
size_t max_length
Definition: my_sys.h:313
Definition: my_sys.h:319
int running_threads
Definition: my_sys.h:329
int error
Definition: my_sys.h:331
mysql_mutex_t mutex
Definition: my_sys.h:320
uchar * read_end
Definition: my_sys.h:328
my_off_t pos_in_file
Definition: my_sys.h:324
int total_threads
Definition: my_sys.h:330
mysql_cond_t cond_writer
Definition: my_sys.h:322
mysql_cond_t cond
Definition: my_sys.h:321
IO_CACHE * source_cache
Definition: my_sys.h:326
uchar * buffer
Definition: my_sys.h:327
Definition: my_sys.h:336
uchar * write_buffer
Definition: my_sys.h:354
uchar * read_pos
Definition: my_sys.h:346
my_off_t pos_in_file
Definition: my_sys.h:338
my_off_t end_of_file
Definition: my_sys.h:344
uchar * read_end
Definition: my_sys.h:348
uchar ** current_end
Definition: my_sys.h:373
ulong disk_writes
Definition: my_sys.h:424
IO_CACHE_CALLBACK post_read
Definition: my_sys.h:417
myf myflags
Definition: my_sys.h:444
void * arg
Definition: my_sys.h:425
uchar * buffer
Definition: my_sys.h:349
bool seek_not_done
Definition: my_sys.h:438
uchar * write_pos
Definition: my_sys.h:363
uchar ** current_pos
Definition: my_sys.h:373
PSI_file_key file_key
Definition: my_sys.h:429
int(* write_function)(IO_CACHE *, const uchar *, size_t)
Definition: my_sys.h:402
char * file_name
Definition: my_sys.h:426
uchar * append_read_pos
Definition: my_sys.h:361
uint disk_sync_delay
Definition: my_sys.h:460
uchar * request_pos
Definition: my_sys.h:351
size_t buffer_length
Definition: my_sys.h:441
int(* read_function)(IO_CACHE *, uchar *, size_t)
Definition: my_sys.h:397
char * dir
Definition: my_sys.h:427
bool alloced_buffer
Definition: my_sys.h:451
uchar * write_end
Definition: my_sys.h:365
Stream_cipher * m_encryptor
Definition: my_sys.h:453
char * prefix
Definition: my_sys.h:427
Stream_cipher * m_decryptor
Definition: my_sys.h:455
IO_CACHE_CALLBACK pre_close
Definition: my_sys.h:418
int error
Definition: my_sys.h:439
IO_CACHE_SHARE * share
Definition: my_sys.h:387
cache_type type
Definition: my_sys.h:408
size_t read_length
Definition: my_sys.h:443
IO_CACHE_CALLBACK pre_read
Definition: my_sys.h:416
mysql_mutex_t append_buffer_lock
Definition: my_sys.h:379
bool disk_sync
Definition: my_sys.h:457
The MEM_ROOT is a simple arena, where allocations are carved out of larger blocks.
Definition: my_alloc.h:83
Helper structure to return error messages from collation parser/initializer.
Definition: m_ctype.h:180
Definition: my_sys.h:305
char ** list
Definition: my_sys.h:306
uint max
Definition: my_sys.h:307
uint cur
Definition: my_sys.h:307
mysql_mutex_t mutex
Definition: my_sys.h:308
Entry point for the performance schema interface.
Definition: psi_cond.h:46
Entry point for the performance schema interface.
Definition: psi_data_lock.h:82
Entry point for the performance schema interface.
Definition: psi_error.h:59
Entry point for the performance schema interface.
Definition: psi_file.h:66
Entry point for the performance schema interface.
Definition: psi_idle.h:60
Entry point for the performance schema interface.
Definition: psi_logger_client.h:46
Entry point for the performance schema interface.
Definition: psi_mdl.h:76
Entry point for the performance schema interface.
Definition: psi_memory.h:85
Entry point for the performance schema interface.
Definition: psi_metric.h:46
Entry point for the performance schema interface.
Definition: psi_mutex.h:46
Entry point for the performance schema interface.
Definition: psi_rwlock.h:53
Entry point for the performance schema interface.
Definition: psi_socket.h:52
Entry point for the performance schema interface.
Definition: psi_stage.h:46
Stage instrument information.
Definition: psi_stage_bits.h:74
Entry point for the performance schema interface.
Definition: psi_statement.h:46
Entry point for the performance schema interface.
Definition: psi_system.h:60
Entry point for the performance schema interface.
Definition: psi_table.h:60
Entry point for the performance schema interface.
Definition: psi_thread.h:102
Entry point for the performance schema interface.
Definition: psi_tls_channel.h:46
Entry point for the performance schema interface.
Definition: psi_transaction.h:60
Definition: my_sys.h:469
dev_t st_dev
Definition: my_sys.h:470
ino_t st_ino
Definition: my_sys.h:471
struct for once_alloc (block)
Definition: my_sys.h:554
unsigned int size
size of block
Definition: my_sys.h:557
unsigned int left
memory left in block
Definition: my_sys.h:556
USED_MEM * next
Next block in use.
Definition: my_sys.h:555
Compression context information.
Definition: my_compress.h:74
An instrumented cond structure.
Definition: mysql_cond_bits.h:50
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:50
Include file for Sun RPC to compile out of the box.
#define PSI_NOT_INSTRUMENTED
Definition: validate_password_imp.cc:44
#define HANDLE
Definition: violite.h:159
int n
Definition: xcom_base.cc:509
static uint64_t cache_size
Definition: xcom_cache.cc:363