Lines Matching refs:write_sq

523 	if (sq == &write_sq) {  in sq_setup()
575 if (write_sq.locked == 0) { in sq_write()
576 if ((uWritten = sq_setup(&write_sq)) < 0) return uWritten ; in sq_write()
601 write_sq.syncing &= ~2 ; /* take out POST status */ in sq_write()
604 if (write_sq.count > 0 && in sq_write()
605 (bLeft = write_sq.block_size-write_sq.rear_size) > 0) { in sq_write()
606 dest = write_sq.buffers[write_sq.rear]; in sq_write()
607 bUsed = write_sq.rear_size; in sq_write()
615 write_sq.rear_size = bUsed; in sq_write()
619 while (write_sq.count >= write_sq.max_active) { in sq_write()
621 if (write_sq.open_mode & O_NONBLOCK) in sq_write()
623 SLEEP(write_sq.action_queue); in sq_write()
635 dest = write_sq.buffers[(write_sq.rear+1) % write_sq.max_count]; in sq_write()
637 bLeft = write_sq.block_size; in sq_write()
646 write_sq.rear = (write_sq.rear+1) % write_sq.max_count; in sq_write()
647 write_sq.rear_size = bUsed; in sq_write()
648 write_sq.count++; in sq_write()
662 if (write_sq.locked == 0) { in sq_poll()
663 if ((retVal = sq_setup(&write_sq)) < 0) in sq_poll()
668 poll_wait(file, &write_sq.action_queue, wait); in sq_poll()
677 if (write_sq.count < write_sq.max_active || write_sq.block_size - write_sq.rear_size > 0) in sq_poll()
843 #define write_sq_init_waitqueue() sq_init_waitqueue(&write_sq)
845 #define write_sq_wake_up(file) sq_wake_up(&write_sq, file, FMODE_WRITE)
847 #define write_sq_release_buffers() sq_release_buffers(&write_sq)
849 sq_open2(&write_sq, file, FMODE_WRITE, numWriteBufs, writeBufSize )
939 write_sq.active = 0; in sq_reset_output()
940 write_sq.count = 0; in sq_reset_output()
941 write_sq.rear_size = 0; in sq_reset_output()
943 write_sq.front = 0 ; in sq_reset_output()
944 write_sq.rear = -1 ; /* same as for set-up */ in sq_reset_output()
947 write_sq.locked = 0 ; in sq_reset_output()
948 write_sq.user_frags = 0 ; in sq_reset_output()
949 write_sq.user_frag_size = 0 ; in sq_reset_output()
1001 write_sq.syncing |= 1; in sq_fsync()
1004 while (write_sq.active) { in sq_fsync()
1005 SLEEP(write_sq.sync_queue); in sq_fsync()
1017 write_sq.syncing = 0 ; in sq_fsync()
1039 if (write_sq.busy) in sq_release()
1044 write_sq.busy = 0; in sq_release()
1099 if (write_sq.locked) in queues_are_quiescent()
1182 if ( !write_sq.locked ) in sq_ioctl()
1183 sq_setup(&write_sq) ; in sq_ioctl()
1184 size = write_sq.user_frag_size ; in sq_ioctl()
1194 write_sq.syncing |= 0x2 ; in sq_ioctl()
1293 result = set_queue_frags(&write_sq, nbufs, size) ; in sq_ioctl()
1306 if ( !write_sq.locked ) in sq_ioctl()
1307 sq_setup(&write_sq) ; in sq_ioctl()
1308 info.fragments = write_sq.max_active - write_sq.count; in sq_ioctl()
1309 info.fragstotal = write_sq.max_active; in sq_ioctl()
1310 info.fragsize = write_sq.user_frag_size; in sq_ioctl()
1495 "write", write_sq.numBufs, write_sq.bufSize) ; in state_open()
1505 "write", write_sq.max_count, write_sq.block_size, in state_open()
1506 write_sq.max_active, write_sq.front, write_sq.rear, in state_open()
1507 write_sq.count, write_sq.rear_size, write_sq.active, in state_open()
1508 write_sq.busy, write_sq.syncing, write_sq.locked, write_sq.xruns) ; in state_open()