mirror of
https://github.com/servalproject/serval-dna.git
synced 2025-01-29 15:43:56 +00:00
gadzooks, rhizome over mdp appears to work.
This commit is contained in:
parent
dbb1fe8d1e
commit
41261bf122
@ -117,7 +117,7 @@ int overlay_mdp_service_rhizomerequest(overlay_mdp_frame *mdp)
|
||||
// read data for block
|
||||
if (blob_bytes>=blockOffset) {
|
||||
sqlite3_blob_read(blob,&reply.out.payload[1+16+8+8],
|
||||
blockBytes,0);
|
||||
blockBytes,blockOffset);
|
||||
reply.out.payload_length=1+16+8+8+blockBytes;
|
||||
|
||||
// Mark terminal block if required
|
||||
|
@ -1242,7 +1242,8 @@ void rhizome_write_content(struct rhizome_fetch_slot *slot, char *buffer, int by
|
||||
schedule(&slot->alarm);
|
||||
}
|
||||
|
||||
int rhizome_received_content(unsigned char *bidprefix,uint64_t version, uint64_t offset,
|
||||
int rhizome_received_content(unsigned char *bidprefix,
|
||||
uint64_t version, uint64_t offset,
|
||||
int count,unsigned char *bytes,int type)
|
||||
{
|
||||
IN();
|
||||
@ -1264,6 +1265,7 @@ int rhizome_received_content(unsigned char *bidprefix,uint64_t version, uint64_t
|
||||
else slot->file_len=offset+count+1;
|
||||
DEBUGF("Trying to write %d bytes @ %d (file len = %d)",
|
||||
count,(int)slot->file_ofs,(int)slot->file_len);
|
||||
dump("content", bytes,count);
|
||||
rhizome_write_content(slot,(char *)bytes,count);
|
||||
debug=0;
|
||||
slot->mdpRXWindowStart=offset+count;
|
||||
|
Loading…
x
Reference in New Issue
Block a user