Searched refs:cluster_ops (Results 1 – 6 of 6) sorted by relevance
66 int64_t GetNextOpOffset(const CowOperation& op, uint32_t cluster_ops) { in GetNextOpOffset() argument69 } else if ((op.type == kCowReplaceOp || op.type == kCowXorOp) && cluster_ops == 0) { in GetNextOpOffset()76 int64_t GetNextDataOffset(const CowOperation& op, uint32_t cluster_ops) { in GetNextDataOffset() argument78 return cluster_ops * sizeof(CowOperation); in GetNextDataOffset()79 } else if (cluster_ops == 0) { in GetNextDataOffset()
166 if (header_.cluster_ops && in SetupWriteOptions()172 if (header_.cluster_ops && in SetupWriteOptions()189 header_.cluster_ops = options_.cluster_ops; in SetupHeaders()209 if (options_.cluster_ops == 1) { in ParseOptions()254 data_vec_ = std::make_unique<struct iovec[]>(header_.cluster_ops); in InitBatchWrites()257 for (size_t i = 0; i < header_.cluster_ops; i++) { in InitBatchWrites()330 cluster_size_ = header_.cluster_ops * sizeof(CowOperation); in InitPos()331 if (header_.cluster_ops) { in InitPos()397 options_.cluster_ops = header_.cluster_ops; in OpenForAppend()793 if (op_vec_index_ == header_.cluster_ops || data_vec_index_ == header_.cluster_ops || in WriteOperation()[all …]
67 options.cluster_ops = 0; in TEST_F()109 options.cluster_ops = 0; in TEST_F()187 options.cluster_ops = 0; in TEST_F()266 options.cluster_ops = 0; in TEST_F()383 options.cluster_ops = 0; in TEST_P()448 options.cluster_ops = 2; in TEST_F()512 options.cluster_ops = 0; in TEST_F()555 options.cluster_ops = 0; in TEST_P()585 options.cluster_ops = 0; in TEST_F()1139 int cluster_ops = 5; in TEST_F() local[all …]
134 if (header_.cluster_ops == 1) { in Parse()143 if (header_.cluster_ops == 1) { in Parse()189 if (header_.cluster_ops) { in ParseOps()190 data_pos = pos + header_.cluster_ops * sizeof(CowOperation); in ParseOps()197 uint64_t cluster_ops = header_.cluster_ops ?: 1; in ParseOps() local202 uint64_t to_add = std::min(cluster_ops, (fd_size_ - pos) / sizeof(CowOperation)); in ParseOps()217 pos += sizeof(CowOperation) + GetNextOpOffset(current_op, header_.cluster_ops); in ParseOps()218 data_pos += current_op.data_length + GetNextDataOffset(current_op, header_.cluster_ops); in ParseOps()
74 uint32_t cluster_ops; member
46 uint32_t cluster_ops = 200; member