MySQL 8.4.3
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
58#include "my_compiler.h"
59#include "my_compress.h"
60#include "my_inttypes.h"
61#include "mysql/my_loglevel.h"
62
63/* HAVE_PSI_*_INTERFACE */
64#include "my_psi_config.h" /* IWYU pragma: keep */
65
66#include "my_sharedlib.h"
75#include "sql/stream_cipher.h"
76#include "string_with_len.h"
77
79
80struct CHARSET_INFO;
82
101struct MEM_ROOT;
102
103#define MY_INIT(name) \
104 { \
105 my_progname = name; \
106 my_init(); \
107 }
108
109/**
110 Max length of an error message generated by mysys utilities.
111 Some mysys functions produce error messages. These mostly go
112 to stderr.
113 This constant defines the size of the buffer used to format
114 the message. It should be kept in sync with MYSQL_ERRMSG_SIZE,
115 since sometimes mysys errors are stored in the server diagnostics
116 area, and we would like to avoid unexpected truncation.
117*/
118#define MYSYS_ERRMSG_SIZE (512)
119#define MYSYS_STRERROR_SIZE (128)
120
121#define MY_FILE_ERROR ((size_t)-1)
122
123/* General bitmaps for my_func's */
124// 1 used to be MY_FFNF which has been removed
125#define MY_FNABP 2 /* Fatal if not all bytes read/written */
126#define MY_NABP 4 /* Error if not all bytes read/written */
127#define MY_FAE 8 /* Fatal if any error */
128#define MY_WME 16 /* Write message on error */
129#define MY_WAIT_IF_FULL 32 /* Wait and try again if disk full error */
130#define MY_IGNORE_BADFD 32 /* my_sync: ignore 'bad descriptor' errors */
131#define MY_REPORT_WAITING_IF_FULL 64 /* my_write: set status as waiting */
132#define MY_FULL_IO 512 /* For my_read - loop intil I/O is complete */
133#define MY_DONT_CHECK_FILESIZE 128 /* Option to init_io_cache() */
134#define MY_LINK_WARNING 32 /* my_redel() gives warning if links */
135#define MY_COPYTIME 64 /* my_redel() copies time */
136#define MY_DELETE_OLD 256 /* my_create_with_symlink() */
137#define MY_RESOLVE_LINK 128 /* my_realpath(); Only resolve links */
138#define MY_HOLD_ORIGINAL_MODES 128 /* my_copy() holds to file modes */
139#define MY_SEEK_NOT_DONE 32 /* my_lock may have to do a seek */
140#define MY_DONT_WAIT 64 /* my_lock() don't wait if can't lock */
141#define MY_ZEROFILL 32 /* my_malloc(), fill array with zero */
142#define MY_ALLOW_ZERO_PTR 64 /* my_realloc() ; zero ptr -> malloc */
143#define MY_FREE_ON_ERROR 128 /* my_realloc() ; Free old ptr on error */
144#define MY_HOLD_ON_ERROR 256 /* my_realloc() ; Return old ptr on error */
145#define MY_DONT_OVERWRITE_FILE 1024 /* my_copy: Don't overwrite file */
146#define MY_SYNC 4096 /* my_copy(): sync dst file */
147
148#define MYF_RW MYF(MY_WME + MY_NABP) /* For my_read & my_write */
149
150#define MY_CHECK_ERROR 1 /* Params to my_end; Check open-close */
151#define MY_GIVE_INFO 2 /* Give time info about process*/
152#define MY_DONT_FREE_DBUG 4 /* Do not call DBUG_END() in my_end() */
153
154/* Flags for my_error() */
155#define ME_BELL 4 /* DEPRECATED: Ring bell then printing message */
156#define ME_ERRORLOG 64 /* Write the error message to error log */
157#define ME_FATALERROR 1024 /* Fatal statement error */
158
159/* Bits in last argument to fn_format */
160#define MY_REPLACE_DIR 1 /* replace dir in name with 'dir' */
161#define MY_REPLACE_EXT 2 /* replace extension with 'ext' */
162#define MY_UNPACK_FILENAME 4 /* Unpack name (~ -> home) */
163/* 8 Unused. Previously used for MY_PACK_FILENAME. */
164#define MY_RESOLVE_SYMLINKS 16 /* Resolve all symbolic links */
165#define MY_RETURN_REAL_PATH 32 /* return full path for file */
166#define MY_SAFE_PATH 64 /* Return NULL if too long path */
167#define MY_RELATIVE_PATH 128 /* name is relative to 'dir' */
168#define MY_APPEND_EXT 256 /* add 'ext' as additional extension*/
169
170/* My seek flags */
171#define MY_SEEK_SET 0
172#define MY_SEEK_CUR 1
173#define MY_SEEK_END 2
174
175/* Some constants */
176#define MY_WAIT_FOR_USER_TO_FIX_PANIC 60 /* in seconds */
177#define MY_WAIT_GIVE_USER_A_MESSAGE 10 /* Every 10 times of prev */
178#define MIN_COMPRESS_LENGTH 50 /* Don't compress small bl. */
179#define DFLT_INIT_HITS 3
180
181/* Internal error numbers (for assembler functions) */
182#define MY_ERRNO_EDOM 33
183#define MY_ERRNO_ERANGE 34
184
185/* defines when allocating data */
186extern void *my_multi_malloc(PSI_memory_key key, myf flags, ...);
187
188/*
189 Switch to my_malloc() if the memory block to be allocated is bigger than
190 max_alloca_sz.
191*/
193#define my_safe_alloca(size, max_alloca_sz) \
194 ((size <= max_alloca_sz) ? my_alloca(size) \
195 : my_malloc(key_memory_max_alloca, size, MYF(0)))
196#define my_safe_afree(ptr, size, max_alloca_sz) \
197 if (size > max_alloca_sz) my_free(ptr)
198
199#if defined(ENABLED_DEBUG_SYNC)
200using DebugSyncCallbackFp = void (*)(const char *, size_t);
201extern DebugSyncCallbackFp debug_sync_C_callback_ptr;
202
203#define DEBUG_SYNC_C(_sync_point_name_) \
204 do { \
205 if (debug_sync_C_callback_ptr != NULL) \
206 (*debug_sync_C_callback_ptr)(STRING_WITH_LEN(_sync_point_name_)); \
207 } while (0)
208#define DEBUG_SYNC_C_IF_THD(thd, _sync_point_name_) \
209 do { \
210 if (debug_sync_C_callback_ptr != NULL && thd) \
211 (*debug_sync_C_callback_ptr)(STRING_WITH_LEN(_sync_point_name_)); \
212 } while (0)
213#else
214#define DEBUG_SYNC_C(_sync_point_name_)
215#define DEBUG_SYNC_C_IF_THD(thd, _sync_point_name_)
216#endif /* defined(ENABLED_DEBUG_SYNC) */
217
218#ifdef HAVE_LINUX_LARGE_PAGES
219extern uint my_get_large_page_size(void);
220#else
221#define my_get_large_page_size() (0)
222#endif /* HAVE_LINUX_LARGE_PAGES */
223
224#define my_alloca(SZ) alloca((size_t)(SZ))
225
226extern char *home_dir; /* Home directory for user */
227extern const char *my_progname; /* program-name (printed in errors) */
228
229using ErrorHandlerFunctionPointer = void (*)(uint, const char *, myf);
230extern std::atomic<ErrorHandlerFunctionPointer> error_handler_hook;
231extern void (*local_message_hook)(enum loglevel ll, uint ecode, va_list args);
232
234
235/*
236 Hooks for reporting execution stage information. The server implementation
237 of these will also set THD::current_cond/current_mutex.
238 By having hooks, we avoid direct dependencies on server code.
239*/
240extern void (*enter_cond_hook)(void *opaque_thd, mysql_cond_t *cond,
241 mysql_mutex_t *mutex,
242 const PSI_stage_info *stage,
243 PSI_stage_info *old_stage,
244 const char *src_function, const char *src_file,
245 int src_line);
246
247extern void (*exit_cond_hook)(void *opaque_thd, const PSI_stage_info *stage,
248 const char *src_function, const char *src_file,
249 int src_line);
250
251extern void (*enter_stage_hook)(void *opaque_thd,
252 const PSI_stage_info *new_stage,
253 PSI_stage_info *old_stage,
254 const char *src_function, const char *src_file,
255 int src_line);
256
257/*
258 Hook for setting THD waiting_for_disk_space flag.
259*/
260extern void (*set_waiting_for_disk_space_hook)(void *opaque_thd, bool waiting);
261/*
262 Hook for checking if the thread has been killed.
263*/
264extern int (*is_killed_hook)(const void *opaque_thd);
265
266/* charsets */
267#define MY_ALL_CHARSETS_SIZE 2048
271
272/* statistics */
273extern ulong my_tmp_file_created;
274extern ulong my_file_opened;
275extern ulong my_stream_opened;
276extern ulong my_file_total_opened;
277extern bool my_init_done;
278
279extern MYSQL_PLUGIN_IMPORT int my_umask; /* Default creation mask */
280extern int my_umask_dir;
281
284
285extern const char *charsets_dir;
286
291 SEQ_READ_APPEND /* sequential read or append */,
296
298 FLUSH_KEEP, /* flush block and keep it in the cache */
299 FLUSH_RELEASE, /* flush block and remove it from the cache */
300 FLUSH_IGNORE_CHANGED, /* remove block from the cache */
301 /*
302 As my_disable_flush_pagecache_blocks is always 0, the following option
303 is strictly equivalent to FLUSH_KEEP
304 */
307
309 uchar *buffer{nullptr};
314};
315
316struct MY_TMPDIR {
317 char **list{nullptr};
318 uint cur{0}, max{0};
320};
321
323 char *str;
325};
326
327struct IO_CACHE;
328typedef int (*IO_CACHE_CALLBACK)(IO_CACHE *);
329
331 mysql_mutex_t mutex; /* To sync on reads into buffer. */
332 mysql_cond_t cond; /* To wait for signals. */
333 mysql_cond_t cond_writer; /* For a synchronized writer. */
334 /* Offset in file corresponding to the first byte of buffer. */
336 /* If a synchronized write cache is the source of the data. */
338 uchar *buffer; /* The read buffer. */
339 uchar *read_end; /* Behind last valid byte of buffer. */
340 int running_threads; /* threads not in lock. */
341 int total_threads; /* threads sharing the cache. */
342 int error; /* Last error. */
343};
344
345struct IO_CACHE /* Used when caching files */
346{
347 /* Offset in file corresponding to the first byte of uchar* buffer. */
349 /*
350 The offset of end of file for READ_CACHE and WRITE_CACHE.
351 For SEQ_READ_APPEND it the maximum of the actual end of file and
352 the position represented by read_end.
353 */
355 /* Points to current read position in the buffer */
356 uchar *read_pos{nullptr};
357 /* the non-inclusive boundary in the buffer for the currently valid read */
358 uchar *read_end{nullptr};
359 uchar *buffer{nullptr}; /* The read buffer */
360 /* Used in ASYNC_IO */
362
363 /* Only used in WRITE caches and in SEQ_READ_APPEND to buffer writes */
365 /*
366 Only used in SEQ_READ_APPEND, and points to the current read position
367 in the write buffer. Note that reads in SEQ_READ_APPEND caches can
368 happen from both read buffer (uchar* buffer) and write buffer
369 (uchar* write_buffer).
370 */
372 /* Points to current write position in the write buffer */
373 uchar *write_pos{nullptr};
374 /* The non-inclusive boundary of the valid write area */
375 uchar *write_end{nullptr};
376
377 /*
378 Current_pos and current_end are convenience variables used by
379 my_b_tell() and other routines that need to know the current offset
380 current_pos points to &write_pos, and current_end to &write_end in a
381 WRITE_CACHE, and &read_pos and &read_end respectively otherwise
382 */
383 uchar **current_pos{nullptr}, **current_end{nullptr};
384
385 /*
386 The lock is for append buffer used in SEQ_READ_APPEND cache
387 need mutex copying from append buffer to read buffer.
388 */
390 /*
391 The following is used when several threads are reading the
392 same file in parallel. They are synchronized on disk
393 accesses reading the cached part of the file asynchronously.
394 It should be set to NULL to disable the feature. Only
395 READ_CACHE mode is supported.
396 */
398
399 /*
400 A caller will use my_b_read() macro to read from the cache
401 if the data is already in cache, it will be simply copied with
402 memcpy() and internal variables will be accordinging updated with
403 no functions invoked. However, if the data is not fully in the cache,
404 my_b_read() will call read_function to fetch the data. read_function
405 must never be invoked directly.
406 */
407 int (*read_function)(IO_CACHE *, uchar *, size_t){nullptr};
408 /*
409 Same idea as in the case of read_function, except my_b_write() needs to
410 be replaced with my_b_append() for a SEQ_READ_APPEND cache
411 */
412 int (*write_function)(IO_CACHE *, const uchar *, size_t){nullptr};
413 /*
414 Specifies the type of the cache. Depending on the type of the cache
415 certain operations might not be available and yield unpredictable
416 results. Details to be documented later
417 */
419 /*
420 Callbacks when the actual read I/O happens. These were added and
421 are currently used for binary logging of LOAD DATA INFILE - when a
422 block is read from the file, we create a block create/append event, and
423 when IO_CACHE is closed, we create an end event. These functions could,
424 of course be used for other things
425 */
429 /*
430 Counts the number of times, when we were forced to use disk. We use it to
431 increase the binlog_cache_disk_use and binlog_stmt_cache_disk_use status
432 variables.
433 */
434 ulong disk_writes{0};
435 void *arg{nullptr}; /* for use by pre/post_read */
436 char *file_name{nullptr}; /* if used with 'open_cached_file' */
437 char *dir{nullptr}, *prefix{nullptr};
438 File file{-1}; /* file descriptor */
439 PSI_file_key file_key{PSI_NOT_INSTRUMENTED}; /* instrumented file key */
440
441 /*
442 seek_not_done is set by my_b_seek() to inform the upcoming read/write
443 operation that a seek needs to be performed prior to the actual I/O
444 error is 0 if the cache operation was successful, -1 if there was a
445 "hard" error, and the actual number of I/O-ed bytes if the read/write was
446 partial.
447 */
448 bool seek_not_done{false};
449 int error{0};
450 /* buffer_length is memory size allocated for buffer or write_buffer */
451 size_t buffer_length{0};
452 /* read_length is the same as buffer_length except when we use async io */
453 size_t read_length{0};
454 myf myflags{0}; /* Flags used to my_read/my_write */
455 /*
456 alloced_buffer is 1 if the buffer was allocated by init_io_cache() and
457 0 if it was supplied by the user.
458 Currently READ_NET is the only one that will use a buffer allocated
459 somewhere else
460 */
461 bool alloced_buffer{false};
462 // This is an encryptor for encrypting the temporary file of the IO cache.
464 // This is a decryptor for decrypting the temporary file of the IO cache.
466 // Synchronize flushed buffer with disk.
467 bool disk_sync{false};
468 // Delay in milliseconds after disk synchronization of the flushed buffer.
469 // Requires disk_sync = true.
471};
472
473typedef int (*qsort2_cmp)(const void *, const void *, const void *);
474
475/*
476 Subset of struct stat fields filled by stat/lstat/fstat that uniquely
477 identify a file
478*/
480 dev_t st_dev;
481 ino_t st_ino;
482};
483
484typedef void (*my_error_reporter)(enum loglevel level, uint ecode, ...);
485typedef void (*my_error_vreporter)(enum loglevel level, uint ecode, va_list);
486
488
489/* defines for mf_iocache */
491
492/* Test if buffer is inited */
493inline void my_b_clear(IO_CACHE *info) { info->buffer = nullptr; }
494
495inline bool my_b_inited(const IO_CACHE *info) {
496 return info->buffer != nullptr;
497}
498
499constexpr int my_b_EOF = INT_MIN;
500
501inline int my_b_read(IO_CACHE *info, uchar *buffer, size_t count) {
502 assert(info->type != WRITE_CACHE);
503 if (info->read_pos + count <= info->read_end) {
504 memcpy(buffer, info->read_pos, count);
505 info->read_pos += count;
506 return 0;
507 }
508 return (*info->read_function)(info, buffer, count);
509}
510
511inline int my_b_write(IO_CACHE *info, const uchar *buffer, size_t count) {
512 assert(info->type != READ_CACHE);
513 if (info->write_pos + count <= info->write_end) {
514 memcpy(info->write_pos, buffer, count);
515 info->write_pos += count;
516 return 0;
517 }
518 return (*info->write_function)(info, buffer, count);
519}
520
521extern int _my_b_get(IO_CACHE *info);
522
523inline int my_b_get(IO_CACHE *info) {
524 if (info->read_pos != info->read_end) {
525 info->read_pos++;
526 return info->read_pos[-1];
527 }
528 return _my_b_get(info);
529}
530
531inline my_off_t my_b_tell(const IO_CACHE *info) {
532 return info->pos_in_file + *info->current_pos - info->request_pos;
533}
534
536 return info->request_pos;
537}
538
539inline size_t my_b_get_bytes_in_buffer(const IO_CACHE *info) {
540 return info->read_end - my_b_get_buffer_start(info);
541}
542
544 return info->pos_in_file;
545}
546
547/* tell write offset in the SEQ_APPEND cache */
548int my_b_copy_to_file(IO_CACHE *cache, FILE *file);
549
550inline size_t my_b_bytes_in_cache(const IO_CACHE *info) {
551 return *info->current_end - *info->current_pos;
552}
553
554/*
555 How much overhead does malloc have. The code often allocates
556 something like 1024-MALLOC_OVERHEAD bytes
557*/
558#define MALLOC_OVERHEAD 8
559
560/* Typical record cache */
561#define RECORD_CACHE_SIZE (uint)(64 * 1024 - MALLOC_OVERHEAD)
562
563/** struct for once_alloc (block) */
564struct USED_MEM {
565 USED_MEM *next; /**< Next block in use */
566 unsigned int left; /**< memory left in block */
567 unsigned int size; /**< size of block */
568};
569
570/* Prototypes for mysys and my_func functions */
571
572extern int my_copy(const char *from, const char *to, myf MyFlags);
573extern int my_delete(const char *name, myf MyFlags);
574extern int my_getwd(char *buf, size_t size, myf MyFlags);
575extern int my_setwd(const char *dir, myf MyFlags);
576extern void *my_once_alloc(size_t Size, myf MyFlags);
577extern void my_once_free(void);
578extern char *my_once_strdup(const char *src, myf myflags);
579extern void *my_once_memdup(const void *src, size_t len, myf myflags);
580extern File my_open(const char *filename, int Flags, myf MyFlags);
581
582extern File my_create(const char *FileName, int CreateFlags, int AccessFlags,
583 myf MyFlags);
584extern int my_close(File fd, myf MyFlags);
585extern int my_mkdir(const char *dir, int Flags, myf MyFlags);
586extern int my_readlink(char *to, const char *filename, myf MyFlags);
587extern int my_is_symlink(const char *filename, ST_FILE_ID *file_id);
588extern int my_realpath(char *to, const char *filename, myf MyFlags);
589extern int my_is_same_file(File file, const ST_FILE_ID *file_id);
590extern File my_create_with_symlink(const char *linkname, const char *filename,
591 int createflags, int access_flags,
592 myf MyFlags);
593extern int my_delete_with_symlink(const char *name, myf MyFlags);
594extern int my_rename_with_symlink(const char *from, const char *to,
595 myf MyFlags);
596#ifndef _WIN32
597extern int my_symlink(const char *content, const char *linkname, myf MyFlags);
598#endif
599extern size_t my_read(File Filedes, uchar *Buffer, size_t Count, myf MyFlags);
600extern size_t my_pread(File Filedes, uchar *Buffer, size_t Count,
601 my_off_t offset, myf MyFlags);
602extern int my_rename(const char *from, const char *to, myf MyFlags);
603extern my_off_t my_seek(File fd, my_off_t pos, int whence, myf MyFlags);
604extern my_off_t my_tell(File fd, myf MyFlags);
605extern size_t my_write(File Filedes, const uchar *Buffer, size_t Count,
606 myf MyFlags);
607extern size_t my_pwrite(File Filedes, const uchar *Buffer, size_t Count,
608 my_off_t offset, myf MyFlags);
609extern size_t my_fread(FILE *stream, uchar *Buffer, size_t Count, myf MyFlags);
610extern size_t my_fwrite(FILE *stream, const uchar *Buffer, size_t Count,
611 myf MyFlags);
612extern my_off_t my_fseek(FILE *stream, my_off_t pos, int whence);
613extern my_off_t my_ftell(FILE *stream);
614
615/* implemented in my_syslog.c */
616
617// Maximum size of message that will be logged.
618#define MAX_SYSLOG_MESSAGE_SIZE 1024
619
620/* Platform-independent SysLog support */
622
623extern int my_openlog(const char *eventSourceName, int option, int facility);
624extern int my_closelog();
625extern int my_syslog(const CHARSET_INFO *cs, enum loglevel level,
626 const char *msg);
627
628#ifdef _WIN32
629extern int my_access(const char *path, int amode);
630#else
631#define my_access access
632#endif
633
634extern int check_if_legal_filename(const char *path);
635extern int check_if_legal_tablename(const char *path);
636
637#ifdef _WIN32
638extern bool is_filename_allowed(const char *name, size_t length,
639 bool allow_current_dir);
640#else /* _WIN32 */
641#define is_filename_allowed(name, length, allow_cwd) (true)
642#endif /* _WIN32 */
643
644#ifdef _WIN32
645extern int nt_share_delete(const char *name, myf MyFlags);
646#define my_delete_allow_opened(fname, flags) nt_share_delete((fname), (flags))
647#else
648#define my_delete_allow_opened(fname, flags) my_delete((fname), (flags))
649#endif
650
651#ifdef _WIN32
652/* Windows-only functions (CRT equivalents)*/
653extern HANDLE my_get_osfhandle(File fd);
654extern void my_osmaperr(unsigned long last_error);
655#endif
656
657extern const char *get_global_errmsg(int nr);
658extern void wait_for_free_space(const char *filename, int errors);
659extern FILE *my_fopen(const char *filename, int Flags, myf MyFlags);
660extern FILE *my_fdopen(File fd, const char *filename, int Flags, myf MyFlags);
661extern FILE *my_freopen(const char *filename, const char *mode, FILE *stream);
662extern int my_fclose(FILE *stream, myf MyFlags);
663extern File my_fileno(FILE *stream);
664extern int my_chsize(File fd, my_off_t newlength, int filler, myf MyFlags);
665extern int my_fallocator(File fd, my_off_t newlength, int filler, myf MyFlags);
666extern void thr_set_sync_wait_callback(void (*before_sync)(void),
667 void (*after_sync)(void));
668extern int my_sync(File fd, myf my_flags);
669extern char *my_strerror(char *buf, size_t len, int errnum);
670extern const char *my_get_err_msg(int nr);
671extern void my_error(int nr, myf MyFlags, ...);
672extern void my_printf_error(uint my_err, const char *format, myf MyFlags, ...)
673 MY_ATTRIBUTE((format(printf, 2, 4)));
674extern void my_printv_error(uint error, const char *format, myf MyFlags,
675 va_list ap) MY_ATTRIBUTE((format(printf, 2, 0)));
676extern int my_error_register(const char *(*get_errmsg)(int), int first,
677 int last);
678extern bool my_error_unregister(int first, int last);
679extern void my_message(uint my_err, const char *str, myf MyFlags);
680extern void my_message_stderr(uint my_err, const char *str, myf MyFlags);
681void my_message_local_stderr(enum loglevel, uint ecode, va_list args);
682extern void my_message_local(enum loglevel ll, uint ecode, ...);
683
684/**
685 Convenience wrapper for OS error messages which report
686 errno/my_errno with %d followed by strerror as %s, as the last
687 conversions in the error message.
688
689 The OS error message (my_errno) is formatted in a stack buffer and
690 the errno value and a pointer to the buffer is added to the end of
691 the parameter pack passed to my_error().
692
693 @param errno_val errno/my_errno number.
694 @param ppck parameter pack of additional arguments to pass to my_error().
695 */
696template <class... Ts>
697inline void MyOsError(int errno_val, Ts... ppck) {
698 char errbuf[MYSYS_STRERROR_SIZE];
699 my_error(ppck..., errno_val, my_strerror(errbuf, sizeof(errbuf), errno_val));
700}
701
702extern bool my_init(void);
703extern void my_end(int infoflag);
704extern const char *my_filename(File fd);
705extern MY_MODE get_file_perm(ulong perm_flags);
706extern bool my_chmod(const char *filename, ulong perm_flags, myf my_flags);
707
708extern bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist);
709extern char *my_tmpdir(MY_TMPDIR *tmpdir);
710extern void free_tmpdir(MY_TMPDIR *tmpdir);
711
712extern size_t dirname_part(char *to, const char *name, size_t *to_res_length);
713extern size_t dirname_length(const char *name);
714#define base_name(A) (A + dirname_length(A))
715extern int test_if_hard_path(const char *dir_name);
716extern bool has_path(const char *name);
717extern char *convert_dirname(char *to, const char *from, const char *from_end);
718extern void to_unix_path(char *name);
719extern char *fn_ext(char *name);
720extern const char *fn_ext(const char *name);
721extern char *fn_same(char *toname, const char *name, int flag);
722extern char *fn_format(char *to, const char *name, const char *dir,
723 const char *form, uint flag);
724extern size_t strlength(const char *str);
725extern size_t normalize_dirname(char *to, const char *from);
726extern size_t unpack_dirname(char *to, const char *from);
727extern size_t cleanup_dirname(char *to, const char *from);
728extern size_t system_filename(char *to, const char *from);
729extern size_t unpack_filename(char *to, const char *from);
730extern char *intern_filename(char *to, const char *from);
731extern char *my_path(char *to, const char *progname,
732 const char *own_pathname_part);
733extern char *my_load_path(char *to, const char *path,
734 const char *own_path_prefix);
735extern bool array_append_string_unique(const char *str, const char **array,
736 size_t size);
737
738void my_store_ptr(uchar *buff, size_t pack_length, my_off_t pos);
739my_off_t my_get_ptr(uchar *ptr, size_t pack_length);
740extern int init_io_cache_ext(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,
743 PSI_file_key file_key);
744extern int init_io_cache(IO_CACHE *info, File file, size_t cachesize,
745 enum cache_type type, my_off_t seek_offset,
746 bool use_async_io, myf cache_myflags);
747extern bool reinit_io_cache(IO_CACHE *info, enum cache_type type,
748 my_off_t seek_offset, bool use_async_io,
749 bool clear_cache);
750extern void setup_io_cache(IO_CACHE *info);
751extern int _my_b_read(IO_CACHE *info, uchar *Buffer, size_t Count);
752extern int _my_b_read_r(IO_CACHE *info, uchar *Buffer, size_t Count);
753extern void init_io_cache_share(IO_CACHE *read_cache, IO_CACHE_SHARE *cshare,
754 IO_CACHE *write_cache, uint num_threads);
755extern void remove_io_thread(IO_CACHE *info);
756extern int _my_b_seq_read(IO_CACHE *info, uchar *Buffer, size_t Count);
757extern int _my_b_net_read(IO_CACHE *info, uchar *Buffer, size_t Count);
758extern int _my_b_write(IO_CACHE *info, const uchar *Buffer, size_t Count);
759extern int my_b_append(IO_CACHE *info, const uchar *Buffer, size_t Count);
760extern int my_b_safe_write(IO_CACHE *info, const uchar *Buffer, size_t Count);
761
762extern int my_block_write(IO_CACHE *info, const uchar *Buffer, size_t Count,
763 my_off_t pos);
764extern int my_b_flush_io_cache(IO_CACHE *info, int need_append_buffer_lock);
765
766#define flush_io_cache(info) my_b_flush_io_cache((info), 1)
767
768extern int end_io_cache(IO_CACHE *info);
769extern size_t my_b_fill(IO_CACHE *info);
770extern void my_b_seek(IO_CACHE *info, my_off_t pos);
771extern size_t my_b_gets(IO_CACHE *info, char *to, size_t max_length);
772extern my_off_t my_b_filelength(IO_CACHE *info);
773extern size_t my_b_printf(IO_CACHE *info, const char *fmt, ...)
774 MY_ATTRIBUTE((format(printf, 2, 3)));
775extern size_t my_b_vprintf(IO_CACHE *info, const char *fmt, va_list ap);
776extern bool open_cached_file(IO_CACHE *cache, const char *dir,
777 const char *prefix, size_t cache_size,
778 myf cache_myflags);
779extern bool real_open_cached_file(IO_CACHE *cache);
780extern void close_cached_file(IO_CACHE *cache);
781
783#ifdef WIN32
784// Maximum temporary filename length is 3 chars for prefix + 16 chars for base
785// 32 encoded UUID (excluding MAC address)
786const size_t MY_MAX_TEMP_FILENAME_LEN = 19;
787#endif
788File create_temp_file(char *to, const char *dir, const char *pfx, int mode,
789 UnlinkOrKeepFile unlink_or_keep, myf MyFlags);
790
791// Use Prealloced_array or std::vector or something similar in C++
793 uint element_size, void *init_buffer,
794 uint init_alloc, uint alloc_increment);
795/* init_dynamic_array() function is deprecated */
796
797#define dynamic_element(array, array_index, type) \
798 ((type)((array)->buffer) + (array_index))
799
800/* Some functions are still in use in C++, because HASH uses DYNAMIC_ARRAY */
801extern bool insert_dynamic(DYNAMIC_ARRAY *array, const void *element);
802extern void *alloc_dynamic(DYNAMIC_ARRAY *array);
803extern void delete_dynamic(DYNAMIC_ARRAY *array);
804
805extern bool init_dynamic_string(DYNAMIC_STRING *str, const char *init_str,
806 size_t init_alloc);
807extern bool dynstr_append(DYNAMIC_STRING *str, const char *append);
808bool dynstr_append_mem(DYNAMIC_STRING *str, const char *append, size_t length);
809extern bool dynstr_append_os_quoted(DYNAMIC_STRING *str, const char *append,
810 ...);
811extern bool dynstr_append_quoted(DYNAMIC_STRING *str, const char *quote_str,
812 const uint quote_len, const char *append, ...);
813extern bool dynstr_set(DYNAMIC_STRING *str, const char *init_str);
814extern bool dynstr_realloc(DYNAMIC_STRING *str, size_t additional_size);
815extern bool dynstr_trunc(DYNAMIC_STRING *str, size_t n);
816extern void dynstr_free(DYNAMIC_STRING *str);
817#define alloc_root_inited(A) ((A)->inited())
818extern void *multi_alloc_root(MEM_ROOT *mem_root, ...);
819extern char *strdup_root(MEM_ROOT *root, const char *str);
820extern char *safe_strdup_root(MEM_ROOT *root, const char *str);
821extern char *strmake_root(MEM_ROOT *root, const char *str, size_t len);
822extern void *memdup_root(MEM_ROOT *root, const void *str, size_t len);
823extern bool my_compress(mysql_compress_context *, uchar *, size_t *, size_t *);
824extern bool my_uncompress(mysql_compress_context *, uchar *, size_t, size_t *);
826 const uchar *packet, size_t *len,
827 size_t *complen);
828
829extern uint my_set_max_open_files(uint files);
830
831extern bool my_gethwaddr(uchar *to);
832
833#ifdef HAVE_SYS_MMAN_H
834#include <sys/mman.h>
835
836#ifndef MAP_NOSYNC
837#define MAP_NOSYNC 0
838#endif
839
840/*
841 Not defined in FreeBSD 11.
842 Was never implemented in FreeBSD, so we just set it to 0.
843*/
844#ifndef MAP_NORESERVE
845#define MAP_NORESERVE 0
846#endif
847
848#ifdef HAVE_MMAP64
849#define my_mmap(a, b, c, d, e, f) mmap64(a, b, c, d, e, f)
850#else
851#define my_mmap(a, b, c, d, e, f) mmap(a, b, c, d, e, f)
852#endif
853#define my_munmap(a, b) munmap((a), (b))
854
855#else
856/* not a complete set of mmap() flags, but only those that nesessary */
857#define PROT_READ 1
858#define PROT_WRITE 2
859#define MAP_NORESERVE 0
860#define MAP_SHARED 0x0001
861#define MAP_PRIVATE 0x0002
862#define MAP_NOSYNC 0x0800
863#define MAP_FAILED ((void *)-1)
864#define MS_SYNC 0x0000
865
866void *my_mmap(void *, size_t, int, int, int, my_off_t);
867int my_munmap(void *, size_t);
868#endif
869
870/* my_getpagesize */
871static inline int my_getpagesize() {
872#ifndef _WIN32
873 return getpagesize();
874#else
875 SYSTEM_INFO si;
876 GetSystemInfo(&si);
877 return (int)si.dwPageSize;
878#endif
879}
880
881int my_msync(int, void *, size_t, int);
882
883/* character sets */
884extern uint get_charset_number(const char *cs_name, uint cs_flags);
885extern uint get_collation_number(const char *name);
886extern const char *get_collation_name(uint charset_number);
887
888extern CHARSET_INFO *get_charset(uint cs_number, myf flags);
889extern CHARSET_INFO *get_charset_by_name(const char *cs_name, myf flags);
892extern CHARSET_INFO *get_charset_by_csname(const char *cs_name, uint cs_flags,
893 myf my_flags);
894extern CHARSET_INFO *my_charset_get_by_name(const char *name, uint cs_flags,
895 myf my_flags, MY_CHARSET_ERRMSG *);
896extern bool resolve_charset(const char *cs_name, const CHARSET_INFO *default_cs,
897 const CHARSET_INFO **cs);
898extern bool resolve_collation(const char *cl_name,
899 const CHARSET_INFO *default_cl,
900 const CHARSET_INFO **cl);
901extern char *get_charsets_dir(char *buf);
902
904 char *to, size_t to_length,
905 const char *from, size_t length);
906extern void charset_uninit();
907#ifdef _WIN32
908/* File system character set */
909extern CHARSET_INFO *fs_character_set(void);
910#endif
911extern size_t escape_quotes_for_mysql(CHARSET_INFO *charset_info, char *to,
912 size_t to_length, const char *from,
913 size_t length, char quote);
914#ifdef _WIN32
915extern bool have_tcpip; /* Is set if tcpip is used */
916
917/* implemented in my_windac.c */
918
919int my_security_attr_create(SECURITY_ATTRIBUTES **psa, const char **perror,
920 DWORD owner_rights, DWORD everybody_rights);
921
922void my_security_attr_free(SECURITY_ATTRIBUTES *sa);
923
924/* implemented in my_conio.c */
925bool my_win_is_console(FILE *file);
926char *my_win_console_readline(const CHARSET_INFO *cs, char *mbbuf,
927 size_t mbbufsize, size_t *nread);
928void my_win_console_write(const CHARSET_INFO *cs, const char *data,
929 size_t datalen);
930void my_win_console_fputs(const CHARSET_INFO *cs, const char *data);
931void my_win_console_putc(const CHARSET_INFO *cs, int c);
932void my_win_console_vfprintf(const CHARSET_INFO *cs, const char *fmt,
933 va_list args);
934int my_win_translate_command_line_args(const CHARSET_INFO *cs, int *ac,
935 char ***av);
936#endif /* _WIN32 */
937
938#ifdef HAVE_PSI_INTERFACE
939void my_init_mysys_psi_keys(void);
940
942extern void set_psi_cond_service(void *psi);
944extern void set_psi_data_lock_service(void *psi);
946extern void set_psi_error_service(void *psi);
948extern void set_psi_file_service(void *psi);
950extern void set_psi_idle_service(void *psi);
952extern void set_psi_mdl_service(void *psi);
954extern void set_psi_memory_service(void *psi);
956extern void set_psi_metric_service(void *psi);
958extern void set_psi_mutex_service(void *psi);
960extern void set_psi_rwlock_service(void *psi);
962extern void set_psi_socket_service(void *psi);
964extern void set_psi_stage_service(void *psi);
966extern void set_psi_statement_service(void *psi);
968extern void set_psi_system_service(void *psi);
970extern void set_psi_table_service(void *psi);
972extern void set_psi_thread_service(void *psi);
974extern void set_psi_transaction_service(void *psi);
976extern void set_psi_tls_channel_service(void *psi);
977#endif /* HAVE_PSI_INTERFACE */
978
979/* Total physical memory available */
980[[nodiscard]] extern unsigned long long my_physical_memory();
981
982/* Compares versions and determine if clone is allowed */
983[[nodiscard]] extern bool are_versions_clone_compatible(std::string ver1,
984 std::string ver2);
985
986/**
987 @} (end of group MYSYS)
988*/
989
990// True if the temporary file of binlog cache is encrypted.
991#ifndef NDEBUG
993#endif
994
995/**
996 This is a wrapper around mysql_file_seek. Seek to a position in the
997 temporary file of a binlog cache, and set the encryption/decryption
998 stream offset if binlog_encryption is on.
999
1000 @param cache The handler of a binlog cache to seek.
1001 @param pos The expected position (absolute or relative)
1002 @param whence A direction parameter and one of
1003 {SEEK_SET, SEEK_CUR, SEEK_END}
1004 @param flags The bitmap of different flags
1005 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
1006 MY_DONT_CHECK_FILESIZE and so on.
1007
1008 @retval The new position in the file, or MY_FILEPOS_ERROR on error.
1009*/
1011 myf flags);
1012/**
1013 This is a wrapper around mysql_file_read. Read data from the temporary
1014 file of a binlog cache, and take care of decrypting the data if
1015 binlog_encryption is on.
1016
1017
1018 @param cache The handler of a binlog cache to read.
1019 @param[out] buffer The memory buffer to write to.
1020 @param count The length of data in the temporary file to be read in bytes.
1021 @param flags The bitmap of different flags
1022 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
1023 MY_DONT_CHECK_FILESIZE and so on.
1024
1025 @retval The length of bytes to be read, or MY_FILE_ERROR on error.
1026*/
1027size_t mysql_encryption_file_read(IO_CACHE *cache, uchar *buffer, size_t count,
1028 myf flags);
1029/**
1030 This is a wrapper around mysql_file_write. Write data in buffer to the
1031 temporary file of a binlog cache, and take care of encrypting the data
1032 if binlog_encryption is on.
1033
1034 @param cache The handler of a binlog cache to write.
1035 @param buffer The memory buffer to write from.
1036 @param count The length of data in buffer to be written in bytes.
1037 @param flags The bitmap of different flags
1038 MY_WME | MY_FAE | MY_NABP | MY_FNABP |
1039 MY_DONT_CHECK_FILESIZE and so on
1040
1041 @return The number of bytes written
1042*/
1043size_t mysql_encryption_file_write(IO_CACHE *cache, const uchar *buffer,
1044 size_t count, myf flags);
1045#endif /* _my_sys_h */
User-specified callback interface for collation parser/initializer.
Definition: m_ctype.h:190
This abstract class represents the interface of a replication logs encryption cipher that can be used...
Definition: stream_cipher.h:78
static MEM_ROOT mem_root
Definition: client_plugin.cc:114
my_off_t my_b_tell(const IO_CACHE *info)
Definition: my_sys.h:531
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:444
PSI_file_key key_file_io_cache
Definition: mf_iocache.cc:92
void(* my_error_vreporter)(enum loglevel level, uint ecode, va_list)
Definition: my_sys.h:485
MYSQL_PLUGIN_IMPORT PSI_thread_bootstrap * psi_thread_hook
Definition: psi_noop.cc:247
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:923
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:582
my_error_vreporter my_charset_error_reporter
Definition: charset.cc:123
cache_type
Definition: my_sys.h:287
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:585
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:671
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:631
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:539
my_off_t my_b_get_pos_in_file(const IO_CACHE *info)
Definition: my_sys.h:543
void set_psi_tls_channel_service(void *psi)
Definition: psi_noop.cc:1009
void set_psi_mutex_service(void *psi)
Definition: psi_noop.cc:281
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:119
void * alloc_dynamic(DYNAMIC_ARRAY *array)
Definition: array.cc:141
ulong my_default_record_cache_size
Definition: my_static.cc:162
MYSQL_PLUGIN_IMPORT PSI_stage_bootstrap * psi_stage_hook
Definition: psi_noop.cc:626
MYSQL_PLUGIN_IMPORT PSI_metric_bootstrap * psi_metric_hook
Definition: psi_noop.cc:1032
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:990
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
CHARSET_INFO * get_charset_by_name(const char *cs_name, myf flags)
Definition: charset.cc:277
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:620
int my_block_write(IO_CACHE *info, const uchar *Buffer, size_t Count, my_off_t pos)
Definition: mf_iocache.cc:1376
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:902
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:957
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:1320
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:915
bool my_init_dynamic_array(DYNAMIC_ARRAY *array, PSI_memory_key key, uint element_size, void *init_buffer, uint init_alloc, uint alloc_increment)
Definition: array.cc:69
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:176
#define MY_ALL_CHARSETS_SIZE
Definition: my_sys.h:267
bool dynstr_trunc(DYNAMIC_STRING *str, size_t n)
Definition: my_string.cc:116
void(*)(uint, const char *, myf) ErrorHandlerFunctionPointer
Definition: my_sys.h:229
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:1084
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:490
void set_psi_table_service(void *psi)
Definition: psi_noop.cc:548
void dynstr_free(DYNAMIC_STRING *str)
Definition: my_string.cc:188
int(* qsort2_cmp)(const void *, const void *, const void *)
Definition: my_sys.h:473
#define my_mmap(a, b, c, d, e, f)
Definition: my_sys.h:849
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:328
void my_b_clear(IO_CACHE *info)
Definition: my_sys.h:493
MYSQL_PLUGIN_IMPORT PSI_tls_channel_bootstrap * psi_tls_channel_hook
Definition: psi_noop.cc:1006
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:495
void set_psi_error_service(void *psi)
Definition: psi_noop.cc:918
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:954
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:641
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:376
const char * my_filename(File fd)
Get filename of file.
Definition: my_file.cc:247
bool my_enable_symlinks
Definition: my_sys.h:283
MYSQL_PLUGIN_IMPORT PSI_table_bootstrap * psi_table_hook
Definition: psi_noop.cc:545
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:523
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:348
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:697
int my_b_safe_write(IO_CACHE *info, const uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1359
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:604
bool insert_dynamic(DYNAMIC_ARRAY *array, const void *element)
Definition: array.cc:112
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:511
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:328
size_t my_b_bytes_in_cache(const IO_CACHE *info)
Definition: my_sys.h:550
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:835
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:117
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:601
bool my_uncompress(mysql_compress_context *, uchar *, size_t, size_t *)
Uncompress packet.
Definition: my_compress.cc:324
UnlinkOrKeepFile
Definition: my_sys.h:782
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:853
int _my_b_read(IO_CACHE *info, uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:424
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:441
MYSQL_PLUGIN_IMPORT PSI_data_lock_bootstrap * psi_data_lock_hook
Definition: psi_noop.cc:974
int my_msync(int, void *, size_t, int)
Definition: my_mmap.cc:51
size_t escape_quotes_for_mysql(CHARSET_INFO *charset_info, char *to, size_t to_length, const char *from, size_t length, char quote)
Definition: charset.cc:539
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:501
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:286
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:326
MYSQL_PLUGIN_IMPORT PSI_rwlock_bootstrap * psi_rwlock_hook
Definition: psi_noop.cc:322
int end_io_cache(IO_CACHE *info)
Definition: mf_iocache.cc:1520
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 delete_dynamic(DYNAMIC_ARRAY *array)
Definition: array.cc:176
void set_psi_data_lock_service(void *psi)
Definition: psi_noop.cc:977
my_syslog_options
Definition: my_sys.h:621
MYSQL_PLUGIN_IMPORT PSI_cond_bootstrap * psi_cond_hook
Definition: psi_noop.cc:354
bool has_path(const char *name)
Definition: my_getwd.cc:160
size_t escape_string_for_mysql(const CHARSET_INFO *charset_info, char *to, size_t to_length, const char *from, size_t length)
Definition: charset.cc:413
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:263
void set_psi_cond_service(void *psi)
Definition: psi_noop.cc:357
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:1220
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:325
const char * get_collation_name(uint charset_number)
Definition: charset.cc:218
constexpr int my_b_EOF
Definition: my_sys.h:499
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:312
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:1431
int _my_b_write(IO_CACHE *info, const uchar *Buffer, size_t Count)
Definition: mf_iocache.cc:1239
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:292
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:97
void set_psi_thread_service(void *psi)
Definition: psi_noop.cc:250
MYSQL_PLUGIN_IMPORT PSI_socket_bootstrap * psi_socket_hook
Definition: psi_noop.cc:487
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:328
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:535
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:629
void set_psi_metric_service(void *psi)
Definition: psi_noop.cc:1035
MYSQL_PLUGIN_IMPORT PSI_system_bootstrap * psi_system_hook
Definition: psi_noop.cc:987
MYSQL_PLUGIN_IMPORT PSI_mdl_bootstrap * psi_mdl_hook
Definition: psi_noop.cc:582
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:838
void set_psi_transaction_service(void *psi)
Definition: psi_noop.cc:905
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:278
void(* my_error_reporter)(enum loglevel level, uint ecode,...)
Definition: my_sys.h:484
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:871
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:297
@ SEQ_READ_APPEND
Definition: my_sys.h:291
@ TYPE_NOT_SET
Definition: my_sys.h:288
@ READ_NET
Definition: my_sys.h:293
@ WRITE_CACHE
Definition: my_sys.h:290
@ WRITE_NET
Definition: my_sys.h:294
@ READ_CACHE
Definition: my_sys.h:289
@ READ_FIFO
Definition: my_sys.h:292
@ UNLINK_FILE
Definition: my_sys.h:782
@ KEEP_FILE
Definition: my_sys.h:782
@ MY_SYSLOG_PIDS
Definition: my_sys.h:621
@ FLUSH_KEEP
Definition: my_sys.h:298
@ FLUSH_RELEASE
Definition: my_sys.h:299
@ FLUSH_FORCE_WRITE
Definition: my_sys.h:305
@ FLUSH_IGNORE_CHANGED
Definition: my_sys.h:300
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:10161
Header for compiler-dependent features.
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:1656
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:1641
bool binlog_cache_temporary_file_is_encrypted
(end of group MYSYS)
Definition: mf_iocache.cc:94
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:1648
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:247
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:1081
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
This file includes core components for encrypting/decrypting binary log files.
Definition: m_ctype.h:423
Definition: my_sys.h:308
uchar * buffer
Definition: my_sys.h:309
uint elements
Definition: my_sys.h:310
uint size_of_element
Definition: my_sys.h:312
uint alloc_increment
Definition: my_sys.h:311
uint max_element
Definition: my_sys.h:310
PSI_memory_key m_psi_key
Definition: my_sys.h:313
Definition: my_sys.h:322
char * str
Definition: my_sys.h:323
size_t length
Definition: my_sys.h:324
size_t max_length
Definition: my_sys.h:324
Definition: my_sys.h:330
int running_threads
Definition: my_sys.h:340
int error
Definition: my_sys.h:342
mysql_mutex_t mutex
Definition: my_sys.h:331
uchar * read_end
Definition: my_sys.h:339
my_off_t pos_in_file
Definition: my_sys.h:335
int total_threads
Definition: my_sys.h:341
mysql_cond_t cond_writer
Definition: my_sys.h:333
mysql_cond_t cond
Definition: my_sys.h:332
IO_CACHE * source_cache
Definition: my_sys.h:337
uchar * buffer
Definition: my_sys.h:338
Definition: my_sys.h:346
uchar * write_buffer
Definition: my_sys.h:364
uchar * read_pos
Definition: my_sys.h:356
my_off_t pos_in_file
Definition: my_sys.h:348
my_off_t end_of_file
Definition: my_sys.h:354
uchar * read_end
Definition: my_sys.h:358
uchar ** current_end
Definition: my_sys.h:383
ulong disk_writes
Definition: my_sys.h:434
IO_CACHE_CALLBACK post_read
Definition: my_sys.h:427
myf myflags
Definition: my_sys.h:454
void * arg
Definition: my_sys.h:435
uchar * buffer
Definition: my_sys.h:359
bool seek_not_done
Definition: my_sys.h:448
uchar * write_pos
Definition: my_sys.h:373
uchar ** current_pos
Definition: my_sys.h:383
PSI_file_key file_key
Definition: my_sys.h:439
int(* write_function)(IO_CACHE *, const uchar *, size_t)
Definition: my_sys.h:412
char * file_name
Definition: my_sys.h:436
uchar * append_read_pos
Definition: my_sys.h:371
uint disk_sync_delay
Definition: my_sys.h:470
uchar * request_pos
Definition: my_sys.h:361
size_t buffer_length
Definition: my_sys.h:451
int(* read_function)(IO_CACHE *, uchar *, size_t)
Definition: my_sys.h:407
char * dir
Definition: my_sys.h:437
bool alloced_buffer
Definition: my_sys.h:461
uchar * write_end
Definition: my_sys.h:375
Stream_cipher * m_encryptor
Definition: my_sys.h:463
char * prefix
Definition: my_sys.h:437
Stream_cipher * m_decryptor
Definition: my_sys.h:465
IO_CACHE_CALLBACK pre_close
Definition: my_sys.h:428
int error
Definition: my_sys.h:449
IO_CACHE_SHARE * share
Definition: my_sys.h:397
cache_type type
Definition: my_sys.h:418
size_t read_length
Definition: my_sys.h:453
IO_CACHE_CALLBACK pre_read
Definition: my_sys.h:426
mysql_mutex_t append_buffer_lock
Definition: my_sys.h:389
bool disk_sync
Definition: my_sys.h:467
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:181
Definition: my_sys.h:316
char ** list
Definition: my_sys.h:317
uint max
Definition: my_sys.h:318
uint cur
Definition: my_sys.h:318
mysql_mutex_t mutex
Definition: my_sys.h:319
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_mdl.h:68
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:479
dev_t st_dev
Definition: my_sys.h:480
ino_t st_ino
Definition: my_sys.h:481
struct for once_alloc (block)
Definition: my_sys.h:564
unsigned int size
size of block
Definition: my_sys.h:567
unsigned int left
memory left in block
Definition: my_sys.h:566
USED_MEM * next
Next block in use.
Definition: my_sys.h:565
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:42
#define HANDLE
Definition: violite.h:159
int n
Definition: xcom_base.cc:509
static uint64_t cache_size
Definition: xcom_cache.cc:362