2003-08-13 05:53:07 +04:00
/*
Unix SMB / CIFS implementation .
2005-01-30 03:54:57 +03:00
2003-08-13 05:53:07 +04:00
process model : process ( 1 process handles all client connections )
2005-01-30 03:54:57 +03:00
2003-08-13 05:53:07 +04:00
Copyright ( C ) Andrew Tridgell 2003
Copyright ( C ) James J Myers 2003 < myersjj @ samba . org >
2004-07-14 01:04:56 +04:00
Copyright ( C ) Stefan ( metze ) Metzmacher 2004
2003-08-13 05:53:07 +04:00
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
2007-07-10 06:07:03 +04:00
the Free Software Foundation ; either version 3 of the License , or
2003-08-13 05:53:07 +04:00
( 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
2007-07-10 06:07:03 +04:00
along with this program . If not , see < http : //www.gnu.org/licenses/>.
2003-08-13 05:53:07 +04:00
*/
# include "includes.h"
2006-03-26 05:23:40 +04:00
# include "smbd/process_model.h"
2006-11-07 15:03:01 +03:00
# include "system/filesys.h"
2007-01-10 13:52:09 +03:00
# include "cluster/cluster.h"
2003-08-13 05:53:07 +04:00
/*
called when the process model is selected
*/
2005-01-30 03:54:57 +03:00
static void single_model_init ( struct event_context * ev )
2005-01-14 04:32:56 +03:00
{
2003-08-13 05:53:07 +04:00
}
/*
2005-01-30 03:54:57 +03:00
called when a listening socket becomes readable .
2003-08-13 05:53:07 +04:00
*/
2005-01-30 03:54:57 +03:00
static void single_accept_connection ( struct event_context * ev ,
2008-01-06 04:03:43 +03:00
struct loadparm_context * lp_ctx ,
2005-01-30 03:54:57 +03:00
struct socket_context * sock ,
2008-01-06 04:03:43 +03:00
void ( * new_conn ) ( struct event_context * ,
struct loadparm_context * ,
struct socket_context * ,
2007-01-10 13:52:09 +03:00
struct server_id , void * ) ,
2005-01-30 03:54:57 +03:00
void * private )
2003-08-13 05:53:07 +04:00
{
2004-09-20 16:31:07 +04:00
NTSTATUS status ;
2005-01-30 03:54:57 +03:00
struct socket_context * sock2 ;
2004-07-14 01:04:56 +04:00
2003-08-13 05:53:07 +04:00
/* accept an incoming connection. */
2005-01-30 03:54:57 +03:00
status = socket_accept ( sock , & sock2 ) ;
2004-09-20 16:31:07 +04:00
if ( ! NT_STATUS_IS_OK ( status ) ) {
2006-09-22 07:49:24 +04:00
DEBUG ( 0 , ( " single_accept_connection: accept: %s \n " , nt_errstr ( status ) ) ) ;
2005-10-12 15:04:01 +04:00
/* this looks strange, but is correct. We need to
throttle things until the system clears enough
resources to handle this new socket . If we don ' t
then we will spin filling the log and causing more
problems . We don ' t panic as this is probably a
temporary resource constraint */
sleep ( 1 ) ;
2003-12-13 13:58:48 +03:00
return ;
}
2004-07-14 01:04:56 +04:00
2005-01-30 03:54:57 +03:00
talloc_steal ( private , sock ) ;
2004-09-26 07:05:04 +04:00
2008-01-06 04:03:43 +03:00
new_conn ( ev , lp_ctx , sock2 , cluster_id ( socket_get_fd ( sock2 ) ) , private ) ;
2003-08-13 05:53:07 +04:00
}
2005-01-30 05:55:30 +03:00
/*
called to startup a new task
*/
static void single_new_task ( struct event_context * ev ,
2008-01-06 04:03:43 +03:00
struct loadparm_context * lp_ctx ,
void ( * new_task ) ( struct event_context * , struct loadparm_context * , struct server_id , void * ) ,
2005-01-30 05:55:30 +03:00
void * private )
{
static uint32_t taskid = 0x10000000 ;
2008-01-06 04:03:43 +03:00
new_task ( ev , lp_ctx , cluster_id ( taskid + + ) , private ) ;
2005-01-30 05:55:30 +03:00
}
2004-07-14 01:04:56 +04:00
2005-01-30 05:55:30 +03:00
/* called when a task goes down */
static void single_terminate ( struct event_context * ev , const char * reason )
2003-12-14 02:25:15 +03:00
{
2005-02-16 04:48:11 +03:00
DEBUG ( 2 , ( " single_terminate: reason[%s] \n " , reason ) ) ;
2004-02-02 16:43:03 +03:00
}
2006-03-09 20:48:41 +03:00
/* called to set a title of a task or connection */
static void single_set_title ( struct event_context * ev , const char * title )
{
}
2007-09-03 17:13:25 +04:00
const struct model_ops single_ops = {
2005-01-14 04:32:56 +03:00
. name = " single " ,
. model_init = single_model_init ,
2005-01-30 05:55:30 +03:00
. new_task = single_new_task ,
2005-01-14 04:32:56 +03:00
. accept_connection = single_accept_connection ,
2005-01-30 05:55:30 +03:00
. terminate = single_terminate ,
2006-03-09 20:48:41 +03:00
. set_title = single_set_title ,
2005-01-14 04:32:56 +03:00
} ;
2003-08-13 05:53:07 +04:00
/*
2005-01-30 03:54:57 +03:00
initialise the single process model , registering ourselves with the
process model subsystem
2003-08-13 05:53:07 +04:00
*/
2004-02-02 16:43:03 +03:00
NTSTATUS process_model_single_init ( void )
2003-08-13 05:53:07 +04:00
{
2005-01-30 03:54:57 +03:00
return register_process_model ( & single_ops ) ;
2003-08-13 05:53:07 +04:00
}