* The LOCKMANAGER Message
*/
struct GNUNET_LOCKMANAGER_Message *msg;
+
+ /**
+ * If this is a AQUIRE_LOCK message, this is the
+ * affiliated locking request.
+ */
+ struct GNUNET_LOCKMANAGER_LockingRequest *lr;
};
*/
GNUNET_LOCKMANAGER_StatusCallback status_cb;
+ /**
+ * Entry in the request message queue for aquiring this
+ * lock; NULL after request has been sent.
+ */
+ struct MessageQueue *mqe;
+
/**
* Closure for the status callback
*/
LOG (GNUNET_ERROR_TYPE_DEBUG, "Queueing ACQUIRE message\n");
queue_message (handle, msg);
get_key (r->domain, r->lock, &hash);
- GNUNET_CONTAINER_multihashmap_put (r->handle->hashmap,
- &hash,
- r,
- GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
+ GNUNET_assert (GNUNET_OK ==
+ GNUNET_CONTAINER_multihashmap_put (r->handle->hashmap,
+ &hash,
+ r,
+ GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__);
return r;
}
-
/**
* Function to cancel the locking request generated by
* GNUNET_LOCKMANAGER_acquire_lock. If the lock is acquired by us then the lock