- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 117 for RPC (0.01 sec)
-
src/main/java/jcifs/smb1/smb1/SmbFile.java
getAddress().getHostAddress() + "[\\PIPE\\srvsvc]", auth); try { handle.sendrecv(rpc); if (rpc.retval != 0) throw new SmbException(rpc.retval, true); return rpc.getEntries(); } finally { try { handle.close(); } catch(IOException ioe) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Mon Mar 13 12:00:57 UTC 2023 - 107.9K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "testing" "github.com/minio/minio/internal/dsync" ) // Tests lock rpc client. func TestLockRESTlient(t *testing.T) { // These should not be connectable. endpoint, err := NewEndpoint("http://localhost:9876") if err != nil { t.Fatalf("unexpected error %v", err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/samr.idl
[ uuid(12345778-1234-abcd-ef00-0123456789ac), version(1.0) ] interface samr { import "../rpc.idl"; import "lsarpc.idl"; typedef [v1_enum] enum { ACB_DISABLED = 0x00000001, /* 1 = User account disabled */ ACB_HOMDIRREQ = 0x00000002, /* 1 = Home directory required */ ACB_PWNOTREQ = 0x00000004, /* 1 = User password not required */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/lsarpc.idl
[ uuid(12345778-1234-abcd-ef00-0123456789ab), version(0.0) ] interface lsarpc { import "../rpc.idl"; typedef struct { uint32_t length; uint16_t impersonation_level; uint8_t context_mode; uint8_t effective_only; } LsarQosInfo; typedef struct { uint32_t length; uint8_t *root_directory; unicode_string *object_name; uint32_t attributes; uint32_t security_descriptor;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/lsarpc.idl
[ uuid(12345778-1234-abcd-ef00-0123456789ab), version(0.0) ] interface lsarpc { import "../rpc.idl"; typedef struct { uint32_t length; uint16_t impersonation_level; uint8_t context_mode; uint8_t effective_only; } LsarQosInfo; typedef struct { uint32_t length; uint8_t *root_directory; unicode_string *object_name; uint32_t attributes; uint32_t security_descriptor;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/MsrpcSamrCloseHandle.java
* License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.dcerpc.msrpc; import jcifs.dcerpc.rpc.policy_handle; /** * @author mbechler * */ public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle { /** * @param handle */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.2K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_test_util.h
#ifndef TENSORFLOW_C_EAGER_C_API_REMOTE_TEST_UTIL_H_ #define TENSORFLOW_C_EAGER_C_API_REMOTE_TEST_UTIL_H_ // Run a function containing a MatMul op and check its output. // If heavy_load_on_streaming_rpc is true, send some rpc requests before the one // which creates a remote input, to simulate a scenario that the remote input // is not ready when we start running an op or a function. void TestRemoteExecuteSilentCopies(bool async, bool remote, bool func,
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Fri Dec 11 22:56:03 UTC 2020 - 1.4K bytes - Viewed (0) -
cmd/metacache.go
func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) { // we intentionally operate on a copy of m, so we can update without locks. t := time.NewTicker(metacacheMaxClientWait / 10) defer t.Stop() for { select { case <-ctx.Done(): // Request is done, stop updating. return case <-t.C: m.lastHandout = time.Now() if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/lock-rest-client.go
} // Refresh calls Refresh REST API. func (c *lockRESTClient) Refresh(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRefresh, &args) } // Unlock calls write unlock RPC. func (c *lockRESTClient) Unlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCUnlock, &args) } // ForceUnlock calls force unlock handler to forcibly unlock an active lock.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/notification.go
} // NotificationPeerErr returns error associated for a remote peer. type NotificationPeerErr struct { Host xnet.Host // Remote host on which the rpc call was initiated Err error // Error returned by the remote peer for an rpc call } // A NotificationGroup is a collection of goroutines working on subtasks that are part of // the same overall task. //
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0)