aa_ungapped.c

ncbi源码

/*
 * ===========================================================================
 * PRODUCTION $Log: aa_ungapped.c,v $
 * PRODUCTION Revision 1000.2  2004/06/01 18:07:00  gouriano
 * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.32
 * PRODUCTION
 * ===========================================================================
 */

/* $Id: aa_ungapped.c,v 1000.2 2004/06/01 18:07:00 gouriano Exp $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's offical duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 */

/** @file aa_ungapped.c
 * @todo FIXME Need description
 */

static char const rcsid[] = 
    "$Id: aa_ungapped.c,v 1000.2 2004/06/01 18:07:00 gouriano Exp $";

#include <algo/blast/core/aa_ungapped.h>

Int2 BlastAaWordFinder(BLAST_SequenceBlk* subject,
                       BLAST_SequenceBlk* query,
                       LookupTableWrap* lut_wrap,
                       Int4** matrix,
                       const BlastInitialWordParameters* word_params,
                       Blast_ExtendWord* ewp,
                       Uint4* query_offsets,
                       Uint4* subject_offsets,
                       Int4 offset_array_size,
                       BlastInitHitList* init_hitlist, 
                       BlastUngappedStats* ungapped_stats)
{
  Int2 status=0;

  /* find the word hits and do ungapped extensions */

  if (ewp->diag_table->multiple_hits)
    {
      status = BlastAaWordFinder_TwoHit(subject, query,
                                        lut_wrap, ewp->diag_table,
                                        matrix,
                                        word_params->cutoff_score,
                                        word_params->x_dropoff,
                                        query_offsets, subject_offsets,
                                        offset_array_size,
                                        init_hitlist, ungapped_stats);
    }
  else
    {
      status = BlastAaWordFinder_OneHit(subject, query,
                                        lut_wrap, ewp->diag_table,
                                        matrix,
                                        word_params->cutoff_score,
                                        word_params->x_dropoff,
                                        query_offsets, subject_offsets,
                                        offset_array_size,
                                        init_hitlist, ungapped_stats);
    }

  return status;
}

Int2 BlastAaWordFinder_TwoHit(const BLAST_SequenceBlk* subject,
			      const BLAST_SequenceBlk* query,
			      const LookupTableWrap* lookup_wrap,
			      BLAST_DiagTable* diag,
			      Int4 ** matrix,
			      Int4 cutoff,
			      Int4 dropoff,
			      Uint4 * NCBI_RESTRICT query_offsets,
			      Uint4 * NCBI_RESTRICT subject_offsets,
			      Int4 array_size,
			      BlastInitHitList* ungapped_hsps, 
               BlastUngappedStats* ungapped_stats)
{
   LookupTable* lookup=NULL;
   RPSLookupTable* rps_lookup=NULL;
   Boolean use_pssm;
   Int4 wordsize;
   Int4 i;
   Int4 hits=0;
   Int4 totalhits=0;
   Int4 first_offset = 0;
   Int4 last_offset;
   Int4 score;
   Int4 hsp_q, hsp_s, hsp_len;
   Int4 window;
   Int4 last_hit, s_last_off, diff;
   Int4 diag_offset, diag_coord, diag_mask;
   DiagStruct* diag_array;
   Boolean right_extend;
   Int4 hits_extended = 0;

   if (diag == NULL)
      return -1;

   diag_offset = diag->offset;
   diag_array = diag->diag_array;
   diag_mask = diag->diag_mask;
   window = diag->window;

   if (lookup_wrap->lut_type == RPS_LOOKUP_TABLE) {
      rps_lookup = (RPSLookupTable *)lookup_wrap->lut;
      wordsize = rps_lookup->wordsize;
   }
   else {
      lookup = (LookupTable *)lookup_wrap->lut;
      wordsize = lookup->wordsize;
   }
   last_offset  = subject->length - wordsize;
   use_pssm = (rps_lookup != NULL) || (lookup->use_pssm);

   while(first_offset <= last_offset) {
      /* scan the subject sequence for hits */
      if (rps_lookup)
         hits = BlastRPSScanSubject(lookup_wrap, subject, &first_offset, 
                                query_offsets, subject_offsets, array_size);
      else
         hits = BlastAaScanSubject(lookup_wrap, subject, &first_offset, 
                                query_offsets, subject_offsets, array_size);

      totalhits += hits;
      /* for each hit, */
      for (i = 0; i < hits; ++i)
      {
         /* calculate the diagonal associated with this query-subject
            pair, and find the distance to the last hit on this diagonal */

         diag_coord = 
            (subject_offsets[i]  - query_offsets[i]) & diag_mask;
         
         last_hit = diag_array[diag_coord].last_hit - diag_offset;
         diff = subject_offsets[i] - last_hit;

         if (diff >= window) {
            /* We are beyond the window for this diagonal; start a new hit */
            diag_array[diag_coord].last_hit = subject_offsets[i] + diag_offset;
         } 
         else {
            /* If the difference is negative, or is less than the 
               wordsize (i.e. last hit and this hit overlap), give up */

            if (diff < wordsize)
               continue;

            /* If a previous extension has not already 
               covered this portion of the query and subject 
               sequences, do the ungapped extension */

            right_extend = TRUE;
            if ((Int4)(subject_offsets[i] + diag_offset) > 
                diag_array[diag_coord].diag_level) {

               /* Extend this pair of hits. The extension to the left must 
                  reach the end of the first word in order for extension 
                  to the right to proceed. */
               hsp_len = 0;
               score = BlastAaExtendTwoHit(matrix, subject, query,
                                        last_hit + wordsize, 
                                        subject_offsets[i], query_offsets[i], 
                                        dropoff, &hsp_q, &hsp_s, 
                                        &hsp_len, use_pssm,
                                        wordsize, &right_extend, &s_last_off);

               ++hits_extended;

               /* if the hsp meets the score threshold, report it */
               if (score >= cutoff)
                  BlastSaveInitHsp(ungapped_hsps, hsp_q, hsp_s,
                        query_offsets[i], subject_offsets[i], hsp_len, score);

               /* whether or not the score was high enough, remember
                  the rightmost subject word offset examined. Future hits must
                  lie at least one letter to the right of this point */
               diag_array[diag_coord].diag_level = 
                        s_last_off - (wordsize - 1) + diag_offset;
            }

            /* If an extension to the right happened (or no extension
               at all), reset the last hit so that future hits to this 
               diagonal must start over. Otherwise make the present hit
               into the previous hit for this diagonal */

            if (right_extend)
               diag_array[diag_coord].last_hit = 0;
            else
               diag_array[diag_coord].last_hit = 
                        subject_offsets[i] + diag_offset;
         } 
      }/* end for - done with this batch of hits, call scansubject again. */
   } /* end while - done with the entire sequence. */
 
   /* increment the offset in the diagonal array */
   DiagUpdate(diag, subject->length + window); 
 
   Blast_UngappedStatsUpdate(ungapped_stats, totalhits, hits_extended, 
                             ungapped_hsps->total);
   return 0;
}

