*/
#include "includes.h"
-
-static struct db_context *connections_db_ctx(bool rw)
-{
- static struct db_context *db_ctx;
- int open_flags;
-
- if (db_ctx != NULL) {
- return db_ctx;
- }
-
- open_flags = rw ? (O_RDWR|O_CREAT) : O_RDONLY;
-
- db_ctx = db_open(NULL, lock_path("connections.tdb"), 0,
- TDB_CLEAR_IF_FIRST|TDB_DEFAULT, open_flags, 0644);
- return db_ctx;
-}
-
-static struct db_record *connections_fetch_record(TALLOC_CTX *mem_ctx,
- TDB_DATA key)
-{
- struct db_context *ctx = connections_db_ctx(True);
-
- if (ctx == NULL) {
- return NULL;
- }
-
- return ctx->fetch_locked(ctx, mem_ctx, key);
-}
-
-struct db_record *connections_fetch_entry(TALLOC_CTX *mem_ctx,
- connection_struct *conn,
- const char *name)
-{
- struct connections_key ckey;
- TDB_DATA key;
-
- ZERO_STRUCT(ckey);
- ckey.pid = procid_self();
- ckey.cnum = conn ? conn->cnum : -1;
- strlcpy(ckey.name, name, sizeof(ckey.name));
-
- key.dsize = sizeof(ckey);
- key.dptr = (uint8 *)&ckey;
-
- return connections_fetch_record(mem_ctx, key);
-}
-
-struct conn_traverse_state {
- int (*fn)(struct db_record *rec,
- 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(struct db_record *rec, 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 ((rec->key.dsize != sizeof(struct connections_key))
- || (rec->value.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(rec, (const struct connections_key *)rec->key.dptr,
- (const struct connections_data *)rec->value.dptr,
- state->private_data);
+ return 0;
}
-int connections_traverse(int (*fn)(struct db_record *rec,
- void *private_data),
- void *private_data)
+static int traverse_tcon_fn(struct smbXsrv_tcon_global0 *global,
+ void *connections_forall_state)
{
- struct db_context *ctx = connections_db_ctx(False);
-
- if (ctx == 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 ctx->traverse(ctx, fn, private_data);
-}
-
-int connections_forall(int (*fn)(struct db_record *rec,
- const struct connections_key *key,
- const struct connections_data *data,
- void *private_data),
- void *private_data)
-{
- struct db_context *ctx;
- struct conn_traverse_state state;
+ ZERO_STRUCT(key);
+ ZERO_STRUCT(data);
- ctx = connections_db_ctx(true);
- if (ctx == NULL) {
- return -1;
- }
+ 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 ctx->traverse(ctx, 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 (connections_db_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;
}
+