Lines Matching defs:rqst
266 static int send_packet(CNID_private *db, struct cnid_dbd_rqst *rqst)
272 iov[0].iov_base = rqst;
277 if (rqst->namelen) {
278 iov[1].iov_base = rqst->name;
279 iov[1].iov_len = rqst->namelen;
280 towrite += rqst->namelen;
285 LOG(log_warning, logtype_cnid, "send_packet: Error writev rqst (db_dir %s): %s",
295 static void dbd_initstamp(struct cnid_dbd_rqst *rqst)
297 RQST_RESET(rqst);
298 rqst->op = CNID_DBD_OP_GETSTAMP;
322 static int dbd_rpc(CNID_private *db, struct cnid_dbd_rqst *rqst, struct cnid_dbd_rply *rply)
328 if (send_packet(db, rqst) < 0) {
361 static int transmit(CNID_private *db, struct cnid_dbd_rqst *rqst, struct cnid_dbd_rply *rply)
408 if (!dbd_rpc(db, rqst, rply)) {
547 struct cnid_dbd_rqst rqst;
563 RQST_RESET(&rqst);
564 rqst.op = CNID_DBD_OP_ADD;
567 rqst.dev = st->st_dev;
570 rqst.ino = st->st_ino;
571 rqst.type = S_ISDIR(st->st_mode)?1:0;
572 rqst.cnid = hint;
573 rqst.did = did;
574 rqst.name = name;
575 rqst.namelen = len;
578 ntohl(did), name, (long long)st->st_ino, rqst.type);
581 if (transmit(db, &rqst, &rply) < 0) {
611 struct cnid_dbd_rqst rqst;
629 RQST_RESET(&rqst);
630 rqst.op = CNID_DBD_OP_GET;
631 rqst.did = did;
632 rqst.name = name;
633 rqst.namelen = len;
636 if (transmit(db, &rqst, &rply) < 0) {
664 struct cnid_dbd_rqst rqst;
681 RQST_RESET(&rqst);
682 rqst.op = CNID_DBD_OP_RESOLVE;
683 rqst.cnid = *id;
689 if (transmit(db, &rqst, &rply) < 0) {
738 struct cnid_dbd_rqst rqst;
754 RQST_RESET(&rqst);
755 rqst.op = CNID_DBD_OP_LOOKUP;
758 rqst.dev = st->st_dev;
761 rqst.ino = st->st_ino;
762 rqst.type = S_ISDIR(st->st_mode)?1:0;
763 rqst.did = did;
764 rqst.name = name;
765 rqst.namelen = len;
768 ntohl(did), name, (long long)st->st_ino, rqst.type);
771 if (transmit(db, &rqst, &rply) < 0) {
799 struct cnid_dbd_rqst rqst;
817 RQST_RESET(&rqst);
818 rqst.op = CNID_DBD_OP_SEARCH;
820 rqst.name = name;
821 rqst.namelen = namelen;
826 if (transmit(db, &rqst, &rply) < 0) {
855 struct cnid_dbd_rqst rqst;
870 RQST_RESET(&rqst);
871 rqst.op = CNID_DBD_OP_UPDATE;
872 rqst.cnid = id;
874 rqst.dev = st->st_dev;
876 rqst.ino = st->st_ino;
877 rqst.type = S_ISDIR(st->st_mode)?1:0;
878 rqst.did = did;
879 rqst.name = name;
880 rqst.namelen = len;
883 ntohl(id), name, (long long)st->st_ino, rqst.type);
886 if (transmit(db, &rqst, &rply) < 0) {
910 struct cnid_dbd_rqst rqst;
926 RQST_RESET(&rqst);
927 rqst.op = CNID_DBD_OP_REBUILD_ADD;
930 rqst.dev = st->st_dev;
933 rqst.ino = st->st_ino;
934 rqst.type = S_ISDIR(st->st_mode)?1:0;
935 rqst.did = did;
936 rqst.name = name;
937 rqst.namelen = len;
938 rqst.cnid = hint;
941 ntohl(did), name, (long long)st->st_ino, rqst.type, hint);
943 if (transmit(db, &rqst, &rply) < 0) {
972 struct cnid_dbd_rqst rqst;
983 RQST_RESET(&rqst);
984 rqst.op = CNID_DBD_OP_DELETE;
985 rqst.cnid = id;
988 if (transmit(db, &rqst, &rply) < 0) {