Path *subpath = list_nth(mtpath->subpaths, subpath_index);
	RangeTblEntry *rte = planner_rt_fetch(hypertable_rti, root);

	memcpy(&path->cpath.path, subpath, sizeof(Path));
	path->cpath.path.type = T_CustomPath;
	path->cpath.path.pathtype = T_CustomScan;
	path->cpath.methods = &chunk_dispatch_path_methods;
	path->cpath.custom_paths = list_make1(subpath);
	path->mtpath = mtpath;

            

Reported by FlawFinder.

              {
	SSLConnection *sslconn = (SSLConnection *) conn;
	const char *reason;
	static char errbuf[32];
	int err = conn->err;
	unsigned long ecode = sslconn->errcode;

	/* Clear errors */
	conn->err = 0;

            

Reported by FlawFinder.

              int
ts_plain_connect(Connection *conn, const char *host, const char *servname, int port)
{
	char strport[6];
	struct addrinfo *ainfo, hints = {
		.ai_family = AF_UNSPEC,
		.ai_socktype = SOCK_STREAM,
	};
	int ret;

            

Reported by FlawFinder.

              	int (*connect)(Connection *conn, const char *host, const char *servname, int port);
	void (*close)(Connection *conn);
	ssize_t (*write)(Connection *conn, const char *buf, size_t writelen);
	ssize_t (*read)(Connection *conn, char *buf, size_t readlen);
	int (*set_timeout)(Connection *conn, unsigned long millis);
	const char *(*errmsg)(Connection *conn);
} ConnOps;

extern int ts_connection_register(ConnectionType type, ConnOps *ops);

            

Reported by FlawFinder.

              ssize_t
ts_connection_read(Connection *conn, char *buf, size_t buflen)
{
	return conn->ops->read(conn, buf, buflen);
}

void
ts_connection_close(Connection *conn)
{

            

Reported by FlawFinder.

              ---------------------------------------------------
-- Test views and size_utils functions on distributed hypertable
---------------------------------------------------
\c :TEST_DBNAME :ROLE_CLUSTER_SUPERUSER

SET client_min_messages TO ERROR;
DROP DATABASE IF EXISTS view_node_1;
DROP DATABASE IF EXISTS view_node_2;
DROP DATABASE IF EXISTS view_node_3;

            

Reported by SQLint.

              --the correct column name 
SELECT format('%I.%I', cht.schema_name, cht.table_name) AS "COMPRESSION_TBLNM"
FROM _timescaledb_catalog.hypertable ht, _timescaledb_catalog.hypertable cht
WHERE ht.table_name = 'test1' and cht.id = ht.compressed_hypertable_id \gset

SELECT count(*) 
FROM ( SELECT attrelid::regclass, attname FROM pg_attribute 
       WHERE attrelid in (SELECT inhrelid::regclass from pg_inherits 
                          where inhparent = :'COMPRESSION_TBLNM'::regclass )

            

Reported by SQLint.

              	List *subset_nodes;
	DistCmdResult *results;
	PreparedDistCmd *prepped_cmd;
	const char *test_args[3] = { "1976-09-18 00:00:00-07", "47", "103.4" };
	ListCell *lc;

	if (data_nodes == NIL)
		elog(ERROR, "no data nodes specified");


            

Reported by FlawFinder.

              
	fd->hypertable_id =
		DatumGetInt32(values[AttrNumberGetAttrOffset(Anum_hypertable_compression_hypertable_id)]);
	memcpy(&fd->attname,
		   DatumGetName(values[AttrNumberGetAttrOffset(Anum_hypertable_compression_attname)]),
		   NAMEDATALEN);
	fd->algo_id =
		DatumGetInt16(values[AttrNumberGetAttrOffset(Anum_hypertable_compression_algo_id)]);


            

Reported by FlawFinder.

              
DROP DATABASE IF EXISTS test;
CREATE DATABASE test;
\c test
\timing

DROP EXTENSION IF EXISTS timescaledb CASCADE;
CREATE EXTENSION timescaledb;


            

Reported by SQLint.