开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mysqld.cc
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：130k
源码类别：

MySQL数据库

开发平台：

Visual C++

mysqld.cc：源码内容
  1. (void*) thd)))
  2.       {
  3. DBUG_PRINT("error",
  4.    ("Can't create thread to handle request (error %d)",
  5.     error));
  6. (void) pthread_mutex_lock(&LOCK_thread_count);
  7. thread_count--;
  8. thd->killed=1; // Safety
  9. (void) pthread_mutex_unlock(&LOCK_thread_count);
  10. net_printf(net,ER_CANT_CREATE_THREAD,error);
  11. (void) pthread_mutex_lock(&LOCK_thread_count);
  12. close_connection(net,0,0);
  13. delete thd;
  14. (void) pthread_mutex_unlock(&LOCK_thread_count);
  15. DBUG_VOID_RETURN;
  16.       }
  17.     }
  18.   }
  19.   DBUG_PRINT("info",(("Thread %d created"), thd->thread_id));
  20.   DBUG_VOID_RETURN;
  21. }
  24. /* Handle new connections and spawn new process to handle them */
  26. pthread_handler_decl(handle_connections_sockets,arg __attribute__((unused)))
  27. {
  28.   my_socket sock,new_sock;
  29.   uint error_count=0;
  30.   uint max_used_connection= (uint) (max(ip_sock,unix_sock)+1);
  31.   fd_set readFDs,clientFDs;
  32.   THD *thd;
  33.   struct sockaddr_in cAddr;
  34.   int ip_flags=0,socket_flags=0,flags;
  35.   Vio *vio_tmp;
  36.   DBUG_ENTER("handle_connections_sockets");
  38.   LINT_INIT(new_sock);
  40.   (void) my_pthread_getprio(pthread_self()); // For debugging
  42.   FD_ZERO(&clientFDs);
  43.   if (ip_sock != INVALID_SOCKET)
  44.   {
  45.     FD_SET(ip_sock,&clientFDs);
  46. #ifdef HAVE_FCNTL
  47.     ip_flags = fcntl(ip_sock, F_GETFL, 0);
  48. #endif
  49.   }
  50. #ifdef HAVE_SYS_UN_H
  51.   FD_SET(unix_sock,&clientFDs);
  52.   socket_flags=fcntl(unix_sock, F_GETFL, 0);
  53. #endif
  55.   DBUG_PRINT("general",("Waiting for connections."));
  56.   while (!abort_loop)
  57.   {
  58.     readFDs=clientFDs;
  59. #ifdef HPUX
  60.     if (select(max_used_connection,(int*) &readFDs,0,0,0) < 0)
  61.       continue;
  62. #else
  63.     if (select((int) max_used_connection,&readFDs,0,0,0) < 0)
  64.     {
  65.       if (errno != EINTR)
  66.       {
  67. if (!select_errors++ && !abort_loop) /* purecov: inspected */
  68.   sql_print_error("mysqld: Got error %d from select",errno); /* purecov: inspected */
  69.       }
  70.       continue;
  71.     }
  72. #endif /* HPUX */
  73.     if (abort_loop)
  74.       break;
  76.     /*
  77.     ** Is this a new connection request
  78.     */
  80. #ifdef HAVE_SYS_UN_H
  81.     if (FD_ISSET(unix_sock,&readFDs))
  82.     {
  83.       sock = unix_sock;
  84.       flags= socket_flags;
  85.     }
  86.     else
  87. #endif
  88.     {
  89.       sock = ip_sock;
  90.       flags= ip_flags;
  91.     }
  93. #if !defined(NO_FCNTL_NONBLOCK)
  94.     if (!(test_flags & TEST_BLOCKING))
  95.     {
  96. #if defined(O_NONBLOCK)
  97.       fcntl(sock, F_SETFL, flags | O_NONBLOCK);
  98. #elif defined(O_NDELAY)
  99.       fcntl(sock, F_SETFL, flags | O_NDELAY);
  100. #endif
  101.     }
  102. #endif /* NO_FCNTL_NONBLOCK */
  103.     for (uint retry=0; retry < MAX_ACCEPT_RETRY; retry++)
  104.     {
  105.       size_socket length=sizeof(struct sockaddr_in);
  106.       new_sock = accept(sock, my_reinterpret_cast(struct sockaddr *) (&cAddr),
  107. &length);
  108.       if (new_sock != INVALID_SOCKET || (errno != EINTR && errno != EAGAIN))
  109. break;
  110. #if !defined(NO_FCNTL_NONBLOCK)
  111.       if (!(test_flags & TEST_BLOCKING))
  112.       {
  113. if (retry == MAX_ACCEPT_RETRY - 1)
  114.   fcntl(sock, F_SETFL, flags); // Try without O_NONBLOCK
  115.       }
  116. #endif
  117.     }
  118. #if !defined(NO_FCNTL_NONBLOCK)
  119.     if (!(test_flags & TEST_BLOCKING))
  120.       fcntl(sock, F_SETFL, flags);
  121. #endif
  122.     if (new_sock < 0)
  123.     {
  124.       if ((error_count++ & 255) == 0) // This can happen often
  125. sql_perror("Error in accept");
  126.       if (errno == ENFILE || errno == EMFILE)
  127. sleep(1); // Give other threads some time
  128.       continue;
  129.     }
  131. #ifdef HAVE_LIBWRAP
  132.     {
  133.       if (sock == ip_sock)
  134.       {
  135. struct request_info req;
  136. signal(SIGCHLD, SIG_DFL);
  137. request_init(&req, RQ_DAEMON, libwrapName, RQ_FILE, new_sock, NULL);
  138. fromhost(&req);
  139. if (!hosts_access(&req))
  140. {
  141.   // This may be stupid but refuse() includes an exit(0)
  142.   // which we surely don't want...
  143.   // clean_exit() - same stupid thing ...
  144.   syslog(deny_severity, "refused connect from %s", eval_client(&req));
  145.   if (req.sink)
  146.     ((void (*)(int))req.sink)(req.fd);
  148.   // C++ sucks (the gibberish in front just translates the supplied
  149.   // sink function pointer in the req structure from a void (*sink)();
  150.   // to a void(*sink)(int) if you omit the cast, the C++ compiler
  151.   // will cry...
  153.   (void) shutdown(new_sock,2);  // This looks fine to me...
  154.   (void) closesocket(new_sock);
  155.   continue;
  156. }
  157.       }
  158.     }
  159. #endif /* HAVE_LIBWRAP */
  161.     {
  162.       size_socket dummyLen;
  163.       struct sockaddr dummy;
  164.       dummyLen = sizeof(struct sockaddr);
  165.       if (getsockname(new_sock,&dummy, &dummyLen) < 0)
  166.       {
  167. sql_perror("Error on new connection socket");
  168. (void) shutdown(new_sock,2);
  169. (void) closesocket(new_sock);
  170. continue;
  171.       }
  172.     }
  174.     /*
  175.     ** Don't allow too many connections
  176.     */
  178.     if (!(thd= new THD))
  179.     {
  180.       (void) shutdown(new_sock,2); VOID(closesocket(new_sock));
  181.       continue;
  182.     }
  183.     if (!(vio_tmp=vio_new(new_sock,
  184.   sock == unix_sock ? VIO_TYPE_SOCKET :
  185.   VIO_TYPE_TCPIP,
  186.   sock == unix_sock)) ||
  187. my_net_init(&thd->net,vio_tmp))
  188.     {
  189.       if (vio_tmp)
  190. vio_delete(vio_tmp);
  191.       else
  192.       {
  193. (void) shutdown(new_sock,2);
  194. (void) closesocket(new_sock);
  195.       }
  196.       delete thd;
  197.       continue;
  198.     }
  199.     if (sock == unix_sock)
  200.       thd->host=(char*) localhost;
  201.     create_new_thread(thd);
  202.   }
  204. #ifdef __NT__
  205.   pthread_mutex_lock(&LOCK_thread_count);
  206.   handler_count--;
  207.   pthread_mutex_unlock(&LOCK_thread_count);
  208.   pthread_cond_signal(&COND_handler_count);
  209. #endif
  210.   DBUG_RETURN(0);
  211. }
  214. #ifdef __NT__
  215. pthread_handler_decl(handle_connections_namedpipes,arg)
  216. {
  217.   HANDLE hConnectedPipe;
  218.   BOOL fConnected;
  219.   THD *thd;
  220.   my_thread_init();
  221.   DBUG_ENTER("handle_connections_namedpipes");
  222.   (void) my_pthread_getprio(pthread_self()); // For debugging
  224.   DBUG_PRINT("general",("Waiting for named pipe connections."));
  225.   while (!abort_loop)
  226.   {
  227.     /* wait for named pipe connection */
  228.     fConnected = ConnectNamedPipe( hPipe, NULL );
  229.     if (abort_loop)
  230.       break;
  231.     if ( !fConnected )
  232.       fConnected = GetLastError() == ERROR_PIPE_CONNECTED;
  233.     if ( !fConnected )
  234.     {
  235.       CloseHandle( hPipe );
  236.       if ((hPipe = CreateNamedPipe(szPipeName,
  237.    PIPE_ACCESS_DUPLEX,
  238.    PIPE_TYPE_BYTE |
  239.    PIPE_READMODE_BYTE |
  240.    PIPE_WAIT,
  241.    PIPE_UNLIMITED_INSTANCES,
  242.    (int) net_buffer_length,
  243.    (int) net_buffer_length,
  244.    NMPWAIT_USE_DEFAULT_WAIT,
  245.    &saPipeSecurity )) ==
  246.   INVALID_HANDLE_VALUE )
  247.       {
  248. sql_perror("Can't create new named pipe!");
  249. break; // Abort
  250.       }
  251.     }
  252.     hConnectedPipe = hPipe;
  253.     /* create new pipe for new connection */
  254.     if ((hPipe = CreateNamedPipe(szPipeName,
  255.  PIPE_ACCESS_DUPLEX,
  256.  PIPE_TYPE_BYTE |
  257.  PIPE_READMODE_BYTE |
  258.  PIPE_WAIT,
  259.  PIPE_UNLIMITED_INSTANCES,
  260.  (int) net_buffer_length,
  261.  (int) net_buffer_length,
  262.  NMPWAIT_USE_DEFAULT_WAIT,
  263.  &saPipeSecurity)) ==
  264. INVALID_HANDLE_VALUE)
  265.     {
  266.       sql_perror("Can't create new named pipe!");
  267.       hPipe=hConnectedPipe;
  268.       continue; // We have to try again
  269.     }
  271.     if ( !(thd = new THD))
  272.     {
  273.       DisconnectNamedPipe( hConnectedPipe );
  274.       CloseHandle( hConnectedPipe );
  275.       continue;
  276.     }
  277.     if (!(thd->net.vio = vio_new_win32pipe(hConnectedPipe)) ||
  278. my_net_init(&thd->net, thd->net.vio))
  279.     {
  280.       close_connection(&thd->net,ER_OUT_OF_RESOURCES);
  281.       delete thd;
  282.       continue;
  283.     }
  284.     /* host name is unknown */
  285.     thd->host = my_strdup(localhost,MYF(0)); /* Host is unknown */
  286.     create_new_thread(thd);
  287.   }
  289.   pthread_mutex_lock(&LOCK_thread_count);
  290.   handler_count--;
  291.   pthread_cond_signal(&COND_handler_count);
  292.   pthread_mutex_unlock(&LOCK_thread_count);
  293.   DBUG_RETURN(0);
  294. }
  295. #endif /* __NT__ */
  298. /******************************************************************************
  299. ** handle start options
  300. ******************************************************************************/
  302. enum options {
  303.                OPT_ISAM_LOG=256,            OPT_SKIP_NEW, 
  304.                OPT_SKIP_GRANT,              OPT_SKIP_LOCK, 
  305.                OPT_ENABLE_LOCK,             OPT_USE_LOCKING,
  306.                OPT_SOCKET,                  OPT_UPDATE_LOG, 
  307.                OPT_BIN_LOG,                 OPT_SKIP_RESOLVE, 
  308.                OPT_SKIP_NETWORKING,         OPT_BIN_LOG_INDEX,
  309.                OPT_BIND_ADDRESS,            OPT_PID_FILE,
  310.                OPT_SKIP_PRIOR,              OPT_BIG_TABLES,    
  311.                OPT_STANDALONE,              OPT_ONE_THREAD,
  312.                OPT_CONSOLE,                 OPT_LOW_PRIORITY_UPDATES,
  313.                OPT_SKIP_HOST_CACHE,         OPT_LONG_FORMAT,   
  314.                OPT_FLUSH,                   OPT_SAFE, 
  315.                OPT_BOOTSTRAP,               OPT_SKIP_SHOW_DB,
  316.                OPT_TABLE_TYPE,              OPT_INIT_FILE,   
  317.                OPT_DELAY_KEY_WRITE,         OPT_SLOW_QUERY_LOG, 
  318.                OPT_SKIP_DELAY_KEY_WRITE,    OPT_CHARSETS_DIR,
  319.                OPT_BDB_HOME,                OPT_BDB_LOG,  
  320.                OPT_BDB_TMP,                 OPT_BDB_NOSYNC,
  321.                OPT_BDB_LOCK,                OPT_BDB_SKIP, 
  322.                OPT_BDB_NO_RECOVER,     OPT_BDB_SHARED,
  323.        OPT_MASTER_HOST,             OPT_MASTER_USER,
  324.                OPT_MASTER_PASSWORD,         OPT_MASTER_PORT,
  325.                OPT_MASTER_INFO_FILE,        OPT_MASTER_CONNECT_RETRY,
  326.                OPT_SQL_BIN_UPDATE_SAME,     OPT_REPLICATE_DO_DB,      
  327.                OPT_REPLICATE_IGNORE_DB,     OPT_LOG_SLAVE_UPDATES,
  328.                OPT_BINLOG_DO_DB,            OPT_BINLOG_IGNORE_DB,
  329.                OPT_WANT_CORE,               OPT_SKIP_CONCURRENT_INSERT,
  330.                OPT_MEMLOCK,                 OPT_MYISAM_RECOVER,
  331.                OPT_REPLICATE_REWRITE_DB,    OPT_SERVER_ID, 
  332.                OPT_SKIP_SLAVE_START,        OPT_SKIP_INNOBASE,
  333.                OPT_SAFEMALLOC_MEM_LIMIT,    OPT_REPLICATE_DO_TABLE, 
  334.                OPT_REPLICATE_IGNORE_TABLE,  OPT_REPLICATE_WILD_DO_TABLE, 
  335.                OPT_REPLICATE_WILD_IGNORE_TABLE, 
  336.                OPT_DISCONNECT_SLAVE_EVENT_COUNT, 
  337.                OPT_ABORT_SLAVE_EVENT_COUNT,
  338.        OPT_INNOBASE_DATA_HOME_DIR,
  339.                OPT_INNOBASE_DATA_FILE_PATH,
  340.        OPT_INNOBASE_LOG_GROUP_HOME_DIR, 
  341.                OPT_INNOBASE_LOG_ARCH_DIR, 
  342.                OPT_INNOBASE_LOG_ARCHIVE, 
  343.                OPT_INNOBASE_FLUSH_LOG_AT_TRX_COMMIT, 
  344.                OPT_SAFE_SHOW_DB,
  345.        OPT_GEMINI_SKIP, OPT_INNOBASE_SKIP,
  346.                OPT_TEMP_POOL
  347. };
  349. static struct option long_options[] = {
  350.   {"ansi",                  no_argument,       0, 'a'},
  351.   {"basedir",               required_argument, 0, 'b'},
  352. #ifdef HAVE_BERKELEY_DB
  353.   {"bdb-home",              required_argument, 0, (int) OPT_BDB_HOME},
  354.   {"bdb-lock-detect",       required_argument, 0, (int) OPT_BDB_LOCK},
  355.   {"bdb-logdir",            required_argument, 0, (int) OPT_BDB_LOG},
  356.   {"bdb-no-recover",        no_argument,       0, (int) OPT_BDB_NO_RECOVER},
  357.   {"bdb-no-sync",           no_argument,       0, (int) OPT_BDB_NOSYNC},
  358.   {"bdb-shared-data",       no_argument,       0, (int) OPT_BDB_SHARED},
  359.   {"bdb-tmpdir",            required_argument, 0, (int) OPT_BDB_TMP},
  360. #endif
  361.   {"big-tables",            no_argument,       0, (int) OPT_BIG_TABLES},
  362.   {"binlog-do-db",          required_argument, 0, (int) OPT_BINLOG_DO_DB},
  363.   {"binlog-ignore-db",      required_argument, 0, (int) OPT_BINLOG_IGNORE_DB},
  364.   {"bind-address",          required_argument, 0, (int) OPT_BIND_ADDRESS},
  365.   {"bootstrap",             no_argument,       0, (int) OPT_BOOTSTRAP},
  366. #ifdef __WIN__
  367.   {"console",               no_argument,       0, (int) OPT_CONSOLE},
  368. #endif
  369.   {"core-file",             no_argument,       0, (int) OPT_WANT_CORE},
  370.   {"chroot",                required_argument, 0, 'r'},
  371.   {"character-sets-dir",    required_argument, 0, (int) OPT_CHARSETS_DIR},
  372.   {"datadir",               required_argument, 0, 'h'},
  373. #ifndef DBUG_OFF
  374.   {"debug",                 optional_argument, 0, '#'},
  375. #endif
  376.   {"default-character-set", required_argument, 0, 'C'},
  377.   {"default-table-type",    required_argument, 0, (int) OPT_TABLE_TYPE},
  378.   {"delay-key-write-for-all-tables",
  379.                             no_argument,       0, (int) OPT_DELAY_KEY_WRITE},
  380.   {"enable-locking",        no_argument,       0, (int) OPT_ENABLE_LOCK},
  381.   {"exit-info",             optional_argument, 0, 'T'},
  382.   {"flush",                 no_argument,       0, (int) OPT_FLUSH},
  383.   /* We must always support this option to make scripts like mysqltest easier
  384.      to do */
  385.   {"innobase_data_file_path", required_argument, 0,
  386.      OPT_INNOBASE_DATA_FILE_PATH},
  387. #ifdef HAVE_INNOBASE_DB
  388.   {"innobase_data_home_dir", required_argument, 0,
  389.      OPT_INNOBASE_DATA_HOME_DIR},
  390.   {"innobase_log_group_home_dir", required_argument, 0,
  391.     OPT_INNOBASE_LOG_GROUP_HOME_DIR},
  392.   {"innobase_log_arch_dir", required_argument, 0,
  393.     OPT_INNOBASE_LOG_ARCH_DIR},
  394.   {"innobase_log_archive", optional_argument, 0,
  395.      OPT_INNOBASE_LOG_ARCHIVE},
  396.   {"innobase_flush_log_at_trx_commit", optional_argument, 0,
  397.      OPT_INNOBASE_FLUSH_LOG_AT_TRX_COMMIT},
  398. #endif
  399.   {"help",                  no_argument,       0, '?'},
  400.   {"init-file",             required_argument, 0, (int) OPT_INIT_FILE},
  401.   {"log",                   optional_argument, 0, 'l'},
  402.   {"language",              required_argument, 0, 'L'},
  403.   {"log-bin",               optional_argument, 0, (int) OPT_BIN_LOG},
  404.   {"log-bin-index",         required_argument, 0, (int) OPT_BIN_LOG_INDEX},
  405.   {"log-isam",              optional_argument, 0, (int) OPT_ISAM_LOG},
  406.   {"log-update",            optional_argument, 0, (int) OPT_UPDATE_LOG},
  407.   {"log-slow-queries",      optional_argument, 0, (int) OPT_SLOW_QUERY_LOG},
  408.   {"log-long-format",       no_argument,       0, (int) OPT_LONG_FORMAT},
  409.   {"log-slave-updates",     no_argument,       0, (int) OPT_LOG_SLAVE_UPDATES},
  410.   {"low-priority-updates",  no_argument,       0, (int) OPT_LOW_PRIORITY_UPDATES},
  411.   {"master-host",           required_argument, 0, (int) OPT_MASTER_HOST},
  412.   {"master-user",           required_argument, 0, (int) OPT_MASTER_USER},
  413.   {"master-password",       required_argument, 0, (int) OPT_MASTER_PASSWORD},
  414.   {"master-port",           required_argument, 0, (int) OPT_MASTER_PORT},
  415.   {"master-connect-retry",  required_argument, 0, (int) OPT_MASTER_CONNECT_RETRY},
  416.   {"master-info-file",      required_argument, 0, (int) OPT_MASTER_INFO_FILE},
  417.   {"myisam-recover",     optional_argument, 0, (int) OPT_MYISAM_RECOVER},
  418.   {"memlock",     no_argument,       0, (int) OPT_MEMLOCK},
  419.     // needs to be available for the test case to pass in non-debugging mode
  420.     // is a no-op
  421.   {"disconnect-slave-event-count",      required_argument, 0,
  422.      (int) OPT_DISCONNECT_SLAVE_EVENT_COUNT},
  423.   {"abort-slave-event-count",      required_argument, 0,
  424.      (int) OPT_ABORT_SLAVE_EVENT_COUNT},
  425. #if !defined(DBUG_OFF) && defined(SAFEMALLOC)
  426.   {"safemalloc-mem-limit",  required_argument, 0, (int)
  427.      OPT_SAFEMALLOC_MEM_LIMIT},
  428. #endif    
  429.   {"new",                   no_argument,       0, 'n'},
  430.   {"old-protocol",          no_argument,       0, 'o'},
  431. #ifdef ONE_THREAD
  432.   {"one-thread",            no_argument,       0, (int) OPT_ONE_THREAD},
  433. #endif
  434.   {"pid-file",              required_argument, 0, (int) OPT_PID_FILE},
  435.   {"port",                  required_argument, 0, 'P'},
  436.   {"replicate-do-db",       required_argument, 0, (int) OPT_REPLICATE_DO_DB},
  437.   {"replicate-do-table",       required_argument, 0,
  438.    (int) OPT_REPLICATE_DO_TABLE},
  439.   {"replicate-wild-do-table",       required_argument, 0,
  440.    (int) OPT_REPLICATE_WILD_DO_TABLE},
  441.   {"replicate-ignore-db",   required_argument, 0,
  442.    (int) OPT_REPLICATE_IGNORE_DB},
  443.   {"replicate-ignore-table",   required_argument, 0,
  444.    (int) OPT_REPLICATE_IGNORE_TABLE},
  445.   {"replicate-wild-ignore-table",   required_argument, 0,
  446.    (int) OPT_REPLICATE_WILD_IGNORE_TABLE},
  447.   {"replicate-rewrite-db",   required_argument, 0,
  448.      (int) OPT_REPLICATE_REWRITE_DB},
  449.   {"safe-mode",             no_argument,       0, (int) OPT_SAFE},
  450.   {"safe-show-database",    no_argument,       0, (int) OPT_SAFE_SHOW_DB},
  451.   {"socket",                required_argument, 0, (int) OPT_SOCKET},
  452.   {"server-id",     required_argument, 0, (int) OPT_SERVER_ID},
  453.   {"set-variable",          required_argument, 0, 'O'},
  454.   {"skip-bdb",              no_argument,       0, (int) OPT_BDB_SKIP},
  455.   {"skip-innobase",         no_argument,       0, (int) OPT_INNOBASE_SKIP},
  456.   {"skip-gemini",           no_argument,       0, (int) OPT_GEMINI_SKIP},
  457.   {"skip-concurrent-insert", no_argument,      0, (int) OPT_SKIP_CONCURRENT_INSERT},
  458.   {"skip-delay-key-write",  no_argument,       0, (int) OPT_SKIP_DELAY_KEY_WRITE},
  459.   {"skip-grant-tables",     no_argument,       0, (int) OPT_SKIP_GRANT},
  460.   {"skip-locking",          no_argument,       0, (int) OPT_SKIP_LOCK},
  461.   {"skip-host-cache",       no_argument,       0, (int) OPT_SKIP_HOST_CACHE},
  462.   {"skip-name-resolve",     no_argument,       0, (int) OPT_SKIP_RESOLVE},
  463.   {"skip-new",              no_argument,       0, (int) OPT_SKIP_NEW},
  464.   {"skip-show-database",    no_argument,       0, (int) OPT_SKIP_SHOW_DB},
  465.   {"skip-slave-start",      no_argument,       0, (int) OPT_SKIP_SLAVE_START},
  466.   {"skip-networking",       no_argument,       0, (int) OPT_SKIP_NETWORKING},
  467.   {"skip-thread-priority",  no_argument,       0, (int) OPT_SKIP_PRIOR},
  468.   {"sql-bin-update-same",   no_argument,       0, (int) OPT_SQL_BIN_UPDATE_SAME},
  469. #include "sslopt-longopts.h"
  470. #ifdef __WIN__
  471.   {"standalone",            no_argument,       0, (int) OPT_STANDALONE},
  472. #endif
  473.   {"temp-pool",             no_argument,       0, (int) OPT_TEMP_POOL},
  474.   {"tmpdir",                required_argument, 0, 't'},
  475.   {"use-locking",           no_argument,       0, (int) OPT_USE_LOCKING},
  476. #ifdef USE_SYMDIR
  477.   {"use-symbolic-links",    no_argument,       0, 's'},
  478. #endif
  479.   {"user",                  required_argument, 0, 'u'},
  480.   {"version",               no_argument,       0, 'V'},
  481.   {0, 0, 0, 0}
  482. };
  484. CHANGEABLE_VAR changeable_vars[] = {
  485.   { "back_log",                (long*) &back_log, 
  486.       50, 1, 65535, 0, 1 },
  487. #ifdef HAVE_BERKELEY_DB
  488.   { "bdb_cache_size",          (long*) &berkeley_cache_size, 
  489.       KEY_CACHE_SIZE, 20*1024, (long) ~0, 0, IO_SIZE },
  490.   {"bdb_log_buffer_size",      (long*) &berkeley_log_buffer_size, 0, 256*1024L,
  491.      ~0L, 0, 1024},
  492.   { "bdb_max_lock",            (long*) &berkeley_max_lock, 
  493.       10000, 0, (long) ~0, 0, 1 },
  494.     /* QQ: The following should be removed soon! */
  495.   { "bdb_lock_max",            (long*) &berkeley_max_lock, 
  496.       10000, 0, (long) ~0, 0, 1 },
  497. #endif
  498.   { "binlog_cache_size",       (long*) &binlog_cache_size,
  499.       32*1024L, IO_SIZE, ~0L, 0, IO_SIZE },
  500.   { "connect_timeout",         (long*) &connect_timeout,
  501.       CONNECT_TIMEOUT, 2, 65535, 0, 1 },
  502.   { "delayed_insert_timeout",  (long*) &delayed_insert_timeout, 
  503.       DELAYED_WAIT_TIMEOUT, 1, ~0L, 0, 1 },
  504.   { "delayed_insert_limit",    (long*) &delayed_insert_limit, 
  505.       DELAYED_LIMIT, 1, ~0L, 0, 1 },
  506.   { "delayed_queue_size",      (long*) &delayed_queue_size,
  507.       DELAYED_QUEUE_SIZE, 1, ~0L, 0, 1 },
  508.   { "flush_time",              (long*) &flush_time,
  509.       FLUSH_TIME, 0, ~0L, 0, 1 },
  510. #ifdef HAVE_INNOBASE_DB
  511.   {"innobase_mirrored_log_groups",
  512.    (long*) &innobase_mirrored_log_groups, 1, 1, 10, 0, 1},
  513.   {"innobase_log_files_in_group",
  514.      (long*) &innobase_log_files_in_group, 2, 2, 100, 0, 1},
  515.   {"innobase_log_file_size",
  516.      (long*) &innobase_log_file_size, 5*1024*1024L, 1*1024*1024L,
  517.      ~0L, 0, 1024*1024L},
  518.   {"innobase_log_buffer_size",
  519.      (long*) &innobase_log_buffer_size, 1024*1024L, 256*1024L,
  520.      ~0L, 0, 1024},
  521.   {"innobase_buffer_pool_size",
  522.      (long*) &innobase_buffer_pool_size, 8*1024*1024L, 1024*1024L,
  523.      ~0L, 0, 1024*1024L},
  524.   {"innobase_additional_mem_pool_size",
  525.    (long*) &innobase_additional_mem_pool_size, 1*1024*1024L, 512*1024L,
  526.      ~0L, 0, 1024},
  527.   {"innobase_file_io_threads",
  528.      (long*) &innobase_file_io_threads, 9, 4, 64, 0, 1},
  529.   {"innobase_lock_wait_timeout",
  530.      (long*) &innobase_lock_wait_timeout, 1024 * 1024 * 1024, 1,
  531. 1024 * 1024 * 1024, 0, 1},
  532. #endif
  533.   { "interactive_timeout",     (long*) &net_interactive_timeout,
  534.       NET_WAIT_TIMEOUT, 1, 31*24*60*60, 0, 1 },
  535.   { "join_buffer_size",        (long*) &join_buff_size,
  536.       128*1024L, IO_SIZE*2+MALLOC_OVERHEAD, ~0L, MALLOC_OVERHEAD, IO_SIZE },
  537.   { "key_buffer_size",         (long*) &keybuff_size,
  538.       KEY_CACHE_SIZE, MALLOC_OVERHEAD, (long) ~0, MALLOC_OVERHEAD, IO_SIZE },
  539.   { "long_query_time",         (long*) &long_query_time,
  540.       10, 1, ~0L, 0, 1 },
  541.   { "lower_case_table_names",  (long*) &lower_case_table_names,
  542.       IF_WIN(1,0), 0, 1, 0, 1 },
  543.   { "max_allowed_packet",      (long*) &max_allowed_packet,
  544.       1024*1024L, 80, 64*1024*1024L, MALLOC_OVERHEAD, 1024 },
  545.   { "max_binlog_cache_size",   (long*) &max_binlog_cache_size,
  546.       ~0L, IO_SIZE, ~0L, 0, IO_SIZE },
  547.   { "max_binlog_size",         (long*) &max_binlog_size,
  548.       1024*1024L*1024L, 1024, 1024*1024L*1024L, 0, 1 },
  549.   { "max_connections",         (long*) &max_connections,
  550.       100, 1, 16384, 0, 1 },
  551.   { "max_connect_errors",      (long*) &max_connect_errors,
  552.       MAX_CONNECT_ERRORS, 1, ~0L, 0, 1 },
  553.   { "max_delayed_threads",     (long*) &max_insert_delayed_threads,
  554.       20, 1, 16384, 0, 1 },
  555.   { "max_heap_table_size",     (long*) &max_heap_table_size,
  556.       16*1024*1024L, 16384, ~0L, MALLOC_OVERHEAD, 1024 },
  557.   { "max_join_size",           (long*) &max_join_size,
  558.       ~0L, 1, ~0L, 0, 1 },
  559.   { "max_sort_length",         (long*) &max_item_sort_length,
  560.       1024, 4, 8192*1024L, 0, 1 },
  561.   { "max_tmp_tables",          (long*) &max_tmp_tables,
  562.       32, 1, ~0L, 0, 1 },
  563.   { "max_user_connections",       (long*) &max_user_connections,
  564.       0, 1, ~0L, 0, 1 },
  565.   { "max_write_lock_count",    (long*) &max_write_lock_count,
  566.       ~0L, 1, ~0L, 0, 1 },
  567.   { "myisam_sort_buffer_size", (long*) &myisam_sort_buffer_size,
  568.       8192*1024, 4, ~0L, 0, 1 },
  569.   { "net_buffer_length",       (long*) &net_buffer_length,
  570.       16384, 1024, 1024*1024L, MALLOC_OVERHEAD, 1024 },
  571.   { "net_retry_count",         (long*) &mysqld_net_retry_count,
  572.       MYSQLD_NET_RETRY_COUNT, 1, ~0L, 0, 1 },
  573.   { "net_read_timeout",        (long*) &net_read_timeout, 
  574.       NET_READ_TIMEOUT, 1, 65535, 0, 1 },
  575.   { "net_write_timeout",       (long*) &net_write_timeout,
  576.       NET_WRITE_TIMEOUT, 1, 65535, 0, 1 },
  577.   { "open_files_limit",        (long*) &open_files_limit,
  578.       0, 0, 65535, 0, 1},
  579.   { "query_buffer_size",       (long*) &query_buff_size,
  580.       0, MALLOC_OVERHEAD, (long) ~0, MALLOC_OVERHEAD, IO_SIZE },
  581.   { "record_buffer",           (long*) &my_default_record_cache_size,
  582.       128*1024L, IO_SIZE*2+MALLOC_OVERHEAD, ~0L, MALLOC_OVERHEAD, IO_SIZE },
  583.   { "slow_launch_time",        (long*) &slow_launch_time, 
  584.       2L, 0L, ~0L, 0, 1 },
  585.   { "sort_buffer",             (long*) &sortbuff_size,
  586.       MAX_SORT_MEMORY, MIN_SORT_MEMORY+MALLOC_OVERHEAD*2, ~0L, MALLOC_OVERHEAD, 1 },
  587.   { "table_cache",             (long*) &table_cache_size,
  588.       64, 1, 16384, 0, 1 },
  589.   { "thread_concurrency",      (long*) &concurrency,
  590.       DEFAULT_CONCURRENCY, 1, 512, 0, 1 },
  591.   { "thread_cache_size",       (long*) &thread_cache_size,
  592.       0, 0, 16384, 0, 1 },
  593.   { "tmp_table_size",          (long*) &tmp_table_size,
  594.       1024*1024L, 1024, ~0L, MALLOC_OVERHEAD, 1 },
  595.   { "thread_stack",            (long*) &thread_stack,
  596.       DEFAULT_THREAD_STACK, 1024*32, ~0L, 0, 1024 },
  597.   { "wait_timeout",            (long*) &net_wait_timeout,
  598.       NET_WAIT_TIMEOUT, 1, ~0L, 0, 1 },
  599.   { NullS, (long*) 0, 0, 0, 0, 0, 0}
  600. };
  603. struct show_var_st init_vars[]= {
  604.   {"ansi_mode",               (char*) &opt_ansi_mode,               SHOW_BOOL},
  605.   {"back_log",                (char*) &back_log,                    SHOW_LONG},
  606.   {"basedir",                 mysql_home,                           SHOW_CHAR},
  607. #ifdef HAVE_BERKELEY_DB
  608.   {"bdb_cache_size",          (char*) &berkeley_cache_size,         SHOW_LONG},
  609.   {"bdb_log_buffer_size",     (char*) &berkeley_log_buffer_size,    SHOW_LONG},
  610.   {"bdb_home",                (char*) &berkeley_home,               SHOW_CHAR_PTR},
  611.   {"bdb_max_lock",            (char*) &berkeley_max_lock,     SHOW_LONG},
  612.   {"bdb_logdir",              (char*) &berkeley_logdir,             SHOW_CHAR_PTR},
  613.   {"bdb_shared_data",       (char*) &berkeley_shared_data,     SHOW_BOOL},
  614.   {"bdb_tmpdir",              (char*) &berkeley_tmpdir,             SHOW_CHAR_PTR},
  615.   {"bdb_version",             (char*) DB_VERSION_STRING,            SHOW_CHAR},
  616. #endif
  617.   {"binlog_cache_size",       (char*) &binlog_cache_size,     SHOW_LONG},
  618.   {"character_set",           default_charset,                      SHOW_CHAR},
  619.   {"character_sets",          (char*) &charsets_list,               SHOW_CHAR_PTR},
  620.   {"concurrent_insert",       (char*) &myisam_concurrent_insert,    SHOW_MY_BOOL},
  621.   {"connect_timeout",         (char*) &connect_timeout,             SHOW_LONG},
  622.   {"datadir",                 mysql_real_data_home,                 SHOW_CHAR},
  623.   {"delay_key_write",         (char*) &myisam_delay_key_write,      SHOW_MY_BOOL},
  624.   {"delayed_insert_limit",    (char*) &delayed_insert_limit,        SHOW_LONG},
  625.   {"delayed_insert_timeout",  (char*) &delayed_insert_timeout,      SHOW_LONG},
  626.   {"delayed_queue_size",      (char*) &delayed_queue_size,          SHOW_LONG},
  627.   {"flush",                   (char*) &myisam_flush,                SHOW_MY_BOOL},
  628.   {"flush_time",              (char*) &flush_time,                  SHOW_LONG},
  629.   {"have_bdb",       (char*) &have_berkeley_db,     SHOW_HAVE},
  630.   {"have_gemini",       (char*) &have_gemini,     SHOW_HAVE},
  631.   {"have_innobase",       (char*) &have_innobase,     SHOW_HAVE},
  632.   {"have_isam",              (char*) &have_isam,     SHOW_HAVE},
  633.   {"have_raid",       (char*) &have_raid,     SHOW_HAVE},
  634.   {"have_ssl",       (char*) &have_ssl,     SHOW_HAVE},
  635.   {"init_file",               (char*) &opt_init_file,               SHOW_CHAR_PTR},
  636. #ifdef HAVE_INNOBASE_DB
  637.   {"innobase_data_file_path", (char*) &innobase_data_file_path,     SHOW_CHAR_PTR},
  638.   {"innobase_data_home_dir",  (char*) &innobase_data_home_dir,     SHOW_CHAR_PTR},
  639.   {"innobase_flush_log_at_trx_commit", (char*) &innobase_flush_log_at_trx_commit, SHOW_MY_BOOL},
  640.   {"innobase_log_arch_dir",   (char*) &innobase_log_arch_dir,      SHOW_CHAR_PTR},
  641.   {"innobase_log_archive",    (char*) &innobase_log_archive,      SHOW_MY_BOOL},
  642.   {"innobase_log_group_home_dir", (char*) &innobase_log_group_home_dir, SHOW_CHAR_PTR},
  643. #endif
  644.   {"interactive_timeout",     (char*) &net_interactive_timeout,     SHOW_LONG},
  645.   {"join_buffer_size",        (char*) &join_buff_size,              SHOW_LONG},
  646.   {"key_buffer_size",         (char*) &keybuff_size,                SHOW_LONG},
  647.   {"language",                language,                             SHOW_CHAR},
  648.   {"large_files_support",     (char*) &opt_large_files,             SHOW_BOOL},
  649. #ifdef HAVE_MLOCKALL
  650.   {"locked_in_memory",       (char*) &locked_in_memory,     SHOW_BOOL},
  651. #endif
  652.   {"log",                     (char*) &opt_log,                     SHOW_BOOL},
  653.   {"log_update",              (char*) &opt_update_log,              SHOW_BOOL},
  654.   {"log_bin",                 (char*) &opt_bin_log,                 SHOW_BOOL},
  655.   {"log_slave_updates",       (char*) &opt_log_slave_updates,       SHOW_BOOL},
  656.   {"long_query_time",         (char*) &long_query_time,             SHOW_LONG},
  657.   {"low_priority_updates",    (char*) &low_priority_updates,        SHOW_BOOL},
  658.   {"lower_case_table_names",  (char*) &lower_case_table_names,      SHOW_LONG},
  659.   {"max_allowed_packet",      (char*) &max_allowed_packet,          SHOW_LONG},
  660.   {"max_binlog_cache_size",   (char*) &max_binlog_cache_size,     SHOW_LONG},
  661.   {"max_binlog_size",         (char*) &max_binlog_size,             SHOW_LONG},
  662.   {"max_connections",         (char*) &max_connections,             SHOW_LONG},
  663.   {"max_connect_errors",      (char*) &max_connect_errors,          SHOW_LONG},
  664.   {"max_delayed_threads",     (char*) &max_insert_delayed_threads,  SHOW_LONG},
  665.   {"max_heap_table_size",     (char*) &max_heap_table_size,         SHOW_LONG},
  666.   {"max_join_size",           (char*) &max_join_size,               SHOW_LONG},
  667.   {"max_sort_length",         (char*) &max_item_sort_length,        SHOW_LONG},
  668.   {"max_user_connections",    (char*) &max_user_connections,        SHOW_LONG},
  669.   {"max_tmp_tables",          (char*) &max_tmp_tables,              SHOW_LONG},
  670.   {"max_write_lock_count",    (char*) &max_write_lock_count,        SHOW_LONG},
  671.   {"myisam_recover_options",  (char*) &myisam_recover_options_str,  SHOW_CHAR_PTR},
  672.   {"myisam_sort_buffer_size", (char*) &myisam_sort_buffer_size,     SHOW_LONG},
  673.   {"net_buffer_length",       (char*) &net_buffer_length,           SHOW_LONG},
  674.   {"net_read_timeout",        (char*) &net_read_timeout,     SHOW_LONG},
  675.   {"net_retry_count",         (char*) &mysqld_net_retry_count,      SHOW_LONG},
  676.   {"net_write_timeout",       (char*) &net_write_timeout,     SHOW_LONG},
  677.   {"open_files_limit",       (char*) &open_files_limit,     SHOW_LONG},
  678.   {"pid_file",                (char*) pidfile_name,                 SHOW_CHAR},
  679.   {"port",                    (char*) &mysql_port,                  SHOW_INT},
  680.   {"protocol_version",        (char*) &protocol_version,            SHOW_INT},
  681.   {"record_buffer",           (char*) &my_default_record_cache_size,SHOW_LONG},
  682.   {"query_buffer_size",       (char*) &query_buff_size,     SHOW_LONG},
  683.   {"safe_show_database",      (char*) &opt_safe_show_db,            SHOW_BOOL},
  684.   {"server_id",               (char*) &server_id,     SHOW_LONG},
  685.   {"skip_locking",            (char*) &my_disable_locking,          SHOW_MY_BOOL},
  686.   {"skip_networking",         (char*) &opt_disable_networking,      SHOW_BOOL},
  687.   {"skip_show_database",      (char*) &opt_skip_show_db,            SHOW_BOOL},
  688.   {"slow_launch_time",        (char*) &slow_launch_time,            SHOW_LONG},
  689.   {"socket",                  (char*) &mysql_unix_port,             SHOW_CHAR_PTR},
  690.   {"sort_buffer",             (char*) &sortbuff_size,               SHOW_LONG},
  691.   {"table_cache",             (char*) &table_cache_size,            SHOW_LONG},
  692.   {"table_type",              (char*) &default_table_type_name,     SHOW_CHAR_PTR},
  693.   {"thread_cache_size",       (char*) &thread_cache_size,           SHOW_LONG},
  694. #ifdef HAVE_THR_SETCONCURRENCY
  695.   {"thread_concurrency",      (char*) &concurrency,                 SHOW_LONG},
  696. #endif
  697.   {"thread_stack",            (char*) &thread_stack,                SHOW_LONG},
  698. #ifdef HAVE_TZNAME
  699.   {"timezone",                time_zone,                            SHOW_CHAR},
  700. #endif
  701.   {"tmp_table_size",          (char*) &tmp_table_size,              SHOW_LONG},
  702.   {"tmpdir",                  (char*) &mysql_tmpdir,                SHOW_CHAR_PTR},
  703.   {"version",                 server_version,                       SHOW_CHAR},
  704.   {"wait_timeout",            (char*) &net_wait_timeout,            SHOW_LONG},
  705.   {NullS, NullS, SHOW_LONG}
  706. };
  708. struct show_var_st status_vars[]= {
  709.   {"Aborted_clients",          (char*) &aborted_threads,        SHOW_LONG},
  710.   {"Aborted_connects",         (char*) &aborted_connects,       SHOW_LONG},
  711.   {"Bytes_received",           (char*) &bytes_received,         SHOW_LONG},
  712.   {"Bytes_sent",               (char*) &bytes_sent,             SHOW_LONG},
  713.   {"Connections",              (char*) &thread_id,              SHOW_LONG_CONST},
  714.   {"Created_tmp_disk_tables",  (char*) &created_tmp_disk_tables,SHOW_LONG},
  715.   {"Created_tmp_tables",       (char*) &created_tmp_tables,     SHOW_LONG},
  716.   {"Created_tmp_files",        (char*) &my_tmp_file_created, SHOW_LONG},
  717.   {"Delayed_insert_threads",   (char*) &delayed_insert_threads, SHOW_LONG},
  718.   {"Delayed_writes",           (char*) &delayed_insert_writes,  SHOW_LONG},
  719.   {"Delayed_errors",           (char*) &delayed_insert_errors,  SHOW_LONG},
  720.   {"Flush_commands",           (char*) &refresh_version,        SHOW_LONG_CONST},
  721.   {"Handler_delete",           (char*) &ha_delete_count,        SHOW_LONG},
  722.   {"Handler_read_first",       (char*) &ha_read_first_count,    SHOW_LONG},
  723.   {"Handler_read_key",         (char*) &ha_read_key_count,      SHOW_LONG},
  724.   {"Handler_read_next",        (char*) &ha_read_next_count,     SHOW_LONG},
  725.   {"Handler_read_prev",        (char*) &ha_read_prev_count,     SHOW_LONG},
  726.   {"Handler_read_rnd",         (char*) &ha_read_rnd_count,      SHOW_LONG},
  727.   {"Handler_read_rnd_next",    (char*) &ha_read_rnd_next_count, SHOW_LONG},
  728.   {"Handler_update",           (char*) &ha_update_count,        SHOW_LONG},
  729.   {"Handler_write",            (char*) &ha_write_count,         SHOW_LONG},
  730.   {"Key_blocks_used",          (char*) &_my_blocks_used,        SHOW_LONG_CONST},
  731.   {"Key_read_requests",        (char*) &_my_cache_r_requests,   SHOW_LONG},
  732.   {"Key_reads",                (char*) &_my_cache_read,         SHOW_LONG},
  733.   {"Key_write_requests",       (char*) &_my_cache_w_requests,   SHOW_LONG},
  734.   {"Key_writes",               (char*) &_my_cache_write,        SHOW_LONG},
  735.   {"Max_used_connections",     (char*) &max_used_connections,   SHOW_LONG},
  736.   {"Not_flushed_key_blocks",   (char*) &_my_blocks_changed,     SHOW_LONG_CONST},
  737.   {"Not_flushed_delayed_rows", (char*) &delayed_rows_in_use,    SHOW_LONG_CONST},
  738.   {"Open_tables",              (char*) 0,                       SHOW_OPENTABLES},
  739.   {"Open_files",               (char*) &my_file_opened,         SHOW_INT_CONST},
  740.   {"Open_streams",             (char*) &my_stream_opened,       SHOW_INT_CONST},
  741.   {"Opened_tables",            (char*) &opened_tables,          SHOW_LONG},
  742.   {"Questions",                (char*) 0,                       SHOW_QUESTION},
  743.   {"Select_full_join",         (char*) &select_full_join_count, SHOW_LONG},
  744.   {"Select_full_range_join",   (char*) &select_full_range_join_count, SHOW_LONG},
  745.   {"Select_range",             (char*) &select_range_count,  SHOW_LONG},
  746.   {"Select_range_check",       (char*) &select_range_check_count, SHOW_LONG},
  747.   {"Select_scan",        (char*) &select_scan_count, SHOW_LONG},
  748.   {"Slave_running",            (char*) &slave_running,          SHOW_BOOL},
  749.   {"Slave_open_temp_tables",   (char*) &slave_open_temp_tables, SHOW_LONG},
  750.   {"Slow_launch_threads",      (char*) &slow_launch_threads,    SHOW_LONG},
  751.   {"Slow_queries",             (char*) &long_query_count,       SHOW_LONG},
  752.   {"Sort_merge_passes",        (char*) &filesort_merge_passes,  SHOW_LONG},
  753.   {"Sort_range",        (char*) &filesort_range_count,   SHOW_LONG},
  754.   {"Sort_rows",        (char*) &filesort_rows,         SHOW_LONG},
  755.   {"Sort_scan",        (char*) &filesort_scan_count,    SHOW_LONG},
  756.   {"Table_locks_immediate",    (char*) &locks_immediate,        SHOW_LONG},
  757.   {"Table_locks_waited",       (char*) &locks_waited,           SHOW_LONG},
  758.   {"Threads_cached",           (char*) &cached_thread_count,    SHOW_LONG_CONST},
  759.   {"Threads_created",        (char*) &thread_created, SHOW_LONG_CONST},
  760.   {"Threads_connected",        (char*) &thread_count,           SHOW_INT_CONST},
  761.   {"Threads_running",          (char*) &thread_running,         SHOW_INT_CONST},
  762.   {"Uptime",                   (char*) 0,                       SHOW_STARTTIME},
  763.   {NullS, NullS, SHOW_LONG}
  764. };
  766. static void print_version(void)
  767. {
  768.   printf("%s  Ver %s for %s on %sn",my_progname,
  769.  server_version,SYSTEM_TYPE,MACHINE_TYPE);
  770. }
  772. static void use_help(void)
  773. {
  774.   print_version();
  775.   printf("Use '--help' or '--no-defaults --help' for a list of available optionsn");
  776. }  
  778. static void usage(void)
  779. {
  780.   print_version();
  781.   puts("Copyright (C) 2000 MySQL AB & MySQL Finland AB, by Monty and others");
  782.   puts("This software comes with ABSOLUTELY NO WARRANTY. This is free software,");
  783.   puts("and you are welcome to modify and redistribute it under the GPL licensen");
  784.   puts("Starts the MySQL servern");
  786.   printf("Usage: %s [OPTIONS]n", my_progname);
  787.   puts("n
  788.   --ansi Use ANSI SQL syntax instead of MySQL syntaxn
  789.   -b, --basedir=path Path to installation directory. All paths aren
  790. usually resolved relative to thisn
  791.   --big-tables Allow big result sets by saving all temporary setsn
  792. on file (Solves most 'table full' errors)n
  793.   --bind-address=IP Ip address to bind ton
  794.   --bootstrap Used by mysql installation scriptsn
  795.   --character-sets-dir=...n
  796.                         Directory where character sets aren
  797.   --chroot=path Chroot mysqld daemon during startupn
  798.   --core-file Write core on errorsn
  799.   -h, --datadir=path Path to the database root");
  800. #ifndef DBUG_OFF
  801.   printf("
  802.   -#, --debug[=...]     Debug log. Default is '%s'n",default_dbug_option);
  803. #endif
  804.   puts("
  805.   --default-character-set=charsetn
  806. Set the default character setn
  807.   --default-table-type=typen
  808. Set the default table type for tablesn
  809.   --delay-key-write-for-all-tablesn
  810. Don't flush key buffers between writes for any MyISAMn
  811. tablen
  812.   --enable-locking Enable system lockingn
  813.   -T, --exit-info Used for debugging;  Use at your own risk!n
  814.   --flush Flush tables to disk between SQL commandsn
  815.   -?, --help Display this help and exitn
  816.   --init-file=file Read SQL commands from this file at startupn
  817.   -L, --language=... Client error messages in given language. May ben
  818. given as a full pathn
  819.   -l, --log[=file] Log connections and queries to filen
  820.   --log-bin[=file]      Log queries in new binary format (for replication)n
  821.   --log-bin-index=file  File that holds the names for last binary log filesn
  822.   --log-update[=file] Log updates to file.# where # is a unique numbern
  823. if not given.n
  824.   --log-isam[=file] Log all MyISAM changes to filen
  825.   --log-long-format Log some extra information to update logn
  826.   --low-priority-updates INSERT/DELETE/UPDATE has lower priority than selectsn
  827.   --log-slow-queries=[file]n
  828. Log slow queries to this log file.  Defaults loggingn
  829.                         to hostname-slow.logn
  830.   --pid-file=path Pid file used by safe_mysqldn
  831.   --myisam-recover[=option[,option...]] where options is one of DEAULT,n
  832. BACKUP or FORCE.n
  833.   --memlock Lock mysqld in memoryn
  834.   -n, --new Use very new possible 'unsafe' functionsn
  835.   -o, --old-protocol Use the old (3.20) protocoln
  836.   -P, --port=... Port number to use for connectionn");
  837. #ifdef ONE_THREAD
  838.   puts("
  839.   --one-thread Only use one thread (for debugging under Linux)n");
  840. #endif
  841.   puts("
  842.   -O, --set-variable var=optionn
  843. Give a variable an value. --help lists variablesn
  844.   -Sg, --skip-grant-tablesn
  845. Start without grant tables. This gives all usersn
  846. FULL ACCESS to all tables!n
  847.   --safe-mode Skip some optimize stages (for testing)n
  848.   --skip-concurrent-insertn
  849.         Don't use concurrent insert with MyISAMn
  850.   --skip-delay-key-writen
  851. Ignore the delay_key_write option for all tablesn
  852.   --skip-locking Don't use system locking. To use isamchk one hasn
  853. to shut down the server.n
  854.   --skip-name-resolve Don't resolve hostnames.n
  855. All hostnames are IP's or 'localhost'n
  856.   --skip-networking Don't allow connection with TCP/IP.n
  857.   --skip-new Don't use new, possible wrong routines.n
  858.   --skip-host-cache Don't cache host namesn");
  859.   /* We have to break the string here because of VC++ limits */
  860.   puts("
  861.   --skip-show-database  Don't allow 'SHOW DATABASE' commandsn
  862.   --skip-thread-priorityn
  863. Don't give threads different priorities.n
  864.   --socket=... Socket file to use for connectionn
  865.   -t, --tmpdir=path Path for temporary filesn
  866.   --temp-pool           Use a pool of temporary filesn
  867.   -u, --user=user_name Run mysqld daemon as usern
  868.   -V, --version output version information and exit");
  869. #ifdef __WIN__
  870.   puts("NT and Win32 specific options:n
  871.   --console Don't remove the console windown
  872.   --install Install mysqld as a service (NT)n
  873.   --remove Remove mysqld from the service list (NT)n
  874.   --standalone Dummy option to start as a standalone program (NT)n
  875. ");
  876. #endif
  877. #ifdef HAVE_BERKELEY_DB
  878.   puts("
  879.   --bdb-home=  directory  Berkeley home direcoryn
  880.   --bdb-lock-detect=#   Berkeley lock detectn
  881.                           (DEFAULT, OLDEST, RANDOM or YOUNGEST, # sec)n
  882.   --bdb-logdir=directory  Berkeley DB log file directoryn
  883.   --bdb-no-sync   Don't synchronously flush logsn
  884.   --bdb-no-recover   Don't try to recover Berkeley DB tables on startn
  885.   --bdb-shared-data   Start Berkeley DB in multi-process moden
  886.   --bdb-tmpdir=directory  Berkeley DB tempfile namen
  887.   --skip-bdb   Don't use berkeley db (will save memory)n
  888. ");
  889. #endif /* HAVE_BERKELEY_DB */
  890. #ifdef HAVE_INNOBASE_DB
  891.   puts("
  892.   --innobase_data_home_dir=dir   The common part for innobase table spacesn
  893.   --innobase_data_file_path=dir  Path to individual files and their sizesn
  894.   --innobase_flush_log_at_trx_commit[=#]
  895.  Set to 0 if you don't want to flush logsn
  896.   --innobase_log_arch_dir=dir  Where full logs should be archivedn
  897.   --innobase_log_archive[=#]  Set to 1 if you want to have logs archivedn
  898.   --innobase_log_group_home_dir=dir  Path to Innobase log files.
  899.   --skip-innobase          Don't use innobase (will save memory)n
  900. ");
  901. #endif /* HAVE_INNOBASE_DB */
  902.   print_defaults("my",load_default_groups);
  903.   puts("");
  905. #include "sslopt-usage.h"
  907.   fix_paths();
  908.   set_ports();
  909.   printf("
  910. To see what values a running MySQL server is using, typen
  911. 'mysqladmin variables' instead of 'mysqld --help'.n
  912. The default values (after parsing the command line arguments) are:nn");
  914.   printf("basedir:     %sn",mysql_home);
  915.   printf("datadir:     %sn",mysql_real_data_home);
  916.   printf("tmpdir:      %sn",mysql_tmpdir);
  917.   printf("language:    %sn",language);
  918. #ifndef __WIN__
  919.   printf("pid file:    %sn",pidfile_name);
  920. #endif
  921.   if (opt_logname)
  922.     printf("logfile:     %sn",opt_logname);
  923.   if (opt_update_logname)
  924.     printf("update log:  %sn",opt_update_logname);
  925.   if (opt_bin_log)
  926.   {
  927.     printf("binary log:  %sn",opt_bin_logname ? opt_bin_logname : "");
  928.     printf("binary log index:  %sn",
  929.    opt_binlog_index_name ? opt_binlog_index_name : "");
  930.   }
  931.   if (opt_slow_logname)
  932.     printf("update log:  %sn",opt_slow_logname);
  933.   printf("TCP port:    %dn",mysql_port);
  934. #if defined(HAVE_SYS_UN_H)
  935.   printf("Unix socket: %sn",mysql_unix_port);
  936. #endif
  937.   if (my_disable_locking)
  938.     puts("nsystem locking is not in use");
  939.   if (opt_noacl)
  940.     puts("nGrant tables are not used. All users have full access rights");
  941.   printf("nPossible variables for option --set-variable (-O) are:n");
  942.   for (uint i=0 ; changeable_vars[i].name ; i++)
  943.     printf("%-20s  current value: %lun",
  944.    changeable_vars[i].name,
  945.    (ulong) *changeable_vars[i].varptr);
  946. }
  949. static void set_options(void)
  950. {
  951.   set_all_changeable_vars( changeable_vars );
  952. #if !defined( my_pthread_setprio ) && !defined( HAVE_PTHREAD_SETSCHEDPARAM )
  953.   opt_specialflag |= SPECIAL_NO_PRIOR;
  954. #endif
  956.   (void) strmov( default_charset, MYSQL_CHARSET);
  957.   (void) strmov( language, LANGUAGE);
  958.   (void) strmov( mysql_real_data_home, get_relative_path(DATADIR));
  959. #ifdef __WIN__
  960.   /* Allow Win32 users to move MySQL anywhere */
  961.   {
  962.     char prg_dev[LIBLEN];
  963.     my_path(prg_dev,my_progname,"mysql/bin");
  964.     strcat(prg_dev,"/../"); // Remove 'bin' to get base dir
  965.     cleanup_dirname(mysql_home,prg_dev);
  966.   }
  967. #else
  968.   const char *tmpenv;
  969.   if ( !(tmpenv = getenv("MY_BASEDIR_VERSION")))
  970.     tmpenv = DEFAULT_MYSQL_HOME;
  971.   (void) strmov( mysql_home, tmpenv );
  972. #endif
  974. #if defined( HAVE_mit_thread ) || defined( __WIN__ ) || defined( HAVE_LINUXTHREADS )
  975.   my_disable_locking = 1;
  976. #endif
  977.   my_bind_addr = htonl( INADDR_ANY );
  978. }
  980. /* Initiates DEBUG - but no debugging here ! */
  982. static void get_options(int argc,char **argv)
  983. {
  984.   int c,option_index=0;
  986.   myisam_delay_key_write=1; // Allow use of this
  987.   while ((c=getopt_long(argc,argv,"ab:C:h:#::T::?l::L:O:P:sS::t:u:noVvI?",
  988. long_options, &option_index)) != EOF)
  989.   {
  990.     switch(c) {
  991. #ifndef DBUG_OFF
  992.     case '#':
  993.       DBUG_PUSH(optarg ? optarg : default_dbug_option);
  994.       opt_endinfo=1; /* unireg: memory allocation */
  995.       break;
  996. #endif
  997.     case 'a':
  998.       opt_ansi_mode=1;
  999.       thd_startup_options|=OPTION_ANSI_MODE;
  1000.       break;
  1001.     case 'b':
  1002.       strmov(mysql_home,optarg);
  1003.       break;
  1004.     case 'l':
  1005.       opt_log=1;
  1006.       opt_logname=optarg; // Use hostname.log if null
  1007.       break;
  1008.     case 'h':
  1009.       strmov(mysql_real_data_home,optarg);
  1010.       break;
  1011.     case 'L':
  1012.       strmov(language,optarg);
  1013.       break;
  1014.     case 'n':
  1015.       opt_specialflag|= SPECIAL_NEW_FUNC;
  1016.       break;
  1017.     case 'o':
  1018.       protocol_version=PROTOCOL_VERSION-1;
  1019.       break;
  1020.     case 'O':
  1021.       if (set_changeable_var(optarg, changeable_vars))
  1022.       {
  1023. use_help();
  1024. exit(1);
  1025.       }
  1026.       break;
  1027.     case 'P':
  1028.       mysql_port= (unsigned int) atoi(optarg);
  1029.       break;
  1030. #if !defined(DBUG_OFF) && defined(SAFEMALLOC)      
  1031.     case OPT_SAFEMALLOC_MEM_LIMIT:
  1032.       safemalloc_mem_limit = atoi(optarg);
  1033.       break;
  1034. #endif      
  1035.     case OPT_SOCKET:
  1036.       mysql_unix_port= optarg;
  1037.       break;
  1038.     case 'r':
  1039.       mysqld_chroot=optarg;
  1040.       break;
  1041. #ifdef USE_SYMDIR
  1042.     case 's':
  1043.       my_use_symdir=1; /* Use internal symbolic links */
  1044.       break;
  1045. #endif
  1046.     case 't':
  1047.       mysql_tmpdir=optarg;
  1048.       break;
  1049.     case OPT_TEMP_POOL:
  1050.       use_temp_pool=1;
  1051.       break;
  1052.     case 'u':
  1053.       mysqld_user=optarg;
  1054.       break;
  1055.     case 'v':
  1056.     case 'V':
  1057.       print_version();
  1058.       exit(0);
  1059.     case 'I':
  1060.     case '?':
  1061.       usage();
  1062.       exit(0);
  1063.     case 'T':
  1064.       test_flags= optarg ? (uint) atoi(optarg) : 0;
  1065.       opt_endinfo=1;
  1066.       break;
  1067.     case 'S':
  1068.       if (!optarg)
  1069. opt_specialflag|= SPECIAL_NO_NEW_FUNC | SPECIAL_SAFE_MODE;
  1070.       else if (!strcmp(optarg,"l"))
  1071. my_disable_locking=1;
  1072.       else if (!strcmp(optarg,"g"))
  1073. opt_noacl=1;
  1074.       else
  1075.       {
  1076. fprintf(stderr,"%s: Unrecognized option: %sn",my_progname,optarg);
  1077. use_help();
  1078. exit(1);
  1079.       }
  1080.       break;
  1081.     case (int) OPT_BIG_TABLES:
  1082.       thd_startup_options|=OPTION_BIG_TABLES;
  1083.       break;
  1084.     case (int) OPT_ISAM_LOG:
  1085.       opt_myisam_log=1;
  1086.       if (optarg)
  1087. myisam_log_filename=optarg;
  1088.       break;
  1089.     case (int) OPT_UPDATE_LOG:
  1090.       opt_update_log=1;
  1091.       opt_update_logname=optarg; // Use hostname.# if null
  1092.       break;
  1093.     case (int) OPT_BIN_LOG_INDEX:
  1094.       opt_binlog_index_name = optarg;
  1095.       break;
  1096.     case (int) OPT_BIN_LOG:
  1097.       opt_bin_log=1;
  1098.       x_free(opt_bin_logname);
  1099.       if (optarg && optarg[0])
  1100. opt_bin_logname=my_strdup(optarg,MYF(0));
  1101.       break;
  1102.       // needs to be handled (as no-op) in non-debugging mode for test suite
  1103.     case (int)OPT_DISCONNECT_SLAVE_EVENT_COUNT:
  1104. #ifndef DBUG_OFF      
  1105.       disconnect_slave_event_count = atoi(optarg);
  1106. #endif      
  1107.       break;
  1108.     case (int)OPT_ABORT_SLAVE_EVENT_COUNT:
  1109. #ifndef DBUG_OFF      
  1110.       abort_slave_event_count = atoi(optarg);
  1111. #endif      
  1112.       break;
  1113.     case (int) OPT_LOG_SLAVE_UPDATES:
  1114.       opt_log_slave_updates = 1;
  1115.       break;
  1117.     case (int)OPT_REPLICATE_IGNORE_DB:
  1118.       {
  1119. i_string *db = new i_string(optarg);
  1120. replicate_ignore_db.push_back(db);
  1121.         break;
  1122.       }
  1123.     case (int)OPT_REPLICATE_DO_DB:
  1124.       {
  1125. i_string *db = new i_string(optarg);
  1126. replicate_do_db.push_back(db);
  1127.         break;
  1128.       }
  1129.     case (int)OPT_REPLICATE_REWRITE_DB:
  1130.       {
  1131. char* key = optarg,*p, *val;
  1132. p = strstr(optarg, "->");
  1133. if (!p)
  1134.   {
  1135.     fprintf(stderr,
  1136.     "Bad syntax in replicate-rewrite-db - missing '->'!n");
  1137.     exit(1);
  1138.   }
  1139. val = p--;
  1140. while(isspace(*p) && p > optarg) *p-- = 0;
  1141. if(p == optarg)
  1142.   {
  1143.     fprintf(stderr,
  1144.     "Bad syntax in replicate-rewrite-db - empty FROM db!n");
  1145.     exit(1);
  1146.   }
  1147. *val = 0;
  1148. val += 2;
  1149. while(*val && isspace(*val)) *val++;
  1150. if (!*val)
  1151.   {
  1152.     fprintf(stderr,
  1153.     "Bad syntax in replicate-rewrite-db - empty TO db!n");
  1154.     exit(1);
  1155.   }
  1157. i_string_pair* db_pair = new i_string_pair(key, val);
  1158. replicate_rewrite_db.push_back(db_pair);
  1159. break;
  1160.       }
  1162.     case (int)OPT_BINLOG_IGNORE_DB:
  1163.       {
  1164. i_string *db = new i_string(optarg);
  1165. binlog_ignore_db.push_back(db);
  1166.         break;
  1167.       }
  1168.     case (int)OPT_BINLOG_DO_DB:
  1169.       {
  1170. i_string *db = new i_string(optarg);
  1171. binlog_do_db.push_back(db);
  1172.         break;
  1173.       }
  1174.     case (int)OPT_REPLICATE_DO_TABLE:
  1175.       {
  1176. if (!do_table_inited)
  1177.   init_table_rule_hash(&replicate_do_table, &do_table_inited);
  1178. if(add_table_rule(&replicate_do_table, optarg))
  1179.   {
  1180.     fprintf(stderr, "Could not add do table rule '%s'!n", optarg);
  1181.     exit(1);
  1182.   }
  1183. table_rules_on = 1;
  1184. break;
  1185.       }
  1186.     case (int)OPT_REPLICATE_WILD_DO_TABLE:
  1187.       {
  1188. if (!wild_do_table_inited)
  1189.   init_table_rule_array(&replicate_wild_do_table,
  1190. &wild_do_table_inited);
  1191. if(add_wild_table_rule(&replicate_wild_do_table, optarg))
  1192.   {
  1193.     fprintf(stderr, "Could not add do table rule '%s'!n", optarg);
  1194.     exit(1);
  1195.   }
  1196. table_rules_on = 1;
  1197. break;
  1198.       }
  1199.     case (int)OPT_REPLICATE_WILD_IGNORE_TABLE:
  1200.       {
  1201. if (!wild_ignore_table_inited)
  1202.   init_table_rule_array(&replicate_wild_ignore_table,
  1203. &wild_ignore_table_inited);
  1204. if(add_wild_table_rule(&replicate_wild_ignore_table, optarg))
  1205.   {
  1206.     fprintf(stderr, "Could not add ignore table rule '%s'!n", optarg);
  1207.     exit(1);
  1208.   }
  1209. table_rules_on = 1;
  1210. break;
  1211.       }
  1212.     case (int)OPT_REPLICATE_IGNORE_TABLE:
  1213.       {
  1214. if (!ignore_table_inited)
  1215.   init_table_rule_hash(&replicate_ignore_table, &ignore_table_inited);
  1216. if(add_table_rule(&replicate_ignore_table, optarg))
  1217.   {
  1218.     fprintf(stderr, "Could not add ignore table rule '%s'!n", optarg);
  1219.     exit(1);
  1220.   }
  1221. table_rules_on = 1;
  1222. break;
  1223.       }
  1224.     case (int) OPT_SQL_BIN_UPDATE_SAME:
  1225.       opt_sql_bin_update  = 1;
  1226.       break;
  1227.     case (int) OPT_SLOW_QUERY_LOG:
  1228.       opt_slow_log=1;
  1229.       opt_slow_logname=optarg;
  1230.       break;
  1231.     case (int)OPT_SKIP_SLAVE_START:
  1232.       opt_skip_slave_start = 1;
  1233.       break;
  1234.     case (int) OPT_SKIP_NEW:
  1235.       opt_specialflag|= SPECIAL_NO_NEW_FUNC;
  1236.       default_table_type=DB_TYPE_ISAM;
  1237.       myisam_delay_key_write=0;
  1238.       myisam_concurrent_insert=0;
  1239.       myisam_recover_options= HA_RECOVER_NONE;
  1240.       ha_open_options&= ~HA_OPEN_ABORT_IF_CRASHED;
  1241.       break;
  1242.     case (int) OPT_SAFE:
  1243.       opt_specialflag|= SPECIAL_SAFE_MODE;
  1244.       myisam_delay_key_write=0;
  1245.       myisam_recover_options= HA_RECOVER_NONE; // To be changed
  1246.       ha_open_options&= ~HA_OPEN_ABORT_IF_CRASHED;
  1247.       break;
  1248.     case (int) OPT_SKIP_CONCURRENT_INSERT:
  1249.       myisam_concurrent_insert=0;
  1250.       break;
  1251.     case (int) OPT_SKIP_PRIOR:
  1252.       opt_specialflag|= SPECIAL_NO_PRIOR;
  1253.       break;
  1254.     case (int) OPT_SKIP_GRANT:
  1255.       opt_noacl=1;
  1256.       break;
  1257.     case (int) OPT_SKIP_LOCK:
  1258.       my_disable_locking=1;
  1259.       break;
  1260.     case (int) OPT_SKIP_HOST_CACHE:
  1261.       opt_specialflag|= SPECIAL_NO_HOST_CACHE;
  1262.       break;
  1263.     case (int) OPT_ENABLE_LOCK:
  1264.       my_disable_locking=0;
  1265.       break;
  1266.     case (int) OPT_USE_LOCKING:
  1267.       my_disable_locking=0;
  1268.       break;
  1269.     case (int) OPT_SKIP_RESOLVE:
  1270.       opt_specialflag|=SPECIAL_NO_RESOLVE;
  1271.       break;
  1272.     case (int) OPT_LONG_FORMAT:
  1273.       opt_specialflag|=SPECIAL_LONG_LOG_FORMAT;
  1274.       break;
  1275.     case (int) OPT_SKIP_NETWORKING:
  1276.       opt_disable_networking=1;
  1277.       mysql_port=0;
  1278.       break;
  1279.     case (int) OPT_SKIP_SHOW_DB:
  1280.       opt_skip_show_db=1;
  1281.       opt_specialflag|=SPECIAL_SKIP_SHOW_DB;
  1282.       mysql_port=0;
  1283.       break;
  1284.     case (int) OPT_MEMLOCK:
  1285.       locked_in_memory=1;
  1286.       break;
  1287.     case (int) OPT_ONE_THREAD:
  1288.       test_flags |= TEST_NO_THREADS;
  1289.       break;
  1290.     case (int) OPT_WANT_CORE:
  1291.       test_flags |= TEST_CORE_ON_SIGNAL;
  1292.       break;
  1293.     case (int) OPT_BIND_ADDRESS:
  1294.       if (optarg && isdigit(optarg[0]))
  1295.       {
  1296. my_bind_addr = (ulong) inet_addr(optarg);
  1297.       }
  1298.       else
  1299.       {
  1300. struct hostent *ent;
  1301. if (!optarg || !optarg[0])
  1302.   ent=gethostbyname(optarg);
  1303. else
  1304. {
  1305.   char myhostname[255];
  1306.   if (gethostname(myhostname,sizeof(myhostname)) < 0)
  1307.   {
  1308.     sql_perror("Can't start server: cannot get my own hostname!");
  1309.     exit(1);
  1310.   }
  1311.   ent=gethostbyname(myhostname);
  1312. }
  1313. if (!ent)
  1314. {
  1315.   sql_perror("Can't start server: cannot resolve hostname!");
  1316.   exit(1);
  1317. }
  1318. my_bind_addr = (ulong) ((in_addr*)ent->h_addr_list[0])->s_addr;
  1319.       }
  1320.       break;
  1321.     case (int) OPT_PID_FILE:
  1322.       strmov(pidfile_name,optarg);
  1323.       break;
  1324.     case (int) OPT_INIT_FILE:
  1325.       opt_init_file=optarg;
  1326.       break;
  1327. #ifdef __WIN__
  1328.     case (int) OPT_STANDALONE: /* Dummy option for NT */
  1329.       break;
  1330.     case (int) OPT_CONSOLE:
  1331.       opt_console=1;
  1332.       break;
  1333. #endif
  1334.     case (int) OPT_FLUSH:
  1335.       nisam_flush=myisam_flush=1;
  1336.       flush_time=0; // No auto flush
  1337.       break;
  1338.     case OPT_LOW_PRIORITY_UPDATES:
  1339.       thd_startup_options|=OPTION_LOW_PRIORITY_UPDATES;
  1340.       low_priority_updates=1;
  1341.       break;
  1342.     case OPT_BOOTSTRAP:
  1343.       opt_noacl=opt_bootstrap=1;
  1344.       break;
  1345.     case OPT_TABLE_TYPE:
  1346.     {
  1347.       int type;
  1348.       if ((type=find_type(optarg, &ha_table_typelib, 2)) <= 0)
  1349.       {
  1350. fprintf(stderr,"Unknown table type: %sn",optarg);
  1351. exit(1);
  1352.       }
  1353.       default_table_type= (enum db_type) type;
  1354.       break;
  1355.     }
  1356.     case OPT_SERVER_ID:
  1357.       server_id = atoi(optarg);
  1358.       server_id_supplied = 1;
  1359.       break;
  1360.     case OPT_DELAY_KEY_WRITE:
  1361.       ha_open_options|=HA_OPEN_DELAY_KEY_WRITE;
  1362.       myisam_delay_key_write=1;
  1363.       break;
  1364.     case OPT_SKIP_DELAY_KEY_WRITE:
  1365.       myisam_delay_key_write=0;
  1366.       break;
  1367.     case 'C':
  1368.       strmov(default_charset,optarg);
  1369.       break;
  1370.     case OPT_CHARSETS_DIR:
  1371.       strmov(mysql_charsets_dir, optarg);
  1372.       charsets_dir = mysql_charsets_dir;
  1373.       break;
  1374. #include "sslopt-case.h"
  1375. #ifdef HAVE_BERKELEY_DB
  1376.     case OPT_BDB_LOG:
  1377.       berkeley_logdir=optarg;
  1378.       break;
  1379.     case OPT_BDB_HOME:
  1380.       berkeley_home=optarg;
  1381.       break;
  1382.     case OPT_BDB_NOSYNC:
  1383.       berkeley_env_flags|=DB_TXN_NOSYNC;
  1384.       break;
  1385.     case OPT_BDB_NO_RECOVER:
  1386.       berkeley_init_flags&= ~(DB_RECOVER);
  1387.       break;
  1388.     case OPT_BDB_TMP:
  1389.       berkeley_tmpdir=optarg;
  1390.       break;
  1391.     case OPT_BDB_LOCK:
  1392.     {
  1393.       int type;
  1394.       if ((type=find_type(optarg, &berkeley_lock_typelib, 2)) > 0)
  1395. berkeley_lock_type=berkeley_lock_types[type-1];
  1396.       else
  1397.       {
  1398. if (test_if_int(optarg,(uint) strlen(optarg)))
  1399.   berkeley_lock_scan_time=atoi(optarg);
  1400. else
  1401. {
  1402.   fprintf(stderr,"Unknown lock type: %sn",optarg);
  1403.   exit(1);
  1404. }
  1405.       }
  1406.       break;
  1407.     }
  1408.     case OPT_BDB_SHARED:
  1409.       berkeley_init_flags&= ~(DB_PRIVATE);
  1410.       berkeley_shared_data=1;
  1411.       break;
  1412. #endif /* HAVE_BERKELEY_DB */
  1413.     case OPT_BDB_SKIP:
  1414. #ifdef HAVE_BERKELEY_DB
  1415.       berkeley_skip=1;
  1416.       have_berkeley_db=SHOW_OPTION_DISABLED;
  1417. #endif
  1418.       break;
  1419.     case OPT_GEMINI_SKIP:
  1420. #ifdef HAVE_GEMINI_DB
  1421.       gemini_skip=1;
  1422.       have_gemini=SHOW_OPTION_DISABLED;  
  1423. #endif
  1424.       break;
  1425.     case OPT_INNOBASE_SKIP:
  1426. #ifdef HAVE_INNOBASE_DB
  1427.       innobase_skip=1;
  1428.       have_innobase=SHOW_OPTION_DISABLED;
  1429. #endif
  1430.       break;
  1431.     case OPT_INNOBASE_DATA_FILE_PATH:
  1432. #ifdef HAVE_INNOBASE_DB
  1433.       innobase_data_file_path=optarg;
  1434. #endif
  1435.       break;
  1436. #ifdef HAVE_INNOBASE_DB
  1437.     case OPT_INNOBASE_DATA_HOME_DIR:
  1438.       innobase_data_home_dir=optarg;
  1439.       break;
  1440.     case OPT_INNOBASE_LOG_GROUP_HOME_DIR:
  1441.       innobase_log_group_home_dir=optarg;
  1442.       break;
  1443.     case OPT_INNOBASE_LOG_ARCH_DIR:
  1444.       innobase_log_arch_dir=optarg;
  1445.       break;
  1446.     case OPT_INNOBASE_LOG_ARCHIVE:
  1447.       innobase_log_archive= optarg ? test(atoi(optarg)) : 1;
  1448.       break;
  1449.     case OPT_INNOBASE_FLUSH_LOG_AT_TRX_COMMIT:
  1450.       innobase_flush_log_at_trx_commit= optarg ? test(atoi(optarg)) : 1;
  1451.       break;
  1452. #endif /* HAVE_INNOBASE_DB */
  1453.     case OPT_MYISAM_RECOVER:
  1454.     {
  1455.       if (!optarg || !optarg[0])
  1456.       {
  1457. myisam_recover_options=    HA_RECOVER_DEFAULT;
  1458. myisam_recover_options_str= myisam_recover_typelib.type_names[0];
  1459.       }
  1460.       else
  1461.       {
  1462. myisam_recover_options_str=optarg;
  1463. if ((myisam_recover_options=
  1464. find_bit_type(optarg, &myisam_recover_typelib)) == ~(ulong) 0)
  1465. {
  1466.   fprintf(stderr, "Unknown option to myisam-recover: %sn",optarg);
  1467.   exit(1);
  1468. }
  1469.       }
  1470.       ha_open_options|=HA_OPEN_ABORT_IF_CRASHED;
  1471.       break;
  1472.     }
  1473.     case OPT_MASTER_HOST:
  1474.       master_host=optarg;
  1475.       break;
  1476.     case OPT_MASTER_USER:
  1477.       master_user=optarg;
  1478.       break;
  1479.     case OPT_MASTER_PASSWORD:
  1480.       master_password=optarg;
  1481.       break;
  1482.     case OPT_MASTER_INFO_FILE:
  1483.       master_info_file=optarg;
  1484.       break;
  1485.     case OPT_MASTER_PORT:
  1486.       master_port= atoi(optarg);
  1487.       break;
  1488.     case OPT_MASTER_CONNECT_RETRY:
  1489.       master_connect_retry= atoi(optarg);
  1490.       break;
  1491.     case (int) OPT_SAFE_SHOW_DB:
  1492.       opt_safe_show_db=1;
  1493.       break;
  1495.     default:
  1496.       fprintf(stderr,"%s: Unrecognized option: %cn",my_progname,c);
  1497.       use_help();
  1498.       exit(1);
  1499.     }
  1500.   }
  1501.   // Skipp empty arguments (from shell)
  1502.   while (argc != optind && !argv[optind][0])
  1503.     optind++;
  1504.   if (argc != optind)
  1505.   {
  1506.     fprintf(stderr,"%s: Too many parametersn",my_progname);
  1507.     use_help();
  1508.     exit(1);
  1509.   }
  1510.   fix_paths();
  1511.   default_table_type_name=ha_table_typelib.type_names[default_table_type-1];
  1512. }
  1515. #ifdef __WIN__
  1517. #ifndef KEY_SERVICE_PARAMETERS
  1518. #define KEY_SERVICE_PARAMETERS "SYSTEM\CurrentControlSet\Services\MySql\Parameters"
  1519. #endif
  1521. #define COPY_KEY_VALUE(value) if (copy_key_value(hParametersKey,&(value),lpszValue)) return 1
  1522. #define CHECK_KEY_TYPE(type,name) if ( type != dwKeyValueType ) { key_type_error(hParametersKey,name); return 1; }
  1523. #define SET_CHANGEABLE_VARVAL(varname) if (set_varval(hParametersKey,varname,szKeyValueName,dwKeyValueType,lpdwValue)) return 1;
  1525. static void key_type_error(HKEY hParametersKey,const char *szKeyValueName)
  1526. {
  1527.  TCHAR szErrorMsg[512];
  1528.  RegCloseKey( hParametersKey );
  1529.  strxmov(szErrorMsg,TEXT("Value ""),
  1530.  szKeyValueName,
  1531.  TEXT("" of registry key "" KEY_SERVICE_PARAMETERS "" has wrong typen"),NullS);
  1532.  fprintf(stderr, szErrorMsg); /* not unicode compatible */
  1533. }
  1535. static bool copy_key_value(HKEY hParametersKey, char **var, const char *value)
  1536. {
  1537.   if (!(*var=my_strdup(value,MYF(MY_WME))))
  1538.   {
  1539.     RegCloseKey(hParametersKey);
  1540.     fprintf(stderr, "Couldn't allocate memory for registry key valuen");
  1541.     return 1;
  1542.   }
  1543.   return 0;
  1544. }
  1546. static bool set_varval(HKEY hParametersKey,const char *var,
  1547.        const char *szKeyValueName, DWORD dwKeyValueType,
  1548.        LPDWORD lpdwValue)
  1549. {
  1550.   CHECK_KEY_TYPE(dwKeyValueType, szKeyValueName );
  1551.   if (set_changeable_varval(var, *lpdwValue, changeable_vars))
  1552.   {
  1553.     TCHAR szErrorMsg [ 512 ];
  1554.     RegCloseKey( hParametersKey );
  1555.     strxmov(szErrorMsg,
  1556.     TEXT("Value ""),
  1557.     szKeyValueName,
  1558.     TEXT("" of registry key "" KEY_SERVICE_PARAMETERS  "" is invalidn"),NullS);
  1559.     fprintf( stderr, szErrorMsg ); /* not unicode compatible */
  1560.     return 1;
  1561.   }
  1562.   return 0;
  1563. }
  1566. static int get_service_parameters()
  1567. {
  1568.   DWORD dwLastError;
  1569.   HKEY hParametersKey;
  1570.   DWORD dwIndex;
  1571.   TCHAR szKeyValueName [ 256 ];
  1572.   DWORD dwKeyValueName;
  1573.   DWORD dwKeyValueType;
  1574.   BYTE bKeyValueBuffer [ 512 ];
  1575.   DWORD dwKeyValueBuffer;
  1576.   LPDWORD lpdwValue = (LPDWORD) &bKeyValueBuffer[0];
  1577.   LPCTSTR lpszValue = (LPCTSTR) &bKeyValueBuffer[0];
  1579.   /* open parameters of service */
  1580.   dwLastError = (DWORD) RegOpenKeyEx( HKEY_LOCAL_MACHINE,
  1581.       TEXT(KEY_SERVICE_PARAMETERS), 0,
  1582.       KEY_READ, &hParametersKey );
  1583.   if ( dwLastError == ERROR_FILE_NOT_FOUND ) /* no parameters available */
  1584.     return 0;
  1585.   if ( dwLastError != ERROR_SUCCESS )
  1586.   {
  1587.     fprintf(stderr,"Can't open registry key "" KEY_SERVICE_PARAMETERS "" for readingn" );
  1588.     return 1;
  1589.   }
  1591.   /* enumerate all values of key */
  1592.   dwIndex = 0;
  1593.   dwKeyValueName = sizeof( szKeyValueName ) / sizeof( TCHAR );
  1594.   dwKeyValueBuffer = sizeof( bKeyValueBuffer );
  1595.   while ( (dwLastError = (DWORD) RegEnumValue(hParametersKey, dwIndex,
  1596.       szKeyValueName, &dwKeyValueName,
  1597.       NULL, &dwKeyValueType,
  1598.       &bKeyValueBuffer[0],
  1599.       &dwKeyValueBuffer))
  1600.   != ERROR_NO_MORE_ITEMS )
  1601.   {
  1602.     /* check if error occured */
  1603.     if ( dwLastError != ERROR_SUCCESS )
  1604.     {
  1605.       RegCloseKey( hParametersKey );
  1606.       fprintf( stderr, "Can't enumerate values of registry key "" KEY_SERVICE_PARAMETERS ""n" );
  1607.       return 1;
  1608.     }
  1609.     if ( lstrcmp(szKeyValueName, TEXT("BaseDir")) == 0 )
  1610.     {
  1611.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName);
  1612.       strmov( mysql_home, lpszValue ); /* not unicode compatible */
  1613.     }
  1614.     else if ( lstrcmp(szKeyValueName, TEXT("BindAddress")) == 0 )
  1615.     {
  1616.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName);
  1618.       my_bind_addr = (ulong) inet_addr( lpszValue );
  1619.       if ( my_bind_addr == (ulong) INADDR_NONE )
  1620.       {
  1621. struct hostent* ent;
  1623. if ( !(*lpszValue) )
  1624. {
  1625.   char szHostName [ 256 ];
  1626.   if ( gethostname(szHostName, sizeof(szHostName)) == SOCKET_ERROR )
  1627.   {
  1628.     RegCloseKey( hParametersKey );
  1629.     fprintf( stderr, "Can't get my own hostnamen" );
  1630.     return 1;
  1631.   }
  1632.   ent = gethostbyname( szHostName );
  1633. }
  1634. else ent = gethostbyname( lpszValue );
  1635. if ( !ent )
  1636. {
  1637.   RegCloseKey( hParametersKey );
  1638.   fprintf( stderr, "Can't resolve hostname!n" );
  1639.   return 1;
  1640. }
  1641. my_bind_addr = (ulong) ((in_addr*)ent->h_addr_list[0])->s_addr;
  1642.       }
  1643.     }
  1644.     else if ( lstrcmp(szKeyValueName, TEXT("BigTables")) == 0 )
  1645.     {
  1646.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName);
  1647.       if ( *lpdwValue )
  1648. thd_startup_options |= OPTION_BIG_TABLES;
  1649.       else
  1650. thd_startup_options &= ~((ulong)OPTION_BIG_TABLES);
  1651.     }
  1652.     else if ( lstrcmp(szKeyValueName, TEXT("DataDir")) == 0 )
  1653.     {
  1654.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1655.       strmov( mysql_real_data_home, lpszValue ); /* not unicode compatible */
  1656.     }
  1657.     else if ( lstrcmp(szKeyValueName, TEXT("Locking")) == 0 )
  1658.     {
  1659.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1660.       my_disable_locking = !(*lpdwValue);
  1661.     }
  1662.     else if ( lstrcmp(szKeyValueName, TEXT("LogFile")) == 0 )
  1663.     {
  1664.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1665.       opt_log = 1;
  1666.       COPY_KEY_VALUE( opt_logname );
  1667.     }
  1668.     else if ( lstrcmp(szKeyValueName, TEXT("UpdateLogFile")) == 0 )
  1669.     {
  1670.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1671.       opt_update_log = 1;
  1672.       COPY_KEY_VALUE( opt_update_logname );
  1673.     }
  1674.     else if ( lstrcmp(szKeyValueName, TEXT("BinaryLogFile")) == 0 )
  1675.     {
  1676.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1677.       opt_bin_log = 1;
  1678.       COPY_KEY_VALUE( opt_bin_logname );
  1679.     }
  1680.     else if ( lstrcmp(szKeyValueName, TEXT("BinaryLogIndexFile")) == 0 )
  1681.     {
  1682.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1683.       opt_bin_log = 1;
  1684.       COPY_KEY_VALUE( opt_binlog_index_name );
  1685.     }
  1686.     else if ( lstrcmp(szKeyValueName, TEXT("ISAMLogFile")) == 0 )
  1687.     {
  1688.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1689.       COPY_KEY_VALUE( myisam_log_filename );
  1690.       opt_myisam_log=1;
  1691.     }
  1692.     else if ( lstrcmp(szKeyValueName, TEXT("LongLogFormat")) == 0 )
  1693.     {
  1694.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1695.       if ( *lpdwValue )
  1696. opt_specialflag |= SPECIAL_LONG_LOG_FORMAT;
  1697.       else
  1698. opt_specialflag &= ~((ulong)SPECIAL_LONG_LOG_FORMAT);
  1699.     }
  1700.     else if ( lstrcmp(szKeyValueName, TEXT("LowPriorityUpdates")) == 0 )
  1701.     {
  1702.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1703.       if ( *lpdwValue )
  1704.       {
  1705. thd_startup_options |= OPTION_LOW_PRIORITY_UPDATES;
  1706. low_priority_updates = 1;
  1707.       }
  1708.       else
  1709.       {
  1710. thd_startup_options &= ~((ulong)OPTION_LOW_PRIORITY_UPDATES);
  1711. low_priority_updates = 0;
  1712.       }
  1713.     }
  1714.     else if ( lstrcmp(szKeyValueName, TEXT("Port")) == 0 )
  1715.     {
  1716.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1717.       mysql_port = (unsigned int) *lpdwValue;
  1718.     }
  1719.     else if ( lstrcmp(szKeyValueName, TEXT("OldProtocol")) == 0 )
  1720.     {
  1721.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1722.       protocol_version = *lpdwValue ? PROTOCOL_VERSION - 1 : PROTOCOL_VERSION;
  1723.     }
  1724.     else if ( lstrcmp(szKeyValueName, TEXT("HostnameResolving")) == 0 )
  1725.     {
  1726.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1727.       if ( !*lpdwValue )
  1728. opt_specialflag |= SPECIAL_NO_RESOLVE;
  1729.       else
  1730. opt_specialflag &= ~((ulong)SPECIAL_NO_RESOLVE);
  1731.     }
  1732.     else if ( lstrcmp(szKeyValueName, TEXT("Networking")) == 0 )
  1733.     {
  1734.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1735.       opt_disable_networking = !(*lpdwValue);
  1736.     }
  1737.     else if ( lstrcmp(szKeyValueName, TEXT("ShowDatabase")) == 0 )
  1738.     {
  1739.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1740.       opt_skip_show_db = !(*lpdwValue);
  1741.     }
  1742.     else if ( lstrcmp(szKeyValueName, TEXT("HostnameCaching")) == 0 )
  1743.     {
  1744.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1745.       if ( !*lpdwValue )
  1746. opt_specialflag |= SPECIAL_NO_HOST_CACHE;
  1747.       else
  1748. opt_specialflag &= ~((ulong)SPECIAL_NO_HOST_CACHE);
  1749.     }
  1750.     else if ( lstrcmp(szKeyValueName, TEXT("ThreadPriority")) == 0 )
  1751.     {
  1752.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1753.       if ( !(*lpdwValue) )
  1754. opt_specialflag |= SPECIAL_NO_PRIOR;
  1755.       else
  1756. opt_specialflag &= ~((ulong)SPECIAL_NO_PRIOR);
  1757.     }
  1758.     else if ( lstrcmp(szKeyValueName, TEXT("NamedPipe")) == 0 )
  1759.     {
  1760.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1761.       COPY_KEY_VALUE( mysql_unix_port );
  1762.     }
  1763.     else if ( lstrcmp(szKeyValueName, TEXT("TempDir")) == 0 )
  1764.     {
  1765.       CHECK_KEY_TYPE( REG_SZ, szKeyValueName );
  1766.       COPY_KEY_VALUE( mysql_tmpdir );
  1767.     }
  1768.     else if ( lstrcmp(szKeyValueName, TEXT("FlushTables")) == 0 )
  1769.     {
  1770.       CHECK_KEY_TYPE( REG_DWORD, szKeyValueName );
  1771.       nisam_flush = myisam_flush= *lpdwValue ? 1 : 0;
  1772.     }
  1773.     else if ( lstrcmp(szKeyValueName, TEXT("BackLog")) == 0 )
  1774.     {
  1775.       SET_CHANGEABLE_VARVAL( "back_log" );
  1776.     }
  1777.     else if ( lstrcmp(szKeyValueName, TEXT("ConnectTimeout")) == 0 )
  1778.     {
  1779.       SET_CHANGEABLE_VARVAL( "connect_timeout" );
  1780.     }
  1781.     else if ( lstrcmp(szKeyValueName, TEXT("JoinBufferSize")) == 0 )
  1782.     {
  1783.       SET_CHANGEABLE_VARVAL( "join_buffer" );
  1784.     }
  1785.     else if ( lstrcmp(szKeyValueName, TEXT("KeyBufferSize")) == 0 )
  1786.     {
  1787.       SET_CHANGEABLE_VARVAL( "key_buffer" );
  1788.     }
  1789.     else if ( lstrcmp(szKeyValueName, TEXT("LongQueryTime")) == 0 )
  1790.     {
  1791.       SET_CHANGEABLE_VARVAL( "long_query_time" );
  1792.     }
  1793.     else if ( lstrcmp(szKeyValueName, TEXT("MaxAllowedPacket")) == 0 )
  1794.     {
  1795.       SET_CHANGEABLE_VARVAL( "max_allowed_packet" );
  1796.     }
  1797.     else if ( lstrcmp(szKeyValueName, TEXT("MaxConnections")) == 0 )
  1798.     {
  1799.       SET_CHANGEABLE_VARVAL( "max_connections" );
  1800.     }
  1801.     else if ( lstrcmp(szKeyValueName, TEXT("MaxUserConnections")) == 0 )
  1802.     {
  1803.       SET_CHANGEABLE_VARVAL( "max_user_connections" );
  1804.     }
  1805.     else if ( lstrcmp(szKeyValueName, TEXT("MaxConnectErrors")) == 0 )
  1806.     {
  1807.       SET_CHANGEABLE_VARVAL( "max_connect_errors" );
  1808.     }
  1809.     else if ( lstrcmp(szKeyValueName, TEXT("MaxInsertDelayedThreads")) == 0 )
  1810.     {
  1811.       SET_CHANGEABLE_VARVAL( "max_delayed_threads" );
  1812.     }
  1813.     else if ( lstrcmp(szKeyValueName, TEXT("MaxJoinSize")) == 0 )
  1814.     {
  1815.       SET_CHANGEABLE_VARVAL( "max_join_size" );
  1816.     }
  1817.     else if ( lstrcmp(szKeyValueName, TEXT("MaxSortLength")) == 0 )
  1818.     {
  1819.       SET_CHANGEABLE_VARVAL( "max_sort_length" );
  1820.     }
  1821.     else if ( lstrcmp(szKeyValueName, TEXT("NetBufferLength")) == 0 )
  1822.     {
  1823.       SET_CHANGEABLE_VARVAL( "net_buffer_length" );
  1824.     }
  1825.     else if ( lstrcmp(szKeyValueName, TEXT("RecordBufferSize")) == 0 )
  1826.     {
  1827.       SET_CHANGEABLE_VARVAL( "record_buffer" );
  1828.     }
  1829.     else if ( lstrcmp(szKeyValueName, TEXT("SortBufferSize")) == 0 )
  1830.     {
  1831.       SET_CHANGEABLE_VARVAL( "sort_buffer" );
  1832.     }
  1833.     else if ( lstrcmp(szKeyValueName, TEXT("TableCacheSize")) == 0 )
  1834.     {
  1835.       SET_CHANGEABLE_VARVAL( "table_cache" );
  1836.     }
  1837.     else if ( lstrcmp(szKeyValueName, TEXT("TmpTableSize")) == 0 )
  1838.     {
  1839.       SET_CHANGEABLE_VARVAL( "tmp_table_size" );
  1840.     }
  1841.     else if ( lstrcmp(szKeyValueName, TEXT("ThreadStackSize")) == 0 )
  1842.     {
  1843.       SET_CHANGEABLE_VARVAL( "thread_stack" );
  1844.     }
  1845.     else if ( lstrcmp(szKeyValueName, TEXT("WaitTimeout")) == 0 )
  1846.     {
  1847.       SET_CHANGEABLE_VARVAL( "wait_timeout" );
  1848.     }
  1849.     else if ( lstrcmp(szKeyValueName, TEXT("DelayedInsertTimeout"))
  1850.       == 0 )
  1851.     {
  1852.       SET_CHANGEABLE_VARVAL( "delayed_insert_timeout" );
  1853.     }
  1854.     else if ( lstrcmp(szKeyValueName, TEXT("DelayedInsertLimit")) ==
  1855.       0 )
  1856.     {
  1857.       SET_CHANGEABLE_VARVAL( "delayed_insert_limit" );
  1858.     }
  1859.     else if ( lstrcmp(szKeyValueName, TEXT("DelayedQueueSize")) == 0
  1860.       )
  1861.     {
  1862.       SET_CHANGEABLE_VARVAL( "delayed_queue_size" );
  1863.     }
  1864.     else if ( lstrcmp(szKeyValueName, TEXT("FlushTime")) == 0 )
  1865.     {
  1866.       SET_CHANGEABLE_VARVAL( "flush_time" );
  1867.     }
  1868.     else if ( lstrcmp(szKeyValueName, TEXT("InteractiveTimeout")) ==
  1869.       0 )
  1870.     {
  1871.       SET_CHANGEABLE_VARVAL( "interactive_timeout" );
  1872.     }
  1873.     else if ( lstrcmp(szKeyValueName, TEXT("LowerCaseTableNames"))
  1874.       == 0 )
  1875.     {
  1876.       SET_CHANGEABLE_VARVAL( "lower_case_table_names" );
  1877.     }
  1878.     else if ( lstrcmp(szKeyValueName, TEXT("MaxHeapTableSize")) == 0
  1879.       )
  1880.     {
  1881.       SET_CHANGEABLE_VARVAL( "max_heap_table_size" );
  1882.     }
  1883.     else if ( lstrcmp(szKeyValueName, TEXT("MaxTmpTables")) == 0 )
  1884.     {
  1885.       SET_CHANGEABLE_VARVAL( "max_tmp_tables" );
  1886.     }
  1887.     else if ( lstrcmp(szKeyValueName, TEXT("MaxWriteLockCount")) ==
  1888.       0 )
  1889.     {
  1890.       SET_CHANGEABLE_VARVAL( "max_write_lock_count" );
  1891.     }
  1892.     else if ( lstrcmp(szKeyValueName, TEXT("NetRetryCount")) == 0 )
  1893.     {
  1894.       SET_CHANGEABLE_VARVAL( "net_retry_count" );
  1895.     }
  1896.     else if ( lstrcmp(szKeyValueName, TEXT("QueryBufferSize")) == 0
  1897.       )
  1898.     {
  1899.       SET_CHANGEABLE_VARVAL( "query_buffer_size" );
  1900.     }
  1901.     else if ( lstrcmp(szKeyValueName, TEXT("ThreadConcurrency")) ==
  1902.       0 )
  1903.     {
  1904.       SET_CHANGEABLE_VARVAL( "thread_concurrency" );
  1905.     }
  1906.     else
  1907.     {
  1908.       TCHAR szErrorMsg [ 512 ];
  1909.       RegCloseKey( hParametersKey );
  1910.       lstrcpy( szErrorMsg, TEXT("Value "") );
  1911.       lstrcat( szErrorMsg, szKeyValueName );
  1912.       lstrcat( szErrorMsg, TEXT("" of registry key "" KEY_SERVICE_PARAMETERS "" is not defined by MySQLn") );
  1913.       fprintf( stderr, szErrorMsg ); /* not unicode compatible */
  1914.       return 1;
  1915.     }
  1917.     dwIndex++;
  1918.     dwKeyValueName = sizeof( szKeyValueName ) / sizeof( TCHAR );
  1919.     dwKeyValueBuffer = sizeof( bKeyValueBuffer );
  1920.   }
  1921.   RegCloseKey( hParametersKey );
  1923.   /* paths are fixed by method get_options() */
  1924.   return 0;
  1925. }
  1926. #endif
  1929. static char *get_relative_path(const char *path)
  1930. {
  1931.   if (test_if_hard_path(path) &&
  1932.       is_prefix(path,DEFAULT_MYSQL_HOME) &&
  1933.       strcmp(DEFAULT_MYSQL_HOME,FN_ROOTDIR))
  1934.   {
  1935.     path+=(uint) strlen(DEFAULT_MYSQL_HOME);
  1936.     while (*path == FN_LIBCHAR)
  1937.       path++;
  1938.   }
  1939.   return (char*) path;
  1940. }
  1943. static void fix_paths(void)
  1944. {
  1945.   (void) fn_format(mysql_home,mysql_home,"","",16); // Remove symlinks
  1946.   convert_dirname(mysql_home);
  1947.   convert_dirname(mysql_real_data_home);
  1948.   convert_dirname(language);
  1949.   (void) my_load_path(mysql_home,mysql_home,""); // Resolve current dir
  1950.   (void) my_load_path(mysql_real_data_home,mysql_real_data_home,mysql_home);
  1951.   (void) my_load_path(pidfile_name,pidfile_name,mysql_real_data_home);
  1953.   char buff[FN_REFLEN],*sharedir=get_relative_path(SHAREDIR);
  1954.   if (test_if_hard_path(sharedir))
  1955.     strmov(buff,sharedir); /* purecov: tested */
  1956.   else
  1957.     strxmov(buff,mysql_home,sharedir,NullS);
  1958.   convert_dirname(buff);
  1959.   (void) my_load_path(language,language,buff);
  1961.   /* If --character-sets-dir isn't given, use shared library dir */
  1962.   if (charsets_dir != mysql_charsets_dir)
  1963.   {
  1964.     strmov(strmov(mysql_charsets_dir,buff),CHARSET_DIR);
  1965.     charsets_dir=mysql_charsets_dir;
  1966.   }
  1968.   /* Add '/' to TMPDIR if needed */
  1969.   char *tmp= (char*) my_malloc(FN_REFLEN,MYF(MY_FAE));
  1970.   if (tmp)
  1971.   {
  1972.     strmov(tmp,mysql_tmpdir);
  1973.     mysql_tmpdir=tmp;
  1974.     convert_dirname(mysql_tmpdir);
  1975.     mysql_tmpdir=(char*) my_realloc(mysql_tmpdir,(uint) strlen(mysql_tmpdir)+1,
  1976.     MYF(MY_HOLD_ON_ERROR));
  1977.   }
  1978. }
  1981. #ifdef SET_RLIMIT_NOFILE
  1982. static uint set_maximum_open_files(uint max_file_limit)
  1983. {
  1984.   struct rlimit rlimit;
  1985.   ulong old_cur;
  1987.   if (!getrlimit(RLIMIT_NOFILE,&rlimit))
  1988.   {
  1989.     old_cur=rlimit.rlim_cur;
  1990.     if (rlimit.rlim_cur >= max_file_limit) // Nothing to do
  1991.       return rlimit.rlim_cur; /* purecov: inspected */
  1992.     rlimit.rlim_cur=rlimit.rlim_max=max_file_limit;
  1993.     if (setrlimit(RLIMIT_NOFILE,&rlimit))
  1994.     {
  1995.       sql_print_error("Warning: setrlimit couldn't increase number of open files to more than %ld",
  1996.       old_cur); /* purecov: inspected */
  1997.       max_file_limit=old_cur;
  1998.     }
  1999.     else
  2000.     {
  2001.       (void) getrlimit(RLIMIT_NOFILE,&rlimit);
  2002.       if ((uint) rlimit.rlim_cur != max_file_limit)
  2003. sql_print_error("Warning: setrlimit returned ok, but didn't change limits. Max open files is %ld",
  2004.   (ulong) rlimit.rlim_cur); /* purecov: inspected */
  2005.       max_file_limit=rlimit.rlim_cur;
  2006.     }
  2007.   }
  2008.   return max_file_limit;
  2009. }
  2010. #endif
  2013. /*
  2014.   Return a bitfield from a string of substrings separated by ','
  2015.   returns ~(ulong) 0 on error.
  2016. */
  2018. static ulong find_bit_type(const char *x, TYPELIB *bit_lib)
  2019. {
  2020.   bool found_end;
  2021.   int  found_count;
  2022.   const char *end,*i,*j;
  2023.   const char **array, *pos;
  2024.   ulong found,found_int,bit;
  2025.   DBUG_ENTER("find_bit_type");
  2026.   DBUG_PRINT("enter",("x: '%s'",x));
  2028.   found=0;
  2029.   found_end= 0;
  2030.   pos=(my_string) x;
  2031.   do
  2032.   {
  2033.     if (!*(end=strcend(pos,','))) /* Let end point at fieldend */
  2034.     {
  2035.       while (end > pos && end[-1] == ' ')
  2036. end--; /* Skipp end-space */
  2037.       found_end=1;
  2038.     }
  2039.     found_int=0; found_count=0;
  2040.     for (array=bit_lib->type_names, bit=1 ; (i= *array++) ; bit<<=1)
  2041.     {
  2042.       j=pos;
  2043.       while (j != end)
  2044.       {
  2045. if (toupper(*i++) != toupper(*j++))
  2046.   goto skipp;
  2047.       }
  2048.       found_int=bit;
  2049.       if (! *i)
  2050.       {
  2051. found_count=1;
  2052. break;
  2053.       }
  2054.       else if (j != pos) // Half field found
  2055.       {
  2056. found_count++; // Could be one of two values
  2057.       }
  2058. skipp: ;
  2059.     }
  2060.     if (found_count != 1)
  2061.       DBUG_RETURN(~(ulong) 0); // No unique value
  2062.     found|=found_int;
  2063.     pos=end+1;
  2064.   } while (! found_end);
  2066.   DBUG_PRINT("exit",("bit-field: %ld",(ulong) found));
  2067.   DBUG_RETURN(found);
  2068. } /* find_bit_type */
  2071. /*****************************************************************************
  2072. ** Instantiate templates
  2073. *****************************************************************************/
  2075. #ifdef __GNUC__
  2076. /* Used templates */
  2077. template class I_List<THD>;
  2078. template class I_List_iterator<THD>;
  2079. template class I_List<i_string>;
  2080. template class I_List<i_string_pair>;
  2081. #endif