diff options
Diffstat (limited to 'src/testbed/testbed_api_operations.c')
-rw-r--r-- | src/testbed/testbed_api_operations.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/testbed/testbed_api_operations.c b/src/testbed/testbed_api_operations.c index ce2ef5715..2a559a90e 100644 --- a/src/testbed/testbed_api_operations.c +++ b/src/testbed/testbed_api_operations.c | |||
@@ -455,7 +455,7 @@ change_state (struct GNUNET_TESTBED_Operation *op, enum OperationState state) | |||
455 | { | 455 | { |
456 | if (OP_STATE_INIT == op->state) | 456 | if (OP_STATE_INIT == op->state) |
457 | { | 457 | { |
458 | entry = GNUNET_malloc (sizeof (struct QueueEntry)); | 458 | entry = GNUNET_new (struct QueueEntry); |
459 | entry->op = op; | 459 | entry->op = op; |
460 | entry->nres = op->nres[cnt]; | 460 | entry->nres = op->nres[cnt]; |
461 | s = cnt; | 461 | s = cnt; |
@@ -557,7 +557,7 @@ rq_add (struct GNUNET_TESTBED_Operation *op) | |||
557 | struct ReadyQueueEntry *rq_entry; | 557 | struct ReadyQueueEntry *rq_entry; |
558 | 558 | ||
559 | GNUNET_assert (NULL == op->rq_entry); | 559 | GNUNET_assert (NULL == op->rq_entry); |
560 | rq_entry = GNUNET_malloc (sizeof (struct ReadyQueueEntry)); | 560 | rq_entry = GNUNET_new (struct ReadyQueueEntry); |
561 | rq_entry->op = op; | 561 | rq_entry->op = op; |
562 | GNUNET_CONTAINER_DLL_insert_tail (rq_head, rq_tail, rq_entry); | 562 | GNUNET_CONTAINER_DLL_insert_tail (rq_head, rq_tail, rq_entry); |
563 | op->rq_entry = rq_entry; | 563 | op->rq_entry = rq_entry; |
@@ -970,7 +970,7 @@ GNUNET_TESTBED_operation_create_ (void *cls, OperationStart start, | |||
970 | { | 970 | { |
971 | struct GNUNET_TESTBED_Operation *op; | 971 | struct GNUNET_TESTBED_Operation *op; |
972 | 972 | ||
973 | op = GNUNET_malloc (sizeof (struct GNUNET_TESTBED_Operation)); | 973 | op = GNUNET_new (struct GNUNET_TESTBED_Operation); |
974 | op->start = start; | 974 | op->start = start; |
975 | op->state = OP_STATE_INIT; | 975 | op->state = OP_STATE_INIT; |
976 | op->release = release; | 976 | op->release = release; |
@@ -994,7 +994,7 @@ GNUNET_TESTBED_operation_queue_create_ (enum OperationQueueType type, | |||
994 | struct OperationQueue *queue; | 994 | struct OperationQueue *queue; |
995 | struct FeedbackCtx *fctx; | 995 | struct FeedbackCtx *fctx; |
996 | 996 | ||
997 | queue = GNUNET_malloc (sizeof (struct OperationQueue)); | 997 | queue = GNUNET_new (struct OperationQueue); |
998 | queue->type = type; | 998 | queue->type = type; |
999 | if (OPERATION_QUEUE_TYPE_FIXED == type) | 999 | if (OPERATION_QUEUE_TYPE_FIXED == type) |
1000 | { | 1000 | { |
@@ -1002,7 +1002,7 @@ GNUNET_TESTBED_operation_queue_create_ (enum OperationQueueType type, | |||
1002 | } | 1002 | } |
1003 | else | 1003 | else |
1004 | { | 1004 | { |
1005 | fctx = GNUNET_malloc (sizeof (struct FeedbackCtx)); | 1005 | fctx = GNUNET_new (struct FeedbackCtx); |
1006 | fctx->max_active_bound = max_active; | 1006 | fctx->max_active_bound = max_active; |
1007 | fctx->sd = GNUNET_TESTBED_SD_init_ (10); /* FIXME: Why 10? */ | 1007 | fctx->sd = GNUNET_TESTBED_SD_init_ (10); /* FIXME: Why 10? */ |
1008 | queue->fctx = fctx; | 1008 | queue->fctx = fctx; |