← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to storage/archive/concurrency_test.c

Merged build changes from Antony.

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/archive/concurrency_test.c
2
2
  Just a test application for threads.
3
3
  */
4
4
#include "azio.h"
5
 
#include <drizzle.h>
6
 
#include <my_getopt.h>
7
 
#include <drizzle_version.h>
 
5
#include <libdrizzle/drizzle.h>
 
6
#include <mysys/my_getopt.h>
8
7
#include <stdio.h>
9
8
#include <stdlib.h>
10
9
#include <sys/types.h>
14
13
#include <fcntl.h>
15
14
#include <sys/time.h>
16
15
#include <pthread.h>
17
 
#include <strings.h>
 
16
#include <string.h>                             /* Pull in memset() */
18
17
#ifndef __WIN__
19
18
#include <sys/wait.h>
20
19
#endif
88
87
  if (argc > 1)
89
88
    exit(1);
90
89
 
91
 
  if (!(mysql_thread_safe()))
 
90
  if (!(drizzle_thread_safe()))
92
91
      fprintf(stderr, "This application was compiled incorrectly. Please recompile with thread support.\n");
93
92
 
94
93
  srandom(time(NULL));
138
137
  pthread_mutex_unlock(&sleeper_mutex);
139
138
 
140
139
  context= (thread_context_st *)malloc(sizeof(thread_context_st) * DEFAULT_CONCURRENCY);
141
 
  bzero(context, sizeof(thread_context_st) * DEFAULT_CONCURRENCY);
 
140
  memset(context, 0, sizeof(thread_context_st) * DEFAULT_CONCURRENCY);
142
141
 
143
142
  if (!context)
144
143
  {
195
194
  {
196
195
    struct timespec abstime;
197
196
 
198
 
    bzero(&abstime, sizeof(struct timespec));
 
197
    memset(&abstime, 0, sizeof(struct timespec));
199
198
    abstime.tv_sec= 1;
200
199
 
201
200
    pthread_cond_timedwait(&count_threshhold, &counter_mutex, &abstime);
216
215
  time_t *timer_length= (time_t *)p;
217
216
  struct timespec abstime;
218
217
 
219
 
  if (mysql_thread_init())
 
218
  if (drizzle_thread_init())
220
219
  {
221
 
    fprintf(stderr,"%s: mysql_thread_init() failed.\n",
 
220
    fprintf(stderr,"%s: drizzle_thread_init() failed.\n",
222
221
            my_progname);
223
222
    exit(1);
224
223
  }
244
243
  timer_alarm= false;
245
244
  pthread_mutex_unlock(&timer_alarm_mutex);
246
245
 
247
 
  mysql_thread_end();
 
246
  drizzle_thread_end();
248
247
 
249
248
  return 0;
250
249
}
257
256
  int error;
258
257
  azio_stream reader_handle;
259
258
 
260
 
  if (mysql_thread_init())
 
259
  if (drizzle_thread_init())
261
260
  {
262
 
    fprintf(stderr,"%s: mysql_thread_init() failed.\n", my_progname);
 
261
    fprintf(stderr,"%s: drizzle_thread_init() failed.\n", my_progname);
263
262
    exit(1);
264
263
  }
265
264
 
301
300
  pthread_mutex_unlock(&counter_mutex);
302
301
  azclose(&reader_handle);
303
302
 
304
 
  mysql_thread_end();
 
303
  drizzle_thread_end();
305
304
 
306
305
  return NULL;
307
306
}