smbd/conn.c

ソースコードを見る。

関数
void	conn_init (void)
int	conn_num_open (void)
BOOL	conn_snum_used (int snum)
connection_struct *	conn_find (unsigned cnum)
connection_struct *	conn_new (void)
void	conn_close_all (void)
BOOL	conn_idle_all (time_t t, int deadtime)
void	conn_clear_vuid_cache (uint16 vuid)
void	conn_free_internal (connection_struct *conn)
void	conn_free (connection_struct *conn)
void	msg_force_tdis (int msg_type, struct process_id pid, void *buf, size_t len, void *private_data)
変数
static connection_struct *	Connections
static struct bitmap *	bmap
static int	num_open

---

関数

void conn_init

(

void

)

conn.c の 39 行で定義されています。

参照先 bitmap_allocate()・bmap.

参照元 init_structs()・main().

{
        bmap = bitmap_allocate(BITMAP_BLOCK_SZ);
}

int conn_num_open

(

void

)

conn.c の 47 行で定義されています。

参照先 num_open.

参照元 make_connection()・timeout_processing().

{
        return num_open;
}

BOOL conn_snum_used

(

int

snum

)

conn.c の 56 行で定義されています。

参照先 Connections・connection_struct::next・connection_struct::params・share_params::service.

{
        connection_struct *conn;
        for (conn=Connections;conn;conn=conn->next) {
                if (conn->params->service == snum) {
                        return(True);
                }
        }
        return(False);
}

connection_struct* conn_find

(

unsigned

cnum

)

conn.c の 71 行で定義されています。

参照先 connection_struct::cnum・Connections・connection_struct::next.

参照元 process_blocking_lock_queue()・switch_message().

{
        int count=0;
        connection_struct *conn;

        for (conn=Connections;conn;conn=conn->next,count++) {
                if (conn->cnum == cnum) {
                        if (count > 10) {
                                DLIST_PROMOTE(Connections, conn);
                        }
                        return conn;
                }
        }

        return NULL;
}

connection_struct* conn_new

(

void

)

conn.c の 93 行で定義されています。

参照先 bitmap_allocate()・bitmap_copy()・bitmap_find()・bitmap_free()・bitmap_set()・bmap・connection_struct::cnum・Connections・connection_struct::connectpath・connection_struct::dirpath・connection_struct::mem_ctx・bitmap::n・num_open・connection_struct::origpath・connection_struct::params・string_set()・talloc_init()・connection_struct::user.

参照元 main()・make_connection_snum().

{
        TALLOC_CTX *mem_ctx;
        connection_struct *conn;
        int i;
        int find_offset = 1;

find_again:
        i = bitmap_find(bmap, find_offset);
        
        if (i == -1) {
                /* Expand the connections bitmap. */
                int             oldsz = bmap->n;
                int             newsz = bmap->n + BITMAP_BLOCK_SZ;
                struct bitmap * nbmap;

                if (newsz <= oldsz) {
                        /* Integer wrap. */
                        DEBUG(0,("ERROR! Out of connection structures\n"));
                        return NULL;
                }

                DEBUG(4,("resizing connections bitmap from %d to %d\n",
                        oldsz, newsz));

                nbmap = bitmap_allocate(newsz);
                if (!nbmap) {
                        DEBUG(0,("ERROR! malloc fail.\n"));
                        return NULL;
                }

                bitmap_copy(nbmap, bmap);
                bitmap_free(bmap);

                bmap = nbmap;
                find_offset = oldsz; /* Start next search in the new portion. */

                goto find_again;
        }

        /* The bitmap position is used below as the connection number
         * conn->cnum). This ends up as the TID field in the SMB header,
         * which is limited to 16 bits (we skip 0xffff which is the
         * NULL TID).
         */
        if (i > 65534) {
                DEBUG(0, ("Maximum connection limit reached\n"));
                return NULL;
        }

        if ((mem_ctx=talloc_init("connection_struct"))==NULL) {
                DEBUG(0,("talloc_init(connection_struct) failed!\n"));
                return NULL;
        }

        if (!(conn=TALLOC_ZERO_P(mem_ctx, connection_struct)) ||
            !(conn->params = TALLOC_P(mem_ctx, struct share_params))) {
                DEBUG(0,("TALLOC_ZERO() failed!\n"));
                TALLOC_FREE(mem_ctx);
                return NULL;
        }
        conn->mem_ctx = mem_ctx;
        conn->cnum = i;

        bitmap_set(bmap, i);

        num_open++;

        string_set(&conn->user,"");
        string_set(&conn->dirpath,"");
        string_set(&conn->connectpath,"");
        string_set(&conn->origpath,"");
        
        DLIST_ADD(Connections, conn);

        return conn;
}

void conn_close_all

(

void

)

conn.c の 175 行で定義されています。

参照先 close_cnum()・Connections・connection_struct::next・set_current_service()・connection_struct::vuid.

参照元 exit_server_common()・msg_force_tdis()・setup_new_vc_session().

{
        connection_struct *conn, *next;
        for (conn=Connections;conn;conn=next) {
                next=conn->next;
                set_current_service(conn, 0, True);
                close_cnum(conn, conn->vuid);
        }
}

BOOL conn_idle_all	(	time_t	t,
		int	deadtime
	)

conn.c の 189 行で定義されています。

参照先 Connections・dptr_idlecnum()・connection_struct::lastused・connection_struct::lastused_count・connection_struct::next.

参照元 timeout_processing().

