#include "mltaln.h" #include "dp.h" #define MACHIGAI 0 #define OUTGAP0TRY 0 #define DEBUG 0 #define XXXXXXX 0 #define USE_PENALTY_EX 1 #define FASTMATCHCALC 1 #define SLOW 0 #define TERMGAPFAC 0.0 #define TERMGAPFAC_EX 0.0 static TLS double **impmtx = NULL; static TLS int impalloclen = 0; double imp_match_out_sc( int i1, int j1 ) { // fprintf( stderr, "imp+match = %f\n", impmtx[i1][j1] * fastathreshold ); // fprintf( stderr, "val = %f\n", impmtx[i1][j1] ); return( impmtx[i1][j1] ); } #if 0 static void imp_match_out_vead_gapmap( double *imp, int i1, int lgth2, int *gapmap2 ) { #if FASTMATCHCALC double *pt = impmtx[i1]; int *gapmappt = gapmap2; while( lgth2-- ) *imp++ += pt[*gapmappt++]; #else int j; double *pt = impmtx[i1]; for( j=0; j target -> localhomtable. seedinlh12 -> localhom ni haitteiru. else fillimp_file( impmtx, imp, clus1, clus2, lgth1, lgth2, seq1, seq2, eff1, eff2, eff1_kozo, eff2_kozo, localhom, swaplist, forscore, orinum1, orinum2, uselh, seedinlh1, seedinlh2, nodeid, nfiles ); } static void match_calc_del( int **which, double ***matrices, double *match, int n1, char **seq1, double *eff1, int n2, char **seq2, double *eff2, int i1, int lgth2, int mid, int nmask, int *mask1, int *mask2 ) { // osoi! int i, j, k, m; int c1, c2; // fprintf( stderr, "\nmatch_calc_dynamicmtx... %d", i1 ); // fprintf( stderr, "\nseq1[0]=%s\n", seq1[0] ); // fprintf( stderr, "\nseq2[0]=%s\n", seq2[0] ); // for( i=0; i ", match[k], mid ); match[k] -= matrices[mid][c1][c2] * eff1[i] * eff2[j]; // fprintf( stderr, "match[k] = %f (mid=%d)\n", match[k], mid ); } } // fprintf( stderr, "done\n" ); return; } #if SLOW static void match_calc_slow( int **which, double ***matrices, double *match, int n1, char **seq1, double *eff1, int n2, char **seq2, double *eff2, int i1, int lgth2, double **doublework, int **intwork, int initialize, int flip ) { // osoi! int i, j, k; int c1, c2; int mid; // fprintf( stderr, "\nmatch_calc_dynamicmtx... %d", i1 ); // fprintf( stderr, "\nseq1[0]=%s\n", seq1[0] ); // fprintf( stderr, "\nseq2[0]=%s\n", seq2[0] ); // for( i=0; i-1 ) *matchpt += scarr[*cpmxpdnpt++] * *cpmxpdpt++; matchpt++; } } free( scarr ); // fprintf( stderr, "done\n" ); #else int j, k, l; // double scarr[26]; double **cpmxpd = doublework; int **cpmxpdn = intwork; double *scarr; scarr = calloc( nalphabets, sizeof( double ) ); // simple if( initialize ) { int count = 0; for( j=0; j-1; k++ ) match[j] += scarr[cpmxpdn[k][j]] * cpmxpd[k][j]; } free( scarr ); #endif } static void match_calc( double **n_dynamicmtx, double *match, double **cpmx1, double **cpmx2, int i1, int lgth2, double **doublework, int **intwork, int initialize ) { #if FASTMATCHCALC // fprintf( stderr, "\nmatch_calc... %d", i1 ); int j, l; // double scarr[26]; double **cpmxpd = doublework; int **cpmxpdn = intwork; double *matchpt, *cpmxpdpt, **cpmxpdptpt; int *cpmxpdnpt, **cpmxpdnptpt; double *scarr; scarr = calloc( nalphabets, sizeof( double ) ); if( initialize ) { int count = 0; for( j=0; j-1 ) *matchpt += scarr[*cpmxpdnpt++] * *cpmxpdpt++; matchpt++; } } free( scarr ); // fprintf( stderr, "done\n" ); #else int j, k, l; // double scarr[26]; double **cpmxpd = doublework; int **cpmxpdn = intwork; double *scarr; scarr = calloc( nalphabets, sizeof( double ) ); // simple if( initialize ) { int count = 0; for( j=0; j-1; k++ ) match[j] += scarr[cpmxpdn[k][j]] * cpmxpd[k][j]; } free( scarr ); #endif } static void Atracking_localhom( double *impwmpt, double *lasthorizontalw, double *lastverticalw, char **seq1, char **seq2, char **mseq1, char **mseq2, int **ijp, int icyc, int jcyc, int *warpis, int *warpjs, int warpbase, int *ngap1, int *ngap2, int reuseprofiles, char **gt1, char **gt2 ) { int i, j, l, iin, jin, ifi, jfi, lgth1, lgth2, k, limk; double wm; char *gaptable1, *gt1bk; char *gaptable2, *gt2bk; lgth1 = strlen( seq1[0] ); lgth2 = strlen( seq2[0] ); if( gt1 == NULL ) { gt1bk = AllocateCharVec( lgth1+lgth2+1 ); gt2bk = AllocateCharVec( lgth1+lgth2+1 ); } else { gt1bk = *gt1; gt2bk = *gt2; } #if 0 for( i=0; i= wm ) { wm = lastverticalw[i]; iin = i; jin = lgth2-1; ijp[lgth1][lgth2] = +( lgth1 - i ); } } for( j=0; j= wm ) { wm = lasthorizontalw[j]; iin = lgth1-1; jin = j; ijp[lgth1][lgth2] = -( lgth2 - j ); } } } for( i=0; i= warpbase ) { ifi = warpis[ijp[iin][jin]-warpbase]; jfi = warpjs[ijp[iin][jin]-warpbase]; } else if( ijp[iin][jin] < 0 ) { ifi = iin-1; jfi = jin+ijp[iin][jin]; } else if( ijp[iin][jin] > 0 ) { ifi = iin-ijp[iin][jin]; jfi = jin-1; } else { ifi = iin-1; jfi = jin-1; } if( ifi == -warpbase && jfi == -warpbase ) { l = iin; while( --l >= 0 ) { *--gaptable1 = 'o'; *--gaptable2 = '-'; k++; //*ngap2 = 1; // shita de keisan } l= jin; while( --l >= 0 ) { *--gaptable1 = '-'; *--gaptable2 = 'o'; k++; //*ngap1 = 1; } break; } else { l = iin - ifi; while( --l ) { *--gaptable1 = 'o'; *--gaptable2 = '-'; k++; //*ngap2 = 1; } l= jin - jfi; while( --l ) { *--gaptable1 = '-'; *--gaptable2 = 'o'; k++; //*ngap1 = 1; } } if( iin == lgth1 || jin == lgth2 ) ; else { *impwmpt += (double)imp_match_out_sc( iin, jin ); // fprintf( stderr, "impwm = %f (iin=%d, jin=%d) seq1=%c, seq2=%c\n", *impwmpt, iin, jin, seq1[0][iin], seq2[0][jin] ); } if( iin <= 0 || jin <= 0 ) break; *--gaptable1 = 'o'; *--gaptable2 = 'o'; k++; iin = ifi; jin = jfi; } #if 1 // Atracking() to onaji. Wazukani hayai hazu. Test mada. if( strchr( gaptable1, '-' ) ) *ngap1 = 1; else *ngap1 = 0; if( strchr( gaptable2, '-' ) ) *ngap2 = 1; else *ngap2 = 0; if( *ngap1 == 0 && reuseprofiles ) ; else if( *ngap1 == 0 ) { limk = gt1bk + lgth1+lgth2 - gaptable1; for( i=0; i yobidashimoto // gapf1 = NULL; // free( gapf2 ); // gapf1 = NULL; #if 0 reporterr( "gaptable1=%s\n", gaptable1 ); reporterr( "gaptable2=%s\n", gaptable2 ); reporterr( "result (gapfreq) = " ); for( j=0; j=0; j-- ) { if( (g=lasthorizontalw[j]+ ( fpenalty * TERMGAPFAC + fpenalty_ex * (lgth2-1-j) * TERMGAPFAC_EX ) ) > wm ) { wm = g; iin = lgth1-1; jin = j; ijp[lgth1][lgth2] = -( lgth2 - j ); } } for( i=lgth1-2; i>=0; i-- ) { if( ( g=lastverticalw[i]+ ( fpenalty * TERMGAPFAC + fpenalty_ex * (lgth1-1-i) * TERMGAPFAC_EX ) ) > wm ) { wm = g; iin = i; jin = lgth2-1; ijp[lgth1][lgth2] = +( lgth1 - i ); } } if( lasthorizontalw[lgth2-1] > wm ) // score ga onaji baai erabarenai { wm = lasthorizontalw[lgth2-1]; iin = lgth1-1; jin = lgth2-1; ijp[lgth1][lgth2] = 0; } #else wm = lastverticalw[0]; for( i=0; i= wm ) { wm = lastverticalw[i]; iin = i; jin = lgth2-1; ijp[lgth1][lgth2] = +( lgth1 - i ); } } for( j=0; j= wm ) { wm = lasthorizontalw[j]; iin = lgth1-1; jin = j; ijp[lgth1][lgth2] = -( lgth2 - j ); } } #endif } for( i=0; i= warpbase ) { ifi = warpis[ijp[iin][jin]-warpbase]; jfi = warpjs[ijp[iin][jin]-warpbase]; } else if( ijp[iin][jin] < 0 ) { ifi = iin-1; jfi = jin+ijp[iin][jin]; } else if( ijp[iin][jin] > 0 ) { ifi = iin-ijp[iin][jin]; jfi = jin-1; } else { ifi = iin-1; jfi = jin-1; } if( ifi == -warpbase && jfi == -warpbase ) { l = iin; while( --l >= 0 ) { *--gaptable1 = 'o'; *--gaptable2 = '-'; k++; } l= jin; while( --l >= 0 ) { *--gaptable1 = '-'; *--gaptable2 = 'o'; k++; } break; } else { l = iin - ifi; while( --l ) { *--gaptable1 = 'o'; *--gaptable2 = '-'; k++; } l= jin - jfi; while( --l ) { *--gaptable1 = '-'; *--gaptable2 = 'o'; k++; } } if( iin <= 0 || jin <= 0 ) break; *--gaptable1 = 'o'; *--gaptable2 = 'o'; k++; iin = ifi; jin = jfi; } // reporterr( "gaptable1=%s\n", gaptable1 ); // reporterr( "gaptable2=%s\n", gaptable2 ); if( strchr( gaptable1, '-' ) ) *ngap1 = 1; else *ngap1 = 0; if( strchr( gaptable2, '-' ) ) *ngap2 = 1; else *ngap2 = 0; #if 1 if( *ngap1 == 0 && reuseprofiles ) ; else if( *ngap1 == 0 ) { limk = gt1bk + lgth1+lgth2 - gaptable1; for( i=0; i lgth1, outgap == 1 -> lgth1+1 */ int lgth1, lgth2; int resultlen; double wm = 0.0; /* int ?????? */ double wmo = 0.0; double g; double *currentw, *previousw; // double fpenalty = (double)penalty; #if USE_PENALTY_EX double fpenalty_ex = (double)penalty_ex_l; #endif #if 1 double *wtmp; int *ijppt; double *mjpt, *prept, *curpt; int *mpjpt; #endif static TLS double mi, *m; static TLS int **ijp; static TLS int mpi, *mp; static TLS double *w1, *w2; static TLS double *match; static TLS double *initverticalw; /* kufuu sureba iranai */ static TLS double *lastverticalw; /* kufuu sureba iranai */ char **mseq1; char **mseq2; char **mseq; static TLS double *ogcp1, *ogcp1o; static TLS double *ogcp2, *ogcp2o; static TLS double *fgcp1, *fgcp1o; static TLS double *fgcp2, *fgcp2o; double *ogcp1opt, *ogcp2opt, *fgcp1opt, *fgcp2opt; static TLS double **cpmx1; double ***cpmx1pt = NULL; static TLS double **cpmx2; double ***cpmx2pt = NULL; static TLS int **intwork; static TLS double **doublework; static TLS int orlgth1 = 0, orlgth2 = 0; static TLS double *gapfreq1; double *gapfreq1pt; static TLS double *gapfreq2; double *gapfreq2pt; double fpenalty = (double)penalty_l; double fpenalty_shift = (double)penalty_shift; double *fgcp2pt; double *ogcp2pt; double fgcp1va; double ogcp1va; double *gf2pt; double *gf2ptpre; double gf1va; double gf1vapre; double headgapfreq1; double headgapfreq2; int *warpis = NULL; int *warpjs = NULL; int *warpi = NULL; int *warpj = NULL; int *prevwarpi = NULL; int *prevwarpj = NULL; double *wmrecords = NULL; double *prevwmrecords = NULL; int warpn = 0; int warpbase; double curm = 0.0; double *wmrecordspt, *wmrecords1pt, *prevwmrecordspt; int *warpipt, *warpjpt; char *gt1, *gt2, *gt1bk, *gt2bk; // for( i=0; i orlgth1 || lgth2 > orlgth2 ) { int ll1, ll2; if( orlgth1 > 0 && orlgth2 > 0 ) { FreeFloatVec( w1 ); FreeFloatVec( w2 ); FreeFloatVec( match ); FreeFloatVec( initverticalw ); FreeFloatVec( lastverticalw ); FreeFloatVec( m ); FreeIntVec( mp ); FreeFloatVec( ogcp1 ); FreeFloatVec( ogcp1o ); FreeFloatVec( ogcp2 ); FreeFloatVec( ogcp2o ); FreeFloatVec( fgcp1 ); FreeFloatVec( fgcp1o ); FreeFloatVec( fgcp2 ); FreeFloatVec( fgcp2o ); FreeFloatMtx( cpmx1 ); FreeFloatMtx( cpmx2 ); FreeFloatVec( gapfreq1 ); FreeFloatVec( gapfreq2 ); FreeFloatMtx( doublework ); FreeIntMtx( intwork ); } ll1 = MAX( (int)(1.3*lgth1), orlgth1 ) + 100; ll2 = MAX( (int)(1.3*lgth2), orlgth2 ) + 100; #if DEBUG fprintf( stderr, "\ntrying to allocate (%d+%d)xn matrices ... ", ll1, ll2 ); #endif w1 = AllocateFloatVec( ll2+2 ); w2 = AllocateFloatVec( ll2+2 ); match = AllocateFloatVec( ll2+2 ); initverticalw = AllocateFloatVec( ll1+2 ); lastverticalw = AllocateFloatVec( ll1+2 ); m = AllocateFloatVec( ll2+2 ); mp = AllocateIntVec( ll2+2 ); ogcp1 = AllocateFloatVec( ll1+2 ); ogcp1o = AllocateFloatVec( ll1+2 ); ogcp2 = AllocateFloatVec( ll2+2 ); ogcp2o = AllocateFloatVec( ll2+2 ); fgcp1 = AllocateFloatVec( ll1+2 ); fgcp1o = AllocateFloatVec( ll1+2 ); fgcp2 = AllocateFloatVec( ll2+2 ); fgcp2o = AllocateFloatVec( ll2+2 ); cpmx1 = AllocateFloatMtx( nalphabets, ll1+2 ); cpmx2 = AllocateFloatMtx( nalphabets, ll2+2 ); previousfirstlen = -1; previousicyc = -1; gapfreq1 = AllocateFloatVec( ll1+2 ); gapfreq2 = AllocateFloatVec( ll2+2 ); #if FASTMATCHCALC doublework = AllocateFloatMtx( MAX( ll1, ll2 )+2, nalphabets ); intwork = AllocateIntMtx( MAX( ll1, ll2 )+2, nalphabets+1 ); #else doublework = AllocateFloatMtx( nalphabets, MAX( ll1, ll2 )+2 ); intwork = AllocateIntMtx( nalphabets, MAX( ll1, ll2 )+2 ); #endif #if DEBUG fprintf( stderr, "succeeded\n" ); #endif orlgth1 = ll1 - 100; orlgth2 = ll2 - 100; } for( i=0; i commonAlloc1 || orlgth2 > commonAlloc2 ) { int ll1, ll2; if( commonAlloc1 && commonAlloc2 ) { FreeIntMtx( commonIP ); } ll1 = MAX( orlgth1, commonAlloc1 ); ll2 = MAX( orlgth2, commonAlloc2 ); #if DEBUG fprintf( stderr, "\n\ntrying to allocate %dx%d matrices ... ", ll1+1, ll2+1 ); #endif commonIP = AllocateIntMtx( ll1+10, ll2+10 ); #if DEBUG fprintf( stderr, "succeeded\n\n" ); #endif commonAlloc1 = ll1; commonAlloc2 = ll2; } ijp = commonIP; #if 0 { double t = 0.0; for( i=0; i= 0 && firstmem == previousfirstmem && lgth1 == previousfirstlen && nthread == 0 && icyc == previousicyc+1 ) // mouhitotsu jouken ga iru. firstmem >= 0 && firstmem == previousfirstmem && calledbytreebase && prevcalledbytreebase if( calledbyfulltreebase == 1 && previouscall && firstmem >= 0 && firstmem == previousfirstmem && lgth1 == previousfirstlen && nthread == 0 && icyc == previousicyc+1 ) // mouhitotsu jouken ga iru. firstmem >= 0 && firstmem == previousfirstmem && calledbytreebase && prevcalledbytreebase reuseprofiles = 1; else reuseprofiles = 0; // Atracking de gapireru() wo skip surutameni reuseprofile flag wo tsukau. #if 0 reporterr( "nthread=%d\n", nthread ); reporterr( "reuseprofiles=%d\n", reuseprofiles ); reporterr( "calledbyfulltreebase=%d\n", calledbyfulltreebase ); reporterr( "previouscall=%d\n", previouscall ); reporterr( "firstmem=%d, prefiousfirstmem=%d\n", firstmem, previousfirstmem ); reporterr( "lgth1=%d, previousfirstlen=%d\n", lgth1, previousfirstlen ); if( reuseprofiles ) exit(1 ); #endif if( n_dis[0][amino_n['-']] != 0 ) { reporterr( "Bug probably in versions >7.36. Please report this issue to katoh@ifrec.osaka-u.ac.jp\n" ); exit( 1 ); } if( cpmxresult && specificityconsideration == 0.0 ) // n_dynamicmtx ga henka suru toki profile ha sairiyou dekinai. { if( sgap1 ) { reporterr( "The combination of sgap1 and cpmxhit is not supported. See Salignmm.c\n" ); exit( 1 ); } if( cpmxchild0 && *cpmxchild0 ) { // reporterr( "\nUse cpmxhist for child 0!\n" ); cpmx1pt = (cpmxchild0); gapfreq1pt = (*cpmxchild0)[nalphabets]; ogcp1opt = (*cpmxchild0)[nalphabets+1]; fgcp1opt = (*cpmxchild0)[nalphabets+2]; } else { // reporterr( "\nDo not use cpmxhist for child 0!\n" ); cpmx1pt = &cpmx1; cpmx_calc_new( seq1, *cpmx1pt, eff1, lgth1, icyc ); gapfreq1pt = gapfreq1; gapcountf( gapfreq1pt, seq1, icyc, eff1, lgth1 ); for( i=0; i tbfast.c // impossible if( localhom ) imp_match_calc( n_dynamicmtx, currentw, icyc, jcyc, lgth1, lgth2, seq1, seq2, eff1, eff2, localhom, 1, 0 ); #endif if( headgp == 1 ) { for( i=1; i", wm ); fprintf( stderr, "%5.0f? (penal=%5.2f)", g=mi+*fgcp2pt*(1.0-gapfreq1pt[i]), *fgcp2pt*(1.0-gapfreq1pt[i]) ); #endif if( (g=mi+*fgcp2pt*gf1va) > wm ) { wm = g; *ijppt = -( j - mpi ); // fprintf( stderr, "Jump to %d (%c)!", mpi, seq2[0][mpi] ); } if( (g=*prept+*ogcp2pt*gf1vapre) >= mi ) // if( (g=*prept+*ogcp2pt*gf1vapre) > mi ) { mi = g; mpi = j-1; } #if USE_PENALTY_EX mi += fpenalty_ex; #endif #if 0 fprintf( stderr, "%5.0f->", wm ); fprintf( stderr, "%5.0f? (penal=%5.2f)", g=*mjpt+fgcp1va*(1.0-gapfreq2pt[j]), fgcp1va*(1.0-gapfreq2pt[j]) ); #endif if( (g=*mjpt+ fgcp1va* *gf2pt) > wm ) { wm = g; *ijppt = +( i - *mpjpt ); // fprintf( stderr, "Jump to %d (%c)!", *mpjpt, seq1[0][*mpjpt] ); } if( (g=*prept+ ogcp1va* *gf2ptpre) >= *mjpt ) // if( (g=*prept+ ogcp1va* *gf2ptpre) > *mjpt ) { *mjpt = g; *mpjpt = i-1; } #if USE_PENALTY_EX m[j] += fpenalty_ex; #endif if( trywarp ) { #if USE_PENALTY_EX if( ( g=*prevwmrecordspt++ + fpenalty_shift + fpenalty_ex * ( i - prevwarpi[j-1] + j - prevwarpj[j-1] ) ) > wm ) // naka ha osokute kamawanai #else if( ( g=*prevwmrecordspt++ + fpenalty_shift ) > wm ) // naka ha osokute kamawanai #endif { // fprintf( stderr, "WARP!!\n" ); if( warpn && prevwarpi[j-1] == warpis[warpn-1] && prevwarpj[j-1] == warpjs[warpn-1] ) { *ijppt = warpbase + warpn - 1; } else { *ijppt = warpbase + warpn; warpis = realloc( warpis, sizeof(int) * ( warpn+1 ) ); warpjs = realloc( warpjs, sizeof(int) * ( warpn+1 ) ); warpis[warpn] = prevwarpi[j-1]; warpjs[warpn] = prevwarpj[j-1]; warpn++; } wm = g; } #if 0 fprintf( stderr, "%5.0f ", wm ); #endif curm = *curpt + wm; if( *wmrecords1pt > *wmrecordspt ) { *wmrecordspt = *wmrecords1pt; *warpipt = *(warpipt-1); *warpjpt = *(warpjpt-1); } if( curm > *wmrecordspt ) { *wmrecordspt = curm; *warpipt = i; *warpjpt = j; } wmrecordspt++; wmrecords1pt++; warpipt++; warpjpt++; } *curpt++ += wm; ijppt++; mjpt++; prept++; mpjpt++; fgcp2pt++; ogcp2pt++; gf2ptpre++; gf2pt++; } lastverticalw[i] = currentw[lgth2-1]; if( trywarp ) { fltncpy( prevwmrecords, wmrecords, lastj ); intncpy( prevwarpi, warpi, lastj ); intncpy( prevwarpj, warpj, lastj ); } } if( trywarp ) { // fprintf( stderr, "wm = %f\n", wm ); // fprintf( stderr, "warpn = %d\n", warpn ); free( wmrecords ); free( prevwmrecords ); free( warpi ); free( warpj ); free( prevwarpi ); free( prevwarpj ); } #if OUTGAP0TRY if( !outgap ) { for( j=1; j" ); for( i=0; i 20 ) // if( 0 ) // if( 1 ) { int limk = gt1bk + lgth1+lgth2 - gt1; limk = (int)(( (limk+1000) / 1000 ) * 1000); // kiriage //reporterr( "limk=%d\n", limk ); #if 1 // marume gosa wo teigenn suru tame double totaleff1 = 0.0; double totaleff2 = 0.0; for( i=0; i0.001 || fabs(totaleff2-1.0)>0.001 ) { reporterr( "totaleff1 = %50.40f\n", totaleff1 ); reporterr( "totaleff2 = %50.40f\n", totaleff2 ); exit( 1 ); } totaleff1 = totaleff1 * orieff1 / (orieff1 + orieff2); totaleff2 = totaleff2 * orieff2 / (orieff1 + orieff2); #else // reporterr( "totaleff1 (rescaled ) = %20.10f\n", totaleff1 ); // reporterr( "totaleff2 (rescaled ) = %20.10f\n", totaleff2 ); // double bk1 = totaleff1; // double bk2 = totaleff2; double totaleff1 = orieff1 / (orieff1 + orieff2); double totaleff2 = orieff2 / (orieff1 + orieff2); // reporterr( "totaleff1 (not rescaled) = %20.10f\n", totaleff1 ); // reporterr( "totaleff2 (not rescaled) = %20.10f\n", totaleff2 ); // reporterr( "ratio1 = %30.25f\n", totaleff1/bk1 ); // reporterr( "ratio2 = %30.25f\n", totaleff2/bk2 ); #endif *cpmxresult = AllocateDoubleMtx( nalphabets+3, 0 ); // gapcount, opg, fng no bun createcpmxresult( *cpmxresult, limk, totaleff1, totaleff2, cpmx1pt, cpmx2pt, gt1, gt2, (cpmx1!=*cpmx1pt), (cpmx2!=*cpmx2pt) ); // naka de free creategapfreqresult( *cpmxresult+nalphabets, limk, totaleff1, totaleff2, gapfreq1pt, gapfreq2pt, gt1, gt2 ); // naka deha free shinai // gapfreq1, gapfreq2 ha mada tsukau createogresult( *cpmxresult+nalphabets+1, limk, totaleff1, totaleff2, ogcp1opt, ogcp2opt, gapfreq1pt, gapfreq2pt, gt1, gt2 ); // naka deha free shinai if( cpmx1!=*cpmx1pt ) free( ogcp1opt ); if( cpmx2!=*cpmx2pt ) free( ogcp2opt ); createfgresult( *cpmxresult+nalphabets+2, limk, totaleff1, totaleff2, fgcp1opt, fgcp2opt, gapfreq1pt, gapfreq2pt, gt1, gt2 ); // naka deha free shinai if( cpmx1!=*cpmx1pt ) free( fgcp1opt ); if( cpmx2!=*cpmx2pt ) free( fgcp2opt ); if( cpmx1!=*cpmx1pt ) free( gapfreq1pt ); if( cpmx2!=*cpmx2pt ) free( gapfreq2pt ); #if 0 reporterr( "\n" ); for( j=0; j N ) { fprintf( stderr, "alloclen=%d, resultlen=%d, N=%d\n", alloclen, resultlen, N ); ErrorExit( "LENGTH OVER!\n" ); } if( ngap1 || !reuseprofiles ) for( i=0; i %d\n", strlen( seq1[0] ) ); previousfirstlen = lgth1; previousfirstmem = firstmem; previousicyc = icyc; previouscall = calledbyfulltreebase; free( mseq1 ); free( mseq2 ); FreeCharMtx( mseq ); return( wm ); } double A__align_gapmap( char **seq1, char **seq2, double *eff1, double *eff2, int icyc, int jcyc, int alloclen, int constraint, double *impmatch, int *gapmap1, int *gapmap2 ) /* score no keisan no sai motokaraaru gap no atukai ni mondai ga aru */ { fprintf( stderr, "Unexpected error. Please contact katoh@ifrec.osaka-u.ac.jp\n" ); exit( 1 ); } double A__align_variousdist( int **which, double ***matrices, double **n_dynamicmtx, int penalty_l, int penalty_ex_l, char **seq1, char **seq2, double *eff1, double *eff2, double **eff1s, double **eff2s, int icyc, int jcyc, int alloclen, int constraint, double *impmatch, char *sgap1, char *sgap2, char *egap1, char *egap2, int *chudanpt, int chudanref, int *chudanres, int headgp, int tailgp ) /* score no keisan no sai motokaraaru gap no atukai ni mondai ga aru */ { // int k; register int i, j, c; int ngap1, ngap2; int lasti, lastj; /* outgap == 0 -> lgth1, outgap == 1 -> lgth1+1 */ int lgth1, lgth2; int resultlen; double wm = 0.0; /* int ?????? */ double wmo = 0.0; /* int ?????? */ double g; double *currentw, *previousw; // double fpenalty = (double)penalty; #if USE_PENALTY_EX double fpenalty_ex = (double)penalty_ex_l; #endif #if 1 double *wtmp; int *ijppt; double *mjpt, *prept, *curpt; int *mpjpt; #endif static TLS double mi, *m; static TLS int **ijp; static TLS int mpi, *mp; static TLS double *w1, *w2; static TLS double *match; static TLS double *initverticalw; /* kufuu sureba iranai */ static TLS double *lastverticalw; /* kufuu sureba iranai */ static TLS char **mseq1; static TLS char **mseq2; static TLS char **mseq; static TLS double *ogcp1; static TLS double *ogcp2; static TLS double *fgcp1; static TLS double *fgcp2; static TLS double ***cpmx1s; static TLS double ***cpmx2s; static TLS int ***intwork; static TLS double ***doublework; static TLS int orlgth1 = 0, orlgth2 = 0; static TLS double *gapfreq1; static TLS double *gapfreq2; double fpenalty = (double)penalty_l; double fpenalty_shift = (double)penalty_shift; double *fgcp2pt; double *ogcp2pt; double fgcp1va; double ogcp1va; double *gf2pt; double *gf2ptpre; double gf1va; double gf1vapre; double headgapfreq1; double headgapfreq2; int *warpis = NULL; int *warpjs = NULL; int *warpi = NULL; int *warpj = NULL; int *prevwarpi = NULL; int *prevwarpj = NULL; double *wmrecords = NULL; double *prevwmrecords = NULL; int warpn = 0; int warpbase; double curm = 0.0; double *wmrecordspt, *wmrecords1pt, *prevwmrecordspt; int *warpipt, *warpjpt; int *nmask, **masklist1, **masklist2; if( seq1 == NULL ) { if( orlgth1 ) { // fprintf( stderr, "## Freeing local arrays in A__align\n" ); orlgth1 = 0; orlgth2 = 0; imp_match_init_strict( NULL, 0, 0, 0, 0, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 0, NULL, NULL, NULL, NULL, NULL, 0, 0 ); free( mseq1 ); free( mseq2 ); FreeFloatVec( w1 ); FreeFloatVec( w2 ); FreeFloatVec( match ); FreeFloatVec( initverticalw ); FreeFloatVec( lastverticalw ); FreeFloatVec( m ); FreeIntVec( mp ); FreeCharMtx( mseq ); FreeFloatVec( ogcp1 ); FreeFloatVec( ogcp2 ); FreeFloatVec( fgcp1 ); FreeFloatVec( fgcp2 ); FreeFloatCub( cpmx1s ); FreeFloatCub( cpmx2s ); FreeFloatVec( gapfreq1 ); FreeFloatVec( gapfreq2 ); FreeFloatCub( doublework ); FreeIntCub( intwork ); } else { // fprintf( stderr, "## Not allocated\n" ); } return( 0.0 ); } #if SLOW nmask = calloc( maxdistclass, sizeof( int ) ); #else masklist1 = AllocateIntMtx( maxdistclass, 0 ); masklist2 = AllocateIntMtx( maxdistclass, 0 ); nmask = calloc( maxdistclass, sizeof( int ) ); for( c=0; c orlgth1 || lgth2 > orlgth2 ) { int ll1, ll2; if( orlgth1 > 0 && orlgth2 > 0 ) { FreeFloatVec( w1 ); FreeFloatVec( w2 ); FreeFloatVec( match ); FreeFloatVec( initverticalw ); FreeFloatVec( lastverticalw ); FreeFloatVec( m ); FreeIntVec( mp ); FreeCharMtx( mseq ); FreeFloatVec( ogcp1 ); FreeFloatVec( ogcp2 ); FreeFloatVec( fgcp1 ); FreeFloatVec( fgcp2 ); FreeFloatCub( cpmx1s ); FreeFloatCub( cpmx2s ); FreeFloatVec( gapfreq1 ); FreeFloatVec( gapfreq2 ); FreeFloatCub( doublework ); FreeIntCub( intwork ); } ll1 = MAX( (int)(1.3*lgth1), orlgth1 ) + 100; ll2 = MAX( (int)(1.3*lgth2), orlgth2 ) + 100; #if DEBUG fprintf( stderr, "\ntrying to allocate (%d+%d)xn matrices ... ", ll1, ll2 ); #endif w1 = AllocateFloatVec( ll2+2 ); w2 = AllocateFloatVec( ll2+2 ); match = AllocateFloatVec( ll2+2 ); initverticalw = AllocateFloatVec( ll1+2 ); lastverticalw = AllocateFloatVec( ll1+2 ); m = AllocateFloatVec( ll2+2 ); mp = AllocateIntVec( ll2+2 ); mseq = AllocateCharMtx( njob, ll1+ll2 ); ogcp1 = AllocateFloatVec( ll1+2 ); ogcp2 = AllocateFloatVec( ll2+2 ); fgcp1 = AllocateFloatVec( ll1+2 ); fgcp2 = AllocateFloatVec( ll2+2 ); cpmx1s = AllocateFloatCub( maxdistclass, nalphabets, ll1+2 ); cpmx2s = AllocateFloatCub( maxdistclass, nalphabets, ll2+2 ); gapfreq1 = AllocateFloatVec( ll1+2 ); gapfreq2 = AllocateFloatVec( ll2+2 ); doublework = AllocateFloatCub( maxdistclass, MAX( ll1, ll2 )+2, nalphabets ); intwork = AllocateIntCub( maxdistclass, MAX( ll1, ll2 )+2, nalphabets+1 ); #if DEBUG fprintf( stderr, "succeeded\n" ); #endif orlgth1 = ll1 - 100; orlgth2 = ll2 - 100; } for( i=0; i commonAlloc1 || orlgth2 > commonAlloc2 ) { int ll1, ll2; if( commonAlloc1 && commonAlloc2 ) { FreeIntMtx( commonIP ); } ll1 = MAX( orlgth1, commonAlloc1 ); ll2 = MAX( orlgth2, commonAlloc2 ); #if DEBUG fprintf( stderr, "\n\ntrying to allocate %dx%d matrices ... ", ll1+1, ll2+1 ); #endif commonIP = AllocateIntMtx( ll1+10, ll2+10 ); #if DEBUG fprintf( stderr, "succeeded\n\n" ); #endif commonAlloc1 = ll1; commonAlloc2 = ll2; } ijp = commonIP; #if 0 { double t = 0.0; for( i=0; i tbfast.c // impossible if( localhom ) imp_match_calc( n_dynamicmtx, currentw, icyc, jcyc, lgth1, lgth2, seq1, seq2, eff1, eff2, localhom, 1, 0 ); #endif if( headgp == 1 ) { for( i=1; i", wm ); fprintf( stderr, "%5.0f? (penal=%5.2f)", g=mi+*fgcp2pt*(1.0-gapfreq1[i]), *fgcp2pt*(1.0-gapfreq1[i]) ); #endif if( (g=mi+*fgcp2pt*gf1va) > wm ) { wm = g; *ijppt = -( j - mpi ); // fprintf( stderr, "Jump to %d (%c)!", mpi, seq2[0][mpi] ); } if( (g=*prept+*ogcp2pt*gf1vapre) >= mi ) // if( (g=*prept+*ogcp2pt*gf1vapre) > mi ) { mi = g; mpi = j-1; } #if USE_PENALTY_EX mi += fpenalty_ex; #endif #if 0 fprintf( stderr, "%5.0f->", wm ); fprintf( stderr, "%5.0f? (penal=%5.2f)", g=*mjpt+fgcp1va*(1.0-gapfreq2[j]), fgcp1va*(1.0-gapfreq2[j]) ); #endif if( (g=*mjpt+ fgcp1va* *gf2pt) > wm ) { wm = g; *ijppt = +( i - *mpjpt ); // fprintf( stderr, "Jump to %d (%c)!", *mpjpt, seq1[0][*mpjpt] ); } if( (g=*prept+ ogcp1va* *gf2ptpre) >= *mjpt ) // if( (g=*prept+ ogcp1va* *gf2ptpre) > *mjpt ) { *mjpt = g; *mpjpt = i-1; } #if USE_PENALTY_EX m[j] += fpenalty_ex; #endif if( trywarp ) { #if USE_PENALTY_EX if( ( g=*prevwmrecordspt++ + fpenalty_shift + fpenalty_ex * ( i - prevwarpi[j-1] + j - prevwarpj[j-1] ) ) > wm ) // naka ha osokute kamawanai #else if( ( g=*prevwmrecordspt++ + fpenalty_shift ) > wm ) // naka ha osokute kamawanai #endif { if( warpn && prevwarpi[j-1] == warpis[warpn-1] && prevwarpj[j-1] == warpjs[warpn-1] ) { *ijppt = warpbase + warpn - 1; } else { *ijppt = warpbase + warpn; warpis = realloc( warpis, sizeof(int) * ( warpn+1 ) ); warpjs = realloc( warpjs, sizeof(int) * ( warpn+1 ) ); warpis[warpn] = prevwarpi[j-1]; warpjs[warpn] = prevwarpj[j-1]; warpn++; } wm = g; } curm = *curpt + wm; if( *wmrecords1pt > *wmrecordspt ) { *wmrecordspt = *wmrecords1pt; *warpipt = *(warpipt-1); *warpjpt = *(warpjpt-1); } if( curm > *wmrecordspt ) { *wmrecordspt = curm; *warpipt = i; *warpjpt = j; } wmrecordspt++; wmrecords1pt++; warpipt++; warpjpt++; } #if 0 fprintf( stderr, "%5.0f ", wm ); #endif *curpt++ += wm; ijppt++; mjpt++; prept++; mpjpt++; fgcp2pt++; ogcp2pt++; gf2ptpre++; gf2pt++; } lastverticalw[i] = currentw[lgth2-1]; if( trywarp ) { fltncpy( prevwmrecords, wmrecords, lastj ); intncpy( prevwarpi, warpi, lastj ); intncpy( prevwarpj, warpj, lastj ); } } if( trywarp ) { // fprintf( stderr, "wm = %f\n", wm ); // fprintf( stderr, "warpn = %d\n", warpn ); free( wmrecords ); free( prevwmrecords ); free( warpi ); free( warpj ); free( prevwarpi ); free( prevwarpj ); } #if OUTGAP0TRY if( !outgap ) { for( j=1; j" ); for( i=0; i N ) { fprintf( stderr, "alloclen=%d, resultlen=%d, N=%d\n", alloclen, resultlen, N ); ErrorExit( "LENGTH OVER!\n" ); } for( i=0; i