List:Commits« Previous MessageNext Message »
From:tomas Date:July 3 2007 6:29pm
Subject:bk commit into 5.1 tree (tomas:1.2531)
View as plain text  
Below is the list of changes that have just been committed into a local
5.1 repository of tomas. When tomas does a push these changes will
be propagated to the main repository and, within 24 hours after the
push, to the public repository.
For information on how to access the public repository
see http://dev.mysql.com/doc/mysql/en/installing-source-tree.html

ChangeSet@stripped, 2007-07-03 18:28:56+02:00, tomas@stripped +7 -0
  after merge fixes

  sql/ha_ndbcluster.cc@stripped, 2007-07-03 18:28:52+02:00, tomas@stripped +57
-47
    after merge fixes

  sql/ha_ndbcluster.h@stripped, 2007-07-03 18:28:52+02:00, tomas@stripped +11
-6
    after merge fixes

  sql/ha_ndbcluster_binlog.cc@stripped, 2007-07-03 18:28:52+02:00,
tomas@stripped +4 -4
    after merge fixes

  sql/mysqld.cc@stripped, 2007-07-03 18:28:52+02:00, tomas@stripped +4 -4
    after merge fixes

  storage/ndb/src/ndbapi/NdbBlob.cpp@stripped, 2007-07-03 18:28:52+02:00,
tomas@stripped +2 -2
    after merge fixes

  storage/ndb/src/ndbapi/NdbOperationSearch.cpp@stripped, 2007-07-03 18:28:52+02:00,
tomas@stripped +1 -1
    after merge fixes

  storage/ndb/tools/restore/restore_main.cpp@stripped, 2007-07-03 18:28:52+02:00,
tomas@stripped +1 -1
    after merge fixes

diff -Nrup a/sql/ha_ndbcluster.cc b/sql/ha_ndbcluster.cc
--- a/sql/ha_ndbcluster.cc	2007-07-02 19:07:59 +02:00
+++ b/sql/ha_ndbcluster.cc	2007-07-03 18:28:52 +02:00
@@ -765,7 +765,7 @@ alloc_batch_row(Thd_ndb *thd_ndb, uint s
    */
   if (thd_ndb->m_unsent_bytes == 0)
     free_root(&(thd_ndb->m_batch_mem_root), MY_MARK_BLOCKS_FREE);
-  return alloc_root(&(thd_ndb->m_batch_mem_root), size);
+  return (uchar*)alloc_root(&(thd_ndb->m_batch_mem_root), size);
 }
 
 /*
@@ -780,7 +780,7 @@ uchar *
 ha_ndbcluster::batch_copy_row_to_buffer(Thd_ndb *thd_ndb, const uchar *record,
                                         bool & batch_full)
 {
-  char *row= copy_row_to_buffer(thd_ndb, record);
+  uchar *row= copy_row_to_buffer(thd_ndb, record);
   if (unlikely(!row))
     return NULL;
   uint unsent= thd_ndb->m_unsent_bytes;
@@ -814,7 +814,7 @@ ha_ndbcluster::batch_copy_key_to_buffer(
 uchar *
 ha_ndbcluster::copy_row_to_buffer(Thd_ndb *thd_ndb, const uchar *record)
 {
-  char *row;
+  uchar *row;
   uint size= table->s->reclength + m_extra_reclength;
   row= alloc_batch_row(thd_ndb, size);
   if (unlikely(!row))
@@ -828,8 +828,8 @@ uchar *
 ha_ndbcluster::get_row_buffer()
 {
   Thd_ndb *thd_ndb= get_thd_ndb(table->in_use);
-  return alloc_root(&(thd_ndb->m_batch_mem_root),
-                    table->s->reclength + m_extra_reclength);
+  return (uchar*)alloc_root(&(thd_ndb->m_batch_mem_root),
+                            table->s->reclength + m_extra_reclength);
 }
 
 /*
@@ -899,7 +899,8 @@ int g_get_ndb_blobs_value(NdbBlob *ndb_b
     my_free(ha->m_blobs_buffer, MYF(MY_ALLOW_ZERO_PTR));
     DBUG_PRINT("info", ("allocate blobs buffer size %u",
                         (uint32)(ha->m_blob_total_size)));
-    ha->m_blobs_buffer= my_malloc(ha->m_blob_total_size, MYF(MY_WME));
+    ha->m_blobs_buffer=
+      (uchar*) my_malloc(ha->m_blob_total_size, MYF(MY_WME));
     if (ha->m_blobs_buffer == NULL)
     {
       ha->m_blobs_buffer_size= 0;
@@ -935,7 +936,7 @@ int g_get_ndb_blobs_value(NdbBlob *ndb_b
       if (ndb_blob->getLength(len64) != 0)
         ERR_RETURN(ndb_blob->getNdbError());
       DBUG_ASSERT(len64 < 0xffffffff);
-      char *buf= ha->m_blobs_buffer + offset;
+      uchar *buf= ha->m_blobs_buffer + offset;
       uint32 len= ha->m_blobs_buffer_size - offset;
       if (ndb_blob->readData(buf, len) != 0)
           ERR_RETURN(ndb_blob->getNdbError());
@@ -958,7 +959,7 @@ int g_get_ndb_blobs_value(NdbBlob *ndb_b
       /* Have to set length even in this case. */
       my_ptrdiff_t ptrdiff=
         ha->m_blob_destination_record - ha->table->record[0];
