+Workaround Linux kernel last device block inaccessibility.
[captive.git] / src / libcaptive / storage / size.c
index 442054a..cab7f76 100644 (file)
 #include "config.h"
 
 #include "captive/storage.h"   /* self */
+#include "../client/giochannel-blind.h"        /* for captive_giochannel_blind_get_size() */
+#include "../client/giochannel-subrange.h"     /* for captive_giochannel_subrange_get_size() */
+#include "../sandbox/client-CaptiveIOChannel.h"        /* for captive_io_channel_get_size() */
 #include <glib/gmessages.h>
 #include <glib/gtypes.h>
+#include <fcntl.h>
+#include <sys/ioctl.h>
+#include <unistd.h>
+/* Do not: #include <linux/fs.h>       * for 'BLKGETSIZE64' *
+ * as including any Linux kernel include files is too much incompatible.
+ */
+#include <sys/mount.h> /* for 'BLKGETSIZE' */
+#include "iounixchannel.h"
 
 
-guint64 captive_giochannel_size(GIOChannel *iochannel)
+static guint64 size_subrange(GIOChannel *iochannel)
+{
+guint64 r;
+
+       g_return_val_if_fail(iochannel!=NULL,0);
+
+       if (!captive_giochannel_subrange_get_size(iochannel,&r))
+               return 0;
+
+       return r;
+}
+
+
+static guint64 size_blind(GIOChannel *iochannel)
+{
+guint64 r;
+
+       g_return_val_if_fail(iochannel!=NULL,0);
+
+       if (!captive_giochannel_blind_get_size(iochannel,&r))
+               return 0;
+
+       return r;
+}
+
+
+static guint64 size_sandbox(GIOChannel *iochannel)
+{
+guint64 r;
+
+       g_return_val_if_fail(iochannel!=NULL,0);
+
+       if (!captive_io_channel_get_size(iochannel,&r))
+               return 0;
+
+       return r;
+}
+
+
+guint64 captive_giochannel_size_ioctl(GIOChannel *iochannel)
+{
+int fd;
+guint64 r;
+long r_long;
+
+       g_return_val_if_fail(iochannel!=NULL,0);
+
+       if (-1==(fd=captive_iounixchannel_get_fd(iochannel)))
+               return 0;
+
+#ifdef BLKGETSIZE64
+       if (!ioctl(fd,BLKGETSIZE64,&r))
+               return r;
+#endif
+       if (ioctl(fd,BLKGETSIZE,&r_long))
+               return 0;
+       if (r_long<0)
+               return 0;
+       r=((guint64)512)*r_long;
+
+       return r;
+}
+
+
+static guint64 size_seek(GIOChannel *iochannel)
+{
+int fd;
+off_t offset_orig,offset;
+
+       g_return_val_if_fail(iochannel!=NULL,0);
+
+       /* We may need '_FILE_OFFSET_BITS=64'.
+        * Setting '__USE_FILE_OFFSET64' did not help.
+        * Done by 'AC_SYS_LARGEFILE' of configure.in.
+        */
+       g_return_val_if_fail(sizeof(offset)==sizeof(guint64),0);
+
+       if (-1==(fd=captive_iounixchannel_get_fd(iochannel)))
+               return 0;
+
+       if (-1==(offset_orig=lseek(fd,0,SEEK_CUR)))
+               return 0;
+       g_return_val_if_fail(offset_orig>=0,0);
+       offset=lseek(fd,0,SEEK_END);
+       if (offset_orig!=lseek(fd,offset_orig,SEEK_SET))
+               g_assert_not_reached();
+
+       if (-1==offset)
+               return 0;
+       g_return_val_if_fail(offset>=0,0);
+
+       return offset;
+}
+
+
+
+static guint64 size_read(GIOChannel *iochannel)
 {
-gint fd;
 gint64 low,high,mid;
 GIOStatus erriostatus;
 gchar bufchar;
@@ -36,18 +142,13 @@ gsize bufchargot;
        /* Default "UTF-8" encoding is not much usable for us */
        g_return_val_if_fail(g_io_channel_get_encoding(iochannel)==NULL,0);
 
-       fd=g_io_channel_unix_get_fd(iochannel);
-       g_return_val_if_fail(fd!=-1,0);
-
-       /* FIXME: TODO: ioctl() detection */
-
        /* low  ==high: low (high)
         * low+1==high: mid==low; NORMAL: no change: high
         * low+1==high: mid==low; EOF   : high=mid => 'low==high' case
         */
        for (low=0,
                        high=
-                                       G_MAXINT;       /* FIXME: 'G_MAXINT64' fails on g_io_channel_seek_position() */
+                                       G_MAXINT64;
                        low+1<high;) {
                mid=low+(high-low)/2;   /* beware of 'gint64' overflow! */
 
@@ -70,10 +171,18 @@ gsize bufchargot;
                                        sizeof(bufchar),        /* count */
                                        &bufchargot,    /* bytes_read */
                                        NULL);  /* error */
-                       g_assert(erriostatus==G_IO_STATUS_NORMAL || erriostatus==G_IO_STATUS_EOF);
+                       /* During read on the end boundary of Linux kernel block device we will
+                        * get GNOME_VFS_ERROR_IO at least from linux-kernel-2.4.19-ac4
+                        * which will get mapped to G_IO_STATUS_ERROR by captive_gnomevfs_giognomevfs_io_read().
+                        */
+                       g_assert(0
+                                       || erriostatus==G_IO_STATUS_NORMAL
+                                       || erriostatus==G_IO_STATUS_EOF
+                                       || erriostatus==G_IO_STATUS_ERROR);
                        g_assert(0
                                        || (erriostatus==G_IO_STATUS_NORMAL && bufchargot==1)
-                                       || (erriostatus==G_IO_STATUS_EOF    && bufchargot==0));
+                                       || (erriostatus==G_IO_STATUS_EOF    && bufchargot==0)
+                                       || (erriostatus==G_IO_STATUS_ERROR  && bufchargot==0));
                        }
 
                if (erriostatus==G_IO_STATUS_NORMAL)
@@ -85,3 +194,24 @@ gsize bufchargot;
        g_assert(high>=0);
        return high;
 }
+
+
+guint64 captive_giochannel_size(GIOChannel *iochannel)
+{
+guint64 r;
+
+       if ((r=size_subrange(iochannel)))
+               return r;
+       if ((r=size_blind(iochannel)))
+               return r;
+       if ((r=size_sandbox(iochannel)))
+               return r;
+       if ((r=captive_giochannel_size_ioctl(iochannel)))
+               return r;
+       if ((r=size_seek(iochannel)))
+               return r;
+       if ((r=size_read(iochannel)))
+               return r;
+
+       return r;
+}