- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 918 for syncs (0.06 sec)
-
pkg/log/config_test.go
} // make sure that all log outputs is much larger than 2M wg := sync.WaitGroup{} for i := 0; i < 4; i++ { wg.Add(1) go func() { for ii := 0; ii < 1024; ii++ { for j := 0; j < 8; j++ { log.Println(line) } } wg.Done() }() } wg.Wait() Sync() ticker := time.NewTicker(100 * time.Millisecond) defer ticker.Stop()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/test/framework/suite_test.go
g := NewWithT(t) var waitForRun1 sync.WaitGroup waitForRun1.Add(1) var waitForTestCompletion sync.WaitGroup waitForTestCompletion.Add(1) runFn1 := func(ctx *suiteContext) int { waitForRun1.Done() waitForTestCompletion.Wait() return 0 } runFn2 := func(ctx *suiteContext) int { return 0 } var waitForExit1Call sync.WaitGroup waitForExit1Call.Add(1) var errCode1 int
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.5K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/_gen/MIPSOps.go
// SYNC // MOV(B|W) (Rarg0), Rout // SYNC {name: "LoweredAtomicLoad8", argLength: 2, reg: gpload, faultOnNilArg0: true}, {name: "LoweredAtomicLoad32", argLength: 2, reg: gpload, faultOnNilArg0: true}, // store arg1 to arg0. arg2=mem. returns memory. // SYNC // MOV(B|W) Rarg1, (Rarg0) // SYNC
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 14:43:03 UTC 2023 - 24K bytes - Viewed (0) -
schema/field_test.go
package schema_test import ( "context" "database/sql" "reflect" "sync" "testing" "time" "gorm.io/gorm" "gorm.io/gorm/schema" "gorm.io/gorm/utils/tests" ) func TestFieldValuerAndSetter(t *testing.T) { var ( userSchema, _ = schema.Parse(&tests.User{}, &sync.Map{}, schema.NamingStrategy{}) user = tests.User{ Model: gorm.Model{ ID: 10, CreatedAt: time.Now(),
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Sat Feb 19 09:02:53 UTC 2022 - 12.7K bytes - Viewed (0) -
cmd/http-stats.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "net/http" "strings" "sync" "sync/atomic" xhttp "github.com/minio/minio/internal/http" "github.com/prometheus/client_golang/prometheus" ) const ( apiGetObject = "GetObject" ) // connStats - Network statistics
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
See the License for the specific language governing permissions and limitations under the License. */ package healthz import ( "bytes" "context" "fmt" "net/http" "reflect" "strings" "sync" "sync/atomic" "time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/endpoints/metrics" "k8s.io/apiserver/pkg/server/httplog"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
src/net/rpc/server.go
next *Response // for free list in Server } // Server represents an RPC Server. type Server struct { serviceMap sync.Map // map[string]*service reqLock sync.Mutex // protects freeReq freeReq *Request respLock sync.Mutex // protects freeResp freeResp *Response } // NewServer returns a new [Server]. func NewServer() *Server { return &Server{} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/runtime/debuglog.go
break } } } // If the time delta is getting too high, write a new sync // packet. We set the limit so we don't write more than 6 // bytes of delta in the record header. const deltaLimit = 1<<(3*7) - 1 // ~2ms between sync packets if tick-l.w.tick > deltaLimit || nano-l.w.nano > deltaLimit { l.w.writeSync(tick, nano) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 15:10:48 UTC 2024 - 18.3K bytes - Viewed (0) -
api/go1.9.txt
pkg runtime/pprof, type LabelSet struct pkg sync, method (*Map) Delete(interface{}) pkg sync, method (*Map) Load(interface{}) (interface{}, bool) pkg sync, method (*Map) LoadOrStore(interface{}, interface{}) (interface{}, bool) pkg sync, method (*Map) Range(func(interface{}, interface{}) bool) pkg sync, method (*Map) Store(interface{}, interface{}) pkg sync, type Map struct
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 04 20:20:20 UTC 2021 - 10.7K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
// this prevents the autoregistration controller's initial sync from deleting APIServices for CRDs that still exist. // we only need to do this if CRDs are enabled on this server. We can't use discovery because we are the source for discovery. if crdAPIEnabled { klog.Infof("waiting for initial CRD sync...") crdRegistrationController.WaitForInitialSync() klog.Infof("initial CRD sync complete...") } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0)