{
        pipes_struct *plist = NULL;
        BOOL allidle = True;
        connection_struct *conn, *next;

        for (conn=Connections;conn;conn=next) {
                next=conn->next;

                /* Update if connection wasn't idle. */
                if (conn->lastused != conn->lastused_count) {
                        conn->lastused = t;
                        conn->lastused_count = t;
                }

                /* close dirptrs on connections that are idle */
                if ((t-conn->lastused) > DPTR_IDLE_TIMEOUT) {
                        dptr_idlecnum(conn);
                }

                if (conn->num_files_open > 0 || (t-conn->lastused)<deadtime) {
                        allidle = False;
                }
        }

        /*
         * Check all pipes for any open handles. We cannot
         * idle with a handle open.
         */

        for (plist = get_first_internal_pipe(); plist; plist = get_next_internal_pipe(plist))
                if (plist->pipe_handles && plist->pipe_handles->count)
                        allidle = False;
        
        return allidle;
}

void conn_clear_vuid_cache

(

uint16

vuid

)

conn.c の 230 行で定義されています。

参照先 vuid_cache::array・Connections・vuid_cache::entries・connection_struct::next・vuid_cache_entry::vuid・connection_struct::vuid・connection_struct::vuid_cache.

参照元 invalidate_vuid().

{
        connection_struct *conn;
        unsigned int i;

        for (conn=Connections;conn;conn=conn->next) {
                if (conn->vuid == vuid) {
                        conn->vuid = UID_FIELD_INVALID;
                }

                for (i=0;i<conn->vuid_cache.entries && i< VUID_CACHE_SIZE;i++) {
                        if (conn->vuid_cache.array[i].vuid == vuid) {
                                struct vuid_cache_entry *ent = &conn->vuid_cache.array[i];
                                ent->vuid = UID_FIELD_INVALID;
                                ent->read_only = False;
                                ent->admin_user = False;
                        }
                }
        }
}

void conn_free_internal

(

connection_struct *

conn

)

conn.c の 255 行で定義されています。

参照先 connection_struct::aio_write_behind_list・connection_struct::connectpath・trans_state::data・connection_struct::dirpath・free_namearray()・handle・connection_struct::hide_list・connection_struct::mem_ctx・trans_state::next・connection_struct::origpath・trans_state::param・connection_struct::pending_trans・string_free()・connection_struct::user・connection_struct::veto_list・connection_struct::veto_oplock_list・connection_struct::vfs_handles.

参照元 conn_free()・create_conn_struct()・create_msdfs_link()・form_junctions()・get_nt_acl_no_snum()・get_referred_path()・remove_msdfs_link().

{
        vfs_handle_struct *handle = NULL, *thandle = NULL;
        TALLOC_CTX *mem_ctx = NULL;
        struct trans_state *state = NULL;

        /* Free vfs_connection_struct */
        handle = conn->vfs_handles;
        while(handle) {
                DLIST_REMOVE(conn->vfs_handles, handle);
                thandle = handle->next;
                if (handle->free_data)
                        handle->free_data(&handle->data);
                handle = thandle;
        }

        /* Free any pending transactions stored on this conn. */
        for (state = conn->pending_trans; state; state = state->next) {
                /* state->setup is a talloc child of state. */
                SAFE_FREE(state->param);
                SAFE_FREE(state->data);
        }

        free_namearray(conn->veto_list);
        free_namearray(conn->hide_list);
        free_namearray(conn->veto_oplock_list);
        free_namearray(conn->aio_write_behind_list);
        
        string_free(&conn->user);
        string_free(&conn->dirpath);
        string_free(&conn->connectpath);
        string_free(&conn->origpath);

        mem_ctx = conn->mem_ctx;
        ZERO_STRUCTP(conn);
        talloc_destroy(mem_ctx);
}

void conn_free

(

connection_struct *

conn

)

conn.c の 297 行で定義されています。

参照先 bitmap_clear()・bmap・connection_struct::cnum・conn_free_internal()・Connections・num_open.

参照元 close_cnum()・main()・make_connection_snum()・make_connection_with_chdir().

{
        DLIST_REMOVE(Connections, conn);

        bitmap_clear(bmap, conn->cnum);
        num_open--;

        conn_free_internal(conn);
}

void msg_force_tdis	(	int	msg_type,
		struct process_id	pid,
		void *	buf,
		size_t	len,
		void *	private_data
	)

conn.c の 313 行で定義されています。

参照先 close_cnum()・connection_struct::cnum・conn_close_all()・Connections・connection_struct::next・trans_state::next・strequal().

参照元 main().

{
        connection_struct *conn, *next;
        fstring sharename;

        fstrcpy(sharename, (const char *)buf);

        if (strcmp(sharename, "*") == 0) {
                DEBUG(1,("Forcing close of all shares\n"));
                conn_close_all();
                return;
        }

        for (conn=Connections;conn;conn=next) {
                next=conn->next;
                if (strequal(lp_servicename(SNUM(conn)), sharename)) {
                        DEBUG(1,("Forcing close of share %s cnum=%d\n",
                                 sharename, conn->cnum));
                        close_cnum(conn, (uint16)-1);
                }
        }
}

---

変数

connection_struct* Connections [static]

conn.c の 30 行で定義されています。

参照元 conn_clear_vuid_cache()・conn_close_all()・conn_find()・conn_free()・conn_idle_all()・conn_new()・conn_snum_used()・msg_force_tdis().

struct bitmap* bmap [static]

conn.c の 33 行で定義されています。

int num_open [static]

conn.c の 34 行で定義されています。

参照元 conn_free()・conn_new()・conn_num_open()・get_print_db_byname().

---