#At file:///home/jonas/src/telco-6.4/
3024 Jonas Oreland 2008-10-28
ndbmtd - move constants from within source up to beginning of file
modified:
storage/ndb/src/kernel/vm/mt.cpp
=== modified file 'storage/ndb/src/kernel/vm/mt.cpp'
--- a/storage/ndb/src/kernel/vm/mt.cpp 2008-10-27 17:56:57 +0000
+++ b/storage/ndb/src/kernel/vm/mt.cpp 2008-10-28 11:12:13 +0000
@@ -51,12 +51,19 @@
/* Maximum number of signals to execute before sending to remote nodes. */
static const Uint32 MAX_SIGNALS_BEFORE_SEND = 200;
+
/*
* Max. signals to execute from one job buffer before considering other
* possible stuff to do.
*/
static const Uint32 MAX_SIGNALS_PER_JB = 100;
+/**
+ * Max signals written to other thread before calling flush_jbb_write_state
+ */
+static const Uint32 MAX_SIGNALS_BEFORE_FLUSH_RECEIVER = 2;
+static const Uint32 MAX_SIGNALS_BEFORE_FLUSH_OTHER = 20;
+
//#define NDB_MT_LOCK_TO_CPU
#define MAX_BLOCK_INSTANCES (1 + MAX_NDBMT_LQH_WORKERS)
@@ -2529,7 +2536,10 @@ sendlocal(Uint32 self, const SignalHeade
* to the other thread.
* This parameter found to be reasonable by benchmarking.
*/
- Uint32 MAX_SIGNALS_BEFORE_FLUSH = (self == receiver_thread_no ? 2 : 20);
+ Uint32 MAX_SIGNALS_BEFORE_FLUSH = (self == receiver_thread_no) ?
+ MAX_SIGNALS_BEFORE_FLUSH_RECEIVER :
+ MAX_SIGNALS_BEFORE_FLUSH_OTHER;
+
Uint32 dst = block2ThreadId(block, instance);
struct thr_repository* rep = &g_thr_repository;
struct thr_data * selfptr = rep->m_thread + self;
| Thread |
|---|
| • bzr commit into mysql-5.1 branch (jonas:3024) | Jonas Oreland | 28 Oct |