Lines Matching refs:bp
17 __rep_bulk_marshal(env, argp, bp, max, lenp)
20 u_int8_t *bp;
28 start = bp;
30 DB_HTONL_COPYOUT(env, bp, argp->len);
31 DB_HTONL_COPYOUT(env, bp, argp->lsn.file);
32 DB_HTONL_COPYOUT(env, bp, argp->lsn.offset);
33 DB_HTONL_COPYOUT(env, bp, argp->bulkdata.size);
35 memcpy(bp, argp->bulkdata.data, argp->bulkdata.size);
36 bp += argp->bulkdata.size;
39 *lenp = (size_t)(bp - start);
48 __rep_bulk_unmarshal(env, argp, bp, max, nextp)
51 u_int8_t *bp;
60 DB_NTOHL_COPYIN(env, argp->len, bp);
61 DB_NTOHL_COPYIN(env, argp->lsn.file, bp);
62 DB_NTOHL_COPYIN(env, argp->lsn.offset, bp);
63 DB_NTOHL_COPYIN(env, argp->bulkdata.size, bp);
64 argp->bulkdata.data = bp;
68 bp += argp->bulkdata.size;
71 *nextp = bp;
85 __rep_control_marshal(env, argp, bp, max, lenp)
88 u_int8_t *bp;
95 start = bp;
97 DB_HTONL_COPYOUT(env, bp, argp->rep_version);
98 DB_HTONL_COPYOUT(env, bp, argp->log_version);
99 DB_HTONL_COPYOUT(env, bp, argp->lsn.file);
100 DB_HTONL_COPYOUT(env, bp, argp->lsn.offset);
101 DB_HTONL_COPYOUT(env, bp, argp->rectype);
102 DB_HTONL_COPYOUT(env, bp, argp->gen);
103 DB_HTONL_COPYOUT(env, bp, argp->msg_sec);
104 DB_HTONL_COPYOUT(env, bp, argp->msg_nsec);
105 DB_HTONL_COPYOUT(env, bp, argp->flags);
107 *lenp = (size_t)(bp - start);
116 __rep_control_unmarshal(env, argp, bp, max, nextp)
119 u_int8_t *bp;
125 DB_NTOHL_COPYIN(env, argp->rep_version, bp);
126 DB_NTOHL_COPYIN(env, argp->log_version, bp);
127 DB_NTOHL_COPYIN(env, argp->lsn.file, bp);
128 DB_NTOHL_COPYIN(env, argp->lsn.offset, bp);
129 DB_NTOHL_COPYIN(env, argp->rectype, bp);
130 DB_NTOHL_COPYIN(env, argp->gen, bp);
131 DB_NTOHL_COPYIN(env, argp->msg_sec, bp);
132 DB_NTOHL_COPYIN(env, argp->msg_nsec, bp);
133 DB_NTOHL_COPYIN(env, argp->flags, bp);
136 *nextp = bp;
150 __rep_egen_marshal(env, argp, bp, max, lenp)
153 u_int8_t *bp;
160 start = bp;
162 DB_HTONL_COPYOUT(env, bp, argp->egen);
164 *lenp = (size_t)(bp - start);
173 __rep_egen_unmarshal(env, argp, bp, max, nextp)
176 u_int8_t *bp;
182 DB_NTOHL_COPYIN(env, argp->egen, bp);
185 *nextp = bp;
199 __rep_fileinfo_marshal(env, version, argp, bp, max, lenp)
203 u_int8_t *bp;
213 start = bp;
219 memcpy(bp, &argp->pgsize, sizeof(u_int32_t));
220 bp += sizeof(u_int32_t);
222 DB_HTONL_COPYOUT(env, bp, argp->pgsize);
224 memcpy(bp, &argp->pgno, sizeof(u_int32_t));
225 bp += sizeof(u_int32_t);
227 DB_HTONL_COPYOUT(env, bp, argp->pgno);
229 memcpy(bp, &argp->max_pgno, sizeof(u_int32_t));
230 bp += sizeof(u_int32_t);
232 DB_HTONL_COPYOUT(env, bp, argp->max_pgno);
234 memcpy(bp, &argp->filenum, sizeof(u_int32_t));
235 bp += sizeof(u_int32_t);
237 DB_HTONL_COPYOUT(env, bp, argp->filenum);
239 memcpy(bp, &argp->finfo_flags, sizeof(u_int32_t));
240 bp += sizeof(u_int32_t);
242 DB_HTONL_COPYOUT(env, bp, argp->finfo_flags);
244 memcpy(bp, &argp->type, sizeof(u_int32_t));
245 bp += sizeof(u_int32_t);
247 DB_HTONL_COPYOUT(env, bp, argp->type);
249 memcpy(bp, &argp->db_flags, sizeof(u_int32_t));
250 bp += sizeof(u_int32_t);
252 DB_HTONL_COPYOUT(env, bp, argp->db_flags);
254 memcpy(bp, &argp->uid.size, sizeof(u_int32_t));
255 bp += sizeof(u_int32_t);
257 DB_HTONL_COPYOUT(env, bp, argp->uid.size);
259 memcpy(bp, argp->uid.data, argp->uid.size);
260 bp += argp->uid.size;
263 memcpy(bp, &argp->info.size, sizeof(u_int32_t));
264 bp += sizeof(u_int32_t);
266 DB_HTONL_COPYOUT(env, bp, argp->info.size);
268 memcpy(bp, argp->info.data, argp->info.size);
269 bp += argp->info.size;
272 *lenp = (size_t)(bp - start);
281 __rep_fileinfo_unmarshal(env, version, argpp, bp, max, nextp)
285 u_int8_t *bp;
304 memcpy(&argp->pgsize, bp, sizeof(u_int32_t));
305 bp += sizeof(u_int32_t);
307 DB_NTOHL_COPYIN(env, argp->pgsize, bp);
309 memcpy(&argp->pgno, bp, sizeof(u_int32_t));
310 bp += sizeof(u_int32_t);
312 DB_NTOHL_COPYIN(env, argp->pgno, bp);
314 memcpy(&argp->max_pgno, bp, sizeof(u_int32_t));
315 bp += sizeof(u_int32_t);
317 DB_NTOHL_COPYIN(env, argp->max_pgno, bp);
319 memcpy(&argp->filenum, bp, sizeof(u_int32_t));
320 bp += sizeof(u_int32_t);
322 DB_NTOHL_COPYIN(env, argp->filenum, bp);
324 memcpy(&argp->finfo_flags, bp, sizeof(u_int32_t));
325 bp += sizeof(u_int32_t);
327 DB_NTOHL_COPYIN(env, argp->finfo_flags, bp);
329 memcpy(&argp->type, bp, sizeof(u_int32_t));
330 bp += sizeof(u_int32_t);
332 DB_NTOHL_COPYIN(env, argp->type, bp);
334 memcpy(&argp->db_flags, bp, sizeof(u_int32_t));
335 bp += sizeof(u_int32_t);
337 DB_NTOHL_COPYIN(env, argp->db_flags, bp);
339 memcpy(&argp->uid.size, bp, sizeof(u_int32_t));
340 bp += sizeof(u_int32_t);
342 DB_NTOHL_COPYIN(env, argp->uid.size, bp);
343 argp->uid.data = bp;
347 bp += argp->uid.size;
349 memcpy(&argp->info.size, bp, sizeof(u_int32_t));
350 bp += sizeof(u_int32_t);
352 DB_NTOHL_COPYIN(env, argp->info.size, bp);
353 argp->info.data = bp;
357 bp += argp->info.size;
360 *nextp = bp;
375 __rep_grant_info_marshal(env, argp, bp, max, lenp)
378 u_int8_t *bp;
385 start = bp;
387 DB_HTONL_COPYOUT(env, bp, argp->msg_sec);
388 DB_HTONL_COPYOUT(env, bp, argp->msg_nsec);
390 *lenp = (size_t)(bp - start);
399 __rep_grant_info_unmarshal(env, argp, bp, max, nextp)
402 u_int8_t *bp;
408 DB_NTOHL_COPYIN(env, argp->msg_sec, bp);
409 DB_NTOHL_COPYIN(env, argp->msg_nsec, bp);
412 *nextp = bp;
426 __rep_logreq_marshal(env, argp, bp, max, lenp)
429 u_int8_t *bp;
436 start = bp;
438 DB_HTONL_COPYOUT(env, bp, argp->endlsn.file);
439 DB_HTONL_COPYOUT(env, bp, argp->endlsn.offset);
441 *lenp = (size_t)(bp - start);
450 __rep_logreq_unmarshal(env, argp, bp, max, nextp)
453 u_int8_t *bp;
459 DB_NTOHL_COPYIN(env, argp->endlsn.file, bp);
460 DB_NTOHL_COPYIN(env, argp->endlsn.offset, bp);
463 *nextp = bp;
477 __rep_newfile_marshal(env, argp, bp, max, lenp)
480 u_int8_t *bp;
487 start = bp;
489 DB_HTONL_COPYOUT(env, bp, argp->version);
491 *lenp = (size_t)(bp - start);
500 __rep_newfile_unmarshal(env, argp, bp, max, nextp)
503 u_int8_t *bp;
509 DB_NTOHL_COPYIN(env, argp->version, bp);
512 *nextp = bp;
526 __rep_update_marshal(env, version, argp, bp, max, lenp)
530 u_int8_t *bp;
538 start = bp;
544 memcpy(bp, &argp->first_lsn.file, sizeof(u_int32_t));
545 bp += sizeof(u_int32_t);
546 memcpy(bp, &argp->first_lsn.offset, sizeof(u_int32_t));
547 bp += sizeof(u_int32_t);
549 DB_HTONL_COPYOUT(env, bp, argp->first_lsn.file);
550 DB_HTONL_COPYOUT(env, bp, argp->first_lsn.offset);
553 memcpy(bp, &argp->first_vers, sizeof(u_int32_t));
554 bp += sizeof(u_int32_t);
556 DB_HTONL_COPYOUT(env, bp, argp->first_vers);
558 memcpy(bp, &argp->num_files, sizeof(u_int32_t));
559 bp += sizeof(u_int32_t);
561 DB_HTONL_COPYOUT(env, bp, argp->num_files);
563 *lenp = (size_t)(bp - start);
572 __rep_update_unmarshal(env, version, argpp, bp, max, nextp)
576 u_int8_t *bp;
593 memcpy(&argp->first_lsn.file, bp, sizeof(u_int32_t));
594 bp += sizeof(u_int32_t);
595 memcpy(&argp->first_lsn.offset, bp, sizeof(u_int32_t));
596 bp += sizeof(u_int32_t);
598 DB_NTOHL_COPYIN(env, argp->first_lsn.file, bp);
599 DB_NTOHL_COPYIN(env, argp->first_lsn.offset, bp);
602 memcpy(&argp->first_vers, bp, sizeof(u_int32_t));
603 bp += sizeof(u_int32_t);
605 DB_NTOHL_COPYIN(env, argp->first_vers, bp);
607 memcpy(&argp->num_files, bp, sizeof(u_int32_t));
608 bp += sizeof(u_int32_t);
610 DB_NTOHL_COPYIN(env, argp->num_files, bp);
613 *nextp = bp;
628 __rep_vote_info_marshal(env, argp, bp, max, lenp)
631 u_int8_t *bp;
638 start = bp;
640 DB_HTONL_COPYOUT(env, bp, argp->egen);
641 DB_HTONL_COPYOUT(env, bp, argp->nsites);
642 DB_HTONL_COPYOUT(env, bp, argp->nvotes);
643 DB_HTONL_COPYOUT(env, bp, argp->priority);
644 DB_HTONL_COPYOUT(env, bp, argp->tiebreaker);
646 *lenp = (size_t)(bp - start);
655 __rep_vote_info_unmarshal(env, argp, bp, max, nextp)
658 u_int8_t *bp;
664 DB_NTOHL_COPYIN(env, argp->egen, bp);
665 DB_NTOHL_COPYIN(env, argp->nsites, bp);
666 DB_NTOHL_COPYIN(env, argp->nvotes, bp);
667 DB_NTOHL_COPYIN(env, argp->priority, bp);
668 DB_NTOHL_COPYIN(env, argp->tiebreaker, bp);
671 *nextp = bp;