- Sort Score
- Result 10 results
- Languages All
Results 471 - 480 of 767 for Flock (2.29 sec)
-
buildscripts/rewrite-old-new.sh
if ! ps -p ${pid} 1>&2 >/dev/null; then echo "server1 log:" cat "${WORK_DIR}/server1.log" echo "FAILED" purge "$WORK_DIR" exit 1 fi "${WORK_DIR}/mc" mb minio/healing-rewrite-bucket --quiet --with-lock "${WORK_DIR}/mc" cp \ buildscripts/verify-build.sh \ minio/healing-rewrite-bucket/ \ --disable-multipart --quiet "${WORK_DIR}/mc" cp \ buildscripts/verify-build.sh \ minio/healing-rewrite-bucket/ \Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 3.4K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbSessionTest.java
} @Test void sendResetsResponseAndForwards() throws Exception { SmbSession session = new SmbSession(addr, 445, inet, 0, auth); // prepare a dummy request/response using a real SMB block type ServerMessageBlock req = new SmbComOpenAndX("test.txt", 0, 0, null); ServerMessageBlock resp = new SmbComOpenAndX("test.txt", 0, 0, null); resp.received = true;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.6K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbComWriteTest.java
int bytesWritten = write.writeBytesWireFormat(dst, 0); // Assert assertEquals(6, bytesWritten, "Should write 6 bytes (1 type + 2 length + 3 data)"); assertEquals(0x01, dst[0], "Data block type"); assertEquals(3, dst[1] & 0xFF, "Data length low byte"); assertEquals(0, dst[2] & 0xFF, "Data length high byte"); assertEquals(2, dst[3], "First data byte");
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
private lateinit var server: MockWebServer private lateinit var client: OkHttpClient @BeforeEach fun setUp() { // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory = object : DelegatingServerSocketFactory(getDefault()) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 18:33:48 UTC 2025 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
* * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a * full queue, the queue automatically removes its head element. This is different from conventional * bounded queues, which either block or reject new elements when full. * * <p>This class is not thread-safe, and does not accept null elements. * * @author Kurt Alfred Kluever * @since 15.0 */ @GwtCompatible
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 4.6K bytes - Viewed (0) -
finisher_api.go
// Make sure to rollback when panic, Block error or Commit error if panicked || err != nil { db.RollbackTo(fmt.Sprintf("sp%d", spID)) } }() } err = fc(db.Session(&Session{NewDB: db.clone == 1})) } else { tx := db.Begin(opts...) if tx.Error != nil { return tx.Error } defer func() { // Make sure to rollback when panic, Block error or Commit errorRegistered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Sep 19 01:49:06 UTC 2025 - 22.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2LeaseBreakResponse.java
* License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2.lock; import jcifs.Configuration; import jcifs.internal.SMBProtocolDecodingException; import jcifs.internal.smb2.ServerMessageBlock2Response; import jcifs.internal.smb2.lease.Smb2LeaseKey; import jcifs.internal.util.SMBUtil;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java
protected int parameterDisplacement; /** Number of data bytes being sent in this request */ protected int dataCount; /** Offset from the start of the SMB header to the data bytes */ protected int dataOffset; /** Displacement of these data bytes from the start of the total data block */ protected int dataDisplacement;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 17.3K bytes - Viewed (0) -
cmd/utils.go
return buf.Bytes(), err } case madmin.ProfilerBlock: runtime.SetBlockProfileRate(100) prof.stopFn = func() ([]byte, error) { var buf bytes.Buffer err := pprof.Lookup("block").WriteTo(&buf, 0) runtime.SetBlockProfileRate(0) return buf.Bytes(), err } case madmin.ProfilerMutex: prof.record("mutex", 0, "before") runtime.SetMutexProfileFraction(1)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 33K bytes - Viewed (0) -
docs/de/docs/tutorial/dependencies/dependencies-with-yield.md
**FastAPI** wird bei jeder das Richtige tun, so wie auch bei normalen Abhängigkeiten. /// ## Eine Abhängigkeit mit `yield` und `try` { #a-dependency-with-yield-and-try } Wenn Sie einen `try`-Block in einer Abhängigkeit mit `yield` verwenden, empfangen Sie alle Exceptions, die bei Verwendung der Abhängigkeit geworfen wurden.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 14.7K bytes - Viewed (0)