Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 63 for Hockin (0.28 sec)

  1. backend/remote-state/http/client.go

    type httpClient struct {
    	// Update & Retrieve
    	URL          *url.URL
    	UpdateMethod string
    
    	// Locking
    	LockURL      *url.URL
    	LockMethod   string
    	UnlockURL    *url.URL
    	UnlockMethod string
    
    	// HTTP
    	Client   *retryablehttp.Client
    	Username string
    	Password string
    
    	lockID       string
    	jsonLockInfo []byte
    }
    
    Go
    - Registered: 2021-10-29 08:04
    - Last Modified: 2021-01-26 19:39
    - 5.6K bytes
    - Viewed (0)
  2. backend/remote-state/swift/backend_state.go

    		lockInfo.Operation = "init"
    		lockId, err := stateMgr.Lock(lockInfo)
    		if err != nil {
    			return nil, fmt.Errorf("failed to lock state in Swift: %s", err)
    		}
    
    		// Local helper function so we can call it multiple places
    		lockUnlock := func(parent error) error {
    			if err := stateMgr.Unlock(lockId); err != nil {
    				return fmt.Errorf(strings.TrimSpace(errStateUnlock), lockId, err)
    			}
    
    			return parent
    		}
    Go
    - Registered: 2021-10-29 08:04
    - Last Modified: 2020-08-11 15:43
    - 5.1K bytes
    - Viewed (0)
  3. tsdb/fileutil/flock_test.go

    		t.Fatalf("File %q unexpectedly exists.", fileName)
    	}
    
    	lock, existed, err := Flock(fileName)
    	if err != nil {
    		t.Fatalf("Error locking file %q: %s", fileName, err)
    	}
    	if existed {
    		t.Errorf("File %q reported as existing during locking.", fileName)
    	}
    
    	// File must now exist.
    	if _, err = os.Stat(fileName); err != nil {
    		t.Errorf("Could not stat file %q expected to exist: %s", fileName, err)
    	}
    Go
    - Registered: 2021-10-27 16:43
    - Last Modified: 2019-08-14 09:12
    - 2.1K bytes
    - Viewed (0)
  4. backend/remote-state/kubernetes/backend_test.go

    	}))
    
    	// Test
    	backend.TestBackendStates(t, b1)
    }
    
    func TestBackendLocks(t *testing.T) {
    	testACC(t)
    	defer cleanupK8sResources(t)
    
    	// Get the backend. We need two to test locking.
    	b1 := backend.TestBackendConfig(t, New(), backend.TestWrapConfig(map[string]interface{}{
    		"secret_suffix": secretSuffix,
    	}))
    
    	b2 := backend.TestBackendConfig(t, New(), backend.TestWrapConfig(map[string]interface{}{
    Go
    - Registered: 2021-10-29 08:04
    - Last Modified: 2020-08-11 15:43
    - 3.9K bytes
    - Viewed (0)
  5. store/stage/stage_test.go

    		t.Run("FindNumber", testStageFindNumber(store, item))
    		t.Run("List", testStageList(store, item))
    		t.Run("ListSteps", testStageListSteps(store, item))
    		t.Run("Update", testStageUpdate(store, item))
    		t.Run("Locking", testStageLocking(store, item))
    	}
    }
    
    func testStageFind(store *stageStore, stage *core.Stage) func(t *testing.T) {
    	return func(t *testing.T) {
    		result, err := store.Find(noContext, stage.ID)
    		if err != nil {
    Go
    - Registered: 2021-10-20 22:30
    - Last Modified: 2019-09-23 23:44
    - 6.8K bytes
    - Viewed (0)
  6. fs/accounting/stats.go

    }
    
    // calculateTransferStats calculates some addtional transfer stats not
    // stored directly in StatsInfo
    func (s *StatsInfo) calculateTransferStats() (ts transferStats) {
    	// checking and transferring have their own locking so read
    	// here before lock to prevent deadlock on GetBytes
    	transferring, checking := s.transferring.count(), s.checking.count()
    	transferringBytesDone, transferringBytesTotal := s.transferring.progress(s)
    
    Go
    - Registered: 2021-09-20 07:43
    - Last Modified: 2021-08-31 07:57
    - 20.1K bytes
    - Viewed (0)
  7. accounts/usbwallet/wallet.go

    	healthQuit chan chan error
    
    	// Locking a hardware wallet is a bit special. Since hardware devices are lower
    	// performing, any communication with them might take a non negligible amount of
    	// time. Worse still, waiting for user confirmation can take arbitrarily long,
    	// but exclusive communication must be upheld during. Locking the entire wallet
    Go
    - Registered: 2021-10-24 18:27
    - Last Modified: 2021-03-22 08:29
    - 22.2K bytes
    - Viewed (0)
  8. backend/remote/backend_apply_test.go

    	}
    
    	stateMgr, _ := b.StateMgr(backend.DefaultStateName)
    	// An error suggests that the state was not unlocked after apply
    	if _, err := stateMgr.Lock(statemgr.NewLockInfo()); err != nil {
    		t.Fatalf("unexpected error locking state after apply: %s", err.Error())
    	}
    }
    
    func TestRemote_applyCanceled(t *testing.T) {
    	b, bCleanup := testBackendDefault(t)
    	defer bCleanup()
    
    Go
    - Registered: 2021-10-29 08:04
    - Last Modified: 2021-02-18 17:08
    - 39.9K bytes
    - Viewed (0)
  9. lib/ur/usage_report.go

    	svc := &Service{
    		cfg:                cfg,
    		model:              m,
    		connectionsService: connectionsService,
    		noUpgrade:          noUpgrade,
    		forceRun:           make(chan struct{}, 1), // Buffered to prevent locking
    	}
    	svc.Service = util.AsService(svc.serve, svc.String())
    	return svc
    }
    
    // ReportData returns the data to be sent in a usage report with the currently
    // configured usage reporting version.
    Go
    - Registered: 2021-10-20 01:19
    - Last Modified: 2020-04-06 07:53
    - 13.7K bytes
    - Viewed (0)
  10. store/build/build_test.go

    		t.Run("FindRef", testBuildFindRef(store, build))
    		t.Run("List", testBuildList(store, build))
    		t.Run("ListRef", testBuildListRef(store, build))
    		t.Run("Update", testBuildUpdate(store, build))
    		t.Run("Locking", testBuildLocking(store, build))
    		t.Run("Delete", testBuildDelete(store, build))
    	}
    }
    
    func testBuildFind(store *buildStore, build *core.Build) func(t *testing.T) {
    	return func(t *testing.T) {
    Go
    - Registered: 2021-10-20 22:30
    - Last Modified: 2020-03-13 17:27
    - 12K bytes
    - Viewed (0)
Back to top