Home
last modified time | relevance | path

Searched refs:clnt (Results 1 – 25 of 1030) sorted by relevance

12345678910>>...42

/dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/
H A Dclient.go114 func (clnt *Client) Close() {
115 clnt.cluster.Close()
120 return clnt.cluster.IsConnected()
125 return clnt.cluster.GetNodes()
130 nodes := clnt.cluster.GetNodes()
1041 func (clnt *Client) DropIndex(
1171 if clnt.cluster.user == "" {
1288 return clnt.cluster
1293 if clnt.cluster != nil {
1294 return clnt.cluster.String()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/net/sunrpc/
H A Dclnt.c208 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
211 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
285 clnt->cl_nodelen = strlcpy(clnt->cl_nodename, in rpc_clnt_set_nodename()
381 clnt = kzalloc(sizeof(*clnt), GFP_KERNEL); in rpc_new_client()
384 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
396 clnt->cl_metrics = rpc_alloc_iostats(clnt); in rpc_new_client()
416 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
744 clnt->cl_parent = clnt; in rpc_switch_client_transport()
896 if (clnt->cl_parent != clnt) in rpc_free_client()
942 clnt = rpc_free_auth(clnt); in rpc_release_client()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/sunrpc/
H A Dclnt.c208 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
211 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
285 clnt->cl_nodelen = strlcpy(clnt->cl_nodename, in rpc_clnt_set_nodename()
381 clnt = kzalloc(sizeof(*clnt), GFP_KERNEL); in rpc_new_client()
384 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
396 clnt->cl_metrics = rpc_alloc_iostats(clnt); in rpc_new_client()
416 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
744 clnt->cl_parent = clnt; in rpc_switch_client_transport()
896 if (clnt->cl_parent != clnt) in rpc_free_client()
942 clnt = rpc_free_auth(clnt); in rpc_release_client()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/sunrpc/
H A Dclnt.c208 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
211 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
285 clnt->cl_nodelen = strlcpy(clnt->cl_nodename, in rpc_clnt_set_nodename()
381 clnt = kzalloc(sizeof(*clnt), GFP_KERNEL); in rpc_new_client()
384 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
396 clnt->cl_metrics = rpc_alloc_iostats(clnt); in rpc_new_client()
416 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
744 clnt->cl_parent = clnt; in rpc_switch_client_transport()
896 if (clnt->cl_parent != clnt) in rpc_free_client()
942 clnt = rpc_free_auth(clnt); in rpc_release_client()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/docker/libcontainerd/
H A Dclient_linux.go49 clnt.lock(containerID)
139 clnt.lock(containerID)
150 clnt.lock(containerID)
301 clnt.mapMutex.Lock()
312 clnt.lock(cont.Id)
441 clnt.remote.Lock()
501 clnt.lock(cont.Id)
505 clnt.unlock(cont.Id)
513 clnt.remote.Unlock()
528 clnt.remote.Lock()
[all …]
H A Dclient_solaris.go41 func (clnt *client) Pause(containerID string) error {
45 func (clnt *client) Resume(containerID string) error {
49 func (clnt *client) Stats(containerID string) (*Stats, error) {
54 clnt.mapMutex.RLock()
55 defer clnt.mapMutex.RUnlock()
56 return clnt.exitNotifiers[containerID]
60 clnt.mapMutex.Lock()
61 defer clnt.mapMutex.Unlock()
62 w, ok := clnt.exitNotifiers[containerID]
64 w = &exitNotifier{c: make(chan struct{}), client: clnt}
[all …]
H A Dclient.go18 func (clnt *client) lock(containerID string) {
19 clnt.locker.Lock(containerID)
23 clnt.locker.Unlock(containerID)
28 clnt.mapMutex.Lock()
29 clnt.containers[cont.containerID] = cont
30 clnt.mapMutex.Unlock()
33 clnt.mapMutex.Lock()
34 delete(clnt.containers, containerID)
35 clnt.mapMutex.Unlock()
39 clnt.mapMutex.RLock()
[all …]
/dports/security/distcache/distcache-1.5.1/libdistcacheserver/
H A Ddc_server.c133 res = clnt->server->vt->cache_add(clnt->server->cache, now, msecs, in int_do_op_add()
145 len = clnt->server->vt->cache_get(clnt->server->cache, now, in int_do_op_get()
146 clnt->read_data, clnt->read_data_len, NULL, 0); in int_do_op_get()
157 len = clnt->server->vt->cache_get(clnt->server->cache, now, in int_do_op_get()
158 clnt->read_data, clnt->read_data_len, in int_do_op_get()
170 if(clnt->server->vt->cache_remove(clnt->server->cache, now, in int_do_op_remove()
171 clnt->read_data, clnt->read_data_len)) in int_do_op_remove()
181 if(clnt->server->vt->cache_have(clnt->server->cache, now, in int_do_op_have()
182 clnt->read_data, clnt->read_data_len)) in int_do_op_have()
235 if(!DC_PLUG_write_more(clnt->plug, clnt->send_data, in int_do_operation()
[all …]
/dports/security/openct/openct-0.6.20/src/ifd/
H A Dria-server.c83 ria_peer_t *clnt; in ria_svc_accept() local
235 clnt->device.address, clnt->device.type, in ria_svc_dev_handler()
236 clnt->device.handle, clnt->device.name); in ria_svc_dev_handler()
259 ria_peer_t *clnt; in ria_peer_new() local
262 if (!clnt) { in ria_peer_new()
266 clnt->sock = sock; in ria_peer_new()
269 return clnt; in ria_peer_new()
283 clnt->device.name, clnt->device.address); in ria_peer_free()
285 memset(clnt, 0, sizeof(*clnt)); in ria_peer_free()
286 free(clnt); in ria_peer_free()
[all …]
H A Dria.c38 ria_client_t *clnt; in ria_connect() local
50 clnt = (ria_client_t *) calloc(1, sizeof(*clnt) + RIA_QUEUE_LEN); in ria_connect()
51 if (!clnt) { in ria_connect()
55 ct_buf_init(&clnt->data, (clnt + 1), RIA_QUEUE_LEN); in ria_connect()
61 ria_free(clnt); in ria_connect()
65 return clnt; in ria_connect()
70 if (clnt->sock) in ria_free()
72 free(clnt); in ria_free()
87 clnt->xid++; in ria_send()
89 clnt->xid++; in ria_send()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/9p/
H A Dclient.c903 fid->clnt = clnt; in p9_fid_create()
927 clnt = fid->clnt; in p9_fid_destroy()
1039 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create()
1249 clnt = fid->clnt; in p9_client_open()
1345 clnt = fid->clnt; in p9_client_fcreate()
1441 clnt = fid->clnt; in p9_client_fsync()
1478 clnt = fid->clnt; in p9_client_clunk()
1512 clnt = fid->clnt; in p9_client_remove()
1714 clnt = fid->clnt; in p9_client_stat()
1767 clnt = fid->clnt; in p9_client_getattr_dotl()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/net/9p/
H A Dclient.c903 fid->clnt = clnt; in p9_fid_create()
927 clnt = fid->clnt; in p9_fid_destroy()
1039 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create()
1249 clnt = fid->clnt; in p9_client_open()
1345 clnt = fid->clnt; in p9_client_fcreate()
1441 clnt = fid->clnt; in p9_client_fsync()
1478 clnt = fid->clnt; in p9_client_clunk()
1512 clnt = fid->clnt; in p9_client_remove()
1714 clnt = fid->clnt; in p9_client_stat()
1767 clnt = fid->clnt; in p9_client_getattr_dotl()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/9p/
H A Dclient.c903 fid->clnt = clnt; in p9_fid_create()
927 clnt = fid->clnt; in p9_fid_destroy()
1039 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create()
1249 clnt = fid->clnt; in p9_client_open()
1345 clnt = fid->clnt; in p9_client_fcreate()
1441 clnt = fid->clnt; in p9_client_fsync()
1478 clnt = fid->clnt; in p9_client_clunk()
1512 clnt = fid->clnt; in p9_client_remove()
1714 clnt = fid->clnt; in p9_client_stat()
1767 clnt = fid->clnt; in p9_client_getattr_dotl()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/krb5-src-0.2.4+1.18.2/krb5/src/lib/kadm5/clnt/
H A Dclient_rpc.c18 return clnt_call(clnt, CREATE_PRINCIPAL, in create_principal_2()
34 return clnt_call(clnt, DELETE_PRINCIPAL, in delete_principal_2()
58 return clnt_call(clnt, GET_PRINCIPAL, in get_principal_2()
66 return clnt_call(clnt, GET_PRINCS, in get_princs_2()
154 return clnt_call(clnt, GET_POLICY, in get_policy_2()
162 return clnt_call(clnt, GET_POLS, in get_pols_2()
170 return clnt_call(clnt, GET_PRIVS, in get_privs_2()
178 return clnt_call(clnt, INIT, in init_2()
186 return clnt_call(clnt, PURGEKEYS, in purgekeys_2()
194 return clnt_call(clnt, GET_STRINGS, in get_strings_2()
[all …]
/dports/security/krb5/krb5-1.19.2/src/lib/kadm5/clnt/
H A Dclient_rpc.c18 return clnt_call(clnt, CREATE_PRINCIPAL, in create_principal_2()
34 return clnt_call(clnt, DELETE_PRINCIPAL, in delete_principal_2()
58 return clnt_call(clnt, GET_PRINCIPAL, in get_principal_2()
66 return clnt_call(clnt, GET_PRINCS, in get_princs_2()
154 return clnt_call(clnt, GET_POLICY, in get_policy_2()
162 return clnt_call(clnt, GET_POLS, in get_pols_2()
170 return clnt_call(clnt, GET_PRIVS, in get_privs_2()
178 return clnt_call(clnt, INIT, in init_2()
186 return clnt_call(clnt, PURGEKEYS, in purgekeys_2()
194 return clnt_call(clnt, GET_STRINGS, in get_strings_2()
[all …]
/dports/misc/rump/buildrump.sh-b914579/src/sys/fs/nfs/nlm/
H A Dnlm_prot_clnt.c25 return (CLNT_CALL_EXT(clnt, ext, NLM_SM_NOTIFY, in nlm_sm_notify_0()
34 return (CLNT_CALL_EXT(clnt, ext, NLM_TEST, in nlm_test_1()
43 return (CLNT_CALL_EXT(clnt, ext, NLM_LOCK, in nlm_lock_1()
52 return (CLNT_CALL_EXT(clnt, ext, NLM_CANCEL, in nlm_cancel_1()
61 return (CLNT_CALL_EXT(clnt, ext, NLM_UNLOCK, in nlm_unlock_1()
70 return (CLNT_CALL_EXT(clnt, ext, NLM_GRANTED, in nlm_granted_1()
79 return (CLNT_CALL_EXT(clnt, ext, NLM_TEST_MSG, in nlm_test_msg_1()
88 return (CLNT_CALL_EXT(clnt, ext, NLM_LOCK_MSG, in nlm_lock_msg_1()
169 return (CLNT_CALL_EXT(clnt, ext, NLM_SHARE, in nlm_share_3()
205 return (CLNT_CALL_EXT(clnt, ext, NLM4_TEST, in nlm4_test_4()
[all …]
/dports/www/libmicrohttpd/libmicrohttpd-0.9.74/src/microhttpd/
H A Dtest_client_put_stop.c622 return clnt; in _MHD_dumbClient_create()
692 mhd_assert (clnt->req_size > clnt->send_off); in _MHD_dumbClient_send_req()
695 (clnt->req_size > clnt->send_size_limit)) ? in _MHD_dumbClient_send_req()
696 clnt->send_size_limit : clnt->req_size) - clnt->send_off; in _MHD_dumbClient_send_req()
702 res = MHD_send_ (clnt->sckt, clnt->send_buf + clnt->send_off, send_size); in _MHD_dumbClient_send_req()
716 mhd_assert (clnt->send_off <= clnt->req_size); in _MHD_dumbClient_send_req()
717 mhd_assert (clnt->send_off <= clnt->send_size_limit || \ in _MHD_dumbClient_send_req()
719 if (clnt->req_size == clnt->send_off) in _MHD_dumbClient_send_req()
722 (clnt->send_size_limit == clnt->send_off)) in _MHD_dumbClient_send_req()
731 (void) clnt; in _MHD_dumbClient_recv_reply()
[all …]
/dports/net/nfsshell/nfsshell-09cdd52/
H A Dnfs_prot_clnt.c13 nfs3_null_3(void *argp, CLIENT *clnt) in nfs3_null_3() argument
18 if (clnt_call (clnt, NFS3_NULL, in nfs3_null_3()
33 if (clnt_call (clnt, NFS3_GETATTR, in nfs3_getattr_3()
48 if (clnt_call (clnt, NFS3_SETATTR, in nfs3_setattr_3()
63 if (clnt_call (clnt, NFS3_LOOKUP, in nfs3_lookup_3()
78 if (clnt_call (clnt, NFS3_ACCESS, in nfs3_access_3()
108 if (clnt_call (clnt, NFS3_READ, in nfs3_read_3()
123 if (clnt_call (clnt, NFS3_WRITE, in nfs3_write_3()
153 if (clnt_call (clnt, NFS3_MKDIR, in nfs3_mkdir_3()
183 if (clnt_call (clnt, NFS3_MKNOD, in nfs3_mknod_3()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/krb5-src-0.2.4+1.18.2/krb5/src/lib/rpc/unit-test/
H A Dclient.c27 CLIENT *clnt; member
58 CLIENT *clnt; local
148 if (clnt == NULL) {
153 clnt->cl_auth = auth_gssapi_create_default(clnt, target);
192 CLNT_GETERR(clnt, &e);
261 tmp_auth = clnt->cl_auth;
262 clnt->cl_auth = auth_gssapi_create_default(clnt, target);
263 if (clnt->cl_auth == NULL) {
267 AUTH_DESTROY(clnt->cl_auth);
268 clnt->cl_auth = tmp_auth;
[all …]
/dports/security/krb5/krb5-1.19.2/src/lib/rpc/unit-test/
H A Dclient.c27 CLIENT *clnt; member
58 CLIENT *clnt; local
148 if (clnt == NULL) {
153 clnt->cl_auth = auth_gssapi_create_default(clnt, target);
192 CLNT_GETERR(clnt, &e);
235 tmp_auth = clnt->cl_auth;
236 clnt->cl_auth = auth_gssapi_create_default(clnt, target);
237 if (clnt->cl_auth == NULL) {
241 AUTH_DESTROY(clnt->cl_auth);
242 clnt->cl_auth = tmp_auth;
[all …]
/dports/devel/libsigrok/libsigrok-0.5.2/src/scpi/
H A Dvxi_clnt.c19 if (clnt_call (clnt, device_abort, in device_abort_1()
34 if (clnt_call (clnt, create_link, in create_link_1()
49 if (clnt_call (clnt, device_write, in device_write_1()
64 if (clnt_call (clnt, device_read, in device_read_1()
79 if (clnt_call (clnt, device_readstb, in device_readstb_1()
109 if (clnt_call (clnt, device_clear, in device_clear_1()
124 if (clnt_call (clnt, device_remote, in device_remote_1()
139 if (clnt_call (clnt, device_local, in device_local_1()
154 if (clnt_call (clnt, device_lock, in device_lock_1()
199 if (clnt_call (clnt, device_docmd, in device_docmd_1()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/ndbapi/
H A DTransporterFacade.cpp243 if (clnt != 0) in deliver_signal()
1200 if (clnt != 0 && clnt != sender) in for_each()
1292 if (clnt) in close_clnt()
1298 if (m_threads.get(clnt->m_blockNo) != clnt) in close_clnt()
1336 not_finished = (m_threads.get(clnt->m_blockNo) == clnt); in close_clnt()
1887 (clnt, in sendFragmentedSignal()
1958 (clnt, in sendSignal()
1995 (clnt, in sendSignal()
2308 assert(clnt->m_poll.m_locked_clients[0] == clnt); in finish_poll()
2485 clnt->m_poll.start_poll(clnt); in do_poll()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/ndbapi/
H A DTransporterFacade.cpp243 if (clnt != 0) in deliver_signal()
1200 if (clnt != 0 && clnt != sender) in for_each()
1292 if (clnt) in close_clnt()
1298 if (m_threads.get(clnt->m_blockNo) != clnt) in close_clnt()
1336 not_finished = (m_threads.get(clnt->m_blockNo) == clnt); in close_clnt()
1887 (clnt, in sendFragmentedSignal()
1958 (clnt, in sendSignal()
1995 (clnt, in sendSignal()
2308 assert(clnt->m_poll.m_locked_clients[0] == clnt); in finish_poll()
2485 clnt->m_poll.start_poll(clnt); in do_poll()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/ndbapi/
H A DTransporterFacade.cpp243 if (clnt != 0) in deliver_signal()
1200 if (clnt != 0 && clnt != sender) in for_each()
1292 if (clnt) in close_clnt()
1298 if (m_threads.get(clnt->m_blockNo) != clnt) in close_clnt()
1336 not_finished = (m_threads.get(clnt->m_blockNo) == clnt); in close_clnt()
1887 (clnt, in sendFragmentedSignal()
1958 (clnt, in sendSignal()
1995 (clnt, in sendSignal()
2308 assert(clnt->m_poll.m_locked_clients[0] == clnt); in finish_poll()
2485 clnt->m_poll.start_poll(clnt); in do_poll()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/ndbapi/
H A DTransporterFacade.cpp243 if (clnt != 0) in deliver_signal()
1200 if (clnt != 0 && clnt != sender) in for_each()
1292 if (clnt) in close_clnt()
1298 if (m_threads.get(clnt->m_blockNo) != clnt) in close_clnt()
1336 not_finished = (m_threads.get(clnt->m_blockNo) == clnt); in close_clnt()
1887 (clnt, in sendFragmentedSignal()
1958 (clnt, in sendSignal()
1995 (clnt, in sendSignal()
2308 assert(clnt->m_poll.m_locked_clients[0] == clnt); in finish_poll()
2485 clnt->m_poll.start_poll(clnt); in do_poll()
[all …]

12345678910>>...42