Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 142 for recover (0.28 sec)

  1. internal/crypto/metadata_test.go

    		}
    		if !bytes.Equal(sealedKey.Key[:], test.SealedKey.Key[:]) {
    			t.Errorf("Test %d: sealed key mismatch: got '%v' - want '%v'", i, sealedKey.Key, test.SealedKey.Key)
    		}
    	}
    
    	defer func() {
    		if err := recover(); err == nil || err != logger.ErrCritical {
    			t.Errorf("Expected '%s' panic for invalid seal algorithm but got '%s'", logger.ErrCritical, err)
    		}
    	}()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 00:13:57 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  2. docs/erasure/README.md

    MinIO protects data against hardware failures and silent data corruption using erasure code and checksums. With the highest level of redundancy, you may lose up to half (N/2) of the total drives and still be able to recover the data.
    
    ## What is Erasure Code?
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 4.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	go c.monitorState(conn, cancel)
    
    	c.handleMsgWg.Add(2)
    	c.reconnectMu.Unlock()
    
    	// Read goroutine
    	go func() {
    		defer func() {
    			if rec := recover(); rec != nil {
    				gridLogIf(ctx, fmt.Errorf("handleMessages: panic recovered: %v", rec))
    				debug.PrintStack()
    			}
    			c.connChange.L.Lock()
    			if atomic.CompareAndSwapUint32((*uint32)(&c.state), StateConnected, StateConnectionError) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. internal/grid/manager.go

    	return func(w http.ResponseWriter, req *http.Request) {
    		defer func() {
    			if debugPrint {
    				fmt.Printf("grid: Handler returning from: %v %v\n", req.Method, req.URL)
    			}
    			if r := recover(); r != nil {
    				debug.PrintStack()
    				err := fmt.Errorf("grid: panic: %v\n", r)
    				gridLogIf(context.Background(), err, err.Error())
    				w.WriteHeader(http.StatusInternalServerError)
    			}
    		}()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex_test.go

    // Borrowed from rwmutex_test.go
    func TestUnlockPanic(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    	mu := NewLRWMutex()
    	mu.Unlock()
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic2(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex_test.go

    func TestUnlockPanic(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    	mu := NewDRWMutex(ds, "test")
    	mu.Unlock(context.Background())
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic2(t *testing.T) {
    	mu := NewDRWMutex(ds, "test-unlock-panic-2")
    	defer func() {
    		if recover() == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 24 03:49:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
  7. cmd/server_test.go

    	response, err = s.client.Do(request)
    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	var results ListBucketsResponse
    	// parse the list bucket response.
    	decoder := xml.NewDecoder(response.Body)
    	err = decoder.Decode(&results)
    	// validating that the xml-decoding/parsing was successful.
    	c.Assert(err, nil)
    
    	// Fetch the bucket created above
    	var createdBucket Bucket
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  8. docs/bucket/retention/README.md

    ## Get Started
    
    ### 1. Prerequisites
    
    - Install MinIO - [MinIO Quickstart Guide](https://min.io/docs/minio/linux/index.html#quickstart-for-linux)
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  9. internal/bucket/replication/sourceselectioncriteria.go

    		return nil
    	}
    	if !s.IsValid() {
    		return errInvalidSourceSelectionCriteria
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (s *SourceSelectionCriteria) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type sourceSelectionCriteria SourceSelectionCriteria
    	ssc := sourceSelectionCriteria{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  10. internal/s3select/select.go

    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return errMalformedXML(err)
    	}
    
    	parsedType := CompressionType(strings.ToUpper(s))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
Back to top