Lines Matching refs:fdp
125 FuzzedDataProvider fdp(&readerData[0], readerData.size()); in reader() local
127 while (fdp.remaining_bytes()) { in reader()
129 size_t numElements = fdp.ConsumeIntegralInRange<size_t>(0, kMaxNumElements); in reader()
139 if (fdp.ConsumeIntegral<uint8_t>() == 1) { in reader()
142 *writeCounter = fdp.ConsumeIntegral<uint64_t>(); in reader()
161 FuzzedDataProvider fdp(&readerData[0], readerData.size()); in readerBlocking() local
163 size_t count = fdp.remaining_bytes() in readerBlocking()
164 ? fdp.ConsumeIntegralInRange<size_t>(0, readMq.getQuantumCount() + 1) in readerBlocking()
169 } while (fdp.remaining_bytes() > sizeof(size_t) && writersNotFinished > 0); in readerBlocking()
183 void writer(const Desc& desc, Queue& writeMq, FuzzedDataProvider& fdp, bool userFd) { in writer() argument
185 while (fdp.remaining_bytes()) { in writer()
190 fdp.ConsumeIntegral<uint8_t>(); in writer()
199 if (fdp.ConsumeIntegral<uint8_t>() == 1) { in writer()
202 *readCounter = fdp.ConsumeIntegral<uint64_t>(); in writer()
205 *firstStart = fdp.ConsumeIntegral<payload_t>(); in writer()
212 void writerBlocking(Queue& writeMq, FuzzedDataProvider& fdp, in writerBlocking() argument
216 while (fdp.remaining_bytes() > sizeof(size_t) && readersNotFinished > 0) { in writerBlocking()
217 size_t count = fdp.ConsumeIntegralInRange<size_t>(0, writeMq.getQuantumCount() + 1); in writerBlocking()
220 data.push_back(fdp.ConsumeIntegral<payload_t>()); in writerBlocking()
235 inline std::optional<Desc> getDesc(std::unique_ptr<Queue>& queue, FuzzedDataProvider& fdp);
238 inline std::optional<Desc> getAidlDesc(std::unique_ptr<Queue>& queue, FuzzedDataProvider& fdp) { in getAidlDesc() argument
250 size_t numGrantors = fdp.ConsumeIntegralInRange<size_t>(0, 4); in getAidlDesc()
252 grantors.push_back({fdp.ConsumeIntegralInRange<int32_t>(-2, 2) /* fdIndex */, in getAidlDesc()
253 fdp.ConsumeIntegralInRange<int32_t>( in getAidlDesc()
255 fdp.ConsumeIntegralInRange<int64_t>( in getAidlDesc()
269 {grantors, std::move(handle), sizeof(payload_t), fdp.ConsumeBool()}); in getAidlDesc()
275 FuzzedDataProvider& fdp) { in getDesc() argument
276 return getAidlDesc<AidlMessageQueueSync, AidlMQDescSync>(queue, fdp); in getDesc()
281 FuzzedDataProvider& fdp) { in getDesc() argument
282 return getAidlDesc<AidlMessageQueueUnsync, AidlMQDescUnsync>(queue, fdp); in getDesc()
286 inline std::optional<Desc> getHidlDesc(std::unique_ptr<Queue>& queue, FuzzedDataProvider& fdp) { in getHidlDesc() argument
297 size_t numGrantors = fdp.ConsumeIntegralInRange<size_t>(0, 4); in getHidlDesc()
299 grantors.push_back({fdp.ConsumeIntegral<uint32_t>() /* flags */, in getHidlDesc()
300 fdp.ConsumeIntegralInRange<uint32_t>(0, 2) /* fdIndex */, in getHidlDesc()
301 fdp.ConsumeIntegralInRange<uint32_t>( in getHidlDesc()
303 fdp.ConsumeIntegralInRange<uint64_t>( in getHidlDesc()
321 FuzzedDataProvider& fdp) { in getDesc() argument
322 return getHidlDesc<MessageQueueSync, MQDescSync>(queue, fdp); in getDesc()
327 FuzzedDataProvider& fdp) { in getDesc() argument
328 return getHidlDesc<MessageQueueUnsync, MQDescUnsync>(queue, fdp); in getDesc()
334 FuzzedDataProvider fdp(&writerData[0], writerData.size()); in fuzzWithReaders() local
335 bool evFlag = blocking || fdp.ConsumeBool(); in fuzzWithReaders()
336 size_t numElements = fdp.ConsumeIntegralInRange<size_t>(1, kMaxNumElements); in fuzzWithReaders()
338 bool userFd = fdp.ConsumeBool(); in fuzzWithReaders()
339 bool manualGrantors = fdp.ConsumeBool(); in fuzzWithReaders()
342 std::optional<Desc> customDesc(getDesc<Queue, Desc>(writeMq, fdp)); in fuzzWithReaders()
359 const std::optional<Desc> desc(std::move(getDesc<Queue, Desc>(writeMq, fdp))); in fuzzWithReaders()
377 writerBlocking<Queue>(*writeMq, fdp, writersNotFinished, readersNotFinished); in fuzzWithReaders()
379 writer<Queue>(*desc, *writeMq, fdp, userFd); in fuzzWithReaders()
391 FuzzedDataProvider fdp(data, size); in LLVMFuzzerTestOneInput() local
393 bool fuzzSync = fdp.ConsumeBool(); in LLVMFuzzerTestOneInput()
395 uint8_t numReaders = fuzzSync ? fdp.ConsumeIntegralInRange<uint8_t>(0, kMaxNumSyncReaders) in LLVMFuzzerTestOneInput()
396 : fdp.ConsumeIntegralInRange<uint8_t>(0, kMaxNumUnsyncReaders); in LLVMFuzzerTestOneInput()
398 readerData.emplace_back(fdp.ConsumeBytes<uint8_t>(kMaxDataPerReader)); in LLVMFuzzerTestOneInput()
400 bool fuzzBlocking = fdp.ConsumeBool(); in LLVMFuzzerTestOneInput()
401 std::vector<uint8_t> writerData = fdp.ConsumeRemainingBytes<uint8_t>(); in LLVMFuzzerTestOneInput()