aboutsummaryrefslogtreecommitdiff
path: root/src/interfaces/ecpg/ecpglib/data.c
diff options
context:
space:
mode:
authorBruce Momjian <bruce@momjian.us>2003-06-15 04:07:58 +0000
committerBruce Momjian <bruce@momjian.us>2003-06-15 04:07:58 +0000
commit4f70680177879501aa402d880b5099fe5df09847 (patch)
tree24bbb359248e634ca02242a6e49f3485a0dc783a /src/interfaces/ecpg/ecpglib/data.c
parentffa3bfbc30fe69cddc26bbf6b4ca548fa09e5f9c (diff)
downloadpostgresql-4f70680177879501aa402d880b5099fe5df09847.tar.gz
postgresql-4f70680177879501aa402d880b5099fe5df09847.zip
Make ecpg thread safe.
Lee Kindness
Diffstat (limited to 'src/interfaces/ecpg/ecpglib/data.c')
-rw-r--r--src/interfaces/ecpg/ecpglib/data.c8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/interfaces/ecpg/ecpglib/data.c b/src/interfaces/ecpg/ecpglib/data.c
index cae1c500d9b..8105f3a6cf3 100644
--- a/src/interfaces/ecpg/ecpglib/data.c
+++ b/src/interfaces/ecpg/ecpglib/data.c
@@ -1,5 +1,6 @@
-/* $Header: /cvsroot/pgsql/src/interfaces/ecpg/ecpglib/data.c,v 1.4 2003/04/01 14:37:25 meskes Exp $ */
+/* $Header: /cvsroot/pgsql/src/interfaces/ecpg/ecpglib/data.c,v 1.5 2003/06/15 04:07:58 momjian Exp $ */
+#define POSTGRES_ECPG_INTERNAL
#include "postgres_fe.h"
#include <stdlib.h>
@@ -21,6 +22,7 @@ ECPGget_data(const PGresult *results, int act_tuple, int act_field, int lineno,
char *var, char *ind, long varcharsize, long offset,
long ind_offset, bool isarray)
{
+ struct sqlca_t *sqlca = ECPGget_sqlca();
char *pval = (char *) PQgetvalue(results, act_tuple, act_field);
ECPGlog("ECPGget_data line %d: RESULT: %s offset: %ld\n", lineno, pval ? pval : "", offset);
@@ -328,7 +330,7 @@ ECPGget_data(const PGresult *results, int act_tuple, int act_field, int lineno,
default:
break;
}
- sqlca.sqlwarn[0] = sqlca.sqlwarn[1] = 'W';
+ sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
}
}
break;
@@ -373,7 +375,7 @@ ECPGget_data(const PGresult *results, int act_tuple, int act_field, int lineno,
default:
break;
}
- sqlca.sqlwarn[0] = sqlca.sqlwarn[1] = 'W';
+ sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
variable->len = varcharsize;
}