DragonX/dragonx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

+print

Browse Source
This commit is contained in:
jl777
2019-04-12 08:56:44 -11:00
parent d0fd337b25
commit f3056d4829
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/komodo_gateway.h
View File

@@ -2197,9 +2197,9 @@ int32_t komodo_cbopretsize(uint64_t flags)
if ( (ASSETCHAINS_CBOPRET & 2) != 0 ) if ( (ASSETCHAINS_CBOPRET & 2) != 0 )
size += (sizeof(Forex)/sizeof(*Forex)) * sizeof(uint32_t); size += (sizeof(Forex)/sizeof(*Forex)) * sizeof(uint32_t);
if ( (ASSETCHAINS_CBOPRET & 4) != 0 ) if ( (ASSETCHAINS_CBOPRET & 4) != 0 )
size += (sizeof(Cryptos)/sizeof(*Cryptos) + ASSETCHAINS_PRICES.size())*sizeof(uint32_t); size += (sizeof(Cryptos)/sizeof(*Cryptos) + ASSETCHAINS_PRICES.size()) * sizeof(uint32_t);
if ( (ASSETCHAINS_CBOPRET & 8) != 0 ) if ( (ASSETCHAINS_CBOPRET & 8) != 0 )
size += (ASSETCHAINS_STOCKS.size())*sizeof(uint32_t); size += (ASSETCHAINS_STOCKS.size() * sizeof(uint32_t));
} }
return(size); return(size);
} }
@@ -2661,7 +2661,7 @@ int64_t komodo_priceave(int64_t *buf,int64_t *correlated,int32_t cskip)
int32_t komodo_pricesinit() int32_t komodo_pricesinit()
{ {
static int32_t didinit; static int32_t didinit;
int32_t i,createflag = 0; int32_t i,num=0,createflag = 0;
if ( didinit != 0 ) if ( didinit != 0 )
return(-1); return(-1);
didinit = 1; didinit = 1;
@@ -2676,12 +2676,15 @@ int32_t komodo_pricesinit()
if ( i == 0 ) if ( i == 0 )
strcpy(PRICES[i].symbol,"rawprices"); strcpy(PRICES[i].symbol,"rawprices");
pricefname = pricesdir / PRICES[i].symbol; pricefname = pricesdir / PRICES[i].symbol;
PRICES[i].fp = fopen(pricefname.string().c_str(), createflag != 0 ? "wb+" : "rb+"); if ( (PRICES[i].fp= fopen(pricefname.string().c_str(), createflag != 0 ? "wb+" : "rb+")) != 0 )
if ( createflag != 0 )
{ {
fseek(PRICES[i].fp,(2*PRICES_DAYWINDOW+PRICES_SMOOTHWIDTH) * sizeof(int64_t) * PRICES_MAXDATAPOINTS,SEEK_SET); num++;
fputc(0,PRICES[i].fp); if ( createflag != 0 )
fflush(PRICES[i].fp); {
fseek(PRICES[i].fp,(2*PRICES_DAYWINDOW+PRICES_SMOOTHWIDTH) * sizeof(int64_t) * PRICES_MAXDATAPOINTS,SEEK_SET);
fputc(0,PRICES[i].fp);
fflush(PRICES[i].fp);
}
} }
} }
if ( i > 0 && PRICES[0].fp != 0 && createflag != 0 ) if ( i > 0 && PRICES[0].fp != 0 && createflag != 0 )
@@ -2690,7 +2693,7 @@ int32_t komodo_pricesinit()
fputc(0,PRICES[0].fp); fputc(0,PRICES[0].fp);
fflush(PRICES[0].fp); fflush(PRICES[0].fp);
} }
fprintf(stderr,"pricesinit done\n"); fprintf(stderr,"pricesinit done i.%d num.%d numprices.%d\n",i,num,(int32_t)(komodo_cbopretsize(ASSETCHAINS_CBOPRET)/sizeof(uint32_t)));
return(0); return(0);
} }