mirror of
https://github.com/RT-Thread/rt-thread.git
synced 2026-09-25 22:34:19 +08:00
[example] 格式化整理
This commit is contained in:
Meco Man
+33
-33
@@ -11,46 +11,46 @@
|
||||
#include <dirent.h>
|
||||
int libc_dirent()
|
||||
{
|
||||
DIR * dirp;
|
||||
long int save3 = 0;
|
||||
long int cur;
|
||||
int i = 0;
|
||||
int result = 0;
|
||||
struct dirent *dp;
|
||||
DIR * dirp;
|
||||
long int save3 = 0;
|
||||
long int cur;
|
||||
int i = 0;
|
||||
int result = 0;
|
||||
struct dirent *dp;
|
||||
|
||||
dirp = opendir("/");
|
||||
for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp))
|
||||
{
|
||||
/* save position 3 (after fourth entry) */
|
||||
if (i++ == 3)
|
||||
save3 = telldir(dirp);
|
||||
dirp = opendir("/");
|
||||
for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp))
|
||||
{
|
||||
/* save position 3 (after fourth entry) */
|
||||
if (i++ == 3)
|
||||
save3 = telldir(dirp);
|
||||
|
||||
printf("%s\n", dp->d_name);
|
||||
printf("%s\n", dp->d_name);
|
||||
|
||||
/* stop at 400 (just to make sure dirp->__offset and dirp->__size are
|
||||
scrambled */
|
||||
if (i == 400)
|
||||
break;
|
||||
}
|
||||
/* stop at 400 (just to make sure dirp->__offset and dirp->__size are
|
||||
scrambled */
|
||||
if (i == 400)
|
||||
break;
|
||||
}
|
||||
|
||||
printf("going back past 4-th entry...\n");
|
||||
printf("going back past 4-th entry...\n");
|
||||
|
||||
/* go back to saved entry */
|
||||
seekdir(dirp, save3);
|
||||
/* go back to saved entry */
|
||||
seekdir(dirp, save3);
|
||||
|
||||
/* Check whether telldir equals to save3 now. */
|
||||
cur = telldir(dirp);
|
||||
if (cur != save3)
|
||||
{
|
||||
printf("seekdir (d, %ld); telldir (d) == %ld\n", save3, cur);
|
||||
result = 1;
|
||||
}
|
||||
/* Check whether telldir equals to save3 now. */
|
||||
cur = telldir(dirp);
|
||||
if (cur != save3)
|
||||
{
|
||||
printf("seekdir (d, %ld); telldir (d) == %ld\n", save3, cur);
|
||||
result = 1;
|
||||
}
|
||||
|
||||
/* print remaining files (3-last) */
|
||||
for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp))
|
||||
printf("%s\n", dp->d_name);
|
||||
/* print remaining files (3-last) */
|
||||
for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp))
|
||||
printf("%s\n", dp->d_name);
|
||||
|
||||
closedir(dirp);
|
||||
return result;
|
||||
closedir(dirp);
|
||||
return result;
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_dirent, dirent test for libc);
|
||||
|
||||
+4
-4
@@ -10,9 +10,9 @@
|
||||
|
||||
int libc_env()
|
||||
{
|
||||
printf("PATH=%s\n", getenv("PATH"));
|
||||
putenv("foo=bar");
|
||||
printf("foo=%s\n", getenv("foo"));
|
||||
return 0;
|
||||
printf("PATH=%s\n", getenv("PATH"));
|
||||
putenv("foo=bar");
|
||||
printf("foo=%s\n", getenv("foo"));
|
||||
return 0;
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_env, get/set_env test);
|
||||
|
||||
+17
-17
@@ -9,29 +9,29 @@
|
||||
|
||||
static void *process(void * arg)
|
||||
{
|
||||
int i;
|
||||
printf("Starting process %s\n", (char *)arg);
|
||||
for (i = 0; i < 10000; i++)
|
||||
write(1, (char *) arg, 1);
|
||||
return NULL;
|
||||
int i;
|
||||
printf("Starting process %s\n", (char *)arg);
|
||||
for (i = 0; i < 10000; i++)
|
||||
write(1, (char *) arg, 1);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
#define sucfail(r) (r != 0 ? "failed" : "succeeded")
|
||||
int libc_ex1(void)
|
||||
{
|
||||
int pret, ret = 0;
|
||||
pthread_t th_a, th_b;
|
||||
void *retval;
|
||||
int pret, ret = 0;
|
||||
pthread_t th_a, th_b;
|
||||
void *retval;
|
||||
|
||||
ret += (pret = pthread_create(&th_a, NULL, process, (void *)"a"));
|
||||
printf("create a %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_create(&th_b, NULL, process, (void *)"b"));
|
||||
printf("create b %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_join(th_a, &retval));
|
||||
printf("join a %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_join(th_b, &retval));
|
||||
printf("join b %s %d\n", sucfail(pret), pret);
|
||||
return ret;
|
||||
ret += (pret = pthread_create(&th_a, NULL, process, (void *)"a"));
|
||||
printf("create a %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_create(&th_b, NULL, process, (void *)"b"));
|
||||
printf("create b %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_join(th_a, &retval));
|
||||
printf("join a %s %d\n", sucfail(pret), pret);
|
||||
ret += (pret = pthread_join(th_b, &retval));
|
||||
printf("join b %s %d\n", sucfail(pret), pret);
|
||||
return ret;
|
||||
}
|
||||
#include <finsh.h>
|
||||
FINSH_FUNCTION_EXPORT(libc_ex1, example 1 for libc);
|
||||
|
||||
+19
-19
@@ -7,31 +7,31 @@
|
||||
#define usleep rt_thread_sleep
|
||||
|
||||
static void *test_thread(void *v_param) {
|
||||
return NULL;
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int libc_ex6(void) {
|
||||
unsigned long count;
|
||||
unsigned long count;
|
||||
|
||||
setvbuf(stdout, NULL, _IONBF, 0);
|
||||
setvbuf(stdout, NULL, _IONBF, 0);
|
||||
|
||||
for (count = 0; count < 2000; ++count) {
|
||||
pthread_t thread;
|
||||
int status;
|
||||
for (count = 0; count < 2000; ++count) {
|
||||
pthread_t thread;
|
||||
int status;
|
||||
|
||||
status = pthread_create(&thread, NULL, test_thread, NULL);
|
||||
if (status != 0) {
|
||||
printf("status = %d, count = %lu: %s\n", status, count, strerror(
|
||||
errno));
|
||||
return 1;
|
||||
} else {
|
||||
printf("count = %lu\n", count);
|
||||
}
|
||||
/* pthread_detach (thread); */
|
||||
pthread_join(thread, NULL);
|
||||
usleep(10);
|
||||
}
|
||||
return 0;
|
||||
status = pthread_create(&thread, NULL, test_thread, NULL);
|
||||
if (status != 0) {
|
||||
printf("status = %d, count = %lu: %s\n", status, count, strerror(
|
||||
errno));
|
||||
return 1;
|
||||
} else {
|
||||
printf("count = %lu\n", count);
|
||||
}
|
||||
/* pthread_detach (thread); */
|
||||
pthread_join(thread, NULL);
|
||||
usleep(10);
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
#include <finsh.h>
|
||||
FINSH_FUNCTION_EXPORT(libc_ex6, example 6 for libc);
|
||||
|
||||
+60
-60
@@ -14,88 +14,88 @@
|
||||
|
||||
/* Our event variable using a condition variable contruct. */
|
||||
typedef struct {
|
||||
pthread_mutex_t mutex;
|
||||
pthread_cond_t cond;
|
||||
int flag;
|
||||
pthread_mutex_t mutex;
|
||||
pthread_cond_t cond;
|
||||
int flag;
|
||||
} event_t;
|
||||
|
||||
/* Global event to signal main thread the timeout of the child thread. */
|
||||
event_t main_event;
|
||||
|
||||
static void *test_thread(void *ms_param) {
|
||||
int status = 0;
|
||||
event_t foo;
|
||||
struct timespec time;
|
||||
struct timeval now;
|
||||
long ms = (long) ms_param;
|
||||
int status = 0;
|
||||
event_t foo;
|
||||
struct timespec time;
|
||||
struct timeval now;
|
||||
long ms = (long) ms_param;
|
||||
|
||||
/* initialize cond var */
|
||||
pthread_cond_init(&foo.cond, NULL);
|
||||
pthread_mutex_init(&foo.mutex, NULL);
|
||||
foo.flag = 0;
|
||||
/* initialize cond var */
|
||||
pthread_cond_init(&foo.cond, NULL);
|
||||
pthread_mutex_init(&foo.mutex, NULL);
|
||||
foo.flag = 0;
|
||||
|
||||
/* set the time out value */
|
||||
printf("waiting %ld ms ...\n", ms);
|
||||
gettimeofday(&now, NULL);
|
||||
time.tv_sec = now.tv_sec + ms / 1000 + (now.tv_usec + (ms % 1000) * 1000)
|
||||
/ 1000000;
|
||||
time.tv_nsec = ((now.tv_usec + (ms % 1000) * 1000) % 1000000) * 1000;
|
||||
/* set the time out value */
|
||||
printf("waiting %ld ms ...\n", ms);
|
||||
gettimeofday(&now, NULL);
|
||||
time.tv_sec = now.tv_sec + ms / 1000 + (now.tv_usec + (ms % 1000) * 1000)
|
||||
/ 1000000;
|
||||
time.tv_nsec = ((now.tv_usec + (ms % 1000) * 1000) % 1000000) * 1000;
|
||||
|
||||
/* Just use this to test the time out. The cond var is never signaled. */
|
||||
pthread_mutex_lock(&foo.mutex);
|
||||
while (foo.flag == 0 && status != ETIMEDOUT) {
|
||||
status = pthread_cond_timedwait(&foo.cond, &foo.mutex, &time);
|
||||
}
|
||||
pthread_mutex_unlock(&foo.mutex);
|
||||
/* Just use this to test the time out. The cond var is never signaled. */
|
||||
pthread_mutex_lock(&foo.mutex);
|
||||
while (foo.flag == 0 && status != ETIMEDOUT) {
|
||||
status = pthread_cond_timedwait(&foo.cond, &foo.mutex, &time);
|
||||
}
|
||||
pthread_mutex_unlock(&foo.mutex);
|
||||
|
||||
/* post the main event */
|
||||
pthread_mutex_lock(&main_event.mutex);
|
||||
main_event.flag = 1;
|
||||
pthread_cond_signal(&main_event.cond);
|
||||
pthread_mutex_unlock(&main_event.mutex);
|
||||
/* post the main event */
|
||||
pthread_mutex_lock(&main_event.mutex);
|
||||
main_event.flag = 1;
|
||||
pthread_cond_signal(&main_event.cond);
|
||||
pthread_mutex_unlock(&main_event.mutex);
|
||||
|
||||
/* that's it, bye */
|
||||
return (void*) status;
|
||||
/* that's it, bye */
|
||||
return (void*) status;
|
||||
}
|
||||
|
||||
int libc_ex7(void) {
|
||||
unsigned long count;
|
||||
unsigned long count;
|
||||
|
||||
setvbuf(stdout, NULL, _IONBF, 0);
|
||||
setvbuf(stdout, NULL, _IONBF, 0);
|
||||
|
||||
/* initialize main event cond var */
|
||||
pthread_cond_init(&main_event.cond, NULL);
|
||||
pthread_mutex_init(&main_event.mutex, NULL);
|
||||
main_event.flag = 0;
|
||||
/* initialize main event cond var */
|
||||
pthread_cond_init(&main_event.cond, NULL);
|
||||
pthread_mutex_init(&main_event.mutex, NULL);
|
||||
main_event.flag = 0;
|
||||
|
||||
for (count = 0; count < 20; ++count) {
|
||||
pthread_t thread;
|
||||
int status;
|
||||
for (count = 0; count < 20; ++count) {
|
||||
pthread_t thread;
|
||||
int status;
|
||||
|
||||
/* pass down the milli-second timeout in the void* param */
|
||||
status = pthread_create(&thread, NULL, test_thread, (void*) (count
|
||||
* 100));
|
||||
if (status != 0) {
|
||||
printf("status = %d, count = %lu: %s\n", status, count, strerror(
|
||||
errno));
|
||||
return 1;
|
||||
} else {
|
||||
/* pass down the milli-second timeout in the void* param */
|
||||
status = pthread_create(&thread, NULL, test_thread, (void*) (count
|
||||
* 100));
|
||||
if (status != 0) {
|
||||
printf("status = %d, count = %lu: %s\n", status, count, strerror(
|
||||
errno));
|
||||
return 1;
|
||||
} else {
|
||||
|
||||
/* wait for the event posted by the child thread */
|
||||
pthread_mutex_lock(&main_event.mutex);
|
||||
while (main_event.flag == 0) {
|
||||
pthread_cond_wait(&main_event.cond, &main_event.mutex);
|
||||
}
|
||||
main_event.flag = 0;
|
||||
pthread_mutex_unlock(&main_event.mutex);
|
||||
/* wait for the event posted by the child thread */
|
||||
pthread_mutex_lock(&main_event.mutex);
|
||||
while (main_event.flag == 0) {
|
||||
pthread_cond_wait(&main_event.cond, &main_event.mutex);
|
||||
}
|
||||
main_event.flag = 0;
|
||||
pthread_mutex_unlock(&main_event.mutex);
|
||||
|
||||
printf("count = %lu\n", count);
|
||||
}
|
||||
printf("count = %lu\n", count);
|
||||
}
|
||||
|
||||
usleep(10);
|
||||
}
|
||||
usleep(10);
|
||||
}
|
||||
|
||||
return 0;
|
||||
return 0;
|
||||
}
|
||||
#include <finsh.h>
|
||||
FINSH_FUNCTION_EXPORT(libc_ex7, example 7 for libc);
|
||||
|
||||
+451
-451
File diff suppressed because it is too large
Load Diff
+27
-27
@@ -12,45 +12,45 @@
|
||||
static int errors = 0;
|
||||
static void merror(const char *msg)
|
||||
{
|
||||
++errors;
|
||||
printf("Error: %s\n", msg);
|
||||
++errors;
|
||||
printf("Error: %s\n", msg);
|
||||
}
|
||||
|
||||
int libc_mem(void)
|
||||
{
|
||||
void *p;
|
||||
int save;
|
||||
void *p;
|
||||
int save;
|
||||
|
||||
errno = 0;
|
||||
errno = 0;
|
||||
|
||||
p = malloc(-1);
|
||||
save = errno;
|
||||
p = malloc(-1);
|
||||
save = errno;
|
||||
|
||||
if (p != NULL)
|
||||
merror("malloc (-1) succeeded.");
|
||||
if (p != NULL)
|
||||
merror("malloc (-1) succeeded.");
|
||||
|
||||
if (p == NULL && save != ENOMEM)
|
||||
merror("errno is not set correctly");
|
||||
if (p == NULL && save != ENOMEM)
|
||||
merror("errno is not set correctly");
|
||||
|
||||
p = malloc(10);
|
||||
if (p == NULL)
|
||||
merror("malloc (10) failed.");
|
||||
p = malloc(10);
|
||||
if (p == NULL)
|
||||
merror("malloc (10) failed.");
|
||||
|
||||
/* realloc (p, 0) == free (p). */
|
||||
p = realloc(p, 0);
|
||||
if (p != NULL)
|
||||
merror("realloc (p, 0) failed.");
|
||||
/* realloc (p, 0) == free (p). */
|
||||
p = realloc(p, 0);
|
||||
if (p != NULL)
|
||||
merror("realloc (p, 0) failed.");
|
||||
|
||||
p = malloc(0);
|
||||
if (p == NULL)
|
||||
{
|
||||
printf("malloc(0) returns NULL\n");
|
||||
}
|
||||
p = malloc(0);
|
||||
if (p == NULL)
|
||||
{
|
||||
printf("malloc(0) returns NULL\n");
|
||||
}
|
||||
|
||||
p = realloc(p, 0);
|
||||
if (p != NULL)
|
||||
merror("realloc (p, 0) failed.");
|
||||
p = realloc(p, 0);
|
||||
if (p != NULL)
|
||||
merror("realloc (p, 0) failed.");
|
||||
|
||||
return errors != 0;
|
||||
return errors != 0;
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_mem, memory test for libc);
|
||||
|
||||
+81
-81
@@ -7,113 +7,113 @@
|
||||
|
||||
#define MQ_NAME_1 "testmsg1"
|
||||
#define MQ_NAME_2 "testmsg2"
|
||||
#define MSG_SIZE 128
|
||||
#define MAX_MSG 3
|
||||
#define MSG_SIZE 128
|
||||
#define MAX_MSG 3
|
||||
|
||||
const char *s_msg_ptr[] = {"msg test 1", "msg test 2", "msg test 3"};
|
||||
char r_msg_ptr_1[MAX_MSG][MSG_SIZE];
|
||||
char r_msg_ptr_2[MAX_MSG][MSG_SIZE];
|
||||
pthread_t send1, send2, rev1, rev2;
|
||||
|
||||
int * send_1(void * mq)
|
||||
int * send_1(void * mq)
|
||||
{
|
||||
int i;
|
||||
mqd_t mq1 = *(mqd_t *)mq;
|
||||
int i;
|
||||
mqd_t mq1 = *(mqd_t *)mq;
|
||||
|
||||
printf("Enter into send_1 \n");
|
||||
for (i = 0; i < MAX_MSG; i++ ) {
|
||||
if ( -1 == mq_send(mq1, s_msg_ptr[i], MSG_SIZE, i)) {
|
||||
perror("mq_send doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] send '%s' in thread send_1. \n", i+1, s_msg_ptr[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
printf("Enter into send_1 \n");
|
||||
for (i = 0; i < MAX_MSG; i++ ) {
|
||||
if ( -1 == mq_send(mq1, s_msg_ptr[i], MSG_SIZE, i)) {
|
||||
perror("mq_send doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] send '%s' in thread send_1. \n", i+1, s_msg_ptr[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
|
||||
}
|
||||
|
||||
int * send_2(void * mq)
|
||||
int * send_2(void * mq)
|
||||
{
|
||||
int i;
|
||||
mqd_t mq2 = *(mqd_t *)mq;
|
||||
int i;
|
||||
mqd_t mq2 = *(mqd_t *)mq;
|
||||
|
||||
printf("Enter into send_2 \n");
|
||||
for (i = 0; i < MAX_MSG; i++ ) {
|
||||
if ( -1 == mq_send(mq2, s_msg_ptr[i], MSG_SIZE, i)) {
|
||||
perror("mq_send doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] send '%s' in thread send_2. \n", i+1, s_msg_ptr[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
printf("Enter into send_2 \n");
|
||||
for (i = 0; i < MAX_MSG; i++ ) {
|
||||
if ( -1 == mq_send(mq2, s_msg_ptr[i], MSG_SIZE, i)) {
|
||||
perror("mq_send doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] send '%s' in thread send_2. \n", i+1, s_msg_ptr[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
}
|
||||
|
||||
int * receive_1(void * mq)
|
||||
int * receive_1(void * mq)
|
||||
{
|
||||
int i;
|
||||
mqd_t mq1 = *(mqd_t *)mq;
|
||||
int i;
|
||||
mqd_t mq1 = *(mqd_t *)mq;
|
||||
|
||||
printf("Enter into receive_1 \n");
|
||||
for (i = 0; i< MAX_MSG; i++) {
|
||||
if ( -1 == mq_receive(mq1, r_msg_ptr_1[i], MSG_SIZE, NULL) ) {
|
||||
perror("mq_receive doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] receive '%s' in thread receive_1. \n", i+1, r_msg_ptr_1[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
printf("Enter into receive_1 \n");
|
||||
for (i = 0; i< MAX_MSG; i++) {
|
||||
if ( -1 == mq_receive(mq1, r_msg_ptr_1[i], MSG_SIZE, NULL) ) {
|
||||
perror("mq_receive doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] receive '%s' in thread receive_1. \n", i+1, r_msg_ptr_1[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
}
|
||||
int * receive_2(void * mq)
|
||||
int * receive_2(void * mq)
|
||||
{
|
||||
int i;
|
||||
mqd_t mq2 = *(mqd_t *)mq;
|
||||
int i;
|
||||
mqd_t mq2 = *(mqd_t *)mq;
|
||||
|
||||
printf("Enter into receive_2 \n");
|
||||
for (i = 0; i< MAX_MSG; i++) {
|
||||
if ( -1 == mq_receive(mq2, r_msg_ptr_2[i], MSG_SIZE, NULL) ) {
|
||||
perror("mq_receive doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] receive '%s' in thread receive_2. \n", i+1, r_msg_ptr_2[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
printf("Enter into receive_2 \n");
|
||||
for (i = 0; i< MAX_MSG; i++) {
|
||||
if ( -1 == mq_receive(mq2, r_msg_ptr_2[i], MSG_SIZE, NULL) ) {
|
||||
perror("mq_receive doesn't return success \n");
|
||||
pthread_exit((void *)1);
|
||||
}
|
||||
printf("[%d] receive '%s' in thread receive_2. \n", i+1, r_msg_ptr_2[i]);
|
||||
}
|
||||
pthread_exit((void *)0);
|
||||
}
|
||||
|
||||
int libc_mq()
|
||||
{
|
||||
mqd_t mq1 = 0, mq2 = 0;
|
||||
struct mq_attr mqstat;
|
||||
int oflag = O_CREAT|O_RDWR;
|
||||
mqd_t mq1 = 0, mq2 = 0;
|
||||
struct mq_attr mqstat;
|
||||
int oflag = O_CREAT|O_RDWR;
|
||||
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
mqstat.mq_maxmsg = MAX_MSG;
|
||||
mqstat.mq_msgsize = MSG_SIZE;
|
||||
mqstat.mq_flags = 0;
|
||||
|
||||
if( ((mqd_t) -1) == (mq1 = mq_open(MQ_NAME_1,oflag,0777, &mqstat)) ) {
|
||||
printf("mq_open doesn't return success \n");
|
||||
return -1;
|
||||
}
|
||||
if( ((mqd_t) -1) == (mq2 = mq_open(MQ_NAME_2,oflag,0777, &mqstat)) ) {
|
||||
printf("mq_open doesn't return success \n");
|
||||
return -1;
|
||||
}
|
||||
pthread_create(&send1, NULL, (void *)send_1, (void *)&mq1);
|
||||
pthread_create(&send2, NULL, (void *)send_2, (void *)&mq2);
|
||||
pthread_create(&rev1, NULL, (void *)receive_1, (void *)&mq1);
|
||||
pthread_create(&rev2, NULL, (void *)receive_2, (void *)&mq2);
|
||||
pthread_join(send1, NULL);
|
||||
pthread_join(send2, NULL);
|
||||
pthread_join(rev1, NULL);
|
||||
pthread_join(rev2, NULL);
|
||||
|
||||
mq_close(mq1);
|
||||
mq_close(mq2);
|
||||
mq_unlink(MQ_NAME_1);
|
||||
mq_unlink(MQ_NAME_2);
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
mqstat.mq_maxmsg = MAX_MSG;
|
||||
mqstat.mq_msgsize = MSG_SIZE;
|
||||
mqstat.mq_flags = 0;
|
||||
|
||||
printf("PASSED\n");
|
||||
return 0;
|
||||
if( ((mqd_t) -1) == (mq1 = mq_open(MQ_NAME_1,oflag,0777, &mqstat)) ) {
|
||||
printf("mq_open doesn't return success \n");
|
||||
return -1;
|
||||
}
|
||||
if( ((mqd_t) -1) == (mq2 = mq_open(MQ_NAME_2,oflag,0777, &mqstat)) ) {
|
||||
printf("mq_open doesn't return success \n");
|
||||
return -1;
|
||||
}
|
||||
pthread_create(&send1, NULL, (void *)send_1, (void *)&mq1);
|
||||
pthread_create(&send2, NULL, (void *)send_2, (void *)&mq2);
|
||||
pthread_create(&rev1, NULL, (void *)receive_1, (void *)&mq1);
|
||||
pthread_create(&rev2, NULL, (void *)receive_2, (void *)&mq2);
|
||||
pthread_join(send1, NULL);
|
||||
pthread_join(send2, NULL);
|
||||
pthread_join(rev1, NULL);
|
||||
pthread_join(rev2, NULL);
|
||||
|
||||
mq_close(mq1);
|
||||
mq_close(mq2);
|
||||
mq_unlink(MQ_NAME_1);
|
||||
mq_unlink(MQ_NAME_2);
|
||||
|
||||
printf("PASSED\n");
|
||||
return 0;
|
||||
}
|
||||
#include <finsh.h>
|
||||
FINSH_FUNCTION_EXPORT(libc_mq, posix mqueue test);
|
||||
|
||||
+27
-27
@@ -142,59 +142,59 @@ int printf_test()
|
||||
int i;
|
||||
|
||||
printf ("snprintf (\"%%30s\", \"foo\") == %d, \"%.*s\"\n",
|
||||
snprintf (buf, sizeof (buf), "%30s", "foo"), (int) sizeof (buf),
|
||||
buf);
|
||||
snprintf (buf, sizeof (buf), "%30s", "foo"), (int) sizeof (buf),
|
||||
buf);
|
||||
memset(buf2,0,sizeof(buf));
|
||||
i=snprintf(buf2, 256, "%.9999u", 10);
|
||||
printf("%i %i\n",i,strlen(buf2));
|
||||
|
||||
printf ("snprintf (\"%%.999999u\", 10) == %d\n",
|
||||
snprintf(buf2, sizeof(buf2), "%.999999u", 10));
|
||||
snprintf(buf2, sizeof(buf2), "%.999999u", 10));
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
void libc_printf()
|
||||
{
|
||||
printf("stdout test!!\n");
|
||||
fprintf(stdout, "fprintf test!!\n");
|
||||
fprintf(stderr, "fprintf test!!\n");
|
||||
puts("puts test!!\n");
|
||||
printf("stdout test!!\n");
|
||||
fprintf(stdout, "fprintf test!!\n");
|
||||
fprintf(stderr, "fprintf test!!\n");
|
||||
puts("puts test!!\n");
|
||||
|
||||
putc('1', stderr);
|
||||
putc('2', stderr);
|
||||
putc('\n', stderr);
|
||||
putc('1', stderr);
|
||||
putc('2', stderr);
|
||||
putc('\n', stderr);
|
||||
|
||||
printf_test();
|
||||
printf_test();
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_printf, printf test in libc);
|
||||
|
||||
|
||||
void libc_dprintf()
|
||||
{
|
||||
int fd;
|
||||
int fd;
|
||||
|
||||
fd = open("/dev/console", O_WRONLY, 0);
|
||||
if (fd >0)
|
||||
{
|
||||
dprintf(fd, "fd:%d printf test!!\n", fd);
|
||||
close(fd);
|
||||
}
|
||||
fd = open("/dev/console", O_WRONLY, 0);
|
||||
if (fd >0)
|
||||
{
|
||||
dprintf(fd, "fd:%d printf test!!\n", fd);
|
||||
close(fd);
|
||||
}
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_dprintf, dprintf test);
|
||||
|
||||
|
||||
void libc_fdopen()
|
||||
{
|
||||
int fd;
|
||||
FILE* fp;
|
||||
int fd;
|
||||
FILE* fp;
|
||||
|
||||
fd = open("/dev/console", O_WRONLY, 0);
|
||||
if (fd >0)
|
||||
{
|
||||
fp = fdopen(fd, "w");
|
||||
fprintf(fp, "fdopen test, fd %d!!\n", fileno(fp));
|
||||
fclose(fp);
|
||||
}
|
||||
fd = open("/dev/console", O_WRONLY, 0);
|
||||
if (fd >0)
|
||||
{
|
||||
fp = fdopen(fd, "w");
|
||||
fprintf(fp, "fdopen test, fd %d!!\n", fileno(fp));
|
||||
fclose(fp);
|
||||
}
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_fdopen, fdopen test);
|
||||
|
||||
+28
-28
@@ -10,34 +10,34 @@
|
||||
|
||||
int libc_rand(void)
|
||||
{
|
||||
int i1, i2;
|
||||
int j1, j2;
|
||||
int i1, i2;
|
||||
int j1, j2;
|
||||
|
||||
/* The C standard says that "If rand is called before any calls to
|
||||
srand have been made, the same sequence shall be generated as
|
||||
when srand is first called with a seed value of 1." */
|
||||
i1 = rand();
|
||||
i2 = rand();
|
||||
srand(1);
|
||||
j1 = rand();
|
||||
j2 = rand();
|
||||
if (i1 < 0 || i2 < 0 || j1 < 0 || j2 < 0)
|
||||
{
|
||||
puts("Test FAILED!");
|
||||
}
|
||||
if (j1 == i1 && j2 == i2)
|
||||
{
|
||||
puts("Test succeeded.");
|
||||
return 0;
|
||||
}
|
||||
else
|
||||
{
|
||||
if (j1 != i1)
|
||||
printf("%d != %d\n", j1, i1);
|
||||
if (j2 != i2)
|
||||
printf("%d != %d\n", j2, i2);
|
||||
puts("Test FAILED!");
|
||||
return 1;
|
||||
}
|
||||
/* The C standard says that "If rand is called before any calls to
|
||||
srand have been made, the same sequence shall be generated as
|
||||
when srand is first called with a seed value of 1." */
|
||||
i1 = rand();
|
||||
i2 = rand();
|
||||
srand(1);
|
||||
j1 = rand();
|
||||
j2 = rand();
|
||||
if (i1 < 0 || i2 < 0 || j1 < 0 || j2 < 0)
|
||||
{
|
||||
puts("Test FAILED!");
|
||||
}
|
||||
if (j1 == i1 && j2 == i2)
|
||||
{
|
||||
puts("Test succeeded.");
|
||||
return 0;
|
||||
}
|
||||
else
|
||||
{
|
||||
if (j1 != i1)
|
||||
printf("%d != %d\n", j1, i1);
|
||||
if (j2 != i2)
|
||||
printf("%d != %d\n", j2, i2);
|
||||
puts("Test FAILED!");
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_rand, rand test for libc);
|
||||
|
||||
+41
-41
@@ -5,61 +5,61 @@
|
||||
static sem_t sema;
|
||||
static void* other_thread()
|
||||
{
|
||||
printf("other_thread here!\n");
|
||||
printf("other_thread here!\n");
|
||||
|
||||
sleep(1);
|
||||
sleep(1);
|
||||
|
||||
while (1)
|
||||
{
|
||||
printf("other_thread: sem_post...\n");
|
||||
if(sem_post(&sema) == -1)
|
||||
printf("sem_post failed\n");
|
||||
sleep(1);
|
||||
}
|
||||
|
||||
printf("other_thread dies!\n");
|
||||
pthread_exit(0);
|
||||
while (1)
|
||||
{
|
||||
printf("other_thread: sem_post...\n");
|
||||
if(sem_post(&sema) == -1)
|
||||
printf("sem_post failed\n");
|
||||
sleep(1);
|
||||
}
|
||||
|
||||
printf("other_thread dies!\n");
|
||||
pthread_exit(0);
|
||||
}
|
||||
|
||||
static void test_thread(void* parameter)
|
||||
{
|
||||
pthread_t tid;
|
||||
pthread_t tid;
|
||||
|
||||
printf("main thread here!\n");
|
||||
printf("sleep 5 seconds...");
|
||||
sleep(5);
|
||||
printf("done\n");
|
||||
printf("main thread here!\n");
|
||||
printf("sleep 5 seconds...");
|
||||
sleep(5);
|
||||
printf("done\n");
|
||||
|
||||
sem_init(&sema, 0, 0);
|
||||
|
||||
/* create the "other" thread */
|
||||
if(pthread_create(&tid, 0, &other_thread, 0)!=0)
|
||||
/* error */
|
||||
printf("pthread_create OtherThread failed.\n");
|
||||
else
|
||||
printf("created OtherThread=%x\n", tid);
|
||||
sem_init(&sema, 0, 0);
|
||||
|
||||
/* let the other thread run */
|
||||
while (1)
|
||||
{
|
||||
printf("Main: sem_wait...\n");
|
||||
if(sem_wait(&sema) == -1)
|
||||
printf("sem_wait failed\n");
|
||||
printf("Main back.\n\n");
|
||||
}
|
||||
/* create the "other" thread */
|
||||
if(pthread_create(&tid, 0, &other_thread, 0)!=0)
|
||||
/* error */
|
||||
printf("pthread_create OtherThread failed.\n");
|
||||
else
|
||||
printf("created OtherThread=%x\n", tid);
|
||||
|
||||
pthread_exit(0);
|
||||
/* let the other thread run */
|
||||
while (1)
|
||||
{
|
||||
printf("Main: sem_wait...\n");
|
||||
if(sem_wait(&sema) == -1)
|
||||
printf("sem_wait failed\n");
|
||||
printf("Main back.\n\n");
|
||||
}
|
||||
|
||||
pthread_exit(0);
|
||||
}
|
||||
#include <finsh.h>
|
||||
void libc_sem()
|
||||
{
|
||||
rt_thread_t tid;
|
||||
rt_thread_t tid;
|
||||
|
||||
tid = rt_thread_create("semtest", test_thread, RT_NULL,
|
||||
2048, 20, 5);
|
||||
if (tid != RT_NULL)
|
||||
{
|
||||
rt_thread_startup(tid);
|
||||
}
|
||||
tid = rt_thread_create("semtest", test_thread, RT_NULL,
|
||||
2048, 20, 5);
|
||||
if (tid != RT_NULL)
|
||||
{
|
||||
rt_thread_startup(tid);
|
||||
}
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(libc_sem, posix semaphore test);
|
||||
|
||||
@@ -11,14 +11,14 @@
|
||||
|
||||
int speed()
|
||||
{
|
||||
int i;
|
||||
time_t t;
|
||||
int i;
|
||||
time_t t;
|
||||
|
||||
printf("%d\n", time(0));
|
||||
for (i = 0; i < 10000000; ++i)
|
||||
t = time(0);
|
||||
printf("%d\n", time(0));
|
||||
for (i = 0; i < 10000000; ++i)
|
||||
t = time(0);
|
||||
|
||||
printf("%d\n", time(0));
|
||||
return 0;
|
||||
printf("%d\n", time(0));
|
||||
return 0;
|
||||
}
|
||||
FINSH_FUNCTION_EXPORT(speed, speed test);
|
||||
|
||||
Reference in New Issue
Block a user