{
if (NULL != p->ch)
{
- GNUNET_CORE_disconnecT (p->ch);
+ GNUNET_CORE_disconnect (p->ch);
p->ch = NULL;
}
if (NULL != p->ghh)
{
uint64_t flags;
const void *extra;
-
+
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Asking core (1) for transmission to peer `%s'\n",
GNUNET_i2s (&p2.id));
const struct GNUNET_MessageHeader *message)
{
const struct GNUNET_PeerIdentity *peer = cls;
-
+
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Receiving message from `%s'.\n",
GNUNET_i2s (peer));
GNUNET_MQ_hd_fixed_size (test,
MTYPE,
struct GNUNET_MessageHeader,
- NULL);
+ NULL),
GNUNET_MQ_handler_end ()
};
GNUNET_assert (ok == 2);
OKPP;
/* connect p2 */
- p2.ch = GNUNET_CORE_connecT (p2.cfg,
+ p2.ch = GNUNET_CORE_connect (p2.cfg,
&p2,
&init_notify,
&connect_notify,
GNUNET_MQ_hd_fixed_size (test,
MTYPE,
struct GNUNET_MessageHeader,
- NULL);
+ NULL),
GNUNET_MQ_handler_end ()
};
(GNUNET_TIME_UNIT_SECONDS, 300),
&terminate_task_error, NULL);
p1.ch =
- GNUNET_CORE_connecT (p1.cfg,
+ GNUNET_CORE_connect (p1.cfg,
&p1,
&init_notify,
&connect_notify,