Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 628 for kuwait (0.1 sec)

  1. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                        this.handle = this.pipe.openUnshared(this.uncPath, 0, this.access, this.sharing, SmbConstants.ATTR_NORMAL, 0);
                        return this.handle.acquire();
                    }
    
                    // TODO: wait for pipe, still not sure when this needs to be called exactly
                    if ( this.uncPath.startsWith("\\pipe\\") ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Apr 13 17:05:22 UTC 2020
    - 10.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

            new AtomicReference<WeakReference<?>>(
                (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));
        assertNotNull(sepStopwatchA.get());
        // Clear all references to the Stopwatch and wait for it to be gc'd.
        sepStopwatchA.set(null);
        GcFinalization.awaitClear(sepStopwatchRef.get());
        // Return a weak reference to the parallel ClassLoader. This is the reference that should
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    	dstRec.nameIndexMap = r.nameIndexMap
    
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	if r.close != nil {
    		close(r.close)
    		r.readerWg.Wait()
    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. internal/grid/README.md

            // Return the response for reuse
            grid.PutByteBuffer(result)
            return nil
        })
    ```
    
    Context cancellation and timeouts are propagated to the handler. 
    The client does not wait for the remote handler to finish before returning.
    Returning any error will also cancel the stream remotely.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        assertSame(exception, e.getCause());
      }
    
      private static void awaitUnchecked(final CyclicBarrier barrier) {
        try {
          barrier.await();
        } catch (Exception e) {
          throw new RuntimeException(e);
        }
      }
    
      private void checkStackTrace(ExecutionException e) {
        // Our call site for get() should be in the trace.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  6. docs/de/docs/tutorial/dependencies/index.md

    Es spielt keine Rolle. **FastAPI** weiß, was zu tun ist.
    
    /// note | "Hinweis"
    
    Wenn Ihnen das nichts sagt, lesen Sie den [Async: *„In Eile?“*](../../async.md#in-eile){.internal-link target=_blank}-Abschnitt über `async` und `await` in der Dokumentation.
    
    ///
    
    ## Integriert in OpenAPI
    
    Alle Requestdeklarationen, -validierungen und -anforderungen Ihrer Abhängigkeiten (und Unterabhängigkeiten) werden in dasselbe OpenAPI-Schema integriert.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 13K bytes
    - Viewed (0)
  7. cmd/site-replication-utils.go

    						sm.peerResyncMap[dID] = rs
    						wg.Add(1)
    						go func() {
    							defer wg.Done()
    							saveSiteResyncMetadata(ctx, st, newObjectLayerFn())
    						}()
    					}
    				}
    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. docs/debugging/s3-verify/main.go

    			targetFailed = true
    		} else if tgtSize != tgtCtnt.Size {
    			fmt.Printf("unreadable on target - size differs upon read: %s\n", tgtCtnt.Key)
    			targetFailed = true
    		}
    	}()
    	wg.Wait()
    
    	sobj.Close()
    	tobj.Close()
    
    	if !sourceFailed && !targetFailed {
    		ssum := srcSha256.Sum(nil)
    		tsum := tgtSha256.Sum(nil)
    		allgood = bytes.Equal(ssum, tsum)
    		if !allgood {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/ztunnelserver_test.go

    	assert.Equal(t, len(fds), 1)
    	// in theory we should close the fd, but it's just a test..
    
    	assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Add).Add.Uid, uid)
    	// send ack so the server doesn't wait for us.
    	sendAck(ztunClient)
    
    	// second message should be the snap sent message
    	m, fds = readRequest(t, ztunClient)
    	assert.Equal(t, len(fds), 0)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server.go

    					} else {
    						offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, err))
    					}
    				} else {
    					onlineServers++
    				}
    				mu.Unlock()
    			}(clnt)
    		}
    		wg.Wait()
    
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top