smbd/connection.c

ソースコードを見る。

データ構造
struct	count_stat
関数
TDB_CONTEXT *	conn_tdb_ctx (void)
static void	make_conn_key (connection_struct *conn, const char *name, TDB_DATA *pkbuf, struct connections_key *pkey)
BOOL	yield_connection (connection_struct *conn, const char *name)
static int	count_fn (TDB_CONTEXT *the_tdb, TDB_DATA kbuf, TDB_DATA dbuf, void *udp)
int	count_current_connections (const char *sharename, BOOL clear)
BOOL	claim_connection (connection_struct *conn, const char *name, int max_connections, BOOL Clear, uint32 msg_flags)
BOOL	register_message_flags (BOOL doreg, uint32 msg_flags)
static TDB_DATA *	make_pipe_rec_key (struct pipe_open_rec *prec)
static void	fill_pipe_open_rec (struct pipe_open_rec *prec, smb_np_struct *p)
BOOL	store_pipe_opendb (smb_np_struct *p)
BOOL	delete_pipe_opendb (smb_np_struct *p)
変数
static TDB_CONTEXT *	tdb

---

関数

TDB_CONTEXT* conn_tdb_ctx

(

void

)

connection.c の 29 行で定義されています。

参照先 lock_path()・tdb・tdb_open_log().

参照元 _srv_net_share_add()・_srv_net_share_del()・_srv_net_share_set_info()・add_printer_hook()・api_RNetShareAdd()・claim_connection()・delete_pipe_opendb()・delete_printer_hook()・main()・net_enum_pipes()・send_stat_cache_delete_message()・store_pipe_opendb().

{
        if (!tdb)
                tdb = tdb_open_log(lock_path("connections.tdb"), 0, TDB_CLEAR_IF_FIRST|TDB_DEFAULT, 
                               O_RDWR | O_CREAT, 0644);

        return tdb;
}

static void make_conn_key	(	connection_struct *	conn,
		const char *	name,
		TDB_DATA *	pkbuf,
		struct connections_key *	pkey
	)			[static]

connection.c の 38 行で定義されています。

参照先 connection_struct::cnum・connections_key::cnum・TDB_DATA::dptr・TDB_DATA::dsize・connections_key::name・connections_key::pid・procid_self().

参照元 claim_connection()・register_message_flags()・yield_connection().

{
        ZERO_STRUCTP(pkey);
        pkey->pid = procid_self();
        pkey->cnum = conn?conn->cnum:-1;
        fstrcpy(pkey->name, name);
#ifdef DEVELOPER
        /* valgrind fixer... */
        {
                size_t sl = strlen(pkey->name);
                if (sizeof(fstring)-sl)
                        memset(&pkey->name[sl], '\0', sizeof(fstring)-sl);
        }
#endif

        pkbuf->dptr = (char *)pkey;
        pkbuf->dsize = sizeof(*pkey);
}

BOOL yield_connection	(	connection_struct *	conn,
		const char *	name
	)

connection.c の 61 行で定義されています。

参照先 make_conn_key()・tdb・tdb_delete()・TDB_ERR_NOEXIST・tdb_error()・tdb_errorstr().

参照元 close_cnum()・exit_server_common()・make_connection_with_chdir().

{
        struct connections_key key;
        TDB_DATA kbuf;

        if (!tdb)
                return False;

        DEBUG(3,("Yielding connection to %s\n",name));

        make_conn_key(conn, name, &kbuf, &key);

        if (tdb_delete(tdb, kbuf) != 0) {
                int dbg_lvl = (!conn && (tdb_error(tdb) == TDB_ERR_NOEXIST)) ? 3 : 0;
                DEBUG(dbg_lvl,("yield_connection: tdb_delete for name %s failed with error %s.\n",
                        name, tdb_errorstr(tdb) ));
                return (False);
        }

        return(True);
}

static int count_fn	(	TDB_CONTEXT *	the_tdb,
		TDB_DATA	kbuf,
		TDB_DATA	dbuf,
		void *	udp
	)			[static]

connection.c の 94 行で定義されています。

参照先 cs・TDB_DATA::dptr・TDB_DATA::dsize・errno・process_exists()・procid_str_static()・strequal()・tdb・tdb_delete()・tdb_errorstr().

参照元 count_current_connections().

{
        struct connections_data crec;
        struct count_stat *cs = (struct count_stat *)udp;
 
        if (dbuf.dsize != sizeof(crec))
                return 0;

        memcpy(&crec, dbuf.dptr, sizeof(crec));
 
        if (crec.cnum == -1)
                return 0;

        /* If the pid was not found delete the entry from connections.tdb */

        if (cs->Clear && !process_exists(crec.pid) && (errno == ESRCH)) {
                DEBUG(2,("pid %s doesn't exist - deleting connections %d [%s]\n",
                        procid_str_static(&crec.pid), crec.cnum, crec.servicename));
                if (tdb_delete(the_tdb, kbuf) != 0)
                        DEBUG(0,("count_fn: tdb_delete failed with error %s\n", tdb_errorstr(tdb) ));
                return 0;
        }

        if (strequal(crec.servicename, cs->name))
                cs->curr_connections++;

        return 0;
}

