104 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			104 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*
 | |
|  * This file is distributed as part of MaxScale.  It 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,
 | |
|  * version 2.
 | |
|  *
 | |
|  * 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, Inc., 51
 | |
|  * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 | |
|  *
 | |
|  * Copyright MariaDB Corporation Ab 2014
 | |
|  */
 | |
| 
 | |
| /**
 | |
|  *
 | |
|  * @verbatim
 | |
|  * Revision History
 | |
|  *
 | |
|  * Date		Who			Description
 | |
|  * 11-09-2014	Martin Brampton		Initial implementation
 | |
|  *
 | |
|  * @endverbatim
 | |
|  */
 | |
| 
 | |
| #include <stdio.h>
 | |
| #include <stdlib.h>
 | |
| #include <string.h>
 | |
| #include <errno.h>
 | |
| #include <poll.h>
 | |
| #include <dcb.h>
 | |
| 
 | |
| /**
 | |
|  * test1	Allocate a service and do lots of other things
 | |
|  *
 | |
|   */
 | |
| 
 | |
| static int
 | |
| test1()
 | |
| {
 | |
| DCB     *dcb;
 | |
| int     result;
 | |
| 	int eno = 0;
 | |
| 
 | |
|         /* Poll tests */  
 | |
|         ss_dfprintf(stderr,
 | |
|                     "testpoll : Initialise the polling system."); 
 | |
|         poll_init();
 | |
|         ss_dfprintf(stderr, "\t..done\nAdd a DCB");
 | |
|         dcb = dcb_alloc(DCB_ROLE_REQUEST_HANDLER);
 | |
| 
 | |
| 		if(dcb == NULL){
 | |
| 			ss_dfprintf(stderr, "\nError on function call: dcb_alloc() returned NULL.\n");
 | |
| 			return 1;
 | |
| 		}
 | |
| 
 | |
|         dcb->fd = socket(AF_UNIX, SOCK_STREAM, 0);
 | |
| 
 | |
|         if(dcb->fd < 0){
 | |
| 			ss_dfprintf(stderr, "\nError on function call: socket() returned %d: %s\n",errno,strerror(errno));
 | |
| 				    return 1;
 | |
| 		}
 | |
| 
 | |
| 
 | |
|         if((eno = poll_add_dcb(dcb)) != 0){
 | |
| 			ss_dfprintf(stderr, "\nError on function call: poll_add_dcb() returned %d.\n",eno);
 | |
| 				    return 1;
 | |
| 		}
 | |
| 
 | |
|         if((eno = poll_remove_dcb(dcb)) != 0){
 | |
| 			ss_dfprintf(stderr, "\nError on function call: poll_remove_dcb() returned %d.\n",eno);
 | |
| 				    return 1;
 | |
| 		}
 | |
| 
 | |
|         if((eno = poll_add_dcb(dcb)) != 0){
 | |
| 			ss_dfprintf(stderr, "\nError on function call: poll_add_dcb() returned %d.\n",eno);
 | |
| 				    return 1;
 | |
| 		}
 | |
| 
 | |
|         ss_dfprintf(stderr, "\t..done\nStart wait for events.");
 | |
|         sleep(10);
 | |
|         poll_shutdown();
 | |
|         ss_dfprintf(stderr, "\t..done\nTidy up.");
 | |
|         dcb_free(dcb);
 | |
|         ss_dfprintf(stderr, "\t..done\n");
 | |
| 		
 | |
| 	return 0;
 | |
|         
 | |
| }
 | |
| 
 | |
| int main(int argc, char **argv)
 | |
| {
 | |
| int	result = 0;
 | |
| 
 | |
| 	result += test1();
 | |
| 
 | |
| 	exit(result);
 | |
| }
 | |
| 
 | 
