kernel/network/userland_ipc.c

103 static status_t init_connection(net_connection *connection, connection_cookie **_cookie);
131 		localArea[i].id = clone_area("net connection",(void **)&localArea[i].offset,B_ANY_ADDRESS,
242 				printf("Opening socket connection, mode = %lx!\n", cookie->openFlags);
246 				printf("Closing socket connection...\n");
447 init_connection(net_connection *connection, connection_cookie **_cookie)
458 	connection->area = create_area("net connection", (void *) &commands, B_ANY_ADDRESS,
461 	if (connection->area < B_OK) {
462 		fprintf(stderr, "couldn't create area: %s.\n", strerror(connection->area));
464 		return connection->area;
468 	connection->port = create_port(CONNECTION_QUEUE_LENGTH, "net stack connection");
469 	if (connection->port < B_OK) {
470 		fprintf(stderr, "couldn't create port: %s.\n", strerror(connection->port));
471 		delete_area(connection->area);
473 		return connection->port;
476 	connection->commandSemaphore = create_sem(0, "net command queue");
477 	if (connection->commandSemaphore < B_OK) {
478 		fprintf(stderr, "couldn't create semaphore: %s.\n", strerror(connection->commandSemaphore));
479 		delete_area(connection->area);
480 		delete_port(connection->port);
482 		return connection->commandSemaphore;
485 	cookie->runner = spawn_thread(connection_runner, "connection runner", B_NORMAL_PRIORITY, cookie);
488 		delete_sem(connection->commandSemaphore);
489 		delete_area(connection->area);
490 		delete_port(connection->port);
495 	connection->socket_thread = cookie->runner;
497 	connection->numCommands = NUM_COMMANDS;
498 	connection->bufferSize = CONNECTION_BUFFER_SIZE;
500 	// setup connection cookie
501 	cookie->area = connection->area;
504 	cookie->commandSemaphore = connection->commandSemaphore;
505 	cookie->localPort = connection->port;
543 			net_connection connection;
546 			printf("incoming connection...\n");
547 			if (init_connection(&connection, &cookie) == B_OK)
548 				write_port(port, NET_STACK_NEW_CONNECTION, &connection, sizeof(net_connection));
564 	gConnectionOpener = spawn_thread(connection_opener, "connection opener", B_NORMAL_PRIORITY, NULL);