summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorunknown <joerg@trift2.>2008-02-13 13:40:53 +0100
committerunknown <joerg@trift2.>2008-02-13 13:40:53 +0100
commitd509d8324dfad389d5d4ab8cc4851c0d16812be4 (patch)
treee5838a8041a2b6c36a3099d256894fe4b43280ed
parenta62818f335f1a803f1c480f5284354b26b893e5b (diff)
parent4021535b9b496aa1b1bbb8b44afe8c5bbf298de8 (diff)
downloadmariadb-git-d509d8324dfad389d5d4ab8cc4851c0d16812be4.tar.gz
Merge trift2.:/MySQL/M51/clone-5.1
into trift2.:/MySQL/M51/push-5.1 extra/yassl/src/handshake.cpp: Auto merged extra/yassl/src/template_instnt.cpp: Auto merged extra/yassl/src/yassl_imp.cpp: Auto merged scripts/make_binary_distribution.sh: Auto merged sql/handler.cc: Auto merged sql/log_event.cc: Auto merged
-rwxr-xr-xBUILD/compile-dist2
-rw-r--r--sql/handler.cc2
-rw-r--r--sql/log_event.cc20
-rw-r--r--storage/ndb/src/common/util/OutputStream.cpp4
4 files changed, 19 insertions, 9 deletions
diff --git a/BUILD/compile-dist b/BUILD/compile-dist
index d9103e0a419..74690fb0c95 100755
--- a/BUILD/compile-dist
+++ b/BUILD/compile-dist
@@ -39,6 +39,8 @@ then
fi
# Make sure to enable all features that affect "make dist"
+# Remember that configure restricts the man pages to the configured features !
./configure \
+ --with-embedded-server \
--with-ndbcluster
make
diff --git a/sql/handler.cc b/sql/handler.cc
index 95d63740039..eba9b0dc5ea 100644
--- a/sql/handler.cc
+++ b/sql/handler.cc
@@ -4034,6 +4034,8 @@ int handler::ha_reset()
DBUG_ASSERT(inited == NONE);
/* Free cache used by filesort */
free_io_cache(table);
+ /* reset the bitmaps to point to defaults */
+ table->default_column_bitmaps();
DBUG_RETURN(reset());
}
diff --git a/sql/log_event.cc b/sql/log_event.cc
index df0d1e8a020..a4b32a84b42 100644
--- a/sql/log_event.cc
+++ b/sql/log_event.cc
@@ -8031,7 +8031,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
{
DBUG_PRINT("info",("ha_index_init returns error %d",error));
table->file->print_error(error, MYF(0));
- DBUG_RETURN(error);
+ goto err;
}
/* Fill key data for the row */
@@ -8064,7 +8064,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
DBUG_PRINT("info",("no record matching the key found in the table"));
table->file->print_error(error, MYF(0));
table->file->ha_index_end();
- DBUG_RETURN(error);
+ goto err;
}
/*
@@ -8092,7 +8092,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
if (table->key_info->flags & HA_NOSAME)
{
table->file->ha_index_end();
- DBUG_RETURN(0);
+ goto ok;
}
/*
@@ -8124,7 +8124,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
DBUG_PRINT("info",("no record matching the given row found"));
table->file->print_error(error, MYF(0));
table->file->ha_index_end();
- DBUG_RETURN(error);
+ goto err;
}
}
@@ -8145,7 +8145,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
DBUG_PRINT("info",("error initializing table scan"
" (ha_rnd_init returns %d)",error));
table->file->print_error(error, MYF(0));
- DBUG_RETURN(error);
+ goto err;
}
/* Continue until we find the right record or have made a full loop */
@@ -8169,7 +8169,7 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
" (rnd_next returns %d)",error));
table->file->print_error(error, MYF(0));
table->file->ha_rnd_end();
- DBUG_RETURN(error);
+ goto err;
}
}
while (restart_count < 2 && record_compare(table));
@@ -8189,10 +8189,16 @@ int Rows_log_event::find_row(const Relay_log_info *rli)
table->file->ha_rnd_end();
DBUG_ASSERT(error == HA_ERR_END_OF_FILE || error == HA_ERR_RECORD_DELETED || error == 0);
- DBUG_RETURN(error);
+ goto err;
}
+ok:
+ table->default_column_bitmaps();
DBUG_RETURN(0);
+
+err:
+ table->default_column_bitmaps();
+ DBUG_RETURN(error);
}
#endif
diff --git a/storage/ndb/src/common/util/OutputStream.cpp b/storage/ndb/src/common/util/OutputStream.cpp
index 0943e47e33f..cd619380e5a 100644
--- a/storage/ndb/src/common/util/OutputStream.cpp
+++ b/storage/ndb/src/common/util/OutputStream.cpp
@@ -62,7 +62,7 @@ SocketOutputStream::print(const char * fmt, ...){
if(ret >= 0)
m_timeout_remain-=time;
- if(errno==ETIMEDOUT || m_timeout_remain<=0)
+ if((ret < 0 && errno==ETIMEDOUT) || m_timeout_remain<=0)
{
m_timedout= true;
ret= -1;
@@ -84,7 +84,7 @@ SocketOutputStream::println(const char * fmt, ...){
if(ret >= 0)
m_timeout_remain-=time;
- if (errno==ETIMEDOUT || m_timeout_remain<=0)
+ if ((ret < 0 && errno==ETIMEDOUT) || m_timeout_remain<=0)
{
m_timedout= true;
ret= -1;