source: sqlite3_toppers/sqlite3/sqlite3_toppers.c@ 58

/*
 *  TOPPERS Software
 *      Toyohashi Open Platform for Embedded Real-Time Systems
 * 
 *  Copyright (C) 2013 by Kijineko Inc.
 *  Copyright (C) 2013 by Embedded and Real-Time Systems Laboratory
 *              Graduate School of Information Science, Nagoya Univ., JAPAN  
 * 
 *  上記著作権者は，以下の(1)〜(4)の条件を満たす場合に限り，本ソフトウェ
 *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
 *  変・再配布（以下，利用と呼ぶ）することを無償で許諾する．
 *  (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
 *      権表示，この利用条件および下記の無保証規定が，そのままの形でソー
 *      スコード中に含まれていること．
 *  (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
 *      用できる形で再配布する場合には，再配布に伴うドキュメント（利用
 *      者マニュアルなど）に，上記の著作権表示，この利用条件および下記
 *      の無保証規定を掲載すること．
 *  (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
 *      用できない形で再配布する場合には，次のいずれかの条件を満たすこ
 *      と．
 *    (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著
 *        作権表示，この利用条件および下記の無保証規定を掲載すること．
 *    (b) 再配布の形態を，別に定める方法によって，TOPPERSプロジェクトに
 *        報告すること．
 *  (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
 *      害からも，上記著作権者およびTOPPERSプロジェクトを免責すること．
 *      また，本ソフトウェアのユーザまたはエンドユーザからのいかなる理
 *      由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
 *      免責すること．
 * 
 *  本ソフトウェアは，無保証で提供されているものである．上記著作権者お
 *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
 *  に対する適合性も含めて，いかなる保証も行わない．また，本ソフトウェ
 *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
 *  の責任を負わない．
 * 
 *  $Id: sqlite3_toppers.c 58 2013-04-12 00:36:18Z ertl-honda $
 */

/*
 * 以下のマクロは必要に応じて定義してもしなくてもよい
 */
/* #define SQLITE_OMIT_DEPRECATED 1     // 非推奨のAPIを省略する */
/* #define SQLITE_OMIT_FLOATING_POINT 1 // 浮動小数点数を64ビット整数で代用 */
#define NO_GETTOD 1                     /* gettimeofday関数が無い */

/*
 * TOPPERS/ASPカーネルで動作させるための定義
 */
#define SQLITE_OS_UNIX 1      /* UNIX用のコードを使用 */
#define SQLITE_DISABLE_LFS 1  /* 2GBを越えるファイルは扱わない */
#define SQLITE_HOMEGROWN_RECURSIVE_MUTEX 1 /* 再帰的なミューテックスはOSではなくSQLiteの実装を使う */
#define SQLITE_OMIT_WAL 1     /* mmapによるメモリマップドファイルを使わない */
#define SQLITE_OMIT_LOAD_EXTENSION 1 /* 共有ライブラリのダイナミックローディングを用いた機能を使用しない */
#define SQLITE_OMIT_AUTHORIZATION 1 /* AUTHORIZATION機能を使わない */
#define SQLITE_UNIX_THREADS 1 /* UNIXのスレッドを使用 */
#define SQLITE_THREADSAFE 1   /* スレッドセーフに */

/* pthread.hの宣言・定義を適切なものにするため定義 */
#define _POSIX_THREADS  1   
#define _UNIX98_THREAD_MUTEX_ATTRIBUTES 1

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <pthread.h>
#include <errno.h>
#include <limits.h>

#pragma GCC diagnostic ignored "-Wunused-value"
#pragma GCC diagnostic ignored "-Wunused-variable"
#pragma GCC diagnostic ignored "-Wunused-but-set-variable"
#pragma GCC diagnostic ignored "-Wunused-function"

#ifndef TOPPERS_SQLITE_OMIT_DEFAULT_SYSCALL
#include <t_stddef.h>
#include <syssvc/serial.h>
int open(const char *file, int flags, ...) { return -1; }
int close(int fd) { return -1; }
off_t lseek(int __fildes, off_t __offset, int __whence ) { return -1; };
int kill(pid_t pid, int sig) { return -1; };
int getpid(void) { return -1; };
int access(const char *file, int mode) { return -1; }
char *getcwd(char *s, size_t n) { return NULL; }
int stat(const char *file, struct stat* pstat) { return -1; }
int fstat(int fd, struct stat* pstat) { return -1; }
int ftruncate(int fd, off_t pos) { return -1; }
int fcntrl(int fd, int cmd, ...) { return -1; }
ssize_t read(int fd, void *buf, size_t n) { return -1; }
ssize_t write(int fd, const void *buf, size_t n)
{
        if (fd == 1 || fd == 2)
                return serial_wri_dat(1, buf, n);
        return -1;
}
int fchmod(int fd, mode_t mode) { return -1; }
int unlink(const char *file) { return -1; }
int mkdir(const char *dir, mode_t mode) { return -1; }
int rmdir(const char *dir) { return -1; }
int fchown(int fd, uid_t uid, gid_t gid) { return -1; }
mode_t umask(mode_t mode) { return 022; }
#endif /*  TOPPERS_SQLITE_OMIT_DEFAULT_SYSCALL */

