Browse Source

test

release/v0.1
jl777 8 years ago
parent
commit
83406c627d
  1. 8
      basilisk/basilisk.c
  2. 5
      iguana/iguana_peers.c

8
basilisk/basilisk.c

@ -191,14 +191,18 @@ int32_t basilisk_sendcmd(struct supernet_info *myinfo,char *destipaddr,char *typ
cmd[6] = 'E', cmd[7] = 'T'; cmd[6] = 'E', cmd[7] = 'T';
HASH_ITER(hh,myinfo->allcoins,coin,tmp) HASH_ITER(hh,myinfo->allcoins,coin,tmp)
{ {
printf("basilisk iter.(%s) -> (%s)\n",coin->symbol,destipaddr); printf("basilisk iter.(%s) -> (%s) %p\n",coin->symbol,destipaddr,coin->peers);
if ( coin->peers == 0 ) if ( coin->peers == 0 )
continue; continue;
printf("basilisk iter.(%s) -> (%s) %llx\n",coin->symbol,destipaddr,(long long)calc_ipbits(destipaddr));
if ( (addr= iguana_peerslot(coin,calc_ipbits(destipaddr),0)) != 0 ) if ( (addr= iguana_peerslot(coin,calc_ipbits(destipaddr),0)) != 0 )
{ {
printf("RET [%d] to %s\n",datalen,addr->ipaddr); printf("RET [%d] to %s\n",datalen,addr->ipaddr);
fprintf(stderr,"RET [%d] to %s\n",datalen,addr->ipaddr);
return(iguana_queue_send(addr,delaymillis,&data[-(int32_t)sizeof(struct iguana_msghdr)],cmd,datalen)); return(iguana_queue_send(addr,delaymillis,&data[-(int32_t)sizeof(struct iguana_msghdr)],cmd,datalen));
} else printf("cant find (%s) in (%s)\n",addr->ipaddr,coin->symbol); }
printf("cant find (%s) in (%s)\n",addr->ipaddr,coin->symbol);
fprintf(stderr,"cant find (%s) in (%s)\n",addr->ipaddr,coin->symbol);
} }
printf("cant find (%s) to RET to\n",addr->ipaddr); printf("cant find (%s) to RET to\n",addr->ipaddr);
return(-1); return(-1);

5
iguana/iguana_peers.c

@ -517,7 +517,7 @@ int32_t iguana_send(struct iguana_info *coin,struct iguana_peer *addr,uint8_t *s
} }
} }
addr->totalsent += len; addr->totalsent += len;
if ( 0 && addr->msgcounts.verack == 0 ) if ( addr->basilisk != 0 )
printf("verack.%d (%s) sent.%d bytes to %s\n",addr->msgcounts.verack,cmdstr,len,addr->ipaddr); printf("verack.%d (%s) sent.%d bytes to %s\n",addr->msgcounts.verack,cmdstr,len,addr->ipaddr);
return(len); return(len);
} }
@ -546,7 +546,8 @@ int32_t iguana_queue_send(struct iguana_peer *addr,int32_t delay,uint8_t *serial
packet->embargo.millis += delay; packet->embargo.millis += delay;
} }
memcpy(packet->serialized,serialized,datalen); memcpy(packet->serialized,serialized,datalen);
//printf("%p queue send.(%s) %d to (%s)\n",packet,serialized+4,datalen,addr->ipaddr); if ( addr->basilisk != 0 )
printf("%p queue send.(%s) %d to (%s)\n",packet,serialized+4,datalen,addr->ipaddr);
queue_enqueue("sendQ",&addr->sendQ,&packet->DL,0); queue_enqueue("sendQ",&addr->sendQ,&packet->DL,0);
return(datalen); return(datalen);
} }

Loading…
Cancel
Save