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

                 

---

/BdbTransfer/BdbPTRemoteCopyRecv.cc

Go to the documentation of this file.

//------------------------------------------------------------------------------
// File and Version Information:
//      $Id: BdbPTRemoteCopyRecv.cc,v 1.10 1999/07/27 00:03:55 svarovsk Exp $
//
// Description:
//      'sender' class derived from 'transfer' class
//      gets data from socket, calculate checksum and writes to file
//      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 <assert.h>

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

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

void* BdbPTRemoteCopyRecv::run( void ) {
    int i, returnstatus = 0;
    char *buffer;
    
    VERBOSEMSG( 3, ( "receiver 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( i = num; i < total; i += started ) {
        BdbPTChecksumSum sum;
        off_t offset;
        ssize_t len;
        size_t blocklen = 0, blockoff;
        unsigned blocknum;
        unsigned intSum;
        BdbPTRemoteCopyResult result = GOOD;
        
        // reading block number, size and checksum from sender
        if( socket.readInt( (int*)&blocknum ) <= 0 ||
            socket.readInt( (int*)&blocklen ) <= 0 ||
            socket.readInt( (int*)&intSum   ) <= 0 ) {
                returnstatus = 2;
                break;
        }

        // need to make loop here to read all sender wants to tell us
        // packets got fragmented since it is very unlikely we use
        // network with MTU ~1M (reasonable size of buffer)
        for( blockoff = 0; blockoff < blocklen; blockoff += len )
            len = socket.read( buffer + blockoff, blocklen - blockoff );

        VERBOSEMSG( 2, ( "received ( thread=%2d, block=%d, size=%d, checksum=%08X )\n",
                         num, blocknum, blocklen, intSum ) );

        if( !(transferOptions & BDBTRANSFER_NOCHECKSUM ) ) {
            sum = BdbPTChecksumSum::calculate( buffer, blocklen, NULL );

            // verify checksum
            if( intSum != sum.value() ) {
                socket.writeInt( (int)( result = ECHK ) );
                VERBOSEMSG( 2, ( "checksum status ( block=%d, %08X DOESN'T MATCH %08X )\n", 
                                  blocknum, intSum, sum.value() ) );
                returnstatus = 1;
                break;
            }
        }

        // received block and checksum matched
        // can write block to file now
        offset = bufsize * blocknum;

        fileMutex().lock();
        offset = lseek( fd, offset, SEEK_SET );
        len = write( fd, buffer, blocklen );
        fileMutex().unlock();

        if( len < blocklen ) {
            socket.writeInt( (int)( result = EWRT ) );
            returnstatus = 2;
            break;
        }

        // give client confirmation that everything is ok
        socket.writeInt( (int)( result = GOOD ) );
    } // for

    delete[] buffer;

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

    if( returnstatus != 0 ) {
        // on error cancel execution of all threads
        // and let sender get broken pipe from closed connection
        ::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