transport.h

Go to the documentation of this file.

#ifndef PROTON_TRANSPORT_H
#define PROTON_TRANSPORT_H 1
 
/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */
 
#include <proton/import_export.h>
#include <proton/type_compat.h>
#include <proton/condition.h>
#include <proton/logger.h>
#include <stddef.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef int pn_trace_t;
 
typedef void (*pn_tracer_t)(pn_transport_t *transport, const char *message);
 
#define PN_TRACE_OFF (0)
 
#define PN_TRACE_RAW (1)
 
#define PN_TRACE_FRM (2)
 
#define PN_TRACE_DRV (4)
 
#define PN_TRACE_EVT (8)
 
PN_EXTERN pn_transport_t *pn_transport(void);
 
PN_EXTERN void pn_transport_set_server(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_free(pn_transport_t *transport);
 
PN_EXTERN const char *pn_transport_get_user(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_require_auth(pn_transport_t *transport, bool required);
 
PN_EXTERN bool pn_transport_is_authenticated(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_require_encryption(pn_transport_t *transport, bool required);
 
PN_EXTERN bool pn_transport_is_encrypted(pn_transport_t *transport);
 
PN_EXTERN pn_condition_t *pn_transport_condition(pn_transport_t *transport);
 
PN_EXTERN pn_logger_t *pn_transport_logger(pn_transport_t *transport);
 
PN_EXTERN pn_error_t *pn_transport_error(pn_transport_t *transport);
 
PN_EXTERN int pn_transport_bind(pn_transport_t *transport, pn_connection_t *connection);
 
PN_EXTERN int pn_transport_unbind(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_trace(pn_transport_t *transport, pn_trace_t trace);
 
PN_EXTERN void pn_transport_set_tracer(pn_transport_t *transport, pn_tracer_t tracer);
 
PN_EXTERN pn_tracer_t pn_transport_get_tracer(pn_transport_t *transport);
 
PN_EXTERN void *pn_transport_get_context(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_set_context(pn_transport_t *transport, void *context);
 
PN_EXTERN pn_record_t *pn_transport_attachments(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_log(pn_transport_t *transport, const char *message);
 
PN_EXTERN void pn_transport_vlogf(pn_transport_t *transport, const char *fmt, va_list ap);
 
PN_EXTERN void pn_transport_logf(pn_transport_t *transport, const char *fmt, ...);
 
PN_EXTERN uint16_t pn_transport_get_channel_max(pn_transport_t *transport);
 
PN_EXTERN int pn_transport_set_channel_max(pn_transport_t *transport, uint16_t channel_max);
 
PN_EXTERN uint16_t pn_transport_remote_channel_max(pn_transport_t *transport);
 
PN_EXTERN uint32_t pn_transport_get_max_frame(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_set_max_frame(pn_transport_t *transport, uint32_t size);
 
PN_EXTERN uint32_t pn_transport_get_remote_max_frame(pn_transport_t *transport);
 
PN_EXTERN pn_millis_t pn_transport_get_idle_timeout(pn_transport_t *transport);
 
PN_EXTERN void pn_transport_set_idle_timeout(pn_transport_t *transport, pn_millis_t timeout);
 
PN_EXTERN pn_millis_t pn_transport_get_remote_idle_timeout(pn_transport_t *transport);
 
PN_EXTERN ssize_t pn_transport_input(pn_transport_t *transport, const char *bytes, size_t available);
 
PN_EXTERN ssize_t pn_transport_output(pn_transport_t *transport, char *bytes, size_t size);
 
PN_EXTERN ssize_t pn_transport_capacity(pn_transport_t *transport);
 
PN_EXTERN char *pn_transport_tail(pn_transport_t *transport);
 
PN_EXTERN ssize_t pn_transport_push(pn_transport_t *transport, const char *src, size_t size);
 
PN_EXTERN int pn_transport_process(pn_transport_t *transport, size_t size);
 
PN_EXTERN int pn_transport_close_tail(pn_transport_t *transport);
 
PN_EXTERN ssize_t pn_transport_pending(pn_transport_t *transport);
 
PN_EXTERN const char *pn_transport_head(pn_transport_t *transport);
 
PN_EXTERN ssize_t pn_transport_peek(pn_transport_t *transport, char *dst, size_t size);
 
PN_EXTERN void pn_transport_pop(pn_transport_t *transport, size_t size);
 
PN_EXTERN int pn_transport_close_head(pn_transport_t *transport);
 
PN_EXTERN bool pn_transport_quiesced(pn_transport_t *transport);
 
PN_EXTERN bool pn_transport_head_closed(pn_transport_t *transport);
 
PN_EXTERN bool pn_transport_tail_closed(pn_transport_t *transport);
 
PN_EXTERN bool pn_transport_closed(pn_transport_t *transport);
 
PN_EXTERN int64_t pn_transport_tick(pn_transport_t *transport, int64_t now);
 
PN_EXTERN uint64_t pn_transport_get_frames_output(const pn_transport_t *transport);
 
PN_EXTERN uint64_t pn_transport_get_frames_input(const pn_transport_t *transport);
 
PN_EXTERN pn_connection_t *pn_transport_connection(pn_transport_t *transport);
 
#ifdef __cplusplus
}
#endif
 
#endif /* transport.h */