Home
last modified time | relevance | path

Searched defs:streamHandler (Results 1 – 25 of 135) sorted by relevance

123456

/dports/net/concourse-fly/concourse-6.7.1/vendor/code.cloudfoundry.org/garden/client/connection/
H A Dstream_handler.go16 type streamHandler struct { struct
17 log lager.Logger
18 wg *sync.WaitGroup
28 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) {
42 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) {
50 func (sh *streamHandler) wait(decoder *json.Decoder) (int, error) {
/dports/misc/concourse/concourse-6.7.2/vendor/code.cloudfoundry.org/garden/client/connection/
H A Dstream_handler.go16 type streamHandler struct { struct
17 log lager.Logger
18 wg *sync.WaitGroup
28 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) {
42 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) {
50 func (sh *streamHandler) wait(decoder *json.Decoder) (int, error) {
/dports/net/concourse-fly/concourse-6.7.1/atc/worker/gclient/connection/
H A Dstream_handler.go13 type streamHandler struct { struct
14 log lager.Logger
15 wg *sync.WaitGroup
25 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) {
39 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) {
52 func (sh *streamHandler) wait(decoder *json.Decoder) <-chan waitReturn {
/dports/misc/concourse/concourse-6.7.2/atc/worker/gclient/connection/
H A Dstream_handler.go13 type streamHandler struct { struct
14 log lager.Logger
15 wg *sync.WaitGroup
25 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) {
39 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) {
52 func (sh *streamHandler) wait(decoder *json.Decoder) <-chan waitReturn {
/dports/devel/jiic/jiic/de/tu_darmstadt/informatik/rbg/hatlak/iso9660/impl/
H A DISO9660DirectoryRecord.java38 private StreamHandler streamHandler; field in ISO9660DirectoryRecord
46 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660File file, LayoutHelper helper) … in ISO9660DirectoryRecord()
55 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660MovedDirectory moved, LayoutHelp… in ISO9660DirectoryRecord()
64 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660Directory dir, LayoutHelper help… in ISO9660DirectoryRecord()
72 …public ISO9660DirectoryRecord(StreamHandler streamHandler, Object object, ISO9660Directory dir, La… in ISO9660DirectoryRecord()
91 private void init(StreamHandler streamHandler, LayoutHelper helper) { in init()
H A DISO9660PathTableRecord.java27 private StreamHandler streamHandler; field in ISO9660PathTableRecord
32 …public ISO9660PathTableRecord(StreamHandler streamHandler, Object type, Object object, int parent)… in ISO9660PathTableRecord()
51 …public ISO9660PathTableRecord(StreamHandler streamHandler, Object type, DataReference ref, int par… in ISO9660PathTableRecord()
H A DCreateISO.java32 private StreamHandler streamHandler; field in CreateISO
34 …public CreateISO(StreamHandler streamHandler, ISO9660RootDirectory root) throws FileNotFoundExcept… in CreateISO()
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cronet/android/test/javatests/src/org/chromium/net/urlconnection/
H A DCronetHttpURLStreamHandlerTest.java60 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionHttp() local
75 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionHttps() local
87 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionProtocolNotSupported() local
102 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionWithProxy() local
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/rafthttp/
H A Dhttp.go226 type streamHandler struct { struct
227 tr *Transport
228 peerGetter peerGetter
229 r Raft
230 id types.ID
231 cid types.ID
244 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd31/etcd-3.1.20/rafthttp/
H A Dhttp.go249 type streamHandler struct { struct
250 tr *Transport
251 peerGetter peerGetter
252 r Raft
253 id types.ID
254 cid types.ID
267 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/rafthttp/
H A Dhttp.go251 type streamHandler struct { struct
252 tr *Transport
253 peerGetter peerGetter
254 r Raft
255 id types.ID
256 cid types.ID
269 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd32/etcd-3.2.32/rafthttp/
H A Dhttp.go249 type streamHandler struct { struct
250 tr *Transport
251 peerGetter peerGetter
252 r Raft
253 id types.ID
254 cid types.ID
267 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd33/etcd-3.3.23/rafthttp/
H A Dhttp.go251 type streamHandler struct { struct
252 tr *Transport
253 peerGetter peerGetter
254 r Raft
255 id types.ID
256 cid types.ID
269 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd/etcd-2.3.8/rafthttp/
H A Dhttp.go218 type streamHandler struct { struct
219 tr *Transport
220 peerGetter peerGetter
221 r Raft
222 id types.ID
223 cid types.ID
236 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/rafthttp/
H A Dhttp.go245 type streamHandler struct { struct
246 tr *Transport
247 peerGetter peerGetter
248 r Raft
249 id types.ID
250 cid types.ID
263 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/rafthttp/
H A Dhttp.go241 type streamHandler struct { struct
242 tr *Transport
243 peerGetter peerGetter
244 r Raft
245 id types.ID
246 cid types.ID
259 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/
H A Dhttp.go318 type streamHandler struct { struct
319 lg *zap.Logger
320 tr *Transport
321 peerGetter peerGetter
322 r Raft
323 id types.ID
324 cid types.ID
342 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/rafthttp/
H A Dhttp.go350 type streamHandler struct { struct
351 lg *zap.Logger
352 tr *Transport
353 peerGetter peerGetter
354 r Raft
355 id types.ID
356 cid types.ID
370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/devel/etcd34/etcd-3.4.18/etcdserver/api/rafthttp/
H A Dhttp.go350 type streamHandler struct { struct
351 lg *zap.Logger
352 tr *Transport
353 peerGetter peerGetter
354 r Raft
355 id types.ID
356 cid types.ID
370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/
H A Dhttp.go324 type streamHandler struct { struct
325 lg *zap.Logger
326 tr *Transport
327 peerGetter peerGetter
328 r Raft
329 id types.ID
330 cid types.ID
348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/
H A Dhttp.go324 type streamHandler struct { struct
325 lg *zap.Logger
326 tr *Transport
327 peerGetter peerGetter
328 r Raft
329 id types.ID
330 cid types.ID
348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/rafthttp/
H A Dhttp.go324 type streamHandler struct { struct
325 lg *zap.Logger
326 tr *Transport
327 peerGetter peerGetter
328 r Raft
329 id types.ID
330 cid types.ID
348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/
H A Dhttp.go350 type streamHandler struct { struct
351 lg *zap.Logger
352 tr *Transport
353 peerGetter peerGetter
354 r Raft
355 id types.ID
356 cid types.ID
370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
/dports/java/icedtea-web/icedtea-web-1.6.2/plugin/icedteanp/java/sun/applet/
H A DPluginMain.java151 PluginStreamHandler streamHandler = connect(args[0], args[1]); in main() local
179 public static void initSecurityContext(PluginStreamHandler streamHandler) { in initSecurityContext()
191 PluginStreamHandler streamHandler = null; in connect() local
262 private static void setCookieHandler(PluginStreamHandler streamHandler) { in setCookieHandler()
/dports/devel/jiic/jiic/de/tu_darmstadt/informatik/rbg/hatlak/iso9660/volumedescriptors/
H A DISO9660VolumeDescriptor.java30 StreamHandler streamHandler; field in ISO9660VolumeDescriptor
34 public ISO9660VolumeDescriptor(StreamHandler streamHandler, int type, LayoutHelper helper) { in ISO9660VolumeDescriptor()

123456