Context Navigation

source: cpp/frams/util/extvalue.cpp @ 547

Last change on this file since 547 was 522, checked in by Maciej Komosinski, 9 years ago
Code formatting
Property svn:eol-style set to `native`
File size: 31.0 KB

Line
1	// This file is a part of Framsticks SDK. http://www.framsticks.com/
2	// Copyright (C) 1999-2015 Maciej Komosinski and Szymon Ulatowski.
3	// See LICENSE.txt for details.
4
5	#include "extvalue.h"
6	#include <frams/param/param.h>
7	#include "sstringutils.h"
8	#include <ctype.h>
9	#include <frams/vm/classes/collectionobj.h>
10	#include <frams/vm/classes/3dobject.h>
11	#include <frams/vm/classes/genoobj.h>
12	#include <common/nonstd_math.h>
13	#include <common/Convert.h>
14	#include <climits>
15	#include <errno.h>
16
17	#ifndef NO_BARRIER
18	#include <frams/simul/barrier.h>
19	#include <common/threads.h>
20	#endif
21
22	#ifdef MULTITHREADED
23	#include <pthread.h>
24	//this lock only protects against ref.counter corruption caused by concurrent reads.
25	//read/write conficts and nonatomicity are handled by BarrierObject (at least in theory ;-))
26	static pthread_mutex_t extobject_ref_lock = PTHREAD_MUTEX_INITIALIZER;
27	#define REF_LOCK pthread_mutex_lock(&extobject_ref_lock)
28	#define REF_UNLOCK pthread_mutex_unlock(&extobject_ref_lock)
29	#else
30	#define REF_LOCK
31	#define REF_UNLOCK
32	#endif
33
34	void ExtObject::incref() const
35	{
36	if (subtype & 1)
37	{
38	REF_LOCK;
39	dbobject->refcount++;
40	REF_UNLOCK;
41	}
42	}
43
44	void ExtObject::decref() const
45	{
46	if (subtype & 1)
47	{
48	REF_LOCK;
49	bool destroy = !--dbobject->refcount;
50	REF_UNLOCK;
51	//another thread can now access the object while we are deleting it
52	//but this is not a bug since we only guarantee read/read safety
53	if (destroy) delete dbobject;
54	}
55	}
56
57	bool ExtObject::operator==(const ExtObject& src) const
58	{
59	if (object != src.object) return false;
60	const char* n1 = interfaceName();
61	const char* n2 = src.interfaceName();
62	return (n1 == n2) \|\| (strcmp(n1, n2) == 0);
63	}
64
65	bool ExtObject::makeUnique()
66	{
67	if (!(subtype & 1)) return false;
68	if (dbobject->refcount == 1) return false;
69	VectorObject* v = VectorObject::fromObject(*this, false);
70	if (v)
71	{
72	VectorObject* n = new VectorObject;
73	n->data.setSize(n->data.size());
74	for (int i = 0; i < v->data.size(); i++)
75	{
76	ExtValue x = (ExtValue)v->data(i);
77	n->data.set(i, x ? new ExtValue(*x) : NULL);
78	}
79	operator=(n->makeObject());
80	return true;
81	}
82	return false;
83	}
84
85	void* ExtObject::getTarget(const char* classname, bool through_barrier, bool warn) const
86	{
87	if (!strcmp(interfaceName(), classname))
88	return getTarget();
89	#ifndef NO_BARRIER
90	if (through_barrier)
91	{
92	BarrierObject bo = BarrierObject::fromObject(this);
93	if (bo)
94	return bo->getSourceObject().getTarget(classname, true, warn);
95	}
96	#endif
97
98	if (warn)
99	{
100	logPrintf("ExtValue", "getObjectTarget", LOG_WARN, "%s object expected, %s found", classname, interfaceName());
101	}
102
103	return NULL;
104	}
105
106	bool ExtObject::callDelegate(const char* delegate, ExtValue args, ExtValue ret)
107	{
108	Param tmp;
109	ParamInterface *pi = getParamInterface(tmp);
110	if (pi)
111	{
112	int f = pi->findId(delegate);
113	if (f >= 0)
114	{
115	pi->call(f, args, ret);
116	return true;
117	}
118	}
119	logPrintf("Genotype", "get", LOG_ERROR, "Could not call delegate '%s.%s'", pi ? pi->getName() : "NULL", delegate);
120	return false;
121	}
122
123	SString ExtObject::toString() const
124	{
125	if (isEmpty()) return SString("null");
126	Param tmp_param;
127	ParamInterface *p = getParamInterface(tmp_param);
128	int tostr = p->findId("toString");
129	if (tostr >= 0)
130	{
131	return SString(p->getString(tostr));
132	}
133	else
134	{
135	SString tmp("<");
136	tmp += p->getName();
137	tmp += SString::sprintf(" object at %p>", object ? object : paraminterface);
138	return tmp;
139	}
140	}
141
142	THREAD_LOCAL_DEF(ExtObject::Serialization, ExtObject_serialization);
143
144	void ExtObject::Serialization::begin()
145	{
146	if (level == 0)
147	refs.clear();
148	level++;
149	}
150
151	int ExtObject::Serialization::add(const ExtObject &o)
152	{
153	if (o.isEmpty()) return -1;
154	for (int i = 0; i < (int)refs.size(); i++)
155	{
156	ExtObject& r = refs[i];
157	if (r == o) return i;
158	}
159	refs.push_back(o);
160	return -1;
161	}
162
163	void ExtObject::Serialization::replace(const ExtObject& o, const ExtObject& other)
164	{
165	if (o.isEmpty()) return;
166	for (int i = 0; i < (int)refs.size(); i++)
167	{
168	ExtObject& r = refs[i];
169	if (r == o)
170	{
171	r = other;
172	return;
173	}
174	}
175	}
176
177	void ExtObject::Serialization::remove(const ExtObject& o)
178	{
179	if (o.isEmpty()) return;
180	for (int i = 0; i < (int)refs.size(); i++)
181	{
182	ExtObject& r = refs[i];
183	if (o == r) refs.erase(refs.begin() + i);
184	}
185	}
186
187	const ExtObject* ExtObject::Serialization::get(int ref)
188	{
189	if (ref < 0) return NULL;
190	if (ref >= (int)refs.size()) return NULL;
191	return &refs[ref];
192	}
193
194	void ExtObject::Serialization::end()
195	{
196	level--;
197	if (level == 0)
198	refs.clear();
199	}
200
201	SString ExtObject::serialize_inner(SerializationFormat format) const
202	{
203	int ref = tlsGetRef(ExtObject_serialization).add(*this);
204	SString ret;
205
206	if (ref >= 0)
207	{
208	switch (format)
209	{
210	case NativeSerialization: return SString::sprintf("^%d", ref);
211	case JSONSerialization: return SString("null");
212	}
213	}
214
215	if (isEmpty()) return SString("null");
216	{
217	VectorObject vec = VectorObject::fromObject(this, false);
218	if (vec)
219	{
220	ret = vec->serialize(format); goto finally;
221	}
222	}
223	{
224	DictionaryObject dic = DictionaryObject::fromObject(this, false);
225	if (dic)
226	{
227	ret = dic->serialize(format); goto finally;
228	}
229	}
230	{
231	Param tmp_param;
232	ParamInterface *p = getParamInterface(tmp_param);
233	int m = p->findId("toVector");
234	if (m < 0)
235	m = p->findId("toDictionary");
236	if (m >= 0)
237	{
238	ExtObject o(p->getObject(m));
239	switch (format)
240	{
241	case NativeSerialization: ret = SString(interfaceName()) + o.serialize(format); break;
242	case JSONSerialization: ret = SString::sprintf("{\"class\":\"%s\",\"data\":%s}", interfaceName(), o.serialize(format).c_str()); break;
243	}
244	goto finally;
245	}
246	m = p->findId("toString");
247	if (m >= 0)
248	{
249	SString str = p->getString(m);
250	sstringQuote(str);
251	switch (format)
252	{
253	case NativeSerialization: ret = SString(interfaceName()) + "\"" + str + "\""; break;
254	case JSONSerialization: ret = SString::sprintf("{\"class\":\"%s\",\"data\":\"%s\"}", interfaceName(), str.c_str()); break;
255	}
256	goto finally;
257	}
258	}
259
260	tlsGetRef(ExtObject_serialization).remove(*this);//undo nonserializable reference
261	switch (format)
262	{
263	case NativeSerialization: return SString(interfaceName()) + SString::sprintf("<%p>", object ? object : paraminterface); break;
264	case JSONSerialization: return SString::sprintf("{\"class\":\"%s\"}", interfaceName()); break;
265	}
266
267	finally: // not 100% "finally", the case of nonserializable reference (directly above) returns directly without going through finally
268
269	switch (format)
270	{
271	case JSONSerialization:
272	tlsGetRef(ExtObject_serialization).remove(*this);//JSON only tracks recursion, does not track reuse
273	break;
274	case NativeSerialization:; //nop (just to avoid compiler warning)
275	}
276
277	return ret;
278	}
279
280	SString ExtObject::serialize(SerializationFormat format) const
281	{
282	tlsGetRef(ExtObject_serialization).begin();
283	SString ret = serialize_inner(format);
284	tlsGetRef(ExtObject_serialization).end();
285	return ret;
286	}
287
288	///////////////////////////////////////
289
290	SString ExtValue::typeDescription() const
291	{
292	switch (type)
293	{
294	case TInt: return SString("int");
295	case TDouble: return SString("float");
296	case TString: return SString("string");
297	case TUnknown: return SString("null");
298	case TInvalid: return SString("invalid");
299	case TObj: return getObject().isEmpty() ? SString("null") : SString(getObject().interfaceName());
300	}
301	return SString::empty();
302	}
303
304	SString ExtValue::typeAndValue() const
305	{
306	SString msg = typeDescription();
307	switch (type)
308	{
309	case TInt: case TDouble: case TString: case TObj:
310	msg += " '";
311	msg += getString();
312	msg += "'";
313	default:;
314	}
315	return msg;
316	}
317
318	void ExtValue::getObjectTarget(const char classname, bool warn) const
319	{
320	if (type != TObj)
321	{
322	if (warn)
323	{
324	SString tmp = getString();
325	if (tmp.len() > 30) tmp = tmp.substr(0, 30) + "...";
326	if (type == TString) tmp = SString("\"") + tmp + SString("\"");
327	logPrintf("ExtValue", "getObjectTarget", LOG_WARN, "%s object expected, %s found", classname, tmp.c_str());
328	}
329	return NULL;
330	}
331
332	return getObject().getTarget(classname, true, warn);
333	}
334
335	void ExtValue::set(const ExtValue& src)
336	{
337	switch (src.type)
338	{
339	case TString: sets(src.sdata()); break;
340	case TInt: seti(src.idata()); break;
341	case TDouble: setd(src.ddata()); break;
342	case TObj: seto(src.odata()); break;
343	default:type = src.type; break;
344	}
345	}
346
347	void ExtValue::setEmpty()
348	{
349	switch (type)
350	{
351	#ifdef EXTVALUEUNION
352	case TString: sdata().~SString(); break;
353	case TObj: odata().~ExtObject(); break;
354	#else
355	case TString: delete s; break;
356	case TObj: delete o; break;
357	#endif
358	default:;
359	}
360	type = TUnknown;
361	}
362
363	void ExtValue::setError(const SString& msg)
364	{
365	ErrorObject *err = new ErrorObject;
366	err->message = msg;
367	setObject(ErrorObject::makeDynamicObject(err));
368	}
369
370	static ExtValue::CompareResult longsign(paInt x)
371	{
372	if (x < 0) return ExtValue::ResultLower;
373	if (x > 0) return ExtValue::ResultHigher;
374	return ExtValue::ResultEqual;
375	}
376
377	static ExtValue::CompareResult compareNull(const ExtValue& v)
378	{
379	if (v.isNull()) return ExtValue::ResultEqualUnordered;
380	if ((v.getType() == TInt) && (v.getInt() == 0)) return ExtValue::ResultUnequal_RelaxedEqual;
381	return ExtValue::ResultUnequal_RelaxedUnequal; //comparing anything else with null is valid but null is neither higher nor lower than numbers or strings
382	}
383
384	static ExtValue::CompareResult compareInvalid(const ExtValue& v)
385	{
386	if (v.getType() == TInvalid) return ExtValue::ResultEqualUnordered;
387	if ((v.getType() == TInt) && (v.getInt() == 0)) return ExtValue::ResultUnequal_RelaxedEqual;
388	return ExtValue::ResultMismatch; //comparing anything else with invalid is invalid
389	}
390
391	static ExtValue::CompareResult compareFloat(double a, double b)
392	{
393	double t = a - b;
394	if (t < 0) return ExtValue::ResultLower;
395	else if (t > 0) return ExtValue::ResultHigher;
396	return ExtValue::ResultEqual;
397	}
398
399	static ExtValue::CompareResult compareString(const SString &a, const SString &b)
400	{
401	const char* s1 = a.c_str();
402	const char* s2 = b.c_str();
403	return longsign(strcmp(s1, s2));
404	}
405
406	ExtValue::CompareResult ExtValue::compare(const ExtValue& src) const
407	{
408	if (isNull())
409	return compareNull(src);
410	else if (src.isNull())
411	return compareNull(*this);
412	if (getType() == TInvalid)
413	return compareInvalid(src);
414	else if (src.getType() == TInvalid)
415	return compareInvalid(*this);
416	switch (type)
417	{
418
419	case TInt:
420
421	if (src.getType() == TInt)
422	{
423	paInt t = src.getInt();
424	if (idata() > 0)
425	{
426	if (t > 0) return longsign(idata() - t); else return ResultHigher;
427	}
428	else
429	{
430	if (t <= 0) return longsign(idata() - t); else return ResultLower;
431	}
432	}
433	else if (src.getType() == TDouble)
434	return compareFloat((double)idata(), src.getDouble());
435	else
436	return ResultMismatch;//comparing numbers with other things is invalid
437	break;
438
439	case TDouble:
440	if ((src.getType() == TDouble) \|\| (src.getType() == TInt))
441	return compareFloat(getDouble(), src.getDouble());
442	else
443	return ResultMismatch;
444	break;
445
446	case TString:
447	if (src.getType() == TString)
448	return compareString(sdata(), src.getString());
449	else
450	return ResultMismatch;
451	break;
452
453	case TObj:
454	{
455	if (src.type == TObj)
456	return odata() == src.odata() ? ResultEqualUnordered : ResultUnequal_RelaxedUnequal;
457	if ((src.type == TInt) && (src.getInt() == 0))
458	return ResultMismatch_RelaxedUnequal;
459	return ResultMismatch;
460	}
461	default:;
462	}
463	return ResultMismatch;
464	}
465
466	const char* ExtValue::cmp_op_names[] = { "==", "!=", ">=", "<=", ">", "<", "~=", "!~", NULL };
467
468	int ExtValue::interpretCompare(CmpOperator op, CompareResult result, CmpContext *context)
469	{
470	CompareResult error_threshold = ResultUnequal_RelaxedEqual;//error when ResultUnequal_RelaxedEqual or higher (not comparable)
471	int ret = 0;
472	switch (op)
473	{
474	case CmpEQ: ret = (result == ResultEqual) \|\| (result == ResultEqualUnordered); error_threshold = ResultMismatch_RelaxedUnequal; break;
475	case CmpNE: ret = !((result == ResultEqual) \|\| (result == ResultEqualUnordered)); error_threshold = ResultMismatch_RelaxedUnequal; break;
476	case CmpGT: ret = (result == ResultHigher); error_threshold = ResultEqualUnordered; break;
477	case CmpGE: ret = (result == ResultEqual) \|\| (result == ResultHigher); error_threshold = ResultEqualUnordered; break;
478	case CmpLT: ret = (result == ResultLower); error_threshold = ResultEqualUnordered; break;
479	case CmpLE: ret = (result == ResultEqual) \|\| (result == ResultLower); error_threshold = ResultEqualUnordered; break;
480	case CmpREQ: ret = (result == ResultEqual) \|\| (result == ResultEqualUnordered) \|\| (result == ResultUnequal_RelaxedEqual); error_threshold = ResultMismatch; break;
481	case CmpRNE: ret = !((result == ResultEqual) \|\| (result == ResultEqualUnordered) \|\| (result == ResultUnequal_RelaxedEqual)); error_threshold = ResultMismatch; break;
482	default:;
483	}
484	if (result >= error_threshold)
485	{
486	SString msg = "Type mismatch while comparing";
487	if (context)
488	{
489	if (context->v1 && context->v2)
490	msg += SString::sprintf(": %s %s %s",
491	context->v1->typeAndValue().c_str(),
492	cmp_op_names[op - CmpFIRST],
493	context->v2->typeAndValue().c_str());
494	}
495	logPrintf("ExtValue", "interpretCompare", LOG_ERROR, "%s", msg.c_str());
496	ret = -1;
497	}
498	return ret;
499	}
500
501	int ExtValue::operator==(const ExtValue& src) const
502	{
503	if (type != src.type) return 0;
504	switch (type)
505	{
506	case TInt: return idata() == src.idata();
507	case TDouble: return ddata() == src.ddata();
508	case TString: return sdata() == src.sdata();
509	case TObj: return odata() == src.odata();
510	default:;
511	}
512	return 1;
513	}
514
515	void ExtValue::operator+=(const ExtValue& src)
516	{
517	// return = ok, break = fail
518	switch (type)
519	{
520	case TInt:
521	switch (src.getType())
522	{
523	case TDouble:
524	setDouble(double(getInt()) + src.getDouble());
525	return;
526	case TString:
527	break;
528	default:
529	idata() += src.getInt();
530	return;
531	}
532	break;
533	case TDouble:
534	switch (src.getType())
535	{
536	case TString:
537	break;
538	default:
539	ddata() += src.getDouble();
540	return;
541	}
542	break;
543	case TString: sdata() += src.getString(); return;
544	case TObj:
545	{
546	VectorObject *vec = VectorObject::fromObject(getObject(), false);
547	VectorObject *vec2 = VectorObject::fromObject(src.getObject(), false);
548	if (vec && vec2)
549	{
550	for (int i = 0; i < vec2->data.size(); i++)
551	{
552	ExtValue s = (ExtValue)vec2->data(i);
553	ExtValue d = s ? new ExtValue(s) : NULL;
554	vec->data += d;
555	}
556	return;
557	}
558	}
559	//NO break;
560	default:;
561	}
562	logPrintf("ExtValue", "add", LOG_ERROR, "Can't add %s to %s", src.typeAndValue().c_str(), typeAndValue().c_str());
563	}
564
565	void ExtValue::operator-=(const ExtValue& src)
566	{
567	// return = ok, break = fail
568	switch (type)
569	{
570	case TInt:
571	switch (src.getType())
572	{
573	case TInt:
574	idata() -= src.getInt();
575	return;
576	case TDouble:
577	setDouble(double(getInt()) - src.getDouble());
578	return;
579	default:;
580	}
581	break;
582	case TDouble:
583	switch (src.getType())
584	{
585	case TDouble:
586	case TInt:
587	ddata() -= src.getDouble();
588	return;
589	default:;
590	}
591	break;
592	default:;
593	}
594	logPrintf("ExtValue", "subtract", LOG_ERROR, "Can't subtract %s from %s", src.typeAndValue().c_str(), typeAndValue().c_str());
595	}
596
597	void ExtValue::operator*=(const ExtValue& src)
598	{
599	// return = ok, break = fail
600	switch (type)
601	{
602	case TInt:
603	switch (src.getType())
604	{
605	case TInt:
606	idata() *= src.getInt();
607	return;
608	case TDouble:
609	setDouble(double(getInt())*src.getDouble());
610	return;
611	default:;
612	}
613	break;
614	case TDouble:
615	switch (src.getType())
616	{
617	case TInt:
618	case TDouble:
619	ddata() *= src.getDouble();
620	return;
621	default:;
622	}
623	break;
624	case TString:
625	switch (src.getType())
626	{
627	case TInt: case TDouble:
628	{
629	SString t;
630	for (int n = src.getInt(); n > 0; n--)
631	t += getString();
632	setString(t);
633	return;
634	}
635	default:;
636	}
637	break;
638	case TObj:
639	{
640	VectorObject *vec = VectorObject::fromObject(getObject(), false);
641	if (vec)
642	{
643	int n = src.getInt();
644	int orig_size = vec->data.size();
645	if (n <= 0)
646	{
647	vec->clear(); return;
648	}
649	for (; n > 1; n--)
650	{
651	for (int i = 0; i < orig_size; i++)
652	{
653	ExtValue s = (ExtValue)vec->data(i);
654	ExtValue d = s ? new ExtValue(s) : NULL;
655	vec->data += d;
656	}
657	}
658	return;
659	}
660	}
661	//NO break;
662	default:;
663	}
664	logPrintf("ExtValue", "multiply", LOG_WARN, "Can't multiply %s by %s", typeAndValue().c_str(), src.typeAndValue().c_str());
665	}
666
667	/*#include "fpu_control.h"
668	#include <signal.h>
669
670	static int fpuexception;
671	void mathhandler(int sig)
672	{
673	printf("fpu exception!\n");
674	fpuexception=1;
675	signal(SIGFPE,SIG_IGN);
676	} */
677
678	void ExtValue::divInt(paInt a)
679	{
680	if (a)
681	idata() /= a;
682	else
683	{
684	logPrintf("ExtValue", "divide", LOG_ERROR, "Division by zero: %d/0", idata());
685	setInvalid();
686	}
687	}
688
689	void ExtValue::divDouble(double a)
690	{
691	if (a == 0.0)
692	{
693	logPrintf("ExtValue", "divide", LOG_ERROR, "Division by zero: %s/0.0", getString().c_str());
694	setInvalid();
695	}
696	else
697	{
698	fpExceptDisable();
699	double tmp = getDouble() / a;
700	if (!finite(tmp))
701	{
702	logPrintf("ExtValue", "divide", LOG_ERROR, "Overflow %s/%g", getString().c_str(), a); setInvalid();
703	}
704	else
705	setDouble(tmp);
706	// niby dobrze ale lepiej byloby to robic bardziej systematycznie a nie tylko w dzieleniu?
707	//if (isnan(ddata())) //http://www.digitalmars.com/d/archives/c++/Traping_divide_by_zero_5728.html
708	// { logPrintf("ExtValue","divide",LOG_ERROR,"not-a-number",(const char*)getString()); setInvalid(); }
709	fpExceptEnable();
710	}
711	}
712
713	void ExtValue::operator/=(const ExtValue& src)
714	{
715	switch (type)
716	{
717	case TInt:
718	switch (src.getType())
719	{
720	case TInt:
721	divInt(src.idata());
722	return;
723	case TDouble:
724	divDouble(src.ddata());
725	return;
726	default:;
727	}
728	break;
729
730	case TDouble:
731	switch (src.getType())
732	{
733	case TInt:
734	divDouble(src.getDouble());
735	return;
736	case TDouble:
737	divDouble(src.ddata());
738	return;
739	default:;
740	}
741	break;
742
743	default:;
744	}
745	logPrintf("ExtValue", "divide", LOG_ERROR, "Can't divide %s by %s", typeAndValue().c_str(), src.typeAndValue().c_str());
746	}
747
748	SString ExtValue::format(SString& fmt, const ExtValue **values, int count)
749	{
750	SString ret;
751	// "..........%.........%..........%........"
752	// ^_cur ^_next
753	// ^^^^^^^^^^___sub
754	//
755	// "..........%.........%..........%........"
756	// ^-cur ^-next
757	// ^^^^^^^^^^___sub
758	const char* begin = fmt.c_str(), end = begin + fmt.len(), curr = begin;
759	int type = 0;
760
761	class Args
762	{
763	const ExtValue **values;
764	int count;
765	int arg;
766	public:
767	Args(const ExtValue **v, int c) :values(v), count(c), arg(0) {}
768	bool finished() { return arg >= count; }
769	const ExtValue getNext() { const ExtValue ret = NULL; if ((arg < count) && values[arg]) ret = values[arg]; arg++; return ret; }
770	};
771	Args args(values, count);
772
773	while (curr < end)
774	{
775	const char* next = strchr(curr, '%');
776	if (!next) next = end; else if ((next == curr) && (curr > begin))
777	{
778	next = strchr(next + 1, '%'); if (!next) next = end;
779	}
780	type = 0;
781	if (curr > begin)
782	{
783	type = 0;
784	for (const char* t = curr; t < next; t++)
785	switch (*t)
786	{
787	case 'd': case 'x': case 'X': case 'u': case 'p': case 'c': type = 'd'; t = next; break;
788	case 'f': case 'g': case 'e': type = 'f'; t = next; break;
789	case 's': type = 's'; t = next; break;
790	case 't': case 'T': type = *t; t = next; break;
791	case '%': if (t > begin) { type = *t; t = next; } break;
792	}
793	}
794	if (curr > begin) curr--;
795	const ExtValue *a;
796	if (args.finished() && (type != 0) && (type != '%'))
797	{
798	ret += fmt.substr((int)(curr - begin));
799	break;
800	}
801	SString sub = fmt.substr((int)(curr - begin), (int)(next - curr));
802	switch (type)
803	{
804	case 'd': a = args.getNext(); ret += SString::sprintf(sub.c_str(), a ? a->getInt() : 0); break;
805	case 'f': a = args.getNext(); ret += SString::sprintf(sub.c_str(), a ? a->getDouble() : 0); break;
806	case 's': {a = args.getNext(); SString tmp; if (a) tmp = a->getString(); ret += SString::sprintf(sub.c_str(), tmp.c_str()); } break;
807	case 't': case 'T':
808	{
809	a = args.getNext();
810	time_t ti = a ? a->getInt() : 0;
811	struct tm tm = Convert::localtime(ti);
812	SString timtxt;
813	if (type == 'T')
814	timtxt = SString::sprintf("%04d-%02d-%02d %02d:%02d:%02d", 1900 + tm.tm_year, 1 + tm.tm_mon, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec);
815	else
816	timtxt = Convert::asctime(tm).c_str();
817	ret += timtxt;
818	ret += sub.substr(2);
819	}
820	break;
821	case '%': ret += '%'; ret += sub.substr(2); break;
822	case 0: ret += sub; break;
823	}
824	curr = next + 1;
825	}
826	return ret;
827	}
828
829
830	void ExtValue::operator%=(const ExtValue& src)
831	{
832	switch (type)
833	{
834	case TInt: idata() = idata() % src.getInt(); break;
835	case TDouble: ddata() = fmod(ddata(), src.getDouble()); break;
836
837	case TString:
838	{
839	VectorObject *vec = VectorObject::fromObject(src.getObject(), false);
840	if (vec)
841	sdata() = format(sdata(), (const ExtValue**)&vec->data.getref(0), vec->data.size());
842	else
843	{
844	const ExtValue *ptr = &src; sdata() = ExtValue::format(sdata(), &ptr, 1);
845	}
846	}
847	break;
848
849	case TObj: case TUnknown: case TInvalid:
850	logPrintf("ExtValue", "modulo", LOG_WARN, "Can't apply modulo to %s", typeDescription().c_str());
851
852	default:;
853	}
854	}
855
856	bool ExtValue::parseInt(const char* s, paInt &result, bool strict, bool error)
857	{
858	ExtValue tmp;
859	const char* after = tmp.parseNumber(s, strict ? TInt : TUnknown);
860	if ((after == NULL) \|\| (after[0] != 0))
861	{
862	if (error)
863	logPrintf("ExtValue", "parseInt", LOG_ERROR, "Could not parse '%s'%s", s, strict ? " (strict)" : "");
864	return false;
865	}
866	result = tmp.getInt();
867	return true;
868	}
869
870	bool ExtValue::parseDouble(const char* s, double &result, bool error)
871	{
872	ExtValue tmp;
873	const char* after = tmp.parseNumber(s, TDouble);
874	if ((after == NULL) \|\| (after[0] != 0))
875	{
876	if (error)
877	logPrintf("ExtValue", "parseDouble", LOG_ERROR, "Could not parse '%s'", s);
878	return false;
879	}
880	result = tmp.getDouble();
881	return true;
882	}
883
884	paInt ExtValue::getInt(const char* s, bool strict)
885	{
886	paInt result;
887	if (parseInt(s, result, strict, true))
888	return result;
889	return 0;
890	}
891
892	double ExtValue::getDouble(const char* s)
893	{
894	double result;
895	if (parseDouble(s, result, true))
896	return result;
897	return 0;
898	}
899
900	paInt ExtValue::getInt() const
901	{
902	switch (type)
903	{
904	case TInt: return idata();
905	case TDouble: return (int)ddata();
906	case TString: return getInt(sdata().c_str());
907	case TObj:
908	logPrintf("ExtValue", "getInt", LOG_ERROR, "Getting integer value from object reference (%s)", getString().c_str());
909	return (paInt)(intptr_t)odata().param;
910	default:;
911	}
912	return 0;
913	}
914
915	double ExtValue::getDouble() const
916	{
917	switch (type)
918	{
919	case TDouble: return ddata();
920	case TInt: return (double)idata();
921	case TString: return getDouble(sdata().c_str());
922	case TObj:
923	logPrintf("ExtValue", "getDouble", LOG_ERROR, "Getting floating point value from object reference (%s)", getString().c_str());
924	return (double)(intptr_t)odata().param;
925	default:;
926	}
927	return 0.0;
928	}
929
930	SString ExtValue::getString() const
931	{
932	switch (type)
933	{
934	case TString: return sdata();
935	case TInt: return SString::valueOf(idata());
936	case TDouble: return SString::valueOf(ddata());
937	case TObj: return odata().toString();
938	case TInvalid: return SString("invalid");
939	default: return SString("null");
940	}
941	}
942
943	const SString* ExtValue::getStringPtr() const
944	{
945	if (type == TString)
946	return &sdata();
947	return NULL;
948	}
949
950	SString ExtValue::serialize(SerializationFormat format) const
951	{
952	switch (type)
953	{
954	case TString:
955	{
956	SString q = sdata();
957	sstringQuote(q);
958	return SString("\"") + q + SString("\"");
959	}
960	case TInt:
961	return SString::valueOf(idata());
962	case TDouble:
963	return SString::valueOf(ddata());
964	case TObj:
965	return odata().serialize(format);
966	case TInvalid:
967	if (format == NativeSerialization)
968	return SString("invalid");
969	// else null --v
970	default:
971	return SString("null");
972	}
973	}
974
975	/// returns the first character after the parsed number, or NULL if not a number
976	/// @param strict_type = restrict the allowed return value (TUnknown = unrestricted)
977	const char* ExtValue::parseNumber(const char* in, ExtPType strict_type)
978	{
979	char* after;
980	if (in == NULL) return NULL;
981	if (in[0] == 0) return NULL;
982	while (isspace(*in)) in++;
983	bool minus = (in[0] == '-');
984	bool plus = (in[0] == '+');
985	if (((in[0] == '0') && ((in[1] == 'x') \|\| (in[1] == 'X')))
986	\|\| (((minus \|\| plus) && (in[1] == '0') && ((in[2] == 'x') \|\| (in[2] == 'X')))))
987	{
988	in += (minus \|\| plus) ? 3 : 2;
989	if (isspace(*in)) return NULL;
990	errno = 0;
991	unsigned long intvalue = strtoul(in, &after, 16);
992	if ((after > in) && (errno == 0) && (intvalue <= 0xffffffff))
993	{
994	if (strict_type == TDouble)
995	setDouble(minus ? -(double)intvalue : (double)intvalue);
996	else
997	setInt(minus ? -intvalue : intvalue);
998	return after;
999	}
1000	else
1001	return NULL;
1002	}
1003
1004	errno = 0;
1005	double fpvalue = strtod(in, &after);
1006	if ((after > in) && (errno == 0))
1007	{
1008	if (strict_type != TDouble)
1009	{
1010	if ((memchr(in, '.', after - in) == NULL) && (memchr(in, 'e', after - in) == NULL) && (memchr(in, 'E', after - in) == NULL) // no "special" characters
1011	&& (fpvalue == floor(fpvalue)) // value is integer
1012	&& (fpvalue >= INT_MIN) && (fpvalue <= INT_MAX)) // within limits
1013	{
1014	setInt(fpvalue);
1015	return after;
1016	}
1017	else if (strict_type == TInt)
1018	return NULL;
1019	}
1020	setDouble(fpvalue);
1021	return after;
1022	}
1023	return NULL;
1024	}
1025
1026	PtrListTempl<ParamInterface*> &ExtValue::getDeserializableClasses()
1027	{
1028	static PtrListTempl<ParamInterface*> classes;
1029	return classes;
1030	}
1031
1032	ParamInterface ExtValue::findDeserializableClass(const char name)
1033	{
1034	FOREACH(ParamInterface*, cls, getDeserializableClasses())
1035	if (!strcmp(cls->getName(), name))
1036	return cls;
1037	return NULL;
1038	}
1039
1040	static const char* skipWord(const char* in)
1041	{
1042	while (isalpha(in) \|\| (in == '_'))
1043	in++;
1044	return in;
1045	}
1046
1047	//returns the first character after the parsed portion or NULL if invalid format
1048	const char* ExtValue::deserialize_inner(const char* in)
1049	{
1050	while (isspace(*in)) in++;
1051	const char* ret = parseNumber(in);
1052	if (ret)
1053	return ret;
1054	else if (*in == '\"')
1055	{
1056	ret = skipQuoteString(in + 1, NULL);
1057	SString s(in + 1, (int)(ret - (in + 1)));
1058	sstringUnquote(s);
1059	setString(s);
1060	if (*ret == '\"')
1061	return ret + 1;
1062	else
1063	{
1064	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Missing '\"' in string: '%s'", ret);
1065	return NULL;
1066	}
1067	}
1068	else if (*in == '[')
1069	{
1070	VectorObject *vec = new VectorObject;
1071	ExtObject o(&VectorObject::par, vec);
1072	tlsGetRef(ExtObject_serialization).add(o);
1073	const char* p = in + 1;
1074	ExtValue tmp;
1075	while (*p)
1076	{
1077	if (isspace(*p)) p++;
1078	if (*p == ']') { p++; break; }
1079	ret = tmp.deserialize(p);
1080	if (ret)
1081	{
1082	vec->data += new ExtValue(tmp);
1083	p = ret;
1084	if (*p == ',') p++;
1085	else if (*p != ']')
1086	{
1087	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Missing ',' in Vector: '%s'", p);
1088	return NULL;
1089	}
1090	}
1091	else
1092	{
1093	p = NULL;
1094	break;
1095	}
1096	}
1097	setObject(o);
1098	return p;
1099	}
1100	else if (*in == '{')
1101	{
1102	DictionaryObject *dic = new DictionaryObject;
1103	ExtObject o(&DictionaryObject::par, dic);
1104	tlsGetRef(ExtObject_serialization).add(o);
1105	const char* p = in + 1;
1106	ExtValue args[2]/={value,key}/, dummy_ret;
1107	while (*p)
1108	{
1109	if (isspace(*p)) p++;
1110	if (*p == '}') { p++; break; }
1111	ret = args[1].deserialize(p);
1112	if ((!ret) \|\| (args[1].getType() != TString)) { p = NULL; break; }
1113	p = ret;
1114	if (*p != ':') { logPrintf("ExtValue", "deserialize", LOG_ERROR, "Missing ':' in Dictionary: '%s'", p); p = NULL; break; }
1115	p++;
1116	ret = args[0].deserialize(p);
1117	if (!ret) { p = NULL; break; }
1118	p = ret;
1119	dic->p_set(args, &dummy_ret);
1120	if (*p == ',') p++;
1121	else if (*p != '}')
1122	{
1123	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Missing ',' in Dictionary: '%s'", p);
1124	return NULL;
1125	}
1126	}
1127	setObject(o);
1128	return p;
1129	}
1130	else if (!strncmp(in, "null", 4))
1131	{
1132	setEmpty();
1133	return in + 4;
1134	}
1135	else if (!strncmp(in, "true", 4))
1136	{
1137	setInt(1);
1138	return in + 4;
1139	}
1140	else if (!strncmp(in, "false", 5))
1141	{
1142	setInt(0);
1143	return in + 5;
1144	}
1145	else if (!strncmp(in, "invalid", 7))
1146	{
1147	setInvalid();
1148	return in + 7;
1149	}
1150	else if (*in == '<')
1151	{ //unserializable object
1152	const char* end = in + 1;
1153	while (*end)
1154	if (*end == '>')
1155	{
1156	setError(SString("Unserializable class: ") + SString(in + 1, end - in - 1));
1157	return end + 1;
1158	}
1159	else
1160	end++;
1161	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Missing '>'");
1162	return NULL;
1163	}
1164	else if (*in == '^')
1165	{
1166	in++;
1167	ExtValue ref;
1168	ret = ref.parseNumber(in, TInt);
1169	if (ret && (ref.getType() == TInt))
1170	{
1171	const ExtObject* o = tlsGetRef(ExtObject_serialization).get(ref.getInt());
1172	if (o)
1173	{
1174	setObject(*o);
1175	return ret;
1176	}
1177	}
1178	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Invalid reference: '%s'", in - 1);
1179	return NULL;
1180	}
1181	else if ((ret = skipWord(in)) && (ret != in))
1182	{
1183	SString clsname(in, (int)(ret - in));
1184	ExtValue tmp;
1185	ret = tmp.deserialize(ret);
1186	ParamInterface *cls = findDeserializableClass(clsname.c_str());
1187	if (cls && (tmp.getType() != TUnknown) && (tmp.getType() != TInvalid))
1188	{
1189	VectorObject *vec = VectorObject::fromObject(tmp.getObject(), false);
1190	if (vec)
1191	{
1192	int m = cls->findId("newFromVector");
1193	if (m >= 0)
1194	{
1195	cls->call(m, &tmp, this);
1196	tlsGetRef(ExtObject_serialization).replace(tmp.getObject(), getObject());
1197	return ret;
1198	}
1199	}
1200	DictionaryObject *dic = DictionaryObject::fromObject(tmp.getObject(), false);
1201	if (dic)
1202	{
1203	int m = cls->findId("newFromDictionary");
1204	if (m >= 0)
1205	{
1206	cls->call(m, &tmp, this);
1207	tlsGetRef(ExtObject_serialization).replace(tmp.getObject(), getObject());
1208	return ret;
1209	}
1210	}
1211	if (tmp.getType() == TString)
1212	{
1213	int m = cls->findId("newFromString");
1214	if (m >= 0)
1215	{
1216	cls->call(m, &tmp, this);
1217	tlsGetRef(ExtObject_serialization).replace(tmp.getObject(), getObject());
1218	return ret;
1219	}
1220	}
1221	tlsGetRef(ExtObject_serialization).remove(tmp.getObject());
1222	setEmpty();
1223	}
1224	setEmpty();
1225	logPrintf("ExtValue", "deserialize", LOG_WARN, "object of class \"%s\" could not be deserialized", clsname.c_str());
1226	return ret;
1227	}
1228	logPrintf("ExtValue", "deserialize", LOG_ERROR, "Bad syntax: '%s'", in);
1229	setEmpty();
1230	return NULL;
1231	}
1232
1233	const char* ExtValue::deserialize(const char* in)
1234	{
1235	tlsGetRef(ExtObject_serialization).begin();
1236	const char* ret = deserialize_inner(in);
1237	if (ret) while (isspace(*ret)) ret++;
1238	tlsGetRef(ExtObject_serialization).end();
1239	return ret;
1240	}
1241
1242	ExtObject ExtValue::getObject() const
1243	{
1244	if (type == TObj) return odata();
1245	return ExtObject();
1246	}
1247
1248	ExtValue ExtValue::getExtType()
1249	{
1250	static const char* typenames[] = { "null", "int", "float", "string", "", "invalid" };
1251	if (getType() != TObj)
1252	return ExtValue(typenames[(int)getType()]);
1253	ExtObject& o = odata();
1254	return ExtValue(SString(o.isEmpty() ? "" : o.interfaceName()));
1255	}
1256
1257	SString SString::valueOf(const ExtValue& v)
1258	{
1259	return v.getString();
1260	}
1261	SString SString::valueOf(const ExtObject& v)
1262	{
1263	return v.toString();
1264	}
1265
1266	#define FIELDSTRUCT ErrorObject
1267	static ParamEntry errorobject_paramtab[] =
1268	{
1269	{ "Error", 1, 3, "Error", },
1270	{ "message", 0, 0, "Message", "s", FIELD(message), },
1271	{ "newFromString", 0, 0, "create new object", "p oError(s message)", PROCEDURE(p_newfromstring), },
1272	{ "toString", 0, PARAM_READONLY \| PARAM_NOSTATIC, "Textual form", "s", GETONLY(toString), },
1273	{ 0, 0, 0, },
1274	};
1275	#undef FIELDSTRUCT
1276
1277	Param& ErrorObject::getParam()
1278	{
1279	static Param param(errorobject_paramtab);
1280	return param;
1281	}
1282
1283	ExtObject ErrorObject::makeDynamicObject(ErrorObject* e)
1284	{
1285	return ExtObject(&getParam(), (DestrBase*)e);
1286	}
1287
1288	const SString ErrorObject::TO_STRING_PREFIX = "Error: ";
1289
1290	void ErrorObject::get_toString(ExtValue* ret)
1291	{
1292	ret->setString(TO_STRING_PREFIX + message);
1293	}
1294
1295	void ErrorObject::p_newfromstring(ExtValue args, ExtValue ret)
1296	{
1297	ErrorObject *err = new ErrorObject();
1298	err->message = args[0].getString();
1299	if (err->message.startsWith(TO_STRING_PREFIX.c_str()))
1300	err->message = err->message.substr(TO_STRING_PREFIX.len());
1301	*ret = makeDynamicObject(err);
1302	}
1303
1304	REGISTER_DESERIALIZABLE(ErrorObject)

Note: See TracBrowser for help on using the repository browser.

Download in other formats: