Skip to content
Closed
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
110 changes: 55 additions & 55 deletions .drone.jsonnet
Original file line number Diff line number Diff line change
Expand Up @@ -663,69 +663,69 @@ local Pipeline(branch, platform, event, arch="amd64", server="10.6-enterprise",


local AllPipelines =
[
Pipeline(b, platform, triggeringEvent, a, server, flag, "")
for a in ["amd64"]
for b in std.objectFields(platforms)
for platform in ["rockylinux:8"]
for flag in ["gcc-toolset"]
for triggeringEvent in events
for server in servers[current_branch]
] +
[
Pipeline(b, p, e, a, s)
for b in std.objectFields(platforms)
for p in platforms[b]
for s in servers[b]
for e in events
for a in archs
] +
[
Pipeline(any_branch, p, "custom", a, server)
for p in platforms[current_branch]
for server in servers[current_branch]
for a in archs
] +
// clang
[
Pipeline(b, platform, triggeringEvent, a, server, "", buildenv)
for a in ["amd64"]
for b in std.objectFields(platforms)
for platform in ["ubuntu:24.04"]
for buildenv in std.objectFields(customEnvCommandsMap)
for triggeringEvent in events
for server in servers[current_branch]
] +
// last argument is to ignore mtr and regression failures
[
Pipeline(b, platform, triggeringEvent, a, server, "", "", ["regression"])
for a in ["amd64"]
for b in std.objectFields(platforms)
for server in extra_servers[current_branch]
for platform in extra_servers_platforms[current_branch]
for triggeringEvent in events
] +
// [
// Pipeline(b, platform, triggeringEvent, a, server, flag, "")
// for a in ["amd64"]
// for b in std.objectFields(platforms)
// for platform in ["rockylinux:8"]
// for flag in ["gcc-toolset"]
// for triggeringEvent in events
// for server in servers[current_branch]
// ] +
// [
// Pipeline(b, p, e, a, s)
// for b in std.objectFields(platforms)
// for p in platforms[b]
// for s in servers[b]
// for e in events
// for a in archs
// ] +
// [
// Pipeline(any_branch, p, "custom", a, server)
// for p in platforms[current_branch]
// for server in servers[current_branch]
// for a in archs
// ] +
// // clang
// [
// Pipeline(b, platform, triggeringEvent, a, server, "", buildenv)
// for a in ["amd64"]
// for b in std.objectFields(platforms)
// for platform in ["ubuntu:24.04"]
// for buildenv in std.objectFields(customEnvCommandsMap)
// for triggeringEvent in events
// for server in servers[current_branch]
// ] +
// // last argument is to ignore mtr and regression failures
[
Pipeline(b, platform, triggeringEvent, a, server, flag, envcommand, ["regression", "mtr"])
for a in ["amd64"]
for b in std.objectFields(platforms)
for platform in ["ubuntu:24.04"]
for flag in ["libcpp"]
for envcommand in ["clang-20"]
for triggeringEvent in events
for server in servers[current_branch]
] +
// last argument is to ignore mtr and regression failures
// [
// Pipeline(b, platform, triggeringEvent, a, server, flag, "", ["regression", "mtr"])
// Pipeline(b, platform, triggeringEvent, a, server, "", "", ["regression"])
// for a in ["amd64"]
// for b in std.objectFields(platforms)
// for server in extra_servers[current_branch]
// for platform in extra_servers_platforms[current_branch]
// for triggeringEvent in events
// ] +
// // // last argument is to ignore mtr and regression failures
// [
// Pipeline(b, platform, triggeringEvent, a, server, flag, envcommand, ["regression", "mtr"])
// for a in ["amd64"]
// for b in std.objectFields(platforms)
// for platform in ["ubuntu:24.04"]
// for flag in ["ASan", "UBSan"]
// for flag in ["libcpp"]
// for envcommand in ["clang-20"]
// for triggeringEvent in events
// for server in servers[current_branch]
// ] +
// last argument is to ignore mtr and regression failures
[
Pipeline(b, platform, triggeringEvent, a, server, flag)
for a in ["amd64"]
for b in std.objectFields(platforms)
for platform in ["ubuntu:24.04"]
for flag in ["ASan", "UBSan"]
for triggeringEvent in events
for server in servers[current_branch]
] +

[];

Expand Down
6 changes: 4 additions & 2 deletions dbcon/execplan/arithmeticoperator.h
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,8 @@ class ArithmeticOperator : public Operator

#include "parsetree.h"

inline void ArithmeticOperator::evaluate(rowgroup::Row& row, bool& isNull, ParseTree* lop, ParseTree* rop)
inline __attribute__((no_sanitize("signed-integer-overflow")))
void ArithmeticOperator::evaluate(rowgroup::Row& row, bool& isNull, ParseTree* lop, ParseTree* rop)
{
// fOpType should have already been set on the connector during parsing
switch (fOperationType.colDataType)
Expand Down Expand Up @@ -327,7 +328,8 @@ inline void ArithmeticOperator::evaluate(rowgroup::Row& row, bool& isNull, Parse
}

template <typename result_t>
inline result_t ArithmeticOperator::execute(result_t op1, result_t op2, bool& isNull)
inline __attribute__((no_sanitize("signed-integer-overflow"))) result_t
ArithmeticOperator::execute(result_t op1, result_t op2, bool& isNull)
{
if (isNull)
{
Expand Down
4 changes: 2 additions & 2 deletions dbcon/execplan/selectfilter.h
Original file line number Diff line number Diff line change
Expand Up @@ -180,9 +180,9 @@ class SelectFilter : public Filter
std::vector<SRCP> fCols;
SOP fOp;
SCSEP fSub;
bool fCorrelated;
bool fCorrelated = false;
std::string fData;
uint64_t fReturnedColPos; // offset in fSub->returnedColList to indicate the start of projection
uint64_t fReturnedColPos = 0; // offset in fSub->returnedColList to indicate the start of projection
std::vector<SimpleColumn*> fSimpleColumnListExtended{};
};

Expand Down
2 changes: 1 addition & 1 deletion primitives/primproc/batchprimitiveprocessor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2467,7 +2467,7 @@ SBPP BatchPrimitiveProcessor::duplicate()
bpp->smallNullPointers = smallNullPointers;
bpp->joinedRG = joinedRG;
}
bpp->mSmallSideRGPtr = &bpp->smallSideRGs[0];
bpp->mSmallSideRGPtr = bpp->smallSideRGs.empty() ? nullptr : &bpp->smallSideRGs[0];

#ifdef __FreeBSD__
pthread_mutex_unlock(&bpp->objLock);
Expand Down
7 changes: 5 additions & 2 deletions utils/funcexp/funchelpers.h
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,8 @@ inline int power(int16_t a)
}

template <typename T>
inline void decimalPlaceDec(int64_t& d, T& p, int8_t& s)
inline __attribute__((no_sanitize("signed-integer-overflow"))) void decimalPlaceDec(int64_t& d, T& p,
int8_t& s)
{
// find new scale if D < s
if (d < s)
Expand Down Expand Up @@ -541,7 +542,9 @@ inline int getNumbers(const std::string& expr, int64_t* array, execplan::OpType
return index;
}

inline int getNumbers(const std::string& expr, int* array, execplan::OpType funcType)
inline __attribute__((no_sanitize("signed-integer-overflow"))) int getNumbers(const std::string& expr,
int* array,
execplan::OpType funcType)
{
int index = 0;

Expand Down