- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for mq_open (0.14 sec)
-
prepare_stmt.go
defer close(cacheStmt.prepared) // Reason why cannot lock conn.PrepareContext // suppose the maxopen is 1, g1 is creating record and g2 is querying record. // 1. g1 begin tx, g1 is requeue because of waiting for the system call, now `db.ConnPool` db.numOpen == 1. // 2. g2 select lock `conn.PrepareContext(ctx, query)`, now db.numOpen == db.maxOpen , wait for release.
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Mar 28 08:47:39 UTC 2024 - 6.4K bytes - Viewed (0) -
src/database/sql/sql.go
db.mu.Lock() if n > 0 { db.maxIdleCount = n } else { // No idle connections. db.maxIdleCount = -1 } // Make sure maxIdle doesn't exceed maxOpen if db.maxOpen > 0 && db.maxIdleConnsLocked() > db.maxOpen { db.maxIdleCount = db.maxOpen } var closing []*driverConn idleCount := len(db.freeConn) maxIdle := db.maxIdleConnsLocked() if idleCount > maxIdle { closing = db.freeConn[maxIdle:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/flatbuffer_to_string.cc
*serialized_model = std::string{std::istreambuf_iterator<char>(std::cin), std::istreambuf_iterator<char>()}; } else { std::ifstream t(file_path); if (!t.is_open()) { std::cerr << "Failed to open input file.\n"; return true; } *serialized_model = std::string{std::istreambuf_iterator<char>(t), std::istreambuf_iterator<char>()};
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 21 15:52:23 UTC 2024 - 4.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_zos_s390x.go
IN_ACCESS = 0x00000001 IN_MODIFY = 0x00000002 IN_ATTRIB = 0x00000004 IN_CLOSE_WRITE = 0x00000008 IN_CLOSE_NOWRITE = 0x00000010 IN_OPEN = 0x00000020 IN_MOVED_FROM = 0x00000040 IN_MOVED_TO = 0x00000080 IN_CREATE = 0x00000100 IN_DELETE = 0x00000200 IN_DELETE_SELF = 0x00000400
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 39.4K bytes - Viewed (0) -
src/database/sql/sql_test.go
t.Errorf("free conns = %d; want %d", g, w) } } // Issue 10886: tests that all connection attempts return when more than // DB.maxOpen connections are in flight and the first DB.maxOpen fail. func TestPendingConnsAfterErr(t *testing.T) { const ( maxOpen = 2 tryOpen = maxOpen*2 + 2 ) // No queries will be run. db, err := Open("test", fakeDBName) if err != nil { t.Fatalf("Open: %v", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux.go
IN_MOVED_TO = 0x80 IN_MOVE_SELF = 0x800 IN_ONESHOT = 0x80000000 IN_ONLYDIR = 0x1000000 IN_OPEN = 0x20 IN_Q_OVERFLOW = 0x4000 IN_UNMOUNT = 0x2000 IPPROTO_AH = 0x33
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 185.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"IN_MOVED_FROM", Const, 0}, {"IN_MOVED_TO", Const, 0}, {"IN_MOVE_SELF", Const, 0}, {"IN_NONBLOCK", Const, 0}, {"IN_ONESHOT", Const, 0}, {"IN_ONLYDIR", Const, 0}, {"IN_OPEN", Const, 0}, {"IN_Q_OVERFLOW", Const, 0}, {"IN_RFC3021_HOST", Const, 1}, {"IN_RFC3021_MASK", Const, 1}, {"IN_RFC3021_NET", Const, 1}, {"IN_RFC3021_NSHIFT", Const, 1},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)