int count_current_connections	(	const char *	sharename,
		BOOL	clear
	)

connection.c の 127 行で定義されています。

参照先 count_fn()・cs・sys_getpid()・tdb・tdb_errorstr()・tdb_traverse().

参照元 claim_connection()・init_srv_share_info_2().

{
        struct count_stat cs;

        cs.mypid = sys_getpid();
        cs.curr_connections = 0;
        cs.name = sharename;
        cs.Clear = clear;

        /*
         * This has a race condition, but locking the chain before hand is worse
         * as it leads to deadlock.
         */

        if (tdb_traverse(tdb, count_fn, &cs) == -1) {
                DEBUG(0,("claim_connection: traverse of connections.tdb failed with error %s.\n",
                        tdb_errorstr(tdb) ));
                return False;
        }
        
        return cs.curr_connections;
}

BOOL claim_connection	(	connection_struct *	conn,
		const char *	name,
		int	max_connections,
		BOOL	Clear,
		uint32	msg_flags
	)

connection.c の 154 行で定義されています。

参照先 connections_data::addr・connections_data::bcast_msg_flags・client_addr()・connection_struct::client_address・connection_struct::cnum・connections_data::cnum・conn_tdb_ctx()・count_current_connections()・get_remote_machine_name()・connection_struct::gid・connections_data::gid・connections_data::machine・connections_data::magic・make_conn_key()・connections_data::pid・procid_self()・connections_data::servicename・connections_data::start・tdb・tdb_errorstr()・tdb_store()・connection_struct::uid・connections_data::uid.

参照元 main()・reply_negprot()・start_background_queue().

{
        struct connections_key key;
        struct connections_data crec;
        TDB_DATA kbuf, dbuf;

        if (!tdb) {
                if ( (tdb =conn_tdb_ctx()) == NULL ) {
                        return False;
                }
        }
        
        /*
         * Enforce the max connections parameter.
         */

        if (max_connections > 0) {
                int curr_connections;
                
                curr_connections = count_current_connections( lp_servicename(SNUM(conn)), True );

                if (curr_connections >= max_connections) {
                        DEBUG(1,("claim_connection: Max connections (%d) exceeded for %s\n",
                                max_connections, name ));
                        return False;
                }
        }

        DEBUG(5,("claiming %s %d\n",name,max_connections));

        make_conn_key(conn, name, &kbuf, &key);

        /* fill in the crec */
        ZERO_STRUCT(crec);
        crec.magic = 0x280267;
        crec.pid = procid_self();
        crec.cnum = conn?conn->cnum:-1;
        if (conn) {
                crec.uid = conn->uid;
                crec.gid = conn->gid;
                safe_strcpy(crec.servicename,
                            lp_servicename(SNUM(conn)),sizeof(crec.servicename)-1);
        }
        crec.start = time(NULL);
        crec.bcast_msg_flags = msg_flags;
        
        safe_strcpy(crec.machine,get_remote_machine_name(),sizeof(crec.machine)-1);
        safe_strcpy(crec.addr,conn?conn->client_address:client_addr(),sizeof(crec.addr)-1);

        dbuf.dptr = (char *)&crec;
        dbuf.dsize = sizeof(crec);

        if (tdb_store(tdb, kbuf, dbuf, TDB_REPLACE) != 0) {
                DEBUG(0,("claim_connection: tdb_store failed with error %s.\n",
                        tdb_errorstr(tdb) ));
                return False;
        }

        return True;
}

BOOL register_message_flags	(	BOOL	doreg,
		uint32	msg_flags
	)

connection.c の 215 行で定義されています。

参照先 connections_data::bcast_msg_flags・TDB_DATA::dptr・make_conn_key()・tdb・tdb_errorstr()・tdb_fetch()・tdb_store().

参照元 srv_spoolss_replycloseprinter()・srv_spoolss_replyopenprinter().