#include <kernel.h>
#include "kernel_cfg.h"

#if NO_GETTOD && !defined(TOPPERS_SQLITE_OMIT_DEFAULT_TIME)

time_t time(time_t *timer)
{
  if (timer != NULL)
    *timer = (time_t)-1;
  return (time_t)-1;
}

#endif  /* NO_GETTOD && !defined(TOPPERS_SQLITE_OMIT_DEFAULT_TIME) */

#if SQLITE_UNIX_THREADS && !defined(TOPPERS_SQLITE_OMIT_DEFAULT_PTHREAD)

pthread_t pthread_self(void)
{
  ID tskid = 0;
  get_tid(&tskid);
  return (pthread_t)tskid;
}

int pthread_equal(pthread_t lhs, pthread_t rhs)
{
  if (lhs < 1 || TNUM_TSKID < lhs)
    return 0;
  return lhs == rhs;
}

static ID sqlite3_toppers_mutexes[] =
{
  SQLITE_SEMID1,
  SQLITE_SEMID2,
  SQLITE_SEMID3,
  SQLITE_SEMID4,
  SQLITE_SEMID5,
  SQLITE_SEMID6,
};

int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr)
{
  size_t i;
  for (i = 0; i < sizeof(sqlite3_toppers_mutexes) / sizeof(sqlite3_toppers_mutexes[0]); i++)
  {
    if (sqlite3_toppers_mutexes[i] != 0)
    {
      *mutex = sqlite3_toppers_mutexes[i];
      sqlite3_toppers_mutexes[i] = 0;
      return 0;
    }
  }
  return -1;
}

int pthread_mutex_lock(pthread_mutex_t *mutex)
{
  ER er;
  if (*mutex == (pthread_mutex_t)PTHREAD_MUTEX_INITIALIZER)
    pthread_mutex_init(mutex, NULL);
  er = wai_sem((ID)*mutex);
  if (MERCD(er) == E_ID)
    errno = EINVAL;
  return er;
}

int pthread_mutex_trylock(pthread_mutex_t *mutex)
{
  ER er;
  if (*mutex == (pthread_mutex_t)PTHREAD_MUTEX_INITIALIZER)
    pthread_mutex_init(mutex, NULL);
  er = pol_sem((ID)*mutex);
  switch (MERCD(er))
  {
  case E_ID:
    errno = EINVAL;
    break;
  case E_TMOUT:
    errno = EBUSY;
    break;
  }
  return er;
}

int pthread_mutex_unlock(pthread_mutex_t *mutex)
{
  ER er = sig_sem((ID)*mutex);
  if (MERCD(er) == E_ID)
    errno = EINVAL;
  return er;
}

int pthread_mutex_destroy(pthread_mutex_t *mutex)
{
  size_t i;
  for (i = 0; i < sizeof(sqlite3_toppers_mutexes) / sizeof(sqlite3_toppers_mutexes[0]); i++)
  {
    if (sqlite3_toppers_mutexes[i] == 0)
    {
      sqlite3_toppers_mutexes[i] = *mutex;
      ini_sem(*mutex);
      *mutex = 0;
      return 0;
    }
  }
  
  return -1;
}

#endif  /* SQLITE_UNIX_THREADS && !defined(TOPPERS_SQLITE_OMIT_DEFAULT_PTHREAD) */

uid_t getuid(void)
{
  return 10000;
}

uid_t geteuid(void)
{
  return 10000;
}

unsigned int sleep(unsigned int t)
{
  SYSTIM t1, t2;

  get_tim(&t1);
  if (dly_tsk(t * 1000) != E_OK)
  {
    get_tim(&t2);
    return (t - (t2 - t1) + 999) / 1000;
  }
  return 0;
}

int utimes(const char *filename, const struct timeval times[2])
{
  return -1;
}

int fsync(int fd)
{
  return -1;
}

/* SQLite本体 */
#include "sqlite3.c"