Home
last modified time | relevance | path

Searched refs:writer (Results 1 – 25 of 74) 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 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 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 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.rs37 let mut writer = kernel::str::Formatter::new(page);
38 writer.write_str("blocksize,size,rotational,irqmode\n")?; in show()
39 Ok(writer.bytes_written()) localVariable
133 let mut writer = kernel::str::Formatter::new(page);
136 writer.write_str("1\n")?;
138 writer.write_str("0\n")?;
141 Ok(writer.bytes_written())
171 let mut writer = kernel::str::Formatter::new(page);
172 writer.write_fmt(fmt!("{}\n", this.data.lock().block_size))?; in show()
173 Ok(writer in show() localVariable
135 let mut writer = kernel::str::Formatter::new(page); global() localVariable
197 let mut writer = kernel::str::Formatter::new(page); global() localVariable
224 let mut writer = kernel::str::Formatter::new(page); global() localVariable
247 let mut writer = kernel::str::Formatter::new(page); global() localVariable
[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/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/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/drivers/iommu/arm/arm-smmu-v3/
H A Darm-smmu-v3-test.c11 struct arm_smmu_entry_writer writer; member
61 arm_smmu_test_writer_record_syncs(struct arm_smmu_entry_writer *writer) in arm_smmu_test_writer_record_syncs()
64 container_of(writer, struct arm_smmu_test_writer, writer); in arm_smmu_test_writer_record_syncs()
100 writer->ops->get_used(test_writer->entry, entry_used_bits); in arm_smmu_v3_test_debug_print_used_bits()
101 if (writer->ops->get_update_safe) in arm_smmu_v3_test_debug_print_used_bits()
102 writer->ops->get_update_safe(test_writer->entry, in arm_smmu_v3_test_debug_print_used_bits()
105 if (writer->ops->get_update_safe)
106 writer->ops->get_update_safe(test_writer->entry,
123 arm_smmu_v3_test_debug_print_used_bits(struct arm_smmu_entry_writer *writer, in arm_smmu_v3_test_ste_expect_transition()
54 arm_smmu_test_writer_record_syncs(struct arm_smmu_entry_writer * writer) arm_smmu_test_writer_record_syncs() argument
95 arm_smmu_v3_test_debug_print_used_bits(struct arm_smmu_entry_writer * writer,const __le64 * ste) arm_smmu_v3_test_debug_print_used_bits() argument
[all...]
H A Darm-smmu-v3.c1145 static u8 arm_smmu_entry_qword_diff(struct arm_smmu_entry_writer *writer,
1155 writer->ops->get_used(entry, cur_used);
1156 writer->ops->get_used(target, target_used);
1157 if (writer->ops->get_update_safe)
1158 writer->ops->get_update_safe(entry, target, safe);
1188 static void entry_set(struct arm_smmu_entry_writer *writer, __le64 *entry, in arm_smmu_write_entry()
1203 writer->ops->sync(writer); in arm_smmu_write_entry()
1233 void arm_smmu_write_entry(struct arm_smmu_entry_writer *writer, __le64 *entry, in arm_smmu_sync_cd()
1240 arm_smmu_entry_qword_diff(writer, entr in arm_smmu_sync_cd()
1091 arm_smmu_entry_qword_diff(struct arm_smmu_entry_writer * writer,const __le64 * entry,const __le64 * target,__le64 * unused_update) arm_smmu_entry_qword_diff() argument
1124 entry_set(struct arm_smmu_entry_writer * writer,__le64 * entry,const __le64 * target,unsigned int start,unsigned int len) entry_set() argument
1170 arm_smmu_write_entry(struct arm_smmu_entry_writer * writer,__le64 * entry,const __le64 * target) arm_smmu_write_entry() argument
1311 struct arm_smmu_entry_writer writer; global() member
1337 arm_smmu_cd_writer_sync_entry(struct arm_smmu_entry_writer * writer) arm_smmu_cd_writer_sync_entry() argument
1524 struct arm_smmu_entry_writer writer; global() member
1528 arm_smmu_ste_writer_sync_entry(struct arm_smmu_entry_writer * writer) arm_smmu_ste_writer_sync_entry() argument
[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 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.rs99 writer: UserSliceWriter,
104 fn new(writer: UserSliceWriter, thread: &'a Thread) -> Self {
105 BinderReturnWriter { writer, thread }
113 self.writer.write(&code) in write_code()
118 self.writer.write(payload)
122 self.writer.len()
139 writer: &mut BinderReturnWriter<'_>, in do_work()
244 writer: &mut BinderReturnWriter<'_>, in do_work()
247 writer.write_code(self.code)?; in do_work()
101 writer: UserSliceWriter, global() field
H A Dthread.rs500 let mut writer = data.writer();
502 writer.write(&ee)?; in has_current_transaction()
1411 let mut writer = BinderReturnWriter::new( in read()
1412 UserSlice::new(UserPtr::from_addr(read_start as _), read_len as _).writer(), in read()
1430 if let Err(err) = writer.write_code(BR_NOOP) { in read()
1438 let initial_len = writer.len(); in read()
1439 while writer.len() >= size_of::<uapi::binder_transaction_data_secctx>() + 4 { in read()
1440 match getter(self, wait && initial_len == writer.len()) { in read() localVariable
1441 Ok(Some(work)) => match work.into_arc().do_work(self, &mut writer) { in read()
491 let mut writer = data.writer(); get_extended_error() localVariable
1382 let mut writer = BinderReturnWriter::new( read() localVariable
[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/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/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/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