/*
 * Copyright (c) International Business Machines  Corp., 2002
 * Copyright (c) 2013 Oracle and/or its affiliates. All Rights Reserved.
 *
 * 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 would 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 the Free Software Foundation,
 * Inc.,  51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include "libmsgctl.h"

int doreader(long key, int tid, long type, int child, int nreps)
{
	int i, size;
	int id;
	struct mbuffer buffer;

	id = msgget(key, 0);
	if (id < 0) {
		printf("msgget() error in the reader of child group %d: %s\n",
			child, strerror(errno));

		return FAIL;
	}
	if (id != tid) {
		printf("Message queue mismatch in the reader of child group %d for message queue id %d\n",
			child, id);

		return FAIL;
	}
	for (i = 0; i < nreps; i++) {
		memset(&buffer, 0, sizeof(buffer));

		size = msgrcv(id, &buffer, 100, type, 0);
		if (size < 0) {
			printf("msgrcv() error in child %d, read # = %d: %s\n",
				child, (i + 1), strerror(errno));

			return FAIL;
		}
		if (buffer.type != type) {
			printf("Type mismatch in child %d, read #d = %d: ",
				child, (i + 1));
			printf("for message got %ld, expected - %ld\n",
				buffer.type, type);

			return FAIL;
		}
		if (buffer.data.len + 1 != size) {
			printf("Size mismatch in child %d, read # = %d: ",
				child, (i + 1));
			printf("for message got %d, expected - %d\n",
				buffer.data.len + 1, size);

			return FAIL;
		}
		if (verify(buffer.data.pbytes, (key % 255), size - 1, child)) {
			printf("Verify failed in child %d read # = %d, key = %lx\n",
				child, (i + 1), key);

			return FAIL;
		}
		key++;
	}
	return PASS;
}

int dowriter(long key, int tid, long type, int child, int nreps)
{
	int i, size;
	int id;
	struct mbuffer buffer;

	id = msgget(key, 0);
	if (id < 0) {
		printf("msgget() error in the writer of child group %d: %s\n",
			child, strerror(errno));

		return FAIL;
	}
	if (id != tid) {
		printf("Message queue mismatch in the reader of child group %d for message queue id %d\n",
			child, id);

		return FAIL;
	}

	for (i = 0; i < nreps; i++) {
		memset(&buffer, 0, sizeof(buffer));

		do {
			size = (lrand48() % 99);
		} while (size == 0);
		fill_buffer(buffer.data.pbytes, (key % 255), size);
		buffer.data.len = size;
		buffer.type = type;
		if (msgsnd(id, &buffer, size + 1, 0) < 0) {
			printf("msgsnd() error in child %d, write # = %d, key = %lx: %s\n",
				child, nreps, key, strerror(errno));

			return FAIL;
		}
		key++;
	}
	return PASS;
}

int fill_buffer(char *buf, char val, int size)
{
	int i;

	for (i = 0; i < size; i++)
		buf[i] = val;
	return 0;
}

/* Check a buffer for correct values */
int verify(char *buf, char val, int size, int child)
{
	while (size-- > 0) {
		if (*buf++ != val) {
			printf("Verify error in child %d, *buf = %x, val = %x, size = %d\n",
				child, *buf, val, size);

			return FAIL;
		}
	}
	return PASS;
}