Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion contrib/extprotocol/expected/exttableext.out
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ NOTICE: foreign table "exttabtest_options_r" does not exist, skipping
SELECT * FROM exttabtest_options_r
EXCEPT ALL
SELECT * FROM exttabtest;
ERROR: This is greenplum. (gpextprotocol.c:56)
ERROR: This is greenplum. (gpextprotocol.c:67)
CONTEXT: External table exttabtest_options_r, line 1 of file demoprot://exttabtest.txt
DROP EXTERNAL TABLE IF EXISTS exttabtest_w;
NOTICE: foreign table "exttabtest_w" does not exist, skipping
Expand Down
11 changes: 11 additions & 0 deletions contrib/extprotocol/gpextprotocol.c
Original file line number Diff line number Diff line change
@@ -1,3 +1,14 @@
/*-------------------------------------------------------------------------
*
* gpextprotocol.c
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
* IDENTIFICATION
* contrib/extprotocol/gpextprotocol.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
#include "fmgr.h"
#include "funcapi.h"
Expand Down
6 changes: 3 additions & 3 deletions contrib/interconnect/ic_common.h
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
/*-------------------------------------------------------------------------
* ic_common.c
* ic_common.h
* Interconnect code shared between UDP, and TCP IPC Layers.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* contrib/interconnect/ic_common.c
* contrib/interconnect/ic_common.h
*
*-------------------------------------------------------------------------
*/
Expand Down Expand Up @@ -140,4 +140,4 @@ extern TupleRemapper * GetMotionConnTupleRemapper(ChunkTransportState *transport
int16 targetRoute);


#endif
#endif
4 changes: 2 additions & 2 deletions contrib/interconnect/ic_internal.h
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
/*-------------------------------------------------------------------------
* interconnect_internal.h
* ic_internal.h
* Motion IPC Layer.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* contrib/interconnect/interconnect_internal.h
* contrib/interconnect/ic_internal.h
*
*-------------------------------------------------------------------------
*/
Expand Down
6 changes: 3 additions & 3 deletions contrib/interconnect/ic_modules.c
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
/*-------------------------------------------------------------------------
* interconnect.c
* ic_modules.c
* Interconnect code shared between UDP, and TCP IPC Layers.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* contrib/interconnect/interconnect.c
* contrib/interconnect/ic_modules.c
*
*-------------------------------------------------------------------------
*/
Expand Down Expand Up @@ -162,4 +162,4 @@ _PG_init(void)
errmsg("could not decide interconnect type")));
}

}
}
6 changes: 3 additions & 3 deletions contrib/interconnect/ic_modules.h
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
/*-------------------------------------------------------------------------
* interconnect.h
* ic_modules.h
* Motion IPC Layer.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* contrib/interconnect/interconnect.h
* contrib/interconnect/ic_modules.h
*
*-------------------------------------------------------------------------
*/
Expand All @@ -21,4 +21,4 @@ extern MotionIPCLayer udpifc_ipc_layer;

extern void _PG_init(void);

#endif // INTER_CONNECT_H
#endif // INTER_CONNECT_H
1 change: 1 addition & 0 deletions contrib/interconnect/proxy/ic_proxy_backend.c
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
* Note that the backend setup part of ic-proxy has been implemented by libuv
* loop. Data flow send/recv and connection tear down is still based on ic-tcp.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Copyright (c) 2020-Present VMware, Inc. or its affiliates.
*
*
Expand Down
3 changes: 2 additions & 1 deletion contrib/interconnect/tcp/ic_tcp.c
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,11 @@
*
* Portions Copyright (c) 2005-2008, Greenplum, Inc.
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* src/backend/cdb/motion/ic_tcp.c
* contrib/interconnect/tcp/ic_tcp.c
*
*-------------------------------------------------------------------------
*/
Expand Down
3 changes: 2 additions & 1 deletion contrib/interconnect/udp/ic_udpifc.c
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,14 @@
* ic_udpifc.c
* Interconnect code specific to UDP transport.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 2005-2011, Greenplum Inc.
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Copyright (c) 2011-2012, EMC Corporation
*
*
* IDENTIFICATION
* src/backend/cdb/motion/ic_udpifc.c
* contrib/interconnect/udp/ic_udpifc.c
*
*-------------------------------------------------------------------------
*/
Expand Down
4 changes: 2 additions & 2 deletions contrib/interconnect/udp/ic_udpifc.h
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
/*-------------------------------------------------------------------------
* ic_udp.h
* ic_udpifc.h
* Motion IPC UDP implements.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
* contrib/interconnect/udp/ic_udp.h
* contrib/interconnect/udp/ic_udpifc.h
*
*-------------------------------------------------------------------------
*/
Expand Down
11 changes: 11 additions & 0 deletions contrib/pgcrypto/sm3.h
Original file line number Diff line number Diff line change
@@ -1,3 +1,14 @@
/*-------------------------------------------------------------------------
*
* sm3.h
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
* IDENTIFICATION
* contrib/pgcrypto/sm3.h
*
*-------------------------------------------------------------------------
*/
#ifndef _SM3_H_
#define _SM3_H_

