- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 116 for rpc (0.71 sec)
-
src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcSamrCloseHandle.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.smb1.dcerpc.msrpc; import jcifs.smb1.dcerpc.rpc; public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle { public MsrpcSamrCloseHandle(rpc.policy_handle policyHandle) { super(policyHandle); ptype = 0; flags = DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG; }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 1.2K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_test_util.cc
TFE_TensorHandle* h1_task0 = TestMatrixTensorHandle(ctx); std::vector<TFE_TensorHandle*> handles_task0; if (heavy_load_on_streaming_rpc) { // Send 50 tensor copy requests to simulate that there have been some RPC // requests been enqueued. for (int i = 0; i < 50; ++i) { handles_task0.push_back(TestMatrixTensorHandle(ctx)); } }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Dec 11 22:56:03 GMT 2020 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
* be unique to the built instance of the ThreadFactory and will be assigned sequentially. For * example, {@code "rpc-pool-%d"} will generate thread names like {@code "rpc-pool-0"}, {@code * "rpc-pool-1"}, {@code "rpc-pool-2"}, etc. * @return this for the builder pattern */ @CanIgnoreReturnValue public ThreadFactoryBuilder setNameFormat(String nameFormat) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 10 21:56:03 GMT 2023 - 7.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_test.cc
#include "tensorflow/core/common_runtime/eager/eager_operation.h" #include "tensorflow/core/common_runtime/function_optimization_registry.h" #include "tensorflow/core/distributed_runtime/rpc/grpc_server_lib.h" #include "tensorflow/core/framework/function.h" #include "tensorflow/core/graph/graph.h" #include "tensorflow/core/platform/casts.h" #include "tensorflow/core/platform/errors.h"
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 12 00:14:22 GMT 2020 - 5.4K 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. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/metacache-manager.go
// checkMetacacheState should be used if data is not updating. // Should only be called if a failure occurred. func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error { // We operate on a copy... o.Create = false c, err := rpc.GetMetacacheListing(ctx, o) if err != nil { return err } cache := *c if cache.status == scanStateNone || cache.fileNotFound { return errFileNotFound
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
src/cmd/asm/internal/arch/arch.go
"cmd/internal/obj/wasm" "cmd/internal/obj/x86" "fmt" "strings" ) // Pseudo-registers whose names are the constant name without the leading R. const ( RFP = -(iota + 1) RSB RSP RPC ) // Arch wraps the link architecture object with more architecture-specific information. type Arch struct { *obj.LinkArch // Map of instruction names to enumeration. Instructions map[string]obj.As
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Mar 21 06:51:28 GMT 2023 - 21.3K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.Fatal("No connection") } // Send the payload. t := time.Now() resp, err := rpc.Call(ctx, conn, &req) latency += time.Since(t).Nanoseconds() if err != nil { if debugReqs { fmt.Println(err.Error()) } b.Fatal(err.Error()) } rpc.PutResponse(resp) n++ } atomic.AddInt64(&ops, int64(n)) atomic.AddInt64(&lat, latency)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/LsarSidArrayX.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.sid_t; import jcifs.smb.SID; class LsarSidArrayX extends lsarpc.LsarSidArray { LsarSidArrayX ( jcifs.SID[] sids ) { this.num_sids = sids.length; this.sids = new lsarpc.LsarSidPtr[sids.length];
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 1.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateResponse.java
return false; } PreauthIntegrityNegotiateContext rpc = null; for ( NegotiateContextRequest rnc : req.getNegotiateContexts() ) { if ( rnc instanceof PreauthIntegrityNegotiateContext ) { rpc = (PreauthIntegrityNegotiateContext) rnc; } } if ( rpc == null ) { return false; } boolean valid = false;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Mar 22 10:09:46 GMT 2020 - 17.6K bytes - Viewed (0)