diff options
Diffstat (limited to 'src/tests')
-rw-r--r-- | src/tests/bigmyriad.cpp | 8 | ||||
-rw-r--r-- | src/tests/cache.cpp | 289 | ||||
-rw-r--r-- | src/tests/cachedel.cpp | 288 | ||||
-rw-r--r-- | src/tests/mfstest.cpp | 88 | ||||
-rw-r--r-- | src/tests/myriadfs.cpp | 62 |
5 files changed, 4 insertions, 731 deletions
diff --git a/src/tests/bigmyriad.cpp b/src/tests/bigmyriad.cpp index 9af301c..21c5ff2 100644 --- a/src/tests/bigmyriad.cpp +++ b/src/tests/bigmyriad.cpp | |||
@@ -5,17 +5,17 @@ | |||
5 | int main() | 5 | int main() |
6 | { | 6 | { |
7 | Bu::File f("big.myr", Bu::File::Read|Bu::File::Write|Bu::File::Create ); | 7 | Bu::File f("big.myr", Bu::File::Read|Bu::File::Write|Bu::File::Create ); |
8 | Bu::Myriad m( f, 2048 ); | 8 | Bu::Myriad m( f, 8, 12 ); |
9 | 9 | ||
10 | char *buf = new char[1024*1024*10]; | 10 | char *buf = new char[1024*1024*10]; |
11 | memset( buf, 0, 1024*1024*10 ); | 11 | memset( buf, 0, 1024*1024*10 ); |
12 | 12 | ||
13 | for( int j = 0; j < 250; j++ ) | 13 | for( int j = 0; j < 250; j++ ) |
14 | { | 14 | { |
15 | m.openStream( m.createStream() ).write( buf, 1024*1024*10 ); | 15 | // m.openStream( m.createStream() ).write( buf, 1024*1024*10 ); |
16 | // m.sync(); | 16 | // m.sync(); |
17 | printf("\r%03d%%", (j+1)*100/250 ); | 17 | // printf("\r%03d%%", (j+1)*100/250 ); |
18 | fflush( stdout ); | 18 | // fflush( stdout ); |
19 | } | 19 | } |
20 | 20 | ||
21 | printf("\n\n"); | 21 | printf("\n\n"); |
diff --git a/src/tests/cache.cpp b/src/tests/cache.cpp deleted file mode 100644 index 4751559..0000000 --- a/src/tests/cache.cpp +++ /dev/null | |||
@@ -1,289 +0,0 @@ | |||
1 | #include "bu/myriadcache.h" | ||
2 | #include "bu/uuid.h" | ||
3 | #include "bu/string.h" | ||
4 | #include "bu/sio.h" | ||
5 | |||
6 | class Something : public Bu::CacheObject<Bu::Uuid, Something> | ||
7 | { | ||
8 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, Something &s ); | ||
9 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const Something &s ); | ||
10 | public: | ||
11 | Something() | ||
12 | { | ||
13 | } | ||
14 | |||
15 | Something( const Bu::String &sName ) : | ||
16 | uId( Bu::Uuid::generate() ), | ||
17 | sName( sName ) | ||
18 | { | ||
19 | } | ||
20 | |||
21 | virtual ~Something() | ||
22 | { | ||
23 | } | ||
24 | |||
25 | virtual Bu::Uuid getKey() const | ||
26 | { | ||
27 | return uId; | ||
28 | } | ||
29 | |||
30 | Bu::String getName() const | ||
31 | { | ||
32 | return sName; | ||
33 | } | ||
34 | |||
35 | void setName( const Bu::String &sNewName ) | ||
36 | { | ||
37 | sName = sNewName; | ||
38 | changed(); | ||
39 | } | ||
40 | |||
41 | virtual Bu::String toString() const=0; | ||
42 | |||
43 | private: | ||
44 | Bu::Uuid uId; | ||
45 | Bu::String sName; | ||
46 | }; | ||
47 | |||
48 | class SubSomethingA : public Something | ||
49 | { | ||
50 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingA &s ); | ||
51 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingA &s ); | ||
52 | public: | ||
53 | SubSomethingA() | ||
54 | { | ||
55 | } | ||
56 | |||
57 | SubSomethingA( const Bu::String &sName, int iNumber ) : | ||
58 | Something( sName ), | ||
59 | iNumber( iNumber ) | ||
60 | { | ||
61 | } | ||
62 | |||
63 | virtual Bu::String toString() const | ||
64 | { | ||
65 | return Bu::String("[typeA] %1 (%2)").arg( getName() ).arg( iNumber ); | ||
66 | } | ||
67 | |||
68 | private: | ||
69 | int iNumber; | ||
70 | }; | ||
71 | |||
72 | class SubSomethingB : public Something | ||
73 | { | ||
74 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingB &s ); | ||
75 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingB &s ); | ||
76 | public: | ||
77 | SubSomethingB() | ||
78 | { | ||
79 | } | ||
80 | |||
81 | SubSomethingB( const Bu::String &sName, const Bu::String &sString ) : | ||
82 | Something( sName ), | ||
83 | sString( sString ) | ||
84 | { | ||
85 | } | ||
86 | |||
87 | virtual Bu::String toString() const | ||
88 | { | ||
89 | return Bu::String("[typeB] %1 (%2)").arg( getName() ).arg( sString ); | ||
90 | } | ||
91 | |||
92 | private: | ||
93 | Bu::String sString; | ||
94 | }; | ||
95 | |||
96 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, Something &s ) | ||
97 | { | ||
98 | return ar >> s.uId >> s.sName; | ||
99 | } | ||
100 | |||
101 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const Something &s ) | ||
102 | { | ||
103 | return ar << s.uId << s.sName; | ||
104 | } | ||
105 | |||
106 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingA &s ) | ||
107 | { | ||
108 | return ar >> (Something &)s >> s.iNumber; | ||
109 | } | ||
110 | |||
111 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingA &s ) | ||
112 | { | ||
113 | return ar << (Something &)s << s.iNumber; | ||
114 | } | ||
115 | |||
116 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingB &s ) | ||
117 | { | ||
118 | return ar >> (Something &)s >> s.sString; | ||
119 | } | ||
120 | |||
121 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingB &s ) | ||
122 | { | ||
123 | return ar << (Something &)s << s.sString; | ||
124 | } | ||
125 | |||
126 | namespace Bu | ||
127 | { | ||
128 | template<> | ||
129 | void _cacheObjectSave<const Something>( Bu::Stream &s, const Something *pObject ) | ||
130 | { | ||
131 | Bu::Archive ar( s, Bu::Archive::save ); | ||
132 | if( typeid(*pObject) == typeid(SubSomethingA) ) | ||
133 | { | ||
134 | ar << (uint8_t)1 << (SubSomethingA &)*pObject; | ||
135 | } | ||
136 | else if( typeid(*pObject) == typeid(SubSomethingB) ) | ||
137 | { | ||
138 | ar << (uint8_t)2 << (SubSomethingB &)*pObject; | ||
139 | } | ||
140 | else | ||
141 | { | ||
142 | Bu::println("Not a recognized type!"); | ||
143 | throw Bu::ExceptionBase("Not recognized type!"); | ||
144 | } | ||
145 | } | ||
146 | |||
147 | template<> | ||
148 | Something *_cacheObjectLoad<Bu::Uuid, Something>( Bu::CacheObject<Bu::Uuid, Something>::Initializer &initObj, const Bu::Uuid &rKey, Bu::Stream &s ) | ||
149 | { | ||
150 | Bu::Archive ar( s, Bu::Archive::load ); | ||
151 | uint8_t uType; | ||
152 | ar >> uType; | ||
153 | switch( uType ) | ||
154 | { | ||
155 | case 1: | ||
156 | { | ||
157 | SubSomethingA *ret = initObj(new SubSomethingA()); | ||
158 | ar >> *ret; | ||
159 | return ret; | ||
160 | } | ||
161 | break; | ||
162 | |||
163 | case 2: | ||
164 | { | ||
165 | SubSomethingB *ret = initObj(new SubSomethingB()); | ||
166 | ar >> *ret; | ||
167 | return ret; | ||
168 | } | ||
169 | break; | ||
170 | |||
171 | default: | ||
172 | throw Bu::ExceptionBase("Flagrant error! Invalid type!"); | ||
173 | } | ||
174 | |||
175 | return NULL; | ||
176 | } | ||
177 | } | ||
178 | |||
179 | typedef Bu::CachePtr<Bu::Uuid, Something> SomethingPtr; | ||
180 | typedef Bu::CachePtr<Bu::Uuid, SubSomethingA, Something> SomethingAPtr; | ||
181 | typedef Bu::CachePtr<Bu::Uuid, SubSomethingB, Something> SomethingBPtr; | ||
182 | typedef Bu::MyriadCache<Bu::Uuid, Something> SomethingCache; | ||
183 | |||
184 | int main( int, char *[] ) | ||
185 | { | ||
186 | Bu::File fStore("test.myr", Bu::File::Create|Bu::File::ReadWrite); | ||
187 | SomethingCache c( fStore ); | ||
188 | |||
189 | SomethingPtr ptr; | ||
190 | if( time(NULL)%2 ) | ||
191 | ptr = c.insert( new SubSomethingA("Hello", 55) ).cast<Something>(); | ||
192 | else | ||
193 | ptr = c.insert( new SubSomethingB("Goodbye", "Things") ).cast<Something>(); | ||
194 | |||
195 | Bu::println("Something[%1]: %2"). | ||
196 | arg( ptr.getKey() ). | ||
197 | arg( ptr->getName() ); | ||
198 | |||
199 | SomethingCache::KeyList lKeys = c.getKeys(); | ||
200 | Bu::println("Count: %1").arg( lKeys.getSize() ); | ||
201 | for( SomethingCache::KeyList::iterator i = lKeys.begin(); i; i++ ) | ||
202 | { | ||
203 | Bu::println(" - %1: '%2'").arg( *i ).arg( c.get( *i )->toString() ); | ||
204 | } | ||
205 | Bu::println("Count: %1").arg( c.getSize() ); | ||
206 | |||
207 | SomethingPtr p2 = c.get( ptr.getKey() ); | ||
208 | Bu::println("%1 == %2").arg( p2->getName() ).arg( ptr->getName() ); | ||
209 | SomethingPtr p3 = ptr.cast<Something>(); | ||
210 | Bu::println("%1: %2").arg( p3.getKey() ).arg( p3->getName() ); | ||
211 | |||
212 | return 0; | ||
213 | } | ||
214 | |||
215 | /* | ||
216 | int main( int argc, char *argv[] ) | ||
217 | { | ||
218 | Bu::File fStore("test.myr", Bu::File::Create|Bu::File::ReadWrite); | ||
219 | SomethingCache c( fStore ); | ||
220 | |||
221 | for( int j = 1; j < argc; j++ ) | ||
222 | { | ||
223 | SomethingPtr ptr = c.insert( new Something(argv[j]) ); | ||
224 | |||
225 | Bu::println("Something[%1]: %2"). | ||
226 | arg( ptr.getKey() ). | ||
227 | arg( ptr->getName() ); | ||
228 | } | ||
229 | |||
230 | SomethingCache::KeyList lKeys = c.getKeys(); | ||
231 | Bu::println("Count: %1").arg( lKeys.getSize() ); | ||
232 | int j = 0; | ||
233 | for( SomethingCache::KeyList::iterator i = lKeys.begin(); i; i++ ) | ||
234 | { | ||
235 | Bu::println(" - %1: '%2'").arg( *i ).arg( c.get( *i )->getName() ); | ||
236 | if( ((j++)%2) ) | ||
237 | c.erase( *i ); | ||
238 | } | ||
239 | Bu::println("Count: %1").arg( c.getSize() ); | ||
240 | |||
241 | c._debug(); | ||
242 | |||
243 | SomethingPtr p2; | ||
244 | SomethingPtr p1( c.get( lKeys.first() ) ); | ||
245 | |||
246 | c._debug(); | ||
247 | |||
248 | { | ||
249 | SomethingPtr p2( p1 ); | ||
250 | c._debug(); | ||
251 | } | ||
252 | |||
253 | c._debug(); | ||
254 | |||
255 | p2 = p1; | ||
256 | |||
257 | c._debug(); | ||
258 | |||
259 | p1.unbind(); | ||
260 | |||
261 | c._debug(); | ||
262 | |||
263 | Bu::println("Name: %1").arg( p1->getName() ); | ||
264 | |||
265 | p1.unbind(); | ||
266 | p1.lock(); | ||
267 | p1.unlock(); | ||
268 | |||
269 | c._debug(); | ||
270 | |||
271 | SomethingPtr p3 = c.getLazy( lKeys.first() ); | ||
272 | |||
273 | c._debug(); | ||
274 | |||
275 | { | ||
276 | SomethingPtr::Locker l( p3 ); | ||
277 | |||
278 | Bu::println("Name again: %1").arg( p3->getName() ); | ||
279 | |||
280 | p3->setName( p3->getName() + " - again" ); | ||
281 | } | ||
282 | |||
283 | c.sync(); | ||
284 | |||
285 | c._debug(); | ||
286 | |||
287 | return 0; | ||
288 | } | ||
289 | */ | ||
diff --git a/src/tests/cachedel.cpp b/src/tests/cachedel.cpp deleted file mode 100644 index 817757c..0000000 --- a/src/tests/cachedel.cpp +++ /dev/null | |||
@@ -1,288 +0,0 @@ | |||
1 | #include "bu/myriadcache.h" | ||
2 | #include "bu/uuid.h" | ||
3 | #include "bu/string.h" | ||
4 | #include "bu/sio.h" | ||
5 | #include "bu/membuf.h" | ||
6 | |||
7 | class Something : public Bu::CacheObject<Bu::Uuid, Something> | ||
8 | { | ||
9 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, Something &s ); | ||
10 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const Something &s ); | ||
11 | public: | ||
12 | Something() | ||
13 | { | ||
14 | } | ||
15 | |||
16 | Something( const Bu::String &sName ) : | ||
17 | uId( Bu::Uuid::generate() ), | ||
18 | sName( sName ) | ||
19 | { | ||
20 | } | ||
21 | |||
22 | virtual ~Something() | ||
23 | { | ||
24 | } | ||
25 | |||
26 | virtual Bu::Uuid getKey() const | ||
27 | { | ||
28 | return uId; | ||
29 | } | ||
30 | |||
31 | Bu::String getName() const | ||
32 | { | ||
33 | return sName; | ||
34 | } | ||
35 | |||
36 | void setName( const Bu::String &sNewName ) | ||
37 | { | ||
38 | sName = sNewName; | ||
39 | changed(); | ||
40 | } | ||
41 | |||
42 | virtual Bu::String toString() const=0; | ||
43 | |||
44 | private: | ||
45 | Bu::Uuid uId; | ||
46 | Bu::String sName; | ||
47 | }; | ||
48 | |||
49 | class SubSomethingA : public Something | ||
50 | { | ||
51 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingA &s ); | ||
52 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingA &s ); | ||
53 | public: | ||
54 | SubSomethingA() | ||
55 | { | ||
56 | } | ||
57 | |||
58 | SubSomethingA( const Bu::String &sName, int iNumber ) : | ||
59 | Something( sName ), | ||
60 | iNumber( iNumber ) | ||
61 | { | ||
62 | } | ||
63 | |||
64 | virtual Bu::String toString() const | ||
65 | { | ||
66 | return Bu::String("[typeA] %1 (%2)").arg( getName() ).arg( iNumber ); | ||
67 | } | ||
68 | |||
69 | private: | ||
70 | int iNumber; | ||
71 | }; | ||
72 | |||
73 | class SubSomethingB : public Something | ||
74 | { | ||
75 | friend Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingB &s ); | ||
76 | friend Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingB &s ); | ||
77 | public: | ||
78 | SubSomethingB() | ||
79 | { | ||
80 | } | ||
81 | |||
82 | SubSomethingB( const Bu::String &sName, const Bu::String &sString ) : | ||
83 | Something( sName ), | ||
84 | sString( sString ) | ||
85 | { | ||
86 | } | ||
87 | |||
88 | virtual Bu::String toString() const | ||
89 | { | ||
90 | return Bu::String("[typeB] %1 (%2)").arg( getName() ).arg( sString ); | ||
91 | } | ||
92 | |||
93 | private: | ||
94 | Bu::String sString; | ||
95 | }; | ||
96 | |||
97 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, Something &s ) | ||
98 | { | ||
99 | return ar >> s.uId >> s.sName; | ||
100 | } | ||
101 | |||
102 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const Something &s ) | ||
103 | { | ||
104 | return ar << s.uId << s.sName; | ||
105 | } | ||
106 | |||
107 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingA &s ) | ||
108 | { | ||
109 | return ar >> (Something &)s >> s.iNumber; | ||
110 | } | ||
111 | |||
112 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingA &s ) | ||
113 | { | ||
114 | return ar << (Something &)s << s.iNumber; | ||
115 | } | ||
116 | |||
117 | Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, SubSomethingB &s ) | ||
118 | { | ||
119 | return ar >> (Something &)s >> s.sString; | ||
120 | } | ||
121 | |||
122 | Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const SubSomethingB &s ) | ||
123 | { | ||
124 | return ar << (Something &)s << s.sString; | ||
125 | } | ||
126 | |||
127 | namespace Bu | ||
128 | { | ||
129 | template<> | ||
130 | void _cacheObjectSave<const Something>( Bu::Stream &s, const Something *pObject ) | ||
131 | { | ||
132 | Bu::Archive ar( s, Bu::Archive::save ); | ||
133 | if( typeid(*pObject) == typeid(SubSomethingA) ) | ||
134 | { | ||
135 | ar << (uint8_t)1 << (SubSomethingA &)*pObject; | ||
136 | } | ||
137 | else if( typeid(*pObject) == typeid(SubSomethingB) ) | ||
138 | { | ||
139 | ar << (uint8_t)2 << (SubSomethingB &)*pObject; | ||
140 | } | ||
141 | else | ||
142 | { | ||
143 | Bu::println("Not a recognized type!"); | ||
144 | throw Bu::ExceptionBase("Not recognized type!"); | ||
145 | } | ||
146 | } | ||
147 | |||
148 | template<> | ||
149 | Something *_cacheObjectLoad<Bu::Uuid, Something>( Bu::CacheObject<Bu::Uuid, Something>::Initializer &initObj, const Bu::Uuid &rKey, Bu::Stream &s ) | ||
150 | { | ||
151 | Bu::Archive ar( s, Bu::Archive::load ); | ||
152 | uint8_t uType; | ||
153 | ar >> uType; | ||
154 | switch( uType ) | ||
155 | { | ||
156 | case 1: | ||
157 | { | ||
158 | SubSomethingA *ret = initObj(new SubSomethingA()); | ||
159 | ar >> *ret; | ||
160 | return ret; | ||
161 | } | ||
162 | break; | ||
163 | |||
164 | case 2: | ||
165 | { | ||
166 | SubSomethingB *ret = initObj(new SubSomethingB()); | ||
167 | ar >> *ret; | ||
168 | return ret; | ||
169 | } | ||
170 | break; | ||
171 | |||
172 | default: | ||
173 | throw Bu::ExceptionBase("Flagrant error! Invalid type!"); | ||
174 | } | ||
175 | |||
176 | return NULL; | ||
177 | } | ||
178 | } | ||
179 | |||
180 | typedef Bu::CachePtr<Bu::Uuid, Something> SomethingPtr; | ||
181 | typedef Bu::CachePtr<Bu::Uuid, SubSomethingA, Something> SomethingAPtr; | ||
182 | typedef Bu::CachePtr<Bu::Uuid, SubSomethingB, Something> SomethingBPtr; | ||
183 | typedef Bu::MyriadCache<Bu::Uuid, Something> SomethingCache; | ||
184 | |||
185 | int main( int, char *[] ) | ||
186 | { | ||
187 | Bu::MemBuf mbStore; | ||
188 | SomethingCache c( mbStore ); | ||
189 | |||
190 | SomethingPtr ptr; | ||
191 | if( time(NULL)%2 ) | ||
192 | ptr = c.insert( new SubSomethingA("Hello", 55) ).cast<Something>(); | ||
193 | else | ||
194 | ptr = c.insert( new SubSomethingB("Goodbye", "Things") ).cast<Something>(); | ||
195 | |||
196 | Bu::Uuid id = ptr.getKey(); | ||
197 | Bu::println("Something[%1]: %2"). | ||
198 | arg( ptr.getKey() ). | ||
199 | arg( ptr->getName() ); | ||
200 | |||
201 | Bu::println("has %1: %2").arg( id ).arg( c.has( id ) ); | ||
202 | c.erase( ptr.getKey() ); | ||
203 | Bu::println("has %1: %2").arg( id ).arg( c.has( id ) ); | ||
204 | SomethingPtr b = ptr; | ||
205 | |||
206 | SomethingPtr p2 = c.insert( new SubSomethingA("new test", 123) ).cast<Something>(); | ||
207 | id = p2.getKey(); | ||
208 | p2.unbind(); | ||
209 | c.erase( id ); | ||
210 | |||
211 | return 0; | ||
212 | } | ||
213 | |||
214 | /* | ||
215 | int main( int argc, char *argv[] ) | ||
216 | { | ||
217 | Bu::File fStore("test.myr", Bu::File::Create|Bu::File::ReadWrite); | ||
218 | SomethingCache c( fStore ); | ||
219 | |||
220 | for( int j = 1; j < argc; j++ ) | ||
221 | { | ||
222 | SomethingPtr ptr = c.insert( new Something(argv[j]) ); | ||
223 | |||
224 | Bu::println("Something[%1]: %2"). | ||
225 | arg( ptr.getKey() ). | ||
226 | arg( ptr->getName() ); | ||
227 | } | ||
228 | |||
229 | SomethingCache::KeyList lKeys = c.getKeys(); | ||
230 | Bu::println("Count: %1").arg( lKeys.getSize() ); | ||
231 | int j = 0; | ||
232 | for( SomethingCache::KeyList::iterator i = lKeys.begin(); i; i++ ) | ||
233 | { | ||
234 | Bu::println(" - %1: '%2'").arg( *i ).arg( c.get( *i )->getName() ); | ||
235 | if( ((j++)%2) ) | ||
236 | c.erase( *i ); | ||
237 | } | ||
238 | Bu::println("Count: %1").arg( c.getSize() ); | ||
239 | |||
240 | c._debug(); | ||
241 | |||
242 | SomethingPtr p2; | ||
243 | SomethingPtr p1( c.get( lKeys.first() ) ); | ||
244 | |||
245 | c._debug(); | ||
246 | |||
247 | { | ||
248 | SomethingPtr p2( p1 ); | ||
249 | c._debug(); | ||
250 | } | ||
251 | |||
252 | c._debug(); | ||
253 | |||
254 | p2 = p1; | ||
255 | |||
256 | c._debug(); | ||
257 | |||
258 | p1.unbind(); | ||
259 | |||
260 | c._debug(); | ||
261 | |||
262 | Bu::println("Name: %1").arg( p1->getName() ); | ||
263 | |||
264 | p1.unbind(); | ||
265 | p1.lock(); | ||
266 | p1.unlock(); | ||
267 | |||
268 | c._debug(); | ||
269 | |||
270 | SomethingPtr p3 = c.getLazy( lKeys.first() ); | ||
271 | |||
272 | c._debug(); | ||
273 | |||
274 | { | ||
275 | SomethingPtr::Locker l( p3 ); | ||
276 | |||
277 | Bu::println("Name again: %1").arg( p3->getName() ); | ||
278 | |||
279 | p3->setName( p3->getName() + " - again" ); | ||
280 | } | ||
281 | |||
282 | c.sync(); | ||
283 | |||
284 | c._debug(); | ||
285 | |||
286 | return 0; | ||
287 | } | ||
288 | */ | ||
diff --git a/src/tests/mfstest.cpp b/src/tests/mfstest.cpp deleted file mode 100644 index 813ef8e..0000000 --- a/src/tests/mfstest.cpp +++ /dev/null | |||
@@ -1,88 +0,0 @@ | |||
1 | #include <bu/file.h> | ||
2 | #include <bu/myriadfs.h> | ||
3 | #include <bu/myriadstream.h> | ||
4 | #include <bu/sio.h> | ||
5 | |||
6 | class Obstore | ||
7 | { | ||
8 | public: | ||
9 | Obstore() : | ||
10 | fStore("test.mfs", Bu::File::WriteNew|Bu::File::Read ), | ||
11 | fsOb( fStore, 1024 ) | ||
12 | { | ||
13 | } | ||
14 | |||
15 | virtual ~Obstore() | ||
16 | { | ||
17 | } | ||
18 | |||
19 | Bu::String getObject( const Bu::String &sPath ) | ||
20 | { | ||
21 | try | ||
22 | { | ||
23 | Bu::MyriadStream s = fsOb.open( | ||
24 | sPath, | ||
25 | Bu::MyriadFs::Read | ||
26 | ); | ||
27 | return s.readAll(); | ||
28 | } | ||
29 | catch( Bu::ExceptionBase &e ) | ||
30 | { | ||
31 | Bu::println("Exception opening file: %1").arg( e.what() ); | ||
32 | return Bu::String(); | ||
33 | } | ||
34 | } | ||
35 | |||
36 | void storeObject( const Bu::String &sPath, const Bu::String &sData ) | ||
37 | { | ||
38 | for( Bu::String::const_iterator i = sPath.begin()+1; i; i++ ) | ||
39 | { | ||
40 | if( *i == '/' ) | ||
41 | { | ||
42 | Bu::String sChunk( sPath.begin(), i ); | ||
43 | fsOb.mkDir( sChunk, 0664 ); | ||
44 | } | ||
45 | } | ||
46 | try | ||
47 | { | ||
48 | Bu::MyriadStream s = fsOb.open( | ||
49 | sPath, | ||
50 | Bu::MyriadFs::Write|Bu::MyriadFs::Create|Bu::MyriadFs::Truncate | ||
51 | ); | ||
52 | s.write( sData ); | ||
53 | } | ||
54 | catch(Bu::ExceptionBase &e ) | ||
55 | { | ||
56 | Bu::println("Exception opening file: %1").arg( e.what() ); | ||
57 | } | ||
58 | } | ||
59 | |||
60 | Bu::File fStore; | ||
61 | Bu::MyriadFs fsOb; | ||
62 | }; | ||
63 | |||
64 | int main( int, char *[] ) | ||
65 | { | ||
66 | Obstore os; | ||
67 | |||
68 | os.storeObject("/killTeamState.json", "This is a json file."); | ||
69 | os.storeObject("/appCredentials/local", "App credentials"); | ||
70 | os.storeObject("/appCredentials/inckybot", "App credentials"); | ||
71 | os.storeObject("/appCredentials/playwith", "App credentials"); | ||
72 | os.storeObject("/restreamIo/users", "User data"); | ||
73 | os.storeObject("/youTube/users", "User data"); | ||
74 | os.storeObject("/topTippers.json", "{\"people\": [\"sam\", \"joe\", \"bob\"]}"); | ||
75 | os.storeObject("/wh40kDecks.json", ""); | ||
76 | |||
77 | Bu::MyriadStream s = os.fsOb.open( | ||
78 | "/appCredentials/inckybot", | ||
79 | Bu::MyriadFs::Write|Bu::MyriadFs::Create|Bu::MyriadFs::Truncate | ||
80 | ); | ||
81 | s.write("Some new credentials, this is a bigger bit of data."); | ||
82 | |||
83 | os.storeObject("/wh40kDecks.json", "{ \"op\": \"replaceDecks\", \"decks\": { \"lev\": { \"name\": \"Leviathan\", \"primary\": { \"pt\": {\"name\": \"Priority Targets\"}, \"vg\": {\"name\": \"Vital Ground\"}, \"se\": {\"name\": \"Scorched Earth\"}, \"pf\": {\"name\": \"Purge the Foe\"}, \"th\": {\"name\": \"Take and Hold\"}, \"sd\": {\"name\": \"Supply Drop\"}, \"tr\": {\"name\": \"The Ritual\"}, \"ds\": {\"name\": \"Deploy Servo-Skulls\"}, \"sp\": {\"name\": \"Sites of Power\"}, }, \"secondary\": { \"tt\": {\"name\": \"A Tempting Target\"}, \"ad\": {\"name\": \"Area Denial\"}, \"as\": {\"name\": \"Assassination\"}, \"be\": {\"name\": \"Behind Enemy Lines\"}, \"bd\": {\"name\": \"Bring It Down\"}, \"ce\": {\"name\": \"Capture Enemy Outpost\"}, \"cl\": {\"name\": \"Cleanse\"}, \"ds\": {\"name\": \"Defend Stronghold\"}, \"dt\": {\"name\": \"Deploy Teleport Homer\"}, \"ef\": {\"name\": \"Engage On All Fronts\"}, \"eb\": {\"name\": \"Extend Battle Lines\"}, \"is\": {\"name\": \"Investigate Signals\"}, \"np\": {\"name\": \"No Prisoners\"}, \"of\": {\"name\": \"Overwhelming Force\"}, \"sl\": {\"name\": \"Secure No Man’s Land\"}, \"sh\": {\"name\": \"Storm Hostile Objective\"}, }, \"gambit\": { \"dt\": {\"name\": \"Delaying Tactics\"}, \"ee\": {\"name\": \"Emergency Evacuation\"}, \"oc\": {\"name\": \"Orbital Strike Coordinates\"}, \"pp\": {\"name\": \"Proceed As Planned\"}, }, \"missionRule\": { \"cr\": {\"name\": \"Chilling Rain\"}, \"sc\": {\"name\": \"Sweep and Clear\"}, \"hs\": {\"name\": \"Hidden Supplies\"}, \"mi\": {\"name\": \"Minefields\"}, \"to\": {\"name\": \"Targets of Opportunity\"}, \"sf\": {\"name\": \"Scrambler Fields\"}, \"dr\": {\"name\": \"Delayed Reserves\"}, \"cb\": {\"name\": \"Chosen Battlefield\"}, \"mb\": {\"name\": \"Maelstrom of Battle\"}, \"sl\": {\"name\": \"Supply Lines\"}, \"si\": {\"name\": \"Secret Intel\"}, \"vs\": {\"name\": \"Vox Static\"}, }, }, } }"); | ||
84 | os.storeObject("/wh40kState.json", "{\"cards\": \"hello\"}"); | ||
85 | |||
86 | return 0; | ||
87 | } | ||
88 | |||
diff --git a/src/tests/myriadfs.cpp b/src/tests/myriadfs.cpp deleted file mode 100644 index 1266e4b..0000000 --- a/src/tests/myriadfs.cpp +++ /dev/null | |||
@@ -1,62 +0,0 @@ | |||
1 | #include "bu/file.h" | ||
2 | #include "bu/membuf.h" | ||
3 | #include "bu/myriadfs.h" | ||
4 | #include "bu/myriadstream.h" | ||
5 | #include "bu/sio.h" | ||
6 | |||
7 | using namespace Bu; | ||
8 | |||
9 | int main() | ||
10 | { | ||
11 | // Bu::MemBuf mb; | ||
12 | Bu::File mb("store.myr", File::Read|File::Write|File::Create ); | ||
13 | Bu::MyriadFs mfs( mb, 512 ); | ||
14 | |||
15 | sio << "Creating dirs..." << sio.nl; | ||
16 | mfs.create("/etc", Bu::MyriadFs::typeDir|0755 ); | ||
17 | mfs.create("/dev", Bu::MyriadFs::typeDir|0755 ); | ||
18 | mfs.create("/usr", Bu::MyriadFs::typeDir|0755 ); | ||
19 | |||
20 | mfs.create("/dev/null", Bu::MyriadFs::typeChrDev|0666, 1, 3 ); | ||
21 | mfs.create("/dev/zero", Bu::MyriadFs::typeChrDev|0666, 1, 5 ); | ||
22 | mfs.create("/dev/sda", Bu::MyriadFs::typeBlkDev|0660, 8, 0 ); | ||
23 | |||
24 | sio << "Creating files..." << sio.nl; | ||
25 | { | ||
26 | Bu::MyriadStream ms = mfs.open("/hello", Bu::MyriadFs::Read ); | ||
27 | ms.write("world!"); | ||
28 | } | ||
29 | { | ||
30 | Bu::MyriadStream ms = mfs.open("/etc/hello", Bu::MyriadFs::Read ); | ||
31 | ms.write("world, again!"); | ||
32 | } | ||
33 | { | ||
34 | Bu::MyriadStream ms = mfs.open("/etc/trunc", Bu::MyriadFs::Write ); | ||
35 | ms.write("[longer text shouldn't be seen]"); | ||
36 | } | ||
37 | { | ||
38 | Bu::MyriadStream ms = mfs.open("/etc/trunc", Bu::MyriadFs::Write|Bu::MyriadFs::Create|Bu::MyriadFs::Truncate ); | ||
39 | ms.write("[short text]"); | ||
40 | } | ||
41 | |||
42 | sio << "Reading files..." << sio.nl; | ||
43 | { | ||
44 | Bu::MyriadStream ms = mfs.open("/hello", Bu::MyriadFs::Read ); | ||
45 | char buf[512]; | ||
46 | buf[ms.read( buf, 512 )] = '\0'; | ||
47 | sio << "read: '" << buf << "'" << sio.nl; | ||
48 | } | ||
49 | { | ||
50 | Bu::MyriadStream ms = mfs.open("/etc/hello", Bu::MyriadFs::Read ); | ||
51 | char buf[512]; | ||
52 | buf[ms.read( buf, 512 )] = '\0'; | ||
53 | sio << "read: '" << buf << "'" << sio.nl; | ||
54 | } | ||
55 | { | ||
56 | Bu::MyriadStream ms = mfs.open("/etc/trunc", Bu::MyriadFs::Read ); | ||
57 | char buf[512]; | ||
58 | buf[ms.read( buf, 512 )] = '\0'; | ||
59 | sio << "read: '" << buf << "'" << sio.nl; | ||
60 | } | ||
61 | } | ||
62 | |||