Home
last modified time | relevance | path

Searched refs:rpc (Results 1 – 25 of 6152) sorted by relevance

12345678910>>...247

/dports/net/libnfs/libnfs-libnfs-4.0.0/lib/
H A Dsocket.c329 memcpy(rpc->inbuf, &rpc->rm_buf, 4); in rpc_read_from_socket()
334 count = recv(rpc->fd, buf + rpc->inpos, pdu_size - rpc->inpos, in rpc_read_from_socket()
369 } while (rpc->is_nonblocking && rpc->waitpdu_len > 0); in rpc_read_from_socket()
384 tmp_cb(rpc, status, rpc->error_string, rpc->connect_data); in maybe_call_connect_cb()
564 if (set_bind_device(rpc->fd, rpc->ifname) != 0) { in rpc_connect_sockaddr_async()
578 if (set_bind_device(rpc->fd, rpc->ifname) != 0) { in rpc_connect_sockaddr_async()
601 if (dup2(rpc->fd, rpc->old_fd) == -1) { in rpc_connect_sockaddr_async()
605 rpc->fd = rpc->old_fd; in rpc_connect_sockaddr_async()
687 rpc->is_nonblocking = !set_nonblocking(rpc->fd); in rpc_connect_sockaddr_async()
836 rpc->num_retries = rpc->auto_reconnect; in rpc_reconnect_requeue()
[all …]
H A Dinit.c81 free(rpc); in rpc_init_context()
105 return rpc; in rpc_init_context()
121 rpc->fd = s; in rpc_init_server_context()
123 rpc->is_udp = rpc_is_udp_socket(rpc); in rpc_init_server_context()
126 return rpc; in rpc_init_server_context()
209 return rpc; in rpc_init_udp_context()
223 if (uid != rpc->uid || gid != rpc->gid) { in rpc_set_uid_gid()
234 rpc_set_uid_gid(rpc, uid, rpc->gid); in rpc_set_uid()
238 rpc_set_uid_gid(rpc, rpc->uid, gid); in rpc_set_gid()
253 RPC_LOG(rpc, 1, "error: %s", rpc->error_string); in rpc_set_error()
[all …]
/dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/tests/
H A Dtest-mongoc-rpc.c108 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_delete_gather()
134 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_delete_scatter()
162 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_get_more_gather()
185 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_get_more_scatter()
214 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_insert_gather()
250 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_insert_scatter()
289 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_kill_cursors_gather()
312 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_kill_cursors_scatter()
337 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_msg_gather()
357 memset (&rpc, 0xFFFFFFFF, sizeof rpc); in test_mongoc_rpc_msg_scatter()
[all …]
/dports/sysutils/istio/istio-1.6.7/mixer/pkg/status/
H A Dstatus.go30 var OK = rpc.Status{Code: int32(rpc.OK)}
33 func New(c rpc.Code) rpc.Status {
38 func WithMessage(c rpc.Code, message string) rpc.Status {
44 return rpc.Status{Code: int32(rpc.INTERNAL), Message: err.Error()}
49 return rpc.Status{Code: int32(rpc.INTERNAL), Message: message}
54 return rpc.Status{Code: int32(rpc.CANCELLED), Message: message}
79 return rpc.Status{Code: int32(rpc.UNKNOWN), Message: message}
84 return rpc.Status{Code: int32(rpc.NOT_FOUND), Message: message}
99 return rpc.Status{Code: int32(rpc.ABORTED), Message: message}
119 return rpc.Status{Code: int32(rpc.DATA_LOSS), Message: message}
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Dispatcher/
H A DImmutableDispatchRuntime.cs443 rpc.RequestContext.Reply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime()); in Reply()
490 … rpc.AsyncResult = rpc.RequestContext.BeginReply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime(), in BeginReply()
548 rpc.Reply = rpc.CorrelationCallback.EndFinalizeCorrelation(rpc.AsyncResult); in EndFinalizeCorrelation()
570 rpc.RequestContext.EndReply(rpc.AsyncResult); in EndReply()
833 AddMessageProperties(rpc.Reply, rpc.OperationContext, rpc.Channel); in PrepareAndAddressReply()
1158 rpc.Operation.InvokeBegin(ref rpc); in ProcessMessage5()
1216 rpc.NextProcessor = (rpc.Operation.IsSynchronous) ? in ProcessMessage6()
1259 rpc.Operation.InvokeEnd(ref rpc); in ProcessMessage7()
1496 if ((rpc.Reply != null) && (rpc.Reply != rpc.ReturnParameter)) in ProcessMessageCleanup()
1791 this.rpc = rpc; in RpcCorrelationCallbackMessageProperty()
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/modules/secfilter/
H A Dsecfilter_rpc.c66 rpc->fault(ctx, 0, in secf_rpc_add_dst()
82 rpc->rpl_printf(ctx, in secf_rpc_add_dst()
100 rpc->fault(ctx, 0, in secf_rpc_add_bl()
129 rpc->fault(ctx, 0, in secf_rpc_add_wl()
189 rpc->rpl_printf(ctx, ""); in secf_rpc_print()
198 rpc->rpl_printf(ctx, ""); in secf_rpc_print()
204 rpc->rpl_printf(ctx, ""); in secf_rpc_print()
262 rpc->rpl_printf(ctx, ""); in secf_rpc_print()
268 rpc->rpl_printf(ctx, ""); in secf_rpc_stats()
284 rpc->rpl_printf(ctx, ""); in secf_rpc_stats()
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/gitaly/v14/ruby/proto/gitaly/
H A Drepository-service_services_pb.rb19 rpc :RepackFull, Gitaly::RepackFullRequest, Gitaly::RepackFullResponse
20 rpc :MidxRepack, Gitaly::MidxRepackRequest, Gitaly::MidxRepackResponse
27 rpc :FetchRemote, Gitaly::FetchRemoteRequest, Gitaly::FetchRemoteResponse
29 rpc :GetArchive, Gitaly::GetArchiveRequest, stream(Gitaly::GetArchiveResponse)
34 rpc :Fsck, Gitaly::FsckRequest, Gitaly::FsckResponse
35 rpc :WriteRef, Gitaly::WriteRefRequest, Gitaly::WriteRefResponse
37 rpc :CreateFork, Gitaly::CreateForkRequest, Gitaly::CreateForkResponse
45 rpc :GetConfig, Gitaly::GetConfigRequest, stream(Gitaly::GetConfigResponse)
46 rpc :SetConfig, Gitaly::SetConfigRequest, Gitaly::SetConfigResponse
48 rpc :FindLicense, Gitaly::FindLicenseRequest, Gitaly::FindLicenseResponse
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/gitaly/v14/ruby/proto/gitaly/
H A Drepository-service_services_pb.rb19 rpc :RepackFull, Gitaly::RepackFullRequest, Gitaly::RepackFullResponse
20 rpc :MidxRepack, Gitaly::MidxRepackRequest, Gitaly::MidxRepackResponse
27 rpc :FetchRemote, Gitaly::FetchRemoteRequest, Gitaly::FetchRemoteResponse
29 rpc :GetArchive, Gitaly::GetArchiveRequest, stream(Gitaly::GetArchiveResponse)
34 rpc :Fsck, Gitaly::FsckRequest, Gitaly::FsckResponse
35 rpc :WriteRef, Gitaly::WriteRefRequest, Gitaly::WriteRefResponse
37 rpc :CreateFork, Gitaly::CreateForkRequest, Gitaly::CreateForkResponse
51 rpc :GetConfig, Gitaly::GetConfigRequest, stream(Gitaly::GetConfigResponse)
52 rpc :FindLicense, Gitaly::FindLicenseRequest, Gitaly::FindLicenseResponse
55 rpc :Cleanup, Gitaly::CleanupRequest, Gitaly::CleanupResponse
[all …]
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/gitaly/v14/ruby/proto/gitaly/
H A Drepository-service_services_pb.rb19 rpc :RepackFull, Gitaly::RepackFullRequest, Gitaly::RepackFullResponse
20 rpc :MidxRepack, Gitaly::MidxRepackRequest, Gitaly::MidxRepackResponse
27 rpc :FetchRemote, Gitaly::FetchRemoteRequest, Gitaly::FetchRemoteResponse
29 rpc :GetArchive, Gitaly::GetArchiveRequest, stream(Gitaly::GetArchiveResponse)
34 rpc :Fsck, Gitaly::FsckRequest, Gitaly::FsckResponse
35 rpc :WriteRef, Gitaly::WriteRefRequest, Gitaly::WriteRefResponse
37 rpc :CreateFork, Gitaly::CreateForkRequest, Gitaly::CreateForkResponse
51 rpc :GetConfig, Gitaly::GetConfigRequest, stream(Gitaly::GetConfigResponse)
52 rpc :FindLicense, Gitaly::FindLicenseRequest, Gitaly::FindLicenseResponse
55 rpc :Cleanup, Gitaly::CleanupRequest, Gitaly::CleanupResponse
[all …]
/dports/net/libnfs/libnfs-libnfs-4.0.0/nfs/
H A Dnfs.c144 rpc_free_pdu(rpc, pdu); in rpc_nfs3_getattr_async()
179 rpc_free_pdu(rpc, pdu); in rpc_nfs3_pathconf_async()
214 rpc_free_pdu(rpc, pdu); in rpc_nfs3_lookup_async()
250 rpc_free_pdu(rpc, pdu); in rpc_nfs3_access_async()
286 rpc_free_pdu(rpc, pdu); in rpc_nfs3_read_async()
323 rpc_free_pdu(rpc, pdu); in rpc_nfs3_write_async()
363 rpc_free_pdu(rpc, pdu); in rpc_nfs3_commit_async()
400 rpc_free_pdu(rpc, pdu); in rpc_nfs3_setattr_async()
429 rpc_free_pdu(rpc, pdu); in rpc_nfs3_mkdir_async()
458 rpc_free_pdu(rpc, pdu); in rpc_nfs3_rmdir_async()
[all …]
/dports/net/libnfs/libnfs-libnfs-4.0.0/portmap/
H A Dportmap.c66 rpc_free_pdu(rpc, pdu); in rpc_pmap2_getport_async()
95 rpc_free_pdu(rpc, pdu); in rpc_pmap2_set_async()
124 rpc_free_pdu(rpc, pdu); in rpc_pmap2_unset_async()
173 rpc_free_pdu(rpc, pdu); in rpc_pmap2_callit_async()
178 rpc_set_error(rpc, "Failed to queue PORTMAP2/CALLIT pdu: %s", rpc_get_error(rpc)); in rpc_pmap2_callit_async()
218 rpc_free_pdu(rpc, pdu); in rpc_pmap3_set_async()
242 rpc_free_pdu(rpc, pdu); in rpc_pmap3_unset_async()
266 rpc_free_pdu(rpc, pdu); in rpc_pmap3_getaddr_async()
333 rpc_free_pdu(rpc, pdu); in rpc_pmap3_callit_async()
357 rpc_free_pdu(rpc, pdu); in rpc_pmap3_uaddr2taddr_async()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/memory/
H A Drenesas-rpc-if.c377 regmap_write(rpc->regmap, RPCIF_SMCMR, rpc->command); in rpcif_manual_xfer()
378 regmap_write(rpc->regmap, RPCIF_SMOPR, rpc->option); in rpcif_manual_xfer()
379 regmap_write(rpc->regmap, RPCIF_SMDMCR, rpc->dummy); in rpcif_manual_xfer()
380 regmap_write(rpc->regmap, RPCIF_SMDRENR, rpc->ddr); in rpcif_manual_xfer()
443 regmap_write(rpc->regmap, RPCIF_DRDRENR, rpc->ddr); in rpcif_manual_xfer()
444 memcpy_fromio(rpc->buffer, rpc->dirmap, rpc->xferlen); in rpcif_manual_xfer()
485 regmap_write(rpc->regmap, RPCIF_SMENR, rpc->enable); in rpcif_manual_xfer()
500 rpcif_hw_init(rpc, rpc->bus_size == 2); in rpcif_manual_xfer()
520 regmap_write(rpc->regmap, RPCIF_DROPR, rpc->option); in rpcif_dirmap_read()
523 regmap_write(rpc->regmap, RPCIF_DRDMCR, rpc->dummy); in rpcif_dirmap_read()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/memory/
H A Drenesas-rpc-if.c377 regmap_write(rpc->regmap, RPCIF_SMCMR, rpc->command); in rpcif_manual_xfer()
378 regmap_write(rpc->regmap, RPCIF_SMOPR, rpc->option); in rpcif_manual_xfer()
379 regmap_write(rpc->regmap, RPCIF_SMDMCR, rpc->dummy); in rpcif_manual_xfer()
380 regmap_write(rpc->regmap, RPCIF_SMDRENR, rpc->ddr); in rpcif_manual_xfer()
443 regmap_write(rpc->regmap, RPCIF_DRDRENR, rpc->ddr); in rpcif_manual_xfer()
444 memcpy_fromio(rpc->buffer, rpc->dirmap, rpc->xferlen); in rpcif_manual_xfer()
485 regmap_write(rpc->regmap, RPCIF_SMENR, rpc->enable); in rpcif_manual_xfer()
500 rpcif_hw_init(rpc, rpc->bus_size == 2); in rpcif_manual_xfer()
520 regmap_write(rpc->regmap, RPCIF_DROPR, rpc->option); in rpcif_dirmap_read()
523 regmap_write(rpc->regmap, RPCIF_DRDMCR, rpc->dummy); in rpcif_dirmap_read()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/memory/
H A Drenesas-rpc-if.c377 regmap_write(rpc->regmap, RPCIF_SMCMR, rpc->command); in rpcif_manual_xfer()
378 regmap_write(rpc->regmap, RPCIF_SMOPR, rpc->option); in rpcif_manual_xfer()
379 regmap_write(rpc->regmap, RPCIF_SMDMCR, rpc->dummy); in rpcif_manual_xfer()
380 regmap_write(rpc->regmap, RPCIF_SMDRENR, rpc->ddr); in rpcif_manual_xfer()
443 regmap_write(rpc->regmap, RPCIF_DRDRENR, rpc->ddr); in rpcif_manual_xfer()
444 memcpy_fromio(rpc->buffer, rpc->dirmap, rpc->xferlen); in rpcif_manual_xfer()
485 regmap_write(rpc->regmap, RPCIF_SMENR, rpc->enable); in rpcif_manual_xfer()
500 rpcif_hw_init(rpc, rpc->bus_size == 2); in rpcif_manual_xfer()
520 regmap_write(rpc->regmap, RPCIF_DROPR, rpc->option); in rpcif_dirmap_read()
523 regmap_write(rpc->regmap, RPCIF_DRDMCR, rpc->dummy); in rpcif_dirmap_read()
[all …]
/dports/net/libnfs/libnfs-libnfs-4.0.0/mount/
H A Dmount.c40 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_null_async()
65 rpc_free_pdu(rpc, pdu); in rpc_mount3_mnt_async()
69 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_mnt_async()
92 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_dump_async()
117 rpc_free_pdu(rpc, pdu); in rpc_mount3_umnt_async()
121 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_umnt_async()
144 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_umntall_async()
167 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount3_export_async()
230 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_mount1_null_async()
250 rpc_free_pdu(rpc, pdu); in rpc_mount1_mnt_async()
[all …]
/dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/src/mongoc/
H A Dmongoc-rpc.c160 rpc->_name[i] = BSON_UINT64_FROM_LE (rpc->_name[i]); \
162 rpc->_len = BSON_UINT32_FROM_LE (rpc->_len); \
188 rpc->_len = BSON_UINT32_FROM_LE (rpc->_len); \
190 rpc->_name[i] = BSON_UINT64_FROM_LE (rpc->_name[i]); \
415 rpc->_name = &rpc->_name##_recv; \
472 _mongoc_rpc_gather_reply (&rpc->reply, &rpc->header, array); in _mongoc_rpc_gather()
475 _mongoc_rpc_gather_msg (&rpc->msg, &rpc->header, array); in _mongoc_rpc_gather()
478 _mongoc_rpc_gather_update (&rpc->update, &rpc->header, array); in _mongoc_rpc_gather()
481 _mongoc_rpc_gather_insert (&rpc->insert, &rpc->header, array); in _mongoc_rpc_gather()
484 _mongoc_rpc_gather_query (&rpc->query, &rpc->header, array); in _mongoc_rpc_gather()
[all …]
/dports/devel/plan9port/plan9port-1f098efb7370a0b28306d10681e21883fb1c1507/src/libauth/
H A Dauth_rpc.c24 if (rpc->afd >= 0) in rpcread()
64 AuthRpc *rpc; in auth_allocrpc() local
66 rpc = mallocz(sizeof(*rpc), 1); in auth_allocrpc()
67 if(rpc == nil) in auth_allocrpc()
73 free(rpc); in auth_allocrpc()
77 return rpc; in auth_allocrpc()
83 if(rpc == nil) in auth_freerpc()
89 free(rpc); in auth_freerpc()
107 if((n=rpcwrite(rpc, rpc->obuf, l+1+na)) != l+1+na){ in auth_rpc()
113 if((n=rpcread(rpc, rpc->ibuf, AuthRpcMax)) < 0) in auth_rpc()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/arch/mips/pci/
H A Dpci-rt3883.c212 rpc->irq_domain = in rt3883_pci_irq_init()
215 rpc); in rt3883_pci_irq_init()
216 if (!rpc->irq_domain) { in rt3883_pci_irq_init()
381 if (!rpc->pcie_ready) { in rt3883_pci_preinit()
415 rpc = devm_kzalloc(dev, sizeof(*rpc), GFP_KERNEL); in rt3883_pci_probe()
416 if (!rpc) in rt3883_pci_probe()
421 if (IS_ERR(rpc->base)) in rt3883_pci_probe()
489 rpc->pci_controller.io_resource = &rpc->io_res; in rt3883_pci_probe()
490 rpc->pci_controller.mem_resource = &rpc->mem_res; in rt3883_pci_probe()
496 rt3883_pci_w32(rpc, rpc->mem_res.start, RT3883_PCI_REG_MEMBASE); in rt3883_pci_probe()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/arch/mips/pci/
H A Dpci-rt3883.c212 rpc->irq_domain = in rt3883_pci_irq_init()
215 rpc); in rt3883_pci_irq_init()
216 if (!rpc->irq_domain) { in rt3883_pci_irq_init()
381 if (!rpc->pcie_ready) { in rt3883_pci_preinit()
415 rpc = devm_kzalloc(dev, sizeof(*rpc), GFP_KERNEL); in rt3883_pci_probe()
416 if (!rpc) in rt3883_pci_probe()
421 if (IS_ERR(rpc->base)) in rt3883_pci_probe()
489 rpc->pci_controller.io_resource = &rpc->io_res; in rt3883_pci_probe()
490 rpc->pci_controller.mem_resource = &rpc->mem_res; in rt3883_pci_probe()
496 rt3883_pci_w32(rpc, rpc->mem_res.start, RT3883_PCI_REG_MEMBASE); in rt3883_pci_probe()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/arch/mips/pci/
H A Dpci-rt3883.c212 rpc->irq_domain = in rt3883_pci_irq_init()
215 rpc); in rt3883_pci_irq_init()
216 if (!rpc->irq_domain) { in rt3883_pci_irq_init()
381 if (!rpc->pcie_ready) { in rt3883_pci_preinit()
415 rpc = devm_kzalloc(dev, sizeof(*rpc), GFP_KERNEL); in rt3883_pci_probe()
416 if (!rpc) in rt3883_pci_probe()
421 if (IS_ERR(rpc->base)) in rt3883_pci_probe()
489 rpc->pci_controller.io_resource = &rpc->io_res; in rt3883_pci_probe()
490 rpc->pci_controller.mem_resource = &rpc->mem_res; in rt3883_pci_probe()
496 rt3883_pci_w32(rpc, rpc->mem_res.start, RT3883_PCI_REG_MEMBASE); in rt3883_pci_probe()
[all …]
/dports/databases/pecl-mongodb/mongodb-1.9.1/src/libmongoc/src/libmongoc/src/mongoc/
H A Dmongoc-rpc.c207 rpc->_name[i] = BSON_UINT64_FROM_LE (rpc->_name[i]); \
209 rpc->_len = BSON_UINT32_FROM_LE (rpc->_len); \
235 rpc->_len = BSON_UINT32_FROM_LE (rpc->_len); \
237 rpc->_name[i] = BSON_UINT64_FROM_LE (rpc->_name[i]); \
503 rpc->_name = &rpc->_name##_recv; \
584 _mongoc_rpc_gather_reply (&rpc->reply, &rpc->header, array); in _mongoc_rpc_gather()
588 _mongoc_rpc_gather_msg (&rpc->msg, &rpc->header, array); in _mongoc_rpc_gather()
593 _mongoc_rpc_gather_update (&rpc->update, &rpc->header, array); in _mongoc_rpc_gather()
598 _mongoc_rpc_gather_insert (&rpc->insert, &rpc->header, array); in _mongoc_rpc_gather()
603 _mongoc_rpc_gather_query (&rpc->query, &rpc->header, array); in _mongoc_rpc_gather()
[all …]
/dports/net/libnfs/libnfs-libnfs-4.0.0/include/nfsc/
H A Dlibnfs-raw.h40 EXTERN void rpc_destroy_context(struct rpc_context *rpc);
70 EXTERN int rpc_get_fd(struct rpc_context *rpc);
71 EXTERN int rpc_which_events(struct rpc_context *rpc);
79 EXTERN int rpc_queue_length(struct rpc_context *rpc);
86 EXTERN void rpc_set_uid(struct rpc_context *rpc, int uid);
87 EXTERN void rpc_set_gid(struct rpc_context *rpc, int gid);
141 EXTERN char *rpc_get_error(struct rpc_context *rpc);
172 EXTERN void rpc_set_fd(struct rpc_context *rpc, int fd);
274 EXTERN int rpc_pmap2_null_async(struct rpc_context *rpc,
425 EXTERN int rpc_pmap3_set_async(struct rpc_context *rpc,
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/modules/usrloc/
H A Dul_rpc.c233 rpc->scan(ctx, "*S", &brief); in ul_rpc_dump()
238 if (rpc->add(ctx, "{", &th) < 0) in ul_rpc_dump()
258 if(rpc->struct_add(dh, "Sd[", in ul_rpc_dump()
274 if(rpc->struct_add(ah, "S", in ul_rpc_dump()
282 if(rpc->struct_add(ah, "{", in ul_rpc_dump()
317 if(rpc->struct_add(sh, "dd", in ul_rpc_dump()
427 if (rpc->add(ctx, "{", &th) < 0) in ul_rpc_lookup()
434 if(rpc->struct_add(th, "S[", in ul_rpc_lookup()
790 rpc->add(ctx, "d", count); in ul_rpc_db_users()
844 rpc->add(ctx, "d", count); in ul_rpc_db_contacts()
[all …]
/dports/net/libnfs/libnfs-libnfs-4.0.0/nsm/
H A Dnsm.c40 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_null_async()
60 rpc_free_pdu(rpc, pdu); in rpc_nsm1_stat_async()
64 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_stat_async()
84 rpc_free_pdu(rpc, pdu); in rpc_nsm1_mon_async()
88 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_mon_async()
108 rpc_free_pdu(rpc, pdu); in rpc_nsm1_unmon_async()
112 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_unmon_async()
132 rpc_free_pdu(rpc, pdu); in rpc_nsm1_unmonall_async()
136 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_unmonall_async()
154 if (rpc_queue_pdu(rpc, pdu) != 0) { in rpc_nsm1_simucrash_async()
[all …]
/dports/net-p2p/c-lightning/lightning-0.10.2/tests/
H A Dtest_invoices.py172 l1.rpc.pay(inv['bolt11'])
196 l0.rpc.close(l1.info['id'])
381 l1.rpc.pay(inv)
436 l2.rpc.delexpiredinvoice()
491 l1.rpc.pay(inv2['bolt11'])
499 l1.rpc.pay(inv1['bolt11'])
526 l1.rpc.pay(inv1['bolt11'])
527 l1.rpc.pay(inv2['bolt11'])
541 l1.rpc.pay(inv3['bolt11'])
553 l1.rpc.pay(inv4['bolt11'])
[all …]

12345678910>>...247