| /linux/drivers/md/dm-vdo/indexer/ |
| H A D | index.c | 27 * chapter writer, and sparse cache barrier messages for the sparse cache. 29 * The chapter writer is responsible for committing chapters of records to storage. Since zones can 31 * its available space in a chapter, it informs the chapter writer that the chapter is complete, 34 * Once every zone has closed the chapter, the chapter writer will commit that chapter to storage. 66 /* The number of bytes allocated by the chapter writer */ 182 struct chapter_writer *writer = index->chapter_writer; in finish_previous_chapter() local 184 mutex_lock(&writer->mutex); in finish_previous_chapter() 186 uds_wait_cond(&writer->cond, &writer->mutex); in finish_previous_chapter() 187 result = writer->result; in finish_previous_chapter() 188 mutex_unlock(&writer->mutex); in finish_previous_chapter() [all …]
|
| H A D | index-layout.c | 517 struct buffered_writer *writer) in write_index_save_header() argument 541 result = uds_write_to_buffered_writer(writer, buffer, offset); in write_index_save_header() 546 return uds_flush_buffered_writer(writer); in write_index_save_header() 554 struct buffered_writer *writer; in write_index_save_layout() local 560 result = open_region_writer(layout, &isl->header, &writer); in write_index_save_layout() 566 result = write_index_save_header(isl, table, writer); in write_index_save_layout() 568 uds_free_buffered_writer(writer); in write_index_save_layout() 687 struct buffered_writer *writer) in write_layout_header() argument 716 result = uds_write_to_buffered_writer(writer, buffer, offset); in write_layout_header() 721 return uds_flush_buffered_writer(writer); in write_layout_header() [all …]
|
| H A D | io-factory.h | 13 * clients are the index layout and the volume. The buffered reader and buffered writer interfaces 59 int __must_check uds_write_to_buffered_writer(struct buffered_writer *writer, 62 int __must_check uds_flush_buffered_writer(struct buffered_writer *writer);
|
| /linux/Documentation/trace/ |
| H A D | ring-buffer-design.rst | 28 - the task that writes into the ring buffer (same as writer) 30 writer 81 but a writer may interrupt another writer, but it must finish writing 82 before the previous writer may continue. This is very important to the 94 This is very much like a writer being preempted by an interrupt and 99 cannot preempt/interrupt a writer, but it may read/consume from the 100 buffer at the same time as a writer is writing, but the reader must be 102 and can be preempted by a writer. 104 A writer can preempt a reader, but a reader cannot preempt a writer. 106 as a writer. [all …]
|
| /linux/rust/kernel/debugfs/ |
| H A D | traits.rs | 46 /// between Rust versions, so if stability is key for your use case, please implement `Writer` 48 pub trait Writer { 53 impl<T: Writer> Writer for Mutex<T> { in write_to_slice() 59 impl<T: fmt::Debug> Writer for T { 67 /// Writes the binary form of `self` into `writer`. 71 /// On success, returns the number of bytes written in to `writer`. in write_to_slice() 74 writer: &mut UserSliceWriter, in write_to_slice() 83 writer: &mut UserSliceWriter, 86 writer 27 pub trait Writer { global() interface [all...] |
| H A D | callback_adapters.rs | 9 Writer, // 50 impl<D: Writer, W> Writer for WritableAdapter<D, W> { 67 /// Adapter to implement `Writer` via a callback with the same representation as `T`. 85 impl<D, F> Writer for FormatAdapter<D, F>
|
| H A D | file_ops.rs | 8 Writer, // 78 impl<'a, T: Writer> fmt::Display for WriterAdapter<&'a T> { 91 unsafe extern "C" fn writer_open<T: Writer + Sync>( in writer_open() 112 unsafe extern "C" fn writer_act<T: Writer + Sync>( in writer_act() 131 impl<T: Writer + Sync> ReadFile<T> for T { 182 impl<T: Writer + Reader + Sync> ReadWriteFile<T> for T { 272 let mut writer = UserSlice::new(UserPtr::from_ptr(buf.cast()), count).writer(); in blob_read() 275 let written = this.write_to_slice(&mut writer, pos)?; in blob_read() 266 let mut writer = UserSlice::new(UserPtr::from_ptr(buf.cast()), count).writer(); blob_read() localVariable
|
| /linux/include/linux/ |
| H A D | seqlock_types.h | 12 * This is the raw counting mechanism, without any writer protection. 21 * as the writer can invalidate a pointer that a reader is following. 27 * If it's desired to automatically handle the sequence counter writer 47 * reader preempting the writer, use a different technique: let the reader 48 * detect if a seqcount_LOCKNAME_t writer is in progress. If that is the 49 * case, acquire then release the associated LOCKNAME writer serialization 50 * lock. This will allow any possibly-preempted writer to make progress 51 * until the end of its writer serialization lock critical section. 77 * Sequence counters with an embedded spinlock for writer serialization
|
| /linux/tools/lib/python/ |
| H A D | jobserver.py | 20 os.write(writer, b"+") # os.write(writer, claim) 60 self.writer = None 95 self.writer = os.open(path, os.O_WRONLY) 109 self.writer = int(split_fds[1]) 150 os.write(self.writer, self.jobs) 169 os.write(self.writer, self.jobs)
|
| /linux/tools/perf/util/ |
| H A D | data-convert-bt.c | 14 #include <babeltrace/ctf-writer/writer.h> 15 #include <babeltrace/ctf-writer/clock.h> 16 #include <babeltrace/ctf-writer/stream.h> 17 #include <babeltrace/ctf-writer/event.h> 18 #include <babeltrace/ctf-writer/event-types.h> 19 #include <babeltrace/ctf-writer/event-fields.h> 65 /* writer primitives */ 66 struct bt_ctf_writer *writer; member 94 struct ctf_writer writer; member 712 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class); in ctf_stream__create() [all …]
|
| /linux/kernel/locking/ |
| H A D | rwsem.c | 7 * Writer lock-stealing by Alex Shi <alex.shi@intel.com> 42 * When the rwsem is reader-owned and a spinning writer has timed out, 45 * When a writer acquires a rwsem, it puts its task_struct pointer 60 * is previously owned by a writer and the following conditions are met: 61 * - rwsem is not currently writer owned 85 * Bit 0 - writer locked bit 94 * Bit 0 - writer locked bit 107 * atomic_long_cmpxchg() will be used to obtain writer lock. 114 * For all the above cases, wait_lock will be held. A writer must also 293 * by a writer. [all …]
|
| H A D | qrwlock.c | 29 * if the writer is just waiting (not holding the lock yet), in queued_read_lock_slowpath() 72 /* Put the writer into the wait queue */ in queued_write_lock_slowpath() 80 /* Set the waiting flag to notify readers that a writer is pending */ in queued_write_lock_slowpath()
|
| /linux/kernel/trace/ |
| H A D | trace_recursion_record.c | 43 * If there's two writers and this writer comes in second, in ftrace_record_recursion() 45 * writer will try again. It is possible that index will now in ftrace_record_recursion() 46 * be greater than nr_records. This is because the writer in ftrace_record_recursion() 48 * This writer could keep trying again until the other writer in ftrace_record_recursion() 49 * updates nr_records. But if the other writer takes an in ftrace_record_recursion() 54 * writer will simply use the next position to update the in ftrace_record_recursion()
|
| /linux/drivers/acpi/acpica/ |
| H A D | utlock.c | 4 * Module Name: utlock - Reader/Writer lock interfaces 25 * DESCRIPTION: Reader/writer lock creation and deletion interfaces. 62 * DESCRIPTION: Reader interfaces for reader/writer locks. On acquisition, 122 * DESCRIPTION: Writer interfaces for reader/writer locks. Simply acquire or 123 * release the writer mutex associated with the lock. Acquisition
|
| /linux/arch/arc/include/asm/ |
| H A D | spinlock.h | 75 * Read-write spinlocks, allowing multiple readers but only one writer. 84 * zero means writer holds the lock exclusively, deny Reader. in arch_read_lock() 140 * deny writer. Otherwise if unlocked grant to writer in arch_write_lock() 290 * Read-write spinlocks, allowing multiple readers but only one writer. 307 * zero means writer holds the lock exclusively, deny Reader. in arch_read_trylock() 332 * deny writer. Otherwise if unlocked grant to writer in arch_write_trylock()
|
| /linux/drivers/gpu/drm/amd/display/dc/ |
| H A D | dm_pp_smu.h | 106 /* reader and writer WM's are sent together as part of one table*/ 206 /* reader and writer WM's are sent together as part of one table*/ 215 * writer fill clk = socclk 216 * writer drain clk = uclk 275 * reader and writer WM's are sent together as part of one table 293 * reader and writer WM's are sent together as part of one table
|
| /linux/kernel/printk/ |
| H A D | printk_ringbuffer.h | 39 * Using prb_rec_init_wr(), a writer sets @text_buf_size before calling 41 * buffers reserved for that writer. 123 desc_reserved = 0x0, /* reserved, in use by writer */ 124 desc_committed = 0x1, /* committed by writer, could get reopened */ 126 desc_reusable = 0x3, /* free, not yet used by any writer */ 176 * The first record reserved by a writer is assigned sequence number 0. 188 * writer (head + 1) to be the first descriptor in the array. (Only the first 222 * writer, which has the assigned sequence number 0. 266 /* this will be the first record reserved by a writer */ \ 311 /* Writer Interfac [all...] |
| H A D | printk_ringbuffer.c | 50 * A writer is modifying the record. 53 * The record and all its data are written. A writer can reopen the 59 * writer cannot reopen the descriptor. 88 * When a writer calls the commit function prb_commit(), record data is 89 * fully stored and is consistent within the ringbuffer. However, a writer can 91 * modify that record. When finished, the writer must again commit the record. 98 * 1) A writer can simultaneously commit and finalize its record by calling 116 * Each data block consists of an ID followed by the writer data. The ID is 129 * If the writer data of a data block would extend beyond the end of the 131 * position and the full data block (ID and writer data) is stored at the [all …]
|
| /linux/arch/parisc/include/asm/ |
| H A D | spinlock.h | 71 * Read-write spinlocks, allowing multiple readers but only one writer. 88 * zero means writer holds the lock exclusively, deny Reader. in arch_read_trylock() 113 * deny writer. Otherwise if unlocked grant to writer in arch_write_trylock()
|
| /linux/Documentation/devicetree/bindings/mmc/ |
| H A D | litex,mmc.yaml | 31 - description: DMA Writer buffer 40 - const: writer 74 reg-names = "phy", "core", "reader", "writer", "irq";
|
| /linux/tools/testing/selftests/powerpc/dscr/ |
| H A D | dscr_default_test.c | 41 pthread_t writer; in dscr_default_lockstep_test() local 50 FAIL_IF(sem_init(writer_sem, 0, 1)); /* writer starts first */ in dscr_default_lockstep_test() 52 FAIL_IF(pthread_create(&writer, NULL, dscr_default_lockstep_writer, (void *)rw_semaphores)); in dscr_default_lockstep_test() 65 FAIL_IF(pthread_join(writer, NULL)); in dscr_default_lockstep_test()
|
| /linux/include/asm-generic/ |
| H A D | qrwlock.h | 25 * Writer states & reader shift and bias. 27 #define _QW_WAITING 0x100 /* A writer is waiting */ 28 #define _QW_LOCKED 0x0ff /* A writer holds the lock */ 29 #define _QW_WMASK 0x1ff /* Writer mask */
|
| /linux/tools/testing/radix-tree/ |
| H A D | regression4.c | 60 pthread_t reader, writer; in regression4_test() local 68 pthread_create(&writer, NULL, writer_fn, NULL)) { in regression4_test() 73 if (pthread_join(reader, NULL) || pthread_join(writer, NULL)) { in regression4_test()
|
| /linux/drivers/android/binder/ |
| H A D | freeze.rs | 88 writer: &mut BinderReturnWriter<'_>, in do_work() 100 writer.write_code(BR_CLEAR_FREEZE_NOTIFICATION_DONE)?; in do_work() 101 writer.write_payload(&self.cookie.0)?; in do_work() 120 writer.write_code(BR_CLEAR_FREEZE_NOTIFICATION_DONE)?; in do_work() 121 writer.write_payload(&self.cookie.0)?; in do_work() 136 writer.write_code(BR_FROZEN_BINDER)?; in do_work() 137 writer.write_payload(&state_info)?; in do_work()
|
| /linux/tools/build/feature/ |
| H A D | test-libbabeltrace.c | 3 #include <babeltrace/ctf-writer/writer.h>
|