mirror of
https://github.com/samba-team/samba.git
synced 2024-12-24 21:34:56 +03:00
b05b6046fc
by increasing bitmap size. Limited by "max connections" parameter.
Bug #716.
Jeremy.
(This used to be commit fbbeb55b23
)
294 lines
7.9 KiB
C
294 lines
7.9 KiB
C
/*
|
|
Unix SMB/CIFS implementation.
|
|
Manage connections_struct structures
|
|
Copyright (C) Andrew Tridgell 1998
|
|
Copyright (C) Alexander Bokovoy 2002
|
|
|
|
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
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(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
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
*/
|
|
|
|
#include "includes.h"
|
|
|
|
/* The connections bitmap is expanded in increments of BITMAP_BLOCK_SZ. The
|
|
* maximum size of the bitmap is the largest positive integer, but you will hit
|
|
* the "max connections" limit, looong before that.
|
|
*/
|
|
#define BITMAP_BLOCK_SZ 128
|
|
|
|
static connection_struct *Connections;
|
|
|
|
/* number of open connections */
|
|
static struct bitmap *bmap;
|
|
static int num_open;
|
|
|
|
/****************************************************************************
|
|
init the conn structures
|
|
****************************************************************************/
|
|
void conn_init(void)
|
|
{
|
|
bmap = bitmap_allocate(BITMAP_BLOCK_SZ);
|
|
}
|
|
|
|
/****************************************************************************
|
|
return the number of open connections
|
|
****************************************************************************/
|
|
int conn_num_open(void)
|
|
{
|
|
return num_open;
|
|
}
|
|
|
|
|
|
/****************************************************************************
|
|
check if a snum is in use
|
|
****************************************************************************/
|
|
BOOL conn_snum_used(int snum)
|
|
{
|
|
connection_struct *conn;
|
|
for (conn=Connections;conn;conn=conn->next) {
|
|
if (conn->service == snum) {
|
|
return(True);
|
|
}
|
|
}
|
|
return(False);
|
|
}
|
|
|
|
|
|
/****************************************************************************
|
|
find a conn given a cnum
|
|
****************************************************************************/
|
|
connection_struct *conn_find(unsigned cnum)
|
|
{
|
|
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;
|
|
}
|
|
|
|
|
|
/****************************************************************************
|
|
find first available connection slot, starting from a random position.
|
|
The randomisation stops problems with the server dieing and clients
|
|
thinking the server is still available.
|
|
****************************************************************************/
|
|
connection_struct *conn_new(void)
|
|
{
|
|
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 <= 0) {
|
|
/* 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);
|
|
|
|
bitmap_copy(nbmap, bmap);
|
|
bitmap_free(bmap);
|
|
|
|
bmap = nbmap;
|
|
find_offset = oldsz; /* Start next search in the new portion. */
|
|
|
|
goto find_again;
|
|
}
|
|
|
|
if ((mem_ctx=talloc_init("connection_struct"))==NULL) {
|
|
DEBUG(0,("talloc_init(connection_struct) failed!\n"));
|
|
return NULL;
|
|
}
|
|
|
|
if ((conn=(connection_struct *)talloc_zero(mem_ctx, sizeof(*conn)))==NULL) {
|
|
DEBUG(0,("talloc_zero() failed!\n"));
|
|
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;
|
|
}
|
|
|
|
/****************************************************************************
|
|
close all conn structures
|
|
****************************************************************************/
|
|
void conn_close_all(void)
|
|
{
|
|
connection_struct *conn, *next;
|
|
for (conn=Connections;conn;conn=next) {
|
|
next=conn->next;
|
|
close_cnum(conn, conn->vuid);
|
|
}
|
|
}
|
|
|
|
/****************************************************************************
|
|
Idle inactive connections.
|
|
****************************************************************************/
|
|
|
|
BOOL conn_idle_all(time_t t, int deadtime)
|
|
{
|
|
pipes_struct *plist = NULL;
|
|
BOOL allidle = True;
|
|
connection_struct *conn, *next;
|
|
|
|
for (conn=Connections;conn;conn=next) {
|
|
next=conn->next;
|
|
/* 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;
|
|
}
|
|
|
|
/****************************************************************************
|
|
clear a vuid out of the validity cache, and as the 'owner' of a connection.
|
|
****************************************************************************/
|
|
void conn_clear_vuid_cache(uint16 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.list[i] == vuid) {
|
|
conn->vuid_cache.list[i] = UID_FIELD_INVALID;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/****************************************************************************
|
|
Free a conn structure.
|
|
****************************************************************************/
|
|
|
|
void conn_free(connection_struct *conn)
|
|
{
|
|
vfs_handle_struct *handle = NULL, *thandle = NULL;
|
|
TALLOC_CTX *mem_ctx = 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;
|
|
}
|
|
|
|
DLIST_REMOVE(Connections, conn);
|
|
|
|
if (conn->ngroups && conn->groups) {
|
|
SAFE_FREE(conn->groups);
|
|
conn->ngroups = 0;
|
|
}
|
|
|
|
free_namearray(conn->veto_list);
|
|
free_namearray(conn->hide_list);
|
|
free_namearray(conn->veto_oplock_list);
|
|
|
|
string_free(&conn->user);
|
|
string_free(&conn->dirpath);
|
|
string_free(&conn->connectpath);
|
|
string_free(&conn->origpath);
|
|
|
|
bitmap_clear(bmap, conn->cnum);
|
|
num_open--;
|
|
|
|
mem_ctx = conn->mem_ctx;
|
|
ZERO_STRUCTP(conn);
|
|
talloc_destroy(mem_ctx);
|
|
}
|
|
|
|
|
|
/****************************************************************************
|
|
receive a smbcontrol message to forcibly unmount a share
|
|
the message contains just a share name and all instances of that
|
|
share are unmounted
|
|
the special sharename '*' forces unmount of all shares
|
|
****************************************************************************/
|
|
void msg_force_tdis(int msg_type, pid_t pid, void *buf, size_t len)
|
|
{
|
|
connection_struct *conn, *next;
|
|
fstring sharename;
|
|
|
|
fstrcpy(sharename, 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(conn->service), sharename)) {
|
|
DEBUG(1,("Forcing close of share %s cnum=%d\n",
|
|
sharename, conn->cnum));
|
|
close_cnum(conn, (uint16)-1);
|
|
}
|
|
}
|
|
}
|