greenplumn cdbendpoint_private 源码

2022-08-18
浏览 (386)

greenplumn cdbendpoint_private 代码

文件路径：/src/backend/cdb/endpoint/cdbendpoint_private.h

/*-------------------------------------------------------------------------
 *
 * cdbendpoint_private.h
 *	  Internal routines for parallel retrieve cursor.
 *
 *
 * Copyright (c) 2020-Present VMware, Inc. or its affiliates
 *
 * src/backend/cdb/endpoints/cdbendpoint_private.h
 *
 *-------------------------------------------------------------------------
 */

#include "cdb/cdbendpoint.h"

#ifndef CDBENDPOINTINTERNAL_H
#define CDBENDPOINTINTERNAL_H

#define MAX_ENDPOINT_SIZE				1024
#define ENDPOINT_TOKEN_ARR_LEN			16
#define ENDPOINT_TOKEN_STR_LEN			(ENDPOINT_TOKEN_ARR_LEN<<1)
#define InvalidEndpointSessionId		(-1)	/* follows invalid
												 * gp_session_id */

#define ENDPOINT_KEY_TUPLE_DESC_LEN		1
#define ENDPOINT_KEY_TUPLE_DESC			2
#define ENDPOINT_KEY_TUPLE_QUEUE		3

#define ENDPOINT_MSG_QUEUE_MAGIC		0x1949100119980802U

/*
 * Naming rules for endpoint:
 * cursorname_sessionIdHex_segIndexHex
 */

/* ACK NOTICE MESSAGE FROM ENDPOINT QE/Entry DB to QD */
#define ENDPOINT_NAME_SESSIONID_LEN	8
#define ENDPOINT_NAME_COMMANDID_LEN 8
#define ENDPOINT_NAME_CURSOR_LEN   (NAMEDATALEN - 1 - ENDPOINT_NAME_SESSIONID_LEN - ENDPOINT_NAME_COMMANDID_LEN)

extern void check_parallel_retrieve_cursor_errors(EState *estate);

/* Endpoint shared memory utility functions in "cdbendpoint.c" */
extern Endpoint *get_endpointdesc_by_index(int index);
extern Endpoint *find_endpoint(const char *endpointName, int sessionID);
extern void get_token_from_session_hashtable(int sessionId, Oid userID, int8 *token /* out */ );
extern int	get_session_id_from_token(Oid userID, const int8 *token);

/* utility functions in "cdbendpointutilities.c" */
extern bool endpoint_token_hex_equals(const int8 *token1, const int8 *token2);
extern bool endpoint_name_equals(const char *name1, const char *name2);
extern void endpoint_token_str2arr(const char *tokenStr, int8 *token);
extern void endpoint_token_arr2str(const int8 *token, char *tokenStr);
extern char *state_enum_to_string(EndpointState state);

#endif							/* CDBENDPOINTINTERNAL_H */

相关信息

greenplumn 源码目录

相关文章

greenplumn cdbendpoint 源码

greenplumn cdbendpointretrieve 源码

greenplumn cdbendpointutils 源码

0 赞

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

热门推荐

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...