Home
last modified time | relevance | path

Searched refs:readBufferSize (Results 1 – 25 of 1095) sorted by relevance

12345678910>>...44

/dports/games/hedgewars-server/hedgewars-src-1.0.0/project_files/frontlib/ipc/
H A Dipcbase.c39 int readBufferSize; member
59 result->readBufferSize = 0; in flib_ipcbase_create()
98 …_socket_nbrecv(ipc->sock, ipc->readBuffer+ipc->readBufferSize, sizeof(ipc->readBuffer)-ipc->readBu… in receiveToBuffer()
100 ipc->readBufferSize += size; in receiveToBuffer()
110 return ipc->readBufferSize >= ipc->readBuffer[0]+1; in isMessageReady()
138 memmove(ipc->readBuffer, ipc->readBuffer+size, ipc->readBufferSize-size); in popFromReadBuffer()
139 ipc->readBufferSize -= size; in popFromReadBuffer()
156 } else if(!ipc->sock && ipc->readBufferSize>0) { in flib_ipcbase_recv_message()
157 …data stream is incomplete (received %u of %u bytes)", (unsigned)ipc->readBufferSize, (unsigned)(ip… in flib_ipcbase_recv_message()
158 ipc->readBufferSize = 0; in flib_ipcbase_recv_message()
[all …]
/dports/games/hedgewars/hedgewars-src-1.0.0/project_files/frontlib/ipc/
H A Dipcbase.c39 int readBufferSize; member
59 result->readBufferSize = 0; in flib_ipcbase_create()
98 …_socket_nbrecv(ipc->sock, ipc->readBuffer+ipc->readBufferSize, sizeof(ipc->readBuffer)-ipc->readBu… in receiveToBuffer()
100 ipc->readBufferSize += size; in receiveToBuffer()
110 return ipc->readBufferSize >= ipc->readBuffer[0]+1; in isMessageReady()
138 memmove(ipc->readBuffer, ipc->readBuffer+size, ipc->readBufferSize-size); in popFromReadBuffer()
139 ipc->readBufferSize -= size; in popFromReadBuffer()
156 } else if(!ipc->sock && ipc->readBufferSize>0) { in flib_ipcbase_recv_message()
157 …data stream is incomplete (received %u of %u bytes)", (unsigned)ipc->readBufferSize, (unsigned)(ip… in flib_ipcbase_recv_message()
158 ipc->readBufferSize = 0; in flib_ipcbase_recv_message()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/api-doc-tools/external/Lucene.Net.Light/src/core/Index/
H A DCompoundFileReader.cs37 private readonly int readBufferSize; field in Lucene.Net.Index.CompoundFileReader
59 public CompoundFileReader(Directory dir, System.String name, int readBufferSize) in CompoundFileReader() argument
63 this.readBufferSize = readBufferSize; in CompoundFileReader()
69 stream = dir.OpenInput(name, readBufferSize); in CompoundFileReader()
150 return OpenInput(id, readBufferSize); in OpenInput()
154 public override IndexInput OpenInput(System.String id, int readBufferSize) in OpenInput() argument
165 return new CSIndexInput(stream, entry.offset, entry.length, readBufferSize); in OpenInput()
248 …IndexInput(IndexInput @base, long fileOffset, long length, int readBufferSize):base(readBufferSize) in base() argument
H A DSegmentReader.cs52 private int readBufferSize; field in Lucene.Net.Index.SegmentReader
96 internal int readBufferSize; field in Lucene.Net.Index.SegmentReader.CoreReaders
110 this.readBufferSize = readBufferSize; in CoreReaders()
141 freqStream = cfsDir.OpenInput(segment + "." + IndexFileNames.FREQ_EXTENSION, readBufferSize); in CoreReaders()
246 tis = new TermInfosReader(dir0, segment, fieldInfos, readBufferSize, termsIndexDivisor); in LoadTermsIndex()
773 instance.readBufferSize = readBufferSize; in Get()
779 instance.core = new CoreReaders(instance, dir, si, readBufferSize, termInfosIndexDivisor); in Get()
785 instance.OpenNorms(instance.core.cfsDir, readBufferSize); in Get()
923 clone.readBufferSize = readBufferSize; in ReopenSegment()
1380 private void OpenNorms(Directory cfsDir, int readBufferSize) in OpenNorms() argument
[all …]
/dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/core/index/
H A DCompoundFileReader.cpp16 …leReader::CompoundFileReader(const DirectoryPtr& dir, const String& name, int32_t readBufferSize) { in CompoundFileReader() argument
17 ConstructReader(dir, name, readBufferSize); in CompoundFileReader()
23 …dFileReader::ConstructReader(const DirectoryPtr& dir, const String& name, int32_t readBufferSize) { in ConstructReader() argument
26 this->readBufferSize = readBufferSize; in ConstructReader()
33 stream = dir->openInput(name, readBufferSize); in ConstructReader()
95 return openInput(name, readBufferSize); in openInput()
109 …turn newLucene<CSIndexInput>(stream, entry->second->offset, entry->second->length, readBufferSize); in openInput()
169 … base, int64_t fileOffset, int64_t length, int32_t readBufferSize) : BufferedIndexInput(readBuffer… in CSIndexInput() argument
H A DSegmentReader.cpp44 readBufferSize = 0; in SegmentReader()
64 instance->readBufferSize = readBufferSize; in get()
69 … instance->core = newLucene<CoreReaders>(instance, dir, si, readBufferSize, termInfosIndexDivisor); in get()
74 instance->openNorms(instance->core->cfsDir, readBufferSize); in get()
176 clone->readBufferSize = readBufferSize; in reopenSegment()
222 … clone->openNorms(si->getUseCompoundFile() ? core->getCFSReader() : directory(), readBufferSize); in reopenSegment()
514 void SegmentReader::openNorms(const DirectoryPtr& cfsDir, int32_t readBufferSize) { in openNorms() argument
539 singleNormStream = d->openInput(fileName, readBufferSize); in openNorms()
742 this->readBufferSize = readBufferSize; in CoreReaders()
767 … freqStream = cfsDir->openInput(segment + L"." + IndexFileNames::FREQ_EXTENSION(), readBufferSize); in CoreReaders()
[all …]
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/util/
H A DDbVerifyLog.java54 private final int readBufferSize; field in DbVerifyLog
83 public DbVerifyLog(final Environment env, final int readBufferSize) { in DbVerifyLog() argument
84 this(DbInternal.getEnvironmentImpl(env), readBufferSize); in DbVerifyLog()
88 final int readBufferSize) { in DbVerifyLog() argument
89 this.readBufferSize = (readBufferSize > 0) ? in DbVerifyLog()
90 readBufferSize : in DbVerifyLog()
136 final byte[] buf = new byte[readBufferSize]; in verify()
H A DDbPrintLog.java61 int readBufferSize = in dump() local
70 new LastFileReader(env, readBufferSize); in dump()
86 readBufferSize, startLsn, endLsn, in dump()
91 reader = new StatsFileReader(env, readBufferSize, startLsn, in dump()
96 reader = new VLSNDistributionReader(env, readBufferSize, in dump()
101 reader = new PrintFileReader(env, readBufferSize, startLsn, in dump()
306 int readBufferSize, in getDebugReader() argument
340 readBufferSize, in getDebugReader()
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/stream/
H A DFeederReaderTest.java85 for (int readBufferSize = 100; in testForwardScans()
86 readBufferSize < 2000; in testForwardScans()
87 readBufferSize += 100) { in testForwardScans()
92 readBufferSize, in testForwardScans()
345 readBufferSize, in checkBackwardScan()
353 readBufferSize, in checkBackwardScan()
419 int readBufferSize) in checkSyncScan() argument
430 readBufferSize, in checkSyncScan()
563 for (int readBufferSize = 100; in testSwitchFetch()
564 readBufferSize < 2000; in testSwitchFetch()
[all …]
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/log/
H A DFileSource.java23 private final int readBufferSize; field in FileSource
29 int readBufferSize, in FileSource() argument
34 this.readBufferSize = readBufferSize; in FileSource()
55 ByteBuffer destBuf = ByteBuffer.allocate(readBufferSize); in getBytes()
H A DFileReader.java90 int readBufferSize, in FileReader() argument
108 window = makeWindow(readBufferSize); in FileReader()
109 saveBuffer = ByteBuffer.allocate(readBufferSize); in FileReader()
127 protected ReadWindow makeWindow(int readBufferSize) in makeWindow() argument
130 return new ReadWindow(readBufferSize, envImpl); in makeWindow()
1197 int readBufferSize = readBuffer.capacity(); in adjustReadBufferSize() local
1203 if (amountToRead > readBufferSize) { in adjustReadBufferSize()
1206 if (readBufferSize < maxReadBufferSize) { in adjustReadBufferSize()
1213 readBufferSize = amountToRead; in adjustReadBufferSize()
1216 readBufferSize += 1024 - remainder; in adjustReadBufferSize()
[all …]
H A DScavengerFileReader.java39 private int readBufferSize; field in ScavengerFileReader
48 int readBufferSize, in ScavengerFileReader() argument
55 readBufferSize, in ScavengerFileReader()
62 this.readBufferSize = readBufferSize; in ScavengerFileReader()
162 new LastFileReader(envImpl, readBufferSize, in resyncReader()
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/stream/
H A DFeederReader.java70 int readBufferSize, in FeederReader() argument
73 this(envImpl, vlsnIndex, startLsn, readBufferSize, nameIdPair, in FeederReader()
83 int readBufferSize) { in FeederReader() argument
85 this(envImpl, vlsnIndex, startLsn, readBufferSize, in FeederReader()
93 int readBufferSize, in FeederReader() argument
100 readBufferSize, in FeederReader()
114 protected ReadWindow makeWindow(int readBufferSize) { in makeWindow() argument
116 return new SwitchWindow(readBufferSize, envImpl); in makeWindow()
326 SwitchWindow(int readBufferSize, EnvironmentImpl envImpl) { in SwitchWindow() argument
327 super(readBufferSize, envImpl); in SwitchWindow()
/dports/textproc/clucene/clucene-core-2.3.3.4/src/core/CLucene/index/
H A DSegmentReader.cpp137 this->readBufferSize = readBufferSize; in initialize()
193 tis = _CLNEW TermInfosReader(cfsDir, segment.c_str(), _fieldInfos, readBufferSize); in initialize()
199 freqStream = cfsDir->openInput( (segment + ".frq").c_str(), readBufferSize); in initialize()
200 proxStream = cfsDir->openInput( (segment + ".prx").c_str(), readBufferSize); in initialize()
201 openNorms(cfsDir, readBufferSize); in initialize()
230 return get(si->dir, si, NULL, false, false, readBufferSize, doOpenStores); in get()
243 int32_t readBufferSize, in get() argument
247 …instance->initialize(si, readBufferSize==-1 ? BufferedIndexInput::BUFFER_SIZE : readBufferSize, do… in get()
765 void SegmentReader::openNorms(Directory* cfsDir, int32_t readBufferSize) { in openNorms() argument
797 singleNormStream = d->openInput(fileName.c_str(), readBufferSize); in openNorms()
[all …]
/dports/devel/sope2/SOPE/sope-core/NGStreams/
H A DNGBufferedStream.m77 self->readBufferSize = _size;
99 self->readBufferSize = _s;
143 self->readBufferSize = 0;
159 if (_size == self->readBufferSize)
167 self->readBufferSize = _size;
176 self->readBufferSize = _size;
181 - (unsigned)readBufferSize { method in self
182 return self->readBufferSize;
203 if (self->readBufferSize == 0)
257 else if (_len > self->readBufferSize) {
[all …]
/dports/devel/sope/SOPE/sope-core/NGStreams/
H A DNGBufferedStream.m77 self->readBufferSize = _size;
99 self->readBufferSize = _s;
143 self->readBufferSize = 0;
159 if (_size == self->readBufferSize)
167 self->readBufferSize = _size;
176 self->readBufferSize = _size;
181 - (unsigned)readBufferSize { method in self
182 return self->readBufferSize;
203 if (self->readBufferSize == 0)
257 else if (_len > self->readBufferSize) {
[all …]
/dports/devel/sope/SOPE/sope-appserver/mod_ngobjweb/
H A DNGBufferedDescriptor.c31 ((self->readBufferSize == 0) ? 0 : (self->readBufferPos - self->readBuffer))
55 self->readBufferSize = _size; in NGBufferedDescriptor_newWithDescriptorAndSize()
93 self->readBufferSize = 0; in NGBufferedDescriptor_free()
108 return self->readBufferSize; in NGBufferedDescriptor_getReadBufferSize()
122 if (self->readBufferSize == 0) // no read buffering is done (buffersize==0) in NGBufferedDescriptor_read()
147 else if (_len > self->readBufferSize) { in NGBufferedDescriptor_read()
157 self->readBuffer, self->readBufferSize); in NGBufferedDescriptor_read()
/dports/devel/sope2/SOPE/sope-appserver/mod_ngobjweb/
H A DNGBufferedDescriptor.c31 ((self->readBufferSize == 0) ? 0 : (self->readBufferPos - self->readBuffer))
55 self->readBufferSize = _size; in NGBufferedDescriptor_newWithDescriptorAndSize()
93 self->readBufferSize = 0; in NGBufferedDescriptor_free()
108 return self->readBufferSize; in NGBufferedDescriptor_getReadBufferSize()
122 if (self->readBufferSize == 0) // no read buffering is done (buffersize==0) in NGBufferedDescriptor_read()
147 else if (_len > self->readBufferSize) { in NGBufferedDescriptor_read()
157 self->readBuffer, self->readBufferSize); in NGBufferedDescriptor_read()
/dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/include/lucene++/
H A DCompoundFileReader.h21 CompoundFileReader(const DirectoryPtr& dir, const String& name, int32_t readBufferSize);
40 int32_t readBufferSize; variable
45 void ConstructReader(const DirectoryPtr& dir, const String& name, int32_t readBufferSize);
87 …SIndexInput(const IndexInputPtr& base, int64_t fileOffset, int64_t length, int32_t readBufferSize);
/dports/converters/wkhtmltopdf/qt-5db36ec/tests/auto/qabstractsocket/
H A Dtst_qabstractsocket.cpp87 QCOMPARE(qint64(0), obj1.readBufferSize()); in getSetCheck()
89 QCOMPARE((Q_INT64_C(-9223372036854775807) - 1), obj1.readBufferSize()); in getSetCheck()
91 QCOMPARE(Q_INT64_C(9223372036854775807), obj1.readBufferSize()); in getSetCheck()
/dports/net/pear-Net_Server/Net_Server-1.0.3/Net/Server/
H A DDriver.php82 var $readBufferSize = 128; variable in Net_Server_Driver
245 $lookInData = strlen($this->readEndCharacter) > $this->readBufferSize;
247 $extraDataLength = strlen($this->readEndCharacter) - $this->readBufferSize;
254 $this->clientFD[$clientId], $this->readBufferSize
/dports/devel/arcanist/arcanist-b2e715f/src/channel/
H A DPhutilChannel.php35 private $readBufferSize; variable in PhutilChannel
214 if ($this->readBufferSize !== null) {
215 $maximum_read = ($this->readBufferSize - strlen($this->ibuf));
369 $this->readBufferSize = $size;
/dports/devel/arcanist-lib/arcanist-b2e715f/src/channel/
H A DPhutilChannel.php35 private $readBufferSize; variable in PhutilChannel
214 if ($this->readBufferSize !== null) {
215 $maximum_read = ($this->readBufferSize - strlen($this->ibuf));
369 $this->readBufferSize = $size;
/dports/audio/traverso/traverso-0.49.6/src/audiofileio/decode/
H A DAbstractAudioReader.cpp185 m_channels = destinationBufferSize = readBufferSize = 0; in DecodeBuffer()
224 if (readBufferSize < (size*m_channels)) { in check_buffers_capacity()
229 readBufferSize = (size*m_channels); in check_buffers_capacity()
255 readBufferSize = 0; in delete_readbuffer()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/
H A DFramingHandler.h75 void setReadBufferSize(size_t readBufferSize, bool strict = false) {
77 ? readBufferSize
78 : std::max<size_t>(readBufferSize, DEFAULT_BUFFER_SIZE);

12345678910>>...44