fs/ocfs2/cluster/heartbeat.c

438

static int o2hb_nego_timeout_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/cluster/heartbeat.c

456

static int o2hb_nego_approve_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/cluster/tcp.c

1020

struct o2net_msg *msg = NULL;

fs/ocfs2/cluster/tcp.c

1074

msg = kmalloc_obj(struct o2net_msg, GFP_ATOMIC);

fs/ocfs2/cluster/tcp.c

1083

vec[0].iov_len = sizeof(struct o2net_msg);

fs/ocfs2/cluster/tcp.c

1100

sizeof(struct o2net_msg) + caller_bytes);

fs/ocfs2/cluster/tcp.c

114

static struct o2net_msg *o2net_keep_req, *o2net_keep_resp;

fs/ocfs2/cluster/tcp.c

1146

static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,

fs/ocfs2/cluster/tcp.c

1151

.iov_len = sizeof(struct o2net_msg),

fs/ocfs2/cluster/tcp.c

1165

return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg));

fs/ocfs2/cluster/tcp.c

1171

struct o2net_msg *hdr)

fs/ocfs2/cluster/tcp.c

1227

handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) +

fs/ocfs2/cluster/tcp.c

1337

struct o2net_msg *hdr;

fs/ocfs2/cluster/tcp.c

1363

if (sc->sc_page_off < sizeof(struct o2net_msg)) {

fs/ocfs2/cluster/tcp.c

1365

datalen = sizeof(struct o2net_msg) - sc->sc_page_off;

fs/ocfs2/cluster/tcp.c

1372

if (sc->sc_page_off == sizeof(struct o2net_msg)) {

fs/ocfs2/cluster/tcp.c

1383

if (sc->sc_page_off < sizeof(struct o2net_msg)) {

fs/ocfs2/cluster/tcp.c

1394

if (sc->sc_page_off - sizeof(struct o2net_msg) < be16_to_cpu(hdr->data_len)) {

fs/ocfs2/cluster/tcp.c

1397

datalen = (sizeof(struct o2net_msg) + be16_to_cpu(hdr->data_len)) -

fs/ocfs2/cluster/tcp.c

1406

if (sc->sc_page_off - sizeof(struct o2net_msg) == be16_to_cpu(hdr->data_len)) {

fs/ocfs2/cluster/tcp.c

2112

p += sizeof(struct o2net_msg);

fs/ocfs2/cluster/tcp.c

964

static void o2net_init_msg(struct o2net_msg *msg, u16 data_len, u16 msg_type, u32 key)

fs/ocfs2/cluster/tcp.c

966

memset(msg, 0, sizeof(struct o2net_msg));

fs/ocfs2/cluster/tcp.h

36

typedef int (o2net_msg_handler_func)(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/cluster/tcp.h

41

#define O2NET_MAX_PAYLOAD_BYTES (4096 - sizeof(struct o2net_msg))

fs/ocfs2/dlm/dlmast.c

256

int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

818

int dlm_create_lock_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

820

int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

822

int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

830

int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

953

int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

955

int dlm_assert_master_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

958

int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

960

int dlm_deref_lockres_done_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

962

int dlm_migrate_request_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

964

int dlm_mig_lockres_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

966

int dlm_master_requery_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

968

int dlm_request_all_locks_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

970

int dlm_reco_data_done_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

972

int dlm_begin_reco_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmcommon.h

974

int dlm_finalize_reco_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmconvert.c

429

int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

1095

static int dlm_query_region_handler(struct o2net_msg *msg, u32 len,

fs/ocfs2/dlm/dlmdomain.c

1272

static int dlm_query_nodeinfo_handler(struct o2net_msg *msg, u32 len,

fs/ocfs2/dlm/dlmdomain.c

130

static int dlm_query_join_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

132

static int dlm_assert_joined_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

1320

static int dlm_cancel_join_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

134

static int dlm_cancel_join_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

136

static int dlm_query_region_handler(struct o2net_msg *msg, u32 len,

fs/ocfs2/dlm/dlmdomain.c

138

static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

484

static int dlm_begin_exit_domain_handler(struct o2net_msg *msg, u32 len,

fs/ocfs2/dlm/dlmdomain.c

544

static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

789

static int dlm_query_join_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmdomain.c

909

static int dlm_assert_joined_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmlock.c

440

int dlm_create_lock_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmmaster.c

1400

int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmmaster.c

1750

int dlm_assert_master_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmmaster.c

2238

int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmmaster.c

2332

int dlm_deref_lockres_done_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmmaster.c

3088

int dlm_migrate_request_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

1343

int dlm_mig_lockres_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

1695

int dlm_master_requery_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

2753

int dlm_begin_reco_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

2885

int dlm_finalize_reco_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

811

int dlm_request_all_locks_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmrecovery.c

967

int dlm_reco_data_done_handler(struct o2net_msg *msg, u32 len, void *data,

fs/ocfs2/dlm/dlmunlock.c

389

int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,