Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1071 - 1080 of 1,182 for happened (0.08 sec)

  1. internal/event/config_test.go

    	}
    
    	for i, testCase := range testCases {
    		testCase.config.SetRegion(testCase.region)
    		result := []ARN{}
    		for _, queue := range testCase.config.QueueList {
    			result = append(result, queue.ARN)
    		}
    
    		if !reflect.DeepEqual(result, testCase.expectedResult) {
    			t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result)
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    							fmt.Errorf("unable to encode webhook log entry, err  '%w' entry: %v\n", err, entry),
    							h.Name(),
    						)
    						h.failedMessages.Add(1)
    						continue
    					}
    				} else {
    					entries = append(entries, entry)
    				}
    				count++
    			}
    
    			if len(h.logCh) > 0 || len(globalBuffer) > 0 || count == 0 {
    				// there is something in the log queue
    				// process it first, even if we tickered
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. internal/ringbuffer/ring_buffer.go

    // Callers should always process the n > 0 bytes returned before considering the error err.
    // Doing so correctly handles I/O errors that happen after reading some bytes and also both of the allowed EOF behaviors.
    func (r *RingBuffer) Read(p []byte) (n int, err error) {
    	if len(p) == 0 {
    		return 0, r.readErr(false)
    	}
    
    	r.mu.Lock()
    	defer r.mu.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. internal/ringbuffer/ring_buffer_test.go

    	}
    	if n != 16 {
    		t.Fatalf("expect write 16 bytes but got %d", n)
    	}
    	if rb.Free() != 0 {
    		t.Fatalf("expect free 0 bytes but got %d. r.w=%d, r.r=%d", rb.Free(), rb.w, rb.r)
    	}
    	if !bytes.Equal(append(buf, rb.Bytes(nil)...), []byte(strings.Repeat("abcd", 16)+strings.Repeat("1234", 4))) {
    		t.Fatalf("expect 16 abcd and 4 1234 but got %s. r.w=%d, r.r=%d", rb.Bytes(nil), rb.w, rb.r)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    	add = func(path dataUsageHash) {
    		e, ok := d.Cache[path.Key()]
    		if !ok {
    			return
    		}
    		if len(e.Children) == 0 {
    			return
    		}
    		sz := d.sizeRecursive(path.Key())
    		leaves = append(leaves, struct {
    			objects uint64
    			path    dataUsageHash
    		}{objects: sz.Objects, path: path})
    		for ch := range e.Children {
    			add(dataUsageHash(ch))
    		}
    	}
    
    	// Add path recursively.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/CompactHashSet.java

          return delegate.add(object);
        }
        int[] entries = requireEntries();
        @Nullable Object[] elements = requireElements();
    
        int newEntryIndex = this.size; // current size, and pointer to the entry to be appended
        int newSize = newEntryIndex + 1;
        int hash = smearedHash(object);
        int mask = hashTableMask();
        int tableIndex = hash & mask;
        int next = CompactHashing.tableGet(requireTable(), tableIndex);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  7. docs/en/docs/advanced/security/oauth2-scopes.md

    And if you select the scope `me` but not the scope `items`, you will be able to access `/users/me/` but not `/users/me/items/`.
    
    That's what would happen to a third party application that tried to access one of these *path operations* with a token provided by a user, depending on how many permissions the user gave the application.
    
    ## About third party integrations
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 29 11:02:16 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        boolean done = doneSignal.await(1, SECONDS);
        if (!done) {
          StringBuilder builder = new StringBuilder();
          for (StackTraceElement trace : thread.getStackTrace()) {
            builder.append("\tat ").append(trace).append('\n');
          }
          fail(builder.toString());
        }
      }
    
      /**
       * Returns an iterable containing all combinations of maximumSize, expireAfterAccess/Write,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        boolean done = doneSignal.await(1, SECONDS);
        if (!done) {
          StringBuilder builder = new StringBuilder();
          for (StackTraceElement trace : thread.getStackTrace()) {
            builder.append("\tat ").append(trace).append('\n');
          }
          fail(builder.toString());
        }
      }
    
      /**
       * Returns an iterable containing all combinations of maximumSize, expireAfterAccess/Write,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    	}
    
    	testCases := []struct {
    		fileName    string
    		expectedErr error
    	}{
    		{"myobject", nil},
    		{"path/to/my/object", nil},
    		// TestXLStorage to append to previously created file.
    		{"myobject", nil},
    		// TestXLStorage to use same path of previously created file.
    		{"path/to/my/testobject", nil},
    		// TestXLStorage to use object is a directory now.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
Back to top