Subversion Repositories HelenOS-historic

/*

 * Copyright (C) 2006 Ondrej Palkovsky

 * All rights reserved.

 *

 * Redistribution and use in source and binary forms, with or without

 * modification, are permitted provided that the following conditions

 * are met:

 *

 * - Redistributions of source code must retain the above copyright

 *   notice, this list of conditions and the following disclaimer.

 * - Redistributions in binary form must reproduce the above copyright

 *   notice, this list of conditions and the following disclaimer in the

 *   documentation and/or other materials provided with the distribution.

 * - The name of the author may not be used to endorse or promote products

 *   derived from this software without specific prior written permission.

 *

 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR

 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES

 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.

 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,

 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT

 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF

 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

 */

/** @addtogroup ippc IPPC

 * @brief	Interprocess communication tester.

 * @{

 */ 

/**

 * @file

 */

#include <stdio.h>

#include <async.h>

#include <ipc/ipc.h>

#include <ipc/services.h>

#include <errno.h>

#define TEST_START       10000

#define MAXLIST          4

#define MSG_HANG_ME_UP   2000

static int connections[50];

static ipc_callid_t callids[50];

static int phones[20];

static int myservice = 0;

static void client_connection(ipc_callid_t iid, ipc_call_t *icall)

{

	ipc_callid_t callid;

	ipc_call_t call;

	ipcarg_t phonehash = icall->in_phone_hash;

	int retval;

	int i;

	printf("Connected phone: %P, accepting\n", icall->in_phone_hash);

	ipc_answer_fast(iid, 0, 0, 0);

	for (i=0;i < 1024;i++)

		if (!connections[i]) {

			connections[i] = phonehash;

			break;

		}

	while (1) {

		callid = async_get_call(&call);

		switch (IPC_GET_METHOD(call)) {

		case IPC_M_PHONE_HUNGUP:

			printf("Phone (%P) hung up.\n", phonehash);

			retval = 0;

			break;

		default:

			printf("Received message from %P: %X\n", phonehash,callid);

			for (i=0; i < 1024; i++)

				if (!callids[i]) {

					callids[i] = callid;

					break;

				}

			continue;

		}

		ipc_answer_fast(callid, retval, 0, 0);

	}

}

static void printhelp(void)

{

	printf("? - help\n");

	printf("c - connect to other service\n");

	printf("h - hangup connection\n");

	printf("a - send async message to other service\n");

	printf("s - send sync message to other service\n");

	printf("d - answer message that we have received\n");

	printf("j - jump to endless loop\n");

	printf("p - page fault\n");

	printf("u - unaligned read\n");

}

static void callback(void *private, int retval, ipc_call_t *data)

{

	printf("Received response to msg %d - retval: %d.\n", private,

	       retval);

}

static void do_answer_msg(void)

{

	int i,cnt, errn;

	char c;

	ipc_callid_t callid;

	cnt = 0;

	for (i=0;i < 50;i++) {

		if (callids[i]) {

			printf("%d: %P\n", cnt, callids[i]);

			cnt++;

		}

		if (cnt >= 10)

			break;

	}

	if (!cnt)

		return;

	printf("Choose message:\n");

	do {

		c = getchar();

	} while (c < '0' || (c-'0') >= cnt);

	cnt = c - '0' + 1;

	for (i=0;cnt;i++)

		if (callids[i])

			cnt--;

	i -= 1;

	printf("Normal (n) or hangup (h) or error(e) message?\n");

	do {

		c = getchar();

	} while (c != 'n' && c != 'h' && c != 'e');

	if (c == 'n')

		errn = 0;

	else if (c == 'h')

		errn = EHANGUP;

	else if (c == 'e')

		errn = ENOENT;

	printf("Answering %P\n", callids[i]);

	ipc_answer_fast(callids[i], errn, 0, 0);

	callids[i] = 0;

}

static void do_send_msg(int async)

{

	int phoneid;

	int res;

	static int msgid = 1;

	char c;

	printf("Select phoneid to send msg: 2-9\n");

	do {

		c = getchar();

	} while (c < '2' || c > '9');

	phoneid = c - '0';

	if (async) {

		ipc_call_async(phoneid, 2000, 0, (void *)msgid, callback, 1);

		printf("Async sent - msg %d\n", msgid);

		msgid++;

	} else {

		printf("Sending msg...");

		res = ipc_call_sync_2(phoneid, 2000, 0, 0, NULL, NULL);

		printf("done: %d\n", res);

	}

}

static void do_hangup(void)

{

	char c;

	int res;

	int phoneid;

	printf("Select phoneid to hangup: 2-9\n");

	do {

		c = getchar();

	} while (c < '2' || c > '9');

	phoneid = c - '0';

	printf("Hanging up...");

	res = ipc_hangup(phoneid);

	printf("done: %d\n", phoneid);

}

static void do_connect(void)

{

	char c;

	int svc;

	int phid;

	printf("Choose one service: 0:10000....9:10009\n");

	do {

		c = getchar();

	} while (c < '0' || c > '9');

	svc = TEST_START + c - '0';

	if (svc == myservice) {

		printf("Currently cannot connect to myself, update test\n");

		return;

	}

	printf("Connecting to %d..", svc);

	phid = ipc_connect_me_to(PHONE_NS, svc, 0);

	if (phid > 0) {

		printf("phoneid: %d\n", phid);

		phones[phid] = 1;

	} else

		printf("error: %d\n", phid);

}

int main(void)

{

	ipcarg_t phonead;

	int i;

	char c;

	int res;

	volatile long long var;

	volatile int var1;

	printf("********************************\n");

	printf("***********IPC Tester***********\n");

	printf("********************************\n");

	async_set_client_connection(client_connection);

	for (i=TEST_START;i < TEST_START+10;i++) {

		res = ipc_connect_to_me(PHONE_NS, i, 0, &phonead);

		if (!res)

			break;

		printf("Failed registering as %d..:%d\n", i, res);

	}

	printf("Registered as service: %d\n", i);

	myservice = i;

	printhelp();

	while (1) {

		c = getchar();

		switch (c) {

		case '?':

			printhelp();

			break;

		case 'h':

			do_hangup();

			break;

		case 'c':

			do_connect();

			break;

		case 'a':

			do_send_msg(1);

			break;

		case 's':

			do_send_msg(0);

			break;

		case 'd':

			do_answer_msg();

			break;

		case 'j':

			while (1)

				;

		case 'p':

			printf("Doing page fault\n");

			*((char *)0) = 1;

			printf("done\n");

		case 'u':

			var1=*( (int *) ( ( (char *)(&var) ) + 1 ) );

			break;

		}

	}

}

/** @}

 */