You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ko...@apache.org on 2023/06/30 21:05:21 UTC
[arrow-flight-sql-postgresql] branch main updated: Format (#43)
This is an automated email from the ASF dual-hosted git repository.
kou pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-flight-sql-postgresql.git
The following commit(s) were added to refs/heads/main by this push:
new 44420c2 Format (#43)
44420c2 is described below
commit 44420c2634b5d4ae5b774e7bd5d9e03d18a4a5a1
Author: Sutou Kouhei <ko...@clear-code.com>
AuthorDate: Sat Jul 1 06:05:16 2023 +0900
Format (#43)
---
src/afs.cc | 42 +++++++++++++++++++++++++-----------------
1 file changed, 25 insertions(+), 17 deletions(-)
diff --git a/src/afs.cc b/src/afs.cc
index 8f0e778..ffefc46 100644
--- a/src/afs.cc
+++ b/src/afs.cc
@@ -649,7 +649,11 @@ class Executor : public WorkerProcessor {
void signaled()
{
- P("%s: %s: signaled: before: %d/%d", Tag, tag_, session_->selectQuery, session_->updateQuery);
+ P("%s: %s: signaled: before: %d/%d",
+ Tag,
+ tag_,
+ session_->selectQuery,
+ session_->updateQuery);
if (DsaPointerIsValid(session_->selectQuery))
{
select();
@@ -662,7 +666,11 @@ class Executor : public WorkerProcessor {
{
Processor::signaled();
}
- P("%s: %s: signaled: after: %d/%d", Tag, tag_, session_->selectQuery, session_->updateQuery);
+ P("%s: %s: signaled: after: %d/%d",
+ Tag,
+ tag_,
+ session_->selectQuery,
+ session_->updateQuery);
}
private:
@@ -914,17 +922,17 @@ class Executor : public WorkerProcessor {
switch (result)
{
- case SPI_OK_INSERT:
- case SPI_OK_DELETE:
- case SPI_OK_UPDATE:
- session_->nUpdatedRecords = SPI_processed;
- break;
- default:
- set_shared_string(session_->errorMessage,
- std::string(Tag) + ": " + tag_ + ": update" +
- ": failed to run a query: <" + query +
- ">: " + SPI_result_code_string(result));
- break;
+ case SPI_OK_INSERT:
+ case SPI_OK_DELETE:
+ case SPI_OK_UPDATE:
+ session_->nUpdatedRecords = SPI_processed;
+ break;
+ default:
+ set_shared_string(session_->errorMessage,
+ std::string(Tag) + ": " + tag_ + ": update" +
+ ": failed to run a query: <" + query +
+ ">: " + SPI_result_code_string(result));
+ break;
}
PopActiveSnapshot();
@@ -1182,7 +1190,7 @@ class Proxy : public WorkerProcessor {
}
arrow::Result<std::shared_ptr<arrow::Schema>> select(uint64_t sessionID,
- const std::string& query)
+ const std::string& query)
{
auto session = find_session(sessionID);
SessionReleaser sessionReleaser(sessions_, session);
@@ -1231,15 +1239,15 @@ class Proxy : public WorkerProcessor {
session->nUpdatedRecords = -1;
if (session->executorPID != InvalidPid)
{
- P("%s: %s: update: kill executor: %d",
- Tag, tag_, session->executorPID);
+ P("%s: %s: update: kill executor: %d", Tag, tag_, session->executorPID);
kill(session->executorPID, SIGUSR1);
}
{
std::unique_lock<std::mutex> lock(mutex_);
conditionVariable_.wait(lock, [&] {
P("%s: %s: %s: wait: update", Tag, tag_, AFS_FUNC);
- return DsaPointerIsValid(session->errorMessage) || session->nUpdatedRecords >= 0;
+ return DsaPointerIsValid(session->errorMessage) ||
+ session->nUpdatedRecords >= 0;
});
}
if (DsaPointerIsValid(session->errorMessage))