Int2 BlastAaWordFinder_OneHit(const BLAST_SequenceBlk* subject,
			      const BLAST_SequenceBlk* query,
			      const LookupTableWrap* lookup_wrap,
			      BLAST_DiagTable* diag,
			      Int4 ** matrix,
			      Int4 cutoff,
			      Int4 dropoff,
			      Uint4 * NCBI_RESTRICT query_offsets,
			      Uint4 * NCBI_RESTRICT subject_offsets,
			      Int4 array_size,
               BlastInitHitList* ungapped_hsps, 
               BlastUngappedStats* ungapped_stats)
{
   LookupTable* lookup=NULL;
   RPSLookupTable* rps_lookup=NULL;
   Boolean use_pssm;
   Int4 wordsize;
   Int4 hits=0;
   Int4 totalhits=0;
   Int4 first_offset = 0;
   Int4 last_offset;
   Int4 hsp_q, hsp_s, hsp_len;
   Int4 s_last_off;
   Int4 i;
   Int4 score;
   Int4 diag_offset, diag_coord, diag_mask, diff;
   DiagStruct* diag_array;
   Int4 hits_extended = 0;

   if (!diag) 
      return -1;
   
   diag_offset = diag->offset;
   diag_array = diag->diag_array;
   diag_mask = diag->diag_mask;
   
   if (lookup_wrap->lut_type == RPS_LOOKUP_TABLE) {
      rps_lookup = (RPSLookupTable *)lookup_wrap->lut;
      wordsize = rps_lookup->wordsize;
   }
   else {
      lookup = (LookupTable *)lookup_wrap->lut;
      wordsize = lookup->wordsize;
   }
   last_offset  = subject->length - wordsize;
   use_pssm = (rps_lookup != NULL) || (lookup->use_pssm);

   while(first_offset <= last_offset)
   {
      /* scan the subject sequence for hits */
      if (rps_lookup)
         hits = BlastRPSScanSubject(lookup_wrap, subject, &first_offset, 
                                query_offsets, subject_offsets, array_size);
      else
         hits = BlastAaScanSubject(lookup_wrap, subject, &first_offset,
				query_offsets, subject_offsets, array_size);

      totalhits += hits;
      /* for each hit, */
      for (i = 0; i < hits; ++i) {
         diag_coord = 
            (subject_offsets[i]  - query_offsets[i]) & diag_mask;
           
         diff = subject_offsets[i] - 
            (diag_array[diag_coord].diag_level - diag_offset);

         /* do an extension, but only if we have not already extended
            this far */
         if (diff > 0) {
            ++hits_extended;
            score=BlastAaExtendOneHit(matrix, subject, query,
                     subject_offsets[i], query_offsets[i], dropoff,
                     &hsp_q, &hsp_s, &hsp_len, use_pssm, &s_last_off);