/dports/games/hedgewars-server/hedgewars-src-1.0.0/project_files/frontlib/ipc/ |
H A D | ipcbase.c | 39 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 D | ipcbase.c | 39 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 D | CompoundFileReader.cs | 37 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 D | SegmentReader.cs | 52 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 D | CompoundFileReader.cpp | 16 …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 D | SegmentReader.cpp | 44 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 D | DbVerifyLog.java | 54 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 D | DbPrintLog.java | 61 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 D | FeederReaderTest.java | 85 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 D | FileSource.java | 23 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 D | FileReader.java | 90 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 D | ScavengerFileReader.java | 39 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 D | FeederReader.java | 70 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 D | SegmentReader.cpp | 137 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 D | NGBufferedStream.m | 77 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 D | NGBufferedStream.m | 77 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 D | NGBufferedDescriptor.c | 31 ((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 D | NGBufferedDescriptor.c | 31 ((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 D | CompoundFileReader.h | 21 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 D | tst_qabstractsocket.cpp | 87 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 D | Driver.php | 82 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 D | PhutilChannel.php | 35 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 D | PhutilChannel.php | 35 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 D | AbstractAudioReader.cpp | 185 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 D | FramingHandler.h | 75 void setReadBufferSize(size_t readBufferSize, bool strict = false) { 77 ? readBufferSize 78 : std::max<size_t>(readBufferSize, DEFAULT_BUFFER_SIZE);
|