- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for conj (0.17 sec)
-
tensorflow/c/experimental/gradients/math_grad.cc
// Conj each input AbstractTensorHandle* conj_output; std::string name = "Conj_A_MatMul_Grad"; TF_RETURN_IF_ERROR( SafeConj(ctx, forward_inputs_[0], &conj_output, name.c_str())); AbstractTensorHandlePtr A(conj_output); name = "Conj_B_MatMul_Grad"; TF_RETURN_IF_ERROR( SafeConj(ctx, forward_inputs_[1], &conj_output, name.c_str()));
C++ - Registered: Tue Mar 26 12:39:09 GMT 2024 - Last Modified: Wed Feb 28 13:53:47 GMT 2024 - 15.2K bytes - Viewed (0) -
internal/grid/connection.go
} // monitorState will monitor the state of the connection and close the net.Conn if it changes. func (c *Connection) monitorState(conn net.Conn, cancel context.CancelCauseFunc) { c.connChange.L.Lock() defer c.connChange.L.Unlock() for { newState := c.State() if newState != StateConnected { conn.Close() cancel(ErrDisconnected) return } // Unlock and wait for state change.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/common-main.go
ctxt.Interface = ctx.String("interface") ctxt.UserTimeout = ctx.Duration("conn-user-timeout") ctxt.ConnReadDeadline = ctx.Duration("conn-read-deadline") ctxt.ConnWriteDeadline = ctx.Duration("conn-write-deadline") ctxt.ConnClientReadDeadline = ctx.Duration("conn-client-read-deadline") ctxt.ConnClientWriteDeadline = ctx.Duration("conn-client-write-deadline") ctxt.SendBufSize = ctx.Int("send-buf-size")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cni/pkg/install/cniconfig_test.go
}, { name: "standalone CNI plugin unspecified CNI config file", expectedConfName: "YYY-istio-cni.conf", goldenConfName: "istio-cni.conf", }, { name: "standalone CNI plugin specified CNI config file", specifiedConfName: "specific-name.conf", expectedConfName: "specific-name.conf", goldenConfName: "istio-cni.conf",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn) // get hello message from ztunnel m, _, err := readProto[zdsapi.ZdsHello](conn.u, readWriteDeadline, nil) if err != nil { return err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
for ( SmbTransportImpl conn : this.connections ) { if ( conn.matches(address, port, localAddr, localPort, hostName) && ( tc.getConfig().getSessionLimit() == 0 || conn.getNumSessions() < tc.getConfig().getSessionLimit() ) ) { try { if ( conn.isFailed() || ( connectedOnly && conn.isDisconnected() ) ) { continue;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 12.5K bytes - Viewed (0) -
api/go1.9.txt
pkg database/sql, method (*Conn) BeginTx(context.Context, *TxOptions) (*Tx, error) pkg database/sql, method (*Conn) Close() error pkg database/sql, method (*Conn) ExecContext(context.Context, string, ...interface{}) (Result, error) pkg database/sql, method (*Conn) PingContext(context.Context) error pkg database/sql, method (*Conn) PrepareContext(context.Context, string) (*Stmt, error)
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
conn := client.gridConn() if conn == nil { return nil } _, err := reloadPoolMetaRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{})) return err } func (client *peerRESTClient) StopRebalance(ctx context.Context) error { conn := client.gridConn() if conn == nil { return nil } _, err := stopRebalanceRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{}))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/event/target/amqp.go
// close when we know this is a network error. target.conn.Close() } conn, err = amqp091.Dial(target.args.URL.String()) if err != nil { if xnet.IsConnRefusedErr(err) { return nil, nil, store.ErrNotConnected } return nil, nil, err } ch, err = conn.Channel() if err != nil { return nil, nil, err } target.conn = conn if target.args.PublisherConfirms {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
} return pluginResponse(conf) } func doAddRun(args *skel.CmdArgs, conf *Config, kClient kubernetes.Interface, rulesMgr InterceptRuleMgr) error { setupLogging(conf) var loggedPrevResult any if conf.PrevResult == nil { loggedPrevResult = "none" } else { loggedPrevResult = conf.PrevResult } log.WithLabels("if", args.IfName).Debugf("istio-cni CmdAdd config: %+v", conf)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)