Unix SMB/CIFS implementation.
Low-level connections.tdb access functions
Copyright (C) Volker Lendecke 2007
-
+
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
+ the Free Software Foundation; either version 3 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.
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "includes.h"
-
-TDB_CONTEXT *conn_tdb_ctx(BOOL rw)
-{
- static TDB_CONTEXT *tdb;
-
- if (tdb != NULL) {
- return tdb;
- }
-
- if (rw) {
- tdb = tdb_open_log(lock_path("connections.tdb"), 0,
- TDB_CLEAR_IF_FIRST|TDB_DEFAULT,
- O_RDWR | O_CREAT, 0644);
- }
- else {
- tdb = tdb_open_log(lock_path("connections.tdb"), 0,
- TDB_DEFAULT, O_RDONLY, 0);
- }
-
- if (tdb == NULL) {
- DEBUG(0, ("Could not open connections.tdb: %s\n",
- strerror(errno)));
- }
-
- return tdb;
-}
-
-struct conn_traverse_state {
- int (*fn)(TDB_CONTEXT *tdb,
- const struct connections_key *key,
+#include "system/filesys.h"
+#include "smbd/globals.h"
+#include "dbwrap/dbwrap.h"
+#include "dbwrap/dbwrap_open.h"
+#include "dbwrap/dbwrap_rbt.h"
+#include "messages.h"
+#include "lib/conn_tdb.h"
+#include "util_tdb.h"
+
+struct connections_forall_state {
+ struct db_context *session_by_pid;
+ int (*fn)(const struct connections_key *key,
const struct connections_data *data,
void *private_data);
void *private_data;
+ int count;
};
-static int conn_traverse_fn(TDB_CONTEXT *tdb, TDB_DATA key,
- TDB_DATA data, void *private_data)
-{
- struct conn_traverse_state *state =
- (struct conn_traverse_state *)private_data;
+struct connections_forall_session {
+ uid_t uid;
+ gid_t gid;
+ char machine[FSTRING_LEN];
+ char addr[FSTRING_LEN];
+};
- if ((key.dsize != sizeof(struct connections_key))
- || (data.dsize != sizeof(struct connections_data))) {
- return 0;
+static int collect_sessions_fn(struct smbXsrv_session_global0 *global,
+ void *connections_forall_state)
+{
+ NTSTATUS status;
+ struct connections_forall_state *state =
+ (struct connections_forall_state*)connections_forall_state;
+
+ uint32_t id = global->session_global_id;
+ struct connections_forall_session sess;
+
+ sess.uid = global->auth_session_info->unix_token->uid;
+ sess.gid = global->auth_session_info->unix_token->gid;
+ strncpy(sess.machine, global->channels[0].remote_name, sizeof(sess.machine));
+ strncpy(sess.addr, global->channels[0].remote_address, sizeof(sess.addr));
+
+ status = dbwrap_store(state->session_by_pid,
+ make_tdb_data((void*)&id, sizeof(id)),
+ make_tdb_data((void*)&sess, sizeof(sess)),
+ TDB_INSERT);
+ if (!NT_STATUS_IS_OK(status)) {
+ DEBUG(0, ("Failed to store record: %s\n", nt_errstr(status)));
}
-
- return state->fn(
- tdb, (const struct connections_key *)key.dptr,
- (const struct connections_data *)data.dptr,
- state->private_data);
+ return 0;
}
-int connections_traverse(int (*fn)(TDB_CONTEXT *tdb, TDB_DATA key,
- TDB_DATA data, void *private_data),
- void *private_data)
+static int traverse_tcon_fn(struct smbXsrv_tcon_global0 *global,
+ void *connections_forall_state)
{
- TDB_CONTEXT *tdb = conn_tdb_ctx(True);
-
- if (tdb == NULL) {
- DEBUG(5, ("Could not open connections.tdb r/w, trying r/o\n"));
- tdb = conn_tdb_ctx(False);
- }
-
- if (tdb == NULL) {
- return -1;
+ NTSTATUS status;
+ struct connections_forall_state *state =
+ (struct connections_forall_state*)connections_forall_state;
+
+ struct connections_key key;
+ struct connections_data data;
+
+ uint32_t sess_id = global->session_global_id;
+ struct connections_forall_session sess = {
+ .uid = -1,
+ .gid = -1,
+ };
+
+ TDB_DATA val = tdb_null;
+
+ status = dbwrap_fetch(state->session_by_pid, state,
+ make_tdb_data((void*)&sess_id, sizeof(sess_id)),
+ &val);
+ if (NT_STATUS_IS_OK(status)) {
+ memcpy((uint8_t *)&sess, val.dptr, val.dsize);
}
- return tdb_traverse(tdb, fn, private_data);
-}
+ ZERO_STRUCT(key);
+ ZERO_STRUCT(data);
-int connections_forall(int (*fn)(TDB_CONTEXT *tdb,
- const struct connections_key *key,
- const struct connections_data *data,
- void *private_data),
- void *private_data)
-{
- struct conn_traverse_state state;
+ key.pid = data.pid = global->server_id;
+ key.cnum = data.cnum = global->tcon_global_id;
+ strncpy(key.name, global->share_name, sizeof(key.name));
+ strncpy(data.servicename, global->share_name, sizeof(data.servicename));
+ data.uid = sess.uid;
+ data.gid = sess.gid;
+ strncpy(data.addr, sess.addr, sizeof(data.addr));
+ strncpy(data.machine, sess.machine, sizeof(data.machine));
+ data.start = nt_time_to_unix(global->creation_time);
- state.fn = fn;
- state.private_data = private_data;
+ state->count++;
- return connections_traverse(conn_traverse_fn, (void *)&state);
+ return state->fn(&key, &data, state->private_data);
}
-BOOL connections_init(BOOL rw)
+int connections_forall_read(int (*fn)(const struct connections_key *key,
+ const struct connections_data *data,
+ void *private_data),
+ void *private_data)
{
- return (conn_tdb_ctx(rw) != NULL);
+ TALLOC_CTX *frame = talloc_stackframe();
+ struct connections_forall_state *state =
+ talloc_zero(talloc_tos(), struct connections_forall_state);
+ NTSTATUS status;
+ int ret = -1;
+
+ state->session_by_pid = db_open_rbt(state);
+ state->fn = fn;
+ state->private_data = private_data;
+ status = smbXsrv_session_global_traverse(collect_sessions_fn, state);
+ if (!NT_STATUS_IS_OK(status)) {
+ DEBUG(0, ("Failed to traverse sessions: %s\n",
+ nt_errstr(status)));
+ goto done;
+ }
+
+ status = smbXsrv_tcon_global_traverse(traverse_tcon_fn, state);
+ if (!NT_STATUS_IS_OK(status)) {
+ DEBUG(0, ("Failed to traverse tree connects: %s\n",
+ nt_errstr(status)));
+ goto done;
+ }
+ ret = state->count;
+done:
+ talloc_free(frame);
+ return ret;
}
+
git.samba.org / kai / samba.git / blobdiff