PostgreSQL Source Code  git master
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros
thread-alloc.c
Go to the documentation of this file.
1 /* Processed by ecpg (regression mode) */
2 /* These include files are added by the preprocessor */
3 #include <ecpglib.h>
4 #include <ecpgerrno.h>
5 #include <sqlca.h>
6 /* End of automatic include section */
7 #define ECPGdebug(X,Y) ECPGdebug((X)+100,(Y))
8 
9 #line 1 "alloc.pgc"
10 #include <stdlib.h>
11 #include "ecpg_config.h"
12 
13 #ifndef ENABLE_THREAD_SAFETY
14 int
15 main(void)
16 {
17  printf("No threading enabled.\n");
18  return 0;
19 }
20 #else
21 #ifdef WIN32
22 #define WIN32_LEAN_AND_MEAN
23 #include <windows.h>
24 #include <process.h>
25 #include <locale.h>
26 #else
27 #include <pthread.h>
28 #endif
29 #include <stdio.h>
30 
31 #define THREADS 16
32 #define REPEATS 50
33 
34 
35 #line 1 "sqlca.h"
36 #ifndef POSTGRES_SQLCA_H
37 #define POSTGRES_SQLCA_H
38 
39 #ifndef PGDLLIMPORT
40 #if defined(WIN32) || defined(__CYGWIN__)
41 #define PGDLLIMPORT __declspec (dllimport)
42 #else
43 #define PGDLLIMPORT
44 #endif /* __CYGWIN__ */
45 #endif /* PGDLLIMPORT */
46 
47 #define SQLERRMC_LEN 150
48 
49 #ifdef __cplusplus
50 extern "C"
51 {
52 #endif
53 
54 struct sqlca_t
55 {
56  char sqlcaid[8];
57  long sqlabc;
58  long sqlcode;
59  struct
60  {
61  int sqlerrml;
62  char sqlerrmc[SQLERRMC_LEN];
63  } sqlerrm;
64  char sqlerrp[8];
65  long sqlerrd[6];
66  /* Element 0: empty */
67  /* 1: OID of processed tuple if applicable */
68  /* 2: number of rows processed */
69  /* after an INSERT, UPDATE or */
70  /* DELETE statement */
71  /* 3: empty */
72  /* 4: empty */
73  /* 5: empty */
74  char sqlwarn[8];
75  /* Element 0: set to 'W' if at least one other is 'W' */
76  /* 1: if 'W' at least one character string */
77  /* value was truncated when it was */
78  /* stored into a host variable. */
79 
80  /*
81  * 2: if 'W' a (hopefully) non-fatal notice occurred
82  */ /* 3: empty */
83  /* 4: empty */
84  /* 5: empty */
85  /* 6: empty */
86  /* 7: empty */
87 
88  char sqlstate[5];
89 };
90 
91 struct sqlca_t *ECPGget_sqlca(void);
92 
93 #ifndef POSTGRES_ECPG_INTERNAL
94 #define sqlca (*ECPGget_sqlca())
95 #endif
96 
97 #ifdef __cplusplus
98 }
99 #endif
100 
101 #endif
102 
103 #line 25 "alloc.pgc"
104 
105 
106 #line 1 "regression.h"
107 
108 
109 
110 
111 
112 
113 #line 26 "alloc.pgc"
114 
115 
116 /* exec sql whenever sqlerror sqlprint ; */
117 #line 28 "alloc.pgc"
118 
119 /* exec sql whenever not found sqlprint ; */
120 #line 29 "alloc.pgc"
121 
122 
123 #ifdef WIN32
124 static unsigned __stdcall fn(void* arg)
125 #else
126 static void* fn(void* arg)
127 #endif
128 {
129  int i;
130 
131  /* exec sql begin declare section */
132 
133 
134 
135 
136 #line 40 "alloc.pgc"
137  int value ;
138 
139 #line 41 "alloc.pgc"
140  char name [ 100 ] ;
141 
142 #line 42 "alloc.pgc"
143  char ** r = NULL ;
144 /* exec sql end declare section */
145 #line 43 "alloc.pgc"
146 
147 
148 #ifdef WIN32
149 #ifdef _MSC_VER /* requires MSVC */
150  _configthreadlocale(_ENABLE_PER_THREAD_LOCALE);
151 #endif
152 #endif
153 
154  value = (long)arg;
155  sprintf(name, "Connection: %d", value);
156 
157  { ECPGconnect(__LINE__, 0, "ecpg1_regression" , NULL, NULL , name, 0);
158 #line 54 "alloc.pgc"
159 
160 if (sqlca.sqlcode < 0) sqlprint();}
161 #line 54 "alloc.pgc"
162 
163  { ECPGsetcommit(__LINE__, "on", NULL);
164 #line 55 "alloc.pgc"
165 
166 if (sqlca.sqlcode < 0) sqlprint();}
167 #line 55 "alloc.pgc"
168 
169  for (i = 1; i <= REPEATS; ++i)
170  {
171  { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "select relname from pg_class where relname = 'pg_class'", ECPGt_EOIT,
172  ECPGt_char,&(r),(long)0,(long)0,(1)*sizeof(char),
173  ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);
174 #line 58 "alloc.pgc"
175 
176 if (sqlca.sqlcode == ECPG_NOT_FOUND) sqlprint();
177 #line 58 "alloc.pgc"
178 
179 if (sqlca.sqlcode < 0) sqlprint();}
180 #line 58 "alloc.pgc"
181 
182  free(r);
183  r = NULL;
184  }
185  { ECPGdisconnect(__LINE__, name);
186 #line 62 "alloc.pgc"
187 
188 if (sqlca.sqlcode < 0) sqlprint();}
189 #line 62 "alloc.pgc"
190 
191 
192  return 0;
193 }
194 
195 int main ()
196 {
197  int i;
198 #ifdef WIN32
199  HANDLE threads[THREADS];
200 #else
201  pthread_t threads[THREADS];
202 #endif
203 
204 #ifdef WIN32
205  for (i = 0; i < THREADS; ++i)
206  {
207  unsigned id;
208  threads[i] = (HANDLE)_beginthreadex(NULL, 0, fn, (void*)i, 0, &id);
209  }
210 
211  WaitForMultipleObjects(THREADS, threads, TRUE, INFINITE);
212  for (i = 0; i < THREADS; ++i)
213  CloseHandle(threads[i]);
214 #else
215  for (i = 0; i < THREADS; ++i)
216  pthread_create(&threads[i], NULL, fn, (void *) (long) i);
217  for (i = 0; i < THREADS; ++i)
218  pthread_join(threads[i], NULL);
219 #endif
220 
221  return 0;
222 }
223 #endif
bool ECPGdisconnect(int lineno, const char *connection_name)
Definition: connect.c:669
long sqlabc
Definition: sqlca.h:22
struct sqlca_t::@124 sqlerrm
#define sqlca
Definition: sqlca.h:59
bool ECPGdo(const int lineno, const int compat, const int force_indicator, const char *connection_name, const bool questionmarks, const int st, const char *query,...)
Definition: execute.c:2030
char sqlwarn[8]
Definition: sqlca.h:39
#define THREADS
int sqlerrml
Definition: sqlca.h:26
char sqlcaid[8]
Definition: sqlca.h:21
int main(void)
Definition: thread-alloc.c:15
#define REPEATS
struct sqlca_t * ECPGget_sqlca(void)
Definition: misc.c:142
static struct @121 value
bool ECPGconnect(int lineno, int c, const char *name, const char *user, const char *passwd, const char *connection_name, int autocommit)
Definition: connect.c:271
Definition: sqlca.h:19
long sqlerrd[6]
Definition: sqlca.h:30
char sqlstate[5]
Definition: sqlca.h:53
#define ECPG_NOT_FOUND
Definition: ecpgerrno.h:10
long sqlcode
Definition: sqlca.h:23
void sqlprint(void)
Definition: error.c:336
static void * fn(void *arg)
#define free(a)
Definition: header.h:65
#define SQLERRMC_LEN
Definition: sqlca.h:12
char sqlerrp[8]
Definition: sqlca.h:29
const char * name
Definition: encode.c:521
bool ECPGsetcommit(int lineno, const char *mode, const char *connection_name)
Definition: connect.c:165
char sqlerrmc[SQLERRMC_LEN]
Definition: sqlca.h:27
int i
void * arg
#define TRUE
Definition: c.h:215
#define pthread_t
Definition: pgbench.c:79