#define MM_RESOURCE_MANAGER_RESERVED_PART_ARRAY_SIZE 4 /* preallocated size */
#define MM_RESOURCE_MANAGER_RESERVED_CALLBACK_ARRAY_SIZE 32 /* preallocated size */
#define MM_RESOURCE_MANGER_NOT_FOUND -1
-#define RELEASE_CB_SYNC_TIMEOUT 300 /* milliseconds */
+#define RELEASE_CB_SYNC_TIMEOUT 500 /* milliseconds */
typedef enum {
MM_RESOURCE_MANAGER_RES_STATE_FOR_ACQUIRE,
mm_resource_manager_id recv_id;
ssize_t read_size;
+ MM_RM_DEBUG("Enter");
sync.fd = open(RELEASE_CB_SYNC_PATH, O_RDONLY | O_NONBLOCK);
+ MM_RM_DEBUG("[%d] opened %s", sync.fd, RELEASE_CB_SYNC_PATH);
+
MM_RM_RETVM_IF(sync.fd == -1, FALSE, "Sync FIFO cannot be opened");
if (!__poll(sync, id))
out:
close(sync.fd);
+ MM_RM_DEBUG("[%d] closed", sync.fd);
return ret;
}
{
int sync_fd;
+ MM_RM_DEBUG("Enter");
sync_fd = open(RELEASE_CB_SYNC_PATH, O_WRONLY);
+ MM_RM_DEBUG("[%d] opened %s", sync_fd, RELEASE_CB_SYNC_PATH);
+
MM_RM_RETM_IF(sync_fd == -1, "Sync FIFO cannot be opened [errno %d]", errno);
if (write(sync_fd, &id, sizeof(id)) == sizeof(id))
MM_RM_ERROR("[SYNC] message cannot be sent RM #%"PRIu64, _mm_rm_hash64(id));
close(sync_fd);
+ MM_RM_DEBUG("[%d] closed", sync_fd);
}
static void __init_lib()