144 lines
3.9 KiB
C
144 lines
3.9 KiB
C
/* 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 */
|
|
}
|