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

test

Browse Source
This commit is contained in:
jl777
2016-11-04 16:26:07 -03:00
parent 2ef81a6e8b
commit 2ab43fd2fe
1 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/komodo_gateway.h
View File

@@ -25,6 +25,17 @@ struct pax_transaction
char symbol[16],coinaddr[64]; uint8_t rmd160[20],shortflag; char symbol[16],coinaddr[64]; uint8_t rmd160[20],shortflag;
} *PAX; } *PAX;
uint64_t komodo_paxtotal()
{
struct pax_transaction *pax,*tmp; uint64_t total = 0;
HASH_ITER(hh,PAX,pax,tmp)
{
if ( pax->marked == 0 )
total += pax->fiatoshis;
}
return(total);
}
struct pax_transaction *komodo_paxfind(struct pax_transaction *space,uint256 txid,uint16_t vout) struct pax_transaction *komodo_paxfind(struct pax_transaction *space,uint256 txid,uint16_t vout)
{ {
struct pax_transaction *pax; struct pax_transaction *pax;
@@ -41,6 +52,13 @@ struct pax_transaction *komodo_paxmark(struct pax_transaction *space,uint256 txi
struct pax_transaction *pax; struct pax_transaction *pax;
pthread_mutex_lock(&komodo_mutex); pthread_mutex_lock(&komodo_mutex);
HASH_FIND(hh,PAX,&txid,sizeof(txid),pax); HASH_FIND(hh,PAX,&txid,sizeof(txid),pax);
if ( pax == 0 )
{
pax = (struct pax_transaction *)calloc(1,sizeof(*pax));
pax->txid = txid;
pax->vout = vout;
HASH_ADD_KEYPTR(hh,PAX,&pax->txid,sizeof(pax->txid),pax);
}
if ( pax != 0 ) if ( pax != 0 )
{ {
pax->marked = mark; pax->marked = mark;
@@ -80,11 +98,8 @@ void komodo_gateway_deposit(char *coinaddr,uint64_t value,int32_t shortflag,char
} }
pax->txid = txid; pax->txid = txid;
pax->vout = vout; pax->vout = vout;
pthread_mutex_lock(&komodo_mutex);
HASH_ADD_KEYPTR(hh,PAX,&pax->txid,sizeof(pax->txid),pax); HASH_ADD_KEYPTR(hh,PAX,&pax->txid,sizeof(pax->txid),pax);
pthread_mutex_unlock(&komodo_mutex); pthread_mutex_unlock(&komodo_mutex);
KOMODO_DEPOSIT += fiatoshis;
pthread_mutex_unlock(&komodo_mutex);
} }
int32_t komodo_issued_opreturn(uint8_t *shortflagp,char *base,uint256 *txids,uint16_t *vouts,uint8_t *opretbuf,int32_t opretlen) int32_t komodo_issued_opreturn(uint8_t *shortflagp,char *base,uint256 *txids,uint16_t *vouts,uint8_t *opretbuf,int32_t opretlen)
@@ -401,4 +416,5 @@ void komodo_gateway_iteration(char *symbol)
printf("error from %s\n",symbol); printf("error from %s\n",symbol);
sleep(30); sleep(30);
} }
KOMODO_DEPOSIT = komodo_paxtotal();
} }