/dports/devel/pecl-swoole/swoole-4.8.5/src/os/ |
H A D | file.cc | 117 size_t written_bytes = 0; in write_all() local 118 while (written_bytes < len) { in write_all() 121 n = write((char *) data + written_bytes, len - written_bytes); in write_all() 123 n = pwrite((char *) data + written_bytes, len - written_bytes, written_bytes); in write_all() 126 written_bytes += n; in write_all() 133 …oole_sys_warning("pwrite(%d, %p, %lu, %lu) failed", fd_, data, len - written_bytes, written_bytes); in write_all() 138 return written_bytes; in write_all()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/examples/word_count/ |
H A D | random_text_writer.cpp | 43 uint64_t written_bytes = 0; in Sequential() local 45 while (written_bytes < totalbytes) in Sequential() 56 if (written_bytes + out_size > totalbytes) break; in Sequential() 63 written_bytes += out_size; in Sequential() 80 uint64_t written_bytes = 0; in Parallel() local 81 while (written_bytes < totalbytes / num_workers) in Parallel() 92 if (written_bytes + out_size > totalbytes) break; in Parallel() 99 written_bytes += out_size; in Parallel()
|
/dports/devel/grpc134/grpc-1.34.1/test/core/iomgr/ |
H A D | tcp_posix_test.cc | 205 size_t written_bytes; in read_test() local 224 written_bytes = fill_socket_partial(sv[0], num_bytes); in read_test() 229 state.target_read_bytes = written_bytes; in read_test() 257 ssize_t written_bytes; in large_read_test() local 275 written_bytes = fill_socket(sv[0]); in large_read_test() 488 size_t written_bytes; in release_fd_test() local 514 written_bytes = fill_socket_partial(sv[0], num_bytes); in release_fd_test() 519 state.target_read_bytes = written_bytes; in release_fd_test() 554 drain_socket_blocking(fd, written_bytes, written_bytes); in release_fd_test() 555 written_bytes = fill_socket_partial(fd, num_bytes); in release_fd_test() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/test/core/iomgr/ |
H A D | tcp_posix_test.cc | 205 size_t written_bytes; in read_test() local 224 written_bytes = fill_socket_partial(sv[0], num_bytes); in read_test() 229 state.target_read_bytes = written_bytes; in read_test() 257 ssize_t written_bytes; in large_read_test() local 275 written_bytes = fill_socket(sv[0]); in large_read_test() 488 size_t written_bytes; in release_fd_test() local 514 written_bytes = fill_socket_partial(sv[0], num_bytes); in release_fd_test() 519 state.target_read_bytes = written_bytes; in release_fd_test() 554 drain_socket_blocking(fd, written_bytes, written_bytes); in release_fd_test() 555 written_bytes = fill_socket_partial(fd, num_bytes); in release_fd_test() [all …]
|
/dports/devel/grpc/grpc-1.42.0/test/core/iomgr/ |
H A D | tcp_posix_test.cc | 206 size_t written_bytes; in read_test() local 225 written_bytes = fill_socket_partial(sv[0], num_bytes); in read_test() 230 state.target_read_bytes = written_bytes; in read_test() 258 ssize_t written_bytes; in large_read_test() local 276 written_bytes = fill_socket(sv[0]); in large_read_test() 489 size_t written_bytes; in release_fd_test() local 515 written_bytes = fill_socket_partial(sv[0], num_bytes); in release_fd_test() 520 state.target_read_bytes = written_bytes; in release_fd_test() 555 drain_socket_blocking(fd, written_bytes, written_bytes); in release_fd_test() 556 written_bytes = fill_socket_partial(fd, num_bytes); in release_fd_test() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/iomgr/ |
H A D | tcp_posix_test.cc | 205 size_t written_bytes; in read_test() local 224 written_bytes = fill_socket_partial(sv[0], num_bytes); in read_test() 229 state.target_read_bytes = written_bytes; in read_test() 257 ssize_t written_bytes; in large_read_test() local 275 written_bytes = fill_socket(sv[0]); in large_read_test() 488 size_t written_bytes; in release_fd_test() local 514 written_bytes = fill_socket_partial(sv[0], num_bytes); in release_fd_test() 519 state.target_read_bytes = written_bytes; in release_fd_test() 554 drain_socket_blocking(fd, written_bytes, written_bytes); in release_fd_test() 555 written_bytes = fill_socket_partial(fd, num_bytes); in release_fd_test() [all …]
|
/dports/net/wireshark-lite/wireshark-3.6.1/ui/qt/utils/ |
H A D | rtp_audio_file.cpp | 95 void RtpAudioFile::frameUpdateRealCounters(qint64 written_bytes) in frameUpdateRealCounters() argument 99 qint64 diff = real_pos_ + written_bytes - real_size_; in frameUpdateRealCounters() 106 real_size_ += written_bytes; in frameUpdateRealCounters() 108 real_pos_ += written_bytes; in frameUpdateRealCounters() 111 void RtpAudioFile::frameUpdateSampleCounters(qint64 written_bytes) in frameUpdateSampleCounters() argument 115 qint64 diff = sample_pos_ + written_bytes - sample_size_; in frameUpdateSampleCounters() 122 sample_size_ += written_bytes; in frameUpdateSampleCounters() 124 sample_pos_ += written_bytes; in frameUpdateSampleCounters()
|
/dports/net/wireshark/wireshark-3.6.1/ui/qt/utils/ |
H A D | rtp_audio_file.cpp | 95 void RtpAudioFile::frameUpdateRealCounters(qint64 written_bytes) in frameUpdateRealCounters() argument 99 qint64 diff = real_pos_ + written_bytes - real_size_; in frameUpdateRealCounters() 106 real_size_ += written_bytes; in frameUpdateRealCounters() 108 real_pos_ += written_bytes; in frameUpdateRealCounters() 111 void RtpAudioFile::frameUpdateSampleCounters(qint64 written_bytes) in frameUpdateSampleCounters() argument 115 qint64 diff = sample_pos_ + written_bytes - sample_size_; in frameUpdateSampleCounters() 122 sample_size_ += written_bytes; in frameUpdateSampleCounters() 124 sample_pos_ += written_bytes; in frameUpdateSampleCounters()
|
/dports/net/tshark-lite/wireshark-3.6.1/ui/qt/utils/ |
H A D | rtp_audio_file.cpp | 95 void RtpAudioFile::frameUpdateRealCounters(qint64 written_bytes) in frameUpdateRealCounters() argument 99 qint64 diff = real_pos_ + written_bytes - real_size_; in frameUpdateRealCounters() 106 real_size_ += written_bytes; in frameUpdateRealCounters() 108 real_pos_ += written_bytes; in frameUpdateRealCounters() 111 void RtpAudioFile::frameUpdateSampleCounters(qint64 written_bytes) in frameUpdateSampleCounters() argument 115 qint64 diff = sample_pos_ + written_bytes - sample_size_; in frameUpdateSampleCounters() 122 sample_size_ += written_bytes; in frameUpdateSampleCounters() 124 sample_pos_ += written_bytes; in frameUpdateSampleCounters()
|
/dports/net/tshark/wireshark-3.6.1/ui/qt/utils/ |
H A D | rtp_audio_file.cpp | 95 void RtpAudioFile::frameUpdateRealCounters(qint64 written_bytes) in frameUpdateRealCounters() argument 99 qint64 diff = real_pos_ + written_bytes - real_size_; in frameUpdateRealCounters() 106 real_size_ += written_bytes; in frameUpdateRealCounters() 108 real_pos_ += written_bytes; in frameUpdateRealCounters() 111 void RtpAudioFile::frameUpdateSampleCounters(qint64 written_bytes) in frameUpdateSampleCounters() argument 115 qint64 diff = sample_pos_ + written_bytes - sample_size_; in frameUpdateSampleCounters() 122 sample_size_ += written_bytes; in frameUpdateSampleCounters() 124 sample_pos_ += written_bytes; in frameUpdateSampleCounters()
|
/dports/editors/poke/poke-1.0/jitter/jitter/ |
H A D | jitter-replicate.c | 487 size_t written_bytes = free_code - code; in jitter_replicate_program() local 534 jitter_executable_shrink_in_place (code, written_bytes); in jitter_replicate_program() 537 (long)written_bytes, (long)code_length, in jitter_replicate_program() 538 written_bytes / (double)code_length * 100.0); in jitter_replicate_program() 539 if (written_bytes > code_length) in jitter_replicate_program() 543 p->native_code_size = written_bytes; in jitter_replicate_program() 550 __builtin___clear_cache (code, code + written_bytes); in jitter_replicate_program() 552 jitter_invalidate_icache (code, written_bytes); in jitter_replicate_program()
|
/dports/sysutils/lizardfs/lizardfs-3.12.0/tests/test_suites/LongSystemTests/ |
H A D | test_xor_consistency.sh | 7 local written_bytes=0 9 while (( written_bytes < data_size_per_thread )); do 16 if (( written_bytes + file_size > data_size_per_thread + 200000000 )); then 30 : $(( written_bytes += file_size ))
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/fetch/ |
H A D | bytes_uploader.cc | 115 uint32_t written_bytes = base::saturated_cast<uint32_t>(available); in WriteDataOnPipe() local 117 buffer, &written_bytes, MOJO_WRITE_DATA_FLAG_NONE); in WriteDataOnPipe() 119 << ", mojo_written=" << written_bytes in WriteDataOnPipe() 132 consumer_result = consumer_->EndRead(written_bytes); in WriteDataOnPipe() 133 if (!base::CheckAdd(total_size_, written_bytes) in WriteDataOnPipe()
|
/dports/graphics/aseprite/aseprite-1.2.9/third_party/libarchive/libarchive/ |
H A D | archive_write_set_format_zip.c | 960 zip->written_bytes += 30; in archive_write_zip_header() 965 zip->written_bytes += ret; in archive_write_zip_header() 1069 zip->written_bytes += l; in archive_write_zip_data() 1076 zip->written_bytes += s; in archive_write_zip_data() 1206 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1213 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1312 zip->written_bytes += 56; in archive_write_zip_close() 1341 zip->written_bytes += 22; in archive_write_zip_close() 1427 size_t written_bytes; in write_path() local 1431 written_bytes = 0; in write_path() [all …]
|
/dports/archivers/libarchive/libarchive-3.5.2/libarchive/ |
H A D | archive_write_set_format_zip.c | 962 zip->written_bytes += 30; in archive_write_zip_header() 967 zip->written_bytes += ret; in archive_write_zip_header() 1072 zip->written_bytes += l; in archive_write_zip_data() 1079 zip->written_bytes += s; in archive_write_zip_data() 1210 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1217 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1316 zip->written_bytes += 56; in archive_write_zip_close() 1345 zip->written_bytes += 22; in archive_write_zip_close() 1448 size_t written_bytes; in write_path() local 1452 written_bytes = 0; in write_path() [all …]
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/innobase/xtrabackup/src/libarchive/libarchive/ |
H A D | archive_write_set_format_zip.c | 960 zip->written_bytes += 30; in archive_write_zip_header() 965 zip->written_bytes += ret; in archive_write_zip_header() 1069 zip->written_bytes += l; in archive_write_zip_data() 1076 zip->written_bytes += s; in archive_write_zip_data() 1206 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1213 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1312 zip->written_bytes += 56; in archive_write_zip_close() 1341 zip->written_bytes += 22; in archive_write_zip_close() 1427 size_t written_bytes; in write_path() local 1431 written_bytes = 0; in write_path() [all …]
|
/dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
H A D | archive_write_set_format_zip.c | 962 zip->written_bytes += 30; in archive_write_zip_header() 967 zip->written_bytes += ret; in archive_write_zip_header() 1072 zip->written_bytes += l; in archive_write_zip_data() 1079 zip->written_bytes += s; in archive_write_zip_data() 1210 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1217 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1316 zip->written_bytes += 56; in archive_write_zip_close() 1345 zip->written_bytes += 22; in archive_write_zip_close() 1448 size_t written_bytes; in write_path() local 1452 written_bytes = 0; in write_path() [all …]
|
/dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
H A D | archive_write_set_format_zip.c | 962 zip->written_bytes += 30; in archive_write_zip_header() 967 zip->written_bytes += ret; in archive_write_zip_header() 1072 zip->written_bytes += l; in archive_write_zip_data() 1079 zip->written_bytes += s; in archive_write_zip_data() 1210 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1217 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1316 zip->written_bytes += 56; in archive_write_zip_close() 1345 zip->written_bytes += 22; in archive_write_zip_close() 1448 size_t written_bytes; in write_path() local 1452 written_bytes = 0; in write_path() [all …]
|
/dports/devel/cmake/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
H A D | archive_write_set_format_zip.c | 962 zip->written_bytes += 30; in archive_write_zip_header() 967 zip->written_bytes += ret; in archive_write_zip_header() 1072 zip->written_bytes += l; in archive_write_zip_data() 1079 zip->written_bytes += s; in archive_write_zip_data() 1210 zip->written_bytes += 24; in archive_write_zip_finish_entry() 1217 zip->written_bytes += 16; in archive_write_zip_finish_entry() 1316 zip->written_bytes += 56; in archive_write_zip_close() 1345 zip->written_bytes += 22; in archive_write_zip_close() 1448 size_t written_bytes; in write_path() local 1452 written_bytes = 0; in write_path() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/native_io/ |
H A D | native_io_file.cc | 345 int written_bytes; in DoWrite() local 351 written_bytes = file_state->file.Write(file_offset, write_data, write_size); in DoWrite() 352 write_error = (written_bytes < 0) ? file_state->file.GetLastFileError() in DoWrite() 359 std::move(resolver), written_bytes, write_error)); in DoWrite() 364 int written_bytes, in DidWrite() argument 376 if (written_bytes < 0) { in DidWrite() 382 resolver->Resolve(written_bytes); in DidWrite()
|
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/bq/third_party/rsa/ |
H A D | varblock.py | 90 written_bytes = 0 99 written_bytes += 1 101 return written_bytes
|
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/python/rsa/rsa/ |
H A D | varblock.py | 89 written_bytes = 0 98 written_bytes += 1 100 return written_bytes
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/tools/swarming_client/third_party/rsa/rsa/ |
H A D | varblock.py | 89 written_bytes = 0 98 written_bytes += 1 100 return written_bytes
|
/dports/www/firefox/firefox-99.0/third_party/python/rsa/rsa/ |
H A D | varblock.py | 89 written_bytes = 0 98 written_bytes += 1 100 return written_bytes
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/python/rsa/rsa/ |
H A D | varblock.py | 89 written_bytes = 0 98 written_bytes += 1 100 return written_bytes
|