| /external/python/cpython2/Lib/bsddb/test/ |
| D | test_thread.py | 72 writers = 0 variable in ConcurrentDataStoreBase
84 records_per_writer=self.records//self.writers
85 readers_per_writer=self.readers//self.writers
86 self.assertEqual(self.records,self.writers*records_per_writer)
87 self.assertEqual(self.readers,self.writers*readers_per_writer)
102 writers=[]
103 for x in xrange(self.writers):
111 writers.append(wt)
113 for t in writers:
120 for t in writers:
[all …]
|
| /external/libchrome/base/memory/ |
| D | protected_memory.h | 187 static constexpr int& writers = internal::DsoSpecific<int>::value;
193 static int writers;
214 if (writers == 0) { in AutoWritableMemory()
217 AssertMemoryIsReadOnly(&writers); in AutoWritableMemory()
218 CHECK(SetMemoryReadWrite(&writers, &writers + 1)); in AutoWritableMemory()
222 writers++; in AutoWritableMemory()
242 CHECK_GT(writers, 0); in AutoWritableMemory()
243 writers++; in AutoWritableMemory()
252 CHECK_GT(writers, 0); in ~AutoWritableMemory()
253 writers--; in ~AutoWritableMemory()
[all …]
|
| D | protected_memory.cc | 11 PROTECTED_MEMORY_SECTION int AutoWritableMemory::writers = 0; member in base::AutoWritableMemory
|
| /external/pigweed/pw_rpc/ |
| D | base_server_writer_test.cc | 90 auto& writers = context.server().writers(); in TEST() local
91 EXPECT_FALSE(writers.empty()); in TEST()
93 writers.begin(), writers.end(), [&](auto& w) { return &w == &writer; }); in TEST()
94 ASSERT_NE(it, writers.end()); in TEST()
101 auto& writers = context.server().writers(); in TEST() local
102 EXPECT_TRUE(writers.empty()); in TEST()
111 auto& writers = context.server().writers(); in TEST() local
112 EXPECT_TRUE(writers.empty()); in TEST()
|
| /external/llvm/include/llvm/Support/ |
| D | RWMutex.h | 92 unsigned readers, writers; variable
94 explicit SmartRWMutex() : impl(), readers(0), writers(0) { } in SmartRWMutex()
123 assert(writers == 0 && "Writer lock already acquired!"); in lock()
124 ++writers; in lock()
134 assert(writers == 1 && "Writer lock not acquired before release!"); in unlock()
135 --writers; in unlock()
|
| /external/perfetto/src/traced/service/ |
| D | builtin_producer.cc | 119 auto it_and_inserted = metatrace_.writers.emplace( in StartDataSource()
123 metatrace_.writers[ds_id].Enable(task_runner_, std::move(writer), in StartDataSource()
129 auto meta_it = metatrace_.writers.find(ds_id); in StopDataSource()
130 if (meta_it != metatrace_.writers.end()) { in StopDataSource()
134 metatrace_.writers.erase(meta_it); in StopDataSource()
171 auto meta_it = metatrace_.writers.find(ds_ids[i]); in Flush()
172 if (meta_it != metatrace_.writers.end()) { in Flush()
|
| /external/llvm-project/llvm/include/llvm/Support/ |
| D | RWMutex.h | 107 unsigned writers = 0; variable
143 assert(writers == 0 && "Writer lock already acquired!"); in lock()
144 ++writers; in lock()
156 assert(writers == 1 && "Writer lock not acquired before release!"); in unlock()
157 --writers; in unlock()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | RWMutex.h | 109 unsigned writers = 0; variable
145 assert(writers == 0 && "Writer lock already acquired!"); in lock()
146 ++writers; in lock()
158 assert(writers == 1 && "Writer lock not acquired before release!"); in unlock()
159 --writers; in unlock()
|
| /external/igt-gpu-tools/tests/i915/ |
| D | gem_fence_upload.c | 170 struct thread_performance writers[count]; in thread_performance() local
187 writers[n].id = count - n - 1; in thread_performance()
188 writers[n].direction = WRITE; in thread_performance()
189 writers[n].ptr = ptr; in thread_performance()
190 writers[n].count = count; in thread_performance()
191 writers[n].loops = loops; in thread_performance()
200 pthread_create(&writers[n].thread, NULL, write_thread_performance, &writers[n]); in thread_performance()
206 pthread_join(writers[n].thread, NULL); in thread_performance()
221 pthread_create(&writers[n].thread, NULL, write_thread_performance, &writers[n]); in thread_performance()
227 pthread_join(writers[n].thread, NULL); in thread_performance()
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | tf_record_writer_test.py | 25 from tensorflow.python.data.experimental.ops import writers
47 return writers.TFRecordWriter(self._outputFilename(),
94 writers.TFRecordWriter(self._outputFilename(), "").write("whoops")
100 writers.TFRecordWriter(self._outputFilename(), "").write(input_dataset)
106 writers.TFRecordWriter(self._outputFilename(), "").write(input_dataset)
112 return writers.TFRecordWriter(self._outputFilename()).write(input_dataset)
131 writer = writers.TFRecordWriter(shard_filename)
|
| /external/wpa_supplicant_8/src/utils/ |
| D | eloop.c | 102 struct eloop_sock_table writers; member
185 eloop.writers.type = EVENT_TYPE_WRITE; in eloop_init()
444 struct eloop_sock_table *writers, in eloop_sock_table_set_fds() argument
470 if (writers && writers->table) { in eloop_sock_table_set_fds()
471 for (i = 0; i < writers->count; i++) { in eloop_sock_table_set_fds()
476 fd = writers->table[i].sock; in eloop_sock_table_set_fds()
553 struct eloop_sock_table *writers, in eloop_sock_table_dispatch() argument
563 if (eloop_sock_table_dispatch_table(writers, pollfds_map, in eloop_sock_table_dispatch()
628 eloop.writers.changed || in eloop_sock_table_dispatch()
650 eloop.writers.changed || in eloop_sock_table_dispatch()
[all …]
|
| /external/libchrome/mojo/public/c/system/tests/ |
| D | core_perftest.cc | 168 std::vector<MessagePipeWriterThread*> writers; in DoMessagePipeThreadedTest() local
170 writers.push_back(new MessagePipeWriterThread(h0_, num_bytes)); in DoMessagePipeThreadedTest()
182 writers[i]->Start(); in DoMessagePipeThreadedTest()
197 writers[i]->Join(); in DoMessagePipeThreadedTest()
207 num_writes += writers[i]->num_writes(); in DoMessagePipeThreadedTest()
208 delete writers[i]; in DoMessagePipeThreadedTest()
210 writers.clear(); in DoMessagePipeThreadedTest()
|
| /external/tensorflow/tensorflow/core/util/ |
| D | debug_events_writer_test.cc | 105 std::vector<DebugEventsWriter*> writers; in TEST_F() local
107 auto fn = [this, &writers, &mu]() { in TEST_F()
112 writers.push_back(writer); in TEST_F()
120 EXPECT_EQ(writers.size(), 4); in TEST_F()
121 EXPECT_EQ(writers[0], writers[1]); in TEST_F()
122 EXPECT_EQ(writers[1], writers[2]); in TEST_F()
123 EXPECT_EQ(writers[2], writers[3]); in TEST_F()
131 std::vector<DebugEventsWriter*> writers; in TEST_F() local
133 auto fn = [this, &counter, &writers, &mu]() { in TEST_F()
141 writers.push_back(writer); in TEST_F()
[all …]
|
| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | server.h | 25 writers().push_front(writer); in RegisterWriter()
29 writers().remove(writer); in RemoveWriter()
|
| /external/python/cpython3/Lib/test/ |
| D | test_devpoll.py | 34 writers = []
44 writers.append(wr)
50 while writers:
70 writers.remove(r2w[rd])
|
| D | test_poll.py | 37 writers = []
47 writers.append(wr)
53 while writers:
72 writers.remove(r2w[rd])
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | io_ops.cc | 97 writers; in WriteData() local
116 if (writers.count(shard_index) == 0) { in WriteData()
126 writers.insert({shard_index, std::move(writer_thread)}); in WriteData()
128 writers[shard_index]->Write(element); in WriteData()
132 for (auto& writer : writers) { in WriteData()
136 writers.clear(); in WriteData()
|
| /external/python/cpython2/Doc/tools/extensions/ |
| D | pyspecific.py | 20 from sphinx.writers.html import HTMLTranslator
21 from sphinx.writers.latex import LaTeXTranslator
22 from sphinx.writers.text import TextTranslator
157 from sphinx.writers.text import TextWriter
|
| /external/python/cpython2/Lib/test/ |
| D | test_poll.py | 39 writers = []
49 writers.append(wr)
55 while writers:
74 writers.remove(r2w[rd])
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | utils.py | 350 self.writers = {}
400 self.writers[fd] = events.Handle(callback, args, self, None)
404 if fd in self.writers:
405 del self.writers[fd]
411 assert fd in self.writers, 'fd {} is not registered'.format(fd)
412 handle = self.writers[fd]
|
| /external/selinux/python/sepolicy/sepolicy/help/ |
| D | transition_file.txt | 4 SELinux allows policy writers to define file transition rules. These rules define the label of a n…
11 A third option is for policy writers to write a transition rule. For example a process labeled Net…
|
| /external/perfetto/src/tracing/test/ |
| D | mock_producer.cc | 159 std::vector<TraceWriter*> writers; in WaitForFlush() local
161 writers.push_back(writer_to_flush); in WaitForFlush()
162 WaitForFlush(writers, reply); in WaitForFlush()
|
| /external/fmtlib/support/ |
| D | rst2md.py | 5 from docutils import core, nodes, writers
141 class MDWriter(writers.Writer):
|
| /external/arm-trusted-firmware/docs/getting_started/ |
| D | index.rst | 17 rt-svc-writers-guide
|
| /external/angle/infra/config/generated/ |
| D | luci-logdog.cfg | 8 writer_auth_groups: "luci-logdog-angle-writers"
|