src/server/plugins/postgresql/vfs.c

Tue, 01 Feb 2022 17:47:50 +0100

author
Olaf Wintermann <olaf.wintermann@gmail.com>
date
Tue, 01 Feb 2022 17:47:50 +0100
branch
webdav
changeset 281
e9dc53661df4
parent 280
d0d5a970292f
child 282
cfb588e27198
permissions
-rw-r--r--

add pg vfs stat/fstat implementation

275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
1 /*
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
3 *
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
4 * Copyright 2022 Olaf Wintermann. All rights reserved.
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
5 *
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
6 * Redistribution and use in source and binary forms, with or without
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
7 * modification, are permitted provided that the following conditions are met:
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
8 *
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
9 * 1. Redistributions of source code must retain the above copyright
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
10 * notice, this list of conditions and the following disclaimer.
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
11 *
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
12 * 2. Redistributions in binary form must reproduce the above copyright
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
13 * notice, this list of conditions and the following disclaimer in the
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
14 * documentation and/or other materials provided with the distribution.
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
15 *
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
26 * POSSIBILITY OF SUCH DAMAGE.
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
27 */
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
28
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
29 #include "vfs.h"
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
30
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
31 #include <inttypes.h>
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
32
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
33 #include "../../util/util.h"
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
34
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
35 static VFS pg_vfs_class = {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
36 pg_vfs_open,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
37 pg_vfs_stat,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
38 pg_vfs_fstat,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
39 pg_vfs_opendir,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
40 pg_vfs_fdopendir,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
41 pg_vfs_mkdir,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
42 pg_vfs_unlink,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
43 pg_vfs_rmdir
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
44 };
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
45
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
46 static VFS_IO pg_vfs_io_class = {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
47 pg_vfs_io_read,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
48 pg_vfs_io_write,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
49 pg_vfs_io_pread,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
50 pg_vfs_io_pwrite,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
51 pg_vfs_io_seek,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
52 pg_vfs_io_close,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
53 NULL, // no pg aio implementation yet
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
54 NULL
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
55 };
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
56
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
57 static VFS_DIRIO pg_vfs_dirio_class = {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
58 pg_vfs_dirio_readdir,
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
59 pg_vfs_dirio_close
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
60 };
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
61
276
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
62
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
63 /*
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
64 * SQL Queries
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
65 */
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
66
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
67 // Resolves a path into resource_id and parent_id
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
68 // params: $1: path string
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
69 static const char *sql_resolve_path =
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
70 "with recursive resolvepath as (\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
71 select\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
72 resource_id,\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
73 parent_id,\n\
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
74 '' as fullpath,\n\
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
75 iscollection,\n\
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
76 lastmodified,\n\
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
77 creationdate,\n\
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
78 contentlength,\n\
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
79 regexp_split_to_array($1, '/') as pathelm,\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
80 1 as pathdepth\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
81 from Resource\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
82 where parent_id is null\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
83 union\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
84 select\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
85 r.resource_id,\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
86 r.parent_id,\n\
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
87 p.fullpath || '/' || r.nodename,\n\
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
88 r.iscollection,\n\
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
89 r.lastmodified,\n\
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
90 r.creationdate,\n\
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
91 r.contentlength,\n\
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
92 p.pathelm,\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
93 p.pathdepth + 1\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
94 from Resource r\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
95 inner join resolvepath p on r.parent_id = p.resource_id\n\
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
96 where p.pathelm[p.pathdepth+1] = r.nodename\n\
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
97 )\n\
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
98 select resource_id, parent_id, fullpath, iscollection from resolvepath\n\
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
99 where fullpath = $1 ;";
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
100
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
101 // Same as sql_resolve_path, but it returns the root collection
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
102 // params: $1: path string (should be '/')
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
103 static const char *sql_get_root = "select resource_id, parent_id, $1 as fullpath, true as iscollection, lastmodified, creationdate, contentlength from Resource where parent_id is null;";
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
104
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
105 // Get all children of a specific collection
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
106 // params: $1: parent resource_id
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
107 static const char *sql_get_children = "select resource_id, nodename, iscollection, lastmodified, creationdate, contentlength from Resource where parent_id = $1;";
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
108
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
109 // Get resource
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
110 // params: $1: resource_id
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
111 static const char *sql_get_resource = "select resource_id, nodename, iscollection, lastmodified, creationdate, contentlength from Resource where resource_id = $1;";
276
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
112
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
113 VFS* pg_vfs_create(Session *sn, Request *rq, pblock *pb) {
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
114 // resourcepool is required
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
115 char *resource_pool = pblock_findval("resourcepool", pb);
276
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
116 if(!resource_pool) {
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
117 log_ereport(LOG_MISCONFIG, "pg_vfs_create: missing resourcepool parameter");
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
118 return NULL;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
119 }
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
120
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
121 // get the resource first (most likely to fail due to misconfig)
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
122 ResourceData *resdata = resourcepool_lookup(sn, rq, resource_pool, 0);
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
123 if(!resdata) {
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
124 log_ereport(LOG_MISCONFIG, "postgresql vfs: resource pool %s not found", resource_pool);
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
125 return NULL;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
126 }
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
127 // resdata will be freed automatically when the request is finished
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
128
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
129 // Create a new VFS object and a separate instance object
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
130 // VFS contains fptrs that can be copied from pg_vfs_class
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
131 // instance contains request specific data (PGconn)
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
132 VFS *vfs = pool_malloc(sn->pool, sizeof(VFS));
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
133 if(!vfs) {
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
134 return NULL;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
135 }
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
136
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
137 PgVFS *vfs_priv = pool_malloc(sn->pool, sizeof(PgVFS));
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
138 if(!vfs_priv) {
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
139 pool_free(sn->pool, vfs);
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
140 return NULL;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
141 }
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
142 vfs_priv->connection = resdata->data;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
143 vfs_priv->pg_resource = resdata;
276
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
144
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
145 memcpy(vfs, &pg_vfs_class, sizeof(VFS));
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
146 vfs->flags = 0;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
147 vfs->instance = vfs_priv;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
148
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
149 return vfs;
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
150 }
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
151
0cb4eda146c4 add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 275
diff changeset
152
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
153 int pg_resolve_path(
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
154 VFSContext *ctx,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
155 const char *path,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
156 int64_t *parent_id,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
157 int64_t *resource_id,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
158 const char **resource_name,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
159 WSBool *iscollection,
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
160 struct stat *s)
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
161 {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
162 // basic path validation
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
163 if(!path) return 1;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
164 size_t pathlen = strlen(path);
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
165 if(pathlen == 0) return 1;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
166 if(path[0] != '/') {
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
167 return 1;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
168 }
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
169
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
170 char *pathf = NULL;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
171 if(pathlen > 1 && path[pathlen-1] == '/') {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
172 pathf = malloc(pathlen);
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
173 memcpy(pathf, path, pathlen);
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
174 pathf[pathlen-1] = 0; // remove trailing '/'
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
175 path = pathf;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
176 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
177
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
178 // get last node of path
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
179 *resource_name = util_resource_name(path);
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
180
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
181 VFS *vfs = ctx->vfs;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
182 PgVFS *pg = vfs->instance;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
183
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
184 const char *sql = pathlen == 1 ? sql_get_root : sql_resolve_path;
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
185 PGresult *result = PQexecParams(
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
186 pg->connection,
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
187 sql,
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
188 1, // number of parameters
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
189 NULL,
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
190 &path, // parameter value
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
191 NULL,
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
192 NULL,
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
193 0); // 0: result in text format
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
194
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
195 if(pathf) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
196 free(pathf);
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
197 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
198
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
199 if(!result) return 1;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
200
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
201 int ret = 1;
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
202 //int nfields = PQnfields(result);
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
203 int nrows = PQntuples(result);
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
204 if(nrows == 1) {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
205 char *resource_id_str = PQgetvalue(result, 0, 0);
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
206 char *parent_id_str = PQgetvalue(result, 0, 1);
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
207 char *iscol = PQgetvalue(result, 0, 3);
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
208 char *lastmodified = PQgetvalue(result, 0, 4);
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
209 char *creationdate = PQgetvalue(result, 0, 5);
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
210 char *contentlength = PQgetvalue(result, 0, 6);
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
211 if(resource_id_str && parent_id_str) {
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
212 if(util_strtoint(resource_id_str, resource_id)) {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
213 ret = 0; // success
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
214 }
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
215 // optionally get parent_id
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
216 util_strtoint(parent_id_str, parent_id);
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
217 }
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
218
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
219 if(iscollection && iscol) {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
220 *iscollection = iscol[0] == 't' ? TRUE : FALSE;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
221 }
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
222
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
223 if(s) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
224 memset(s, 0, sizeof(struct stat));
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
225
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
226 s->st_ino = *resource_id;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
227 if(iscol) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
228 s->st_mode |= 0x4000;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
229 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
230 if(lastmodified) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
231 // TODO
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
232 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
233 if(creationdate) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
234 // TODO
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
235 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
236 if(contentlength) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
237 int64_t len;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
238 if(util_strtoint(contentlength, &len)) {
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
239 s->st_size = len;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
240 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
241 }
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
242 }
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
243 } else {
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
244 ctx->vfs_errno = ENOENT;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
245 }
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
246
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
247 PQclear(result);
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
248
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
249 return ret;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
250 }
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
251
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
252
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
253 /* -------------------------- VFS functions -------------------------- */
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
254
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
255 SYS_FILE pg_vfs_open(VFSContext *ctx, const char *path, int oflags) {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
256 const char *resname;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
257 int64_t resource_id, parent_id;
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
258 resource_id = -1;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
259 parent_id = -1;
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
260 WSBool iscollection;
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
261 struct stat s;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
262 if(pg_resolve_path(ctx, path, &parent_id, &resource_id, &resname, &iscollection, &s)) {
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
263 return NULL;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
264 }
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
265
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
266 VFSFile *file = pool_malloc(ctx->pool, sizeof(VFSFile));
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
267 if(!file) {
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
268 return NULL;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
269 }
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
270 PgFile *pgfile = pool_malloc(ctx->pool, sizeof(PgFile));
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
271 if(!pgfile) {
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
272 pool_free(ctx->pool, file);
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
273 return NULL;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
274 }
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
275
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
276 pgfile->iscollection = iscollection;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
277 pgfile->resource_id = resource_id;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
278 pgfile->parent_id = parent_id;
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
279 pgfile->s = s;
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
280
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
281 file->ctx = ctx;
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
282 file->io = iscollection ? &pg_vfs_io_class : &pg_vfs_io_class;
278
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
283 file->fd = -1;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
284 file->data = pgfile;
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
285
38bf7b42b58c implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 276
diff changeset
286 return file;
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
287 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
288
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
289 int pg_vfs_stat(VFSContext *ctx, const char *path, struct stat *buf) {
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
290 int64_t parent_id, resource_id;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
291 const char *resname;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
292 WSBool iscollection;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
293 return pg_resolve_path(ctx, path, &parent_id, &resource_id, &resname, &iscollection, buf);
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
294 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
295
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
296 int pg_vfs_fstat(VFSContext *ctx, SYS_FILE fd, struct stat *buf) {
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
297 PgFile *pgfile = fd->data;
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
298 memcpy(buf, &pgfile->s, sizeof(struct stat));
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
299 return 0;
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
300 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
301
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
302 VFS_DIR pg_vfs_opendir(VFSContext *ctx, const char *path) {
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
303 VFSFile *file = pg_vfs_open(ctx, path, O_RDONLY);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
304 if(!file) return NULL;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
305 return pg_vfs_fdopendir(ctx, file);
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
306 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
307
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
308 VFS_DIR pg_vfs_fdopendir(VFSContext *ctx, SYS_FILE fd) {
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
309 PgFile *pg = fd->data;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
310 if(!pg->iscollection) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
311 ctx->vfs_errno = ENOTDIR;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
312 return NULL;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
313 }
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
314
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
315 VFSDir *dir = pool_malloc(ctx->pool, sizeof(VFSDir));
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
316 if(!dir) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
317 fd->io->close(fd);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
318 ctx->vfs_errno = ENOMEM;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
319 return NULL;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
320 }
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
321
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
322 PgDir *pgdir = pool_malloc(ctx->pool, sizeof(PgDir));
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
323 if(!pgdir) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
324 fd->io->close(fd);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
325 pool_free(ctx->pool, dir);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
326 ctx->vfs_errno = ENOMEM;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
327 return NULL;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
328 }
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
329 memset(pgdir, 0, sizeof(PgDir));
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
330 pgdir->file = fd;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
331
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
332 dir->ctx = ctx;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
333 dir->io = &pg_vfs_dirio_class;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
334 dir->data = pgdir;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
335 dir->fd = -1;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
336
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
337 return dir;
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
338 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
339
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
340 int pg_vfs_mkdir(VFSContext *ctx, const char *path) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
341
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
342 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
343
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
344 int pg_vfs_unlink(VFSContext *ctx, const char *path) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
345
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
346 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
347
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
348 int pg_vfs_rmdir(VFSContext *Ctx, const char *path) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
349
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
350 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
351
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
352
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
353 /* -------------------------- VFS_IO functions -------------------------- */
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
354
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
355 ssize_t pg_vfs_io_read(SYS_FILE fd, void *buf, size_t nbyte) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
356
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
357 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
358
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
359 ssize_t pg_vfs_io_write(SYS_FILE fd, const void *buf, size_t nbyte) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
360
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
361 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
362
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
363 ssize_t pg_vfs_io_pread(SYS_FILE fd, void *buf, size_t nbyte, off_t offset) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
364
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
365 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
366
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
367 ssize_t pg_vfs_io_pwrite(SYS_FILE fd, const void *buf, size_t nbyte, off_t offset) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
368
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
369 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
370
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
371 off_t pg_vfs_io_seek(SYS_FILE fd, off_t offset, int whence) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
372
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
373 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
374
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
375 void pg_vfs_io_close(SYS_FILE fd) {
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
376
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
377 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
378
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
379
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
380 /* -------------------------- VFS_DIRIO functions -------------------------- */
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
381
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
382 static int load_dir(VFSDir *dir, PgDir *pg) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
383 VFS *vfs = dir->ctx->vfs;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
384 PgVFS *pgvfs = vfs->instance;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
385 PgFile *pgfd = pg->file->data;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
386 PgDir *pgdir = dir->data;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
387
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
388 char resid_param[32];
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
389 snprintf(resid_param, 32, "%" PRId64, pgfd->resource_id);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
390
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
391 const char *param = resid_param;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
392
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
393 PGresult *result = PQexecParams(
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
394 pgvfs->connection,
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
395 sql_get_children,
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
396 1, // number of parameters
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
397 NULL,
281
e9dc53661df4 add pg vfs stat/fstat implementation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 280
diff changeset
398 &param, // param: parent resource_id
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
399 NULL,
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
400 NULL,
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
401 0); // 0: result in text format
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
402 if(!result) return 1;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
403
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
404 pgdir->result = result;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
405 pgdir->nrows = PQntuples(result);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
406 return 0;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
407 }
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
408
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
409 int pg_vfs_dirio_readdir(VFS_DIR dir, VFS_ENTRY *entry, int getstat) {
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
410 PgDir *pg = dir->data;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
411 if(!pg->result) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
412 if(load_dir(dir, pg)) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
413 return 0;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
414 }
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
415 }
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
416
279
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
417 if(pg->row >= pg->nrows) {
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
418 return 0; // EOF
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
419 }
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
420
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
421 entry->name = PQgetvalue(pg->result, pg->row, 1);
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
422
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
423 // TODO: stat
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
424
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
425 pg->row++;
79029fe26aae add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 278
diff changeset
426 return 1;
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
427 }
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
428
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
429 void pg_vfs_dirio_close(VFS_DIR dir) {
280
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
430 pool_handle_t *pool = dir->ctx->pool;
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
431 PgDir *pg = dir->data;
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
432 if(pg->result) {
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
433 PQclear(pg->result);
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
434 }
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
435 PgFile *pgfile = pg->file->data;
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
436
280
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
437 pool_free(pool, pgfile);
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
438 pool_free(pool, pg->file);
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
439 pool_free(pool, pg);
d0d5a970292f implement pg_vfs_dirio_close
Olaf Wintermann <olaf.wintermann@gmail.com>
parents: 279
diff changeset
440 pool_free(pool, dir);
275
535004faa1a5 add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
441 }

mercurial