Home
last modified time | relevance | path

Searched refs:writeSize (Results 1 – 25 of 762) sorted by relevance

12345678910>>...31

/dports/lang/mosh/mosh-0.2.7/src/
H A DBlockBufferedFileBinaryInputOutputPort.h54 int64_t writeSize = 0; in writeToBuffer() local
59 while (writeSize < reqSize) { in writeToBuffer()
62 MOSH_ASSERT(reqSize > writeSize); in writeToBuffer()
63 const int64_t restSize = reqSize - writeSize; in writeToBuffer()
65 moshMemcpy(buffer_ + bufferIndex_, data + writeSize, restSize); in writeToBuffer()
67 writeSize += restSize; in writeToBuffer()
69 moshMemcpy(buffer_ + bufferIndex_, data + writeSize, bufferRestSize); in writeToBuffer()
71 writeSize += bufferRestSize; in writeToBuffer()
79 return writeSize; in writeToBuffer()
H A DBlockBufferedFileBinaryOutputPort.h56 int64_t writeSize = 0; in writeToBuffer() local
57 while (writeSize < reqSize) { in writeToBuffer()
60 MOSH_ASSERT(reqSize > writeSize); in writeToBuffer()
61 const int64_t sizeDiff = reqSize - writeSize; in writeToBuffer()
63 moshMemcpy(buffer_+bufIdx_, data+writeSize, sizeDiff); in writeToBuffer()
65 writeSize += sizeDiff; in writeToBuffer()
67 moshMemcpy(buffer_+bufIdx_, data+writeSize, bufDiff); in writeToBuffer()
69 writeSize += bufDiff; in writeToBuffer()
73 return writeSize; in writeToBuffer()
H A DLineBufferedFileBinaryOutputPort.h56 int64_t writeSize = 0; in writeToBuffer() local
57 while (writeSize < reqSize) { in writeToBuffer()
62 *(buffer_+bufIdx_) = *(data+writeSize); in writeToBuffer()
64 writeSize++; in writeToBuffer()
70 return writeSize; in writeToBuffer()
H A DLineBufferedFileBinaryInputOutputPort.h56 int64_t writeSize = 0; in writeToBuffer() local
57 while (writeSize < reqSize) { in writeToBuffer()
63 *(buffer_+bufferIndex_) = *(data+writeSize); in writeToBuffer()
65 writeSize++; in writeToBuffer()
74 return writeSize; in writeToBuffer()
/dports/devel/php-ice37/ice-3.7.2/csharp/src/Ice/
H A DOutputStream.cs440 writeSize(0); in writePendingValues()
587 writeSize(0); in writeByteSeq()
606 writeSize(0); in writeByteSeq()
652 writeSize(count); in writeByteSeq()
723 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
813 writeSize(0); in writeBoolSeq()
859 writeSize(count); in writeBoolSeq()
967 writeSize(0); in writeShortSeq()
986 writeSize(0); in writeShortSeq()
[all …]
/dports/devel/ice37/ice-3.7.2/csharp/src/Ice/
H A DOutputStream.cs440 writeSize(0); in writePendingValues()
587 writeSize(0); in writeByteSeq()
606 writeSize(0); in writeByteSeq()
652 writeSize(count); in writeByteSeq()
723 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
813 writeSize(0); in writeBoolSeq()
859 writeSize(count); in writeBoolSeq()
967 writeSize(0); in writeShortSeq()
986 writeSize(0); in writeShortSeq()
[all …]
/dports/devel/py-ice37/ice-3.7.2/csharp/src/Ice/
H A DOutputStream.cs440 writeSize(0); in writePendingValues()
587 writeSize(0); in writeByteSeq()
606 writeSize(0); in writeByteSeq()
652 writeSize(count); in writeByteSeq()
723 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
813 writeSize(0); in writeBoolSeq()
859 writeSize(count); in writeBoolSeq()
967 writeSize(0); in writeShortSeq()
986 writeSize(0); in writeShortSeq()
[all …]
/dports/www/trafficserver/trafficserver-9.1.1/iocore/eventsystem/
H A DMIOBufferWriter.cc50 size_t writeSize = iobbPtr->write_avail(); in write() local
52 if (length < writeSize) { in write()
53 writeSize = length; in write()
56 std::memcpy(iobbPtr->end(), data, writeSize); in write()
57 iobbPtr->fill(writeSize); in write()
59 data += writeSize; in write()
60 length -= writeSize; in write()
62 _numWritten += writeSize; in write()
/dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DOutputStream.java490 writeSize(0); in writePendingValues()
651 writeSize(0); in writeByteSeq()
698 writeSize(0); in writeByteBuffer()
717 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
884 writeSize(0); in writeShortSeq()
934 writeSize(0); in writeShortBuffer()
1008 writeSize(0); in writeIntSeq()
1058 writeSize(0); in writeIntBuffer()
1121 writeSize(0); in writeLongSeq()
[all …]
/dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DOutputStream.java490 writeSize(0); in writePendingValues()
651 writeSize(0); in writeByteSeq()
698 writeSize(0); in writeByteBuffer()
717 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
884 writeSize(0); in writeShortSeq()
934 writeSize(0); in writeShortBuffer()
1008 writeSize(0); in writeIntSeq()
1058 writeSize(0); in writeIntBuffer()
1121 writeSize(0); in writeLongSeq()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DOutputStream.java490 writeSize(0); in writePendingValues()
651 writeSize(0); in writeByteSeq()
698 writeSize(0); in writeByteBuffer()
717 writeSize(0); in writeSerializable()
794 writeSize(0); in writeBoolSeq()
884 writeSize(0); in writeShortSeq()
934 writeSize(0); in writeShortBuffer()
1008 writeSize(0); in writeIntSeq()
1058 writeSize(0); in writeIntBuffer()
1121 writeSize(0); in writeLongSeq()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/
H A DAsyncFileWrite.actor.cpp40 int writeSize; member
52 writeSize = getOption(options, LiteralStringRef("writeSize"), _PAGE_SIZE); in AsyncFileWriteWorkload()
75 if(self->unbufferedIO && self->writeSize % AsyncFileWorkload::_PAGE_SIZE != 0) in _setup()
76 …self->writeSize = std::max(AsyncFileWorkload::_PAGE_SIZE, self->writeSize - self->writeSize % Asyn… in _setup()
79 self->writeBuffer = self->allocateBuffer(self->writeSize); in _setup()
136 …eHandle->file->write(self->writeBuffer->buffer, std::min((int64_t)self->writeSize, self->fileSize … in runWriteTest()
143 offset += self->writeSize; in runWriteTest()
161 self->bytesWritten += self->writeSize * self->numParallelWrites; in runWriteTest()
/dports/devel/ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DOutputStream.java497 writeSize(0); in writePendingValues()
658 writeSize(0); in writeByteSeq()
705 writeSize(0); in writeByteBuffer()
724 writeSize(0); in writeSerializable()
830 writeSize(0); in writeBoolSeq()
920 writeSize(0); in writeShortSeq()
970 writeSize(0); in writeShortBuffer()
1044 writeSize(0); in writeIntSeq()
1094 writeSize(0); in writeIntBuffer()
1157 writeSize(0); in writeLongSeq()
[all …]
/dports/devel/php-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DOutputStream.java497 writeSize(0);
658 writeSize(0);
705 writeSize(0);
724 writeSize(0);
830 writeSize(0);
920 writeSize(0);
970 writeSize(0);
1044 writeSize(0);
1094 writeSize(0);
1157 writeSize(0);
[all …]
/dports/devel/py-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DOutputStream.java497 writeSize(0); in writePendingValues()
658 writeSize(0); in writeByteSeq()
705 writeSize(0); in writeByteBuffer()
724 writeSize(0); in writeSerializable()
830 writeSize(0); in writeBoolSeq()
920 writeSize(0); in writeShortSeq()
970 writeSize(0); in writeShortBuffer()
1044 writeSize(0); in writeIntSeq()
1094 writeSize(0); in writeIntBuffer()
1157 writeSize(0); in writeLongSeq()
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/bulk/
H A Dwe_colbuf.cpp107 int ColumnBuffer::writeToFile(int startOffset, int writeSize, bool fillUpWEmpties) in writeToFile() argument
109 if (writeSize == 0) // skip unnecessary write, if 0 bytes given in writeToFile()
121 static_cast<const void *>(fBuffer + startOffset), writeSize); in writeToFile()
122 blockOp.setEmptyBuf(newBuf + writeSize, BYTE_PER_BLOCK - writeSize, in writeToFile()
132 nitems = fFile->write(fBuffer + startOffset, writeSize) / writeSize; in writeToFile()
H A Dwe_colbufmgr.cpp473 unsigned int writeSize = in writeToFile() local
480 if (writeSize < BLOCK_SIZE) in writeToFile()
483 writeSize = writeSize - writeSize % BLOCK_SIZE; //round down to mult of blksiz in writeToFile()
484 endOffset = (fBufWriteOffset + writeSize - 1) % bufferSize; in writeToFile()
493 "; bytesToWrite-" << writeSize << in writeToFile()
534 uint32_t startOffset, uint32_t writeSize, bool fillUpWEmpties) in writeToFileExtentCheck() argument
545 "; Wanting to write " << writeSize << in writeToFileExtentCheck()
574 if (availableFileSize >= writeSize) in writeToFileExtentCheck()
591 writeSize = BLOCK_SIZE; in writeToFileExtentCheck()
594 fColInfo->updateBytesWrittenCounts( writeSize ); in writeToFileExtentCheck()
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/bulk/
H A Dwe_colbuf.cpp107 int ColumnBuffer::writeToFile(int startOffset, int writeSize, bool fillUpWEmpties) in writeToFile() argument
109 if (writeSize == 0) // skip unnecessary write, if 0 bytes given in writeToFile()
121 static_cast<const void *>(fBuffer + startOffset), writeSize); in writeToFile()
122 blockOp.setEmptyBuf(newBuf + writeSize, BYTE_PER_BLOCK - writeSize, in writeToFile()
132 nitems = fFile->write(fBuffer + startOffset, writeSize) / writeSize; in writeToFile()
H A Dwe_colbufmgr.cpp473 unsigned int writeSize = in writeToFile() local
480 if (writeSize < BLOCK_SIZE) in writeToFile()
483 writeSize = writeSize - writeSize % BLOCK_SIZE; //round down to mult of blksiz in writeToFile()
484 endOffset = (fBufWriteOffset + writeSize - 1) % bufferSize; in writeToFile()
493 "; bytesToWrite-" << writeSize << in writeToFile()
534 uint32_t startOffset, uint32_t writeSize, bool fillUpWEmpties) in writeToFileExtentCheck() argument
545 "; Wanting to write " << writeSize << in writeToFileExtentCheck()
574 if (availableFileSize >= writeSize) in writeToFileExtentCheck()
591 writeSize = BLOCK_SIZE; in writeToFileExtentCheck()
594 fColInfo->updateBytesWrittenCounts( writeSize ); in writeToFileExtentCheck()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/
H A DTimeBasedLimiter.java116 public void checkQuota(long writeSize, long readSize) throws ThrottlingException { in checkQuota() argument
120 if (!reqSizeLimiter.canExecute(writeSize + readSize)) { in checkQuota()
122 .waitInterval(writeSize + readSize)); in checkQuota()
125 if (writeSize > 0) { in checkQuota()
129 if (!writeSizeLimiter.canExecute(writeSize)) { in checkQuota()
130 ThrottlingException.throwWriteSizeExceeded(writeSizeLimiter.waitInterval(writeSize)); in checkQuota()
145 public void grabQuota(long writeSize, long readSize) { in grabQuota() argument
146 assert writeSize != 0 || readSize != 0; in grabQuota()
149 reqSizeLimiter.consume(writeSize + readSize); in grabQuota()
151 if (writeSize > 0) { in grabQuota()
[all …]
/dports/net/freerdp/freerdp-2.5.0/winpr/libwinpr/utils/collections/
H A DBipBuffer.c228 size_t writeSize = 0; in BipBuffer_Write() local
249 writeSize = size - status; in BipBuffer_Write()
251 if (writeSize > blockSize) in BipBuffer_Write()
252 writeSize = blockSize; in BipBuffer_Write()
255 BipBuffer_WriteCommit(bb, writeSize); in BipBuffer_Write()
256 status += writeSize; in BipBuffer_Write()
266 writeSize = size - status; in BipBuffer_Write()
268 if (writeSize > blockSize) in BipBuffer_Write()
269 writeSize = blockSize; in BipBuffer_Write()
272 BipBuffer_WriteCommit(bb, writeSize); in BipBuffer_Write()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.IO/tests/StreamWriter/
H A DStreamWriter.WriteTests.netcoreapp.cs70 …public void Write_Span_WritesExpectedData(int length, int writeSize, int writerBufferSize, bool au… in Write_Span_WritesExpectedData() argument
85 int n = Math.Min(source.Length, writeSize); in Write_Span_WritesExpectedData()
103 …public async Task Write_Memory_WritesExpectedData(int length, int writeSize, int writerBufferSize,… in Write_Memory_WritesExpectedData() argument
118 int n = Math.Min(source.Length, writeSize); in Write_Memory_WritesExpectedData()
136 …public void WriteLine_Span_WritesExpectedData(int length, int writeSize, int writerBufferSize, boo… in WriteLine_Span_WritesExpectedData() argument
151 int n = Math.Min(source.Length, writeSize); in WriteLine_Span_WritesExpectedData()
158 … Assert.Equal(length + (Environment.NewLine.Length * (length / writeSize)), s.Length); in WriteLine_Span_WritesExpectedData()
169 …public async Task WriteLineAsync_Memory_WritesExpectedData(int length, int writeSize, int writerBu… in WriteLineAsync_Memory_WritesExpectedData() argument
184 int n = Math.Min(source.Length, writeSize); in WriteLineAsync_Memory_WritesExpectedData()
191 … Assert.Equal(length + (Environment.NewLine.Length * (length / writeSize)), s.Length); in WriteLineAsync_Memory_WritesExpectedData()
/dports/sysutils/zeroer/zeroer-0.1/
H A Dzeroer.c41 int writeSize=buffersize; in blockWriteLoop() local
44 while(writeSize > 0) { in blockWriteLoop()
48 writeSize in blockWriteLoop()
50 fwrite((void *)pBuf, (size_t)sizeof(char), writeSize, f); in blockWriteLoop()
54 writeSize=writeSize/2; in blockWriteLoop()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/angle/third_party/VK-GL-CTS/src/framework/delibs/destream/
H A DdeRingbuffer.c130 deInt32 writeSize = 0; in producerStream_write() local
140 writeSize = deMin32(ringbuffer->blockSize - ringbuffer->inPos, bufSize - *written); in producerStream_write()
144 deMemcpy(dst, src, (size_t)writeSize); in producerStream_write()
146 ringbuffer->inPos += writeSize; in producerStream_write()
147 *written += writeSize; in producerStream_write()
148 ringbuffer->blockUsage[ringbuffer->inBlock] += writeSize; in producerStream_write()
206 deInt32 writeSize = 0; in consumerStream_read() local
237 …writeSize = deMin32(ringbuffer->blockUsage[ringbuffer->outBlock] - ringbuffer->outPos, bufSize - *… in consumerStream_read()
241 deMemcpy(dst, src, (size_t)writeSize); in consumerStream_read()
243 ringbuffer->outPos += writeSize; in consumerStream_read()
[all …]
/dports/devel/ptlib/ptlib-2.10.11/samples/queue/
H A Dmain.cxx109 writeSize = 320; in Main()
119 writeSize = args.GetOptionString('s').AsInteger(); in Main()
126 values << " Write " << writeSize << " bytes per loop, delay " << writeDelay << " ms" << endl; in Main()
157 BYTE buffer[writeSize]; in GenerateBlockData()
163 queue.Write(buffer, writeSize); in GenerateBlockData()
164 PTRACE(3, "Write " << writeSize << " bytes to the queue (" in GenerateBlockData()
166 << " " << (count * writeSize)); in GenerateBlockData()

12345678910>>...31