Home
last modified time | relevance | path

Searched refs:my_batch (Results 1 – 25 of 35) sorted by relevance

12

/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/db_impl/
H A Ddb_impl_write.cc52 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 Ddb_impl.h487 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 Ddb_impl_write.cc52 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 Ddb_impl.h487 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 Ddb_impl_write.cc52 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 Ddb_impl_write.cc52 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 Ddb_impl_write.cc52 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 Ddb_impl_write.cc52 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 Ddb_impl_write.cc52 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 Ddb_impl_write.cc53 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 Ddb_impl_write.cc53 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 Ddb_impl_write.cc54 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 Ddb_impl_write.cc54 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 Ddb_impl_write.cc53 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 Dbounding_box.cu345 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 Dbounding_box.cu345 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 Ddb_impl.cc1162 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 Ddb_impl.cc1162 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 Ddb_impl.cc1162 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 Ddb_impl.cc1162 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 Ddb_impl.cc1194 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 Ddb_impl.cc1194 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 Ddb_impl.cc1194 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 Drdd.py2102 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 Dtest_Restriction.py580 my_batch = EcoRI + SmaI + KpnI
582 analysis = Analysis(my_batch, my_seq)

12