Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 173 for resptr (0.29 sec)

  1. cmd/lock-rest-server.go

    func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCRefresh.NewResponse()
    	refreshed, err := l.ll.Refresh(context.Background(), *args)
    	if err != nil {
    		return l.makeResp(resp, err)
    	}
    	if !refreshed {
    		return l.makeResp(resp, errLockNotFound)
    	}
    	return l.makeResp(resp, err)
    }
    
    // LockHandler - Acquires a lock.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/ssa/_gen/S390X.rules

    (Zero [0] _ mem) => mem
    (Zero [1] destptr mem) => (MOVBstoreconst [0] destptr mem)
    (Zero [2] destptr mem) => (MOVHstoreconst [0] destptr mem)
    (Zero [4] destptr mem) => (MOVWstoreconst [0] destptr mem)
    (Zero [8] destptr mem) => (MOVDstoreconst [0] destptr mem)
    (Zero [3] destptr mem) =>
    	(MOVBstoreconst [makeValAndOff(0,2)] destptr
    		(MOVHstoreconst [0] destptr mem))
    (Zero [5] destptr mem) =>
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 12 18:09:26 UTC 2023
    - 74.3K bytes
    - Viewed (0)
  3. src/compress/zlib/reader.go

    	err          error
    	scratch      [4]byte
    }
    
    // Resetter resets a ReadCloser returned by [NewReader] or [NewReaderDict]
    // to switch to a new underlying Reader. This permits reusing a ReadCloser
    // instead of allocating a new one.
    type Resetter interface {
    	// Reset discards any buffered data and resets the Resetter as if it was
    	// newly initialized with the given reader.
    	Reset(r io.Reader, dict []byte) error
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 13 23:20:03 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. src/syscall/fs_js.go

    	}
    	for i := 0; i < len(path); i++ {
    		if path[i] == '\x00' {
    			return EINVAL
    		}
    	}
    	return nil
    }
    
    func recoverErr(errPtr *error) {
    	if err := recover(); err != nil {
    		jsErr, ok := err.(js.Error)
    		if !ok {
    			panic(err)
    		}
    		*errPtr = mapJSError(jsErr.Value)
    	}
    }
    
    // mapJSError maps an error given by Node.js to the appropriate Go error.
    func mapJSError(jsErr js.Value) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 11 18:19:17 UTC 2023
    - 10.8K bytes
    - Viewed (0)
  5. subprojects/core/src/main/java/org/gradle/caching/internal/controller/impl/LifecycleAwareBuildCacheController.java

         */
        void configurationAvailable(BuildCacheConfigurationInternal configuration);
    
        /**
         * Resets the state of this controller in preparation for loading configuration from the cache.
         */
        void resetState();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 22 23:28:13 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. src/runtime/tls_ppc64x.s

    // license that can be found in the LICENSE file.
    
    //go:build ppc64 || ppc64le
    
    #include "go_asm.h"
    #include "go_tls.h"
    #include "funcdata.h"
    #include "textflag.h"
    
    // We have to resort to TLS variable to save g (R30).
    // One reason is that external code might trigger
    // SIGSEGV, and our runtime.sigtramp don't even know we
    // are in external code, and will continue to use R30,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 22 02:48:11 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  7. pkg/test/framework/suite_test.go

    	g.Expect(errCode2).NotTo(Equal(0))
    }
    
    func TestSuite_GetResource(t *testing.T) {
    	defer cleanupRT()
    
    	act := func(refPtr any, trackedResource resource.Resource) error {
    		var err error
    		runFn := func(ctx *suiteContext) int {
    			err = ctx.GetResource(refPtr)
    			return 0
    		}
    		s := newTestSuite("tid", runFn, defaultExitFn, defaultSettingsFn)
    		s.Setup(func(c resource.Context) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/typecheck/expr.go

    	return n
    }
    
    // tcSPtr typechecks an OSPTR node.
    func tcSPtr(n *ir.UnaryExpr) ir.Node {
    	n.X = Expr(n.X)
    	t := n.X.Type()
    	if t == nil {
    		n.SetType(nil)
    		return n
    	}
    	if !t.IsSlice() && !t.IsString() {
    		base.Fatalf("OSPTR of %v", t)
    	}
    	if t.IsString() {
    		n.SetType(types.NewPtr(types.Types[types.TUINT8]))
    	} else {
    		n.SetType(types.NewPtr(t.Elem()))
    	}
    	return n
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 14:29:45 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. subprojects/core-api/src/main/java/org/gradle/api/artifacts/DirectDependencyMetadata.java

         * resolution as if they were defined by the endorsing module itself.
         *
         * @since 6.0
         */
        void endorseStrictVersions();
    
        /**
         * Resets the {@link #isEndorsingStrictVersions()} state of this dependency.
         *
         * @since 6.0
         */
        void doNotEndorseStrictVersions();
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Mar 09 17:53:23 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  10. src/crypto/internal/boring/aes.go

    	x := &aesCBC{key: &c.dec, mode: C.GO_AES_DECRYPT}
    	copy(x.iv[:], iv)
    	return x
    }
    
    type aesCTR struct {
    	key        *C.GO_AES_KEY
    	iv         [aesBlockSize]byte
    	num        C.uint
    	ecount_buf [16]C.uint8_t
    }
    
    func (x *aesCTR) XORKeyStream(dst, src []byte) {
    	if inexactOverlap(dst, src) {
    		panic("crypto/cipher: invalid buffer overlap")
    	}
    	if len(dst) < len(src) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jan 26 22:52:27 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top