1998-08-17 10:13:32 +04:00
/*
2002-01-30 09:08:46 +03:00
Unix SMB / CIFS implementation .
1998-08-17 10:13:32 +04:00
Manage connections_struct structures
Copyright ( C ) Andrew Tridgell 1998
2002-08-17 19:27:10 +04:00
Copyright ( C ) Alexander Bokovoy 2002
1998-08-17 10:13:32 +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
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 0213 9 , USA .
*/
# include "includes.h"
/* set these to define the limits of the server. NOTE These are on a
per - client basis . Thus any one machine can ' t connect to more than
MAX_CONNECTIONS services , but any number of machines may connect at
one time . */
# define MAX_CONNECTIONS 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 ( MAX_CONNECTIONS ) ;
}
/****************************************************************************
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 ( int cnum )
{
1998-08-17 10:47:53 +04:00
int count = 0 ;
1998-08-17 10:13:32 +04:00
connection_struct * conn ;
1998-08-17 10:47:53 +04:00
for ( conn = Connections ; conn ; conn = conn - > next , count + + ) {
if ( conn - > cnum = = cnum ) {
if ( count > 10 ) {
DLIST_PROMOTE ( Connections , conn ) ;
}
return conn ;
}
1998-08-17 10:13:32 +04:00
}
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 )
{
connection_struct * conn ;
int i ;
i = bitmap_find ( bmap , 1 ) ;
if ( i = = - 1 ) {
DEBUG ( 1 , ( " ERROR! Out of connection structures \n " ) ) ;
return NULL ;
}
conn = ( connection_struct * ) malloc ( sizeof ( * conn ) ) ;
if ( ! conn ) return NULL ;
1998-09-05 17:24:20 +04:00
ZERO_STRUCTP ( conn ) ;
1998-08-17 10:13:32 +04:00
conn - > cnum = i ;
bitmap_set ( bmap , i ) ;
num_open + + ;
2000-01-16 14:18:04 +03:00
string_set ( & conn - > user , " " ) ;
string_set ( & conn - > dirpath , " " ) ;
string_set ( & conn - > connectpath , " " ) ;
string_set ( & conn - > origpath , " " ) ;
1998-08-17 10:13:32 +04:00
1998-08-17 10:47:53 +04:00
DLIST_ADD ( Connections , conn ) ;
1998-08-17 10:13:32 +04:00
return conn ;
}
/****************************************************************************
close all conn structures
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
void conn_close_all ( void )
{
connection_struct * conn , * next ;
for ( conn = Connections ; conn ; conn = next ) {
next = conn - > next ;
2002-09-25 19:19:00 +04:00
close_cnum ( conn , conn - > vuid ) ;
1998-08-17 10:13:32 +04:00
}
}
/****************************************************************************
idle inactive connections
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
BOOL conn_idle_all ( time_t t , int deadtime )
{
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 ;
}
return allidle ;
}
2002-09-25 19:19:00 +04:00
/****************************************************************************
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 ;
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 ;
}
}
}
}
1998-08-17 10:13:32 +04:00
/****************************************************************************
2000-08-04 02:38:43 +04:00
Free a conn structure .
1998-08-17 10:13:32 +04:00
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
2000-08-04 02:38:43 +04:00
1998-08-17 10:13:32 +04:00
void conn_free ( connection_struct * conn )
{
2002-08-17 19:27:10 +04:00
smb_vfs_handle_struct * handle , * thandle ;
void ( * done_fptr ) ( connection_struct * the_conn ) ;
2000-04-29 01:09:26 +04:00
/* Free vfs_connection_struct */
2002-08-17 19:27:10 +04:00
handle = conn - > vfs_private ;
while ( handle ) {
/* Close dlopen() handle */
done_fptr = ( void ( * ) ( connection_struct * ) ) sys_dlsym ( handle - > handle , " vfs_done " ) ;
if ( done_fptr = = NULL ) {
DEBUG ( 3 , ( " No vfs_done() symbol found in module with handle %p, ignoring \n " , handle - > handle ) ) ;
} else {
done_fptr ( conn ) ;
}
sys_dlclose ( handle - > handle ) ;
DLIST_REMOVE ( conn - > vfs_private , handle ) ;
thandle = handle - > next ;
SAFE_FREE ( handle ) ;
handle = thandle ;
2000-04-29 01:09:26 +04:00
}
1998-08-17 10:47:53 +04:00
DLIST_REMOVE ( Connections , conn ) ;
1998-08-17 10:13:32 +04:00
if ( conn - > ngroups & & conn - > groups ) {
2001-09-17 15:25:41 +04:00
SAFE_FREE ( conn - > groups ) ;
1998-08-17 10:13:32 +04:00
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 - - ;
1998-09-05 17:24:20 +04:00
ZERO_STRUCTP ( conn ) ;
2001-09-17 15:25:41 +04:00
SAFE_FREE ( conn ) ;
1998-08-17 10:13:32 +04:00
}
2001-06-20 07:05:09 +04:00
/****************************************************************************
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 ) ;
}
}
}