/[fuse_dbi]/trunk/fuse_dbi.pl
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/fuse_dbi.pl

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 3 by dpavlin, Wed Aug 4 09:25:31 2004 UTC revision 7 by dpavlin, Sat Aug 7 14:48:23 2004 UTC
# Line 1  Line 1 
1  #!/usr/bin/perl  #!/usr/bin/perl
2    
3  use POSIX qw(ENOENT EISDIR EINVAL);  use POSIX qw(ENOENT EISDIR EINVAL ENOSYS O_RDWR);
4  use Fuse;  use Fuse;
5    
6  use DBI;  use DBI;
# Line 15  my $sql_filenames = q{ Line 15  my $sql_filenames = q{
15          from template ;          from template ;
16  };  };
17    
18  my $sql_content = q{  my $sql_read = q{
19          select template          select template
20          from template                  from template
21          where oid = ?;                  where oid = ?;
22    };
23    
24    my $sql_update = q{
25            update template
26                    set template = ?        
27                    where oid = ?;
28  };  };
29    
30    
31  my $connect = "DBI:Pg:dbname=webgui";  my $connect = "DBI:Pg:dbname=webgui";
32    
33  my $dbh = DBI->connect($connect,"","") || die $DBI::errstr;  my $dbh = DBI->connect($connect,"","", { AutoCommit => 0 }) || die $DBI::errstr;
34    
35  print STDERR "$sql_filenames\n";  print "start transaction\n";
36    #$dbh->begin_work || die $dbh->errstr;
37    
38  my $sth_filenames = $dbh->prepare($sql_filenames) || die $dbh->errstr();  my $sth_filenames = $dbh->prepare($sql_filenames) || die $dbh->errstr();
39  $sth_filenames->execute() || die $sth_filenames->errstr();  $sth_filenames->execute() || die $sth_filenames->errstr();
40    
41  my $sth_content = $dbh->prepare($sql_content) || die $dbh->errstr();  my $sth_read = $dbh->prepare($sql_read) || die $dbh->errstr();
42    my $sth_update = $dbh->prepare($sql_update) || die $dbh->errstr();
 print "#",join(",",@{ $sth_filenames->{NAME} }),"\n";  
43    
44  my $ctime_start = time();  my $ctime_start = time();
45    
# Line 81  while (my $row = $sth_filenames->fetchro Line 87  while (my $row = $sth_filenames->fetchro
87          }          }
88  }  }
89    
90  print scalar (keys %dirs), " dirs:",join(" ",keys %dirs),"\n";  print "found ",scalar(keys %files)-scalar(keys %dirs)," files, ",scalar(keys %dirs), " dirs\n";
91    
92  sub filename_fixup {  sub filename_fixup {
93          my ($file) = shift;          my ($file) = shift;
# Line 123  sub e_getdir { Line 129  sub e_getdir {
129                  } else {                  } else {
130                          $out{$f}++ if ($f =~ /^[^\/]+$/);                          $out{$f}++ if ($f =~ /^[^\/]+$/);
131                  }                  }
                 print "f: $_ -> $f\n";  
132          }          }
133          if (! %out) {          if (! %out) {
134                  $out{'no files? bug?'}++;                  $out{'no files? bug?'}++;
# Line 134  sub e_getdir { Line 139  sub e_getdir {
139    
140  sub e_open {  sub e_open {
141          # VFS sanity check; it keeps all the necessary state, not much to do here.          # VFS sanity check; it keeps all the necessary state, not much to do here.
142          my ($file) = filename_fixup(shift);          my $file = filename_fixup(shift);
143            my $flags = shift;
144    
145          return -ENOENT() unless exists($files{$file});          return -ENOENT() unless exists($files{$file});
146          return -EISDIR() unless exists($files{$file}{id});          return -EISDIR() unless exists($files{$file}{id});
147    
148          if (!exists($files{$file}{cont})) {          if (!exists($files{$file}{cont})) {
149                  $sth_content->execute($files{$file}{id});                  $sth_read->execute($files{$file}{id}) || die $sth_read->errstr;
150                  $files{$file}{cont} = $sth_content->fetchrow_array;                  $files{$file}{cont} = $sth_read->fetchrow_array;
151                    print "file '$file' content read in cache\n";
152          }          }
153          print "open '$file' ",length($files{$file}{cont})," bytes\n";          print "open '$file' ",length($files{$file}{cont})," bytes\n";
154          return 0;          return 0;
# Line 166  sub e_read { Line 175  sub e_read {
175          return substr($files{$file}{cont},$off,$buf);          return substr($files{$file}{cont},$off,$buf);
176  }  }
177    
178    sub clear_cont {
179            print "transaction rollback\n";
180            $dbh->rollback || die $dbh->errstr;
181            print "invalidate all cached content\n";
182            foreach my $f (keys %files) {
183                    delete $files{$f}{cont};
184            }
185            print "begin new transaction\n";
186            $dbh->begin_work || die $dbh->errstr;
187    }
188    
189    
190    sub update_db {
191            my $file = shift || die;
192    
193            if (!$sth_update->execute($files{$file}{cont},$files{$file}{id})) {
194                    print "update problem: ",$sth_update->errstr;
195                    clear_cont;
196                    return 0;
197            } else {
198                    if (! $dbh->commit) {
199                            print "ERROR: commit problem: ",$sth_update->errstr;
200                            clear_cont;
201                            return 0;
202                    }
203                    print "updated '$file' [",$files{$file}{id},"]\n";
204            }
205            return 1;
206    }
207    
208    sub e_write {
209            my $file = filename_fixup(shift);
210            my ($buf,$off) = @_;
211    
212            return -ENOENT() unless exists($files{$file});
213    
214            my $len = length($files{$file}{cont});
215    
216            print "write '$file' [$len bytes] offset $off length $buf\n";
217    
218            $files{$file}{cont} =
219                    substr($files{$file}{cont},0,$off) .
220                    $buf .
221                    substr($files{$file}{cont},$off+length($buf));
222    
223            if (! update_db($file)) {
224                    return -ENOSYS();
225            } else {
226                    return length($buf);
227            }
228    }
229    
230    sub e_truncate {
231            my $file = filename_fixup(shift);
232            my $size = shift;
233    
234            $files{$file}{cont} = substr($files{$file}{cont},0,$size);
235            return 0
236    };
237    
238    
239    sub e_utime {
240            my ($atime,$mtime,$file) = @_;
241            $file = filename_fixup($file);
242    
243            return -ENOENT() unless exists($files{$file});
244    
245            $files{$file}{time} = $mtime;
246            return 0;
247    }
248    
249  sub e_statfs { return 255, 1, 1, 1, 1, 2 }  sub e_statfs { return 255, 1, 1, 1, 1, 2 }
250    
251  # If you run the script directly, it will run fusermount, which will in turn  # If you run the script directly, it will run fusermount, which will in turn
# Line 179  Fuse::main( Line 259  Fuse::main(
259          open=>\&e_open,          open=>\&e_open,
260          statfs=>\&e_statfs,          statfs=>\&e_statfs,
261          read=>\&e_read,          read=>\&e_read,
262          debug=>1,          write=>\&e_write,
263            utime=>\&e_utime,
264            truncate=>\&e_truncate,
265            debug=>0,
266  );  );
Legend:
Removed from v.3  
changed lines
  Added in v.7
  ViewVC Help
Powered by ViewVC 1.1.26