summaryrefslogtreecommitdiffstats
path: root/src/lib
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib')
-rw-r--r--src/lib/eiotas_particle.c41
1 files changed, 40 insertions, 1 deletions
diff --git a/src/lib/eiotas_particle.c b/src/lib/eiotas_particle.c
index 2cf1f47..7f45848 100644
--- a/src/lib/eiotas_particle.c
+++ b/src/lib/eiotas_particle.c
@@ -19,6 +19,8 @@
#include "eiotas_particle.h"
#include "eiotas_private.h"
+static void update_link_value(Eiotas_Particle *particle, const char *field);
+
Eiotas_Particle* eiotas_particle_alloc()
{
BUILD_INSTANCE(Eiotas_Particle,particle);
@@ -110,7 +112,44 @@ EAPI void eiotas_particle_destinations_add(Eiotas_Particle *particle, const char
}
for(; (*sep && *sep!=EIOTAS_FIELDS_SEP); sep++) /* eat whatever following */;
if(!*sep) return;
- dst=sep+1;
+ dst = sep+1;
+ }
+}
+
+static void update_link_value(Eiotas_Particle *particle, const char *field)
+{
+ unsigned int i;
+ unsigned int l;
+ Eina_Stringshare *k;
+ Eina_Stringshare *v;
+ Eina_Array_Iterator it;
+ Eina_Bool update;
+ char tmp[EIOTAS_MAX_VALUE_LENGTH];
+ char *dst;
+
+ if(field!=NULL) {
+ update = EINA_FALSE;
+ EINA_ARRAY_ITER_NEXT(particle->link_fields, i, k, it) {
+ if(strcmp(field,k)==0) {
+ update = EINA_TRUE;
+ break;
+ }
+ }
+ if(!update) return;
+ }
+
+ if(particle->link_value) eina_stringshare_del(particle->link_value);
+
+ dst = tmp;
+ EINA_ARRAY_ITER_NEXT(particle->link_fields, i, k, it) {
+ v = eina_hash_find(particle->payload,k);
+ if(v!=NULL) {
+ l = strlen(v);
+ strcpy(dst,v);
+ dst += l;
+ }
}
+ *dst='\0';
+ particle->link_value = eina_stringshare_add(tmp);
}