s3-talloc Change TALLOC_P() to talloc()
[nivanova/samba-autobuild/.git] / source3 / locking / posix.c
index 37cfa0437395544a2ece3ba0553ac3c3551d0b0a..51151df9a431701329f0ec774c89af5845b71862 100644 (file)
 */
 
 #include "includes.h"
+#include "system/filesys.h"
+#include "locking/proto.h"
+#include "dbwrap.h"
+#include "util_tdb.h"
 
 #undef DBGC_CLASS
 #define DBGC_CLASS DBGC_LOCKING
@@ -30,7 +34,7 @@
  * The pending close database handle.
  */
 
-static TDB_CONTEXT *posix_pending_close_tdb;
+static struct db_context *posix_pending_close_db;
 
 /****************************************************************************
  First - the functions that deal with the underlying system locks - these
@@ -79,7 +83,7 @@ static const char *posix_lock_type_name(int lock_type)
 ****************************************************************************/
 
 static bool posix_lock_in_range(SMB_OFF_T *offset_out, SMB_OFF_T *count_out,
-                               SMB_BIG_UINT u_offset, SMB_BIG_UINT u_count)
+                               uint64_t u_offset, uint64_t u_count)
 {
        SMB_OFF_T offset = (SMB_OFF_T)u_offset;
        SMB_OFF_T count = (SMB_OFF_T)u_count;
@@ -132,9 +136,9 @@ static bool posix_lock_in_range(SMB_OFF_T *offset_out, SMB_OFF_T *count_out,
         * ignore this lock.
         */
 
-       if (u_offset & ~((SMB_BIG_UINT)max_positive_lock_offset)) {
+       if (u_offset & ~((uint64_t)max_positive_lock_offset)) {
                DEBUG(10,("posix_lock_in_range: (offset = %.0f) offset > %.0f and we cannot handle this. Ignoring lock.\n",
-                               (double)u_offset, (double)((SMB_BIG_UINT)max_positive_lock_offset) ));
+                               (double)u_offset, (double)((uint64_t)max_positive_lock_offset) ));
                return False;
        }
 
@@ -142,7 +146,7 @@ static bool posix_lock_in_range(SMB_OFF_T *offset_out, SMB_OFF_T *count_out,
         * We must truncate the count to less than max_positive_lock_offset.
         */
 
-       if (u_count & ~((SMB_BIG_UINT)max_positive_lock_offset)) {
+       if (u_count & ~((uint64_t)max_positive_lock_offset)) {
                count = max_positive_lock_offset;
        }
 
@@ -177,6 +181,14 @@ static bool posix_lock_in_range(SMB_OFF_T *offset_out, SMB_OFF_T *count_out,
        return True;
 }
 
+bool smb_vfs_call_lock(struct vfs_handle_struct *handle,
+                      struct files_struct *fsp, int op, SMB_OFF_T offset,
+                      SMB_OFF_T count, int type)
+{
+       VFS_FIND(lock);
+       return handle->fns->lock(handle, fsp, op, offset, count, type);
+}
+
 /****************************************************************************
  Actual function that does POSIX locks. Copes with 64 -> 32 bit cruft and
  broken NFS implementations.
@@ -188,7 +200,7 @@ static bool posix_fcntl_lock(files_struct *fsp, int op, SMB_OFF_T offset, SMB_OF
 
        DEBUG(8,("posix_fcntl_lock %d %d %.0f %.0f %d\n",fsp->fh->fd,op,(double)offset,(double)count,type));
 
-       ret = SMB_VFS_LOCK(fsp,fsp->fh->fd,op,offset,count,type);
+       ret = SMB_VFS_LOCK(fsp, op, offset, count, type);
 
        if (!ret && ((errno == EFBIG) || (errno == ENOLCK) || (errno ==  EINVAL))) {
 
@@ -212,7 +224,7 @@ static bool posix_fcntl_lock(files_struct *fsp, int op, SMB_OFF_T offset, SMB_OF
                        DEBUG(0,("Count greater than 31 bits - retrying with 31 bit truncated length.\n"));
                        errno = 0;
                        count &= 0x7fffffff;
-                       ret = SMB_VFS_LOCK(fsp,fsp->fh->fd,op,offset,count,type);
+                       ret = SMB_VFS_LOCK(fsp, op, offset, count, type);
                }
        }
 
@@ -220,6 +232,14 @@ static bool posix_fcntl_lock(files_struct *fsp, int op, SMB_OFF_T offset, SMB_OF
        return ret;
 }
 
+bool smb_vfs_call_getlock(struct vfs_handle_struct *handle,
+                         struct files_struct *fsp, SMB_OFF_T *poffset,
+                         SMB_OFF_T *pcount, int *ptype, pid_t *ppid)
+{
+       VFS_FIND(getlock);
+       return handle->fns->getlock(handle, fsp, poffset, pcount, ptype, ppid);
+}
+
 /****************************************************************************
  Actual function that gets POSIX locks. Copes with 64 -> 32 bit cruft and
  broken NFS implementations.
@@ -233,7 +253,7 @@ static bool posix_fcntl_getlock(files_struct *fsp, SMB_OFF_T *poffset, SMB_OFF_T
        DEBUG(8,("posix_fcntl_getlock %d %.0f %.0f %d\n",
                fsp->fh->fd,(double)*poffset,(double)*pcount,*ptype));
 
-       ret = SMB_VFS_GETLOCK(fsp,fsp->fh->fd,poffset,pcount,ptype,&pid);
+       ret = SMB_VFS_GETLOCK(fsp, poffset, pcount, ptype, &pid);
 
        if (!ret && ((errno == EFBIG) || (errno == ENOLCK) || (errno ==  EINVAL))) {
 
@@ -257,7 +277,7 @@ static bool posix_fcntl_getlock(files_struct *fsp, SMB_OFF_T *poffset, SMB_OFF_T
                        DEBUG(0,("Count greater than 31 bits - retrying with 31 bit truncated length.\n"));
                        errno = 0;
                        *pcount &= 0x7fffffff;
-                       ret = SMB_VFS_GETLOCK(fsp,fsp->fh->fd,poffset,pcount,ptype,&pid);
+                       ret = SMB_VFS_GETLOCK(fsp,poffset,pcount,ptype,&pid);
                }
        }
 
@@ -271,8 +291,8 @@ static bool posix_fcntl_getlock(files_struct *fsp, SMB_OFF_T *poffset, SMB_OFF_T
 ****************************************************************************/
 
 bool is_posix_locked(files_struct *fsp,
-                       SMB_BIG_UINT *pu_offset,
-                       SMB_BIG_UINT *pu_count,
+                       uint64_t *pu_offset,
+                       uint64_t *pu_count,
                        enum brl_type *plock_type,
                        enum brl_flavour lock_flav)
 {
@@ -280,8 +300,9 @@ bool is_posix_locked(files_struct *fsp,
        SMB_OFF_T count;
        int posix_lock_type = map_posix_lock_type(fsp,*plock_type);
 
-       DEBUG(10,("is_posix_locked: File %s, offset = %.0f, count = %.0f, type = %s\n",
-               fsp->fsp_name, (double)*pu_offset, (double)*pu_count, posix_lock_type_name(*plock_type) ));
+       DEBUG(10,("is_posix_locked: File %s, offset = %.0f, count = %.0f, "
+                 "type = %s\n", fsp_str_dbg(fsp), (double)*pu_offset,
+                 (double)*pu_count,  posix_lock_type_name(*plock_type)));
 
        /*
         * If the requested lock won't fit in the POSIX range, we will
@@ -302,8 +323,8 @@ bool is_posix_locked(files_struct *fsp,
 
        if (lock_flav == POSIX_LOCK) {
                /* Only POSIX lock queries need to know the details. */
-               *pu_offset = (SMB_BIG_UINT)offset;
-               *pu_count = (SMB_BIG_UINT)count;
+               *pu_offset = (uint64_t)offset;
+               *pu_count = (uint64_t)count;
                *plock_type = (posix_lock_type == F_RDLCK) ? READ_LOCK : WRITE_LOCK;
        }
        return True;
@@ -321,35 +342,17 @@ struct lock_ref_count_key {
        char r;
 }; 
 
-/*******************************************************************
- Form a static locking key for a dev/inode pair for the fd array.
-******************************************************************/
-
-static TDB_DATA fd_array_key(struct file_id id)
-{
-       static struct file_id key;
-       TDB_DATA kbuf;
-       key = id;
-       kbuf.dptr = (uint8 *)&key;
-       kbuf.dsize = sizeof(key);
-       return kbuf;
-}
-
 /*******************************************************************
  Form a static locking key for a dev/inode pair for the lock ref count
 ******************************************************************/
 
-static TDB_DATA locking_ref_count_key(struct file_id id)
+static TDB_DATA locking_ref_count_key_fsp(files_struct *fsp,
+                                         struct lock_ref_count_key *tmp)
 {
-       static struct lock_ref_count_key key;
-       TDB_DATA kbuf;
-
-       memset(&key, '\0', sizeof(key));
-       key.id = id;
-       key.r = 'r';
-       kbuf.dptr = (uint8 *)&key;
-       kbuf.dsize = sizeof(key);
-       return kbuf;
+       ZERO_STRUCTP(tmp);
+       tmp->id = fsp->file_id;
+       tmp->r = 'r';
+       return make_tdb_data((uint8_t *)tmp, sizeof(*tmp));
 }
 
 /*******************************************************************
@@ -358,38 +361,27 @@ static TDB_DATA locking_ref_count_key(struct file_id id)
 
 static TDB_DATA fd_array_key_fsp(files_struct *fsp)
 {
-       return fd_array_key(fsp->file_id);
-}
-
-/*******************************************************************
- Convenience function to get a lock ref count key from an fsp.
-******************************************************************/
-
-static TDB_DATA locking_ref_count_key_fsp(files_struct *fsp)
-{
-       return locking_ref_count_key(fsp->file_id);
+       return make_tdb_data((uint8 *)&fsp->file_id, sizeof(fsp->file_id));
 }
 
 /*******************************************************************
  Create the in-memory POSIX lock databases.
 ********************************************************************/
 
-bool posix_locking_init(int read_only)
+bool posix_locking_init(bool read_only)
 {
-       if (posix_pending_close_tdb) {
-               return True;
-       }
-       
-       if (!posix_pending_close_tdb) {
-               posix_pending_close_tdb = tdb_open_log(NULL, 0, TDB_INTERNAL,
-                                                  read_only?O_RDONLY:(O_RDWR|O_CREAT), 0644);
+       if (posix_pending_close_db != NULL) {
+               return true;
        }
-       if (!posix_pending_close_tdb) {
+
+       posix_pending_close_db = db_open_rbt(NULL);
+
+       if (posix_pending_close_db == NULL) {
                DEBUG(0,("Failed to open POSIX pending close database.\n"));
-               return False;
+               return false;
        }
 
-       return True;
+       return true;
 }
 
 /*******************************************************************
@@ -398,10 +390,11 @@ bool posix_locking_init(int read_only)
 
 bool posix_locking_end(void)
 {
-       if (posix_pending_close_tdb && tdb_close(posix_pending_close_tdb) != 0) {
-               return False;
-       }
-       return True;
+       /*
+        * Shouldn't we close all fd's here?
+        */
+       TALLOC_FREE(posix_pending_close_db);
+       return true;
 }
 
 /****************************************************************************
@@ -425,59 +418,34 @@ bool posix_locking_end(void)
 
 static void increment_windows_lock_ref_count(files_struct *fsp)
 {
-       TDB_DATA kbuf = locking_ref_count_key_fsp(fsp);
-       TDB_DATA dbuf;
-       int lock_ref_count;
-
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
-       if (dbuf.dptr == NULL) {
-               dbuf.dptr = (uint8 *)SMB_MALLOC_P(int);
-               if (!dbuf.dptr) {
-                       smb_panic("increment_windows_lock_ref_count: malloc fail");
-               }
-               memset(dbuf.dptr, '\0', sizeof(int));
-               dbuf.dsize = sizeof(int);
-       }
+       struct lock_ref_count_key tmp;
+       struct db_record *rec;
+       int lock_ref_count = 0;
+       NTSTATUS status;
 
-       memcpy(&lock_ref_count, dbuf.dptr, sizeof(int));
-       lock_ref_count++;
-       memcpy(dbuf.dptr, &lock_ref_count, sizeof(int));
-       
-       if (tdb_store(posix_pending_close_tdb, kbuf, dbuf, TDB_REPLACE) == -1) {
-               smb_panic("increment_windows_lock_ref_count: tdb_store_fail");
-       }
-       SAFE_FREE(dbuf.dptr);
+       rec = posix_pending_close_db->fetch_locked(
+               posix_pending_close_db, talloc_tos(),
+               locking_ref_count_key_fsp(fsp, &tmp));
 
-       DEBUG(10,("increment_windows_lock_ref_count for file now %s = %d\n",
-               fsp->fsp_name, lock_ref_count ));
-}
+       SMB_ASSERT(rec != NULL);
 
-static void decrement_windows_lock_ref_count(files_struct *fsp)
-{
-       TDB_DATA kbuf = locking_ref_count_key_fsp(fsp);
-       TDB_DATA dbuf;
-       int lock_ref_count;
-
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
-       if (!dbuf.dptr) {
-               smb_panic("decrement_windows_lock_ref_count: logic error");
+       if (rec->value.dptr != NULL) {
+               SMB_ASSERT(rec->value.dsize == sizeof(lock_ref_count));
+               memcpy(&lock_ref_count, rec->value.dptr,
+                      sizeof(lock_ref_count));
        }
 
-       memcpy(&lock_ref_count, dbuf.dptr, sizeof(int));
-       lock_ref_count--;
-       memcpy(dbuf.dptr, &lock_ref_count, sizeof(int));
+       lock_ref_count++;
 
-       if (lock_ref_count < 0) {
-               smb_panic("decrement_windows_lock_ref_count: lock_count logic error");
-       }
+       status = rec->store(rec, make_tdb_data((uint8 *)&lock_ref_count,
+                                              sizeof(lock_ref_count)), 0);
 
-       if (tdb_store(posix_pending_close_tdb, kbuf, dbuf, TDB_REPLACE) == -1) {
-               smb_panic("decrement_windows_lock_ref_count: tdb_store_fail");
-       }
-       SAFE_FREE(dbuf.dptr);
+       SMB_ASSERT(NT_STATUS_IS_OK(status));
+
+       TALLOC_FREE(rec);
 
-       DEBUG(10,("decrement_windows_lock_ref_count for file now %s = %d\n",
-               fsp->fsp_name, lock_ref_count ));
+       DEBUG(10,("increment_windows_lock_ref_count for file now %s = %d\n",
+                 fsp_str_dbg(fsp), lock_ref_count));
 }
 
 /****************************************************************************
@@ -486,30 +454,39 @@ static void decrement_windows_lock_ref_count(files_struct *fsp)
 
 void reduce_windows_lock_ref_count(files_struct *fsp, unsigned int dcount)
 {
-       TDB_DATA kbuf = locking_ref_count_key_fsp(fsp);
-       TDB_DATA dbuf;
-       int lock_ref_count;
+       struct lock_ref_count_key tmp;
+       struct db_record *rec;
+       int lock_ref_count = 0;
+       NTSTATUS status;
 
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
-       if (!dbuf.dptr) {
-               return;
-       }
+       rec = posix_pending_close_db->fetch_locked(
+               posix_pending_close_db, talloc_tos(),
+               locking_ref_count_key_fsp(fsp, &tmp));
+
+       SMB_ASSERT((rec != NULL)
+                  && (rec->value.dptr != NULL)
+                  && (rec->value.dsize == sizeof(lock_ref_count)));
+
+       memcpy(&lock_ref_count, rec->value.dptr, sizeof(lock_ref_count));
+
+       SMB_ASSERT(lock_ref_count > 0);
 
-       memcpy(&lock_ref_count, dbuf.dptr, sizeof(int));
        lock_ref_count -= dcount;
 
-       if (lock_ref_count < 0) {
-               smb_panic("reduce_windows_lock_ref_count: lock_count logic error");
-       }
-       memcpy(dbuf.dptr, &lock_ref_count, sizeof(int));
-       
-       if (tdb_store(posix_pending_close_tdb, kbuf, dbuf, TDB_REPLACE) == -1) {
-               smb_panic("reduce_windows_lock_ref_count: tdb_store_fail");
-       }
-       SAFE_FREE(dbuf.dptr);
+       status = rec->store(rec, make_tdb_data((uint8 *)&lock_ref_count,
+                                              sizeof(lock_ref_count)), 0);
+
+       SMB_ASSERT(NT_STATUS_IS_OK(status));
+
+       TALLOC_FREE(rec);
 
        DEBUG(10,("reduce_windows_lock_ref_count for file now %s = %d\n",
-               fsp->fsp_name, lock_ref_count ));
+                 fsp_str_dbg(fsp), lock_ref_count));
+}
+
+static void decrement_windows_lock_ref_count(files_struct *fsp)
+{
+       reduce_windows_lock_ref_count(fsp, 1);
 }
 
 /****************************************************************************
@@ -518,20 +495,26 @@ void reduce_windows_lock_ref_count(files_struct *fsp, unsigned int dcount)
 
 static int get_windows_lock_ref_count(files_struct *fsp)
 {
-       TDB_DATA kbuf = locking_ref_count_key_fsp(fsp);
+       struct lock_ref_count_key tmp;
        TDB_DATA dbuf;
-       int lock_ref_count;
+       int res;
+       int lock_ref_count = 0;
 
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
-       if (!dbuf.dptr) {
-               lock_ref_count = 0;
-       } else {
-               memcpy(&lock_ref_count, dbuf.dptr, sizeof(int));
+       res = posix_pending_close_db->fetch(
+               posix_pending_close_db, talloc_tos(),
+               locking_ref_count_key_fsp(fsp, &tmp), &dbuf);
+
+       SMB_ASSERT(res == 0);
+
+       if (dbuf.dsize != 0) {
+               SMB_ASSERT(dbuf.dsize == sizeof(lock_ref_count));
+               memcpy(&lock_ref_count, dbuf.dptr, sizeof(lock_ref_count));
+               TALLOC_FREE(dbuf.dptr);
        }
-       SAFE_FREE(dbuf.dptr);
 
        DEBUG(10,("get_windows_lock_count for file %s = %d\n",
-               fsp->fsp_name, lock_ref_count ));
+                 fsp_str_dbg(fsp), lock_ref_count));
+
        return lock_ref_count;
 }
 
@@ -541,11 +524,22 @@ static int get_windows_lock_ref_count(files_struct *fsp)
 
 static void delete_windows_lock_ref_count(files_struct *fsp)
 {
-       TDB_DATA kbuf = locking_ref_count_key_fsp(fsp);
+       struct lock_ref_count_key tmp;
+       struct db_record *rec;
+
+       rec = posix_pending_close_db->fetch_locked(
+               posix_pending_close_db, talloc_tos(),
+               locking_ref_count_key_fsp(fsp, &tmp));
+
+       SMB_ASSERT(rec != NULL);
 
        /* Not a bug if it doesn't exist - no locks were ever granted. */
-       tdb_delete(posix_pending_close_tdb, kbuf);
-       DEBUG(10,("delete_windows_lock_ref_count for file %s\n", fsp->fsp_name));
+
+       rec->delete_rec(rec);
+       TALLOC_FREE(rec);
+
+       DEBUG(10,("delete_windows_lock_ref_count for file %s\n",
+                 fsp_str_dbg(fsp)));
 }
 
 /****************************************************************************
@@ -554,30 +548,35 @@ static void delete_windows_lock_ref_count(files_struct *fsp)
 
 static void add_fd_to_close_entry(files_struct *fsp)
 {
-       TDB_DATA kbuf = fd_array_key_fsp(fsp);
-       TDB_DATA dbuf;
+       struct db_record *rec;
+       uint8_t *new_data;
+       NTSTATUS status;
 
-       dbuf.dptr = NULL;
-       dbuf.dsize = 0;
+       rec = posix_pending_close_db->fetch_locked(
+               posix_pending_close_db, talloc_tos(),
+               fd_array_key_fsp(fsp));
 
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
+       SMB_ASSERT(rec != NULL);
 
-       dbuf.dptr = (uint8 *)SMB_REALLOC(dbuf.dptr, dbuf.dsize + sizeof(int));
-       if (!dbuf.dptr) {
-               smb_panic("add_fd_to_close_entry: SMB_REALLOC failed");
-       }
+       new_data = talloc_array(
+               rec, uint8_t, rec->value.dsize + sizeof(fsp->fh->fd));
 
-       memcpy(dbuf.dptr + dbuf.dsize, &fsp->fh->fd, sizeof(int));
-       dbuf.dsize += sizeof(int);
+       SMB_ASSERT(new_data != NULL);
 
-       if (tdb_store(posix_pending_close_tdb, kbuf, dbuf, TDB_REPLACE) == -1) {
-               smb_panic("add_fd_to_close_entry: tdb_store_fail");
-       }
+       memcpy(new_data, rec->value.dptr, rec->value.dsize);
+       memcpy(new_data + rec->value.dsize,
+              &fsp->fh->fd, sizeof(fsp->fh->fd));
 
-       DEBUG(10,("add_fd_to_close_entry: added fd %d file %s\n",
-               fsp->fh->fd, fsp->fsp_name ));
+       status = rec->store(
+               rec, make_tdb_data(new_data,
+                                  rec->value.dsize + sizeof(fsp->fh->fd)), 0);
+
+       SMB_ASSERT(NT_STATUS_IS_OK(status));
+
+       TALLOC_FREE(rec);
 
-       SAFE_FREE(dbuf.dptr);
+       DEBUG(10,("add_fd_to_close_entry: added fd %d file %s\n",
+                 fsp->fh->fd, fsp_str_dbg(fsp)));
 }
 
 /****************************************************************************
@@ -586,37 +585,41 @@ static void add_fd_to_close_entry(files_struct *fsp)
 
 static void delete_close_entries(files_struct *fsp)
 {
-       TDB_DATA kbuf = fd_array_key_fsp(fsp);
+       struct db_record *rec;
 
-       if (tdb_delete(posix_pending_close_tdb, kbuf) == -1) {
-               smb_panic("delete_close_entries: tdb_delete failed");
-       }
+       rec = posix_pending_close_db->fetch_locked(
+               posix_pending_close_db, talloc_tos(),
+               fd_array_key_fsp(fsp));
+
+       SMB_ASSERT(rec != NULL);
+       rec->delete_rec(rec);
+       TALLOC_FREE(rec);
 }
 
 /****************************************************************************
- Get the array of POSIX pending close records for an open fsp. Caller must
free. Returns number of entries.
+ Get the array of POSIX pending close records for an open fsp. Returns number
+ of entries.
 ****************************************************************************/
 
-static size_t get_posix_pending_close_entries(files_struct *fsp, int **entries)
+static size_t get_posix_pending_close_entries(TALLOC_CTX *mem_ctx,
+                                             files_struct *fsp, int **entries)
 {
-       TDB_DATA kbuf = fd_array_key_fsp(fsp);
        TDB_DATA dbuf;
-       size_t count = 0;
+       int res;
 
-       *entries = NULL;
-       dbuf.dptr = NULL;
+       res = posix_pending_close_db->fetch(
+               posix_pending_close_db, mem_ctx, fd_array_key_fsp(fsp),
+               &dbuf);
 
-       dbuf = tdb_fetch(posix_pending_close_tdb, kbuf);
+       SMB_ASSERT(res == 0);
 
-       if (!dbuf.dptr) {
+       if (dbuf.dsize == 0) {
+               *entries = NULL;
                return 0;
        }
 
        *entries = (int *)dbuf.dptr;
-       count = (size_t)(dbuf.dsize / sizeof(int));
-
-       return count;
+       return (size_t)(dbuf.dsize / sizeof(int));
 }
 
 /****************************************************************************
@@ -625,37 +628,34 @@ static size_t get_posix_pending_close_entries(files_struct *fsp, int **entries)
  to delete all locks on this fsp before this function is called.
 ****************************************************************************/
 
-NTSTATUS fd_close_posix(struct connection_struct *conn, files_struct *fsp)
+int fd_close_posix(struct files_struct *fsp)
 {
        int saved_errno = 0;
        int ret;
        int *fd_array = NULL;
        size_t count, i;
 
-       if (!lp_locking(fsp->conn->params) || !lp_posix_locking(conn->params)) {
+       if (!lp_locking(fsp->conn->params) ||
+           !lp_posix_locking(fsp->conn->params))
+       {
                /*
                 * No locking or POSIX to worry about or we want POSIX semantics
                 * which will lose all locks on all fd's open on this dev/inode,
                 * just close.
                 */
-               ret = SMB_VFS_CLOSE(fsp,fsp->fh->fd);
-               fsp->fh->fd = -1;
-               if (ret == -1) {
-                       return map_nt_error_from_unix(errno);
-               }
-               return NT_STATUS_OK;
+               return close(fsp->fh->fd);
        }
 
        if (get_windows_lock_ref_count(fsp)) {
 
                /*
-                * There are outstanding locks on this dev/inode pair on other fds.
-                * Add our fd to the pending close tdb and set fsp->fh->fd to -1.
+                * There are outstanding locks on this dev/inode pair on
+                * other fds. Add our fd to the pending close tdb and set
+                * fsp->fh->fd to -1.
                 */
 
                add_fd_to_close_entry(fsp);
-               fsp->fh->fd = -1;
-               return NT_STATUS_OK;
+               return 0;
        }
 
        /*
@@ -663,13 +663,14 @@ NTSTATUS fd_close_posix(struct connection_struct *conn, files_struct *fsp)
         * from the tdb and close them all.
         */
 
-       count = get_posix_pending_close_entries(fsp, &fd_array);
+       count = get_posix_pending_close_entries(talloc_tos(), fsp, &fd_array);
 
        if (count) {
-               DEBUG(10,("fd_close_posix: doing close on %u fd's.\n", (unsigned int)count ));
+               DEBUG(10,("fd_close_posix: doing close on %u fd's.\n",
+                         (unsigned int)count));
 
                for(i = 0; i < count; i++) {
-                       if (SMB_VFS_CLOSE(fsp,fd_array[i]) == -1) {
+                       if (close(fd_array[i]) == -1) {
                                saved_errno = errno;
                        }
                }
@@ -682,7 +683,7 @@ NTSTATUS fd_close_posix(struct connection_struct *conn, files_struct *fsp)
                delete_close_entries(fsp);
        }
 
-       SAFE_FREE(fd_array);
+       TALLOC_FREE(fd_array);
 
        /* Don't need a lock ref count on this dev/ino anymore. */
        delete_windows_lock_ref_count(fsp);
@@ -691,20 +692,14 @@ NTSTATUS fd_close_posix(struct connection_struct *conn, files_struct *fsp)
         * Finally close the fd associated with this fsp.
         */
 
-       ret = SMB_VFS_CLOSE(fsp,fsp->fh->fd);
+       ret = close(fsp->fh->fd);
 
        if (ret == 0 && saved_errno != 0) {
                errno = saved_errno;
                ret = -1;
-       } 
-
-       fsp->fh->fd = -1;
-
-       if (ret == -1) {
-               return map_nt_error_from_unix(errno);
        }
 
-       return NT_STATUS_OK;
+       return ret;
 }
 
 /****************************************************************************
@@ -897,7 +892,7 @@ BECOMES.....
         | l_curr|         | l_new   |
         +-------+         +---------+
 **********************************************/
-                               struct lock_list *l_new = TALLOC_P(ctx, struct lock_list);
+                               struct lock_list *l_new = talloc(ctx, struct lock_list);
 
                                if(l_new == NULL) {
                                        DEBUG(0,("posix_lock_list: talloc fail.\n"));
@@ -917,12 +912,8 @@ new: start=%.0f,size=%.0f\n", (double)l_curr->start, (double)l_curr->size,
 
                                /*
                                 * Add into the dlink list after the l_curr point - NOT at lhead. 
-                                * Note we can't use DLINK_ADD here as this inserts at the head of the given list.
                                 */
-
-                               l_new->prev = l_curr;
-                               l_new->next = l_curr->next;
-                               l_curr->next = l_new;
+                               DLIST_ADD_AFTER(lhead, l_new, l_curr);
 
                                /* And move after the link we added. */
                                l_curr = l_new->next;
@@ -935,13 +926,12 @@ new: start=%.0f,size=%.0f\n", (double)l_curr->start, (double)l_curr->size,
                                 */
                                char *msg = NULL;
 
-                               /* Don't check if alloc succeeds here - we're
-                                * forcing a core dump anyway. */
-
-                               asprintf(&msg, "logic flaw in cases: l_curr: start = %.0f, size = %.0f : \
-lock: start = %.0f, size = %.0f", (double)l_curr->start, (double)l_curr->size, (double)lock->start, (double)lock->size );
-
-                               smb_panic(msg);
+                               if (asprintf(&msg, "logic flaw in cases: l_curr: start = %.0f, size = %.0f : \
+lock: start = %.0f, size = %.0f", (double)l_curr->start, (double)l_curr->size, (double)lock->start, (double)lock->size ) != -1) {
+                                       smb_panic(msg);
+                               } else {
+                                       smb_panic("posix_lock_list");
+                               }
                        }
                } /* end for ( l_curr = lhead; l_curr;) */
        } /* end for (i=0; i<num_locks && ul_head; i++) */
@@ -955,8 +945,8 @@ lock: start = %.0f, size = %.0f", (double)l_curr->start, (double)l_curr->size, (
 ****************************************************************************/
 
 bool set_posix_lock_windows_flavour(files_struct *fsp,
-                       SMB_BIG_UINT u_offset,
-                       SMB_BIG_UINT u_count,
+                       uint64_t u_offset,
+                       uint64_t u_count,
                        enum brl_type lock_type,
                        const struct lock_context *lock_ctx,
                        const struct lock_struct *plocks,
@@ -972,8 +962,10 @@ bool set_posix_lock_windows_flavour(files_struct *fsp,
        struct lock_list *llist = NULL;
        struct lock_list *ll = NULL;
 
-       DEBUG(5,("set_posix_lock_windows_flavour: File %s, offset = %.0f, count = %.0f, type = %s\n",
-                       fsp->fsp_name, (double)u_offset, (double)u_count, posix_lock_type_name(lock_type) ));
+       DEBUG(5,("set_posix_lock_windows_flavour: File %s, offset = %.0f, "
+                "count = %.0f, type = %s\n", fsp_str_dbg(fsp),
+                (double)u_offset, (double)u_count,
+                posix_lock_type_name(lock_type)));
 
        /*
         * If the requested lock won't fit in the POSIX range, we will
@@ -1008,7 +1000,7 @@ bool set_posix_lock_windows_flavour(files_struct *fsp,
                return False;
        }
 
-       if ((ll = TALLOC_P(l_ctx, struct lock_list)) == NULL) {
+       if ((ll = talloc(l_ctx, struct lock_list)) == NULL) {
                DEBUG(0,("set_posix_lock_windows_flavour: unable to talloc unlock list.\n"));
                talloc_destroy(l_ctx);
                return False;
@@ -1092,8 +1084,8 @@ bool set_posix_lock_windows_flavour(files_struct *fsp,
 ****************************************************************************/
 
 bool release_posix_lock_windows_flavour(files_struct *fsp,
-                               SMB_BIG_UINT u_offset,
-                               SMB_BIG_UINT u_count,
+                               uint64_t u_offset,
+                               uint64_t u_count,
                                enum brl_type deleted_lock_type,
                                const struct lock_context *lock_ctx,
                                const struct lock_struct *plocks,
@@ -1106,8 +1098,9 @@ bool release_posix_lock_windows_flavour(files_struct *fsp,
        struct lock_list *ulist = NULL;
        struct lock_list *ul = NULL;
 
-       DEBUG(5,("release_posix_lock_windows_flavour: File %s, offset = %.0f, count = %.0f\n",
-               fsp->fsp_name, (double)u_offset, (double)u_count ));
+       DEBUG(5,("release_posix_lock_windows_flavour: File %s, offset = %.0f, "
+                "count = %.0f\n", fsp_str_dbg(fsp),
+                (double)u_offset, (double)u_count));
 
        /* Remember the number of Windows locks we have on this dev/ino pair. */
        decrement_windows_lock_ref_count(fsp);
@@ -1126,7 +1119,7 @@ bool release_posix_lock_windows_flavour(files_struct *fsp,
                return False;
        }
 
-       if ((ul = TALLOC_P(ul_ctx, struct lock_list)) == NULL) {
+       if ((ul = talloc(ul_ctx, struct lock_list)) == NULL) {
                DEBUG(0,("release_posix_lock_windows_flavour: unable to talloc unlock list.\n"));
                talloc_destroy(ul_ctx);
                return False;
@@ -1215,8 +1208,8 @@ bool release_posix_lock_windows_flavour(files_struct *fsp,
 ****************************************************************************/
 
 bool set_posix_lock_posix_flavour(files_struct *fsp,
-                       SMB_BIG_UINT u_offset,
-                       SMB_BIG_UINT u_count,
+                       uint64_t u_offset,
+                       uint64_t u_count,
                        enum brl_type lock_type,
                        int *errno_ret)
 {
@@ -1224,8 +1217,10 @@ bool set_posix_lock_posix_flavour(files_struct *fsp,
        SMB_OFF_T count;
        int posix_lock_type = map_posix_lock_type(fsp,lock_type);
 
-       DEBUG(5,("set_posix_lock_posix_flavour: File %s, offset = %.0f, count = %.0f, type = %s\n",
-                       fsp->fsp_name, (double)u_offset, (double)u_count, posix_lock_type_name(lock_type) ));
+       DEBUG(5,("set_posix_lock_posix_flavour: File %s, offset = %.0f, count "
+                "= %.0f, type = %s\n", fsp_str_dbg(fsp),
+                (double)u_offset, (double)u_count,
+                posix_lock_type_name(lock_type)));
 
        /*
         * If the requested lock won't fit in the POSIX range, we will
@@ -1255,8 +1250,8 @@ bool set_posix_lock_posix_flavour(files_struct *fsp,
 ****************************************************************************/
 
 bool release_posix_lock_posix_flavour(files_struct *fsp,
-                               SMB_BIG_UINT u_offset,
-                               SMB_BIG_UINT u_count,
+                               uint64_t u_offset,
+                               uint64_t u_count,
                                const struct lock_context *lock_ctx,
                                const struct lock_struct *plocks,
                                int num_locks)
@@ -1268,8 +1263,9 @@ bool release_posix_lock_posix_flavour(files_struct *fsp,
        struct lock_list *ulist = NULL;
        struct lock_list *ul = NULL;
 
-       DEBUG(5,("release_posix_lock_posix_flavour: File %s, offset = %.0f, count = %.0f\n",
-               fsp->fsp_name, (double)u_offset, (double)u_count ));
+       DEBUG(5,("release_posix_lock_posix_flavour: File %s, offset = %.0f, "
+                "count = %.0f\n", fsp_str_dbg(fsp),
+                (double)u_offset, (double)u_count));
 
        /*
         * If the requested lock won't fit in the POSIX range, we will
@@ -1285,7 +1281,7 @@ bool release_posix_lock_posix_flavour(files_struct *fsp,
                return False;
        }
 
-       if ((ul = TALLOC_P(ul_ctx, struct lock_list)) == NULL) {
+       if ((ul = talloc(ul_ctx, struct lock_list)) == NULL) {
                DEBUG(0,("release_posix_lock_windows_flavour: unable to talloc unlock list.\n"));
                talloc_destroy(ul_ctx);
                return False;