Home
last modified time | relevance | path

Searched refs:writer (Results 1 – 25 of 73) 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()
/linux/drivers/block/rnull/
H A Dconfigfs.rs39 let mut writer = kernel::str::Formatter::new(page); localVariable
40 writer.write_str("blocksize,size,rotational,irqmode\n")?;
41 Ok(writer.bytes_written())
135 let mut writer = kernel::str::Formatter::new(page); localVariable
138 writer.write_str("1\n")?;
140 writer.write_str("0\n")?;
143 Ok(writer.bytes_written())
173 let mut writer = kernel::str::Formatter::new(page); localVariable
174 writer.write_fmt(fmt!("{}\n", this.data.lock().block_size))?;
175 Ok(writer.bytes_written())
[all …]
/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.rs53 writer: &mut UserSliceWriter, in write_to_slice()
62 writer: &mut UserSliceWriter, in write_to_slice()
65 writer.write_slice_file(self.as_bytes(), offset) in write_to_slice()
73 writer: &mut UserSliceWriter, in write_to_slice()
78 guard.write_to_slice(writer, offset) in write_to_slice()
90 writer: &mut UserSliceWriter, in write_to_slice()
93 self.deref().write_to_slice(writer, offset) in write_to_slice()
105 writer: &mut UserSliceWriter, in write_to_slice()
108 self.deref().write_to_slice(writer, offset) in write_to_slice()
119 writer: &mut UserSliceWriter, in write_to_slice()
[all …]
H A Dfile_ops.rs266 let mut writer = UserSlice::new(UserPtr::from_ptr(buf.cast()), count).writer(); in blob_read() localVariable
269 let written = this.write_to_slice(&mut writer, pos)?; in blob_read()
/linux/tools/lib/python/
H A Djobserver.py53 self.writer = None
82 self.writer = os.open(path, os.O_WRONLY)
84 self.reader, self.writer = [int(x) for x in fds.split(",", 1)]
101 os.write(self.writer, self.jobs)
123 os.write(self.writer, self.jobs)
/linux/drivers/iommu/arm/arm-smmu-v3/
H A Darm-smmu-v3-test.c11 struct arm_smmu_entry_writer writer; member
54 arm_smmu_test_writer_record_syncs(struct arm_smmu_entry_writer *writer) in arm_smmu_test_writer_record_syncs() argument
57 container_of(writer, struct arm_smmu_test_writer, writer); in arm_smmu_test_writer_record_syncs()
81 writer->ops->get_used(test_writer->entry, entry_used_bits); in arm_smmu_test_writer_record_syncs()
95 arm_smmu_v3_test_debug_print_used_bits(struct arm_smmu_entry_writer *writer, in arm_smmu_v3_test_debug_print_used_bits() argument
123 .writer = { in arm_smmu_v3_test_ste_expect_transition()
138 arm_smmu_v3_test_debug_print_used_bits(&test_writer.writer, cur->data); in arm_smmu_v3_test_ste_expect_transition()
142 arm_smmu_v3_test_debug_print_used_bits(&test_writer.writer, in arm_smmu_v3_test_ste_expect_transition()
145 arm_smmu_write_entry(&test_writer.writer, cur_copy.data, target->data); in arm_smmu_v3_test_ste_expect_transition()
407 .writer = { in arm_smmu_v3_test_cd_expect_transition()
[all …]
H A Darm-smmu-v3.c1091 static u8 arm_smmu_entry_qword_diff(struct arm_smmu_entry_writer *writer, in arm_smmu_entry_qword_diff() argument
1100 writer->ops->get_used(entry, cur_used); in arm_smmu_entry_qword_diff()
1101 writer->ops->get_used(target, target_used); in arm_smmu_entry_qword_diff()
1124 static bool entry_set(struct arm_smmu_entry_writer *writer, __le64 *entry, in entry_set() argument
1139 writer->ops->sync(writer); in entry_set()
1170 void arm_smmu_write_entry(struct arm_smmu_entry_writer *writer, __le64 *entry, in arm_smmu_write_entry() argument
1177 arm_smmu_entry_qword_diff(writer, entry, target, unused_update); in arm_smmu_write_entry()
1195 entry_set(writer, entry, unused_update, 0, NUM_ENTRY_QWORDS); in arm_smmu_write_entry()
1196 entry_set(writer, entry, target, critical_qword_index, 1); in arm_smmu_write_entry()
1197 entry_set(writer, entry, target, 0, NUM_ENTRY_QWORDS); in arm_smmu_write_entry()
[all …]
/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 Dnode.rs510 fn write(&self, writer: &mut BinderReturnWriter<'_>, code: u32) -> Result { in write()
511 writer.write_code(code)?; in write()
512 writer.write_payload(&self.ptr)?; in write()
513 writer.write_payload(&self.cookie)?; in write()
599 writer: &mut BinderReturnWriter<'_>, in do_work_locked()
634 self.write(writer, BR_INCREFS)?; in do_work_locked()
637 self.write(writer, BR_ACQUIRE)?; in do_work_locked()
640 self.write(writer, BR_RELEASE)?; in do_work_locked()
643 self.write(writer, BR_DECREFS)?; in do_work_locked()
703 writer: &mut BinderReturnWriter<'_>, in do_work()
[all …]
H A Drust_binder_main.rs101 writer: UserSliceWriter, field
106 fn new(writer: UserSliceWriter, thread: &'a Thread) -> Self { in new()
107 BinderReturnWriter { writer, thread } in new()
115 self.writer.write(&code) in write_code()
120 self.writer.write(payload) in write_payload()
124 self.writer.len() in len()
141 writer: &mut BinderReturnWriter<'_>, in do_work()
246 writer: &mut BinderReturnWriter<'_>, in do_work()
249 writer.write_code(self.code)?; in do_work()
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.rs491 let mut writer = data.writer(); in get_extended_error() localVariable
493 writer.write(&ee)?; in get_extended_error()
1382 let mut writer = BinderReturnWriter::new( in read() localVariable
1383 UserSlice::new(UserPtr::from_addr(read_start as _), read_len as _).writer(), in read()
1401 if let Err(err) = writer.write_code(BR_NOOP) { in read()
1409 let initial_len = writer.len(); in read()
1410 while writer.len() >= size_of::<uapi::binder_transaction_data_secctx>() + 4 { in read()
1411 match getter(self, wait && initial_len == writer.len()) { in read()
1412 Ok(Some(work)) => match work.into_arc().do_work(self, &mut writer) { in read()
1427 if initial_len == writer.len() { in read()
[all …]
H A Dtransaction.rs348 writer: &mut BinderReturnWriter<'_>, in do_work()
396 writer.write_code(code)?; in do_work()
399 writer.write_payload(&tr_sec)?; in do_work()
401 writer.write_payload(&*tr)?; in do_work()
/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/perf/util/
H A Ddata-convert-bt.c64 struct bt_ctf_writer *writer; member
92 struct ctf_writer writer; member
705 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class); in ctf_stream__create()
804 struct ctf_writer *cw = &c->writer; in process_sample_event()
881 struct ctf_writer *cw = &c->writer; \
1375 struct bt_ctf_writer *writer = cw->writer; in ctf_writer__setup_env() local
1379 if (bt_ctf_writer_add_environment_field(writer, __n, __v)) \ in ctf_writer__setup_env()
1504 bt_ctf_writer_put(cw->writer); in ctf_writer__cleanup()
1513 struct bt_ctf_writer *writer; in ctf_writer__init() local
1520 writer = bt_ctf_writer_create(path); in ctf_writer__init()
[all …]
/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/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

123