- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,170 for silent (0.27 sec)
-
cmd/lock-rest-client_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "testing" "github.com/minio/minio/internal/dsync" ) // Tests lock rpc client. func TestLockRESTlient(t *testing.T) { // These should not be connectable. endpoint, err := NewEndpoint("http://localhost:9876") if err != nil { t.Fatalf("unexpected error %v", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K bytes - Viewed (0) -
api/go1.12.txt
pkg syscall (freebsd-386), func Mknod(string, uint32, uint64) error pkg syscall (freebsd-386), type Dirent struct, Fileno uint64 pkg syscall (freebsd-386), type Dirent struct, Namlen uint16 pkg syscall (freebsd-386), type Dirent struct, Off int64 pkg syscall (freebsd-386), type Dirent struct, Pad0 uint8 pkg syscall (freebsd-386), type Dirent struct, Pad1 uint16 pkg syscall (freebsd-386), type Stat_t struct, Atim_ext int32
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 02 21:21:53 GMT 2019 - 13.5K bytes - Viewed (0) -
internal/event/target/testdata/contrib/certs/nats_client_key.pem
Harshavardhana <******@****.***> 1622584780 -0700
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 227 bytes - Viewed (0) -
cmd/notification.go
ng := WithNPeers(len(sys.peerClients)).WithRetries(1) for idx, client := range sys.peerClients { client := client ng.Go(GlobalContext, func() error { if client == nil { return errPeerNotReachable } return client.DeletePolicy(policyName) }, idx, *client.host) } return ng.Wait() } // LoadPolicy - reloads a specific modified policy across all peers
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
internal/grid/muxclient.go
for { select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } err := context.Cause(m.ctx) if !errors.Is(err, errStreamEOF) { m.addErrorNonBlockingClose(respHandler, err) } return case resp, ok := <-respServer: if !ok { return } select { case respHandler <- resp:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/event/target/testdata/contrib/certs/nats_client_cert.pem
Harshavardhana <******@****.***> 1622584780 -0700
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 769 bytes - Viewed (0) -
internal/grid/muxserver.go
} // sendResponses will send responses to the client. func (m *muxServer) sendResponses(ctx context.Context, toSend <-chan []byte, c *Connection, handlerErr *atomic.Pointer[RemoteErr], outBlock <-chan struct{}) { for { // Process outgoing message. var payload []byte var ok bool select { case payload, ok = <-toSend: case <-ctx.Done(): return } select { case <-ctx.Done(): return
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/admin-handlers.go
if globalIsDistErasure { ng := WithNPeers(len(globalNotificationSys.peerClients)) for idx, client := range globalNotificationSys.peerClients { _, ok := failedClients[idx] if ok { continue } client := client ng.Go(ctx, func() error { return client.CommitBinary(ctx) }, idx, *client.host) } for _, nerr := range ng.Wait() { if nerr.Err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
internal/grid/connection.go
if _, loaded := c.outgoing.LoadOrStore(client.MuxID, client); client.MuxID != 0 && !loaded { if debugReqs { _, found := c.outgoing.Load(client.MuxID) fmt.Println(client.MuxID, c.String(), "Connection.newMuxClient: RELOADED MUX. loaded:", loaded, "found:", found) } return client, nil } client.MuxID = atomic.AddUint64(&c.NextID, 1) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxyTest.kt
server.enqueue(MockResponse.Builder().body("abc").build()) server.enqueue(MockResponse.Builder().body("def").build()) val client = clientTestRule.newClientBuilder() .proxy(socksProxy.proxy()) .build() val request1 = Request.Builder().url(server.url("/")).build() val response1 = client.newCall(request1).execute() assertThat(response1.body.string()).isEqualTo("abc")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0)