mirror of
https://github.com/msgpack/msgpack-c.git
synced 2025-11-04 12:17:38 +01:00
98 lines
2.5 KiB
C
98 lines
2.5 KiB
C
/*
|
|
* MessagePack for C zero-copy buffer implementation
|
|
*
|
|
* Copyright (C) 2008-2009 FURUHASHI Sadayuki
|
|
*
|
|
* Licensed 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.
|
|
*/
|
|
#ifndef MSGPACK_VREFBUFFER_H__
|
|
#define MSGPACK_VREFBUFFER_H__
|
|
|
|
#include "msgpack/zone.h"
|
|
#include <sys/uio.h>
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
|
|
#ifndef MSGPACK_VREFBUFFER_REF_SIZE
|
|
#define MSGPACK_VREFBUFFER_REF_SIZE 32
|
|
#endif
|
|
|
|
#ifndef MSGPACK_VREFBUFFER_CHUNK_SIZE
|
|
#define MSGPACK_VREFBUFFER_CHUNK_SIZE 2048
|
|
#endif
|
|
|
|
typedef struct msgpack_vrefbuffer_chunk {
|
|
size_t free;
|
|
struct msgpack_vrefbuffer_chunk* next;
|
|
/* data ... */
|
|
} msgpack_vrefbuffer_chunk;
|
|
|
|
typedef struct msgpack_vrefbuffer {
|
|
size_t chunk_size;
|
|
size_t ref_size;
|
|
|
|
struct iovec* tail;
|
|
struct iovec* end;
|
|
struct iovec* array;
|
|
|
|
msgpack_vrefbuffer_chunk* chunk;
|
|
} msgpack_vrefbuffer;
|
|
|
|
|
|
bool msgpack_vrefbuffer_init(msgpack_vrefbuffer* vbuf,
|
|
size_t ref_size, size_t chunk_size);
|
|
void msgpack_vrefbuffer_destroy(msgpack_vrefbuffer* vbuf);
|
|
|
|
static inline int msgpack_vrefbuffer_write(void* data, const char* buf, unsigned int len);
|
|
|
|
static inline const struct iovec* msgpack_vrefbuffer_vec(const msgpack_vrefbuffer* vref);
|
|
static inline size_t msgpack_vrefbuffer_veclen(const msgpack_vrefbuffer* vref);
|
|
|
|
int msgpack_vrefbuffer_append_copy(msgpack_vrefbuffer* vbuf,
|
|
const char* buf, unsigned int len);
|
|
|
|
int msgpack_vrefbuffer_append_ref(msgpack_vrefbuffer* vbuf,
|
|
const char* buf, unsigned int len);
|
|
|
|
|
|
int msgpack_vrefbuffer_write(void* data, const char* buf, unsigned int len)
|
|
{
|
|
msgpack_vrefbuffer* vbuf = (msgpack_vrefbuffer*)data;
|
|
|
|
if(len < vbuf->ref_size) {
|
|
return msgpack_vrefbuffer_append_copy(vbuf, buf, len);
|
|
} else {
|
|
return msgpack_vrefbuffer_append_ref(vbuf, buf, len);
|
|
}
|
|
}
|
|
|
|
const struct iovec* msgpack_vrefbuffer_vec(const msgpack_vrefbuffer* vref)
|
|
{
|
|
return vref->array;
|
|
}
|
|
|
|
size_t msgpack_vrefbuffer_veclen(const msgpack_vrefbuffer* vref)
|
|
{
|
|
return vref->tail - vref->array;
|
|
}
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif /* msgpack/vrefbuffer.h */
|
|
|