/dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/ |
H A D | client.go | 114 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 D | clnt.c | 208 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 D | clnt.c | 208 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 D | clnt.c | 208 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 D | client_linux.go | 49 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 D | client_solaris.go | 41 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 D | client.go | 18 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 D | dc_server.c | 133 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 D | ria-server.c | 83 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 D | ria.c | 38 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 D | client.c | 903 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 D | client.c | 903 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 D | client.c | 903 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 D | client_rpc.c | 18 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 D | client_rpc.c | 18 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 D | nlm_prot_clnt.c | 25 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 D | test_client_put_stop.c | 622 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 D | nfs_prot_clnt.c | 13 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 D | client.c | 27 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 D | client.c | 27 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 D | vxi_clnt.c | 19 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 D | TransporterFacade.cpp | 243 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 D | TransporterFacade.cpp | 243 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 D | TransporterFacade.cpp | 243 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 D | TransporterFacade.cpp | 243 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 …]
|