{
        struct connections_key key;
        struct connections_data *pcrec;
        TDB_DATA kbuf, dbuf;

        if (!tdb)
                return False;

        DEBUG(10,("register_message_flags: %s flags 0x%x\n",
                doreg ? "adding" : "removing",
                (unsigned int)msg_flags ));

        make_conn_key(NULL, "", &kbuf, &key);

        dbuf = tdb_fetch(tdb, kbuf);
        if (!dbuf.dptr) {
                DEBUG(0,("register_message_flags: tdb_fetch failed: %s\n",
                        tdb_errorstr(tdb)));
                return False;
        }

        pcrec = (struct connections_data *)dbuf.dptr;
        if (doreg)
                pcrec->bcast_msg_flags |= msg_flags;
        else
                pcrec->bcast_msg_flags &= ~msg_flags;

        if (tdb_store(tdb, kbuf, dbuf, TDB_REPLACE) != 0) {
                DEBUG(0,("register_message_flags: tdb_store failed: %s.\n",
                        tdb_errorstr(tdb) ));
                SAFE_FREE(dbuf.dptr);
                return False;
        }

        DEBUG(10,("register_message_flags: new flags 0x%x\n",
                (unsigned int)pcrec->bcast_msg_flags ));

        SAFE_FREE(dbuf.dptr);
        return True;
}

static TDB_DATA* make_pipe_rec_key

(

struct pipe_open_rec *

prec

)

[static]

connection.c の 260 行で定義されています。

参照先 TDB_DATA::dptr・TDB_DATA::dsize・pipe_open_rec::name・pipe_open_rec::pid・pipe_open_rec::pnum・procid_to_pid()・snprintf()・talloc_strdup().

参照元 delete_pipe_opendb()・store_pipe_opendb().

{
        TDB_DATA *kbuf = NULL;
        fstring key_string;
        
        if ( !prec )
                return NULL;
        
        if ( (kbuf = TALLOC_P(prec, TDB_DATA)) == NULL ) {
                return NULL;
        }
        
        snprintf( key_string, sizeof(key_string), "%s/%d/%d",
                prec->name, procid_to_pid(&prec->pid), prec->pnum );
                
        if ( (kbuf->dptr = talloc_strdup(prec, key_string)) == NULL )
                return NULL;
                
        kbuf->dsize = strlen(key_string)+1;
        
        return kbuf;
}

static void fill_pipe_open_rec	(	struct pipe_open_rec *	prec,
		smb_np_struct *	p
	)			[static]

connection.c の 286 行で定義されています。

参照先 smb_np_struct::name・pipe_open_rec::name・pipe_open_rec::pid・pid_to_procid()・smb_np_struct::pnum・pipe_open_rec::pnum・sys_getpid()・pipe_open_rec::uid.

参照元 delete_pipe_opendb()・store_pipe_opendb().

{
        prec->pid = pid_to_procid(sys_getpid());
        prec->pnum = p->pnum;
        prec->uid = geteuid();
        fstrcpy( prec->name, p->name );

        return;
}

BOOL store_pipe_opendb

(

smb_np_struct *

p

)

connection.c の 299 行で定義されています。

参照先 conn_tdb_ctx()・TDB_DATA::dptr・TDB_DATA::dsize・fill_pipe_open_rec()・make_pipe_rec_key()・tdb_store().

参照元 nt_open_pipe().

{
        struct pipe_open_rec *prec;
        TDB_DATA *key;
        TDB_DATA data;
        TDB_CONTEXT *pipe_tdb;
        BOOL ret = False;
        
        if ( (prec = TALLOC_P( NULL, struct pipe_open_rec)) == NULL ) {
                DEBUG(0,("store_pipe_opendb: talloc failed!\n"));
                return False;
        }
        
        fill_pipe_open_rec( prec, p );
        if ( (key = make_pipe_rec_key( prec )) == NULL ) {
                goto done;
        }
        
        data.dptr = (char*)prec;
        data.dsize = sizeof(struct pipe_open_rec);
        
        if ( (pipe_tdb = conn_tdb_ctx() ) == NULL ) {
                goto done;
        }
        
        ret = (tdb_store( pipe_tdb, *key, data, TDB_REPLACE ) != -1);
        
done:
        TALLOC_FREE( prec );    
        return ret;
}

BOOL delete_pipe_opendb

(

smb_np_struct *

p

)

connection.c の 334 行で定義されています。

参照先 conn_tdb_ctx()・fill_pipe_open_rec()・make_pipe_rec_key()・tdb_delete().

参照元 close_rpc_pipe_hnd().

{
        struct pipe_open_rec *prec;
        TDB_DATA *key;
        TDB_CONTEXT *pipe_tdb;
        BOOL ret = False;
        
        if ( (prec = TALLOC_P( NULL, struct pipe_open_rec)) == NULL ) {
                DEBUG(0,("store_pipe_opendb: talloc failed!\n"));
                return False;
        }
        
        fill_pipe_open_rec( prec, p );
        if ( (key = make_pipe_rec_key( prec )) == NULL ) {
                goto done;
        }
        
        if ( (pipe_tdb = conn_tdb_ctx() ) == NULL ) {
                goto done;
        }

        ret = (tdb_delete( pipe_tdb, *key ) != -1 );
        
done:
        TALLOC_FREE( prec );
        return ret;
}

---

変数

TDB_CONTEXT* tdb [static]

connection.c の 23 行で定義されています。

---