2 Unix SMB/CIFS implementation.
3 Manage connections_struct structures
4 Copyright (C) Andrew Tridgell 1998
5 Copyright (C) Alexander Bokovoy 2002
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
23 /* The connections bitmap is expanded in increments of BITMAP_BLOCK_SZ. The
24 * maximum size of the bitmap is the largest positive integer, but you will hit
25 * the "max connections" limit, looong before that.
27 #define BITMAP_BLOCK_SZ 128
29 static connection_struct
*Connections
;
31 /* number of open connections */
32 static struct bitmap
*bmap
;
35 /****************************************************************************
36 init the conn structures
37 ****************************************************************************/
40 bmap
= bitmap_allocate(BITMAP_BLOCK_SZ
);
43 /****************************************************************************
44 return the number of open connections
45 ****************************************************************************/
46 int conn_num_open(void)
52 /****************************************************************************
53 check if a snum is in use
54 ****************************************************************************/
55 bool conn_snum_used(int snum
)
57 connection_struct
*conn
;
58 for (conn
=Connections
;conn
;conn
=conn
->next
) {
59 if (conn
->params
->service
== snum
) {
67 /****************************************************************************
68 find a conn given a cnum
69 ****************************************************************************/
70 connection_struct
*conn_find(unsigned cnum
)
73 connection_struct
*conn
;
75 for (conn
=Connections
;conn
;conn
=conn
->next
,count
++) {
76 if (conn
->cnum
== cnum
) {
78 DLIST_PROMOTE(Connections
, conn
);
88 /****************************************************************************
89 find first available connection slot, starting from a random position.
90 The randomisation stops problems with the server dieing and clients
91 thinking the server is still available.
92 ****************************************************************************/
93 connection_struct
*conn_new(void)
95 connection_struct
*conn
;
100 i
= bitmap_find(bmap
, find_offset
);
103 /* Expand the connections bitmap. */
105 int newsz
= bmap
->n
+ BITMAP_BLOCK_SZ
;
106 struct bitmap
* nbmap
;
108 if (newsz
<= oldsz
) {
110 DEBUG(0,("ERROR! Out of connection structures\n"));
114 DEBUG(4,("resizing connections bitmap from %d to %d\n",
117 nbmap
= bitmap_allocate(newsz
);
119 DEBUG(0,("ERROR! malloc fail.\n"));
123 bitmap_copy(nbmap
, bmap
);
127 find_offset
= oldsz
; /* Start next search in the new portion. */
132 /* The bitmap position is used below as the connection number
133 * conn->cnum). This ends up as the TID field in the SMB header,
134 * which is limited to 16 bits (we skip 0xffff which is the
138 DEBUG(0, ("Maximum connection limit reached\n"));
142 if (!(conn
=TALLOC_ZERO_P(NULL
, connection_struct
)) ||
143 !(conn
->params
= TALLOC_P(conn
, struct share_params
))) {
144 DEBUG(0,("TALLOC_ZERO() failed!\n"));
154 string_set(&conn
->user
,"");
155 string_set(&conn
->dirpath
,"");
156 string_set(&conn
->connectpath
,"");
157 string_set(&conn
->origpath
,"");
159 DLIST_ADD(Connections
, conn
);
164 /****************************************************************************
165 Close all conn structures.
166 ****************************************************************************/
168 void conn_close_all(void)
170 connection_struct
*conn
, *next
;
171 for (conn
=Connections
;conn
;conn
=next
) {
173 set_current_service(conn
, 0, True
);
174 close_cnum(conn
, conn
->vuid
);
178 /****************************************************************************
179 Idle inactive connections.
180 ****************************************************************************/
182 bool conn_idle_all(time_t t
)
184 int deadtime
= lp_deadtime()*60;
185 pipes_struct
*plist
= NULL
;
186 connection_struct
*conn
;
189 deadtime
= DEFAULT_SMBD_TIMEOUT
;
191 for (conn
=Connections
;conn
;conn
=conn
->next
) {
193 time_t age
= t
- conn
->lastused
;
195 /* Update if connection wasn't idle. */
196 if (conn
->lastused
!= conn
->lastused_count
) {
198 conn
->lastused_count
= t
;
201 /* close dirptrs on connections that are idle */
202 if (age
> DPTR_IDLE_TIMEOUT
) {
206 if (conn
->num_files_open
> 0 || age
< deadtime
) {
212 * Check all pipes for any open handles. We cannot
213 * idle with a handle open.
216 for (plist
= get_first_internal_pipe(); plist
;
217 plist
= get_next_internal_pipe(plist
)) {
218 if (plist
->pipe_handles
&& plist
->pipe_handles
->count
) {
226 /****************************************************************************
227 Clear a vuid out of the validity cache, and as the 'owner' of a connection.
228 ****************************************************************************/
230 void conn_clear_vuid_cache(uint16 vuid
)
232 connection_struct
*conn
;
235 for (conn
=Connections
;conn
;conn
=conn
->next
) {
236 if (conn
->vuid
== vuid
) {
237 conn
->vuid
= UID_FIELD_INVALID
;
240 for (i
=0;i
<conn
->vuid_cache
.entries
&& i
< VUID_CACHE_SIZE
;i
++) {
241 if (conn
->vuid_cache
.array
[i
].vuid
== vuid
) {
242 struct vuid_cache_entry
*ent
= &conn
->vuid_cache
.array
[i
];
243 ent
->vuid
= UID_FIELD_INVALID
;
244 ent
->read_only
= False
;
245 ent
->admin_user
= False
;
251 /****************************************************************************
252 Free a conn structure - internal part.
253 ****************************************************************************/
255 void conn_free_internal(connection_struct
*conn
)
257 vfs_handle_struct
*handle
= NULL
, *thandle
= NULL
;
258 struct trans_state
*state
= NULL
;
260 /* Free vfs_connection_struct */
261 handle
= conn
->vfs_handles
;
263 DLIST_REMOVE(conn
->vfs_handles
, handle
);
264 thandle
= handle
->next
;
265 if (handle
->free_data
)
266 handle
->free_data(&handle
->data
);
270 /* Free any pending transactions stored on this conn. */
271 for (state
= conn
->pending_trans
; state
; state
= state
->next
) {
272 /* state->setup is a talloc child of state. */
273 SAFE_FREE(state
->param
);
274 SAFE_FREE(state
->data
);
277 free_namearray(conn
->veto_list
);
278 free_namearray(conn
->hide_list
);
279 free_namearray(conn
->veto_oplock_list
);
280 free_namearray(conn
->aio_write_behind_list
);
282 string_free(&conn
->user
);
283 string_free(&conn
->dirpath
);
284 string_free(&conn
->connectpath
);
285 string_free(&conn
->origpath
);
288 talloc_destroy(conn
);
291 /****************************************************************************
292 Free a conn structure.
293 ****************************************************************************/
295 void conn_free(connection_struct
*conn
)
297 DLIST_REMOVE(Connections
, conn
);
299 bitmap_clear(bmap
, conn
->cnum
);
301 SMB_ASSERT(num_open
> 0);
304 conn_free_internal(conn
);
307 /****************************************************************************
308 receive a smbcontrol message to forcibly unmount a share
309 the message contains just a share name and all instances of that
311 the special sharename '*' forces unmount of all shares
312 ****************************************************************************/
313 void msg_force_tdis(struct messaging_context
*msg
,
316 struct server_id server_id
,
319 connection_struct
*conn
, *next
;
322 fstrcpy(sharename
, (const char *)data
->data
);
324 if (strcmp(sharename
, "*") == 0) {
325 DEBUG(1,("Forcing close of all shares\n"));
330 for (conn
=Connections
;conn
;conn
=next
) {
332 if (strequal(lp_servicename(SNUM(conn
)), sharename
)) {
333 DEBUG(1,("Forcing close of share %s cnum=%d\n",
334 sharename
, conn
->cnum
));
335 close_cnum(conn
, (uint16
)-1);