mq_tcp.c File Reference

---

Detailed Description

Message queues, writing to a TCP stack.

Author:

Raphael Manfredi

Date:

2002-2003

#include "common.h"
#include "nodes.h"
#include "mq.h"
#include "mq_tcp.h"
#include "pmsg.h"
#include "gmsg.h"
#include "tx.h"
#include "gnet_stats.h"
#include "lib/walloc.h"
#include "if/gnet_property_priv.h"
#include "lib/override.h"

Defines
#define	MQ_MAXIOV   256 /**< Our limit on the I/O vectors we build */
	Our limit on the I/O vectors we build.
#define	MQ_MINIOV   2 /**< Minimum amount of I/O vectors in service */
	Minimum amount of I/O vectors in service.
#define	MQ_MINSEND   256 /**< Minimum size we try to send */
	Minimum size we try to send.
Functions
	RCSID ("$Id:mq_tcp.c, v 1.10 2005/12/17 09:25:44 daichik Exp $")
void	mq_tcp_service (gpointer data)
	Service routine for TCP message queue.
void	mq_tcp_putq (mqueue_t *q, pmsg_t *mb)
	Enqueue message, which becomes owned by the queue.
mqueue_t *	mq_tcp_make (gint maxsize, struct gnutella_node *n, struct txdriver *nd)
	Create new message queue capable of holding `maxsize' bytes, and owned by the supplied node.
Variables
const struct mq_ops	mq_tcp_ops

---

Define Documentation

#define MQ_MAXIOV   256 /**< Our limit on the I/O vectors we build */

Our limit on the I/O vectors we build.

#define MQ_MINIOV   2 /**< Minimum amount of I/O vectors in service */

Minimum amount of I/O vectors in service.

#define MQ_MINSEND   256 /**< Minimum size we try to send */

Minimum size we try to send.

---

Function Documentation

mqueue_t* mq_tcp_make (  gint  maxsize, struct gnutella_node *  n, struct txdriver *  nd )

Create new message queue capable of holding `maxsize' bytes, and owned by the supplied node.

void mq_tcp_putq (  mqueue_t *  q, pmsg_t *  mb )  [static]

Enqueue message, which becomes owned by the queue. FIXME: The following assertion check failed. --cbiere, 2005-11-01

void mq_tcp_service (  gpointer  data  )  [static]

Service routine for TCP message queue.

RCSID (  "$Id:mq_tcp.  c, v 1.10 2005/12/17 09:25:44 daichik Exp $"  )

---

Variable Documentation

const struct mq_ops mq_tcp_ops [static]

Initial value: { mq_tcp_putq, }

---