Loading client/mysqlbinlog.cc +9 −3 Original line number Diff line number Diff line Loading @@ -1169,7 +1169,13 @@ static int dump_local_log_entries(const char* logname) Log_event* ev = Log_event::read_log_event(file, description_event); if (!ev) { if (file->error) /* if binlog wasn't closed properly ("in use" flag is set) don't complain about a corruption, but treat it as EOF and move to the next binlog. */ if (description_event->flags & LOG_EVENT_BINLOG_IN_USE_F) file->error= 0; else if (file->error) { fprintf(stderr, "Could not read entry at offset %s:" Loading configure.in +1 −1 Original line number Diff line number Diff line Loading @@ -1887,7 +1887,7 @@ AC_CHECK_FUNCS(alarm bcmp bfill bmove bzero chsize cuserid fchmod fcntl \ getcwd gethostbyaddr_r gethostbyname_r getpass getpassphrase getpwnam \ getpwuid getrlimit getrusage getwd gmtime_r index initgroups isnan \ localtime_r locking longjmp lrand48 madvise mallinfo memcpy memmove \ mkstemp mlockall perror poll pread pthread_attr_create mmap \ mkstemp mlockall perror poll pread pthread_attr_create mmap getpagesize \ pthread_attr_getstacksize pthread_attr_setprio pthread_attr_setschedparam \ pthread_attr_setstacksize pthread_condattr_create pthread_getsequence_np \ pthread_key_delete pthread_rwlock_rdlock pthread_setprio \ Loading include/my_global.h +1 −1 Original line number Diff line number Diff line Loading @@ -761,7 +761,7 @@ typedef long int32; #endif typedef unsigned long uint32; /* Short for unsigned integer >= 32 bits */ #else error "Neither int or long is of 4 bytes width" #error "Neither int or long is of 4 bytes width" #endif #if !defined(HAVE_ULONG) && !defined(HAVE_LINUXTHREADS) && !defined(__USE_MISC) Loading include/my_pthread.h +3 −3 Original line number Diff line number Diff line Loading @@ -689,12 +689,12 @@ extern pthread_t shutdown_th, main_th, signal_th; #define thread_safe_add(V,C,L) (pthread_mutex_lock((L)), (V)+=(C), pthread_mutex_unlock((L))) #define thread_safe_sub(V,C,L) \ (pthread_mutex_lock((L)), (V)-=(C), pthread_mutex_unlock((L))) #if defined (__GNUC__) || defined (__cplusplus) static inline bool thread_safe_dec_and_test(ulong V, pthread_mutex_t *L) #ifdef __cplusplus static inline bool thread_safe_dec_and_test(ulong &V, pthread_mutex_t *L) { ulong res; pthread_mutex_lock(L); res=V--; res=--V; pthread_mutex_unlock(L); return res==0; } Loading innobase/include/trx0sys.ic +4 −3 Original line number Diff line number Diff line Loading @@ -325,7 +325,8 @@ trx_is_active( } trx = trx_get_on_id(trx_id); if (trx && (trx->conc_state == TRX_ACTIVE)) { if (trx && (trx->conc_state == TRX_ACTIVE || trx->conc_state == TRX_PREPARED)) { return(TRUE); } Loading Loading
client/mysqlbinlog.cc +9 −3 Original line number Diff line number Diff line Loading @@ -1169,7 +1169,13 @@ static int dump_local_log_entries(const char* logname) Log_event* ev = Log_event::read_log_event(file, description_event); if (!ev) { if (file->error) /* if binlog wasn't closed properly ("in use" flag is set) don't complain about a corruption, but treat it as EOF and move to the next binlog. */ if (description_event->flags & LOG_EVENT_BINLOG_IN_USE_F) file->error= 0; else if (file->error) { fprintf(stderr, "Could not read entry at offset %s:" Loading
configure.in +1 −1 Original line number Diff line number Diff line Loading @@ -1887,7 +1887,7 @@ AC_CHECK_FUNCS(alarm bcmp bfill bmove bzero chsize cuserid fchmod fcntl \ getcwd gethostbyaddr_r gethostbyname_r getpass getpassphrase getpwnam \ getpwuid getrlimit getrusage getwd gmtime_r index initgroups isnan \ localtime_r locking longjmp lrand48 madvise mallinfo memcpy memmove \ mkstemp mlockall perror poll pread pthread_attr_create mmap \ mkstemp mlockall perror poll pread pthread_attr_create mmap getpagesize \ pthread_attr_getstacksize pthread_attr_setprio pthread_attr_setschedparam \ pthread_attr_setstacksize pthread_condattr_create pthread_getsequence_np \ pthread_key_delete pthread_rwlock_rdlock pthread_setprio \ Loading
include/my_global.h +1 −1 Original line number Diff line number Diff line Loading @@ -761,7 +761,7 @@ typedef long int32; #endif typedef unsigned long uint32; /* Short for unsigned integer >= 32 bits */ #else error "Neither int or long is of 4 bytes width" #error "Neither int or long is of 4 bytes width" #endif #if !defined(HAVE_ULONG) && !defined(HAVE_LINUXTHREADS) && !defined(__USE_MISC) Loading
include/my_pthread.h +3 −3 Original line number Diff line number Diff line Loading @@ -689,12 +689,12 @@ extern pthread_t shutdown_th, main_th, signal_th; #define thread_safe_add(V,C,L) (pthread_mutex_lock((L)), (V)+=(C), pthread_mutex_unlock((L))) #define thread_safe_sub(V,C,L) \ (pthread_mutex_lock((L)), (V)-=(C), pthread_mutex_unlock((L))) #if defined (__GNUC__) || defined (__cplusplus) static inline bool thread_safe_dec_and_test(ulong V, pthread_mutex_t *L) #ifdef __cplusplus static inline bool thread_safe_dec_and_test(ulong &V, pthread_mutex_t *L) { ulong res; pthread_mutex_lock(L); res=V--; res=--V; pthread_mutex_unlock(L); return res==0; } Loading
innobase/include/trx0sys.ic +4 −3 Original line number Diff line number Diff line Loading @@ -325,7 +325,8 @@ trx_is_active( } trx = trx_get_on_id(trx_id); if (trx && (trx->conc_state == TRX_ACTIVE)) { if (trx && (trx->conc_state == TRX_ACTIVE || trx->conc_state == TRX_PREPARED)) { return(TRUE); } Loading