git.sur5r.net Git - openldap/blob - servers/slurpd/replica.c

   1 /*
   2  * Copyright (c) 1996 Regents of the University of Michigan.
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms are permitted
   6  * provided that this notice is preserved and that due credit is given
   7  * to the University of Michigan at Ann Arbor. The name of the University
   8  * may not be used to endorse or promote products derived from this
   9  * software without specific prior written permission. This software
  10  * is provided ``as is'' without express or implied warranty.
  11  */
  12
  13
  14 /*
  15  * replica.c - code to start up replica threads.
  16  */
  17
  18
  19 #include <stdio.h>
  20
  21 #include "slurp.h"
  22 #include "globals.h"
  23
  24
  25 /*
  26  * Just invoke the Ri's process() member function, and log the start and
  27  * finish.
  28  */
  29 void
  30 replicate(
  31     Ri  *ri
  32 )
  33 {
  34     int i;
  35     unsigned long seq;
  36
  37     Debug( LDAP_DEBUG_ARGS, "begin replication thread for %s:%d\n",
  38             ri->ri_hostname, ri->ri_port, 0 );
  39
  40     ri->ri_process( ri );
  41
  42     Debug( LDAP_DEBUG_ARGS, "end replication thread for %s:%d\n",
  43             ri->ri_hostname, ri->ri_port, 0 );
  44     return;
  45 }
  46
  47
  48
  49 /*
  50  * Start a detached thread for the given replica.
  51  */
  52 int
  53 start_replica_thread(
  54     Ri  *ri
  55 )
  56 {
  57     pthread_attr_t      attr;
  58
  59     pthread_attr_init( &attr );
  60     pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_DETACHED );
  61
  62     if ( pthread_create( &(ri->ri_tid), attr, (void *) replicate,
  63             (void *) ri ) != 0 ) {
  64         Debug( LDAP_DEBUG_ANY, "replica \"%s:%d\" pthread_create failed\n",
  65                 ri->ri_hostname, ri->ri_port, 0 );
  66         pthread_attr_destroy( &attr );
  67         return -1;
  68     }
  69     pthread_attr_destroy( &attr );
  70     return 0;
  71 }