messenger.h File Reference

#include <linux/kref.h>
#include <linux/mutex.h>
#include <linux/net.h>
#include <linux/radix-tree.h>
#include <linux/uio.h>
#include <linux/workqueue.h>
#include <linux/ceph/types.h>
#include <linux/ceph/buffer.h>

Go to the source code of this file.

Data Structures
struct	ceph_connection_operations
struct	ceph_messenger
struct	ceph_msg
struct	ceph_msg_pos
struct	ceph_connection

Macros
#define	ENTITY_NAME(n)   ceph_entity_type_name((n).type), le64_to_cpu((n).num)
#define	BASE_DELAY_INTERVAL   (HZ/2)
#define	MAX_DELAY_INTERVAL   (5 * 60 * HZ)

Functions
const char *	ceph_pr_addr (const struct sockaddr_storage *ss)
int	ceph_parse_ips (const char *c, const char *end, struct ceph_entity_addr *addr, int max_count, int *count)
int	ceph_msgr_init (void)
void	ceph_msgr_exit (void)
void	ceph_msgr_flush (void)
void	ceph_messenger_init (struct ceph_messenger *msgr, struct ceph_entity_addr *myaddr, u32 supported_features, u32 required_features, bool nocrc)
void	ceph_con_init (struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr)
void	ceph_con_open (struct ceph_connection *con, __u8 entity_type, __u64 entity_num, struct ceph_entity_addr *addr)
bool	ceph_con_opened (struct ceph_connection *con)
void	ceph_con_close (struct ceph_connection *con)
void	ceph_con_send (struct ceph_connection *con, struct ceph_msg *msg)
void	ceph_msg_revoke (struct ceph_msg *msg)
void	ceph_msg_revoke_incoming (struct ceph_msg *msg)
void	ceph_con_keepalive (struct ceph_connection *con)
struct ceph_msg *	ceph_msg_new (int type, int front_len, gfp_t flags, bool can_fail)
void	ceph_msg_kfree (struct ceph_msg *m)
void	ceph_msg_last_put (struct kref *kref)
void	ceph_msg_dump (struct ceph_msg *msg)

Macro Definition Documentation

#define BASE_DELAY_INTERVAL   (HZ/2)

Definition at line 106 of file messenger.h.

#define ENTITY_NAME

(

n

)

ceph_entity_type_name((n).type), le64_to_cpu((n).num)

Definition at line 47 of file messenger.h.

#define MAX_DELAY_INTERVAL   (5 * 60 * HZ)

Definition at line 107 of file messenger.h.

Function Documentation

void ceph_con_close

(

struct ceph_connection *

con

)

Definition at line 532 of file messenger.c.

void ceph_con_init	(	struct ceph_connection *	con,
		void *	private,
		const struct ceph_connection_operations *	ops,
		struct ceph_messenger *	msgr
	)

Definition at line 587 of file messenger.c.

void ceph_con_keepalive

(

struct ceph_connection *

con

)

Definition at line 2598 of file messenger.c.

void ceph_con_open	(	struct ceph_connection *	con,
		__u8	entity_type,
		__u64	entity_num,
		struct ceph_entity_addr *	addr
	)

Definition at line 556 of file messenger.c.

bool ceph_con_opened

(

struct ceph_connection *

con

)

Definition at line 579 of file messenger.c.

void ceph_con_send	(	struct ceph_connection *	con,
		struct ceph_msg *	msg
	)

Definition at line 2481 of file messenger.c.

void ceph_messenger_init	(	struct ceph_messenger *	msgr,
		struct ceph_entity_addr *	myaddr,
		u32	supported_features,
		u32	required_features,
		bool	nocrc
	)

Definition at line 2440 of file messenger.c.

void ceph_msg_dump

(

struct ceph_msg *

msg

)

Definition at line 2842 of file messenger.c.

void ceph_msg_kfree

(

struct ceph_msg *

m

)

Definition at line 2799 of file messenger.c.

void ceph_msg_last_put

(

struct kref *

kref

)

Definition at line 2812 of file messenger.c.

struct ceph_msg* ceph_msg_new ( int  type, int  front_len, gfp_t  flags, bool  can_fail  )

read

Definition at line 2615 of file messenger.c.

void ceph_msg_revoke

(

struct ceph_msg *

msg

)

Definition at line 2523 of file messenger.c.

void ceph_msg_revoke_incoming

(

struct ceph_msg *

msg

)

Definition at line 2558 of file messenger.c.

void ceph_msgr_exit

(

void

)

Definition at line 203 of file messenger.c.

void ceph_msgr_flush

(

void

)

Definition at line 211 of file messenger.c.

int ceph_msgr_init

(

void

)

Definition at line 186 of file messenger.c.

int ceph_parse_ips	(	const char *	c,
		const char *	end,
		struct ceph_entity_addr *	addr,
		int	max_count,
		int *	count
	)

Definition at line 1390 of file messenger.c.

const char* ceph_pr_addr

(

const struct sockaddr_storage *

ss

)

Definition at line 132 of file messenger.c.