Commit ee724f31 authored by unknown's avatar unknown

Merge work.mysql.com:/home/bk/mysql

into cane.mysql.fi:/usr/home/tim/my/work
parents 3a959eeb 4ab437a0
...@@ -206,9 +206,9 @@ int vio_blocking(Vio * vio, my_bool set_blocking_mode) ...@@ -206,9 +206,9 @@ int vio_blocking(Vio * vio, my_bool set_blocking_mode)
old_fcntl=vio->fcntl_mode = fcntl(vio->sd, F_GETFL); old_fcntl=vio->fcntl_mode = fcntl(vio->sd, F_GETFL);
} }
if (set_blocking_mode) if (set_blocking_mode)
vio->fcntl_mode &= ~O_NONBLOCK; //clear bit vio->fcntl_mode &= ~O_NONBLOCK; /*clear bit */
else else
vio->fcntl_mode |= O_NONBLOCK; //set bit vio->fcntl_mode |= O_NONBLOCK; /*set bit */
if (old_fcntl != vio->fcntl_mode) if (old_fcntl != vio->fcntl_mode)
r = fcntl(vio->sd, F_SETFL, vio->fcntl_mode); r = fcntl(vio->sd, F_SETFL, vio->fcntl_mode);
} }
...@@ -228,12 +228,12 @@ int vio_blocking(Vio * vio, my_bool set_blocking_mode) ...@@ -228,12 +228,12 @@ int vio_blocking(Vio * vio, my_bool set_blocking_mode)
if (set_blocking_mode) if (set_blocking_mode)
{ {
arg = 0; arg = 0;
vio->fcntl_mode &= ~O_NONBLOCK; //clear bit vio->fcntl_mode &= ~O_NONBLOCK; /*clear bit */
} }
else else
{ {
arg = 1; arg = 1;
vio->fcntl_mode |= O_NONBLOCK; //set bit vio->fcntl_mode |= O_NONBLOCK; /*set bit */
} }
if (old_fcntl != vio->fcntl_mode) if (old_fcntl != vio->fcntl_mode)
r = ioctlsocket(vio->sd,FIONBIO,(void*) &arg, sizeof(arg)); r = ioctlsocket(vio->sd,FIONBIO,(void*) &arg, sizeof(arg));
......
...@@ -125,7 +125,7 @@ static void permute_aux(int *order, int num_queries, int* fixed) ...@@ -125,7 +125,7 @@ static void permute_aux(int *order, int num_queries, int* fixed)
} }
} }
//printf("num_free = %d\n", num_free); /*printf("num_free = %d\n", num_free); */
if(num_free <= 1) if(num_free <= 1)
{ {
......
...@@ -22,11 +22,11 @@ ...@@ -22,11 +22,11 @@
#define _global_h #define _global_h
#if defined( __EMX__) && !defined( MYSQL_SERVER) #if defined( __EMX__) && !defined( MYSQL_SERVER)
// moved here to use below VOID macro redefinition /* moved here to use below VOID macro redefinition */
#define INCL_BASE #define INCL_BASE
#define INCL_NOPMAPI #define INCL_NOPMAPI
#include <os2.h> #include <os2.h>
#endif // __EMX__ #endif /* __EMX__ */
#if defined(_WIN32) || defined(_WIN64) || defined(__WIN32__) || defined(WIN32) #if defined(_WIN32) || defined(_WIN64) || defined(__WIN32__) || defined(WIN32)
#include <config-win.h> #include <config-win.h>
......
...@@ -22,7 +22,7 @@ ...@@ -22,7 +22,7 @@
#include <errno.h> #include <errno.h>
#ifndef ETIME #ifndef ETIME
#define ETIME ETIMEDOUT // For FreeBSD #define ETIME ETIMEDOUT /* For FreeBSD */
#endif #endif
#if defined(__WIN__) #if defined(__WIN__)
...@@ -119,8 +119,8 @@ void pthread_exit(void *a); /* was #define pthread_exit(A) ExitThread(A)*/ ...@@ -119,8 +119,8 @@ void pthread_exit(void *a); /* was #define pthread_exit(A) ExitThread(A)*/
#define pthread_condattr_init(A) #define pthread_condattr_init(A)
#define pthread_condattr_destroy(A) #define pthread_condattr_destroy(A)
//Irena: compiler does not like this: /*Irena: compiler does not like this: */
//#define my_pthread_getprio(pthread_t thread_id) pthread_dummy(0) /*#define my_pthread_getprio(pthread_t thread_id) pthread_dummy(0) */
#define my_pthread_getprio(thread_id) pthread_dummy(0) #define my_pthread_getprio(thread_id) pthread_dummy(0)
#elif defined(HAVE_UNIXWARE7_THREADS) #elif defined(HAVE_UNIXWARE7_THREADS)
......
...@@ -16,9 +16,9 @@ ...@@ -16,9 +16,9 @@
MA 02111-1307, USA */ MA 02111-1307, USA */
/* Parser needs these defines always, even if USE_RAID is not defined */ /* Parser needs these defines always, even if USE_RAID is not defined */
#define RAID_TYPE_0 1 // Striping #define RAID_TYPE_0 1 /* Striping */
#define RAID_TYPE_x 2 // Some new modes #define RAID_TYPE_x 2 /* Some new modes */
#define RAID_TYPE_y 3 // #define RAID_TYPE_y 3
#define RAID_DEFAULT_CHUNKS 4 #define RAID_DEFAULT_CHUNKS 4
#define RAID_DEFAULT_CHUNKSIZE 256*1024 /* 256kB */ #define RAID_DEFAULT_CHUNKSIZE 256*1024 /* 256kB */
...@@ -102,9 +102,9 @@ class RaidName { ...@@ -102,9 +102,9 @@ class RaidName {
bool IsRaid(); bool IsRaid();
int Rename(const char * from, const char * to, myf MyFlags); int Rename(const char * from, const char * to, myf MyFlags);
private: private:
uint _raid_type; // RAID_TYPE_0 or RAID_TYPE_1 or RAID_TYPE_5 uint _raid_type; /* RAID_TYPE_0 or RAID_TYPE_1 or RAID_TYPE_5 */
uint _raid_chunks; // 1..n uint _raid_chunks; /* 1..n */
ulong _raid_chunksize; // 1..n in bytes ulong _raid_chunksize; /* 1..n in bytes */
}; };
class RaidFd { class RaidFd {
...@@ -126,16 +126,16 @@ class RaidFd { ...@@ -126,16 +126,16 @@ class RaidFd {
static DYNAMIC_ARRAY _raid_map; /* Map of RaidFD* */ static DYNAMIC_ARRAY _raid_map; /* Map of RaidFD* */
private: private:
uint _raid_type; // RAID_TYPE_0 or RAID_TYPE_1 or RAID_TYPE_5 uint _raid_type; /* RAID_TYPE_0 or RAID_TYPE_1 or RAID_TYPE_5 */
uint _raid_chunks; // 1..n uint _raid_chunks; /* 1..n */
ulong _raid_chunksize; // 1..n in bytes ulong _raid_chunksize; /* 1..n in bytes */
ulong _total_block; // We are operating with block no x (can be 0..many). ulong _total_block; /* We are operating with block no x (can be 0..many). */
uint _this_block; // can be 0.._raid_chunks uint _this_block; /* can be 0.._raid_chunks */
uint _remaining_bytes; // Maximum bytes that can be written in this block uint _remaining_bytes; /* Maximum bytes that can be written in this block */
my_off_t _position; my_off_t _position;
my_off_t _size; // Cached file size for faster seek(SEEK_END) my_off_t _size; /* Cached file size for faster seek(SEEK_END) */
File _fd; File _fd;
File *_fd_vector; /* Array of File */ File *_fd_vector; /* Array of File */
off_t *_seek_vector; /* Array of cached seek positions */ off_t *_seek_vector; /* Array of cached seek positions */
...@@ -147,7 +147,7 @@ class RaidFd { ...@@ -147,7 +147,7 @@ class RaidFd {
(ulong) _position, _raid_chunksize, (ulong) _size)); (ulong) _position, _raid_chunksize, (ulong) _size));
_total_block = (ulong) (_position / _raid_chunksize); _total_block = (ulong) (_position / _raid_chunksize);
_this_block = _total_block % _raid_chunks; // can be 0.._raid_chunks _this_block = _total_block % _raid_chunks; /* can be 0.._raid_chunks */
_remaining_bytes = (uint) (_raid_chunksize - _remaining_bytes = (uint) (_raid_chunksize -
(_position - _total_block * _raid_chunksize)); (_position - _total_block * _raid_chunksize));
DBUG_PRINT("info", DBUG_PRINT("info",
......
...@@ -17,25 +17,25 @@ ...@@ -17,25 +17,25 @@
#ifdef HAVE_OPENSSL #ifdef HAVE_OPENSSL
case OPT_SSL_SSL: case OPT_SSL_SSL:
opt_use_ssl = 1; //true opt_use_ssl = 1; /* true */
break; break;
case OPT_SSL_KEY: case OPT_SSL_KEY:
opt_use_ssl = 1; //true opt_use_ssl = 1; /* true */
my_free(opt_ssl_key, MYF(MY_ALLOW_ZERO_PTR)); my_free(opt_ssl_key, MYF(MY_ALLOW_ZERO_PTR));
opt_ssl_key = my_strdup(optarg, MYF(0)); opt_ssl_key = my_strdup(optarg, MYF(0));
break; break;
case OPT_SSL_CERT: case OPT_SSL_CERT:
opt_use_ssl = 1; //true opt_use_ssl = 1; /* true */
my_free(opt_ssl_cert, MYF(MY_ALLOW_ZERO_PTR)); my_free(opt_ssl_cert, MYF(MY_ALLOW_ZERO_PTR));
opt_ssl_cert = my_strdup(optarg, MYF(0)); opt_ssl_cert = my_strdup(optarg, MYF(0));
break; break;
case OPT_SSL_CA: case OPT_SSL_CA:
opt_use_ssl = 1; //true opt_use_ssl = 1; /* true */
my_free(opt_ssl_ca, MYF(MY_ALLOW_ZERO_PTR)); my_free(opt_ssl_ca, MYF(MY_ALLOW_ZERO_PTR));
opt_ssl_ca = my_strdup(optarg, MYF(0)); opt_ssl_ca = my_strdup(optarg, MYF(0));
break; break;
case OPT_SSL_CAPATH: case OPT_SSL_CAPATH:
opt_use_ssl = 1; //true opt_use_ssl = 1; /* true */
my_free(opt_ssl_ca, MYF(MY_ALLOW_ZERO_PTR)); my_free(opt_ssl_ca, MYF(MY_ALLOW_ZERO_PTR));
opt_ssl_ca = my_strdup(optarg, MYF(0)); opt_ssl_ca = my_strdup(optarg, MYF(0));
break; break;
......
...@@ -1404,7 +1404,10 @@ mysql_real_connect(MYSQL *mysql,const char *host, const char *user, ...@@ -1404,7 +1404,10 @@ mysql_real_connect(MYSQL *mysql,const char *host, const char *user,
{ {
charset_name=charset_name_buff; charset_name=charset_name_buff;
sprintf(charset_name,"%d",mysql->server_language); /* In case of errors */ sprintf(charset_name,"%d",mysql->server_language); /* In case of errors */
mysql->charset=get_charset((uint8) mysql->server_language, MYF(MY_WME)); if (!(mysql->charset =
get_charset((uint8) mysql->server_language, MYF(MY_WME))))
mysql->charset = default_charset_info; /* shouldn't be fatal */
} }
else else
mysql->charset=default_charset_info; mysql->charset=default_charset_info;
......
...@@ -50,7 +50,7 @@ ulong net_buffer_length=8192; /* Default length. Enlarged if necessary */ ...@@ -50,7 +50,7 @@ ulong net_buffer_length=8192; /* Default length. Enlarged if necessary */
#if !defined(__WIN__) && !defined(MSDOS) #if !defined(__WIN__) && !defined(MSDOS)
#include <sys/socket.h> #include <sys/socket.h>
#else #else
#undef MYSQL_SERVER // Win32 can't handle interrupts #undef MYSQL_SERVER /* Win32 can't handle interrupts */
#endif #endif
#if !defined(MSDOS) && !defined(__WIN__) && !defined(HAVE_BROKEN_NETINET_INCLUDES) && !defined(__BEOS__) #if !defined(MSDOS) && !defined(__WIN__) && !defined(HAVE_BROKEN_NETINET_INCLUDES) && !defined(__BEOS__)
#include <netinet/in_systm.h> #include <netinet/in_systm.h>
...@@ -418,7 +418,7 @@ static void my_net_skip_rest(NET *net, ulong remain, thr_alarm_t *alarmed) ...@@ -418,7 +418,7 @@ static void my_net_skip_rest(NET *net, ulong remain, thr_alarm_t *alarmed)
{ {
if (!thr_alarm(alarmed,net->timeout,&alarm_buff) || if (!thr_alarm(alarmed,net->timeout,&alarm_buff) ||
(!vio_is_blocking(net->vio) && vio_blocking(net->vio,TRUE) < 0)) (!vio_is_blocking(net->vio) && vio_blocking(net->vio,TRUE) < 0))
return; // Can't setup, abort return; /* Can't setup, abort */
} }
while (remain > 0) while (remain > 0)
{ {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment