Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,091 for closes (0.08 sec)

  1. src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

                rsp = new SmbComWriteResponse();    
            }
        }
    
    /**
     * Closes this output stream and releases any system resources associated
     * with it.
     *
     * @throws IOException if a network error occurs
     */
    
        public void close() throws IOException {
            file.close();
            tmp = null;
        }
    
    /**
     * Writes the specified byte to this file output stream.
     *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 9.2K bytes
    - Viewed (0)
  2. internal/config/dns/etcd_dns.go

    	return json.Marshal(&SrvRecord{
    		Host:         ip,
    		Port:         json.Number(port),
    		TTL:          ttl,
    		CreationDate: t,
    	})
    }
    
    // Close closes the internal etcd client and cannot be used further
    func (c *CoreDNS) Close() error {
    	c.etcdClient.Close()
    	return nil
    }
    
    // List - Retrieves list of DNS entries for the domain.
    func (c *CoreDNS) List() (map[string][]SrvRecord, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K 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/rest/client.go

    	return c.CallWithHTTPMethod(ctx, http.MethodPost, rpcMethod, values, body, length)
    }
    
    // Close closes all idle connections of the underlying http client
    func (c *Client) Close() {
    	atomic.StoreInt32(&c.connected, closed)
    }
    
    // NewClient - returns new REST client.
    func NewClient(uu *url.URL, tr http.RoundTripper, auth func() string) *Client {
    	connected := int32(online)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbFileOutputStream.java

        }
    
    
        /**
         * Closes this output stream and releases any system resources associated
         * with it.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void close () throws IOException {
            try {
                if ( this.handle.isValid() ) {
                    this.handle.close();
                }
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Nov 13 15:14:04 UTC 2021
    - 11.9K bytes
    - Viewed (0)
  6. internal/event/targetlist.go

    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. internal/event/target/mysql.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to MySQL database.
    func (target *MySQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbFileInputStream.java

                ioe.initCause(root);
            }
            return ioe;
        }
    
    
        /**
         * Closes this input stream and releases any system resources associated with the stream.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void close () throws IOException {
            try {
                SmbFileHandleImpl h = this.handle;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  9. internal/s3select/message.go

    		progressTickerC = progressTicker.C
    	}
    	recordStagingTicker := time.NewTicker(500 * time.Millisecond)
    
    	// Exit conditions:
    	//
    	// 1. If a writer.write() returns false, select loop below exits and
    	// closes `doneCh` to indicate to caller to also exit.
    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  10. internal/event/target/nats.go

    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NATS server.
    func (target *NATSTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.stanConn != nil {
    		// closing the streaming connection does not close the provided NATS connection.
    		if target.stanConn.NatsConn() != nil {
    			target.stanConn.NatsConn().Close()
    		}
    		return target.stanConn.Close()
    	}
    
    	if target.natsConn != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top