RTOS/rtems
1
0
Fork 0
forked from Imagelibrary/rtems
Code Pull Requests Activity

posix/aio: modified insertion of sync requests

Browse Source 
now sync requests are appended at the end of the appropriate queue

Closes #5176
This commit is contained in:
alessandronardin
2024-12-11 09:49:07 +01:00
parent 1c9d74cfac
commit ab7f9193eb
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
cpukit/posix/src/aio_misc.c
View File

@@ -393,18 +393,24 @@ static void rtems_aio_insert_prio(
AIO_printf( "First in chain \n" ); AIO_printf( "First in chain \n" );
rtems_chain_prepend( chain, &req->next_prio ); rtems_chain_prepend( chain, &req->next_prio );
} else { } else {
AIO_printf( "Add by priority \n" );
int prio = ((rtems_aio_request *) node)->aiocbp->aio_reqprio;
while ( if ( req->op_type == AIO_OP_SYNC ) {
req->aiocbp->aio_reqprio > prio && AIO_printf( "Sync request. Append to end of chain \n" );
!rtems_chain_is_tail( chain, node ) rtems_chain_append( chain, &req->next_prio );
) { } else {
node = rtems_chain_next( node ); AIO_printf( "Add by priority \n" );
prio = ((rtems_aio_request *) node)->aiocbp->aio_reqprio; int prio = ((rtems_aio_request *) node)->aiocbp->aio_reqprio;
while (
req->aiocbp->aio_reqprio > prio &&
!rtems_chain_is_tail( chain, node )
) {
node = rtems_chain_next( node );
prio = ((rtems_aio_request *) node)->aiocbp->aio_reqprio;
}
rtems_chain_insert( node->previous, &req->next_prio );
} }
rtems_chain_insert( node->previous, &req->next_prio );
} }
} }