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 "if/core/main.h"
#include "lib/override.h"

Defines
#define	MQ_MAXIOV   256
	Our limit on the I/O vectors we build.
#define	MQ_MINIOV   2
	Minimum amount of I/O vectors in service.
#define	MQ_MINSEND   256
	Minimum size we try to send.
Functions
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.

#define MQ_MINIOV   2

Minimum amount of I/O vectors in service.

#define MQ_MINSEND   256

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.

void mq_tcp_service (  gpointer  data  )  [static]

Service routine for TCP message queue.

---

Variable Documentation

const struct mq_ops mq_tcp_ops [static]

Initial value: { mq_tcp_putq, }

---