#At file:///home/jonas/src/telco-7.0/ based on revid:jonas@stripped
4105 jonas oreland 2011-01-12
ndb - rename trp_client::forceSend() to do_forceSend() to avoid nasty clash with TransporterSendBufferHandle::forceSend()
modified:
storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp
storage/ndb/src/ndbapi/Ndbif.cpp
storage/ndb/src/ndbapi/SignalSender.cpp
storage/ndb/src/ndbapi/trp_client.cpp
storage/ndb/src/ndbapi/trp_client.hpp
=== modified file 'storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp'
--- a/storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp 2011-01-10 11:22:17 +0000
+++ b/storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp 2011-01-12 08:04:39 +0000
@@ -5803,7 +5803,7 @@ NdbDictInterface::forceGCPWait(int type)
continue;
}
- m_impl->forceSend();
+ m_impl->do_forceSend();
m_impl->unlock();
}
return m_error.code == 0 ? 0 : -1;
=== modified file 'storage/ndb/src/ndbapi/Ndbif.cpp'
--- a/storage/ndb/src/ndbapi/Ndbif.cpp 2011-01-10 11:22:17 +0000
+++ b/storage/ndb/src/ndbapi/Ndbif.cpp 2011-01-12 08:04:39 +0000
@@ -1204,7 +1204,7 @@ Ndb::sendPrepTrans(int forceSend)
insert_completed_list(a_con);
}//for
theNoOfPreparedTransactions = 0;
- theImpl->forceSend(forceSend);
+ theImpl->do_forceSend(forceSend);
return;
}//Ndb::sendPrepTrans()
=== modified file 'storage/ndb/src/ndbapi/SignalSender.cpp'
--- a/storage/ndb/src/ndbapi/SignalSender.cpp 2011-01-10 13:30:14 +0000
+++ b/storage/ndb/src/ndbapi/SignalSender.cpp 2011-01-12 08:04:39 +0000
@@ -203,7 +203,7 @@ SignalSender::sendFragmentedSignal(Uint1
sig.header.m_noOfSections);
if (ret == 0)
{
- forceSend();
+ do_forceSend();
return SEND_OK;
}
return SEND_DISCONNECTED;
@@ -218,7 +218,7 @@ SignalSender::sendSignal(Uint16 nodeId,
s->header.m_noOfSections);
if (ret == 0)
{
- forceSend();
+ do_forceSend();
return SEND_OK;
}
return SEND_DISCONNECTED;
=== modified file 'storage/ndb/src/ndbapi/trp_client.cpp'
--- a/storage/ndb/src/ndbapi/trp_client.cpp 2011-01-10 11:22:17 +0000
+++ b/storage/ndb/src/ndbapi/trp_client.cpp 2011-01-12 08:04:39 +0000
@@ -100,7 +100,7 @@ trp_client::cond_wait(Uint32 timeout, Nd
}
void
-trp_client::forceSend(int val)
+trp_client::do_forceSend(int val)
{
if (val == 0)
{
@@ -157,7 +157,7 @@ int PollGuard::wait_scan(int wait_time,
int PollGuard::wait_for_input_in_loop(int wait_time, bool forceSend)
{
int ret_val;
- m_clnt->forceSend(forceSend ? 1 : 0);
+ m_clnt->do_forceSend(forceSend ? 1 : 0);
NDB_TICKS curr_time = NdbTick_CurrentMillisecond();
NDB_TICKS max_time = curr_time + (NDB_TICKS)wait_time;
=== modified file 'storage/ndb/src/ndbapi/trp_client.hpp'
--- a/storage/ndb/src/ndbapi/trp_client.hpp 2011-01-10 11:22:17 +0000
+++ b/storage/ndb/src/ndbapi/trp_client.hpp 2011-01-12 08:04:39 +0000
@@ -44,7 +44,7 @@ public:
void complete_poll();
void wakeup();
- void forceSend(int val = 1);
+ void do_forceSend(int val = 1);
int raw_sendSignal(const NdbApiSignal*, Uint32 nodeId);
int raw_sendSignal(const NdbApiSignal*, Uint32 nodeId,
Attachment: [text/bzr-bundle] bzr/jonas@mysql.com-20110112080439-iholq2ygqim3r3e9.bundle
| Thread |
|---|
| • bzr commit into mysql-5.1-telco-7.0 branch (jonas:4105) | jonas oreland | 12 Jan |