1 files changed, 0 insertions, 137 deletions
diff --git a/source4/cluster/ctdb/common/ctdb_lockwait.c b/source4/cluster/ctdb/common/ctdb_lockwait.c
deleted file mode 100644
index 2134cb95e9..0000000000
--- a/source4/cluster/ctdb/common/ctdb_lockwait.c
+++ /dev/null
@@ -1,137 +0,0 @@
-/* 
-   wait for a tdb chain lock
-
-   Copyright (C) Andrew Tridgell  2006
-
-   This library is free software; you can redistribute it and/or
-   modify it under the terms of the GNU Lesser General Public
-   License as published by the Free Software Foundation; either
-   version 3 of the License, or (at your option) any later version.
-
-   This library 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
-   Lesser General Public License for more details.
-
-   You should have received a copy of the GNU Lesser General Public
-   License along with this library; if not, see <http://www.gnu.org/licenses/>.
-*/
-
-#include "includes.h"
-#include "lib/events/events.h"
-#include "system/filesys.h"
-#include "system/wait.h"
-#include "db_wrap.h"
-#include "lib/tdb/include/tdb.h"
-#include "../include/ctdb_private.h"
-
-
-struct lockwait_handle {
-	struct ctdb_context *ctdb;
-	struct fd_event *fde;
-	int fd[2];
-	pid_t child;
-	void *private_data;
-	void (*callback)(void *);
-	struct timeval start_time;
-};
-
-static void lockwait_handler(struct event_context *ev, struct fd_event *fde, 
-			     uint16_t flags, void *private_data)
-{
-	struct lockwait_handle *h = talloc_get_type(private_data, 
-						     struct lockwait_handle);
-	void (*callback)(void *) = h->callback;
-	void *p = h->private_data;
-	pid_t child = h->child;
-	talloc_set_destructor(h, NULL);
-	close(h->fd[0]);
-	ctdb_latency(&h->ctdb->status.max_lockwait_latency, h->start_time);
-	h->ctdb->status.pending_lockwait_calls--;
-	talloc_free(h);	
-	callback(p);
-	waitpid(child, NULL, 0);
-}
-
-static int lockwait_destructor(struct lockwait_handle *h)
-{
-	h->ctdb->status.pending_lockwait_calls--;
-	close(h->fd[0]);
-	kill(h->child, SIGKILL);
-	waitpid(h->child, NULL, 0);
-	return 0;
-}
-
-/*
-  setup a non-blocking chainlock on a tdb record. If this function
-  returns NULL then it could not get the chainlock. Otherwise it
-  returns a opaque handle, and will call callback() once it has
-  managed to get the chainlock. You can cancel it by using talloc_free
-  on the returned handle.
-
-  It is the callers responsibility to unlock the chainlock once
-  acquired
- */
-struct lockwait_handle *ctdb_lockwait(struct ctdb_db_context *ctdb_db,
-				      TDB_DATA key,
-				      void (*callback)(void *private_data),
-				      void *private_data)
-{
-	struct lockwait_handle *result;
-	int ret;
-
-	ctdb_db->ctdb->status.lockwait_calls++;
-	ctdb_db->ctdb->status.pending_lockwait_calls++;
-
-	if (!(result = talloc_zero(ctdb_db, struct lockwait_handle))) {
-		ctdb_db->ctdb->status.pending_lockwait_calls--;
-		return NULL;
-	}
-
-	ret = pipe(result->fd);
-
-	if (ret != 0) {
-		talloc_free(result);
-		ctdb_db->ctdb->status.pending_lockwait_calls--;
-		return NULL;
-	}
-
-	result->child = fork();
-
-	if (result->child == (pid_t)-1) {
-		close(result->fd[0]);
-		close(result->fd[1]);
-		talloc_free(result);
-		ctdb_db->ctdb->status.pending_lockwait_calls--;
-		return NULL;
-	}
-
-	result->callback = callback;
-	result->private_data = private_data;
-	result->ctdb = ctdb_db->ctdb;
-
-	if (result->child == 0) {
-		close(result->fd[0]);
-		/*
-		 * Do we need a tdb_reopen here?
-		 */
-		tdb_chainlock(ctdb_db->ltdb->tdb, key);
-		_exit(0);
-	}
-
-	close(result->fd[1]);
-	talloc_set_destructor(result, lockwait_destructor);
-
-	result->fde = event_add_fd(ctdb_db->ctdb->ev, result, result->fd[0],
-				   EVENT_FD_READ, lockwait_handler,
-				   (void *)result);
-	if (result->fde == NULL) {
-		talloc_free(result);
-		ctdb_db->ctdb->status.pending_lockwait_calls--;
-		return NULL;
-	}
-
-	result->start_time = timeval_current();
-
-	return result;
-}