greenplumn ic_proxy_packet 源码

2022-08-18
浏览 (371)

greenplumn ic_proxy_packet 代码

文件路径：/src/backend/cdb/motion/ic_proxy_packet.h

/*-------------------------------------------------------------------------
 *
 * ic_proxy_packet.h
 *
 *
 * Copyright (c) 2020-Present VMware, Inc. or its affiliates.
 *
 *
 *-------------------------------------------------------------------------
 */

#ifndef IC_PROXY_PACKET_H
#define IC_PROXY_PACKET_H

#include "postgres.h"

#include "cdb/cdbvars.h"

typedef struct ICProxyPkt ICProxyPkt;

/* we have to include it after the declaration of ICProxyPkt */
#include "ic_proxy_key.h"

#define IC_PROXY_MAX_PKT_SIZE (Gp_max_packet_size + sizeof(ICProxyPkt))

typedef enum
{
	IC_PROXY_MESSAGE_DATA = 0,

	/* these are peer messages */
	IC_PROXY_MESSAGE_PEER_HELLO,
	IC_PROXY_MESSAGE_PEER_HELLO_ACK,
	IC_PROXY_MESSAGE_PEER_QUIT,

	/* these are client messages */
	IC_PROXY_MESSAGE_HELLO,
	IC_PROXY_MESSAGE_HELLO_ACK,
	IC_PROXY_MESSAGE_BYE,
	IC_PROXY_MESSAGE_DATA_ACK,
} ICProxyMessageType;

struct ICProxyPkt
{
	uint16		len;
	uint16		type;

	int16		srcContentId;
	uint16		srcDbid;
	int32		srcPid;

	int16		dstContentId;
	uint16		dstDbid;
	int32		dstPid;

	int32		sessionId;
	uint32		commandId;
	int16		sendSliceIndex;
	int16		recvSliceIndex;
};

const char *ic_proxy_message_type_to_str(ICProxyMessageType type);

extern ICProxyPkt *ic_proxy_message_new(ICProxyMessageType type,
										const ICProxyKey *key);
extern void ic_proxy_message_init(ICProxyPkt *pkt,
								  ICProxyMessageType type,
								  const ICProxyKey *key);

extern ICProxyPkt *ic_proxy_pkt_new(const ICProxyKey *key,
									const void *data, uint16 size);
extern ICProxyPkt *ic_proxy_pkt_dup(const ICProxyPkt *pkt);
extern const char *ic_proxy_pkt_to_str(const ICProxyPkt *pkt);
extern bool ic_proxy_pkt_is_from_client(const ICProxyPkt *pkt,
										const ICProxyKey *key);
extern bool ic_proxy_pkt_is_to_client(const ICProxyPkt *pkt,
									  const ICProxyKey *key);
extern bool ic_proxy_pkt_is_live(const ICProxyPkt *pkt,
								 const ICProxyKey *key);
extern bool ic_proxy_pkt_is_out_of_date(const ICProxyPkt *pkt,
										const ICProxyKey *key);
extern bool ic_proxy_pkt_is_in_the_future(const ICProxyPkt *pkt,
										  const ICProxyKey *key);

static inline ICProxyMessageType
ic_proxy_message_get_type(const ICProxyPkt *pkt)
{
	return pkt->type;
}

static inline bool
ic_proxy_pkt_is(const ICProxyPkt *pkt, ICProxyMessageType type)
{
	Assert(pkt);
	Assert(pkt->len >= sizeof(*pkt));

	/* then check the message type on demand */
	return type == pkt->type;
}

#endif   /* IC_PROXY_PACKET_H */

相关信息

greenplumn 源码目录

相关文章

greenplumn cdbmotion 源码

greenplumn htupfifo 源码

greenplumn ic_common 源码

greenplumn ic_proxy 源码

greenplumn ic_proxy_addr 源码

greenplumn ic_proxy_addr 源码

greenplumn ic_proxy_backend 源码

greenplumn ic_proxy_backend 源码

greenplumn ic_proxy_bgworker 源码

greenplumn ic_proxy_client 源码

0 赞

所属分类： 大数据
本文标签： greenplum
版权声明： 原创文章如转载，请注明本文链接: https://www.seaxiang.com/blog/cb02c2b37cc949229bde5f11ac306e89

热门推荐

1、直接访问google.com
2、 - 优质文章
3、 gate.io
4、 harmony 鸿蒙hdc使用指导
5、 harmony 鸿蒙初识ArkTS语言
6、 harmony 鸿蒙ArkUI组件（ArkTS）开发常见问题
7、 flink kafka connector scan.startup.mode 的几个选项
8、 golang
9、 openharmony
10、 Vue中input框自动聚焦

Loading...