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

Streamline dice queue

Browse Source
This commit is contained in:
jl777
2018-08-01 22:42:04 -11:00
parent d83da823e0
commit b0a85aec3f
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/cc/dice.cpp
View File

@@ -122,6 +122,16 @@ void *dicefinish(void *_ptr)
res = DiceWinLoseTimeout(&result,0,name,ptr->fundingtxid,ptr->bettxid,ptr->iswin); res = DiceWinLoseTimeout(&result,0,name,ptr->fundingtxid,ptr->bettxid,ptr->iswin);
if ( result != 0 && res.empty() == 0 && res.size() > 64 && is_hexstr((char *)res.c_str(),0) > 64 ) if ( result != 0 && res.empty() == 0 && res.size() > 64 && is_hexstr((char *)res.c_str(),0) > 64 )
{ {
if ( DecodeHexTx(tx,res) != 0 )
{
LOCK(cs_main);
if ( myAddtomempool(tx) != 0 )
{
RelayTransaction(tx);
fprintf(stderr,"added to mempool and broadcast\n");
} else fprintf(stderr,"error adding to mempool\n");
} else fprintf(stderr,"error decoding hex\n");
/*
//LOCK(cs_main); //LOCK(cs_main);
if ( DecodeHexTx(tx,res) != 0 ) if ( DecodeHexTx(tx,res) != 0 )
{ {
@@ -135,9 +145,9 @@ void *dicefinish(void *_ptr)
sleep(10); sleep(10);
} else break; } else break;
} }
} }*/
} }
fprintf(stderr,"bettxid %s confirmed\n",uint256_str(str,ptr->bettxid)); /*fprintf(stderr,"bettxid %s confirmed\n",uint256_str(str,ptr->bettxid));
for (i=0; i<60; i++) for (i=0; i<60; i++)
{ {
res = DiceWinLoseTimeout(&result,0,name,ptr->fundingtxid,ptr->bettxid,ptr->iswin); res = DiceWinLoseTimeout(&result,0,name,ptr->fundingtxid,ptr->bettxid,ptr->iswin);
@@ -167,7 +177,7 @@ void *dicefinish(void *_ptr)
} }
} else fprintf(stderr,"error decoding result tx\n"); } else fprintf(stderr,"error decoding result tx\n");
sleep(10); sleep(10);
} }*/
} }
free(ptr); free(ptr);
return(0); return(0);