/DragonOS/kernel/src/driver/block/cache/ |
H A D | cached_block_device.rs | 144 pub fn insert(f_data_vec: Vec<FailData>, data: &[u8]) -> Result<usize, BlockCacheError> { in insert() method 168 space.insert(lba_id, data) in insert_one_block() 215 pub fn insert(&mut self, lba_id: BlockId, data: Vec<u8>) -> Result<(), BlockCacheError> { in insert() method 216 unsafe { self.0.get_mut().insert(lba_id, data) } in insert() 276 pub fn insert(&mut self, lba_id: BlockId, data: Vec<u8>) -> Result<(), BlockCacheError> { in insert() method 289 mapper.insert(lba_id, index); in insert() 300 mapper.insert(lba_id, index); in insert() 319 pub fn insert(&mut self, lba_id: BlockId, caddr: CacheBlockAddr) -> Option<()> { in insert() method 320 unsafe { self.lock.get_mut().insert(lba_id, caddr) } in insert() 347 pub fn insert(&mut self, lba_id: BlockId, caddr: CacheBlockAddr) -> Option<()> { in insert() method [all …]
|
/DragonOS/kernel/src/exception/ |
H A D | irqdata.rs | 245 .insert(IrqStatus::IRQD_IRQ_MASKED); in set_masked() 256 .insert(IrqStatus::IRQD_IRQ_INPROGRESS); in set_inprogress() 275 .insert(IrqStatus::IRQD_IRQ_DISABLED); in set_disabled() 298 .insert(IrqStatus::IRQD_IRQ_STARTED); in set_started() 332 self.state.insert(status); in irqd_insert() 542 self.insert(Self::IRQD_AFFINITY_SET); in mark_affinity_set() 550 self.insert(Self::IRQD_DEFAULT_TRIGGER_SET); in mark_trigger_type_set() 573 self.insert(Self::IRQD_SINGLE_TARGET); in set_single_target() 581 self.insert(Self::IRQD_HANDLE_ENFORCE_IRQCTX); in set_handle_enforce_irqctx() 613 self.insert(Self::IRQD_FORWARDED_TO_VCPU); in set_forwarded_to_vcpu() [all …]
|
H A D | irqdesc.rs | 208 .insert(IrqDescState::IRQS_SYSFS); in mark_in_sysfs() 300 desc_guard.line_status.insert(set); in modify_status() 397 self.line_status.insert(IrqLineStatus::IRQ_NOREQUEST); in set_norequest() 407 self.line_status.insert(IrqLineStatus::IRQ_NOPROBE); in set_noprobe() 416 self.line_status.insert(IrqLineStatus::IRQ_NOTHREAD); in set_nothread() 428 self.line_status.insert(IrqLineStatus::IRQ_PER_CPU); in line_status_set_per_cpu() 442 self.line_status.insert(IrqLineStatus::IRQ_NO_BALANCING); in line_status_set_no_debug() 524 .insert(trigger & IrqLineStatus::IRQ_TYPE_SENSE_MASK); in set_trigger_type() 532 self.line_status.insert(IrqLineStatus::IRQ_LEVEL); in set_level() 883 manager.insert(IrqNumber::new(i), irq_desc); in early_irq_init() [all …]
|
H A D | resend.rs | 64 .insert(IrqDescState::IRQS_REPLAY); in irq_check_and_resend()
|
H A D | handle.rs | 83 .insert(IrqDescState::IRQS_PENDING); in handle() 107 .insert(IrqDescState::IRQS_PENDING); in handle() 116 .insert(IrqDescState::IRQS_PENDING); in handle()
|
/DragonOS/kernel/src/libs/ |
H A D | rbtree.rs | 456 self.insert(k, v); in extend() 941 self.insert(k, v); in replace_or_insert() 1009 pub fn insert(&mut self, k: K, v: V) { in insert() method 1426 m.insert(1, 2); in test_insert() 1428 m.insert(2, 4); in test_insert() 1430 m.insert(2, 6); in test_insert() 1442 m.insert(2, 4); in test_replace() 1454 m.insert(1, 2); in test_clone() 1456 m.insert(2, 4); in test_clone() 1494 m.insert(i, i); in test_lots_of_insertions() [all …]
|
H A D | keyboard_parser.rs | 172 scancode_status.insert = true; in handle_func0() 175 scancode_status.insert = false; in handle_func0() 431 insert: bool, field 461 insert: false, in new()
|
H A D | elf.rs | 386 .insert(AtType::PhEnt as u8, ehdr.e_phentsize as usize); in create_auxv() 389 .insert(AtType::PageSize as u8, MMArch::PAGE_SIZE); in create_auxv() 390 init_info.auxv.insert(AtType::Phdr as u8, phdr_vaddr.data()); in create_auxv() 393 .insert(AtType::PhNum as u8, ehdr.e_phnum as usize); in create_auxv() 396 .insert(AtType::Entry as u8, entrypoint_vaddr.data()); in create_auxv() 663 elf_map_flags.insert(MapFlags::MAP_FIXED_NOREPLACE); in load() 670 elf_map_flags.insert(MapFlags::MAP_FIXED_NOREPLACE); in load()
|
/DragonOS/kernel/src/net/socket/ |
H A D | mod.rs | 93 .insert(socket.socket_handle(), handle_item); in new_socket() 560 None => listen_table_guard.insert(port, ProcessManager::current_pid()), in bind_port() 804 events.insert(EPollEventType::EPOLL_LISTEN_CAN_ACCEPT); in tcp_poll() 814 events.insert(EPollEventType::EPOLLHUP); in tcp_poll() 818 events.insert( in tcp_poll() 827 events.insert(EPollEventType::EPOLLIN | EPollEventType::EPOLLRDNORM); in tcp_poll() 833 events.insert(EPollEventType::EPOLLOUT | EPollEventType::EPOLLWRNORM); in tcp_poll() 840 events.insert(EPollEventType::EPOLLOUT | EPollEventType::EPOLLWRNORM); in tcp_poll() 843 events.insert(EPollEventType::EPOLLOUT | EPollEventType::EPOLLWRNORM); in tcp_poll() 849 events.insert(EPollEventType::EPOLLERR); in tcp_poll() [all …]
|
/DragonOS/user/apps/user-manage/src/parser/ |
H A D | parser.rs | 37 options.insert(option, "".to_string()); in parse() 48 options.insert(option, groups.clone()); in parse() 60 options.insert(option, value); in parse() 124 options.insert(option, value); in parse()
|
/DragonOS/kernel/src/driver/tty/pty/ |
H A D | mod.rs | 118 .insert(core.index(), other_tty.clone()); in pty_common_install() 119 driver.ttys().insert(core.index(), tty.clone()); in pty_common_install() 137 PTS_DRIVER.ttys().insert(core.index(), other_tty); in pty_common_install() 147 core.flags_write().insert(TtyFlag::IO_ERROR); in pty_common_open() 152 core.flags_write().insert(TtyFlag::IO_ERROR); in pty_common_open() 160 core.flags_write().insert(TtyFlag::IO_ERROR); in pty_common_open() 166 core.flags_write().insert(TtyFlag::THROTTLED); in pty_common_open() 178 tty.flags_write().insert(TtyFlag::PTY_LOCK); in pty_set_lock()
|
H A D | unix98pty.rs | 69 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_FLUSHWRITE); in flush_buffer() 137 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_DOSTOP); in set_termios() 139 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_NOSTOP); in set_termios() 144 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_IOCTL); in set_termios() 157 .insert(ControlMode::CS8 | ControlMode::CREAD); in set_termios() 170 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_START); in start() 188 ctrl.pktstatus.insert(TtyPacketStatus::TIOCPKT_STOP); in stop() 275 core.flags_write().insert(TtyFlag::PTY_LOCK); in ptmx_open()
|
/DragonOS/kernel/src/driver/base/ |
H A D | kobject.rs | 63 pub fn update_kobj_state(&self, insert: Option<KObjectState>, remove: Option<KObjectState>) { in update_kobj_state() 64 let insert = insert.unwrap_or(KObjectState::empty()); in update_kobj_state() localVariable 67 *state = (*state | insert) & !remove; in update_kobj_state()
|
/DragonOS/tools/debugging/logmonitor/src/backend/monitor/ |
H A D | logset.rs | 39 pub fn insert(&mut self, key: K, value: V) { in insert() method 43 let prev = self.inner.insert(key, value); in insert()
|
/DragonOS/kernel/src/libs/futex/ |
H A D | syscall.rs | 33 flags.insert(FutexFlag::FLAGS_SHARED); in do_futex() 37 flags.insert(FutexFlag::FLAGS_CLOCKRT); in do_futex()
|
/DragonOS/kernel/src/filesystem/vfs/ |
H A D | syscall.rs | 1295 FileType::File => kstat.mode.insert(ModeType::S_IFREG), in do_fstat() 1296 FileType::Dir => kstat.mode.insert(ModeType::S_IFDIR), in do_fstat() 1297 FileType::BlockDevice => kstat.mode.insert(ModeType::S_IFBLK), in do_fstat() 1298 FileType::CharDevice => kstat.mode.insert(ModeType::S_IFCHR), in do_fstat() 1299 FileType::SymLink => kstat.mode.insert(ModeType::S_IFLNK), in do_fstat() 1300 FileType::Socket => kstat.mode.insert(ModeType::S_IFSOCK), in do_fstat() 1301 FileType::Pipe => kstat.mode.insert(ModeType::S_IFIFO), in do_fstat() 1302 FileType::KvmDevice => kstat.mode.insert(ModeType::S_IFCHR), in do_fstat() 1303 FileType::FramebufferDevice => kstat.mode.insert(ModeType::S_IFCHR), in do_fstat() 1466 FileType::File => tmp.stx_mode.insert(ModeType::S_IFREG), in do_statx() [all …]
|
H A D | mount.rs | 427 .insert(metadata.inode_id, new_mount_fs.clone()); in mount() 431 MOUNT_LIST().insert(mount_path?, new_mount_fs.clone()); in mount() 448 .insert(metadata.inode_id, new_mount_fs.clone()); in mount_from() 657 pub fn insert<T: AsRef<str>>(&self, path: T, fs: Arc<MountFS>) { in insert() method 658 self.0.write().insert(MountPath::from(path.as_ref()), fs); in insert()
|
/DragonOS/kernel/src/ipc/ |
H A D | pipe.rs | 78 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLRDNORM); in poll() 83 events.insert(EPollEventType::EPOLLHUP) in poll() 90 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLWRNORM); in poll() 95 events.insert(EPollEventType::EPOLLERR); in poll()
|
H A D | shm.rs | 171 page_manager_guard.insert(paddr, &page); in add() 190 self.id2shm.insert(shm_id, shm_kernel); in add() 191 self.key2id.insert(key, shm_id); in add() 470 self.kern_ipc_perm.mode.insert(shmflg); in set_mode()
|
/DragonOS/kernel/src/driver/pci/ |
H A D | root.rs | 258 .insert(ecam_root_info.segment_group_number, pci_root); in add_pci_root() 260 inner.pci_root.insert(pci_root.bus_begin as u16, pci_root); in add_pci_root()
|
/DragonOS/kernel/src/mm/ |
H A D | memblock.rs | 107 insert: bool, in do_add_block() 135 if insert { in do_add_block() 151 if insert { in do_add_block() 164 if insert { in do_add_block()
|
/DragonOS/kernel/crates/intertrait/macros/src/ |
H A D | args.rs | 42 if !flags.insert(Flag::from(&ident)?) { in parse()
|
/DragonOS/kernel/src/driver/base/block/ |
H A D | manager.rs | 63 inner.disks.insert(dev_name.clone(), dev.clone()); in register() 129 meta_inner.gendisks.insert(idx, gendisk.clone()); in register_gendisk()
|
/DragonOS/kernel/src/driver/base/platform/ |
H A D | mod.rs | 67 self.0.insert(str); in add_device()
|
/DragonOS/kernel/src/driver/virtio/ |
H A D | irq.rs | 54 map.insert(device.dev_id().clone(), device); in register_device()
|