X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=device-src%2Fdevice.c;fp=device-src%2Fdevice.c;h=2413dfc6160e74e4585152522e79ddb4ce0529fc;hb=109540caa4e37a3663b3dcfb9a205b9609e3f561;hp=f0258d5d25b20cba4b4a69aa999312e21016fa82;hpb=4c9eba1feb11adf189bceb4001c425e641f0b56a;p=debian%2Famanda

diff --git a/device-src/device.c b/device-src/device.c
index f0258d5..2413dfc 100644
--- a/device-src/device.c
+++ b/device-src/device.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2007, 2008, 2009, 2010 Zmanda, Inc.  All Rights Reserved.
+ * Copyright (c) 2007-2012 Zmanda, Inc.  All Rights Reserved.
  *
  * This program is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 as published
@@ -526,6 +526,7 @@ device_open (char * device_name)
     device = factory(device_name, device_type, device_node);
     g_assert(device != NULL); /* factories must always return a device */
 
+    device->device_mutex = g_mutex_new();
     amfree(device_type);
     amfree(device_node);
 
@@ -1116,6 +1117,46 @@ device_finish (Device * self) {
     return (klass->finish)(self);
 }
 
+guint64
+device_get_bytes_read (Device * self) {
+    DeviceClass *klass;
+    guint64 bytes = 0;
+
+    g_assert(IS_DEVICE (self));
+
+    g_mutex_lock(self->device_mutex);
+    if (self->in_file) {
+	klass = DEVICE_GET_CLASS(self);
+	if (klass->get_bytes_read) {
+	    bytes = (klass->get_bytes_read)(self);
+	} else {
+	    bytes = self->bytes_read;
+	}
+    }
+    g_mutex_unlock(self->device_mutex);
+    return bytes;
+}
+
+guint64
+device_get_bytes_written (Device * self) {
+    DeviceClass *klass;
+    guint64 bytes = 0;
+
+    g_assert(IS_DEVICE (self));
+
+    g_mutex_lock(self->device_mutex);
+    if (self->in_file) {
+	klass = DEVICE_GET_CLASS(self);
+	if (klass->get_bytes_written) {
+	    bytes = (klass->get_bytes_written)(self);
+	} else {
+	    bytes = self->bytes_written;
+	}
+    }
+    g_mutex_unlock(self->device_mutex);
+    return bytes;
+}
+
 gboolean
 device_configure (Device * self, gboolean use_global_config)
 {
@@ -1392,6 +1433,26 @@ device_accept(
     }
 }
 
+gboolean
+device_accept_with_cond(
+    Device *self,
+    DirectTCPConnection **conn,
+    GMutex *abort_mutex,
+    GCond *abort_cond)
+{
+    DeviceClass *klass;
+
+    klass = DEVICE_GET_CLASS(self);
+    if(klass->accept_with_cond) {
+	return (klass->accept_with_cond)(self, conn, abort_mutex, abort_cond);
+    } else {
+	device_set_error(self,
+	    g_strdup(_("Unimplemented method")),
+	    DEVICE_STATUS_DEVICE_ERROR);
+	return FALSE;
+    }
+}
+
 gboolean
 device_connect(
     Device *self,
@@ -1414,6 +1475,28 @@ device_connect(
     }
 }
 
+gboolean
+device_connect_with_cond(
+    Device *self,
+    gboolean for_writing,
+    DirectTCPAddr *addrs,
+    DirectTCPConnection **conn,
+    GMutex *abort_mutex,
+    GCond *abort_cond)
+{
+    DeviceClass *klass;
+
+    klass = DEVICE_GET_CLASS(self);
+    if(klass->connect) {
+	return (klass->connect_with_cond)(self, for_writing, addrs, conn, abort_mutex, abort_cond);
+    } else {
+	device_set_error(self,
+	    g_strdup(_("Unimplemented method")),
+	    DEVICE_STATUS_DEVICE_ERROR);
+	return FALSE;
+    }
+}
+
 gboolean
 device_write_from_connection(
     Device *self,