Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 172 for defer (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/target/nats_contrib_test.go

    	opts.Port = 14222
    	s := natsserver.RunServer(&opts)
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject: "test",
    	}
    	con, err := clientConfig.connectNats()
    	if err != nil {
    		t.Errorf("Could not connect to nats: %v", err)
    	}
    	defer con.Close()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 3K bytes
    - Click Count (0)
  2. internal/config/lambda/event/targetlist.go

    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  3. internal/event/targetlist.go

    			continue
    		}
    		wg.Add(1)
    		go func(id TargetID, target Target) {
    			list.currentSendCalls.Add(1)
    			list.incCurrentSendCalls(id)
    			list.incTotalEvents(id)
    			defer list.decCurrentSendCalls(id)
    			defer list.currentSendCalls.Add(-1)
    			defer wg.Done()
    
    			if err := target.Save(event); err != nil {
    				list.eventsErrorsTotal.Add(1)
    				list.incFailedEvents(id)
    				reqInfo := &logger.ReqInfo{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  4. internal/grid/muxserver.go

    	var handlerErr atomic.Pointer[RemoteErr]
    	go func() {
    		wg.Wait()
    		defer xioutil.SafeClose(send)
    		err := m.handleRequests(ctx, msg, send, handler, handlerIn)
    		if err != nil {
    			handlerErr.Store(err)
    		}
    	}()
    
    	// Response sender goroutine...
    	go func(outBlock <-chan struct{}) {
    		wg.Wait()
    		defer m.parent.deleteMux(true, m.ID)
    		m.sendResponses(ctx, send, c, &handlerErr, outBlock)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  5. cmd/server-startup-msg_test.go

    	}
    }
    
    // Test printing server common message.
    func TestPrintServerCommonMessage(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	apiEndpoints := []string{"http://127.0.0.1:9000"}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 3K bytes
    - Click Count (0)
  6. internal/store/queuestore.go

    }
    
    // Del - Deletes an entry from the store.
    func (store *QueueStore[_]) Del(key Key) error {
    	store.Lock()
    	defer store.Unlock()
    	return store.del(key)
    }
    
    // Len returns the entry count.
    func (store *QueueStore[_]) Len() int {
    	store.RLock()
    	l := len(store.entries)
    	defer store.RUnlock()
    	return l
    }
    
    // lockless call
    func (store *QueueStore[_]) del(key Key) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  7. internal/pubsub/pubsub.go

    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter}
    	ps.subs = append(ps.subs, sub)
    
    	// We hold a lock, so we are safe to update
    	combined := Mask(atomic.LoadUint64(&ps.types))
    	combined.Merge(Mask(mask.Mask()))
    	atomic.StoreUint64(&ps.types, uint64(combined))
    
    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  8. cmd/os-instrumented.go

    	switch flag & writeMode {
    	case writeMode:
    		defer updateOSMetrics(osMetricOpenFileW, name)(err)
    	default:
    		defer updateOSMetrics(osMetricOpenFileR, name)(err)
    	}
    	return os.OpenFile(name, flag, perm)
    }
    
    // Access captures time taken to call syscall.Access()
    // on windows, plan9 and solaris syscall.Access uses
    // os.Lstat()
    func Access(name string) (err error) {
    	defer updateOSMetrics(osMetricAccess, name)(err)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  9. internal/event/target/nats_tls_contrib_test.go

    	}
    
    	con, err := clientConfig.connectNats()
    	if err != nil {
    		t.Errorf("Could not connect to nats: %v", err)
    	}
    	defer con.Close()
    }
    
    func TestNatsConnTLSCustomCAHandshakeFirst(t *testing.T) {
    	s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls_handshake_first.conf"))
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    			Name:      "localhost",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 22:12:26 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  10. cmd/dummy-handlers.go

    // GetBucketWebsite  - GET bucket website, a dummy api
    func (api objectAPIHandlers) GetBucketWebsiteHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetBucketWebsite")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 13 15:25:16 GMT 2024
    - 8.8K bytes
    - Click Count (0)
Back to Top