Lines Matching refs:aio_workq_entry
123 TAILQ_HEAD(, aio_workq_entry) aioq_entries;
172 static void aio_proc_move_done_locked(proc_t procp, aio_workq_entry *entryp);
173 static void aio_proc_remove_done_locked(proc_t procp, aio_workq_entry *entryp);
178 static boolean_t should_cancel(aio_workq_entry *entryp, user_addr_t aiocbp, int fd);
180 static void aio_entry_lock(aio_workq_entry *entryp);
181 static void aio_entry_lock_spin(aio_workq_entry *entryp);
182 static aio_workq_t aio_entry_workq(aio_workq_entry *entryp);
183 static lck_mtx_t* aio_entry_mutex(__unused aio_workq_entry *entryp);
184 static void aio_workq_remove_entry_locked(aio_workq_t queue, aio_workq_entry *entryp);
185 static void aio_workq_add_entry_locked(aio_workq_t queue, aio_workq_entry *entryp);
186 static void aio_entry_ref_locked(aio_workq_entry *entryp);
187 static void aio_entry_unref_locked(aio_workq_entry *entryp);
188 static void aio_entry_ref(aio_workq_entry *entryp);
189 static void aio_entry_unref(aio_workq_entry *entryp);
190 static void aio_entry_update_for_cancel(aio_workq_entry *entryp, boolean_t cancelled,
192 static int aio_entry_try_workq_remove(aio_workq_entry *entryp);
193 static boolean_t aio_delay_fsync_request( aio_workq_entry *entryp );
194 static int aio_free_request(aio_workq_entry *entryp);
202 static aio_workq_entry *aio_get_some_work( void );
206 static int aio_validate( aio_workq_entry *entryp );
211 static void do_aio_completion( aio_workq_entry *entryp );
212 static int do_aio_fsync( aio_workq_entry *entryp );
213 static int do_aio_read( aio_workq_entry *entryp );
214 static int do_aio_write( aio_workq_entry *entryp );
220 aio_workq_entry **entrypp );
221 static aio_workq_entry *aio_create_queue_entry(proc_t procp,
227 static void aio_enqueue_work( proc_t procp, aio_workq_entry *entryp, int proc_locked);
270 aio_entry_lock(__unused aio_workq_entry *entryp)
276 aio_entry_lock_spin(__unused aio_workq_entry *entryp)
282 aio_entry_unlock(__unused aio_workq_entry *entryp)
289 aio_entry_workq(__unused aio_workq_entry *entryp)
295 aio_entry_mutex(__unused aio_workq_entry *entryp)
314 aio_workq_remove_entry_locked(aio_workq_t queue, aio_workq_entry *entryp)
332 aio_workq_add_entry_locked(aio_workq_t queue, aio_workq_entry *entryp)
356 aio_proc_move_done_locked(proc_t procp, aio_workq_entry *entryp)
367 aio_proc_remove_done_locked(proc_t procp, aio_workq_entry *entryp)
388 aio_entry_ref_locked(aio_workq_entry *entryp)
401 aio_entry_unref_locked(aio_workq_entry *entryp)
412 aio_entry_ref(aio_workq_entry *entryp)
419 aio_entry_unref(aio_workq_entry *entryp)
435 aio_entry_update_for_cancel(aio_workq_entry *entryp, boolean_t cancelled, int wait_for_completion, boolean_t disable_notification)
457 aio_entry_try_workq_remove(aio_workq_entry *entryp)
633 aio_workq_entry *entryp;
762 aio_workq_entry *entryp;
870 aio_workq_entry *entryp;
915 aio_workq_entry *next_entryp;
952 should_cancel(aio_workq_entry *entryp, user_addr_t aiocbp, int fd)
985 aio_workq_entry *entryp;
994 aio_workq_entry *next_entryp;
1109 aio_workq_entry *entryp;
1375 aio_enqueue_work( proc_t procp, aio_workq_entry *entryp, int proc_locked)
1378 aio_workq_entry *my_entryp; /* used for insertion sort */
1461 aio_workq_entry **entryp_listp;
1486 * allocate a list of aio_workq_entry pointers that we will use
1489 MALLOC( entryp_listp, void *, (uap->nent * sizeof(aio_workq_entry *)), M_TEMP, M_WAITOK );
1530 aio_workq_entry *entryp;
1658 aio_workq_entry *entryp;
1755 static aio_workq_entry *
1758 aio_workq_entry *entryp = NULL;
1841 aio_delay_fsync_request( aio_workq_entry *entryp )
1850 static aio_workq_entry *
1853 aio_workq_entry *entryp;
1856 entryp = (aio_workq_entry *) zalloc( aio_workq_zonep );
1864 /* fill in the rest of the aio_workq_entry */
1929 aio_workq_entry *entryp;
1990 * Allocate an aio_workq_entry and fill it in. If all goes well return 0
1991 * and pass the aio_workq_entry pointer back to our caller.
1998 * address of the created aio_workq_entry
2017 aio_workq_entry **entrypp )
2019 aio_workq_entry *entryp;
2030 * not really an error, but we need to free our aio_workq_entry.
2062 aio_free_request(aio_workq_entry *entryp)
2089 aio_validate( aio_workq_entry *entryp )
2215 do_aio_completion( aio_workq_entry *entryp )
2357 do_aio_read( aio_workq_entry *entryp )
2389 do_aio_write( aio_workq_entry *entryp )
2447 aio_workq_entry *entryp;
2463 do_aio_fsync( aio_workq_entry *entryp )
2525 aio_workq_entry *entryp;
2592 i = sizeof( aio_workq_entry );