| /dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1136 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1137 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1140 ev_op= move_data(); in pollEvents()
1141 if (unlikely(ev_op == 0)) in pollEvents()
1147 if (ev_op) in pollEvents()
1151 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1152 ev_op->m_data_done_count= 0; in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 3784 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
3789 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
3799 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
3800 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
3802 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
3817 NdbDictionaryImpl::stopSubscribeEvent(NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
3820 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
3825 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
3837 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
3838 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1262 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1263 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1266 ev_op= move_data(); in pollEvents()
1267 if (unlikely(ev_op == 0)) in pollEvents()
1272 if (ev_op) in pollEvents()
1276 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1277 ev_op->m_data_done_count= 0; in pollEvents()
1281 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 4842 return m_receiver.executeSubscribeEvent(m_ndb, ev_op, buckets); in executeSubscribeEvent()
4847 NdbEventOperationImpl & ev_op, in executeSubscribeEvent() argument
4858 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
4859 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
4861 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
4889 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
4894 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
4906 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
4907 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
4908 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1262 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1263 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1266 ev_op= move_data(); in pollEvents()
1267 if (unlikely(ev_op == 0)) in pollEvents()
1272 if (ev_op) in pollEvents()
1276 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1277 ev_op->m_data_done_count= 0; in pollEvents()
1281 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 4842 return m_receiver.executeSubscribeEvent(m_ndb, ev_op, buckets); in executeSubscribeEvent()
4847 NdbEventOperationImpl & ev_op, in executeSubscribeEvent() argument
4858 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
4859 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
4861 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
4889 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
4894 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
4906 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
4907 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
4908 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1262 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1263 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1266 ev_op= move_data(); in pollEvents()
1267 if (unlikely(ev_op == 0)) in pollEvents()
1272 if (ev_op) in pollEvents()
1276 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1277 ev_op->m_data_done_count= 0; in pollEvents()
1281 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 4842 return m_receiver.executeSubscribeEvent(m_ndb, ev_op, buckets); in executeSubscribeEvent()
4847 NdbEventOperationImpl & ev_op, in executeSubscribeEvent() argument
4858 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
4859 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
4861 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
4889 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
4894 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
4906 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
4907 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
4908 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1262 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1263 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1266 ev_op= move_data(); in pollEvents()
1267 if (unlikely(ev_op == 0)) in pollEvents()
1272 if (ev_op) in pollEvents()
1276 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1277 ev_op->m_data_done_count= 0; in pollEvents()
1281 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 4842 return m_receiver.executeSubscribeEvent(m_ndb, ev_op, buckets); in executeSubscribeEvent()
4847 NdbEventOperationImpl & ev_op, in executeSubscribeEvent() argument
4858 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
4859 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
4861 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
4889 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
4894 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
4906 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
4907 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
4908 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1262 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1263 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1266 ev_op= move_data(); in pollEvents()
1267 if (unlikely(ev_op == 0)) in pollEvents()
1272 if (ev_op) in pollEvents()
1276 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1277 ev_op->m_data_done_count= 0; in pollEvents()
1281 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 4842 return m_receiver.executeSubscribeEvent(m_ndb, ev_op, buckets); in executeSubscribeEvent()
4847 NdbEventOperationImpl & ev_op, in executeSubscribeEvent() argument
4858 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
4859 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
4861 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
4889 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
4894 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
4906 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
4907 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
4908 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1540 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1541 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1544 ev_op= move_data(); in pollEvents()
1548 if (ev_op) in pollEvents()
1552 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1553 ev_op->m_data_done_count= 0; in pollEvents()
1557 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 5177 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
5182 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
5192 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
5193 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
5195 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
5219 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
5224 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
5236 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
5237 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
5238 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1540 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1541 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1544 ev_op= move_data(); in pollEvents()
1548 if (ev_op) in pollEvents()
1552 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1553 ev_op->m_data_done_count= 0; in pollEvents()
1557 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 5177 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
5182 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
5192 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
5193 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
5195 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
5219 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
5224 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
5236 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
5237 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
5238 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1540 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1541 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1544 ev_op= move_data(); in pollEvents()
1548 if (ev_op) in pollEvents()
1552 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1553 ev_op->m_data_done_count= 0; in pollEvents()
1557 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 5177 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
5182 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
5192 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
5193 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
5195 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
5219 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
5224 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
5236 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
5237 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
5238 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1540 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1541 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1544 ev_op= move_data(); in pollEvents()
1548 if (ev_op) in pollEvents()
1552 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1553 ev_op->m_data_done_count= 0; in pollEvents()
1557 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 5177 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
5182 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
5192 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
5193 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
5195 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
5219 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
5224 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
5236 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
5237 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
5238 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/ndbapi/ |
| H A D | NdbEventOperationImpl.cpp | 1540 NdbEventOperationImpl *ev_op= move_data(); in pollEvents() local
1541 if (unlikely(ev_op == 0 && aMillisecondNumber)) in pollEvents()
1544 ev_op= move_data(); in pollEvents()
1548 if (ev_op) in pollEvents()
1552 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1553 ev_op->m_data_done_count= 0; in pollEvents()
1557 if (unlikely(ev_op == 0)) in pollEvents()
|
| H A D | NdbDictionaryImpl.cpp | 5177 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
5182 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
5192 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
5193 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
5195 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
5219 return m_receiver.stopSubscribeEvent(m_ndb, ev_op); in stopSubscribeEvent()
5224 NdbEventOperationImpl & ev_op) in stopSubscribeEvent() argument
5236 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
5237 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
5238 req->subscriberData = ev_op.m_oid; in stopSubscribeEvent()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/ndbapi/ |
| H A D | NdbDictionaryImpl.cpp | 6197 return m_receiver.executeSubscribeEvent(m_ndb, ev_op); in executeSubscribeEvent()
6202 NdbEventOperationImpl & ev_op) in executeSubscribeEvent() argument
6212 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in executeSubscribeEvent()
6213 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in executeSubscribeEvent()
6215 req->subscriberData = ev_op.m_oid; in executeSubscribeEvent()
6236 NdbDictionaryImpl::stopSubscribeEvent(NdbEventOperationImpl & ev_op, in stopSubscribeEvent() argument
6240 return m_receiver.stopSubscribeEvent(m_ndb, ev_op, stop_gci); in stopSubscribeEvent()
6245 NdbEventOperationImpl & ev_op, in stopSubscribeEvent() argument
6258 req->subscriptionId = ev_op.m_eventImpl->m_eventId; in stopSubscribeEvent()
6259 req->subscriptionKey = ev_op.m_eventImpl->m_eventKey; in stopSubscribeEvent()
[all …]
|
| H A D | NdbEventOperationImpl.cpp | 1554 NdbEventOperationImpl *ev_op= ev_data->m_event_op; in pollEvents() local
1557 ev_op->m_data_count-= ev_op->m_data_done_count; in pollEvents()
1558 ev_op->m_data_done_count= 0; in pollEvents()
|