Home
last modified time | relevance | path

Searched refs:writer (Results 1 – 25 of 58) sorted by relevance

123

/linux/Documentation/trace/
H A Dring-buffer-design.rst28 - 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 Dtraits.rs67 /// 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.write_slice_file(self.as_bytes(), offset)
94 writer: &mut UserSliceWriter, in write_to_slice()
99 guard.write_to_slice(writer, offset)
111 writer: &mut UserSliceWriter,
114 self.deref().write_to_slice(writer, offset)
126 writer
[all...]
H A Dfile_ops.rs272 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/tools/lib/python/
H A Djobserver.py20 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/testing/radix-tree/
H A Dregression4.c60 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 Dfreeze.rs88 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()
H A Drust_binder_main.rs109 writer: UserSliceWriter, field
114 fn new(writer: UserSliceWriter, thread: &'a Thread) -> Self { in new()
115 BinderReturnWriter { writer, thread } in new()
124 self.writer.write(&code) in write_code()
129 self.writer.write(payload) in write_payload()
133 self.writer.len() in len()
150 writer: &mut BinderReturnWriter<'_>, in do_work()
255 writer: &mut BinderReturnWriter<'_>, in do_work()
258 writer.write_code(self.code)?; in do_work()
H A Dthread.rs499 let mut writer = data.writer(); in get_extended_error() localVariable
501 writer.write(&ee)?; in get_extended_error()
1438 let mut writer = BinderReturnWriter::new( in read() localVariable
1439 UserSlice::new(UserPtr::from_addr(read_start as _), read_len as _).writer(), in read()
1464 if let Err(err) = writer.write_code(BR_NOOP) { in read()
1472 let initial_len = writer.len(); in read()
1473 while writer.len() >= size_of::<uapi::binder_transaction_data_secctx>() + 4 { in read()
1474 match getter(self, wait && initial_len == writer.len()) { in read()
1475 Ok(Some(work)) => match work.into_arc().do_work(self, &mut writer) { in read()
1490 if initial_len == writer.len() { in read()
[all …]
H A Dtransaction.rs383 writer: &mut BinderReturnWriter<'_>, in do_work()
431 writer.write_code(code)?; in do_work()
434 writer.write_payload(&tr_sec)?; in do_work()
436 writer.write_payload(&*tr)?; in do_work()
H A Dprocess.rs1130 data.writer().write(&BinderVersion::current()) in version()
1155 let (mut reader, mut writer) = data.reader_writer(); in get_node_debug_info()
1171 writer.write(&out) in get_node_debug_info()
1175 let (mut reader, mut writer) = data.reader_writer(); in get_node_info_from_ref()
1201 writer.write(&out) in get_node_info_from_ref()
1511 let (mut reader, mut writer) = data.reader_writer(); in get_frozen_status()
1532 writer.write(&info)?; in get_frozen_status()
/linux/tools/perf/util/
H A Ddata-convert-bt.c14 #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
1388 struct bt_ctf_writer *writer = cw->writer; ctf_writer__setup_env() local
1572 struct bt_ctf_writer *writer; ctf_writer__init() local
[all...]
/linux/lib/
H A Ddecompress_unlzma.c279 struct writer { struct
294 static inline size_t INIT get_pos(struct writer *wr) in get_pos() argument
300 static inline uint8_t INIT peek_old_byte(struct writer *wr, in peek_old_byte()
318 static inline int INIT write_byte(struct writer *wr, uint8_t byte) in write_byte()
332 static inline int INIT copy_byte(struct writer *wr, uint32_t offs) in copy_byte()
337 static inline int INIT copy_bytes(struct writer *wr, in copy_bytes()
349 static inline int INIT process_bit0(struct writer *wr, struct rc *rc, in process_bit0()
393 static inline int INIT process_bit1(struct writer *wr, struct rc *rc, in process_bit1()
555 struct writer wr; in unlzma()
/linux/tools/testing/selftests/powerpc/dscr/
H A Ddscr_default_test.c41 pthread_t writer; in dscr_default_lockstep_test() local
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/drivers/misc/ibmasm/
H A Dremote.c173 unsigned long writer; in ibmasm_handle_mouse_interrupt() local
177 writer = get_queue_writer(sp); in ibmasm_handle_mouse_interrupt()
179 while (reader != writer) { in ibmasm_handle_mouse_interrupt()
180 if (reader >= REMOTE_QUEUE_SIZE || writer >= REMOTE_QUEUE_SIZE) { in ibmasm_handle_mouse_interrupt()
197 writer = get_queue_writer(sp); in ibmasm_handle_mouse_interrupt()
/linux/drivers/md/dm-vdo/indexer/
H A Dio-factory.h59 int __must_check uds_write_to_buffered_writer(struct buffered_writer *writer,
62 int __must_check uds_flush_buffered_writer(struct buffered_writer *writer);
H A Dindex-page-map.h34 struct buffered_writer *writer);
H A Dconfig.h119 int __must_check uds_write_config_contents(struct buffered_writer *writer,
/linux/drivers/char/
H A Dapm-emulation.c107 unsigned int writer: 1; member
253 if (!as->suser || !as->writer) in apm_ioctl()
356 as->writer = (filp->f_mode & FMODE_WRITE) == FMODE_WRITE; in apm_open()
526 as->writer && as->suser) { in apm_suspend_notifier()
/linux/Documentation/locking/
H A Dspinlocks.rst52 Lesson 2: reader-writer spinlocks.
56 to mostly read from the shared variables, the reader-writer locks
61 NOTE! reader-writer locks require more atomic memory operations than
91 NOTE! We are working hard to remove reader-writer spinlocks in most
H A Dlockdep-design.rst436 read_lock() first. And when task B tries to acquire writer on X, it will block
437 and become a waiter for writer on X. Now if read_lock_2() is recursive readers,
438 task A will make progress, because writer waiters don't block recursive readers,
440 it will get blocked by writer waiter B, and cause a self deadlock.
451 writer waiters)
535 exclusive writer to recursive reader dependency, "X -(ER)-> Y" means
536 X -> Y and X is a writer and Y is a recursive reader.
539 exclusive writer to non-recursive locker dependency, "X -(EN)-> Y" means
540 X -> Y and X is a writer and Y is either a writer or non-recursive reader.
548 X -> Y and X is a reader (recursive or not) and Y is either a writer or
[all …]
/linux/drivers/tty/hvc/
H A Dhvsi.c60 struct delayed_work writer; member
752 cancel_delayed_work_sync(&hp->writer); in hvsi_flush_output()
852 container_of(work, struct hvsi_struct, writer.work); in hvsi_write_worker()
872 schedule_delayed_work(&hp->writer, HZ); in hvsi_write_worker()
878 schedule_delayed_work(&hp->writer, 10); in hvsi_write_worker()
948 schedule_delayed_work(&hp->writer, 10); in hvsi_write()
1199 INIT_DELAYED_WORK(&hp->writer, hvsi_write_worker); in hvsi_console_init()
/linux/Documentation/RCU/
H A Drculist_nulls.rst46 * Because a writer could delete object, and a writer could
147 a race (some writer did a delete and/or a move of an object
/linux/rust/kernel/
H A Ddma.rs995 writer: &mut UserSliceWriter, in write_to_slice()
1008 let count = self.size().saturating_sub(offset_val).min(writer.len()); in write_to_slice()
1010 writer.write_dma(self, offset_val, count)?; in write_to_slice()
/linux/Documentation/driver-api/media/
H A Ddtv-common.rst41 2) If there is exactly one reader and one writer, there is no need
/linux/Documentation/driver-api/nvdimm/
H A Dbtt.rst173 writes. We can hit a condition where the writer thread grabs a free block to do
176 writer started writing to the same external LBA, and finished the write updating
185 read is complete. Every writer thread, after grabbing a free block, checks the
193 Consider a case where two writer threads are writing to the same LBA. There can

123