oneechanhax/phunix
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DS: update subscriptions for deleted keys upon process exit

Browse Source
This commit is contained in:
David van Moolenbroek 2011-01-07 17:06:24 +00:00
parent efca30b081
commit dbcca28c19
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
servers/ds/store.c
View File

@ -120,7 +120,7 @@ PRIVATE endpoint_t ds_getprocep(const char *s)
if((dsp = lookup_entry(s, DSF_TYPE_LABEL)) != NULL) if((dsp = lookup_entry(s, DSF_TYPE_LABEL)) != NULL)
return dsp->u.u32; return dsp->u.u32;
return (endpoint_t) -1; panic("ds_getprocep: process endpoint not found");
} }
/*===========================================================================* /*===========================================================================*
@ -629,9 +629,6 @@ PUBLIC int do_check(message *m_ptr)
/* Copy the type and the owner of the original entry. */ /* Copy the type and the owner of the original entry. */
entry_owner_e = ds_getprocep(ds_store[i].owner); entry_owner_e = ds_getprocep(ds_store[i].owner);
if(entry_owner_e == -1) {
panic("ds_getprocep failed");
}
m_ptr->DS_FLAGS = ds_store[i].flags & DSF_MASK_TYPE; m_ptr->DS_FLAGS = ds_store[i].flags & DSF_MASK_TYPE;
m_ptr->DS_OWNER = entry_owner_e; m_ptr->DS_OWNER = entry_owner_e;
@ -688,6 +685,8 @@ PUBLIC int do_delete(message *m_ptr)
for (i = 0; i < NR_DS_KEYS; i++) { for (i = 0; i < NR_DS_KEYS; i++) {
if ((ds_store[i].flags & DSF_IN_USE) if ((ds_store[i].flags & DSF_IN_USE)
&& !strcmp(ds_store[i].owner, label)) { && !strcmp(ds_store[i].owner, label)) {
update_subscribers(&ds_store[i], 0);
ds_store[i].flags = 0; ds_store[i].flags = 0;
} }
} }