/*                                                          square_svc.c
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#include "square.h"
#include <stdio.h>
#include <stdlib.h>
#include <rpc/pmap_clnt.h>
#include <string.h>
#include <memory.h>
#include <sys/socket.h>
#include <netinet/in.h>

#ifndef SIG_PF
#define SIG_PF void(*)(int)
#endif

pthread_t p_thread;
pthread_attr_t attr;

/*

 Процедура выполняемая потоком

 */

void *serv_request(void *data)
{
	struct thr_data {
		struct svc_req *rqstp;
		SVCXPRT *transp;
	} *ptr_data;

	{

		union {
			square_in squareproc_2_arg;
		} argument;
		union {
			square_out squareproc_2_res;
		} result;
		bool_t retval;
		xdrproc_t _xdr_argument, _xdr_result;
		bool_t(*local) (char *, void *, struct svc_req *);

/*

  Распаковка данных , переданных в процедуру при запуске потока.

*/

		ptr_data = (struct thr_data *)data;
		struct svc_req *rqstp = ptr_data->rqstp;
		register SVCXPRT *transp = ptr_data->transp;

		switch (rqstp->rq_proc) {
		case NULLPROC:
			(void)svc_sendreply(transp, (xdrproc_t) xdr_void, (char *)NULL);
			return;

		case SQUAREPROC:
			_xdr_argument = (xdrproc_t) xdr_square_in;
			_xdr_result = (xdrproc_t) xdr_square_out;
			local = (bool_t(*)(char *, void *, struct svc_req *))squareproc_2_svc;
			break;

		default:
			svcerr_noproc(transp);
			return;
		}
		memset((char *)&argument, 0, sizeof(argument));
		if (!svc_getargs(transp, (xdrproc_t) _xdr_argument, (caddr_t) & argument)) {
			svcerr_decode(transp);
			return;
		}

		/*

		   Стандартный  вызов функции сервера.
		   Данные для вызова уже приведены к стандарту.

		 */

		retval = (bool_t) (*local) ((char *)&argument, (void *)&result, rqstp);

		if (retval > 0 && !svc_sendreply(transp, (xdrproc_t) _xdr_result, (char *)&result)) {
			svcerr_systemerr(transp);
		}
		if (!svc_freeargs(transp, (xdrproc_t) _xdr_argument, (caddr_t) & argument)) {
			fprintf(stderr, "%s", "unable to free arguments");
			exit(1);
		}
		if (!square_prog_2_freeresult(transp, _xdr_result, (caddr_t) & result))
			fprintf(stderr, "%s", "unable to free results");
		return;
	}
}

/*

Принципиально измененный код square_prog_2 , стартующей теперь
новый поток для каждого инициированного клиентом вызова
процедуры на удаленном сервере

*/

static void square_prog_2(struct svc_req *rqstp, register SVCXPRT * transp)
{
	struct data_str {
		struct svc_req *rqstp;
		SVCXPRT *transp;
	} *data_ptr = (struct data_str *)malloc(sizeof(struct data_str); {

/*
  Упаковка данных в структуру для передачи ссылки на нее,
   как параметра запускаемому потоку
*/

						data_ptr->rqstp = rqstp;
						data_ptr->transp = transp;
						pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
						pthread_create(&p_thread, &attr, serv_request, (void *)data_ptr);}
						}

						int main(int argc, char **argv) {
						register SVCXPRT * transp;
						pmap_unset(SQUARE_PROG, SQUARE_VERS);
						transp = svcudp_create(RPC_ANYSOCK); if (transp == NULL) {
						fprintf(stderr, "%s", "cannot create udp service."); exit(1);}
						if (!svc_register(transp, SQUARE_PROG, SQUARE_VERS, square_prog_2, IPPROTO_UDP)) {
						fprintf(stderr, "%s", "unable to register (SQUARE_PROG, SQUARE_VERS, udp).");
						exit(1);}

						transp = svctcp_create(RPC_ANYSOCK, 0, 0); if (transp == NULL) {
						fprintf(stderr, "%s", "cannot create tcp service."); exit(1);}
						if (!svc_register(transp, SQUARE_PROG, SQUARE_VERS, square_prog_2, IPPROTO_TCP)) {
						fprintf(stderr, "%s", "unable to register (SQUARE_PROG, SQUARE_VERS, tcp).");
						exit(1);}

						svc_run(); fprintf(stderr, "%s", "svc_run returned"); exit(1);
						/* NOTREACHED */
						}