This is the mail archive of the libc-alpha@sources.redhat.com mailing list for the glibc project.


Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]
Other format: [Raw text]

Re: Threading bug in sunrpc/auth_none.c


On Thu, Apr 11, 2002 at 03:36:47PM -0700, Ulrich Drepper wrote:
> I'm not going to change anything until I see some code (means a test
> program).

Fair enough; program is appended.  

$ gcc -pthread rpcthreadbug.c -o rpcthreadbug

$ ./rpcthreadbug  # buggy libc
test_one_call: success
test_one_call: RPC: Can't encode arguments

$ LD_LIBRARY_PATH=~/src/libc/build ./rpcthreadbug  # fixed libc
test_one_call: success
test_one_call: success

zw

#include <pthread.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <rpc/rpc.h>
#include <arpa/inet.h>

#define PROGNUM 1234
#define VERSNUM 1
#define PROCNUM 1

void
dispatch(struct svc_req *request, SVCXPRT *xprt)
{
    svc_sendreply(xprt, (xdrproc_t)xdr_void, 0);
}

void
test_one_call(CLIENT *c)
{
    struct timeval tout = { 60, 0 };
    enum clnt_stat result;
    
    fprintf(stderr, "test_one_call: ");
    result = clnt_call(c, PROCNUM,
		       (xdrproc_t)xdr_void, 0,
		       (xdrproc_t)xdr_void, 0, tout);
    if(result == RPC_SUCCESS)
	fprintf(stderr, "success\n");
    else
    {
	clnt_perrno(result);
	putc('\n', stderr);
    }
}

void *
thread_wrapper(void *arg)
{
    test_one_call((CLIENT *)arg);
    return 0;
}

int
main(void)
{
    pthread_t tid;
    pid_t pid;
    int err;
    SVCXPRT *svx;
    CLIENT *clnt;
    struct sockaddr_in sin;
    struct timeval wait = { 5, 0 };
    int sock = RPC_ANYSOCK;

    svx = svcudp_create(RPC_ANYSOCK);
    svc_register(svx, PROGNUM, VERSNUM, dispatch, 0);

    pid = fork();
    if(pid == -1)
    {
	perror("fork");
	return 1;
    }
    if (pid == 0)
      svc_run();

    inet_aton("127.0.0.1", &sin.sin_addr);
    sin.sin_port = htons(svx->xp_port);
    sin.sin_family = AF_INET;

    clnt = clntudp_create(&sin, PROGNUM, VERSNUM, wait, &sock);
    
    /* Test in this thread */
    test_one_call(clnt);

    /* Test in a child thread */
    err = pthread_create(&tid, 0, thread_wrapper, (void *)clnt);
    if(err)
	fprintf(stderr, "pthread_create: %s\n", strerror(err));
    err = pthread_join(tid, 0);
    if(err)
	fprintf(stderr, "pthread_join: %s\n", strerror(err));

    return 0;
}


Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]