diff options
Diffstat (limited to 'src/zs.cpp')
| -rw-r--r-- | src/zs.cpp | 222 |
1 files changed, 0 insertions, 222 deletions
diff --git a/src/zs.cpp b/src/zs.cpp deleted file mode 100644 index ca05db3..0000000 --- a/src/zs.cpp +++ /dev/null @@ -1,222 +0,0 @@ -/* - Copyright (c) 2007-2009 FastMQ Inc. - - This file is part of 0MQ. - - 0MQ is free software; you can redistribute it and/or modify it under - the terms of the Lesser GNU General Public License as published by - the Free Software Foundation; either version 3 of the License, or - (at your option) any later version. - - 0MQ is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - Lesser GNU General Public License for more details. - - You should have received a copy of the Lesser GNU General Public License - along with this program. If not, see <http://www.gnu.org/licenses/>. -*/ - -#include "../include/zs.h" - -#include <errno.h> -#include <stdlib.h> -#include <new> - -#include "i_api.hpp" -#include "err.hpp" -#include "dispatcher.hpp" -#include "msg.hpp" - -int zs_msg_init (zs_msg *msg_) -{ - msg_->content = (zs_msg_content*) ZS_VSM; - msg_->vsm_size = 0; - return 0; -} - -int zs_msg_init_size (zs_msg *msg_, size_t size_) -{ - if (size_ <= ZS_MAX_VSM_SIZE) { - msg_->content = (zs_msg_content*) ZS_VSM; - msg_->vsm_size = (uint16_t) size_; - } - else { - msg_->content = (zs_msg_content*) malloc (sizeof (zs_msg_content) + - size_); - if (!msg_->content) { - errno = ENOMEM; - return -1; - } - msg_->shared = 0; - - msg_->content->data = (void*) (msg_->content + 1); - msg_->content->size = size_; - msg_->content->ffn = NULL; - new (&msg_->content->refcnt) zs::atomic_counter_t (); - } - return 0; -} - -int zs_msg_init_data (zs_msg *msg_, void *data_, size_t size_, zs_free_fn *ffn_) -{ - msg_->shared = 0; - msg_->content = (zs_msg_content*) malloc (sizeof (zs_msg_content)); - zs_assert (msg_->content); - msg_->content->data = data_; - msg_->content->size = size_; - msg_->content->ffn = ffn_; - new (&msg_->content->refcnt) zs::atomic_counter_t (); - return 0; -} - -int zs_msg_close (zs_msg *msg_) -{ - // For VSMs and delimiters there are no resources to free - if (msg_->content == (zs_msg_content*) ZS_DELIMITER || - msg_->content == (zs_msg_content*) ZS_VSM || - msg_->content == (zs_msg_content*) ZS_GAP) - return 0; - - // If the content is not shared, or if it is shared and the reference - // count has dropped to zero, deallocate it. - if (!msg_->shared || !msg_->content->refcnt.sub (1)) { - - // We used "placement new" operator to initialize the reference - // counter so we call its destructor now. - msg_->content->refcnt.~atomic_counter_t (); - - if (msg_->content->ffn) - msg_->content->ffn (msg_->content->data); - free (msg_->content); - } - - return 0; -} - -int zs_msg_move (zs_msg *dest_, zs_msg *src_) -{ - zs_msg_close (dest_); - *dest_ = *src_; - zs_msg_init (src_); - return 0; -} - -int zs_msg_copy (zs_msg *dest_, zs_msg *src_) -{ - zs_msg_close (dest_); - - // VSMs and delimiters require no special handling. - if (src_->content != - (zs_msg_content*) ZS_DELIMITER && - src_->content != (zs_msg_content*) ZS_VSM && - src_->content != (zs_msg_content*) ZS_GAP) { - - // One reference is added to shared messages. Non-shared messages - // are turned into shared messages and reference count is set to 2. - if (src_->shared) - src_->content->refcnt.add (1); - else { - src_->shared = true; - src_->content->refcnt.set (2); - } - } - - *dest_ = *src_; - return 0; -} - -void *zs_msg_data (zs_msg *msg_) -{ - if (msg_->content == (zs_msg_content*) ZS_VSM) - return msg_->vsm_data; - if (msg_->content == - (zs_msg_content*) ZS_DELIMITER || - msg_->content == (zs_msg_content*) ZS_GAP) - return NULL; - return msg_->content->data; -} - -size_t zs_msg_size (zs_msg *msg_) -{ - if (msg_->content == (zs_msg_content*) ZS_VSM) - return msg_->vsm_size; - if (msg_->content == - (zs_msg_content*) ZS_DELIMITER || - msg_->content == (zs_msg_content*) ZS_GAP) - return 0; - return msg_->content->size; -} - -int zs_msg_type (zs_msg *msg_) -{ - // If it's a genuine message, return 0. - if (msg_->content >= (zs_msg_content*) ZS_VSM) - return 0; - - // Trick the compiler to believe that content is an integer. - unsigned char *offset = 0; - return (((const unsigned char*) msg_->content) - offset); -} - -void *zs_init (int app_threads_, int io_threads_) -{ - // There should be at least a single thread managed by the dispatcher. - if (app_threads_ < 0 || io_threads_ < 0 || - app_threads_ + io_threads_ == 0) { - errno = EINVAL; - return NULL; - } - - zs::dispatcher_t *dispatcher = - new zs::dispatcher_t (app_threads_, io_threads_); - zs_assert (dispatcher); - return (void*) dispatcher; -} - -int zs_term (void *context_) -{ - ((zs::dispatcher_t*) context_)->shutdown (); - return 0; -} - -void *zs_socket (void *context_, int type_) -{ - return (void*) (((zs::dispatcher_t*) context_)->create_socket (type_)); -} - -int zs_close (void *s_) -{ - ((zs::i_api*) s_)->close (); - return 0; -} - -int zs_bind (void *s_, const char *addr_, zs_opts *opts_) -{ - return (((zs::i_api*) s_)->bind (addr_, opts_)); -} - -int zs_connect (void *s_, const char *addr_, zs_opts *opts_) -{ - return (((zs::i_api*) s_)->connect (addr_, opts_)); -} - -int zs_subscribe (void *s_, const char *criteria_) -{ - return (((zs::i_api*) s_)->subscribe (criteria_)); -} - -int zs_send (void *s_, zs_msg *msg_, int flags_) -{ - return (((zs::i_api*) s_)->send (msg_, flags_)); -} - -int zs_flush (void *s_) -{ - return (((zs::i_api*) s_)->flush ()); -} - -int zs_recv (void *s_, zs_msg *msg_, int flags_) -{ - return (((zs::i_api*) s_)->recv (msg_, flags_)); -} |