greenplumn ic_proxy_backend 源码

  • 2022-08-18
  • 浏览 (478)

greenplumn ic_proxy_backend 代码

文件路径:/src/backend/cdb/motion/ic_proxy_backend.h

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

#ifndef IC_PROXY_BACKEND_H
#define IC_PROXY_BACKEND_H

#include "postgres.h"

#include "cdb/cdbinterconnect.h"

#include <uv.h>

/*
 * ICProxyBackendContext represents the common state of ic_proxy backend for each
 * ChunkTransportState.
 */
typedef struct ICProxyBackendContext
{
	uv_loop_t	loop;

	/* timer for interrupt */
	uv_timer_t	interruptTimer;
	uv_timer_t	cancelFromQDTimer;

	/* timer and queue for connect and reconnect */
	uv_timer_t	connectTimer;
	List	   *connectQueue;

	/* Pointer to ChunkTransportState * */
	ChunkTransportState   *transportState;
} ICProxyBackendContext;

extern void ic_proxy_backend_connect(ICProxyBackendContext *context,
									 ChunkTransportStateEntry *pEntry,
									 MotionConn *conn, bool isSender);

extern void ic_proxy_backend_init_context(ChunkTransportState *state);
extern void ic_proxy_backend_close_context(ChunkTransportState *state);
extern void ic_proxy_backend_run_loop(ICProxyBackendContext *context);

#endif   /* IC_PROXY_BACKEND_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_bgworker 源码

greenplumn ic_proxy_client 源码

greenplumn ic_proxy_iobuf 源码

0  赞