op.c File Reference

Asynchronous operations; register callbacks for operations and call them when a response arrives. More...

#include "platform.h"
#include <inttypes.h>
#include "gnunet_util_lib.h"

Include dependency graph for op.c:

Go to the source code of this file.

Data Structures
struct	OperationListItem
struct	GNUNET_OP_Handle
	Operations handle. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "util-op", __VA_ARGS__)

Functions
struct GNUNET_OP_Handle *	GNUNET_OP_create ()
	Create new operations handle. More...
void	GNUNET_OP_destroy (struct GNUNET_OP_Handle *h)
	Destroy operations handle. More...
uint64_t	GNUNET_OP_get_next_id (struct GNUNET_OP_Handle *h)
	Get a unique operation ID to distinguish between asynchronous requests. More...
static struct OperationListItem *	op_find (struct GNUNET_OP_Handle *h, uint64_t op_id)
	Find operation by ID. More...
int	GNUNET_OP_get (struct GNUNET_OP_Handle *h, uint64_t op_id, GNUNET_ResultCallback *result_cb, void **cls, void **ctx)
	Find operation by ID. More...
uint64_t	GNUNET_OP_add (struct GNUNET_OP_Handle *h, GNUNET_ResultCallback result_cb, void *cls, void *ctx)
	Add a new operation. More...
static int	op_result (struct GNUNET_OP_Handle *h, uint64_t op_id, int64_t result_code, const void *data, uint16_t data_size, void **ctx, uint8_t cancel)
	Remove an operation, and call its result callback (unless it was cancelled). More...
int	GNUNET_OP_result (struct GNUNET_OP_Handle *h, uint64_t op_id, int64_t result_code, const void *data, uint16_t data_size, void **ctx)
	Call the result callback of an operation and remove it. More...
int	GNUNET_OP_remove (struct GNUNET_OP_Handle *h, uint64_t op_id)
	Remove / cancel an operation. More...

Detailed Description

Asynchronous operations; register callbacks for operations and call them when a response arrives.

Author

Gabor X Toth

Definition in file op.c.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from (kind, "util-op", __VA_ARGS__)

Definition at line 34 of file op.c.

Function Documentation

op_find()

static struct OperationListItem * op_find ( struct GNUNET_OP_Handle *  h, uint64_t  op_id  )

static

Find operation by ID.

Parameters

h	Operations handle.
op_id	Operation ID to look up.

Returns

Operation, or NULL if not found.

Definition at line 132 of file op.c.

{
  struct OperationListItem *op;
 
  for (op = h->op_head; NULL != op; op = op->next)
    if (op->op_id == op_id)
      return op;
  return NULL;
}

References h, GNUNET_ARM_Operation::next, op, and OperationListItem::op_id.

Referenced by GNUNET_OP_get(), and op_result().

Here is the caller graph for this function:

op_result()

static int op_result ( struct GNUNET_OP_Handle *  h, uint64_t  op_id, int64_t  result_code, const void *  data, uint16_t  data_size, void **  ctx, uint8_t  cancel  )

static

Remove an operation, and call its result callback (unless it was cancelled).

Parameters

	h	Operations handle.
	op_id	Operation ID.
	result_code	Result of the operation.
	data	Data result of the operation.
	data_size	Size of data.
[out]	ctx	User context.
	cancel	Is the operation cancelled? GNUNET_NO Not cancelled, result callback is called. GNUNET_YES Cancelled, result callback is not called.

Returns

GNUNET_YES if the operation was found and removed, GNUNET_NO if the operation was not found.

Definition at line 246 of file op.c.

{
  if (0 == op_id)
    return GNUNET_NO;
 
  struct OperationListItem *op = op_find (h, op_id);
  if (NULL == op)
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Could not find operation #%" PRIu64 "\n", op_id);
    return GNUNET_NO;
  }
 
  if (NULL != ctx)
    *ctx = op->ctx;
 
  GNUNET_CONTAINER_DLL_remove (h->op_head,
                               h->op_tail,
                               op);
 
  if ((GNUNET_YES != cancel) &&
      (NULL != op->result_cb))
    op->result_cb (op->cls,
                   result_code, data,
                   data_size);
  GNUNET_free (op);
  return GNUNET_YES;
}

References ctx, data, data_size, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_NO, GNUNET_YES, h, LOG, op, op_find(), and OperationListItem::op_id.

Referenced by dht_da(), dht_disconnect(), GNUNET_OP_remove(), GNUNET_OP_result(), and stats_da().

Here is the call graph for this function:

Here is the caller graph for this function: