- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 358 for sekund (0.2 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
panic(err) } err = c.SetWriteDeadline(time.Now().Add(time.Second)) if err != nil { panic(err) } c.Write(data) } func sendHello(c *net.UnixConn) { ack := &zdsapi.ZdsHello{ Version: zdsapi.Version_V1, } data, err := proto.Marshal(ack) if err != nil { panic(err) } err = c.SetWriteDeadline(time.Now().Add(time.Second)) if err != nil { panic(err) } c.Write(data)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java
reqx.writeMode = 0; } file.send( reqx, rspx ); fp += rspx.count; len -= rspx.count; off += rspx.count; } else { req.setParam( file.fid, fp, len - w, b, off, w ); fp += rsp.count; len -= rsp.count; off += rsp.count; file.send( req, rsp ); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 9.2K bytes - Viewed (0) -
cmd/callhome.go
// sleep for some time and try again. duration := time.Duration(r.Float64() * float64(globalCallhomeConfig.FrequencyDur())) if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks. duration = time.Second } time.Sleep(duration) } }() } func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
cmd/shared-lock.go
package cmd import ( "context" "time" ) var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{ timeout: 30 * time.Second, minimum: 10 * time.Second, retryInterval: time.Minute, }) type sharedLock struct { lockContext chan LockContext } func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 13 09:26:38 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
if terr != nil { t.Errorf("failed to accept new connection. %v", terr) return } deadlineconn := New(tcpConn) deadlineconn.WithReadDeadline(time.Second) deadlineconn.WithWriteDeadline(time.Second) defer deadlineconn.Close() // Read a line b := make([]byte, 12) _, terr = deadlineconn.Read(b) if terr != nil { t.Errorf("failed to read from client. %v", terr) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
internal/store/store.go
retryTicker := time.NewTicker(retryInterval) defer retryTicker.Stop() send := func(key Key) bool { for { err := target.SendFromStore(key) if err == nil { break } logger( context.Background(), fmt.Errorf("unable to send webhook log entry to '%s' err '%w'", target.Name(), err), target.Name(), ) select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/event/target/webhook.go
} if err := target.init(); err != nil { return err } err := target.send(eventData) if err != nil { if xnet.IsNetworkOrHostDown(err, false) { return store.ErrNotConnected } } return err } // send - sends an event to the webhook. func (target *WebhookTarget) send(eventData event.Event) error { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/event/target/redis.go
} if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil { return err } return target.send(eventData) } // send - sends an event to the redis. func (target *RedisTarget) send(eventData event.Event) error { conn := target.pool.Get() defer conn.Close() if target.args.Format == event.NamespaceFormat {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* entire response body. If and when the client makes a subsequent request using a pooled socket the * server may not have had time to close the socket. The socket will be closed at an indeterminate * point before or during the second request. It may be closed after client has started sending the * request body. If a request body is not retryable then the client may fail the request, making
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0)