-      char *buf= ha->m_blobs_buffer + offset;
+      uchar *buf= ha->m_blobs_buffer + offset;
       field_blob->move_field_offset(ptrdiff);
       field_blob->set_ptr((uint32)0, buf);
       field_blob->set_null();
@@ -1050,23 +1051,23 @@ ha_ndbcluster::set_blob_values(NdbOperat
       Field_blob *field_blob= (Field_blob *)field;
 
       // Get length and pointer to data
-      const byte* field_ptr= field->ptr + row_offset;
+      const uchar *field_ptr= field->ptr + row_offset;
       uint32 blob_len= field_blob->get_length(field_ptr);
-      char* blob_ptr= NULL;
+      uchar* blob_ptr= NULL;
       field_blob->get_ptr(&blob_ptr);
 
       // Looks like NULL ptr signals length 0 blob
       if (blob_ptr == NULL) {
         DBUG_ASSERT(blob_len == 0);
-        blob_ptr= (char*)"";
+        blob_ptr= (uchar*)"";
       }
 
       DBUG_PRINT("value", ("set blob ptr: 0x%lx  len: %u",
                            (long) blob_ptr, blob_len));
-      DBUG_DUMP("value", (char*)blob_ptr, min(blob_len, 26));
+      DBUG_DUMP("value", blob_ptr, min(blob_len, 26));
 
       // No callback needed to write value
-      res= ndb_blob->setValue(blob_ptr, blob_len);
+      res= ndb_blob->setValue((char*)blob_ptr, blob_len);
       if (res != 0)
         DBUG_RETURN(1);
     }
