Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 858 for err (0.05 sec)

  1. internal/event/targetlist_test.go

    	targetListCase2 := NewTargetList(context.Background())
    	if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	targetListCase3 := NewTargetList(context.Background())
    	if err := targetListCase3.Add(&ExampleTarget{TargetID{"3", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. cmd/tier-last-day-stats_gen.go

    	err = en.WriteMapHeader(uint32(len(z)))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0007, zb0008 := range z {
    		err = en.WriteString(zb0007)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		// map header, size 2
    		// write "Bins"
    		err = en.Append(0x82, 0xa4, 0x42, 0x69, 0x6e, 0x73)
    		if err != nil {
    			return
    		}
    		err = en.WriteArrayHeader(uint32(24))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. internal/config/api/api.go

    		}
    	}
    	cfg.CorsAllowOrigin = corsAllowOrigin
    
    	if err = config.CheckValidKeys(config.APISubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil {
    		return cfg, err
    	}
    
    	// Check environment variables parameters
    	requestsMax, err := strconv.Atoi(env.Get(EnvAPIRequestsMax, kvs.GetWithDefault(apiRequestsMax, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    
    	cfg.RequestsMax = requestsMax
    	if requestsMax < 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (1)
  4. cmd/erasure_test.go

    	disks := make([]StorageAPI, len(diskPaths))
    	var err error
    	for i := range diskPaths {
    		disks[i], diskPaths[i], err = newXLStorageTestSetup(tb)
    		if err != nil {
    			return nil, err
    		}
    		err = disks[i].MakeVol(context.Background(), "testbucket")
    		if err != nil {
    			return nil, err
    		}
    	}
    	return &erasureTestSetup{dataBlocks, parityBlocks, blockSize, diskPaths, disks}, nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    			r.err = err
    			return err
    		}
    
    		var err error
    		var meta metaCacheEntry
    		if meta.name, err = r.mr.ReadString(); err != nil {
    			if err == io.EOF {
    				err = io.ErrUnexpectedEOF
    			}
    			r.err = err
    			return err
    		}
    		if meta.metadata, err = r.mr.ReadBytes(metaDataPoolGet()); err != nil {
    			if err == io.EOF {
    				err = io.ErrUnexpectedEOF
    			}
    			r.err = err
    			return err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server_gen.go

    	if err != nil {
    		err = msgp.WrapError(err, "NEndpoints")
    		return
    	}
    	// write "CmdLines"
    	err = en.Append(0xa8, 0x43, 0x6d, 0x64, 0x4c, 0x69, 0x6e, 0x65, 0x73)
    	if err != nil {
    		return
    	}
    	err = en.WriteArrayHeader(uint32(len(z.CmdLines)))
    	if err != nil {
    		err = msgp.WrapError(err, "CmdLines")
    		return
    	}
    	for za0001 := range z.CmdLines {
    		err = en.WriteString(z.CmdLines[za0001])
    		if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 14:49:49 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. internal/config/lambda/target/webhook.go

    	atomic.AddInt64(&target.activeRequests, 1)
    	defer atomic.AddInt64(&target.activeRequests, -1)
    
    	atomic.AddInt64(&target.totalRequests, 1)
    	defer func() {
    		if err != nil {
    			atomic.AddInt64(&target.failedRequests, 1)
    		}
    	}()
    
    	if err = target.init(); err != nil {
    		return nil, err
    	}
    
    	data, err := json.Marshal(eventData)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. cmd/object-api-datatypes_gen.go

    			z.Name, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Name")
    				return
    			}
    		case "Created":
    			z.Created, bts, err = msgp.ReadTimeBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Created")
    				return
    			}
    		case "Deleted":
    			z.Deleted, bts, err = msgp.ReadTimeBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Deleted")
    				return
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  9. cmd/listen-notification-handlers.go

    		eventName, err := event.ParseName(s)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.ListVols(ctx)
    }
    
    func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return VolInfo{}, err
    	}
    	return d.disk.StatVol(ctx, volume)
    }
    
    func (d *naughtyDisk) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top