[Ltp-cvs] ltp/testcases/kernel/io/aio/aio02/cases aio_tio.c,1.1,1.2

[Mike F. <va...@us...>]

Update of /cvsroot/ltp/ltp/testcases/kernel/io/aio/aio02/cases
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv4767/io/aio/aio02/cases

Modified Files:
	aio_tio.c 
Log Message:
ugh, dos CRLFs, how i hate you so

Index: aio_tio.c
===================================================================
RCS file: /cvsroot/ltp/ltp/testcases/kernel/io/aio/aio02/cases/aio_tio.c,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** aio_tio.c	29 Jan 2004 15:49:03 -0000	1.1
--- aio_tio.c	11 Feb 2006 07:27:18 -0000	1.2
***************
*** 1,278 ****
! /*************************************************************************************
! *
! *  Copyright (c) International Business Machines  Corp., 2003
! *
! *  This program is free software;  you can redistribute it and/or modify
! *  it under the terms of the GNU General Public License as published by
! *  the Free Software Foundation; either version 2 of the License, or
! *  (at your option) any later version.
! *
! *  This program is distributed in the hope that it will be useful,
! *  but WITHOUT ANY WARRANTY;  without even the implied warranty of
! *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See
! *  the GNU General Public License for more details.
! *
! *  You should have received a copy of the GNU General Public License
! *  along with this program;  if not, write to the Free Software
! *  Foundation, 
! *
! *  FILE        : aio_tio
! *  USAGE       : runfstest case/aio_tio
! *
! *  DESCRIPTION : This program will test Asynchronous I/O for 2.5 Kernel infrastructure
! *  REQUIREMENTS:
! *                1) libaio-0.3.92 or up for 2.5 kernal
! *                2) glibc 2.1.91 or up
! *  HISTORY     :
! *      11/03/2003 Kai Zhao (lt...@cn...)
! *
! *  CODE COVERAGE: 
! *                 68.3% - fs/aio.c 
! *
! ************************************************************************************/
! 
! #include "common.h"
! #define AIO_MAXIO 32
! #define AIO_BLKSIZE (64*1024)
! static int alignment = 512;
! static int wait_count = 0;
! 
! 
! /*
!  * write work done 
!  * 
!  */
! static void work_done(io_context_t ctx, struct iocb *iocb, long res, long res2)
! {
! 
! 	if (res2 != 0) {
! 		io_error("aio write", res2);
! 	}
! 
! 	if (res != iocb->u.c.nbytes) {
! 		fprintf(stderr, "write missed bytes expect %lu got %ld\n",
! 			iocb->u.c.nbytes, res2);
! 		exit(1);
! 	}
! 	wait_count --;
! }
! 
! /*
!  * io_wait_run() - wait for an io_event and then call the callback.
!  */
! int io_wait_run(io_context_t ctx, struct timespec *to)
! {
! 	struct io_event events[AIO_MAXIO];
! 	struct io_event *ep;
! 	int ret, n;
! 
! 	/*
! 	 * get up to aio_maxio events at a time.
! 	 */
! 	ret = n = io_getevents( ctx, 1, AIO_MAXIO, events, to );
! 
! 	/*
! 	 * Call the callback functions for each event.
! 	 */
! 	for ( ep = events ; n-- > 0 ; ep++ ) {
! 		io_callback_t cb = ( io_callback_t)ep->data ; struct iocb *iocb = ep->obj ; cb(ctx, iocb, ep->res, ep->res2);
! 	}
! 	return ret;
! }
! 
! 
! int io_tio(char *pathname , int flag , int n , int operation)
! {
! 	int res , fd = 0 , i = 0;
! 	void * bufptr = NULL;
! 	off_t offset = 0;
! 	struct timespec timeout;
! 	
! 	io_context_t myctx;
! 	struct iocb iocb_array[AIO_MAXIO];
! 	struct iocb *iocbps[AIO_MAXIO];
! 	
! 	fd = open ( pathname , flag );
! 	if ( fd <= 0 ) {
! 		perror ( " open : file " );
! 		return -1;
! 	}
! 	
! 	res = io_queue_init(n, &myctx);
! 	//printf ( " res = %d \n", res);
! 	
! 	for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 		
! 		switch (operation) {
! 			case IO_CMD_FSYNC :
! 			case IO_CMD_FDSYNC :
! 			case IO_CMD_PWRITE :
! 			  {
! 				if ( posix_memalign ( &bufptr , alignment , AIO_BLKSIZE )) {
! 					perror ( " posix_memalign failed " );
! 					return -1;
! 				}
! 				memset ( bufptr , 0 , AIO_BLKSIZE );
! 				
! 				io_prep_pwrite ( &iocb_array[i] , fd , bufptr , AIO_BLKSIZE , offset );
! 				io_set_callback( &iocb_array[i] , work_done );
! 				iocbps[i] = &iocb_array[i];
! 				offset += AIO_BLKSIZE;
! 			  }
! 			  break;
! 			case IO_CMD_PREAD :
! 			  {
! 				if ( posix_memalign ( &bufptr , alignment , AIO_BLKSIZE )) {
! 					perror ( " posix_memalign failed " );
! 					return -1;
! 				}
! 				memset ( bufptr , 0 , AIO_BLKSIZE );
! 				
! 				io_prep_pread ( &iocb_array[i] , fd , bufptr , AIO_BLKSIZE , offset );
! 				io_set_callback( &iocb_array[i] , work_done );
! 				iocbps[i] = &iocb_array[i];
! 				offset += AIO_BLKSIZE;
! 			  }
! 			  break;
! 			case IO_CMD_POLL :
! 			  {
! 			  
! 			  }
! 			  break;
! 			case IO_CMD_NOOP :
! 			  {
! 			  
! 			  }
! 			  break;
! 			default:
! 			  {
! 			  	fprintf ( stderr , "CMD Failed \n" );
! 			  	return -1;
! 			  }
! 			  break;
! 		}
! 	}
! 	
! 	if (( res = io_submit ( myctx , AIO_MAXIO , iocbps )) < 0 ) {
! 		io_error("io_submit tio", res);
! 	}
! 	
! 	/*
! 	 * We have submitted all the i/o requests. Wait for at least one to complete
! 	 * and call the callbacks.
! 	 */
! 	wait_count = AIO_MAXIO;
! 	
! 	timeout.tv_sec = 30;
! 	timeout.tv_nsec = 0;
! 	
! 	switch ( operation ) {
! 		case IO_CMD_PREAD :
! 		case IO_CMD_PWRITE :
! 		  {
! 			while ( wait_count ) {
! 				res = io_wait_run( myctx , &timeout );
! 				if ( res < 0 ) 
! 					io_error("io_wait_run", res);
! 			}
! 		  }
! 		  break;
! 		case IO_CMD_FSYNC :
! 		  {
! 			for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 				res = io_fsync( myctx , iocbps[i] , work_done , fd);
! 				if ( res  < 0 ) {
! 					io_error("io_fsync write", res);
! 				}
! 			}
! 		  }
! 		  break;
! 		case IO_CMD_FDSYNC :
! 		  {
! 			for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 				res = io_fdsync( myctx , iocbps[i] , work_done , fd);
! 				if ( res  < 0 ) {
! 					io_error("io_fsync write", res);
! 				}
! 			}
! 		  }
! 		  break;
! 		default :
! 		  {
! 		  
! 		  }
! 		  break;
! 	}
! 	
! 	
! 	close ( fd );
! 	
! 	for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 		if ( iocb_array[i].u.c.buf != NULL ) {
! 			free ( iocb_array[i].u.c.buf );
! 		}
! 	}
! 	
! 	io_queue_release ( myctx );
! 	
! 	return 0;
! }
! 
! int test_main(void)
! {
! 	int	status = 0 ;
! 	//char *filepath = "testdir/file1";
! 	
!     printf("running test 1 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , AIO_MAXIO , IO_CMD_PWRITE);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 2 \n");
! 	status = io_tio( "testdir/file1" , O_RDONLY | O_DIRECT | O_LARGEFILE , AIO_MAXIO , IO_CMD_PREAD);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 3 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_RDWR , AIO_MAXIO , IO_CMD_PWRITE );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 4 \n");
! 	status = io_tio( "testdir/file1" , O_RDWR , AIO_MAXIO , IO_CMD_PREAD );
! 	if ( status ) {
! 		return status;
! 	}
! 		
!     printf("running test 5 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_WRONLY , AIO_MAXIO , IO_CMD_PWRITE );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 6 \n");
! 	status = io_tio( "testdir/file1" , O_RDONLY , AIO_MAXIO , IO_CMD_PREAD );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 7 \n");
! 	status = io_tio( "testdir/file2" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , 
! 				AIO_MAXIO , IO_CMD_FSYNC);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 8 \n");
! 	status = io_tio( "testdir/file2" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , 
! 				AIO_MAXIO , IO_CMD_FDSYNC);
! 	if ( status ) {
! 		return status;
! 	}
! 	
! 	return status;
! }
! 
--- 1,278 ----
! /*************************************************************************************
! *
! *  Copyright (c) International Business Machines  Corp., 2003
! *
! *  This program is free software;  you can redistribute it and/or modify
! *  it under the terms of the GNU General Public License as published by
! *  the Free Software Foundation; either version 2 of the License, or
! *  (at your option) any later version.
! *
! *  This program is distributed in the hope that it will be useful,
! *  but WITHOUT ANY WARRANTY;  without even the implied warranty of
! *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See
! *  the GNU General Public License for more details.
! *
! *  You should have received a copy of the GNU General Public License
! *  along with this program;  if not, write to the Free Software
! *  Foundation, 
! *
! *  FILE        : aio_tio
! *  USAGE       : runfstest case/aio_tio
! *
! *  DESCRIPTION : This program will test Asynchronous I/O for 2.5 Kernel infrastructure
! *  REQUIREMENTS:
! *                1) libaio-0.3.92 or up for 2.5 kernal
! *                2) glibc 2.1.91 or up
! *  HISTORY     :
! *      11/03/2003 Kai Zhao (lt...@cn...)
! *
! *  CODE COVERAGE: 
! *                 68.3% - fs/aio.c 
! *
! ************************************************************************************/
! 
! #include "common.h"
! #define AIO_MAXIO 32
! #define AIO_BLKSIZE (64*1024)
! static int alignment = 512;
! static int wait_count = 0;
! 
! 
! /*
!  * write work done 
!  * 
!  */
! static void work_done(io_context_t ctx, struct iocb *iocb, long res, long res2)
! {
! 
! 	if (res2 != 0) {
! 		io_error("aio write", res2);
! 	}
! 
! 	if (res != iocb->u.c.nbytes) {
! 		fprintf(stderr, "write missed bytes expect %lu got %ld\n",
! 			iocb->u.c.nbytes, res2);
! 		exit(1);
! 	}
! 	wait_count --;
! }
! 
! /*
!  * io_wait_run() - wait for an io_event and then call the callback.
!  */
! int io_wait_run(io_context_t ctx, struct timespec *to)
! {
! 	struct io_event events[AIO_MAXIO];
! 	struct io_event *ep;
! 	int ret, n;
! 
! 	/*
! 	 * get up to aio_maxio events at a time.
! 	 */
! 	ret = n = io_getevents( ctx, 1, AIO_MAXIO, events, to );
! 
! 	/*
! 	 * Call the callback functions for each event.
! 	 */
! 	for ( ep = events ; n-- > 0 ; ep++ ) {
! 		io_callback_t cb = ( io_callback_t)ep->data ; struct iocb *iocb = ep->obj ; cb(ctx, iocb, ep->res, ep->res2);
! 	}
! 	return ret;
! }
! 
! 
! int io_tio(char *pathname , int flag , int n , int operation)
! {
! 	int res , fd = 0 , i = 0;
! 	void * bufptr = NULL;
! 	off_t offset = 0;
! 	struct timespec timeout;
! 	
! 	io_context_t myctx;
! 	struct iocb iocb_array[AIO_MAXIO];
! 	struct iocb *iocbps[AIO_MAXIO];
! 	
! 	fd = open ( pathname , flag );
! 	if ( fd <= 0 ) {
! 		perror ( " open : file " );
! 		return -1;
! 	}
! 	
! 	res = io_queue_init(n, &myctx);
! 	//printf ( " res = %d \n", res);
! 	
! 	for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 		
! 		switch (operation) {
! 			case IO_CMD_FSYNC :
! 			case IO_CMD_FDSYNC :
! 			case IO_CMD_PWRITE :
! 			  {
! 				if ( posix_memalign ( &bufptr , alignment , AIO_BLKSIZE )) {
! 					perror ( " posix_memalign failed " );
! 					return -1;
! 				}
! 				memset ( bufptr , 0 , AIO_BLKSIZE );
! 				
! 				io_prep_pwrite ( &iocb_array[i] , fd , bufptr , AIO_BLKSIZE , offset );
! 				io_set_callback( &iocb_array[i] , work_done );
! 				iocbps[i] = &iocb_array[i];
! 				offset += AIO_BLKSIZE;
! 			  }
! 			  break;
! 			case IO_CMD_PREAD :
! 			  {
! 				if ( posix_memalign ( &bufptr , alignment , AIO_BLKSIZE )) {
! 					perror ( " posix_memalign failed " );
! 					return -1;
! 				}
! 				memset ( bufptr , 0 , AIO_BLKSIZE );
! 				
! 				io_prep_pread ( &iocb_array[i] , fd , bufptr , AIO_BLKSIZE , offset );
! 				io_set_callback( &iocb_array[i] , work_done );
! 				iocbps[i] = &iocb_array[i];
! 				offset += AIO_BLKSIZE;
! 			  }
! 			  break;
! 			case IO_CMD_POLL :
! 			  {
! 			  
! 			  }
! 			  break;
! 			case IO_CMD_NOOP :
! 			  {
! 			  
! 			  }
! 			  break;
! 			default:
! 			  {
! 			  	fprintf ( stderr , "CMD Failed \n" );
! 			  	return -1;
! 			  }
! 			  break;
! 		}
! 	}
! 	
! 	if (( res = io_submit ( myctx , AIO_MAXIO , iocbps )) < 0 ) {
! 		io_error("io_submit tio", res);
! 	}
! 	
! 	/*
! 	 * We have submitted all the i/o requests. Wait for at least one to complete
! 	 * and call the callbacks.
! 	 */
! 	wait_count = AIO_MAXIO;
! 	
! 	timeout.tv_sec = 30;
! 	timeout.tv_nsec = 0;
! 	
! 	switch ( operation ) {
! 		case IO_CMD_PREAD :
! 		case IO_CMD_PWRITE :
! 		  {
! 			while ( wait_count ) {
! 				res = io_wait_run( myctx , &timeout );
! 				if ( res < 0 ) 
! 					io_error("io_wait_run", res);
! 			}
! 		  }
! 		  break;
! 		case IO_CMD_FSYNC :
! 		  {
! 			for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 				res = io_fsync( myctx , iocbps[i] , work_done , fd);
! 				if ( res  < 0 ) {
! 					io_error("io_fsync write", res);
! 				}
! 			}
! 		  }
! 		  break;
! 		case IO_CMD_FDSYNC :
! 		  {
! 			for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 				res = io_fdsync( myctx , iocbps[i] , work_done , fd);
! 				if ( res  < 0 ) {
! 					io_error("io_fsync write", res);
! 				}
! 			}
! 		  }
! 		  break;
! 		default :
! 		  {
! 		  
! 		  }
! 		  break;
! 	}
! 	
! 	
! 	close ( fd );
! 	
! 	for ( i = 0 ; i < AIO_MAXIO ; i ++ ) {
! 		if ( iocb_array[i].u.c.buf != NULL ) {
! 			free ( iocb_array[i].u.c.buf );
! 		}
! 	}
! 	
! 	io_queue_release ( myctx );
! 	
! 	return 0;
! }
! 
! int test_main(void)
! {
! 	int	status = 0 ;
! 	//char *filepath = "testdir/file1";
! 	
!     printf("running test 1 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , AIO_MAXIO , IO_CMD_PWRITE);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 2 \n");
! 	status = io_tio( "testdir/file1" , O_RDONLY | O_DIRECT | O_LARGEFILE , AIO_MAXIO , IO_CMD_PREAD);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 3 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_RDWR , AIO_MAXIO , IO_CMD_PWRITE );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 4 \n");
! 	status = io_tio( "testdir/file1" , O_RDWR , AIO_MAXIO , IO_CMD_PREAD );
! 	if ( status ) {
! 		return status;
! 	}
! 		
!     printf("running test 5 \n");
! 	status = io_tio( "testdir/file1" , O_TRUNC | O_WRONLY , AIO_MAXIO , IO_CMD_PWRITE );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 6 \n");
! 	status = io_tio( "testdir/file1" , O_RDONLY , AIO_MAXIO , IO_CMD_PREAD );
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 7 \n");
! 	status = io_tio( "testdir/file2" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , 
! 				AIO_MAXIO , IO_CMD_FSYNC);
! 	if ( status ) {
! 		return status;
! 	}
! 	
!     printf("running test 8 \n");
! 	status = io_tio( "testdir/file2" , O_TRUNC | O_DIRECT | O_WRONLY | O_CREAT | O_LARGEFILE , 
! 				AIO_MAXIO , IO_CMD_FDSYNC);
! 	if ( status ) {
! 		return status;
! 	}
! 	
! 	return status;
! }
!