Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Gosched (0.22 sec)

  1. cmd/namespace-lock_test.go

    		}()
    
    		// lk4, blocks.
    		lk4ch := make(chan bool)
    		go func() {
    			lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
    		}()
    		runtime.Gosched()
    
    		// unlock the manual lock
    		nsLk.lockMapMutex.Unlock()
    
    		// To trigger the race:
    		// 1) lk3 or lk4 need to advance and increment the ref on the existing resource,
    		//    successfully acquiring the lock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  2. internal/dsync/dsync_test.go

    				m.Lock(id, source)
    				acc0 -= 100
    				acc1 += 100
    				m.Unlock(context.Background())
    			} else {
    				for i := 0; i < len(data); i += 4 {
    					data[i]++
    				}
    				// Elaborate way to say runtime.Gosched
    				// that does not put the goroutine onto global runq.
    				go func() {
    					c <- true
    				}()
    				<-c
    			}
    		}
    	})
    }
    
    func BenchmarkMutexSpin(b *testing.B) {
    	b.ResetTimer()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. internal/grid/grid_test.go

    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    	t.Helper()
    	// Tiny bit racy for tests, but we try to play nice.
    	for i := 10; i >= 0; i-- {
    		runtime.Gosched()
    		stats := c.Stats()
    		if stats.IncomingStreams != 0 {
    			if i > 0 {
    				time.Sleep(100 * time.Millisecond)
    				continue
    			}
    			var found []uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.lastMinuteLatency.addAll(t-1, a)
    			e.mu.Unlock()
    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    			acc = e.cached.Load()
    		}
    	}
    	atomic.AddInt64(&acc.N, 1)
    	atomic.AddInt64(&acc.Total, int64(value))
    	atomic.AddInt64(&acc.Size, sz)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    				continue
    			}
    		}
    		if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 {
    			if len(c.outQueue) == 0 {
    				// Yield to allow more messages to fill.
    				runtime.Gosched()
    			}
    			if len(c.outQueue) > 0 {
    				queue = append(queue, toSend)
    				queueSize += len(toSend)
    				continue
    			}
    		}
    		c.outMessages.Add(int64(len(queue) + 1))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. src/main/resources/fess_label_de.properties

    labels.wizard_button_finish=Überspringen
    labels.search_list_configuration=Suche
    labels.search_list_button_delete=Löschen
    labels.search_list_delete_confirmation=Möchten Sie es wirklich löschen?
    labels.search_list_button_delete_all=Alles mit dieser Query löschen
    labels.search_list_delete_all_confirmation=Möchten Sie wirklich alles mit dieser Query löschen?
    labels.search_list_button_cancel=Abbrechen
    labels.failure_url_configuration=Fehler-URL
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Mar 22 11:58:34 UTC 2024
    - 42.8K bytes
    - Viewed (0)
  7. src/main/resources/fess_message_de.properties

    errors.result_size_exceeded=Keine weiteren Ergebnisse konnten angezeigt werden.
    errors.target_file_does_not_exist=Datei {0} existiert nicht.
    errors.failed_to_delete_file=Löschen der Datei {0} fehlgeschlagen.
    errors.docid_not_found=Dokument-ID nicht gefunden: {0}
    errors.document_not_found=URL der Dokument-ID nicht gefunden: {0}
    errors.not_load_from_server=Konnte nicht vom Server geladen werden: {0}
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Tue Oct 29 15:01:03 UTC 2019
    - 11.8K bytes
    - Viewed (0)
  8. .teamcity/mvnw

    # For Cygwin, ensure paths are in UNIX format before anything is touched
    if $cygwin ; then
      [ -n "$M2_HOME" ] &&
        M2_HOME=`cygpath --unix "$M2_HOME"`
      [ -n "$JAVA_HOME" ] &&
        JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
      [ -n "$CLASSPATH" ] &&
        CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
    fi
    
    # For Mingw, ensure paths are in UNIX format before anything is touched
    if $mingw ; then
      [ -n "$M2_HOME" ] &&
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 9.8K bytes
    - Viewed (0)
  9. mvnw

      fi
    fi
    
    # For Cygwin, ensure paths are in UNIX format before anything is touched
    if $cygwin; then
      [ -n "$JAVA_HOME" ] \
        && JAVA_HOME=$(cygpath --unix "$JAVA_HOME")
      [ -n "$CLASSPATH" ] \
        && CLASSPATH=$(cygpath --path --unix "$CLASSPATH")
    fi
    
    # For Mingw, ensure paths are in UNIX format before anything is touched
    if $mingw; then
      [ -n "$JAVA_HOME" ] && [ -d "$JAVA_HOME" ] \
        && JAVA_HOME="$(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:24:15 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  10. apache-maven/src/assembly/maven/bin/mvn

    # make it fully qualified
    MAVEN_HOME=`cd "$MAVEN_HOME" && pwd`
    
    cd "$saveddir"
    
    CLASSWORLDS_CONF="$MAVEN_HOME/bin/m2.conf"
    
    # For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
    if $cygwin || $mingw ; then
      [ -n "$JAVA_HOME" ] &&
        JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
    fi
    
    if [ -n "$JAVA_HOME" ] ; then
      if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Oct 24 12:01:35 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top