Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for Gosched (0.05 seconds)

  1. internal/dsync/dsync_test.go

    				m.Lock(id, source)
    				acc0 -= 100
    				acc1 += 100
    				m.Unlock(b.Context())
    			} 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()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  2. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  3. cmd/xl-storage-disk-id-check.go

    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.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)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. 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))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  5. src/main/resources/fess_message_de.properties

    errors.invalid_confirm_password = Stimmt nicht mit einem Bestätigungspasswort überein.
    errors.cannot_delete_doc_because_of_running = Ein Crawler wird ausgeführt. Sie können keine Dokumente löschen.
    errors.failed_to_delete_doc_in_admin = Fehler beim Löschen eines Dokuments.
    errors.failed_to_send_testmail=Fehler beim Senden einer Test-E-Mail.
    errors.invalid_query_unknown = Die angegebene Abfrage hat eine unbekannte Bedingung.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  6. docs/de/docs/tutorial/sql-databases.md

    ### Einen Helden lesen { #read-one-hero }
    
    Wir können einen einzelnen `Hero` **lesen**.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[58:63] hl[60] *}
    
    ### Einen Helden löschen { #delete-a-hero }
    
    Wir können auch einen `Hero` **löschen**.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[66:73] hl[71] *}
    
    ### Die App ausführen { #run-the-app }
    
    Sie können die App ausführen:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:58:09 GMT 2026
    - 17.7K bytes
    - Click Count (0)
  7. .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" ] &&
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Feb 26 01:48:39 GMT 2020
    - 9.8K bytes
    - Click Count (0)
  8. maven-tests/mvnw

      native_path() { cygpath --path --windows "$1"; }
      ;;
    esac
    
    # set JAVACMD and JAVACCMD
    set_java_home() {
      # For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
      if [ -n "${JAVA_HOME-}" ]; then
        if [ -x "$JAVA_HOME/jre/sh/java" ]; then
          # IBM's JDK on AIX uses strange locations for the executables
          JAVACMD="$JAVA_HOME/jre/sh/java"
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Sep 25 18:22:49 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  9. docs/de/docs/tutorial/first-steps.md

    Normalerweise verwenden Sie:
    
    * `POST`: um Daten zu erzeugen (create).
    * `GET`: um Daten zu lesen (read).
    * `PUT`: um Daten zu aktualisieren (update).
    * `DELETE`: um Daten zu löschen (delete).
    
    In OpenAPI wird folglich jede dieser HTTP-Methoden als „Operation“ bezeichnet.
    
    Wir werden sie auch „**Operationen**“ nennen.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:58:09 GMT 2026
    - 14.9K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/opensearch/client/SearchEngineClientRebuildTest.java

            // Each creates 2 indices (backup + rebuild) = 4 creates
            assertEquals("Only fess_config indices should be rebuilt", 4, testClient.createdIndices.size());
            // Verify no user/log indices were touched
            for (final String index : testClient.createdIndices) {
                assertFalse(index.contains("fess_user"), "fess_user should not be rebuilt");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 28.6K bytes
    - Click Count (0)
Back to Top