CVS diff for hand.c between 1.9 and 1.3:

#include "pmsg.h"
#include "defines.h"		// refers to #define MAXREQLINE 1024 

#include "defines.h"            // refers to #define MAXREQLINE 1024

//#define HAND_ACCOUNTING

// defined in cow.c

void *hand(void *_arg) { 

extern pth_barrier_t init_bar;
extern pth_t tid_depot;
extern int cow_max_conn;
extern int cow_cur_conn;

void *hand(void *_arg)
{

    char my_name[16];		// 64-bit machine use 16 here? 8 is fine on 32bit pc
    pth_msgport_t depot; 

    char my_name[16];           // 64-bit machine use 16 here? 8 is fine on 32bit pc
    pth_msgport_t depot = NULL; 

    pm_msg.id = my_id = pth_self();
    sprintf(my_name, "%x", (int)my_id);
    /* no doc. of ret val on fail ; on success, it's pth_msgport_t */
    pm_msg.mp = mp = pth_msgport_create(my_name); 

    /*
     * Setup a message port for the current thread so the depot can dispatch
     * requests to us.
     */

    my_id = pth_self();
    sprintf(my_name, "hand%d", (int)_arg);
    mp = pth_msgport_create(my_name);
    if (mp == NULL) {
        perror("Failed to create message port for handler");
        return NULL;
    }

    /* Wait for the depot's message port to become available */
    depot = pth_msgport_find(DEPOT);
    while (NULL == depot) {
        pth_yield(NULL);
        depot = pth_msgport_find(DEPOT);
    }

    /*
     * Send an initial "request finished" message to the depot.  This will
     * push this handler onto the stack of idle handlers and allow the depot
     * to dispatch requests to us.
     */
    pm_msg.id = my_id;
    pm_msg.mp = mp;

    //initialization
    for (;;) { 

        /* Wait for a request to be dispatched to us */
        pth_wait(ev); 

	if (NULL != (depot = pth_msgport_find(DEPOT))) {
	    if (TRUE != pth_msgport_put(depot, (pth_message_t *) & pm_msg)) {
		printf
		    ("ERROR: msgport_put fialed in hand() initialization. \n");
		exit(-1);
	    }
	    break;
	}
	pth_yield(NULL); 

#ifdef HAND_ACCOUNTING
        gettimeofday(&t1, NULL);
        printf("%s starting back up after %d ms delay.\n", my_name, (t1.tv_sec - t2.tv_sec)*1000 + (t1.tv_usec - t2.tv_usec)/1000);
#endif
        
        
        /* Get the request message from our message port */
        pp_msg = (pmsg *) pth_msgport_get(mp);
        assert(pp_msg != NULL);

        /* Extract the file descriptor / transaction buffer */
#ifdef USE_TCPCORK
        req_msg.fdp = pp_msg->fd;
#else
        req_msg.fdp = pp_msg->buf;
#endif

        /* We're done with the pmsg structure now; return it to the pool */
        rn = (reqnode*)pp_msg;
        rn->next = pmsgpool_first;
        pmsgpool_first = rn;

        /* Read and process the request */
        ret_val = read_request(&req_msg);
        cow_tot_served++;

#ifdef HAND_ACCOUNTING
        gettimeofday(&t2, NULL);
        printf("%s finished after %d ms delay.\n", my_name, (t2.tv_sec - t1.tv_sec)*1000 + (t2.tv_usec - t1.tv_usec)/1000);
#endif
        
        /*
         * Send a message to the depot to put this thread back on the 'idle
         * handler' stack.
         */
        if (TRUE != pth_msgport_push(depot, (pth_message_t *) & pm_msg)) {
            printf("ERROR: msgport_push fialed in hand() initialization. \n");
            exit(-1);
        }

    for (;;) {
	if (1 != pth_wait(ev))	// returned value is 0 or 1.

    /* unreachable */
    return _arg; 

	{
	    printf("possibly error on pth_wait in hand() \n");
	    continue;
	}
        printf("(DEBUG) Handler %d got a message\n", my_id);
/*
++cow_cur_conn;
cow_max_conn = cow_max_conn<cow_cur_conn?cow_cur_conn:cow_max_conn;
*/

	pp_msg = (pmsg *) pth_msgport_get(mp);
	if (NULL == pp_msg)
	    exit(-726578);	// ascii dec HAN

	fd = pp_msg->fd;

	req_msg.per_thread = 0;
	req_msg.fdp = fd;
	ret_val = read_request(&req_msg);
/*
if( ret_val ) printf("error? hand.c retval from read_request = %d",ret_val);
*/

	// then put myself on the queue

	if (TRUE != pth_msgport_push(depot, (pth_message_t *) & pm_msg)) {
	    printf("ERROR: msgport_push fialed in hand() initialization. \n");
	    exit(-1);
	}

    }				/* end of for loop */
    // unreachable
    return (void *)NULL;