gnunet-service-fs_push.h File Reference

support for pushing out content More...

#include "gnunet-service-fs.h"

Include dependency graph for gnunet-service-fs_push.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	GSF_push_init_ (void)
	Setup the module. More...
void	GSF_push_done_ (void)
	Shutdown the module. More...
void	GSF_push_start_ (struct GSF_ConnectedPeer *peer)
	A peer connected to us or we are now again allowed to push content. More...
void	GSF_push_stop_ (struct GSF_ConnectedPeer *peer)
	A peer disconnected from us or asked us to stop pushing content for a while. More...

Detailed Description

support for pushing out content

Author

Christian Grothoff

Definition in file gnunet-service-fs_push.h.

Function Documentation

GSF_push_init_()

void GSF_push_init_

(

void

)

Setup the module.

Definition at line 625 of file gnunet-service-fs_push.c.

{
  enabled =
    GNUNET_CONFIGURATION_get_value_yesno (GSF_cfg,
                                          "FS",
                                          "CONTENT_PUSHING");
  if (GNUNET_YES != enabled)
    return;
 
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time (GSF_cfg,
                                           "fs",
                                           "MIN_MIGRATION_DELAY",
                                           &min_migration_delay))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_WARNING,
                               "fs",
                               "MIN_MIGRATION_DELAY",
                               _ ("time required, content pushing disabled"));
    return;
  }
  consider_gathering ();
}

References _, consider_gathering(), enabled, GNUNET_CONFIGURATION_get_value_time(), GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_ERROR_TYPE_WARNING, GNUNET_log_config_invalid(), GNUNET_OK, GNUNET_YES, GSF_cfg, and min_migration_delay.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GSF_push_done_()

void GSF_push_done_

(

void

)

Shutdown the module.

Definition at line 654 of file gnunet-service-fs_push.c.

{
  if (NULL != mig_task)
  {
    GNUNET_SCHEDULER_cancel (mig_task);
    mig_task = NULL;
  }
  if (NULL != mig_qe)
  {
    GNUNET_DATASTORE_cancel (mig_qe);
    mig_qe = NULL;
  }
  while (NULL != mig_head)
    delete_migration_block (mig_head);
  GNUNET_assert (0 == mig_size);
}

References delete_migration_block(), GNUNET_assert, GNUNET_DATASTORE_cancel(), GNUNET_SCHEDULER_cancel(), mig_head, mig_qe, mig_size, and mig_task.

Referenced by shutdown_task().

Here is the call graph for this function:

Here is the caller graph for this function:

GSF_push_start_()

void GSF_push_start_

(

struct GSF_ConnectedPeer *

peer

)

A peer connected to us or we are now again allowed to push content.

Start pushing content to this peer.

Parameters

peer	handle for the peer that connected

A peer connected to us or we are now again allowed to push content.

Start pushing content to this peer.

Parameters

peer	handle for the peer that connected

Definition at line 567 of file gnunet-service-fs_push.c.

{
  struct MigrationReadyPeer *mrp;
 
  if (GNUNET_YES != enabled)
    return;
  for (mrp = peer_head; NULL != mrp; mrp = mrp->next)
    if (mrp->peer == peer)
      break;
  if (NULL != mrp)
  {
    /* same peer added twice, must not happen */
    GNUNET_break (0);
    return;
  }
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Adding peer %s to list for pushing\n",
              GNUNET_i2s (GSF_connected_peer_get_identity2_ (peer)));
 
  mrp = GNUNET_new (struct MigrationReadyPeer);
  mrp->peer = peer;
  find_content (mrp);
  GNUNET_CONTAINER_DLL_insert (peer_head,
                               peer_tail,
                               mrp);
}

References enabled, find_content(), GNUNET_break, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_new, GNUNET_YES, GSF_connected_peer_get_identity2_(), MigrationReadyPeer::next, MigrationReadyPeer::peer, peer_head, and peer_tail.

Referenced by peer_respect_cb(), and revive_migration().

Here is the call graph for this function:

Here is the caller graph for this function:

GSF_push_stop_()

void GSF_push_stop_

(

struct GSF_ConnectedPeer *

peer

)

A peer disconnected from us or asked us to stop pushing content for a while.

Stop pushing content to this peer.

Parameters

peer	handle for the peer that disconnected

A peer disconnected from us or asked us to stop pushing content for a while.

Stop pushing content to this peer.

Parameters

peer	handle for the peer that disconnected

Definition at line 603 of file gnunet-service-fs_push.c.

{
  struct MigrationReadyPeer *pos;
 
  for (pos = peer_head; NULL != pos; pos = pos->next)
    if (pos->peer == peer)
      break;
  if (NULL == pos)
    return;
  if (NULL != pos->env)
    GNUNET_MQ_send_cancel (pos->env);
  GNUNET_CONTAINER_DLL_remove (peer_head,
                               peer_tail,
                               pos);
  GNUNET_free (pos);
}

References MigrationReadyPeer::env, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_MQ_send_cancel(), MigrationReadyPeer::next, MigrationReadyPeer::peer, peer_head, and peer_tail.

Referenced by GSF_peer_disconnect_handler(), and handle_p2p_migration_stop().

Here is the call graph for this function:

Here is the caller graph for this function: