Home
last modified time | relevance | path

Searched refs:MemoryChannel (Results 1 – 25 of 62) sorted by relevance

123

/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/kernel/blocks/ndbfs/
H A DMemoryChannel.hpp76 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 DMemoryChannel.hpp82 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 DAsyncIoThread.hpp127 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 DMemoryChannel.hpp82 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 DAsyncIoThread.hpp127 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 DMemoryChannel.hpp82 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 DAsyncIoThread.hpp127 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp130 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp137 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp130 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp130 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp130 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 DMemoryChannel.hpp85 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 DAsyncIoThread.hpp130 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 DMemoryChannel.hpp82 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 DAsyncIoThread.hpp127 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 DMemoryChannel.hpp82 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 DAsyncIoThread.hpp127 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 DPollingFlumeTestUtils.scala28 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 DSparkSinkSuite.scala31 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 = {

123