Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for function (0.27 sec)

  1. src/cmd/cgo/internal/test/callback.go

    func nestedCall(f func()) {
    	// callback(x) calls goCallback(x)
    	callbackMutex.Lock()
    	callbackToken++
    	i := callbackToken
    	callbackFuncs[i] = f
    	callbackMutex.Unlock()
    
    	// Pass the address of i because the C function was written to
    	// take a pointer.  We could pass an int if we felt like
    	// rewriting the C code.
    	C.callback(unsafe.Pointer(&i))
    
    	callbackMutex.Lock()
    	delete(callbackFuncs, i)
    	callbackMutex.Unlock()
    }
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri May 12 12:00:02 GMT 2023
    - 111.5K bytes
    - Viewed (0)
  2. cmd/object-handlers_test.go

    	for _, input := range objectInputs {
    		uploadTestObject(t, apiRouter, credentials, bucketName, input.objectName, input.partLengths, input.metaData, false)
    	}
    
    	// function type for creating signed requests - used to repeat
    	// requests with V2 and V4 signing.
    	type testSignedReqFn func(method, urlStr string, contentLength int64,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	dependGlobalLockServer          bool
    	dependGlobalIsDistErasure       bool
    	dependGlobalBackgroundHealState bool
    	dependBucketTargetSys           bool
    }
    
    // RegisterRead register the metrics populator function to be used
    // to populate new values upon cache invalidation.
    func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) {
    	g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    	return core, nil
    }
    
    // Check if the destination bucket is on a remote site, this code only gets executed
    // when federation is enabled, ie when globalDNSConfig is non 'nil'.
    //
    // This function is similar to isRemoteCallRequired but specifically for COPY object API
    // if destination and source are same we do not need to check for destination bucket
    // to exist locally.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 125K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    			}
    
    			mu.Lock()
    			rinfos.Targets = append(rinfos.Targets, tgtInfo)
    			mu.Unlock()
    		}(tgt)
    	}
    	wg.Wait()
    
    	replicationStatus = rinfos.ReplicationStatus() // used in defer function
    	// FIXME: add support for missing replication events
    	// - event.ObjectReplicationMissedThreshold
    	// - event.ObjectReplicationReplicatedAfterThreshold
    	eventName := event.ObjectReplicationComplete
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  6. cmd/site-replication.go

    		// server configuration, and convert it to minio-go's
    		// replication configuration type (by converting to xml and
    		// parsing it back), use minio-go's add rule function, and
    		// finally convert it back to the server type (again via xml).
    		// This is needed as there is no add-rule function in the server
    		// yet.
    
    		// Though we do not check if the rule already exists, this is
    		// not a problem as we are always using the same replication
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
Back to top