/* TA-LIB Copyright (c) 1999-2026, Mario Fortier * All rights reserved. * * Redistribution and use in source and binary forms, with or * without modification, are permitted provided that the following * conditions are met: * * - Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * - Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * - Neither name of author nor the names of its contributors * may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE * REGENTS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ /* AUTO-GENERATED by ta_codegen — DO NOT EDIT. * Source of truth: ta_codegen/input// (regenerate: cd ta_codegen/generator && cargo run -- generate) */ #include #include #include "ta_func.h" #include "ta_utility.h" #include "ta_memory.h" #include "ta_func_stream_private.h" /* List of contributors: * * Initial Name/description * ------------------------------------------------------------------- * AC Angelo Ciceri * MF Mario Fortier * CC Claude Code (AI assistant) * * * Change history: * * MMDDYY BY Description * ------------------------------------------------------------------- * 102304 AC Creation * 100426 MF,CC Remove the outInteger comment, which misstated the values */ TA_LIB_API int TA_CDLHAMMER_Lookback( void ) { int BodyShort_avgPeriod = TA_Globals->candleSettings[TA_BodyShort].avgPeriod; int Near_avgPeriod = TA_Globals->candleSettings[TA_Near].avgPeriod; int ShadowLong_avgPeriod = TA_Globals->candleSettings[TA_ShadowLong].avgPeriod; int ShadowVeryShort_avgPeriod = TA_Globals->candleSettings[TA_ShadowVeryShort].avgPeriod; return max(max(max(BodyShort_avgPeriod,ShadowLong_avgPeriod),ShadowVeryShort_avgPeriod),Near_avgPeriod) + 1; } TA_LIB_API int TA_CDLHAMMER_DisplayShift( int outputIdx ) { if( outputIdx < 0 || outputIdx >= 1 ) return INT_MIN; return 0; } TA_LIB_API TA_RetCode TA_CDLHAMMER( int startIdx, int endIdx, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int *outBegIdx, int *outNBElement, int outInteger[] ) { double BodyPeriodTotal; double ShadowLongPeriodTotal; double ShadowVeryShortPeriodTotal; double NearPeriodTotal; int i; int outIdx; int BodyTrailingIdx; int ShadowLongTrailingIdx; int ShadowVeryShortTrailingIdx; int NearTrailingIdx; int lookbackTotal; int BodyShort_avgPeriod = TA_Globals->candleSettings[TA_BodyShort].avgPeriod; int Near_avgPeriod = TA_Globals->candleSettings[TA_Near].avgPeriod; int ShadowLong_avgPeriod = TA_Globals->candleSettings[TA_ShadowLong].avgPeriod; int ShadowVeryShort_avgPeriod = TA_Globals->candleSettings[TA_ShadowVeryShort].avgPeriod; if( (startIdx < 0) || (startIdx > TA_INDEX_MAX) ) return TA_OUT_OF_RANGE_START_INDEX; if( (endIdx < 0) || (endIdx > TA_INDEX_MAX) || (endIdx < startIdx) ) return TA_OUT_OF_RANGE_END_INDEX; if( !inOpen ) return TA_BAD_PARAM; if( !inHigh ) return TA_BAD_PARAM; if( !inLow ) return TA_BAD_PARAM; if( !inClose ) return TA_BAD_PARAM; if( !outBegIdx || !outNBElement ) return TA_BAD_PARAM; if( !outInteger ) return TA_BAD_PARAM; /* Identify the minimum number of price bar needed * to calculate at least one output. */ lookbackTotal = TA_CDLHAMMER_Lookback(); /* Move up the start index if there is not * enough initial data. */ if( startIdx < lookbackTotal ) { startIdx = lookbackTotal; } /* Make sure there is still something to evaluate. */ if( startIdx > endIdx ) { *outBegIdx= 0; *outNBElement= 0; return TA_SUCCESS; } /* Do the calculation using tight loops. */ /* Add-up the initial period, except for the last value. */ BodyPeriodTotal = 0; BodyTrailingIdx = startIdx - BodyShort_avgPeriod; ShadowLongPeriodTotal = 0; ShadowLongTrailingIdx = startIdx - ShadowLong_avgPeriod; ShadowVeryShortPeriodTotal = 0; ShadowVeryShortTrailingIdx = startIdx - ShadowVeryShort_avgPeriod; NearPeriodTotal = 0; NearTrailingIdx = startIdx - 1 - Near_avgPeriod; i = BodyTrailingIdx; while( i < startIdx ) { BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i); i += 1; } i = ShadowLongTrailingIdx; while( i < startIdx ) { ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i); i += 1; } i = ShadowVeryShortTrailingIdx; while( i < startIdx ) { ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i); i += 1; } i = NearTrailingIdx; while( i < startIdx - 1 ) { NearPeriodTotal += TA_CANDLERANGE(Near,i); i += 1; } i = startIdx; /* Proceed with the calculation for the requested range. * Must have: * - small real body * - long lower shadow * - no, or very short, upper shadow * - body below or near the lows of the previous candle * The meaning of "short", "long" and "near the lows" is specified with TA_SetCandleSettings */ outIdx = 0; do { if( fabs(inClose[i] - inOpen[i]) < TA_CANDLEAVERAGE(BodyShort,BodyPeriodTotal,i) && /* small rb */ (((inClose[i] >= inOpen[i]) ? inOpen[i] : inClose[i]) - inLow[i]) > TA_CANDLEAVERAGE(ShadowLong,ShadowLongPeriodTotal,i) && /* long lower shadow */ (inHigh[i] - ((inClose[i] >= inOpen[i]) ? inClose[i] : inOpen[i])) < TA_CANDLEAVERAGE(ShadowVeryShort,ShadowVeryShortPeriodTotal,i) && /* very short upper shadow */ min(inClose[i],inOpen[i]) <= inLow[i - 1] + TA_CANDLEAVERAGE(Near,NearPeriodTotal,i - 1) ) /* rb near the prior candle's lows */ { outInteger[outIdx++] = 100; } else { outInteger[outIdx++] = 0; } /* add the current range and subtract the first range: this is done after the pattern recognition * when avgPeriod is not 0, that means "compare with the previous candles" (it excludes the current candle) */ BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i) - TA_CANDLERANGE(BodyShort,BodyTrailingIdx); ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i) - TA_CANDLERANGE(ShadowLong,ShadowLongTrailingIdx); ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i) - TA_CANDLERANGE(ShadowVeryShort,ShadowVeryShortTrailingIdx); NearPeriodTotal += TA_CANDLERANGE(Near,i - 1) - TA_CANDLERANGE(Near,NearTrailingIdx); i += 1; BodyTrailingIdx += 1; ShadowLongTrailingIdx += 1; ShadowVeryShortTrailingIdx += 1; NearTrailingIdx += 1; } while( i <= endIdx ); /* All done. Indicate the output limits and return. */ *outNBElement= outIdx; *outBegIdx= startIdx; return TA_SUCCESS; } TA_RetCode TA_S_CDLHAMMER( int startIdx, int endIdx, const float inOpen[], const float inHigh[], const float inLow[], const float inClose[], int *outBegIdx, int *outNBElement, int outInteger[] ) { double BodyPeriodTotal; double ShadowLongPeriodTotal; double ShadowVeryShortPeriodTotal; double NearPeriodTotal; int i; int outIdx; int BodyTrailingIdx; int ShadowLongTrailingIdx; int ShadowVeryShortTrailingIdx; int NearTrailingIdx; int lookbackTotal; int BodyShort_avgPeriod = TA_Globals->candleSettings[TA_BodyShort].avgPeriod; int Near_avgPeriod = TA_Globals->candleSettings[TA_Near].avgPeriod; int ShadowLong_avgPeriod = TA_Globals->candleSettings[TA_ShadowLong].avgPeriod; int ShadowVeryShort_avgPeriod = TA_Globals->candleSettings[TA_ShadowVeryShort].avgPeriod; if( (startIdx < 0) || (startIdx > TA_INDEX_MAX) ) return TA_OUT_OF_RANGE_START_INDEX; if( (endIdx < 0) || (endIdx > TA_INDEX_MAX) || (endIdx < startIdx) ) return TA_OUT_OF_RANGE_END_INDEX; if( !inOpen ) return TA_BAD_PARAM; if( !inHigh ) return TA_BAD_PARAM; if( !inLow ) return TA_BAD_PARAM; if( !inClose ) return TA_BAD_PARAM; if( !outBegIdx || !outNBElement ) return TA_BAD_PARAM; if( !outInteger ) return TA_BAD_PARAM; lookbackTotal = TA_CDLHAMMER_Lookback(); if( startIdx < lookbackTotal ) { startIdx = lookbackTotal; } if( startIdx > endIdx ) { *outBegIdx= 0; *outNBElement= 0; return TA_SUCCESS; } BodyPeriodTotal = 0; BodyTrailingIdx = startIdx - BodyShort_avgPeriod; ShadowLongPeriodTotal = 0; ShadowLongTrailingIdx = startIdx - ShadowLong_avgPeriod; ShadowVeryShortPeriodTotal = 0; ShadowVeryShortTrailingIdx = startIdx - ShadowVeryShort_avgPeriod; NearPeriodTotal = 0; NearTrailingIdx = startIdx - 1 - Near_avgPeriod; i = BodyTrailingIdx; while( i < startIdx ) { BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i); i += 1; } i = ShadowLongTrailingIdx; while( i < startIdx ) { ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i); i += 1; } i = ShadowVeryShortTrailingIdx; while( i < startIdx ) { ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i); i += 1; } i = NearTrailingIdx; while( i < startIdx - 1 ) { NearPeriodTotal += TA_CANDLERANGE(Near,i); i += 1; } i = startIdx; outIdx = 0; do { if( fabs((double)inClose[i] - (double)inOpen[i]) < TA_CANDLEAVERAGE(BodyShort,BodyPeriodTotal,i) && ((((double)inClose[i] >= (double)inOpen[i]) ? (double)inOpen[i] : (double)inClose[i]) - (double)inLow[i]) > TA_CANDLEAVERAGE(ShadowLong,ShadowLongPeriodTotal,i) && ((double)inHigh[i] - (((double)inClose[i] >= (double)inOpen[i]) ? (double)inClose[i] : (double)inOpen[i])) < TA_CANDLEAVERAGE(ShadowVeryShort,ShadowVeryShortPeriodTotal,i) && min((double)inClose[i],(double)inOpen[i]) <= (double)inLow[i - 1] + TA_CANDLEAVERAGE(Near,NearPeriodTotal,i - 1) ) { outInteger[outIdx++] = 100; } else { outInteger[outIdx++] = 0; } BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i) - TA_CANDLERANGE(BodyShort,BodyTrailingIdx); ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i) - TA_CANDLERANGE(ShadowLong,ShadowLongTrailingIdx); ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i) - TA_CANDLERANGE(ShadowVeryShort,ShadowVeryShortTrailingIdx); NearPeriodTotal += TA_CANDLERANGE(Near,i - 1) - TA_CANDLERANGE(Near,NearTrailingIdx); i += 1; BodyTrailingIdx += 1; ShadowLongTrailingIdx += 1; ShadowVeryShortTrailingIdx += 1; NearTrailingIdx += 1; } while( i <= endIdx ); *outNBElement= outIdx; *outBegIdx= startIdx; return TA_SUCCESS; } /**** Streaming API *****/ struct TA_CDLHAMMER_Stream { /* The bars this handle has an output for (see TA_CDLHAMMER_OutRange). */ int outRangeBegIdx; int outRangeCount; /* The value(s) at the last bar the stream counted (see TA_CDLHAMMER_Value). */ int cur_outInteger; double BodyPeriodTotal; double ShadowLongPeriodTotal; double ShadowVeryShortPeriodTotal; double NearPeriodTotal; double lag1_inOpen; double lag1_inHigh; double lag1_inLow; double lag1_inClose; int ringPos_BodyTrailingIdx; int ringCap_BodyTrailingIdx; double *ring_BodyTrailingIdx_derived; int ringPos_NearTrailingIdx; int ringCap_NearTrailingIdx; double *ring_NearTrailingIdx_derived; int ringPos_ShadowLongTrailingIdx; int ringCap_ShadowLongTrailingIdx; double *ring_ShadowLongTrailingIdx_derived; int ringPos_ShadowVeryShortTrailingIdx; int ringCap_ShadowVeryShortTrailingIdx; double *ring_ShadowVeryShortTrailingIdx_derived; }; /* Private function, not in public API. */ static void TA_CDLHAMMER_ReleaseImpl( struct TA_CDLHAMMER_Stream *sp ) { if( !sp ) return; if( sp->ring_BodyTrailingIdx_derived ) TA_Free( sp->ring_BodyTrailingIdx_derived ); if( sp->ring_NearTrailingIdx_derived ) TA_Free( sp->ring_NearTrailingIdx_derived ); if( sp->ring_ShadowLongTrailingIdx_derived ) TA_Free( sp->ring_ShadowLongTrailingIdx_derived ); if( sp->ring_ShadowVeryShortTrailingIdx_derived ) TA_Free( sp->ring_ShadowVeryShortTrailingIdx_derived ); TA_Free( sp ); } /* Private function, not in public API. */ static void TA_CDLHAMMER_StepImpl( struct TA_CDLHAMMER_Stream *sp, double inOpen, double inHigh, double inLow, double inClose, int *outInteger ) { if( sp->ringCap_BodyTrailingIdx == 0 ) { sp->ring_BodyTrailingIdx_derived[0] = TA_STREAM_CANDLERANGE(BodyShort,inOpen,inHigh,inLow,inClose); } if( sp->ringCap_NearTrailingIdx == 0 ) { sp->ring_NearTrailingIdx_derived[0] = TA_STREAM_CANDLERANGE(Near,inOpen,inHigh,inLow,inClose); } if( sp->ringCap_ShadowLongTrailingIdx == 0 ) { sp->ring_ShadowLongTrailingIdx_derived[0] = TA_STREAM_CANDLERANGE(ShadowLong,inOpen,inHigh,inLow,inClose); } if( sp->ringCap_ShadowVeryShortTrailingIdx == 0 ) { sp->ring_ShadowVeryShortTrailingIdx_derived[0] = TA_STREAM_CANDLERANGE(ShadowVeryShort,inOpen,inHigh,inLow,inClose); } if( fabs(inClose - inOpen) < TA_STREAM_CANDLEAVERAGE(BodyShort,sp->BodyPeriodTotal,inOpen,inHigh,inLow,inClose) && /* small rb */ (((inClose >= inOpen) ? inOpen : inClose) - inLow) > TA_STREAM_CANDLEAVERAGE(ShadowLong,sp->ShadowLongPeriodTotal,inOpen,inHigh,inLow,inClose) && /* long lower shadow */ (inHigh - ((inClose >= inOpen) ? inClose : inOpen)) < TA_STREAM_CANDLEAVERAGE(ShadowVeryShort,sp->ShadowVeryShortPeriodTotal,inOpen,inHigh,inLow,inClose) && /* very short upper shadow */ min(inClose,inOpen) <= sp->lag1_inLow + TA_STREAM_CANDLEAVERAGE(Near,sp->NearPeriodTotal,sp->lag1_inOpen,sp->lag1_inHigh,sp->lag1_inLow,sp->lag1_inClose) ) /* rb near the prior candle's lows */ { *outInteger= 100; } else { *outInteger= 0; } /* add the current range and subtract the first range: this is done after the pattern recognition * when avgPeriod is not 0, that means "compare with the previous candles" (it excludes the current candle) */ sp->BodyPeriodTotal += TA_STREAM_CANDLERANGE(BodyShort,inOpen,inHigh,inLow,inClose) - sp->ring_BodyTrailingIdx_derived[sp->ringPos_BodyTrailingIdx]; sp->ShadowLongPeriodTotal += TA_STREAM_CANDLERANGE(ShadowLong,inOpen,inHigh,inLow,inClose) - sp->ring_ShadowLongTrailingIdx_derived[sp->ringPos_ShadowLongTrailingIdx]; sp->ShadowVeryShortPeriodTotal += TA_STREAM_CANDLERANGE(ShadowVeryShort,inOpen,inHigh,inLow,inClose) - sp->ring_ShadowVeryShortTrailingIdx_derived[sp->ringPos_ShadowVeryShortTrailingIdx]; sp->NearPeriodTotal += TA_STREAM_CANDLERANGE(Near,sp->lag1_inOpen,sp->lag1_inHigh,sp->lag1_inLow,sp->lag1_inClose) - sp->ring_NearTrailingIdx_derived[sp->ringPos_NearTrailingIdx]; sp->cur_outInteger = *outInteger; sp->lag1_inOpen = inOpen; sp->lag1_inHigh = inHigh; sp->lag1_inLow = inLow; sp->lag1_inClose = inClose; sp->ring_BodyTrailingIdx_derived[sp->ringPos_BodyTrailingIdx] = TA_STREAM_CANDLERANGE(BodyShort,inOpen,inHigh,inLow,inClose); sp->ringPos_BodyTrailingIdx = sp->ringPos_BodyTrailingIdx + 1; if( sp->ringPos_BodyTrailingIdx >= sp->ringCap_BodyTrailingIdx ) { sp->ringPos_BodyTrailingIdx = 0; } sp->ring_NearTrailingIdx_derived[sp->ringPos_NearTrailingIdx] = TA_STREAM_CANDLERANGE(Near,inOpen,inHigh,inLow,inClose); sp->ringPos_NearTrailingIdx = sp->ringPos_NearTrailingIdx + 1; if( sp->ringPos_NearTrailingIdx >= sp->ringCap_NearTrailingIdx ) { sp->ringPos_NearTrailingIdx = 0; } sp->ring_ShadowLongTrailingIdx_derived[sp->ringPos_ShadowLongTrailingIdx] = TA_STREAM_CANDLERANGE(ShadowLong,inOpen,inHigh,inLow,inClose); sp->ringPos_ShadowLongTrailingIdx = sp->ringPos_ShadowLongTrailingIdx + 1; if( sp->ringPos_ShadowLongTrailingIdx >= sp->ringCap_ShadowLongTrailingIdx ) { sp->ringPos_ShadowLongTrailingIdx = 0; } sp->ring_ShadowVeryShortTrailingIdx_derived[sp->ringPos_ShadowVeryShortTrailingIdx] = TA_STREAM_CANDLERANGE(ShadowVeryShort,inOpen,inHigh,inLow,inClose); sp->ringPos_ShadowVeryShortTrailingIdx = sp->ringPos_ShadowVeryShortTrailingIdx + 1; if( sp->ringPos_ShadowVeryShortTrailingIdx >= sp->ringCap_ShadowVeryShortTrailingIdx ) { sp->ringPos_ShadowVeryShortTrailingIdx = 0; } } static TA_RetCode TA_CDLHAMMER_OpenImpl( struct TA_CDLHAMMER_Stream **stream, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int startIdx, int historyLen, int *outBegIdx, int *outNBElement, int outInteger[], int outStride ) { struct TA_CDLHAMMER_Stream *sp; int endIdx; if( !stream ) return TA_BAD_PARAM; *stream = NULL; if( historyLen < 1 ) return TA_OUT_OF_RANGE_START_INDEX; if( historyLen > TA_INDEX_MAX + 1 ) return TA_OUT_OF_RANGE_END_INDEX; if( !inOpen || !inHigh || !inLow || !inClose || !outInteger ) return TA_BAD_PARAM; if( startIdx > historyLen - 1 ) { *outBegIdx = 0; *outNBElement = 0; return TA_INSUFFICIENT_HISTORY; } endIdx = historyLen - 1; { int BodyShort_avgPeriod = TA_Globals->candleSettings[TA_BodyShort].avgPeriod; int Near_avgPeriod = TA_Globals->candleSettings[TA_Near].avgPeriod; int ShadowLong_avgPeriod = TA_Globals->candleSettings[TA_ShadowLong].avgPeriod; int ShadowVeryShort_avgPeriod = TA_Globals->candleSettings[TA_ShadowVeryShort].avgPeriod; double BodyPeriodTotal = 0.0; double ShadowLongPeriodTotal = 0.0; double ShadowVeryShortPeriodTotal = 0.0; double NearPeriodTotal = 0.0; int i; int outIdx; int BodyTrailingIdx; int ShadowLongTrailingIdx; int ShadowVeryShortTrailingIdx; int NearTrailingIdx; int lookbackTotal; /* Identify the minimum number of price bar needed * to calculate at least one output. */ lookbackTotal = TA_CDLHAMMER_Lookback(); /* Move up the start index if there is not * enough initial data. */ if( startIdx < lookbackTotal ) { startIdx = lookbackTotal; } /* Make sure there is still something to evaluate. */ if( startIdx > endIdx ) { *outBegIdx= 0; *outNBElement= 0; return TA_INSUFFICIENT_HISTORY; } /* Do the calculation using tight loops. */ /* Add-up the initial period, except for the last value. */ BodyPeriodTotal = 0; BodyTrailingIdx = startIdx - BodyShort_avgPeriod; ShadowLongPeriodTotal = 0; ShadowLongTrailingIdx = startIdx - ShadowLong_avgPeriod; ShadowVeryShortPeriodTotal = 0; ShadowVeryShortTrailingIdx = startIdx - ShadowVeryShort_avgPeriod; NearPeriodTotal = 0; NearTrailingIdx = startIdx - 1 - Near_avgPeriod; i = BodyTrailingIdx; while( i < startIdx ) { BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i); i += 1; } i = ShadowLongTrailingIdx; while( i < startIdx ) { ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i); i += 1; } i = ShadowVeryShortTrailingIdx; while( i < startIdx ) { ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i); i += 1; } i = NearTrailingIdx; while( i < startIdx - 1 ) { NearPeriodTotal += TA_CANDLERANGE(Near,i); i += 1; } i = startIdx; /* Proceed with the calculation for the requested range. * Must have: * - small real body * - long lower shadow * - no, or very short, upper shadow * - body below or near the lows of the previous candle * The meaning of "short", "long" and "near the lows" is specified with TA_SetCandleSettings */ outIdx = 0; do { if( fabs(inClose[i] - inOpen[i]) < TA_CANDLEAVERAGE(BodyShort,BodyPeriodTotal,i) && /* small rb */ (((inClose[i] >= inOpen[i]) ? inOpen[i] : inClose[i]) - inLow[i]) > TA_CANDLEAVERAGE(ShadowLong,ShadowLongPeriodTotal,i) && /* long lower shadow */ (inHigh[i] - ((inClose[i] >= inOpen[i]) ? inClose[i] : inOpen[i])) < TA_CANDLEAVERAGE(ShadowVeryShort,ShadowVeryShortPeriodTotal,i) && /* very short upper shadow */ min(inClose[i],inOpen[i]) <= inLow[i - 1] + TA_CANDLEAVERAGE(Near,NearPeriodTotal,i - 1) ) /* rb near the prior candle's lows */ { outInteger[outIdx++ * outStride] = 100; } else { outInteger[outIdx++ * outStride] = 0; } /* add the current range and subtract the first range: this is done after the pattern recognition * when avgPeriod is not 0, that means "compare with the previous candles" (it excludes the current candle) */ BodyPeriodTotal += TA_CANDLERANGE(BodyShort,i) - TA_CANDLERANGE(BodyShort,BodyTrailingIdx); ShadowLongPeriodTotal += TA_CANDLERANGE(ShadowLong,i) - TA_CANDLERANGE(ShadowLong,ShadowLongTrailingIdx); ShadowVeryShortPeriodTotal += TA_CANDLERANGE(ShadowVeryShort,i) - TA_CANDLERANGE(ShadowVeryShort,ShadowVeryShortTrailingIdx); NearPeriodTotal += TA_CANDLERANGE(Near,i - 1) - TA_CANDLERANGE(Near,NearTrailingIdx); i += 1; BodyTrailingIdx += 1; ShadowLongTrailingIdx += 1; ShadowVeryShortTrailingIdx += 1; NearTrailingIdx += 1; } while( i <= endIdx ); /* All done. Indicate the output limits and return. */ *outNBElement= outIdx; *outBegIdx= startIdx; /* Capture the live batch state into the handle. */ sp = (struct TA_CDLHAMMER_Stream *)TA_Malloc( sizeof(*sp) ); if( !sp ) { return TA_ALLOC_ERR; } memset( sp, 0, sizeof(*sp) ); sp->BodyPeriodTotal = BodyPeriodTotal; sp->ShadowLongPeriodTotal = ShadowLongPeriodTotal; sp->ShadowVeryShortPeriodTotal = ShadowVeryShortPeriodTotal; sp->NearPeriodTotal = NearPeriodTotal; sp->ringCap_BodyTrailingIdx = (int)(i - BodyTrailingIdx); if( sp->ringCap_BodyTrailingIdx < 0 || sp->ringCap_BodyTrailingIdx > historyLen ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_INTERNAL_ERROR(238); } { size_t allocN = (size_t)(sp->ringCap_BodyTrailingIdx > 0 ? sp->ringCap_BodyTrailingIdx : 1); sp->ring_BodyTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * allocN ); if( !sp->ring_BodyTrailingIdx_derived ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_ALLOC_ERR; } { int fillJ; for( fillJ = historyLen - sp->ringCap_BodyTrailingIdx; fillJ < historyLen; fillJ++ ) sp->ring_BodyTrailingIdx_derived[fillJ - (historyLen - sp->ringCap_BodyTrailingIdx)] = TA_STREAM_CANDLERANGE(BodyShort,inOpen[fillJ],inHigh[fillJ],inLow[fillJ],inClose[fillJ]); } } sp->ringPos_BodyTrailingIdx = 0; sp->ringCap_NearTrailingIdx = (int)(i - NearTrailingIdx); if( sp->ringCap_NearTrailingIdx < 0 || sp->ringCap_NearTrailingIdx > historyLen ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_INTERNAL_ERROR(239); } { size_t allocN = (size_t)(sp->ringCap_NearTrailingIdx > 0 ? sp->ringCap_NearTrailingIdx : 1); sp->ring_NearTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * allocN ); if( !sp->ring_NearTrailingIdx_derived ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_ALLOC_ERR; } { int fillJ; for( fillJ = historyLen - sp->ringCap_NearTrailingIdx; fillJ < historyLen; fillJ++ ) sp->ring_NearTrailingIdx_derived[fillJ - (historyLen - sp->ringCap_NearTrailingIdx)] = TA_STREAM_CANDLERANGE(Near,inOpen[fillJ],inHigh[fillJ],inLow[fillJ],inClose[fillJ]); } } sp->ringPos_NearTrailingIdx = 0; sp->ringCap_ShadowLongTrailingIdx = (int)(i - ShadowLongTrailingIdx); if( sp->ringCap_ShadowLongTrailingIdx < 0 || sp->ringCap_ShadowLongTrailingIdx > historyLen ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_INTERNAL_ERROR(240); } { size_t allocN = (size_t)(sp->ringCap_ShadowLongTrailingIdx > 0 ? sp->ringCap_ShadowLongTrailingIdx : 1); sp->ring_ShadowLongTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * allocN ); if( !sp->ring_ShadowLongTrailingIdx_derived ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_ALLOC_ERR; } { int fillJ; for( fillJ = historyLen - sp->ringCap_ShadowLongTrailingIdx; fillJ < historyLen; fillJ++ ) sp->ring_ShadowLongTrailingIdx_derived[fillJ - (historyLen - sp->ringCap_ShadowLongTrailingIdx)] = TA_STREAM_CANDLERANGE(ShadowLong,inOpen[fillJ],inHigh[fillJ],inLow[fillJ],inClose[fillJ]); } } sp->ringPos_ShadowLongTrailingIdx = 0; sp->ringCap_ShadowVeryShortTrailingIdx = (int)(i - ShadowVeryShortTrailingIdx); if( sp->ringCap_ShadowVeryShortTrailingIdx < 0 || sp->ringCap_ShadowVeryShortTrailingIdx > historyLen ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_INTERNAL_ERROR(241); } { size_t allocN = (size_t)(sp->ringCap_ShadowVeryShortTrailingIdx > 0 ? sp->ringCap_ShadowVeryShortTrailingIdx : 1); sp->ring_ShadowVeryShortTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * allocN ); if( !sp->ring_ShadowVeryShortTrailingIdx_derived ) { TA_CDLHAMMER_ReleaseImpl( sp ); return TA_ALLOC_ERR; } { int fillJ; for( fillJ = historyLen - sp->ringCap_ShadowVeryShortTrailingIdx; fillJ < historyLen; fillJ++ ) sp->ring_ShadowVeryShortTrailingIdx_derived[fillJ - (historyLen - sp->ringCap_ShadowVeryShortTrailingIdx)] = TA_STREAM_CANDLERANGE(ShadowVeryShort,inOpen[fillJ],inHigh[fillJ],inLow[fillJ],inClose[fillJ]); } } sp->ringPos_ShadowVeryShortTrailingIdx = 0; sp->lag1_inOpen = inOpen[historyLen - 1]; sp->lag1_inHigh = inHigh[historyLen - 1]; sp->lag1_inLow = inLow[historyLen - 1]; sp->lag1_inClose = inClose[historyLen - 1]; sp->outRangeBegIdx = *outBegIdx; sp->outRangeCount = *outNBElement; sp->cur_outInteger = outInteger[(*outNBElement - 1) * outStride]; *stream = sp; return TA_SUCCESS; } } /* Private function, not in public API. */ TA_RetCode TA_CDLHAMMER_OpenInternal( struct TA_CDLHAMMER_Stream **stream, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int startIdx, int historyLen, int *outInteger ) { TA_RetCode retCode; int dummyBegIdx = 0; int dummyNBElement = 0; int sink_outInteger = 0; retCode = TA_CDLHAMMER_OpenImpl( stream, inOpen, inHigh, inLow, inClose, startIdx, historyLen, &dummyBegIdx, &dummyNBElement, &sink_outInteger, 0 ); if( retCode == TA_SUCCESS ) { *outInteger = sink_outInteger; } return retCode; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Open( TA_CDLHAMMER_Stream **stream, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int historyLen, int *outInteger ) { if( !stream ) return TA_BAD_PARAM; *stream = NULL; if( historyLen < 1 ) return TA_OUT_OF_RANGE_START_INDEX; if( historyLen > TA_INDEX_MAX + 1 ) return TA_OUT_OF_RANGE_END_INDEX; if( !inOpen || !inHigh || !inLow || !inClose || !outInteger ) return TA_BAD_PARAM; return TA_CDLHAMMER_OpenInternal( stream, inOpen, inHigh, inLow, inClose, 0, historyLen, outInteger ); } TA_LIB_API TA_RetCode TA_CDLHAMMER_OpenAndFill( TA_CDLHAMMER_Stream **stream, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int historyLen, int *outBegIdx, int *outNBElement, int outInteger[] ) { if( !stream ) return TA_BAD_PARAM; *stream = NULL; if( historyLen < 1 ) return TA_OUT_OF_RANGE_START_INDEX; if( historyLen > TA_INDEX_MAX + 1 ) return TA_OUT_OF_RANGE_END_INDEX; if( !inOpen || !inHigh || !inLow || !inClose || !outBegIdx || !outNBElement || !outInteger ) return TA_BAD_PARAM; if( (const void *)outInteger == (const void *)inOpen || (const void *)outInteger == (const void *)inHigh || (const void *)outInteger == (const void *)inLow || (const void *)outInteger == (const void *)inClose ) return TA_BAD_PARAM; return TA_CDLHAMMER_OpenAndFillInternal( stream, inOpen, inHigh, inLow, inClose, 0, historyLen, outBegIdx, outNBElement, outInteger ); } /* Private function, not in public API. */ TA_RetCode TA_CDLHAMMER_OpenAndFillInternal( struct TA_CDLHAMMER_Stream **stream, const double inOpen[], const double inHigh[], const double inLow[], const double inClose[], int startIdx, int historyLen, int *outBegIdx, int *outNBElement, int outInteger[] ) { return TA_CDLHAMMER_OpenImpl( stream, inOpen, inHigh, inLow, inClose, startIdx, historyLen, outBegIdx, outNBElement, outInteger, 1 ); } TA_LIB_API TA_RetCode TA_CDLHAMMER_Update( TA_CDLHAMMER_Stream *stream, double inOpen, double inHigh, double inLow, double inClose, int *outInteger ) { if( !stream ) return TA_BAD_PARAM; if( stream->outRangeBegIdx + stream->outRangeCount > TA_INDEX_MAX ) return TA_OUT_OF_RANGE_END_INDEX; if( !outInteger ) return TA_BAD_PARAM; if( !TA_IS_FINITE( inOpen ) || !TA_IS_FINITE( inHigh ) || !TA_IS_FINITE( inLow ) || !TA_IS_FINITE( inClose ) ) return TA_BAD_PARAM; TA_CDLHAMMER_StepImpl( stream, inOpen, inHigh, inLow, inClose, outInteger ); stream->outRangeCount++; return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Peek( const TA_CDLHAMMER_Stream *stream, double inOpen, double inHigh, double inLow, double inClose, int *outInteger ) { const struct TA_CDLHAMMER_Stream *sp = stream; if( !stream || !outInteger ) return TA_BAD_PARAM; if( !TA_IS_FINITE( inOpen ) || !TA_IS_FINITE( inHigh ) || !TA_IS_FINITE( inLow ) || !TA_IS_FINITE( inClose ) ) return TA_BAD_PARAM; if( fabs(inClose - inOpen) < TA_STREAM_CANDLEAVERAGE(BodyShort,sp->BodyPeriodTotal,inOpen,inHigh,inLow,inClose) && /* small rb */ (((inClose >= inOpen) ? inOpen : inClose) - inLow) > TA_STREAM_CANDLEAVERAGE(ShadowLong,sp->ShadowLongPeriodTotal,inOpen,inHigh,inLow,inClose) && /* long lower shadow */ (inHigh - ((inClose >= inOpen) ? inClose : inOpen)) < TA_STREAM_CANDLEAVERAGE(ShadowVeryShort,sp->ShadowVeryShortPeriodTotal,inOpen,inHigh,inLow,inClose) && /* very short upper shadow */ min(inClose,inOpen) <= sp->lag1_inLow + TA_STREAM_CANDLEAVERAGE(Near,sp->NearPeriodTotal,sp->lag1_inOpen,sp->lag1_inHigh,sp->lag1_inLow,sp->lag1_inClose) ) /* rb near the prior candle's lows */ { *outInteger= 100; } else { *outInteger= 0; } return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Close( TA_CDLHAMMER_Stream *stream ) { TA_CDLHAMMER_ReleaseImpl( stream ); return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Value( const TA_CDLHAMMER_Stream *stream, int *outInteger ) { if( !stream || !outInteger ) return TA_BAD_PARAM; *outInteger = stream->cur_outInteger; return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_OutRange( const TA_CDLHAMMER_Stream *stream, int *outBegIdx, int *outNBElement ) { if( !stream || !outBegIdx || !outNBElement ) return TA_BAD_PARAM; *outBegIdx = stream->outRangeBegIdx; *outNBElement = stream->outRangeCount; return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Advance( TA_CDLHAMMER_Stream *stream ) { if( !stream ) return TA_BAD_PARAM; if( stream->outRangeBegIdx + stream->outRangeCount > TA_INDEX_MAX ) return TA_OUT_OF_RANGE_END_INDEX; stream->outRangeCount++; return TA_SUCCESS; } TA_LIB_API TA_RetCode TA_CDLHAMMER_Clone( const TA_CDLHAMMER_Stream *stream, TA_CDLHAMMER_Stream **clone ) { struct TA_CDLHAMMER_Stream *sp; if( !clone ) return TA_BAD_PARAM; *clone = NULL; if( !stream ) return TA_BAD_PARAM; sp = (struct TA_CDLHAMMER_Stream *)TA_Malloc( sizeof(*sp) ); if( !sp ) return TA_ALLOC_ERR; *sp = *stream; sp->ring_BodyTrailingIdx_derived = NULL; sp->ring_NearTrailingIdx_derived = NULL; sp->ring_ShadowLongTrailingIdx_derived = NULL; sp->ring_ShadowVeryShortTrailingIdx_derived = NULL; if( stream->ring_BodyTrailingIdx_derived ) { size_t copyN = (size_t)(sp->ringCap_BodyTrailingIdx > 0 ? sp->ringCap_BodyTrailingIdx : 1); sp->ring_BodyTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * copyN ); if( !sp->ring_BodyTrailingIdx_derived ) { TA_CDLHAMMER_Close( sp ); return TA_ALLOC_ERR; } memcpy( sp->ring_BodyTrailingIdx_derived, stream->ring_BodyTrailingIdx_derived, sizeof(double) * copyN ); } if( stream->ring_NearTrailingIdx_derived ) { size_t copyN = (size_t)(sp->ringCap_NearTrailingIdx > 0 ? sp->ringCap_NearTrailingIdx : 1); sp->ring_NearTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * copyN ); if( !sp->ring_NearTrailingIdx_derived ) { TA_CDLHAMMER_Close( sp ); return TA_ALLOC_ERR; } memcpy( sp->ring_NearTrailingIdx_derived, stream->ring_NearTrailingIdx_derived, sizeof(double) * copyN ); } if( stream->ring_ShadowLongTrailingIdx_derived ) { size_t copyN = (size_t)(sp->ringCap_ShadowLongTrailingIdx > 0 ? sp->ringCap_ShadowLongTrailingIdx : 1); sp->ring_ShadowLongTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * copyN ); if( !sp->ring_ShadowLongTrailingIdx_derived ) { TA_CDLHAMMER_Close( sp ); return TA_ALLOC_ERR; } memcpy( sp->ring_ShadowLongTrailingIdx_derived, stream->ring_ShadowLongTrailingIdx_derived, sizeof(double) * copyN ); } if( stream->ring_ShadowVeryShortTrailingIdx_derived ) { size_t copyN = (size_t)(sp->ringCap_ShadowVeryShortTrailingIdx > 0 ? sp->ringCap_ShadowVeryShortTrailingIdx : 1); sp->ring_ShadowVeryShortTrailingIdx_derived = (double *)TA_Malloc( sizeof(double) * copyN ); if( !sp->ring_ShadowVeryShortTrailingIdx_derived ) { TA_CDLHAMMER_Close( sp ); return TA_ALLOC_ERR; } memcpy( sp->ring_ShadowVeryShortTrailingIdx_derived, stream->ring_ShadowVeryShortTrailingIdx_derived, sizeof(double) * copyN ); } *clone = sp; return TA_SUCCESS; }