/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
H A D | db_impl.h | 487 WriteBatch* my_batch, 1078 WriteBatch* my_batch, WriteCallback* callback, 1380 WriteBatch* my_batch);
|
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
H A D | db_impl.h | 487 WriteBatch* my_batch, 1077 WriteBatch* my_batch, WriteCallback* callback, 1384 WriteBatch* my_batch);
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 57 WriteBatch* my_batch, in WriteWithCallback() argument 59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 73 if (my_batch == nullptr) { in WriteImpl() 79 tracer_->Write(my_batch); in WriteImpl() 100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 105 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl() 588 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 600 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1456 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 53 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 58 WriteBatch* my_batch, in WriteWithCallback() argument 60 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 74 if (my_batch == nullptr) { in WriteImpl() 81 tracer_->Write(my_batch).PermitUncheckedError(); in WriteImpl() 102 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl() 621 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 634 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1585 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 53 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 58 WriteBatch* my_batch, in WriteWithCallback() argument 60 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 74 if (my_batch == nullptr) { in WriteImpl() 81 tracer_->Write(my_batch).PermitUncheckedError(); in WriteImpl() 102 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl() 621 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 634 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1585 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/rocksdb-lite/rocksdb-6.26.1/db/db_impl/ |
H A D | db_impl_write.cc | 54 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 59 WriteBatch* my_batch, in WriteWithCallback() argument 61 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 75 if (my_batch == nullptr) { in WriteImpl() 82 tracer_->Write(my_batch).PermitUncheckedError(); in WriteImpl() 103 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 157 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl() 625 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 637 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1603 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/rocksdb/rocksdb-6.26.1/db/db_impl/ |
H A D | db_impl_write.cc | 54 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 59 WriteBatch* my_batch, in WriteWithCallback() argument 61 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 75 if (my_batch == nullptr) { in WriteImpl() 82 tracer_->Write(my_batch).PermitUncheckedError(); in WriteImpl() 103 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 157 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl() 625 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 637 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1603 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
H A D | db_impl_write.cc | 53 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write() 58 WriteBatch* my_batch, in WriteWithCallback() argument 60 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback() 74 if (my_batch == nullptr) { in WriteImpl() 81 tracer_->Write(my_batch).PermitUncheckedError(); in WriteImpl() 102 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl() 156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl() 621 WriteBatch* my_batch, in UnorderedWriteMemtable() argument 634 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable() 1585 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded() [all …]
|
/dports/misc/py-mxnet/incubator-mxnet-1.9.0/src/operator/contrib/ |
H A D | bounding_box.cu | 345 const index_t my_batch = (my_block_offset_in_row) / num_blocks_per_row_batch; in CalculateGreedyNMSResultsKernel() local 350 const index_t offset = (my_batch * num_elements_per_batch + in CalculateGreedyNMSResultsKernel() 374 const index_t my_offset = (my_batch * num_elements_per_batch + my_element_in_batch) * in CalculateGreedyNMSResultsKernel() 407 result[(my_row * num_batches + my_batch) * topk + my_element_in_batch] = ~ret; in CalculateGreedyNMSResultsKernel() 422 const index_t my_batch = blockIdx.x; in __launch_bounds__() local 424 const index_t my_element = my_batch * topk + my_element_in_batch; in __launch_bounds__() 468 data[(my_batch * num_elements_per_batch + my_element_in_batch) * element_width + in __launch_bounds__() 488 const index_t my_batch = blockIdx.x / num_blocks_per_batch; in ReduceNMSResultRestKernel() local 491 const index_t my_element = my_batch * topk + my_element_in_batch; in ReduceNMSResultRestKernel() 500 const uint32_t valid_boxes = nms_results[my_batch * topk + i * warp_size + start_index]; in ReduceNMSResultRestKernel() [all …]
|
/dports/misc/mxnet/incubator-mxnet-1.9.0/src/operator/contrib/ |
H A D | bounding_box.cu | 345 const index_t my_batch = (my_block_offset_in_row) / num_blocks_per_row_batch; in CalculateGreedyNMSResultsKernel() local 350 const index_t offset = (my_batch * num_elements_per_batch + in CalculateGreedyNMSResultsKernel() 374 const index_t my_offset = (my_batch * num_elements_per_batch + my_element_in_batch) * in CalculateGreedyNMSResultsKernel() 407 result[(my_row * num_batches + my_batch) * topk + my_element_in_batch] = ~ret; in CalculateGreedyNMSResultsKernel() 422 const index_t my_batch = blockIdx.x; in __launch_bounds__() local 424 const index_t my_element = my_batch * topk + my_element_in_batch; in __launch_bounds__() 468 data[(my_batch * num_elements_per_batch + my_element_in_batch) * element_width + in __launch_bounds__() 488 const index_t my_batch = blockIdx.x / num_blocks_per_batch; in ReduceNMSResultRestKernel() local 491 const index_t my_element = my_batch * topk + my_element_in_batch; in ReduceNMSResultRestKernel() 500 const uint32_t valid_boxes = nms_results[my_batch * topk + i * warp_size + start_index]; in ReduceNMSResultRestKernel() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/leveldb-sys-2.0.5/deps/leveldb-1.18/db/ |
H A D | db_impl.cc | 1162 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1164 w.batch = my_batch; in Write() 1178 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1181 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/zetacoin-utils/zetacoin-0.13.2.1/src/leveldb/db/ |
H A D | db_impl.cc | 1162 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1164 w.batch = my_batch; in Write() 1178 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1181 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/zetacoin-daemon/zetacoin-0.13.2.1/src/leveldb/db/ |
H A D | db_impl.cc | 1162 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1164 w.batch = my_batch; in Write() 1178 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1181 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/zetacoin/zetacoin-0.13.2.1/src/leveldb/db/ |
H A D | db_impl.cc | 1162 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1164 w.batch = my_batch; in Write() 1178 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1181 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/litecoin-daemon/litecoin-0.18.1/src/leveldb/db/ |
H A D | db_impl.cc | 1194 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1196 w.batch = my_batch; in Write() 1210 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1213 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/litecoin-utils/litecoin-0.18.1/src/leveldb/db/ |
H A D | db_impl.cc | 1194 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1196 w.batch = my_batch; in Write() 1210 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1213 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/net-p2p/litecoin/litecoin-0.18.1/src/leveldb/db/ |
H A D | db_impl.cc | 1194 Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) { in Write() argument 1196 w.batch = my_batch; in Write() 1210 Status status = MakeRoomForWrite(my_batch == NULL); in Write() 1213 if (status.ok() && my_batch != NULL) { // NULL batch is for compactions in Write()
|
/dports/devel/spark/spark-2.1.1/python/pyspark/ |
H A D | rdd.py | 2102 my_batch = get_batch_size(self._jrdd_deserializer) 2104 if my_batch != other_batch or not my_batch: 2106 batchSize = min(my_batch, other_batch)
|
/dports/biology/py-biopython/biopython-1.79/Tests/ |
H A D | test_Restriction.py | 580 my_batch = EcoRI + SmaI + KpnI 582 analysis = Analysis(my_batch, my_seq)
|