@@ -1532,7 +1533,7 @@ ndb_set_record_specification(uint field_
   if (table->field[field_no]->null_ptr)
   {
     spec->nullbit_byte_offset=
-      (char *)table->field[field_no]->null_ptr - table->record[0];
+      table->field[field_no]->null_ptr - table->record[0];
     spec->nullbit_bit_in_byte=
       null_bit_mask_to_bit_number(table->field[field_no]->null_bit);
   }
@@ -1541,7 +1542,7 @@ ndb_set_record_specification(uint field_
     /* We need to store the position of the overflow bits. */
     const Field_bit* field_bit= static_cast<Field_bit*>(table->field[field_no]);
     spec->nullbit_byte_offset=
-      (char *)field_bit->bit_ptr - table->record[0];
+      field_bit->bit_ptr - table->record[0];
     spec->nullbit_bit_in_byte= field_bit->bit_ofs;
   }
   else
@@ -2217,7 +2218,7 @@ int ha_ndbcluster::complemented_read(con
   }
 
   const NdbRecord *key_rec;
-  const char *key_row;
+  const uchar *key_row;
   if (table_share->primary_key != MAX_KEY)
   {
     key_rec= m_index[table->s->primary_key].ndb_unique_record_row;
@@ -2227,7 +2228,7 @@ int ha_ndbcluster::complemented_read(con
   {
     /* Hidden primary key, previously read into m_ref. */
     key_rec= m_ndb_hidden_key_record;
-    key_row= (const char *)(&m_ref);
+    key_row= (const uchar*)(&m_ref);
   }
 
   /*
@@ -2239,7 +2240,8 @@ int ha_ndbcluster::complemented_read(con
   bitmap_invert(&m_bitmap);
   NdbOperation::LockMode lm=
     (NdbOperation::LockMode)get_ndb_lock_type(m_lock.type, &m_bitmap);
-  if (!(op= trans->readTuple(key_rec, key_row, m_ndb_record, new_data,
+  if (!(op= trans->readTuple(key_rec, (const char *)key_row,
+                             m_ndb_record, (char *)new_data,
                              lm, (const unsigned char *)(m_bitmap.bitmap))))
     ERR_RETURN(trans->getNdbError());
 
@@ -2424,7 +2426,8 @@ int ha_ndbcluster::peek_indexed_rows(con
 
       NdbOperation *iop;
       const NdbRecord *key_rec= m_index[i].ndb_unique_record_row;
-      if (!(iop= trans->readTuple(key_rec, record, key_rec, dummy_row,
+      if (!(iop= trans->readTuple(key_rec, (const char *)record,
+                                  key_rec, dummy_row,
                                   lm, empty_mask)))
         ERR_RETURN(trans->getNdbError());
 
@@ -2464,7 +2467,7 @@ int ha_ndbcluster::unique_index_read(con
 {
   NdbTransaction *trans= m_active_trans;
   NdbOperation *op;
-  char *row;
+  uchar *row;
   DBUG_ENTER("ha_ndbcluster::unique_index_read");
   DBUG_PRINT("enter", ("key_len: %u, index: %u", key_len, active_index));
   DBUG_DUMP("key", key, key_len);
@@ -2556,7 +2559,8 @@ inline int ha_ndbcluster::fetch_next(Ndb
         DBUG_RETURN(ndb_err(trans));
     }
     
-    if ((local_check= cursor->nextResult(m_next_row, contact_ndb,
+    if ((local_check= cursor->nextResult(_m_next_row,
+                                         contact_ndb,
                                          m_force_send)) == 0)
     {
       /*
@@ -2648,7 +2652,7 @@ inline int ha_ndbcluster::next_result(uc
   The key value is taken from a buffer in mysqld key format.
 */
 NdbOperation *
-ha_ndbcluster::pk_unique_index_read_key(uint idx, const byte *key, byte *buf,
+ha_ndbcluster::pk_unique_index_read_key(uint idx, const uchar *key, uchar *buf,
                                         NdbOperation::LockMode lm)
 {
   NdbOperation *op;
@@ -2678,7 +2682,8 @@ ha_ndbcluster::pk_unique_index_read_key(
         ndb_record= m_ndb_record_fragment;
     }
   }
-  op= m_active_trans->readTuple(key_rec, key, ndb_record, buf, lm, mask);
+  op= m_active_trans->readTuple(key_rec, (const char *)key,
+                                ndb_record, (char *)buf, lm, mask);
 
   if (uses_blob_value(table->read_set) &&
       get_blob_values(op, buf, table->read_set) != 0)
@@ -2894,7 +2899,7 @@ compute_index_bounds(NdbIndexScanOperati
 {
   if (start_key)
   {
-    bound.low_key= start_key->key;
+    bound.low_key= (const char*)start_key->key;
     bound.low_key_count= count_key_columns(key_info, start_key);
     bound.low_inclusive=
       start_key->flag != HA_READ_AFTER_KEY &&
@@ -2916,7 +2921,7 @@ compute_index_bounds(NdbIndexScanOperati
   }
   else if (end_key)
   {
-    bound.high_key= end_key->key;
+    bound.high_key= (const char*)end_key->key;
     bound.high_key_count= count_key_columns(key_info, end_key);
     /*
       For some reason, 'where b >= 1 and b <= 3' uses HA_READ_AFTER_KEY for
@@ -3243,18 +3248,19 @@ int ha_ndbcluster::full_table_scan(uchar
 }
 
 inline void
-ha_ndbcluster::eventSetAnyValue(const THD *thd, NdbOperation *op)
+ha_ndbcluster::eventSetAnyValue(THD *thd, NdbOperation *op)
 {
   if (unlikely(m_slow_path))
   {
-    if (!(thd->options & OPTION_BIN_LOG))
+    Thd_ndb *thd_ndb= get_thd_ndb(thd);
+    if (thd_ndb->trans_options & TNTO_NO_LOGGING)
       op->setAnyValue(NDB_ANYVALUE_FOR_NOLOGGING);
     else if (thd->slave_thread)
       op->setAnyValue(thd->server_id);
   }
 }
 
-int ha_ndbcluster::write_row(byte *record)
+int ha_ndbcluster::write_row(uchar *record)
 {
   DBUG_ENTER("ha_ndbcluster::write_row");
   DBUG_RETURN(ndb_write_row(record, FALSE, FALSE));
@@ -3263,7 +3269,8 @@ int ha_ndbcluster::write_row(byte *recor
 /*
   Insert one record into NDB
 */
-int ha_ndbcluster::ndb_write_row(uchar *record, bool primary_key_update,
+int ha_ndbcluster::ndb_write_row(uchar *record,
+                                 bool primary_key_update,
                                  bool batched_update)
 {
   bool has_auto_increment;
@@ -3421,7 +3428,7 @@ int ha_ndbcluster::ndb_write_row(uchar *
   if (m_use_write)
   {
     const NdbRecord *key_rec;
-    const char *key_row;
+    const uchar *key_row;
     uchar *mask;
     if (table_share->primary_key == MAX_KEY || m_use_partition_function)
     {
@@ -3444,10 +3451,11 @@ int ha_ndbcluster::ndb_write_row(uchar *
       key_rec= m_index[table_share->primary_key].ndb_unique_record_row;
       key_row= row;
     }
-    op= trans->writeTuple(key_rec, key_row, m_ndb_record, row, mask);
+    op= trans->writeTuple(key_rec, (const char *)key_row,
+                          m_ndb_record, (char *)row, mask);
   }
   else
-    op= trans->insertTuple(m_ndb_record, row);
+    op= trans->insertTuple(m_ndb_record, (char *)row);
   if (!(op))
     ERR_RETURN(trans->getNdbError());
 
@@ -3626,7 +3634,7 @@ int ha_ndbcluster::update_row(const ucha
       if (trans->commitStatus() == NdbConnection::Started)
       {
         // Undo delete_row(old_data)
-        undo_res= ndb_write_row(old_data, TRUE, batched_update);
+        undo_res= ndb_write_row((uchar *)old_data, TRUE, batched_update);
         if (undo_res)
           push_warning(current_thd, 
                        MYSQL_ERROR::WARN_LEVEL_WARN, 
@@ -3652,7 +3660,7 @@ int ha_ndbcluster::update_row(const ucha
     clear_extended_column_set(mask);
 
   /* Need to set the value of any user-defined partitioning function. */
-  char *row;
+  uchar *row;
   bool need_execute;
   /*
     Batch update operation if we are doing a scan for update, unless
@@ -3697,7 +3705,8 @@ int ha_ndbcluster::update_row(const ucha
     */
     DBUG_PRINT("info", ("Calling updateTuple on cursor, write_set=0x%x",
                         table->write_set->bitmap[0]));
-    if (!(op= cursor->updateCurrentTuple(trans, m_ndb_record, row, mask)))
+    if (!(op= cursor->updateCurrentTuple(trans, m_ndb_record,
+                                         (const char*)row, mask)))
       ERR_RETURN(trans->getNdbError());
 
     m_lock_tuple= FALSE;
@@ -3706,7 +3715,7 @@ int ha_ndbcluster::update_row(const ucha
   else
   {  
     const NdbRecord *key_rec;
-    const char *key_row;
+    const uchar *key_row;
     if (table_share->primary_key != MAX_KEY)
     {
       key_rec= m_index[table_share->primary_key].ndb_unique_record_row;
@@ -3716,10 +3725,11 @@ int ha_ndbcluster::update_row(const ucha
     {
       /* Use hidden primary key previously read into m_ref. */
       key_rec= m_ndb_hidden_key_record;
-      key_row= (const char *)(&m_ref);
+      key_row= (const uchar *)(&m_ref);
     }
 
-    if (!(op= trans->updateTuple(key_rec, key_row, m_ndb_record, row, mask)))
+    if (!(op= trans->updateTuple(key_rec, (const char *)key_row,
+                                 m_ndb_record, (const char*)row, mask)))
       ERR_RETURN(trans->getNdbError());  
   }
 
@@ -3749,7 +3759,7 @@ int ha_ndbcluster::update_row(const ucha
 }
 
 
-int ha_ndbcluster::delete_row(const byte *record)
+int ha_ndbcluster::delete_row(const uchar *record)
 {
   return ndb_delete_row(record, FALSE);
 }
@@ -3808,7 +3818,7 @@ int ha_ndbcluster::ndb_delete_row(const 
   else
   {
     const NdbRecord *key_rec;
-    const char *key_row;
+    const uchar *key_row;
     uint key_len;
     if (table_share->primary_key != MAX_KEY)
     {
@@ -3819,7 +3829,7 @@ int ha_ndbcluster::ndb_delete_row(const 
     else
     {
       key_rec= m_ndb_hidden_key_record;
-      key_row= (const char *)(&m_ref);
+      key_row= (const uchar *)(&m_ref);
       key_len= sizeof(m_ref);
     }
     /*
@@ -3857,7 +3867,7 @@ int ha_ndbcluster::ndb_delete_row(const 
     else
       need_execute= TRUE;
 
-    if (!(op=trans->deleteTuple(key_rec, key_row)))
+    if (!(op=trans->deleteTuple(key_rec, (const char *)key_row)))
       ERR_RETURN(trans->getNdbError());
     
     if (m_use_partition_function)
@@ -7990,7 +8000,7 @@ ndbcluster_init_error:
         if (g_ndb_cluster_connection_pool[i])
           delete g_ndb_cluster_connection_pool[i];
       }
-      my_free((gptr) g_ndb_cluster_connection_pool, MYF(MY_ALLOW_ZERO_PTR));
+      my_free((uchar*) g_ndb_cluster_connection_pool, MYF(MY_ALLOW_ZERO_PTR));
       pthread_mutex_destroy(&g_ndb_cluster_connection_pool_mutex);
       g_ndb_cluster_connection_pool= 0;
     }
@@ -8070,7 +8080,7 @@ static int ndbcluster_end(handlerton *ht
         if (g_ndb_cluster_connection_pool[i])
           delete g_ndb_cluster_connection_pool[i];
       }
-      my_free((gptr) g_ndb_cluster_connection_pool, MYF(MY_ALLOW_ZERO_PTR));
+      my_free((uchar*) g_ndb_cluster_connection_pool, MYF(MY_ALLOW_ZERO_PTR));
       pthread_mutex_destroy(&g_ndb_cluster_connection_pool_mutex);
       g_ndb_cluster_connection_pool= 0;
     }
@@ -9535,8 +9545,8 @@ ha_ndbcluster::read_multi_range_first(KE
   const NdbOperation* lastOp= m_active_trans->getLastDefinedOperation();
   NdbOperation::LockMode lm= 
     (NdbOperation::LockMode)get_ndb_lock_type(m_lock.type, table->read_set);
-  byte *row_buf= (byte*)buffer->buffer;
-  byte *end_of_buffer= (byte*)buffer->buffer_end;
+  uchar *row_buf= (uchar *)buffer->buffer;
+  const uchar *end_of_buffer= buffer->buffer_end;
   uint num_scan_ranges= 0;
   uint i;
   for (i= 0; i < range_count; i++)
@@ -9696,7 +9706,7 @@ ha_ndbcluster::read_multi_range_next(KEY
       multi_range_curr= old_multi_range_curr + 1;
       const NdbOperation *op= m_current_multi_operation;
       m_current_multi_operation= m_active_trans->getNextCompletedOperation(op);
-      uchar *src_row= m_multi_range_result_ptr;
+      const uchar *src_row= m_multi_range_result_ptr;
       m_multi_range_result_ptr= src_row + table_share->reclength;
 
       const NdbError &error= op->getNdbError();
diff -Nrup a/sql/ha_ndbcluster.h b/sql/ha_ndbcluster.h
--- a/sql/ha_ndbcluster.h	2007-07-02 19:07:59 +02:00
+++ b/sql/ha_ndbcluster.h	2007-07-03 18:28:52 +02:00
@@ -460,8 +460,9 @@ private:
 			uchar *buf);
   int full_table_scan(uchar * buf);
   int flush_bulk_insert();
-  int ndb_write_row(byte *record, bool primary_key_update, bool batched_update);
-  int ndb_delete_row(const byte *record, bool primary_key_update);
+  int ndb_write_row(uchar *record, bool primary_key_update,
+                    bool batched_update);
+  int ndb_delete_row(const uchar *record, bool primary_key_update);
 
   bool check_all_operations_for_error(NdbTransaction *trans,
                                       const NdbOperation *first,
@@ -517,7 +518,7 @@ private:
   int set_blob_values(NdbOperation *ndb_op, my_ptrdiff_t row_offset,
                       const MY_BITMAP *bitmap, uint *set_count);
   friend int g_get_ndb_blobs_value(NdbBlob *ndb_blob, void *arg);
-  void eventSetAnyValue(const THD *thd, NdbOperation *op);
+  void eventSetAnyValue(THD *thd, NdbOperation *op);
 
   NdbOperation *pk_unique_index_read_key(uint idx, const uchar *key, uchar *buf,
                                          NdbOperation::LockMode lm);
@@ -595,7 +596,11 @@ private:
   /*
     Pointer to row returned from scan nextResult().
   */
-  const char *m_next_row;
+  union
+  {
+    const char *_m_next_row;
+    const uchar *m_next_row;
+  };
   /* For read_multi_range scans, the get_range_no() of current row. */
   int m_current_range_no;
   /*
@@ -634,7 +639,7 @@ private:
   /* State for setActiveHook() callback for reading blob data. */
   uint m_blob_counter;
   uint m_blob_expected_count;
-  byte *m_blob_destination_record;
+  uchar *m_blob_destination_record;
   Uint64 m_blob_total_size;
   
   // memory for blobs in one tuple
@@ -649,7 +654,7 @@ private:
 
   ha_ndbcluster_cond *m_cond;
   bool m_disable_multi_read;
-  uchar *m_multi_range_result_ptr;
+  const uchar *m_multi_range_result_ptr;
   KEY_MULTI_RANGE *m_multi_ranges;
   /*
     Points 1 past the end of last multi range operation currently being
diff -Nrup a/sql/ha_ndbcluster_binlog.cc b/sql/ha_ndbcluster_binlog.cc
--- a/sql/ha_ndbcluster_binlog.cc	2007-07-02 18:26:37 +02:00
+++ b/sql/ha_ndbcluster_binlog.cc	2007-07-03 18:28:52 +02:00
@@ -3186,7 +3186,7 @@ ndbcluster_handle_drop_table(Ndb *ndb, c
 */
 
 static void ndb_unpack_record(TABLE *table, NdbValue *value,
-                              MY_BITMAP *defined, byte *buf)
+                              MY_BITMAP *defined, uchar *buf)
 {
   Field **p_field= table->field, *field= *p_field;
   my_ptrdiff_t row_offset= (my_ptrdiff_t) (buf - table->record[0]);
@@ -3273,13 +3273,13 @@ static void ndb_unpack_record(TABLE *tab
           field_bit->Field_bit::move_field_offset(-row_offset);
           DBUG_PRINT("info",("[%u] SET",
                              (*value).rec->getColumn()->getColumnNo()));
-          DBUG_DUMP("info", (const char*) field->ptr, field->pack_length());
+          DBUG_DUMP("info", (const uchar*) field->ptr, field->pack_length());
         }
         else
         {
           DBUG_PRINT("info",("[%u] SET",
                              (*value).rec->getColumn()->getColumnNo()));
-          DBUG_DUMP("info", (const char*) field->ptr, field->pack_length());
+          DBUG_DUMP("info", (const uchar*) field->ptr, field->pack_length());
         }
       }
       else
@@ -3303,7 +3303,7 @@ static void ndb_unpack_record(TABLE *tab
 #ifndef DBUG_OFF
           // pointer vas set in get_ndb_blobs_value
           Field_blob *field_blob= (Field_blob*)field;
-          char* ptr;
+          uchar* ptr;
           field_blob->get_ptr(&ptr, row_offset);
           uint32 len= field_blob->get_length(row_offset);
           DBUG_PRINT("info",("[%u] SET ptr: 0x%lx  len: %u",
diff -Nrup a/sql/mysqld.cc b/sql/mysqld.cc
--- a/sql/mysqld.cc	2007-07-02 18:26:38 +02:00
+++ b/sql/mysqld.cc	2007-07-03 18:28:52 +02:00
@@ -5583,12 +5583,12 @@ master-ssl",
    0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},  
   { "ndb-wait-connected", OPT_NDB_WAIT_CONNECTED,
     "Time (in seconds) for mysqld to wait for connection to cluster management and data
nodes.",
-    (gptr*) &opt_ndb_wait_connected, (gptr*) &opt_ndb_wait_connected,
+    (uchar**) &opt_ndb_wait_connected, (uchar**) &opt_ndb_wait_connected,
     0, GET_ULONG, REQUIRED_ARG, 0, 0, LONG_TIMEOUT, 0, 0, 0},
   { "ndb-cluster-connection-pool", OPT_NDB_CLUSTER_CONNECTION_POOL,
     "Pool of cluster connections to cluster to be used by mysql server.",
-    (gptr*) &opt_ndb_cluster_connection_pool,
-    (gptr*) &opt_ndb_cluster_connection_pool,
+    (uchar**) &opt_ndb_cluster_connection_pool,
+    (uchar**) &opt_ndb_cluster_connection_pool,
     0, GET_ULONG, REQUIRED_ARG, 1, 1, 63, 0, 0, 0},
 #endif
   {"new", 'n', "Use very new possible 'unsafe' functions.",
@@ -6274,7 +6274,7 @@ The minimum value for this variable is 4
    GET_ULONG, REQUIRED_ARG, 10L, 0L, (longlong) ULONG_MAX, 0, 1, 0},
   {"slave-allow-batching", OPT_SLAVE_ALLOW_BATCHING,
    "Allow slave to batch requests.",
-   (gptr*) &slave_allow_batching, (gptr*) &slave_allow_batching,
+   (uchar**) &slave_allow_batching, (uchar**) &slave_allow_batching,
    0, GET_BOOL, NO_ARG, 0, 0, 1, 0, 1, 0},
 #endif /* HAVE_REPLICATION */
   {"slow_launch_time", OPT_SLOW_LAUNCH_TIME,
diff -Nrup a/storage/ndb/src/ndbapi/NdbBlob.cpp b/storage/ndb/src/ndbapi/NdbBlob.cpp
--- a/storage/ndb/src/ndbapi/NdbBlob.cpp	2007-07-02 19:07:59 +02:00
+++ b/storage/ndb/src/ndbapi/NdbBlob.cpp	2007-07-03 18:28:52 +02:00
@@ -723,7 +723,7 @@ NdbBlob::packBlobHead(const Head& head, 
       *p++ = (head.length >> n) & 0xff;
     assert(p - (uchar*)buf == 16);
     assert(head.reserved == 0);
-    DBUG_DUMP("info", buf, 16);
+    DBUG_DUMP("info", (uchar*)buf, 16);
   }
   DBUG_PRINT("info", ("pack: varsize=%u length=%u pkid=%u",
                       (uint)head.varsize, (uint)head.length, (uint)head.pkid));
@@ -758,7 +758,7 @@ NdbBlob::unpackBlobHead(Head& head, cons
     assert(p - (uchar*)buf == 16);
     assert(head.reserved == 0);
     head.headsize = (NDB_BLOB_V2_HEAD_SIZE << 2);
-    DBUG_DUMP("info", buf, 16);
+    DBUG_DUMP("info", (uchar*)buf, 16);
   }
   DBUG_PRINT("info", ("unpack: varsize=%u length=%u pkid=%u",
                       (uint)head.varsize, (uint)head.length, (uint)head.pkid));
diff -Nrup a/storage/ndb/src/ndbapi/NdbOperationSearch.cpp
b/storage/ndb/src/ndbapi/NdbOperationSearch.cpp
--- a/storage/ndb/src/ndbapi/NdbOperationSearch.cpp	2007-05-17 08:27:48 +02:00
+++ b/storage/ndb/src/ndbapi/NdbOperationSearch.cpp	2007-07-03 18:28:52 +02:00
@@ -529,7 +529,7 @@ NdbOperation::handle_distribution_key(co
   if (theNoOfTupKeyLeft > 0 || m_accessTable->m_noOfDistributionKeys > 1)
     DBUG_RETURN(0);
   
-  DBUG_DUMP("value", (const char*)value, len << 2);
+  DBUG_DUMP("value", (const uchar*)value, len << 2);
 
   if(m_accessTable->m_noOfDistributionKeys == 1)
   {
diff -Nrup a/storage/ndb/tools/restore/restore_main.cpp
b/storage/ndb/tools/restore/restore_main.cpp
--- a/storage/ndb/tools/restore/restore_main.cpp	2007-07-02 18:26:39 +02:00
+++ b/storage/ndb/tools/restore/restore_main.cpp	2007-07-03 18:28:52 +02:00
@@ -195,7 +195,7 @@ static struct my_option my_long_options[
     GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0 },
   { "progress-frequency", OPT_PROGRESS_FREQUENCY,
     "Print status uf restore periodically in given seconds", 
-    (gptr*) &opt_progress_frequency, (gptr*) &opt_progress_frequency, 0,
+    (uchar**) &opt_progress_frequency, (uchar**) &opt_progress_frequency, 0,
     GET_INT, REQUIRED_ARG, 0, 0, 65535, 0, 0, 0 },
   { "verbose", OPT_VERBOSE,
     "verbosity", 
Thread
bk commit into 5.1 tree (tomas:1.2531)tomas3 Jul