syscalls.c 8.1 KB
Newer Older
1 2 3 4 5
#include <reent.h>
#include <sys/errno.h>
#include <sys/time.h>
#include <rtthread.h>

6 7
#include <stdio.h>

B
Bernard Xiong 已提交
8 9 10 11 12 13 14 15
#ifdef RT_USING_DFS
#include <dfs_posix.h>
#endif

#ifdef RT_USING_PTHREADS 
#include <pthread.h>
#endif

16
/* Reentrant versions of system calls.  */
17 18
static int __console_fd = -1;
int dump = 0;
19 20 21 22

int
_close_r(struct _reent *ptr, int fd)
{
23 24 25
#ifndef RT_USING_DFS
	return 0;
#else
26
	return close(fd);
27
#endif
28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96
}

int
_execve_r(struct _reent *ptr, const char * name, char *const *argv, char *const *env)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_fcntl_r(struct _reent *ptr, int fd, int cmd, int arg)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_fork_r(struct _reent *ptr)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_fstat_r(struct _reent *ptr, int fd, struct stat *pstat)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_getpid_r(struct _reent *ptr)
{
	return 0;
}

int
_isatty_r(struct _reent *ptr, int fd)
{
	if (fd >=0 && fd < 3) return 1;

	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_kill_r(struct _reent *ptr, int pid, int sig)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_link_r(struct _reent *ptr, const char *old, const char *new)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

_off_t
_lseek_r(struct _reent *ptr, int fd, _off_t pos, int whence)
{
97
#ifndef RT_USING_DFS
98 99
	return 0;
#else
100 101 102 103
	_off_t rc;

	rc = lseek(fd, pos, whence);
	return rc;
104
#endif
105 106 107 108 109
}

int
_mkdir_r(struct _reent *ptr, const char *name, int mode)
{
110 111 112
#ifndef RT_USING_DFS
	return 0;
#else
113 114 115 116
	int rc;

	rc = mkdir(name, mode);
	return rc;
117
#endif
118 119 120 121 122
}

int
_open_r(struct _reent *ptr, const char *file, int flags, int mode)
{
123 124 125
#ifndef RT_USING_DFS
	return 0;
#else
126 127 128 129
	int rc;

	rc = open(file, flags, mode);
	return rc;
130
#endif
131 132 133 134 135
}

_ssize_t 
_read_r(struct _reent *ptr, int fd, void *buf, size_t nbytes)
{
136 137 138
#ifndef RT_USING_DFS
	return 0;
#else
139 140 141 142
	_ssize_t rc;

	rc = read(fd, buf, nbytes);
	return rc;
143
#endif
144 145 146 147 148
}

int
_rename_r(struct _reent *ptr, const char *old, const char *new)
{
149 150 151
#ifndef RT_USING_DFS
	return 0;
#else
152 153 154 155
	int rc;

	rc = rename(old, new);
	return rc;
156
#endif
157 158 159 160 161 162 163 164 165 166 167 168
}

void *
_sbrk_r(struct _reent *ptr, ptrdiff_t incr)
{
	/* no use this routine to get memory */
	return RT_NULL;
}

int
_stat_r(struct _reent *ptr, const char *file, struct stat *pstat)
{
169 170 171
#ifndef RT_USING_DFS
	return 0;
#else
172 173 174 175
	int rc;

	rc = stat(file, pstat);
	return rc;
176
#endif
177 178 179 180 181 182 183 184 185 186 187 188 189
}

_CLOCK_T_
_times_r(struct _reent *ptr, struct tms *ptms)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

int
_unlink_r(struct _reent *ptr, const char *file)
{
190 191 192
#ifndef RT_USING_DFS
	return 0;
#else
193 194 195 196
	int rc;

	rc = unlink(file);
	return rc;
197
#endif
198 199 200 201 202 203 204 205 206 207
}

int
_wait_r(struct _reent *ptr, int *status)
{
	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}

208
#ifdef RT_USING_DEVICE
209 210 211
_ssize_t
_write_r(struct _reent *ptr, int fd, const void *buf, size_t nbytes)
{
212
	if (fd == __console_fd)
213 214 215 216 217 218 219 220
	{
		rt_device_t console_device;
		extern rt_device_t rt_console_get_device(void);

		console_device = rt_console_get_device();
		if (console_device != 0) rt_device_write(console_device, 0, buf, nbytes);
		return nbytes;
	}
221 222
	else
	{
223
#ifdef RT_USING_DFS
224
	    _ssize_t rc;
225

226 227
	    rc = write(fd, buf, nbytes);
	    return rc;
228 229 230
#else
        return 0;
#endif
231
	}
232
}
233
#endif
234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254

#ifndef RT_USING_PTHREADS

#ifndef MILLISECOND_PER_SECOND
#define MILLISECOND_PER_SECOND	1000UL
#endif

#ifndef MICROSECOND_PER_SECOND
#define MICROSECOND_PER_SECOND	1000000UL
#endif

#ifndef NANOSECOND_PER_SECOND
#define NANOSECOND_PER_SECOND	1000000000UL
#endif

#define MILLISECOND_PER_TICK	(MILLISECOND_PER_SECOND / RT_TICK_PER_SECOND)
#define MICROSECOND_PER_TICK	(MICROSECOND_PER_SECOND / RT_TICK_PER_SECOND)
#define NANOSECOND_PER_TICK		(NANOSECOND_PER_SECOND  / RT_TICK_PER_SECOND)


struct timeval _timevalue = {0};
255 256
#ifdef RT_USING_DEVICE
static void libc_system_time_init(void)
257
{
258 259 260 261 262 263 264 265
	time_t time;
	rt_tick_t tick;
	rt_device_t device;

	time = 0;
	device = rt_device_find("rtc");
	if (device != RT_NULL)
	{
266
		/* get realtime seconds */
267 268
		rt_device_control(device, RT_DEVICE_CTRL_RTC_GET_TIME, &time);
	}
269 270

	/* get tick */
271
	tick = rt_tick_get();
272

273 274
	_timevalue.tv_usec = MICROSECOND_PER_SECOND - (tick%RT_TICK_PER_SECOND) * MICROSECOND_PER_TICK;
	_timevalue.tv_sec = time - tick/RT_TICK_PER_SECOND - 1;
275
}
276
#endif
277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295

int libc_get_time(struct timespec *time)
{
	rt_tick_t tick;
	static rt_bool_t inited = 0;

	RT_ASSERT(time != RT_NULL);

	/* initialize system time */
	if (inited == 0)
	{
		libc_system_time_init();
		inited = 1;
	}

	/* get tick */
	tick = rt_tick_get();

	time->tv_sec = _timevalue.tv_sec + tick / RT_TICK_PER_SECOND;
W
weety 已提交
296
	time->tv_nsec = (_timevalue.tv_usec + (tick % RT_TICK_PER_SECOND) * MICROSECOND_PER_TICK) * 1000;
297 298 299 300 301 302 303 304 305 306 307 308 309 310

	return 0;
}

int
_gettimeofday_r(struct _reent *ptr, struct timeval *__tp, void *__tzp)
{
	struct timespec tp;

	if (libc_get_time(&tp) == 0)
	{
		if (__tp != RT_NULL)
		{
			__tp->tv_sec  = tp.tv_sec;
W
weety 已提交
311
			__tp->tv_usec = tp.tv_nsec / 1000UL;
312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333
		}

		return tp.tv_sec;
	}

	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}
#else
/* POSIX thread provides clock_gettime function */
#include <time.h>
int
_gettimeofday_r(struct _reent *ptr, struct timeval *__tp, void *__tzp)
{
	struct timespec tp;

	if (clock_gettime(CLOCK_REALTIME, &tp) == 0)
	{
		if (__tp != RT_NULL)
		{
			__tp->tv_sec  = tp.tv_sec;
W
weety 已提交
334
			__tp->tv_usec = tp.tv_nsec / 1000UL;
335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396
		}

		return tp.tv_sec;
	}

	/* return "not supported" */
	ptr->_errno = ENOTSUP;
	return -1;
}
#endif

/* Memory routine */
void *
_malloc_r (struct _reent *ptr, size_t size)
{
	void* result;

	result = (void*)rt_malloc (size);
	if (result == RT_NULL)
	{
		ptr->_errno = ENOMEM;
	}

	return result;
}

void *
_realloc_r (struct _reent *ptr, void *old, size_t newlen)
{
	void* result;

	result = (void*)rt_realloc (old, newlen);
	if (result == RT_NULL)
	{
		ptr->_errno = ENOMEM;
	}

	return result;
}

void *_calloc_r (struct _reent *ptr, size_t size, size_t len)
{
	void* result;

	result = (void*)rt_calloc (size, len);
	if (result == RT_NULL)
	{
		ptr->_errno = ENOMEM;
	}

	return result;
}

void 
_free_r (struct _reent *ptr, void *addr)
{
	rt_free (addr);
}

void
_exit (int status)
{
397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432
#ifdef RT_USING_MODULE
	rt_module_t module;

	module = rt_module_self();
	if (module != RT_NULL)
	{
		struct rt_list_node *list;
		struct rt_object *object;

		rt_enter_critical();
		
        /* delete all threads in the module */
        list = &module->module_object[RT_Object_Class_Thread].object_list;
        while (list->next != list)
        {
            object = rt_list_entry(list->next, struct rt_object, list);
            if (rt_object_is_systemobject(object) == RT_TRUE)
            {
                /* detach static object */
                rt_thread_detach((rt_thread_t)object);
            }
            else
            {
                /* delete dynamic object */
                rt_thread_delete((rt_thread_t)object);
            }
        }
		/* delete main thread */
		rt_thread_delete(module->module_thread);
		rt_exit_critical();

		/* re-schedule */
		rt_schedule();
	}
#endif
	
433
	rt_kprintf("thread:%s exit with %d\n", rt_thread_self()->name, status);
434
	RT_ASSERT(0);
435

436
	while (1);
437
}
438 439 440 441 442 443 444

void 
_system(const char *s)
{
    /* not support this call */
    return;
}
445 446 447 448 449

void __libc_init_array(void)
{
	/* we not use __libc init_aray to initialize C++ objects */
}
450 451 452

void abort(void)
{
453 454 455 456 457 458 459 460 461 462 463
    if (rt_thread_self())
    {
        rt_thread_t self = rt_thread_self();

        rt_kprintf("thread:%-8.*s abort!\n", RT_NAME_MAX, self->name);
        rt_thread_suspend(self);

        rt_schedule();
    }

	while (1);
464
}
465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485

int libc_console_init(void)
{
    /* open console as stdin/stdout/stderr */
    __console_fd = open("/dev/console", O_RDWR, 0); /* for stdin/stdout/stderr */

	if (__console_fd >= 0)
	{
		_GLOBAL_REENT->_stdin   = fdopen(__console_fd, "r");

		_GLOBAL_REENT->_stdout  = fdopen(__console_fd, "w");
		setvbuf(_GLOBAL_REENT->_stdout, NULL, _IONBF, 0);
		_GLOBAL_REENT->_stderr  = fdopen(__console_fd, "w");
		setvbuf(_GLOBAL_REENT->_stderr, NULL, _IONBF, 0);

		_GLOBAL_REENT->__sdidinit = 1;
	}

    return 0;
}
INIT_APP_EXPORT(libc_console_init);