}
template <typename T>
-void DataSet<T>::update()
+void DataSet<T>::update(long timeslice)
{
+ resman_setopt(rman, RESMAN_OPT_TIMESLICE, timeslice);
resman_poll(rman);
}
T res = create();
data[name] = res;
- resman_lookup(rman, name, res);
+ resman_add(rman, name, res);
return res;
}
+template <typename T>
+int DataSet<T>::pending() const
+{
+ return resman_pending(rman);
+}
+
+template <typename T>
+void DataSet<T>::wait() const
+{
+ resman_wait_all(rman);
+}
+
+template <typename T>
+void DataSet<T>::add_loaded_callback(LoadedCallbackFunc func, void *cls)
+{
+ std::pair<LoadedCallbackFunc, void*> cb;
+ cb.first = func;
+ cb.second = cls;
+ loaded_cb.push_back(cb);
+}
+
+template <typename T>
+bool DataSet<T>::remove_loaded_callback(LoadedCallbackFunc func)
+{
+ int numcb = (int)loaded_cb.size();
+ for(int i=0; i<numcb; i++) {
+ if(loaded_cb[i].first == func) {
+ loaded_cb.erase(loaded_cb.begin() + i);
+ return true;
+ }
+ }
+ return false;
+}
+
// --- static functions to pass as callback to resman ---
if(dset->done) {
dset->done(data);
}
+
+ int numcb = (int)dset->loaded_cb.size();
+ for(int i=0; i<numcb; i++) {
+ dset->loaded_cb[i].first(data, dset->loaded_cb[i].second);
+ }
return 0;
}