Bdb packages | Design docs | Source docs | Guidelines | Recent releases
	Search | Site Map .

                 

---

/BdbTransfer/BdbPTRemoteCopySend.cc

Go to the documentation of this file.

//------------------------------------------------------------------------------
// File and Version Information:
//      $Id: BdbPTRemoteCopySend.cc,v 1.10 1999/07/27 00:03:55 svarovsk Exp $
//
// Description:
//      'sender' class derived from 'transfer' class
//      gets data from file, calculate checksum and writes to socket
//      file and socket must be opened and connected by caller
//
// Environment:
//      Software developed for the BaBar Detector at the SLAC B-Factory
//
// Author:
//      Gennadi S. Svarovski (svarovsk@slac.stanford.edu)
//          original author
//
// Copyright Information:
//      Copyright (C) 1999      Stanford Linear Accelerator Center
//
//------------------------------------------------------------------------------

#include "BaBar/BaBar.hh"
#include <sys/types.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>

#include "BdbTransfer/BdbPTosSpecific.h"
#include "BdbTransfer/BdbPTChecksumSum.h"
#include "BdbTransfer/BdbPTRemoteCopyError.h"
#include "BdbTransfer/BdbPTVerbose.h"
#include "BdbTransfer/BdbPTRemoteCopySend.h"

static char cvsid[]="$Id: BdbPTRemoteCopySend.cc,v 1.10 1999/07/27 00:03:55 svarovsk Exp $";

void* BdbPTRemoteCopySend::run( void ) {
    unsigned blocknum;
    char *buffer;
    int returnstatus = 0;
    BdbPTChecksumSum sum;
    
    VERBOSEMSG( 3, ( "sender started ( number=%2d, total=%2d, started=%2d, bufsize=%d )\n",
                     num, total, started, bufsize ) );

    buffer = new char [bufsize];
    assert( buffer != NULL );

    // main loop across all blocks for this thread
    for( blocknum = num; blocknum < total; blocknum += started ) {
        off_t offset = (off_t)bufsize * blocknum;

        fileMutex().lock();
        offset = lseek( (int)fd, (off_t)offset, (int)SEEK_SET );
        ssize_t len = read( (int)fd, (void*)buffer, (size_t)bufsize );
        fileMutex().unlock();

        if( len < 0 ) {
            perror( "read" );
            returnstatus = 1;
            break;
        }

        if( !(transferOptions & BDBTRANSFER_NOCHECKSUM ) )
            sum = BdbPTChecksumSum::calculate( buffer, len, NULL );
        else
            sum = 0;
            
        VERBOSEMSG( 2, ( "sending ( thread=%2d, block=%d, size=%d, checksum=%08X )\n",
                         num, blocknum, len, sum.value() ) );

        // writing block number and checksum
        socket.writeInt( blocknum    );
        socket.writeInt( len         );
        socket.writeInt( sum.value() );
        if( socket.write( buffer, len ) < len ) {
            perror( "sending buffer" );
            returnstatus = 1;
            break;
        }
        
        BdbPTRemoteCopyResult result = GOOD;
        socket.readInt( (int*)&result );
        if( result != GOOD ) {
            fprintf( stderr, "error from receiver: %s\n", 
                (const char*)BdbPTRemoteCopyError( result ) );
            returnstatus = (int)result;
            break;
        }
    }    

    socket.close();
    delete[] buffer;

    VERBOSEMSG( 3, ( "finished ( sender=%2d, status=%d )\n", num, returnstatus ) );

    if( returnstatus != 0 ) // on error cancel execution of all threads
        ::exit( returnstatus );
        
    return (void*)returnstatus;
}    

 

---

BaBar Public Site | SLAC | News | Links | Who's Who | Contact Us

Page Owner: Jacek Becla
Last Update: October 04, 2002