2 Unix SMB/CIFS implementation.
3 Low-level connections.tdb access functions
4 Copyright (C) Volker Lendecke 2007
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program. If not, see <http://www.gnu.org/licenses/>.
21 #include "system/filesys.h"
22 #include "smbd/globals.h"
23 #include "dbwrap/dbwrap.h"
24 #include "dbwrap/dbwrap_open.h"
25 #include "dbwrap/dbwrap_rbt.h"
27 #include "lib/conn_tdb.h"
30 struct connections_forall_state
{
31 struct db_context
*session_by_pid
;
32 int (*fn
)(const struct connections_key
*key
,
33 const struct connections_data
*data
,
39 struct connections_forall_session
{
48 static int collect_sessions_fn(struct smbXsrv_session_global0
*global
,
49 void *connections_forall_state
)
52 struct connections_forall_state
*state
=
53 (struct connections_forall_state
*)connections_forall_state
;
55 uint32_t id
= global
->session_global_id
;
56 struct connections_forall_session sess
;
58 if (global
->auth_session_info
== NULL
) {
62 sess
.uid
= global
->auth_session_info
->unix_token
->uid
;
63 sess
.gid
= global
->auth_session_info
->unix_token
->gid
;
65 fstrcpy(sess
.machine
, global
->channels
[0].remote_name
);
66 fstrcpy(sess
.addr
, global
->channels
[0].remote_address
);
67 sess
.cipher
= global
->channels
[0].encryption_cipher
;
68 sess
.dialect
= global
->connection_dialect
;
70 status
= dbwrap_store(state
->session_by_pid
,
71 make_tdb_data((void*)&id
, sizeof(id
)),
72 make_tdb_data((void*)&sess
, sizeof(sess
)),
74 if (!NT_STATUS_IS_OK(status
)) {
75 DEBUG(0, ("Failed to store record: %s\n", nt_errstr(status
)));
80 static int traverse_tcon_fn(struct smbXsrv_tcon_global0
*global
,
81 void *connections_forall_state
)
84 struct connections_forall_state
*state
=
85 (struct connections_forall_state
*)connections_forall_state
;
87 struct connections_key key
;
88 struct connections_data data
;
90 uint32_t sess_id
= global
->session_global_id
;
91 struct connections_forall_session sess
= {
96 TDB_DATA val
= tdb_null
;
99 * Note: that share_name is defined as array without a pointer.
100 * that's why it's always a valid pointer here.
102 if (strlen(global
->share_name
) == 0) {
104 * when a smbXsrv_tcon is created it's created
105 * with emtpy share_name first in order to allocate
106 * an id, before filling in the details.
111 status
= dbwrap_fetch(state
->session_by_pid
, state
,
112 make_tdb_data((void*)&sess_id
, sizeof(sess_id
)),
114 if (NT_STATUS_IS_OK(status
)) {
115 memcpy((uint8_t *)&sess
, val
.dptr
, val
.dsize
);
121 key
.pid
= data
.pid
= global
->server_id
;
122 key
.cnum
= data
.cnum
= global
->tcon_global_id
;
123 fstrcpy(key
.name
, global
->share_name
);
124 fstrcpy(data
.servicename
, global
->share_name
);
127 fstrcpy(data
.addr
, sess
.addr
);
128 fstrcpy(data
.machine
, sess
.machine
);
129 data
.start
= nt_time_to_unix(global
->creation_time
);
130 data
.encryption_flags
= global
->encryption_flags
;
131 data
.cipher
= sess
.cipher
;
132 data
.dialect
= sess
.dialect
;
136 return state
->fn(&key
, &data
, state
->private_data
);
139 int connections_forall_read(int (*fn
)(const struct connections_key
*key
,
140 const struct connections_data
*data
,
144 TALLOC_CTX
*frame
= talloc_stackframe();
145 struct connections_forall_state
*state
=
146 talloc_zero(talloc_tos(), struct connections_forall_state
);
150 state
->session_by_pid
= db_open_rbt(state
);
152 state
->private_data
= private_data
;
153 status
= smbXsrv_session_global_traverse(collect_sessions_fn
, state
);
154 if (!NT_STATUS_IS_OK(status
)) {
155 DEBUG(0, ("Failed to traverse sessions: %s\n",
160 status
= smbXsrv_tcon_global_traverse(traverse_tcon_fn
, state
);
161 if (!NT_STATUS_IS_OK(status
)) {
162 DEBUG(0, ("Failed to traverse tree connects: %s\n",