Home
last modified time | relevance | path

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

123

/linux/drivers/md/dm-vdo/indexer/
H A Dindex.c182 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()
218 struct chapter_writer *writer = index->chapter_writer; in start_closing_chapter() local
220 mutex_lock(&writer->mutex); in start_closing_chapter()
221 finished_zones = ++writer->zones_to_write; in start_closing_chapter()
222 writer->chapters[zone_number] = chapter; in start_closing_chapter()
223 uds_broadcast_cond(&writer->cond); in start_closing_chapter()
[all …]
H A Dindex-layout.c517 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 Dopen-chapter.c292 int uds_save_open_chapter(struct uds_index *index, struct buffered_writer *writer) in uds_save_open_chapter() argument
302 result = uds_write_to_buffered_writer(writer, OPEN_CHAPTER_MAGIC, in uds_save_open_chapter()
307 result = uds_write_to_buffered_writer(writer, OPEN_CHAPTER_VERSION, in uds_save_open_chapter()
318 result = uds_write_to_buffered_writer(writer, record_count_data, in uds_save_open_chapter()
334 result = uds_write_to_buffered_writer(writer, (u8 *) record, in uds_save_open_chapter()
345 return uds_flush_buffered_writer(writer); in uds_save_open_chapter()
H A Dconfig.c174 int uds_write_config_contents(struct buffered_writer *writer, in uds_write_config_contents() argument
182 result = uds_write_to_buffered_writer(writer, INDEX_CONFIG_MAGIC, in uds_write_config_contents()
192 result = uds_write_to_buffered_writer(writer, INDEX_CONFIG_VERSION_8_02, in uds_write_config_contents()
197 result = uds_write_to_buffered_writer(writer, INDEX_CONFIG_VERSION_6_02, in uds_write_config_contents()
224 return uds_write_to_buffered_writer(writer, buffer, offset); in uds_write_config_contents()
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.c113 int uds_write_index_page_map(struct index_page_map *map, struct buffered_writer *writer) in uds_write_index_page_map() argument
131 result = uds_write_to_buffered_writer(writer, buffer, offset); in uds_write_index_page_map()
136 return uds_flush_buffered_writer(writer); in uds_write_index_page_map()
H A Dindex-page-map.h34 struct buffered_writer *writer);
H A Dopen-chapter.h72 struct buffered_writer *writer);
/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 Dthread.rs499 let mut writer = data.writer(); in get_extended_error() localVariable
501 writer.write(&ee)?; in get_extended_error()
1406 let mut writer = BinderReturnWriter::new( in read() localVariable
1407 UserSlice::new(UserPtr::from_addr(read_start as _), read_len as _).writer(), in read()
1425 if let Err(err) = writer.write_code(BR_NOOP) { in read()
1433 let initial_len = writer.len(); in read()
1434 while writer.len() >= size_of::<uapi::binder_transaction_data_secctx>() + 4 { in read()
1435 match getter(self, wait && initial_len == writer.len()) { in read()
1436 Ok(Some(work)) => match work.into_arc().do_work(self, &mut writer) { in read()
1451 if initial_len == writer.len() { in read()
[all …]
/linux/tools/perf/util/
H A Ddata-convert-bt.c66 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()
811 struct ctf_writer *cw = &c->writer; in process_sample_event()
893 struct ctf_writer *cw = &c->writer; \
1388 struct bt_ctf_writer *writer = cw->writer; in ctf_writer__setup_env() local
1392 if (__v && bt_ctf_writer_add_environment_field(writer, __n, __v)) \ in ctf_writer__setup_env()
1413 struct ctf_writer *cw = &c->writer; in process_feature_event()
1426 return bt_ctf_writer_add_environment_field(cw->writer, "host", in process_feature_event()
1432 return bt_ctf_writer_add_environment_field(cw->writer, "release", in process_feature_event()
[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()
192 writer = get_queue_writer(sp); in ibmasm_handle_mouse_interrupt()
/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/drivers/iommu/arm/arm-smmu-v3/
H A Darm-smmu-v3.c1145 static u8 arm_smmu_entry_qword_diff(struct arm_smmu_entry_writer *writer, in arm_smmu_entry_qword_diff() argument
1155 writer->ops->get_used(entry, cur_used); in arm_smmu_entry_qword_diff()
1156 writer->ops->get_used(target, target_used); in arm_smmu_entry_qword_diff()
1157 if (writer->ops->get_update_safe) in arm_smmu_entry_qword_diff()
1158 writer->ops->get_update_safe(entry, target, safe); in arm_smmu_entry_qword_diff()
1188 static void entry_set(struct arm_smmu_entry_writer *writer, __le64 *entry, in entry_set() argument
1203 writer->ops->sync(writer); in entry_set()
1233 void arm_smmu_write_entry(struct arm_smmu_entry_writer *writer, __le64 *entry, in arm_smmu_write_entry() argument
1240 arm_smmu_entry_qword_diff(writer, entry, target, unused_update); in arm_smmu_write_entry()
1258 entry_set(writer, entry, unused_update, 0, NUM_ENTRY_QWORDS); in arm_smmu_write_entry()
[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/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/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

123