sanchayanmaity/minix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity
minix/test/ipc/msgctl/msgctl08.c
Ben Gras a4d1b17453 ipc tests by GQ
2009-09-21 14:53:53 +00:00

564 lines
13 KiB
C
Raw Blame History

/*
*
* Copyright (c) International Business Machines Corp., 2002
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See
* the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
/* 06/30/2001 Port to Linux nsharoff@us.ibm.com */
/* 11/06/2002 Port to LTP dbarrera@us.ibm.com */
/*
* NAME
* msgctl08
*
* CALLS
* msgget(2) msgctl(2)
*
* ALGORITHM
* Get and manipulate a message queue.
*
* RESTRICTIONS
*
*/
#define _XOPEN_SOURCE 500
#include <signal.h>
#include <errno.h>
#include <string.h>
#include <fcntl.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <values.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/stat.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include "test.h"
#include "usctest.h"
void setup();
void cleanup();
/*
* * * * These globals must be defined in the test.
* * * */
char *TCID="msgctl08"; /* Test program identifier. */
int TST_TOTAL=1; /* Total number of test cases. */
extern int Tst_count; /* Test Case counter for tst_* routines */
int exp_enos[]={0}; /* List must end with 0 */
#ifndef CONFIG_COLDFIRE
#define MAXNPROCS 1000000 /* This value is set to an arbitrary high limit. */
#else
#define MAXNPROCS 100000 /* Coldfire can't deal with 1000000 */
#endif
#define MAXNREPS 100000
#define FAIL 1
#define PASS 0
key_t keyarray[MAXNPROCS];
struct {
long type;
struct {
char len;
char pbytes[99];
} data;
} buffer;
int pidarray[MAXNPROCS];
int tid;
int MSGMNI,nprocs, nreps;
int procstat;
int dotest(key_t key, int child_process);
int doreader(int id, long key, int child);
int dowriter(int id,long key, int child);
int fill_buffer(register char *buf, char val, register int size);
int verify(register char *buf,char val, register int size,int child);
void sig_handler(); /* signal catching function */
int mykid;
#ifdef UCLINUX
static char *argv0;
void do_child_1_uclinux();
static key_t key_uclinux;
static int i_uclinux;
void do_child_2_uclinux();
static int id_uclinux;
static int child_process_uclinux;
#endif
/*-----------------------------------------------------------------*/
int main(argc, argv)
int argc;
char *argv[];
{
register int i, j, ok, pid;
int count, status;
struct sigaction act;
#ifdef UCLINUX
char *msg; /* message returned from parse_opts */
argv0 = argv[0];
/* parse standard options */
if ((msg = parse_opts(argc, argv, (option_t *)NULL, NULL)) != (char *)NULL)
{
tst_brkm(TBROK, cleanup, "OPTION PARSING ERROR - %s", msg);
}
maybe_run_child(&do_child_1_uclinux, "ndd", 1, &key_uclinux, &i_uclinux);
maybe_run_child(&do_child_2_uclinux, "nddd", 2, &id_uclinux, &key_uclinux,
&child_process_uclinux);
#endif
setup();
if (argc == 1 )
{
/* Set default parameters */
nreps = MAXNREPS;
nprocs = MSGMNI;
}
else if (argc == 3 )
{
if ( atoi(argv[1]) > MAXNREPS )
{
tst_resm(TCONF,"Requested number of iterations too large, setting to Max. of %d", MAXNREPS);
nreps = MAXNREPS;
}
else
{
nreps = atoi(argv[1]);
}
if (atoi(argv[2]) > MSGMNI )
{
tst_resm(TCONF,"Requested number of processes too large, setting to Max. of %d", MSGMNI);
nprocs = MSGMNI;
}
else
{
nprocs = atoi(argv[2]);
}
}
else
{
tst_resm(TCONF," Usage: %s [ number of iterations number of processes ]", argv[0]);
tst_exit();
}
srand(getpid());
tid = -1;
/* Setup signal handleing routine */
memset(&act, 0, sizeof(act));
act.sa_handler = sig_handler;
sigemptyset(&act.sa_mask);
sigaddset(&act.sa_mask, SIGTERM);
if (sigaction(SIGTERM, &act, NULL) < 0)
{
tst_resm(TFAIL, "Sigset SIGTERM failed");
tst_exit();
}
/* Set up array of unique keys for use in allocating message
* queues
*/
for (i = 0; i < nprocs; i++)
{
ok = 1;
do
{
/* Get random key */
keyarray[i] = (key_t)rand();
/* Make sure key is unique and not private */
if (keyarray[i] == IPC_PRIVATE)
{
ok = 0;
continue;
}
for (j = 0; j < i; j++)
{
if (keyarray[j] == keyarray[i])
{
ok = 0;
break;
}
ok = 1;
}
} while (ok == 0);
}
/* Fork a number of processes, each of which will
* create a message queue with one reader/writer
* pair which will read and write a number (iterations)
* of random length messages with specific values.
*/
for (i = 0; i < nprocs; i++)
{
fflush(stdout);
if ((pid = FORK_OR_VFORK()) < 0)
{
tst_resm(TFAIL, "\tFork failed (may be OK if under stress)");
tst_exit();
}
/* Child does this */
if (pid == 0)
{
#ifdef UCLINUX
if (self_exec(argv[0], "ndd", 1, keyarray[i], i) < 0)
{
tst_resm(TFAIL, "\tself_exec failed");
tst_exit();
}
#else
procstat = 1;
exit( dotest(keyarray[i], i) );
#endif
}
pidarray[i] = pid;
}
count = 0;
while(1)
{
if (( wait(&status)) > 0)
{
if (status>>8 != 0 )
{
tst_resm(TFAIL, "Child exit status = %d", status>>8);
tst_exit();
}
count++;
}
else
{
if (errno != EINTR)
{
break;
}
#ifdef DEBUG
tst_resm(TINFO,"Signal detected during wait");
#endif
}
}
/* Make sure proper number of children exited */
if (count != nprocs)
{
tst_resm(TFAIL, "Wrong number of children exited, Saw %d, Expected %d", count, nprocs);
tst_exit();
}
tst_resm(TPASS,"msgctl08 ran successfully!");
cleanup();
return (0);
}
/*--------------------------------------------------------------------*/
#ifdef UCLINUX
void
do_child_1_uclinux()
{
procstat = 1;
exit(dotest(key_uclinux, i_uclinux));
}
void
do_child_2_uclinux()
{
exit(doreader(id_uclinux, key_uclinux % 255, child_process_uclinux));
}
#endif
int dotest(key, child_process)
key_t key;
int child_process;
{
int id, pid;
sighold(SIGTERM);
TEST(msgget(key, IPC_CREAT | S_IRUSR | S_IWUSR));
if (TEST_RETURN < 0)
{
tst_resm(TFAIL, "Msgget error in child %d, errno = %d", child_process, TEST_ERRNO);
tst_exit();
}
tid = id = TEST_RETURN;
sigrelse(SIGTERM);
fflush(stdout);
if ((pid = FORK_OR_VFORK()) < 0)
{
tst_resm(TWARN, "\tFork failed (may be OK if under stress)");
TEST(msgctl(tid, IPC_RMID, 0));
if (TEST_RETURN < 0)
{
tst_resm(TFAIL, "Msgctl error in cleanup, errno = %d", errno);
}
tst_exit();
}
/* Child does this */
if (pid == 0)
{
#ifdef UCLINUX
if (self_exec(argv0, "nddd", 2, id, key, child_process) < 0) {
tst_resm(TWARN, "self_exec failed");
TEST(msgctl(tid, IPC_RMID, 0));
if (TEST_RETURN < 0)
{
tst_resm(TFAIL, "\tMsgctl error in cleanup, "
"errno = %d\n", errno);
}
tst_exit();
}
#else
exit( doreader(id, key % 255, child_process) );
#endif
}
/* Parent does this */
mykid = pid;
procstat = 2;
dowriter(id, key % 255, child_process);
wait(0);
TEST(msgctl(id, IPC_RMID, 0));
if (TEST_RETURN < 0)
{
tst_resm(TFAIL, "msgctl errno %d", TEST_ERRNO);
tst_exit();
}
exit(PASS);
}
int doreader(id, key, child)
int id, child;
long key;
{
int i, size;
for (i = 0; i < nreps; i++)
{
if ((size = msgrcv(id, &buffer, 100, 0, 0)) < 0)
{
tst_brkm(TBROK, cleanup, "Msgrcv error in child %d, read # = %d, errno = %d", (i + 1), child, errno);
tst_exit();
}
if (buffer.data.len + 1 != size)
{
tst_resm(TFAIL, "Size mismatch in child %d, read # = %d", child, (i + 1));
tst_resm(TFAIL, "for message size got %d expected %d %s",size ,buffer.data.len);
tst_exit();
}
if ( verify(buffer.data.pbytes, key, size - 1, child) )
{
tst_resm(TFAIL, "in read # = %d,key = %x", (i + 1), child, key);
tst_exit();
}
key++;
}
return (0);
}
int dowriter(id, key, child)
int id,child;
long key;
{
int i, size;
for (i = 0; i < nreps; i++)
{
do
{
size = (rand() % 99);
} while (size == 0);
fill_buffer(buffer.data.pbytes, key, size);
buffer.data.len = size;
buffer.type = 1;
TEST(msgsnd(id, &buffer, size + 1, 0));
if (TEST_RETURN < 0)
{
tst_brkm(TBROK, cleanup, "Msgsnd error in child %d, key = %x errno = %d", child, key, TEST_ERRNO);
}
key++;
}
return (0);
}
int fill_buffer(buf, val, size)
register char *buf;
char val;
register int size;
{
register int i;
for(i = 0; i < size; i++)
{
buf[i] = val;
}
return (0);
}
/*
* verify()
* Check a buffer for correct values.
*/
int verify(buf, val, size, child)
register char *buf;
char val;
register int size;
int child;
{
while(size-- > 0)
{
if (*buf++ != val)
{
tst_resm(TWARN, "Verify error in child %d, *buf = %x, val = %x, size = %d", child, *buf, val, size);
return(FAIL);
}
}
return(PASS);
}
/*
* * void
* * sig_handler() - signal catching function for 'SIGUSR1' signal.
* *
* * This is a null function and used only to catch the above signal
* * generated in parent process.
* */
void
sig_handler()
{
}
#define BUFSIZE 512
/** Get the number of message queues already in use */
static int get_used_msgqueues()
{
FILE *f;
int used_queues;
char buff[BUFSIZE];
f = popen("ipcs -q", "r");
if (!f) {
tst_resm(TBROK,"Could not run 'ipcs' to calculate used message queues");
tst_exit();
}
/* FIXME: Start at -4 because ipcs prints four lines of header */
for (used_queues = -4; fgets(buff, BUFSIZE, f); used_queues++)
;
pclose(f);
if (used_queues < 0) {
tst_resm(TBROK,"Could not read output of 'ipcs' to calculate used message queues");
tst_exit();
}
return used_queues;
}
/** Get the max number of message queues allowed on system */
static int get_max_msgqueues()
{
FILE *f;
char buff[BUFSIZE];
/* Get the max number of message queues allowed on system */
f = fopen("/proc/sys/kernel/msgmni", "r");
if (!f){
tst_resm(TBROK,"Could not open /proc/sys/kernel/msgmni");
tst_exit();
}
if (!fgets(buff, BUFSIZE, f)) {
tst_resm(TBROK,"Could not read /proc/sys/kernel/msgmni");
tst_exit();
}
fclose(f);
return atoi(buff);
}
/***************************************************************
* setup() - performs all ONE TIME setup for this test.
*****************************************************************/
void
setup()
{
tst_tmpdir();
/* You will want to enable some signal handling so you can capture
* unexpected signals like SIGSEGV.
*/
tst_sig(FORK, DEF_HANDLER, cleanup);
/* Pause if that option was specified */
/* One cavet that hasn't been fixed yet. TEST_PAUSE contains the code to
* fork the test with the -c option. You want to make sure you do this
* before you create your temporary directory.
*/
TEST_PAUSE;
MSGMNI = get_max_msgqueues() - get_used_msgqueues();
if (MSGMNI <= 0){
tst_resm(TBROK,"Max number of message queues already used, cannot create more.");
cleanup();
}
}
/***************************************************************
* cleanup() - performs all ONE TIME cleanup for this test at
* completion or premature exit.
****************************************************************/
void
cleanup()
{
int status;
/*
* Remove the message queue from the system
*/
#ifdef DEBUG
tst_resm(TINFO,"Removing the message queue");
#endif
fflush (stdout);
(void) msgctl(tid, IPC_RMID, (struct msqid_ds *)NULL);
if ((status = msgctl(tid, IPC_STAT, (struct msqid_ds *)NULL)) != -1)
{
(void) msgctl(tid, IPC_RMID, (struct msqid_ds *)NULL);
tst_resm(TFAIL, "msgctl(tid, IPC_RMID) failed");
tst_exit();
}
fflush (stdout);
/*
* print timing stats if that option was specified.
* print errno log if that option was specified.
*/
TEST_CLEANUP;
tst_rmdir();
/* exit with return code appropriate for results */
tst_exit();
}
Reference in a new issue View git blame Copy permalink