Expand Down
11 changes: 11 additions & 0 deletions contrib/pgcrypto/sm4.c
Original file line number Diff line number Diff line change
@@ -1,3 +1,14 @@
/*-------------------------------------------------------------------------
*
* sm4.c
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
* IDENTIFICATION
* contrib/pgcrypto/sm4.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
#include "sm4.h"
#include "px.h"
Expand Down
11 changes: 11 additions & 0 deletions gpcontrib/gp_inject_fault/gp_inject_fault.c
Original file line number Diff line number Diff line change
@@ -1,3 +1,14 @@
/*-------------------------------------------------------------------------
*
* gp_inject_fault.c
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
* IDENTIFICATION
* gpcontrib/gp_inject_fault/gp_inject_fault.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"

#include "access/heapam.h"
Expand Down
13 changes: 12 additions & 1 deletion gpcontrib/gp_replica_check/gp_replica_check.c
Original file line number Diff line number Diff line change
@@ -1,3 +1,14 @@
/*-------------------------------------------------------------------------
*
* gp_replica_check.c
*
* Portions Copyright (c) 2023, HashData Technology Limited.
*
* IDENTIFICATION
* gpcontrib/gp_replica_check/gp_replica_check.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"

#include "access/heapam.h"
Expand Down Expand Up @@ -57,7 +68,7 @@ extern Datum gp_replica_check(PG_FUNCTION_ARGS);

typedef struct RelfilenodeEntry
{
RelFileNodeId relfilenode;
RelFileNodeId relfilenode;
Oid relam;
int relkind;
char relname[NAMEDATALEN];
Expand Down
1 change: 1 addition & 0 deletions src/backend/access/aocs/aocsam.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* aocsam.c
* Append only columnar access methods
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 2009-2010, Greenplum Inc.
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/access/appendonly/appendonlyam.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
* Portions Copyright (c) 1994, Regents of the University of California
* Portions Copyright (c) 2008-2009, Greenplum Inc.
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Portions Copyright (c) 2023, HashData Technology Limited.
*
*
* IDENTIFICATION
Expand Down
7 changes: 4 additions & 3 deletions src/backend/access/gin/ginfast.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
* transfer pending entries into the regular index structure. This
* wins because bulk insertion is much more efficient than retail.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down Expand Up @@ -307,7 +308,7 @@ ginHeapTupleFastInsert(GinState *ginstate, GinTupleCollector *collector)
metadata->nPendingHeapTuples = sublist.nPendingHeapTuples;

if (needWal)
XLogBeginInsert();
XLogBeginInsert();
}
else
{
Expand Down Expand Up @@ -337,8 +338,8 @@ ginHeapTupleFastInsert(GinState *ginstate, GinTupleCollector *collector)

if (needWal)
{
XLogBeginInsert();
XLogRegisterBuffer(1, buffer, REGBUF_STANDARD);
XLogBeginInsert();
XLogRegisterBuffer(1, buffer, REGBUF_STANDARD);
}
}
}
Expand Down
3 changes: 2 additions & 1 deletion src/backend/access/transam/clog.c
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
* for aborts (whether sync or async), since the post-crash assumption would
* be that such transactions failed anyway.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down Expand Up @@ -1146,4 +1147,4 @@ SlruCtl
CLOG_Ctl(void)
{
return XactCtl;
}
}
3 changes: 2 additions & 1 deletion src/backend/access/transam/distributedlog.c
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
* distributed transaction identifier -- the timestamp -- also so we can
* be sure which distributed transaction we are looking at.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
Comment thread
tuhaihe marked this conversation as resolved.
* Portions Copyright (c) 2007-2008, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
*
Expand Down Expand Up @@ -1091,4 +1092,4 @@ SlruCtl
DistributedLog_Ctl(void)
{
return DistributedLogCtl;
}
}
7 changes: 4 additions & 3 deletions src/backend/access/transam/varsup.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* varsup.c
* postgres OID & XID variables support routines
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Copyright (c) 2000-2021, PostgreSQL Global Development Group
*
* IDENTIFICATION
Expand Down Expand Up @@ -700,7 +701,7 @@ AdvanceObjectId(Oid newOid)
static RelFileNodeId
GetNewSegRelfilenodeUnderLock(void)
{
RelFileNodeId result;
RelFileNodeId result;

Assert(LWLockHeldByMe(RelfilenodeGenLock));

Expand All @@ -719,7 +720,7 @@ GetNewSegRelfilenodeUnderLock(void)
}

if (NewSegRelfilenode_assign_hook)
return (*NewSegRelfilenode_assign_hook) ();
return (*NewSegRelfilenode_assign_hook) ();

result = ShmemVariableCache->nextRelfilenode;

Expand All @@ -740,7 +741,7 @@ GetNewSegRelfilenodeUnderLock(void)
RelFileNodeId
GetNewSegRelfilenode(void)
{
RelFileNodeId result;
RelFileNodeId result;

LWLockAcquire(RelfilenodeGenLock, LW_EXCLUSIVE);

Expand Down
1 change: 1 addition & 0 deletions src/backend/access/transam/xlog.c
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
* PostgreSQL write-ahead log manager
*
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/access/transam/xloginsert.c
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
* of XLogRecData structs by a call to XLogRecordAssemble(). See
* access/transam/README for details.
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/access/transam/xlogutils.c
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
* None of this code is used during normal system operation.
*
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 2006-2008, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
Expand Down
1 change: 1 addition & 0 deletions src/backend/catalog/index.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* index.c
* code to create and destroy POSTGRES index relations
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 2006-2009, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
Expand Down
1 change: 1 addition & 0 deletions src/backend/catalog/storage.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* storage.c
* code to create and destroy physical storage for relations
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/cdb/dispatcher/cdbgang.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* cdbgang.c
* Query Executor Factory for gangs of QEs
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 2005-2008, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/cdb/motion/ic_proxy_bgworker.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
* This is only a wrapper, the actual main loop is in ic_proxy_main.c .
*
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Copyright (c) 2020-Present VMware, Inc. or its affiliates.
*
*
Expand Down
1 change: 1 addition & 0 deletions src/backend/executor/functions.c
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
* functions.c
* Execution of SQL-language functions
*
* Portions Copyright (c) 2023, HashData Technology Limited.
* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
Expand Down
Loading