/src/gdal/ogr/ogrsf_frmts/generic/ogrlayerpool.h
Line | Count | Source |
1 | | /****************************************************************************** |
2 | | * |
3 | | * Project: OpenGIS Simple Features Reference Implementation |
4 | | * Purpose: Defines OGRLayerPool and OGRProxiedLayer class |
5 | | * Author: Even Rouault, even dot rouault at spatialys.com |
6 | | * |
7 | | ****************************************************************************** |
8 | | * Copyright (c) 2012-2013, Even Rouault <even dot rouault at spatialys.com> |
9 | | * |
10 | | * SPDX-License-Identifier: MIT |
11 | | ****************************************************************************/ |
12 | | |
13 | | #ifndef OGRLAYERPOOL_H_INCLUDED |
14 | | #define OGRLAYERPOOL_H_INCLUDED |
15 | | |
16 | | #ifndef DOXYGEN_SKIP |
17 | | |
18 | | #include "ogrsf_frmts.h" |
19 | | |
20 | | #include <mutex> |
21 | | |
22 | | typedef OGRLayer *(*OpenLayerFunc)(void *user_data); |
23 | | typedef void (*ReleaseLayerFunc)(OGRLayer *, void *user_data); |
24 | | typedef void (*FreeUserDataFunc)(void *user_data); |
25 | | |
26 | | class OGRLayerPool; |
27 | | |
28 | | /************************************************************************/ |
29 | | /* OGRAbstractProxiedLayer */ |
30 | | /************************************************************************/ |
31 | | |
32 | | class CPL_DLL OGRAbstractProxiedLayer : public OGRLayer |
33 | | { |
34 | | CPL_DISALLOW_COPY_ASSIGN(OGRAbstractProxiedLayer) |
35 | | |
36 | | friend class OGRLayerPool; |
37 | | |
38 | | OGRAbstractProxiedLayer |
39 | | *poPrevLayer; /* Chain to a layer that was used more recently */ |
40 | | OGRAbstractProxiedLayer |
41 | | *poNextLayer; /* Chain to a layer that was used less recently */ |
42 | | |
43 | | protected: |
44 | | OGRLayerPool *poPool; |
45 | | |
46 | | virtual void CloseUnderlyingLayer() = 0; |
47 | | |
48 | | public: |
49 | | explicit OGRAbstractProxiedLayer(OGRLayerPool *poPool); |
50 | | ~OGRAbstractProxiedLayer() override; |
51 | | }; |
52 | | |
53 | | /************************************************************************/ |
54 | | /* OGRLayerPool */ |
55 | | /************************************************************************/ |
56 | | |
57 | | class CPL_DLL OGRLayerPool |
58 | | { |
59 | | CPL_DISALLOW_COPY_ASSIGN(OGRLayerPool) |
60 | | |
61 | | protected: |
62 | | OGRAbstractProxiedLayer *poMRULayer; /* the most recently used layer */ |
63 | | OGRAbstractProxiedLayer |
64 | | *poLRULayer; /* the least recently used layer (still opened) */ |
65 | | int nMRUListSize; /* the size of the list */ |
66 | | int nMaxSimultaneouslyOpened; |
67 | | |
68 | | public: |
69 | | explicit OGRLayerPool(int nMaxSimultaneouslyOpened = 100); |
70 | | ~OGRLayerPool(); |
71 | | |
72 | | void SetLastUsedLayer(OGRAbstractProxiedLayer *poProxiedLayer); |
73 | | void UnchainLayer(OGRAbstractProxiedLayer *poProxiedLayer); |
74 | | |
75 | | int GetMaxSimultaneouslyOpened() const |
76 | 0 | { |
77 | 0 | return nMaxSimultaneouslyOpened; |
78 | 0 | } |
79 | | |
80 | | int GetSize() const |
81 | 0 | { |
82 | 0 | return nMRUListSize; |
83 | 0 | } |
84 | | }; |
85 | | |
86 | | /************************************************************************/ |
87 | | /* OGRProxiedLayer */ |
88 | | /************************************************************************/ |
89 | | |
90 | | class CPL_DLL OGRProxiedLayer : public OGRAbstractProxiedLayer |
91 | | { |
92 | | CPL_DISALLOW_COPY_ASSIGN(OGRProxiedLayer) |
93 | | |
94 | | OpenLayerFunc pfnOpenLayer; |
95 | | ReleaseLayerFunc pfnReleaseLayer; |
96 | | FreeUserDataFunc pfnFreeUserData; |
97 | | void *pUserData; |
98 | | mutable OGRLayer *poUnderlyingLayer; |
99 | | mutable OGRFeatureDefn *poFeatureDefn; |
100 | | mutable OGRSpatialReference *poSRS; |
101 | | mutable std::recursive_mutex m_oMutex{}; |
102 | | |
103 | | int OpenUnderlyingLayer() const; |
104 | | |
105 | | protected: |
106 | | void CloseUnderlyingLayer() override; |
107 | | |
108 | | public: |
109 | | OGRProxiedLayer(OGRLayerPool *poPool, OpenLayerFunc pfnOpenLayer, |
110 | | FreeUserDataFunc pfnFreeUserData, void *pUserData); |
111 | | OGRProxiedLayer(OGRLayerPool *poPool, OpenLayerFunc pfnOpenLayer, |
112 | | ReleaseLayerFunc pfnReleaseLayer, |
113 | | FreeUserDataFunc pfnFreeUserData, void *pUserData); |
114 | | ~OGRProxiedLayer() override; |
115 | | |
116 | | OGRLayer *GetUnderlyingLayer(); |
117 | | |
118 | | OGRGeometry *GetSpatialFilter() override; |
119 | | virtual OGRErr ISetSpatialFilter(int iGeomField, |
120 | | const OGRGeometry *) override; |
121 | | |
122 | | OGRErr SetAttributeFilter(const char *) override; |
123 | | |
124 | | void ResetReading() override; |
125 | | OGRFeature *GetNextFeature() override; |
126 | | OGRErr SetNextByIndex(GIntBig nIndex) override; |
127 | | OGRFeature *GetFeature(GIntBig nFID) override; |
128 | | OGRErr ISetFeature(OGRFeature *poFeature) override; |
129 | | OGRErr ICreateFeature(OGRFeature *poFeature) override; |
130 | | OGRErr IUpsertFeature(OGRFeature *poFeature) override; |
131 | | OGRErr IUpdateFeature(OGRFeature *poFeature, int nUpdatedFieldsCount, |
132 | | const int *panUpdatedFieldsIdx, |
133 | | int nUpdatedGeomFieldsCount, |
134 | | const int *panUpdatedGeomFieldsIdx, |
135 | | bool bUpdateStyleString) override; |
136 | | OGRErr DeleteFeature(GIntBig nFID) override; |
137 | | |
138 | | GDALDataset *GetDataset() override; |
139 | | virtual bool GetArrowStream(struct ArrowArrayStream *out_stream, |
140 | | CSLConstList papszOptions = nullptr) override; |
141 | | |
142 | | const char *GetName() const override; |
143 | | OGRwkbGeometryType GetGeomType() const override; |
144 | | const OGRFeatureDefn *GetLayerDefn() const override; |
145 | | |
146 | | const OGRSpatialReference *GetSpatialRef() const override; |
147 | | |
148 | | GIntBig GetFeatureCount(int bForce = TRUE) override; |
149 | | OGRErr IGetExtent(int iGeomField, OGREnvelope *psExtent, |
150 | | bool bForce) override; |
151 | | |
152 | | int TestCapability(const char *) const override; |
153 | | |
154 | | virtual OGRErr CreateField(const OGRFieldDefn *poField, |
155 | | int bApproxOK = TRUE) override; |
156 | | OGRErr DeleteField(int iField) override; |
157 | | OGRErr ReorderFields(int *panMap) override; |
158 | | virtual OGRErr AlterFieldDefn(int iField, OGRFieldDefn *poNewFieldDefn, |
159 | | int nFlags) override; |
160 | | virtual OGRErr |
161 | | AlterGeomFieldDefn(int iGeomField, |
162 | | const OGRGeomFieldDefn *poNewGeomFieldDefn, |
163 | | int nFlags) override; |
164 | | |
165 | | OGRErr SyncToDisk() override; |
166 | | |
167 | | OGRStyleTable *GetStyleTable() override; |
168 | | void SetStyleTableDirectly(OGRStyleTable *poStyleTable) override; |
169 | | |
170 | | void SetStyleTable(OGRStyleTable *poStyleTable) override; |
171 | | |
172 | | OGRErr StartTransaction() override; |
173 | | OGRErr CommitTransaction() override; |
174 | | OGRErr RollbackTransaction() override; |
175 | | |
176 | | const char *GetFIDColumn() const override; |
177 | | const char *GetGeometryColumn() const override; |
178 | | |
179 | | OGRErr SetIgnoredFields(CSLConstList papszFields) override; |
180 | | |
181 | | OGRErr Rename(const char *pszNewName) override; |
182 | | }; |
183 | | |
184 | | #endif /* #ifndef DOXYGEN_SKIP */ |
185 | | |
186 | | #endif // OGRLAYERPOOL_H_INCLUDED |