/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 76 class MemoryChannel class 79 MemoryChannel( int size= 512); 80 virtual ~MemoryChannel( ); 96 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 100 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 110 template <class T> MemoryChannel<T>::MemoryChannel( int size): in MemoryChannel() function in MemoryChannel 120 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 127 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 138 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 148 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 82 class MemoryChannel class 85 MemoryChannel(); 86 virtual ~MemoryChannel(); 109 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 113 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 122 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 129 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 135 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 141 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 160 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 127 MemoryChannel<Request>::ListMember m_mem_channel; 168 MemoryChannel<Request> *theReportTo; 169 MemoryChannel<Request> *theMemoryChannelPtr; 170 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 82 class MemoryChannel class 85 MemoryChannel(); 86 virtual ~MemoryChannel(); 109 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 113 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 122 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 129 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 135 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 141 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 160 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 127 MemoryChannel<Request>::ListMember m_mem_channel; 168 MemoryChannel<Request> *theReportTo; 169 MemoryChannel<Request> *theMemoryChannelPtr; 170 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 82 class MemoryChannel class 85 MemoryChannel(); 86 virtual ~MemoryChannel(); 109 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 113 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 122 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 129 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 135 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 141 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 160 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 127 MemoryChannel<Request>::ListMember m_mem_channel; 168 MemoryChannel<Request> *theReportTo; 169 MemoryChannel<Request> *theMemoryChannelPtr; 170 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 130 MemoryChannel<Request>::ListMember m_mem_channel; 178 MemoryChannel<Request> *theReportTo; 179 MemoryChannel<Request> *theMemoryChannelPtr; 180 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 137 MemoryChannel<Request>::ListMember m_mem_channel; 190 MemoryChannel<Request> *theReportTo; 191 MemoryChannel<Request> *theMemoryChannelPtr; 192 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 130 MemoryChannel<Request>::ListMember m_mem_channel; 178 MemoryChannel<Request> *theReportTo; 179 MemoryChannel<Request> *theMemoryChannelPtr; 180 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 130 MemoryChannel<Request>::ListMember m_mem_channel; 178 MemoryChannel<Request> *theReportTo; 179 MemoryChannel<Request> *theMemoryChannelPtr; 180 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 130 MemoryChannel<Request>::ListMember m_mem_channel; 178 MemoryChannel<Request> *theReportTo; 179 MemoryChannel<Request> *theMemoryChannelPtr; 180 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 85 class MemoryChannel class 88 MemoryChannel(); 89 virtual ~MemoryChannel(); 112 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 116 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 125 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 132 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 138 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 144 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 163 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 130 MemoryChannel<Request>::ListMember m_mem_channel; 178 MemoryChannel<Request> *theReportTo; 179 MemoryChannel<Request> *theMemoryChannelPtr; 180 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 82 class MemoryChannel class 85 MemoryChannel(); 86 virtual ~MemoryChannel(); 109 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 113 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 122 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 129 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 135 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 141 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 160 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 127 MemoryChannel<Request>::ListMember m_mem_channel; 168 MemoryChannel<Request> *theReportTo; 169 MemoryChannel<Request> *theMemoryChannelPtr; 170 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/kernel/blocks/ndbfs/ |
H A D | MemoryChannel.hpp | 82 class MemoryChannel class 85 MemoryChannel(); 86 virtual ~MemoryChannel(); 109 friend NdbOut& operator<<(NdbOut& out, const MemoryChannel<U> & chn); 113 NdbOut& operator<<(NdbOut& out, const MemoryChannel<T> & chn) in operator <<() 122 template <class T> MemoryChannel<T>::MemoryChannel() : in MemoryChannel() function in MemoryChannel 129 template <class T> MemoryChannel<T>::~MemoryChannel( ) in ~MemoryChannel() 135 template <class T> void MemoryChannel<T>::writeChannel( T *t) in writeChannel() 141 template <class T> void MemoryChannel<T>::writeChannelNoSignal( T *t) in writeChannelNoSignal() 160 template <class T> T* MemoryChannel<T>::readChannel() in readChannel() [all …]
|
H A D | AsyncIoThread.hpp | 127 MemoryChannel<Request>::ListMember m_mem_channel; 168 MemoryChannel<Request> *theReportTo; 169 MemoryChannel<Request> *theMemoryChannelPtr; 170 MemoryChannel<Request> theMemoryChannel; // If file-bound
|
/dports/devel/spark/spark-2.1.1/external/flume/src/main/scala/org/apache/spark/streaming/flume/ |
H A D | PollingFlumeTestUtils.scala | 28 import org.apache.flume.channel.MemoryChannel 45 private val channels = new ArrayBuffer[MemoryChannel] 60 val channel = new MemoryChannel() 88 val channel = new MemoryChannel() 91 val channel2 = new MemoryChannel() 173 private def assertChannelIsEmpty(channel: MemoryChannel): Unit = { 189 private class TxnSubmitter(channel: MemoryChannel) extends Callable[Void] {
|
/dports/devel/spark/spark-2.1.1/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/ |
H A D | SparkSinkSuite.scala | 31 import org.apache.flume.channel.MemoryChannel 163 batchCounter: Int = 1): (MemoryChannel, SparkSink, CountDownLatch) = { 164 val channel = new MemoryChannel() 185 private def putEvents(ch: MemoryChannel, count: Int): Unit = { 208 private def assertChannelIsEmpty(channel: MemoryChannel): Unit = { 212 private def availableChannelSlots(channel: MemoryChannel): Int = {
|