diff options
| author | bernard <[email protected]> | 2017-11-02 13:50:42 +0800 |
|---|---|---|
| committer | bernard <[email protected]> | 2017-11-02 13:50:42 +0800 |
| commit | b2057f506a09e2adef81fc77efd697d16ae14bec (patch) | |
| tree | 3affefabfe376a0ec1b3ac4a5eef957c1dd58dc8 /components/external/SQLite-3.8.1/test/threadtest2.c | |
| parent | 23582c8129228b4961ad35319cfd2d270039345f (diff) | |
[External] Remove external from RT-Thread
Diffstat (limited to 'components/external/SQLite-3.8.1/test/threadtest2.c')
| -rw-r--r-- | components/external/SQLite-3.8.1/test/threadtest2.c | 133 |
1 files changed, 0 insertions, 133 deletions
diff --git a/components/external/SQLite-3.8.1/test/threadtest2.c b/components/external/SQLite-3.8.1/test/threadtest2.c deleted file mode 100644 index 25b1d908d2..0000000000 --- a/components/external/SQLite-3.8.1/test/threadtest2.c +++ /dev/null @@ -1,133 +0,0 @@ -/* -** 2004 January 13 -** -** The author disclaims copyright to this source code. In place of -** a legal notice, here is a blessing: -** -** May you do good and not evil. -** May you find forgiveness for yourself and forgive others. -** May you share freely, never taking more than you give. -** -************************************************************************* -** This file implements a simple standalone program used to test whether -** or not the SQLite library is threadsafe. -** -** This file is NOT part of the standard SQLite library. It is used for -** testing only. -*/ -#include <stdio.h> -#include <unistd.h> -#include <pthread.h> -#include <string.h> -#include <stdlib.h> -#include "sqlite.h" - -/* -** Name of the database -*/ -#define DB_FILE "test.db" - -/* -** When this variable becomes non-zero, all threads stop -** what they are doing. -*/ -volatile int all_stop = 0; - -/* -** Callback from the integrity check. If the result is anything other -** than "ok" it means the integrity check has failed. Set the "all_stop" -** global variable to stop all other activity. Print the error message -** or print OK if the string "ok" is seen. -*/ -int check_callback(void *pid, int argc, char **argv, char **notUsed2){ - int id = (int)pid; - if( strcmp(argv[0],"ok") ){ - all_stop = 1; - fprintf(stderr,"id: %s\n", id, argv[0]); - }else{ - /* fprintf(stderr,"%d: OK\n", id); */ - } - return 0; -} - -/* -** Do an integrity check on the database. If the first integrity check -** fails, try it a second time. -*/ -int integrity_check(sqlite *db, int id){ - int rc; - if( all_stop ) return 0; - /* fprintf(stderr,"%d: CHECK\n", id); */ - rc = sqlite3_exec(db, "pragma integrity_check", check_callback, 0, 0); - if( rc!=SQLITE_OK && rc!=SQLITE_BUSY ){ - fprintf(stderr,"%d, Integrity check returns %d\n", id, rc); - } - if( all_stop ){ - sqlite3_exec(db, "pragma integrity_check", check_callback, 0, 0); - } - return 0; -} - -/* -** This is the worker thread -*/ -void *worker(void *workerArg){ - sqlite *db; - int id = (int)workerArg; - int rc; - int cnt = 0; - fprintf(stderr, "Starting worker %d\n", id); - while( !all_stop && cnt++<10000 ){ - if( cnt%100==0 ) printf("%d: %d\n", id, cnt); - while( (sqlite3_open(DB_FILE, &db))!=SQLITE_OK ) sched_yield(); - sqlite3_exec(db, "PRAGMA synchronous=OFF", 0, 0, 0); - /* integrity_check(db, id); */ - if( all_stop ){ sqlite3_close(db); break; } - /* fprintf(stderr, "%d: BEGIN\n", id); */ - rc = sqlite3_exec(db, "INSERT INTO t1 VALUES('bogus data')", 0, 0, 0); - /* fprintf(stderr, "%d: END rc=%d\n", id, rc); */ - sqlite3_close(db); - } - fprintf(stderr, "Worker %d finished\n", id); - return 0; -} - -/* -** Initialize the database and start the threads -*/ -int main(int argc, char **argv){ - sqlite *db; - int i, rc; - pthread_t aThread[5]; - - if( strcmp(DB_FILE,":memory:") ){ - char *zJournal = sqlite3_mprintf("%s-journal", DB_FILE); - unlink(DB_FILE); - unlink(zJournal); - sqlite3_free(zJournal); - } - sqlite3_open(DB_FILE, &db); - if( db==0 ){ - fprintf(stderr,"unable to initialize database\n"); - exit(1); - } - rc = sqlite3_exec(db, "CREATE TABLE t1(x);", 0,0,0); - if( rc ){ - fprintf(stderr,"cannot create table t1: %d\n", rc); - exit(1); - } - sqlite3_close(db); - for(i=0; i<sizeof(aThread)/sizeof(aThread[0]); i++){ - pthread_create(&aThread[i], 0, worker, (void*)i); - } - for(i=0; i<sizeof(aThread)/sizeof(aThread[i]); i++){ - pthread_join(aThread[i], 0); - } - if( !all_stop ){ - printf("Everything seems ok.\n"); - return 0; - }else{ - printf("We hit an error.\n"); - return 1; - } -} |
