X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=include%2Fmemcached.h;h=3733b2f10f48df34bdb929e244c9e0ee43e7c3f2;hb=b692aac682b04b2866cfc593513b6cf31c443263;hp=634f8884f0fad2306ff4923a25246315892bf44f;hpb=806525899ce3dff894b829416307a4290cd882e2;p=m6w6%2Flibmemcached

diff --git a/include/memcached.h b/include/memcached.h
index 634f8884..3733b2f1 100644
--- a/include/memcached.h
+++ b/include/memcached.h
@@ -38,6 +38,8 @@ typedef struct memcached_server_st memcached_server_st;
 #define SMALL_STRING_LEN 1024
 #define HUGE_STRING_LEN 8196
 #define MEMCACHED_MAX_KEY 251 /* We add one to have it null terminated */
+//#define MEMCACHED_MAX_BUFFER 8196
+#define MEMCACHED_MAX_BUFFER 8196
 
 typedef enum {
   MEMCACHED_SUCCESS,
@@ -60,6 +62,9 @@ typedef enum {
   MEMCACHED_PARTIAL_READ,
   MEMCACHED_SOME_ERRORS,
   MEMCACHED_NO_SERVERS,
+  MEMCACHED_END,
+  MEMCACHED_DELETED,
+  MEMCACHED_VALUE,
   MEMCACHED_MAXIMUM_RETURN, /* Always add new error code before */
 } memcached_return;
 
@@ -115,12 +120,18 @@ struct memcached_st {
   memcached_server_st *hosts;
   unsigned int number_of_hosts;
   unsigned int cursor_server;
+  char read_buffer[MEMCACHED_MAX_BUFFER];
+  size_t read_buffer_length;
+  char *read_ptr;
+  char write_buffer[MEMCACHED_MAX_BUFFER];
+  size_t write_buffer_offset;
+  size_t write_between_flush;
   char connected;
 };
 
 /* Public API */
-memcached_st *memcached_init(memcached_st *ptr);
-void memcached_deinit(memcached_st *ptr);
+memcached_st *memcached_create(memcached_st *ptr);
+void memcached_free(memcached_st *ptr);
 
 memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_length,
                                   time_t expiration);
@@ -175,6 +186,13 @@ char *memcached_fetch(memcached_st *ptr, char *key, size_t *key_length,
 memcached_return memcached_server_add(memcached_st *ptr, char *hostname, 
                                       unsigned int port);
 
+memcached_server_st *memcached_server_list_append(memcached_server_st *ptr, 
+                                             char *hostname, unsigned int port, 
+                                             memcached_return *error);
+void memcached_server_list_free(memcached_server_st *ptr);
+memcached_return memcached_server_push(memcached_st *ptr, memcached_server_st *list);
+unsigned int memcached_server_list_count(memcached_server_st *ptr);
+
 /* These are all private, do not use. */
 memcached_return memcached_connect(memcached_st *ptr);
 memcached_return memcached_response(memcached_st *ptr, 
@@ -192,7 +210,7 @@ char ** memcached_stat_get_keys(memcached_st *ptr, memcached_stat_st *stat,
 #define memcached_string_size(A, B) B->current_size
 #define memcached_string_value(A, B) B->string
 
-memcached_string_st *memcached_string_init(memcached_st *ptr, size_t initial_size);
+memcached_string_st *memcached_string_create(memcached_st *ptr, size_t initial_size);
 memcached_return memcached_string_append_character(memcached_st *ptr, 
                                                    memcached_string_st *string, 
                                                    char character);
@@ -205,6 +223,8 @@ void memcached_string_free(memcached_st *ptr, memcached_string_st *string);
 /* Some personal debugging functions */
 #define WATCHPOINT printf("WATCHPOINT %s:%d\n", __FILE__, __LINE__);fflush(stdout);
 #define WATCHPOINT_ERROR(A) printf("WATCHPOINT %s:%d %s\n", __FILE__, __LINE__, memcached_strerror(NULL, A));fflush(stdout);
+#define WATCHPOINT_STRING(A) printf("WATCHPOINT %s:%d %s\n", __FILE__, __LINE__, A);fflush(stdout);
+#define WATCHPOINT_NUMBER(A) printf("WATCHPOINT %s:%d %d\n", __FILE__, __LINE__, A);fflush(stdout);
 
 
 #ifdef __cplusplus