source3/smbd/dmapi.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3    DMAPI Support routines
   4
   5    Copyright (C) James Peach 2006
   6
   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.
  11
  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.
  16
  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/>.
  19 */
  20
  21 #include "includes.h"
  22
  23 #undef DBGC_CLASS
  24 #define DBGC_CLASS DBGC_DMAPI
  25
  26 #ifndef USE_DMAPI
  27
  28 uint32 dmapi_file_flags(const char * const path) { return 0; }
  29 bool dmapi_have_session(void) { return False; }
  30 const void * dmapi_get_current_session(void) { return NULL; }
  31
  32 #else /* USE_DMAPI */
  33
  34 #ifdef HAVE_XFS_DMAPI_H
  35 #include <xfs/dmapi.h>
  36 #elif defined(HAVE_SYS_DMI_H)
  37 #include <sys/dmi.h>
  38 #elif defined(HAVE_SYS_JFSDMAPI_H)
  39 #include <sys/jfsdmapi.h>
  40 #elif defined(HAVE_SYS_DMAPI_H)
  41 #include <sys/dmapi.h>
  42 #elif defined(HAVE_DMAPI_H)
  43 #include <dmapi.h>
  44 #endif
  45
  46 #define DMAPI_SESSION_NAME "samba"
  47 #define DMAPI_TRACE 10
  48
  49 static dm_sessid_t samba_dmapi_session = DM_NO_SESSION;
  50 static unsigned session_num;
  51
  52 /*
  53    Initialise DMAPI session. The session is persistant kernel state,
  54    so it might already exist, in which case we merely want to
  55    reconnect to it. This function should be called as root.
  56 */
  57 static int dmapi_init_session(void)
  58 {
  59         char    buf[DM_SESSION_INFO_LEN];
  60         size_t  buflen;
  61         uint        nsessions = 5;
  62         dm_sessid_t *sessions = NULL;
  63         char    *version;
  64         char    *session_name;
  65         TALLOC_CTX *tmp_ctx = talloc_new(NULL);
  66
  67         int i, err;
  68
  69         if (session_num == 0) {
  70                 session_name = DMAPI_SESSION_NAME;
  71         } else {
  72                 session_name = talloc_asprintf(tmp_ctx, "%s%u", DMAPI_SESSION_NAME,
  73                                                session_num);
  74         }
  75
  76         if (session_name == NULL) {
  77                 DEBUG(0,("Out of memory in dmapi_init_session\n"));
  78                 talloc_free(tmp_ctx);
  79                 return -1;
  80         }
  81
  82
  83         if (dm_init_service(&version) < 0) {
  84                 DEBUG(0, ("dm_init_service failed - disabling DMAPI\n"));
  85                 talloc_free(tmp_ctx);
  86                 return -1;
  87         }
  88
  89         ZERO_STRUCT(buf);
  90
  91         /* Fetch kernel DMAPI sessions until we get any of them */
  92         do {
  93                 dm_sessid_t *new_sessions;
  94                 nsessions *= 2;
  95                 new_sessions = TALLOC_REALLOC_ARRAY(tmp_ctx, sessions,
  96                                                     dm_sessid_t, nsessions);
  97                 if (new_sessions == NULL) {
  98                         talloc_free(tmp_ctx);
  99                         return -1;
 100                 }
 101
 102                 sessions = new_sessions;
 103                 err = dm_getall_sessions(nsessions, sessions, &nsessions);
 104         } while (err == -1 && errno == E2BIG);
 105
 106         if (err == -1) {
 107                 DEBUGADD(DMAPI_TRACE,
 108                         ("failed to retrieve DMAPI sessions: %s\n",
 109                         strerror(errno)));
 110                 talloc_free(tmp_ctx);
 111                 return -1;
 112         }
 113
 114         /* Look through existing kernel DMAPI sessions to find out ours */
 115         for (i = 0; i < nsessions; ++i) {
 116                 err = dm_query_session(sessions[i], sizeof(buf), buf, &buflen);
 117                 buf[sizeof(buf) - 1] = '\0';
 118                 if (err == 0 && strcmp(session_name, buf) == 0) {
 119                         samba_dmapi_session = sessions[i];
 120                         DEBUGADD(DMAPI_TRACE,
 121                                 ("attached to existing DMAPI session "
 122                                  "named '%s'\n", buf));
 123                         break;
 124                 }
 125         }
 126
 127         /* No session already defined. */
 128         if (samba_dmapi_session == DM_NO_SESSION) {
 129                 err = dm_create_session(DM_NO_SESSION,
 130                                         session_name,
 131                                         &samba_dmapi_session);
 132                 if (err < 0) {
 133                         DEBUGADD(DMAPI_TRACE,
 134                                 ("failed to create new DMAPI session: %s\n",
 135                                 strerror(errno)));
 136                         samba_dmapi_session = DM_NO_SESSION;
 137                         talloc_free(tmp_ctx);
 138                         return -1;
 139                 }
 140
 141                 DEBUG(0, ("created new DMAPI session named '%s' for %s\n",
 142                           session_name, version));
 143         }
 144
 145         if (samba_dmapi_session != DM_NO_SESSION) {
 146                 set_effective_capability(DMAPI_ACCESS_CAPABILITY);
 147         }
 148
 149         /*
 150            Note that we never end the DMAPI session. It gets re-used if possiblie.
 151            DMAPI session is a kernel resource that is usually lives until server reboot
 152            and doesn't get destroed when an application finishes.
 153
 154            However, we free list of references to DMAPI sessions we've got from the kernel
 155            as it is not needed anymore once we have found (or created) our session.
 156          */
 157
 158         talloc_free(tmp_ctx);
 159         return 0;
 160 }
 161
 162 /*
 163   Return a pointer to our DMAPI session, if available.
 164   This assumes that you have called dmapi_have_session() first.
 165 */
 166 const void *dmapi_get_current_session(void)
 167 {
 168         if (samba_dmapi_session == DM_NO_SESSION) {
 169                 return NULL;
 170         }
 171
 172         return (void *)&samba_dmapi_session;
 173 }
 174
 175 /*
 176   dmapi_have_session() must be the first DMAPI call you make in Samba. It will
 177   initialize DMAPI, if available, and tell you if you can get a DMAPI session.
 178   This should be called in the client-specific child process.
 179 */
 180
 181 bool dmapi_have_session(void)
 182 {
 183         static bool initialized;
 184         if (!initialized) {
 185                 initialized = true;
 186
 187                 become_root();
 188                 dmapi_init_session();
 189                 unbecome_root();
 190
 191         }
 192
 193         return samba_dmapi_session != DM_NO_SESSION;
 194 }
 195
 196 /*
 197   only call this when you get back an EINVAL error indicating that the
 198   session you are using is invalid. This destroys the existing session
 199   and creates a new one.
 200  */
 201 bool dmapi_new_session(void)
 202 {
 203         if (dmapi_have_session()) {
 204                 /* try to destroy the old one - this may not succeed */
 205                 dm_destroy_session(samba_dmapi_session);
 206         }
 207         samba_dmapi_session = DM_NO_SESSION;
 208         become_root();
 209         session_num++;
 210         dmapi_init_session();
 211         unbecome_root();
 212         return samba_dmapi_session != DM_NO_SESSION;
 213 }
 214
 215 /*
 216    This is default implementation of dmapi_file_flags() that is
 217    called from VFS is_offline() call to know whether file is offline.
 218    For GPFS-specific version see modules/vfs_tsmsm.c. It might be
 219    that approach on quering existence of a specific attribute that
 220    is used in vfs_tsmsm.c will work with other DMAPI-based HSM
 221    implementations as well.
 222 */
 223 uint32 dmapi_file_flags(const char * const path)
 224 {
 225         int             err;
 226         dm_eventset_t   events = {0};
 227         uint            nevents;
 228
 229         dm_sessid_t     dmapi_session;
 230         const void      *dmapi_session_ptr;
 231         void            *dm_handle = NULL;
 232         size_t          dm_handle_len = 0;
 233
 234         uint32          flags = 0;
 235
 236         dmapi_session_ptr = dmapi_get_current_session();
 237         if (dmapi_session_ptr == NULL) {
 238                 return 0;
 239         }
 240
 241         dmapi_session = *(dm_sessid_t *)dmapi_session_ptr;
 242         if (dmapi_session == DM_NO_SESSION) {
 243                 return 0;
 244         }
 245
 246         /* AIX has DMAPI but no POSIX capablities support. In this case,
 247          * we need to be root to do DMAPI manipulations.
 248          */
 249 #ifndef HAVE_POSIX_CAPABILITIES
 250         become_root();
 251 #endif
 252
 253         err = dm_path_to_handle(CONST_DISCARD(char *, path),
 254                 &dm_handle, &dm_handle_len);
 255         if (err < 0) {
 256                 DEBUG(DMAPI_TRACE, ("dm_path_to_handle(%s): %s\n",
 257                             path, strerror(errno)));
 258
 259                 if (errno != EPERM) {
 260                         goto done;
 261                 }
 262
 263                 /* Linux capabilities are broken in that changing our
 264                  * user ID will clobber out effective capabilities irrespective
 265                  * of whether we have set PR_SET_KEEPCAPS. Fortunately, the
 266                  * capabilities are not removed from our permitted set, so we
 267                  * can re-acquire them if necessary.
 268                  */
 269
 270                 set_effective_capability(DMAPI_ACCESS_CAPABILITY);
 271
 272                 err = dm_path_to_handle(CONST_DISCARD(char *, path),
 273                         &dm_handle, &dm_handle_len);
 274                 if (err < 0) {
 275                         DEBUG(DMAPI_TRACE,
 276                             ("retrying dm_path_to_handle(%s): %s\n",
 277                             path, strerror(errno)));
 278                         goto done;
 279                 }
 280         }
 281
 282         err = dm_get_eventlist(dmapi_session, dm_handle, dm_handle_len,
 283                 DM_NO_TOKEN, DM_EVENT_MAX, &events, &nevents);
 284         if (err < 0) {
 285                 DEBUG(DMAPI_TRACE, ("dm_get_eventlist(%s): %s\n",
 286                             path, strerror(errno)));
 287                 dm_handle_free(dm_handle, dm_handle_len);
 288                 goto done;
 289         }
 290
 291         /* We figure that the only reason a DMAPI application would be
 292          * interested in trapping read events is that part of the file is
 293          * offline.
 294          */
 295         DEBUG(DMAPI_TRACE, ("DMAPI event list for %s\n", path));
 296         if (DMEV_ISSET(DM_EVENT_READ, events)) {
 297                 flags = FILE_ATTRIBUTE_OFFLINE;
 298         }
 299
 300         dm_handle_free(dm_handle, dm_handle_len);
 301
 302         if (flags & FILE_ATTRIBUTE_OFFLINE) {
 303                 DEBUG(DMAPI_TRACE, ("%s is OFFLINE\n", path));
 304         }
 305
 306 done:
 307
 308 #ifndef HAVE_POSIX_CAPABILITIES
 309         unbecome_root();
 310 #endif
 311
 312         return flags;
 313 }
 314
 315
 316 #endif /* USE_DMAPI */