diff options
Diffstat (limited to 'xlators/protocol/lib/src/protocol.c')
| -rw-r--r-- | xlators/protocol/lib/src/protocol.c | 108 | 
1 files changed, 0 insertions, 108 deletions
diff --git a/xlators/protocol/lib/src/protocol.c b/xlators/protocol/lib/src/protocol.c deleted file mode 100644 index 63950f43dec..00000000000 --- a/xlators/protocol/lib/src/protocol.c +++ /dev/null @@ -1,108 +0,0 @@ - -#include "globals.h" -#include "compat.h" -#include "protocol.h" - -char *gf_mop_list[GF_MOP_MAXVALUE]; -char *gf_cbk_list[GF_CBK_MAXVALUE]; - -static int -gf_dirent_nb_size (gf_dirent_t *entries) -{ -	return (sizeof (struct gf_dirent_nb) + strlen (entries->d_name) + 1); -} - -int -gf_dirent_serialize (gf_dirent_t *entries, char *buf, size_t buf_size) -{ -	struct gf_dirent_nb *entry_nb = NULL; -	gf_dirent_t         *entry = NULL; -	int                  size = 0; -	int                  entry_size = 0; - - -	list_for_each_entry (entry, &entries->list, list) { -		entry_size = gf_dirent_nb_size (entry); - -		if (buf && (size + entry_size <= buf_size)) { -			entry_nb = (void *) (buf + size); - -			entry_nb->d_ino  = hton64 (entry->d_ino); -			entry_nb->d_off  = hton64 (entry->d_off); -			entry_nb->d_len  = hton32 (entry->d_len); -			entry_nb->d_type = hton32 (entry->d_type); - -                        gf_stat_from_iatt (&entry_nb->d_stat, &entry->d_stat); - -			strcpy (entry_nb->d_name, entry->d_name); -		} -		size += entry_size; -	} - -	return size; -} - - -int -gf_dirent_unserialize (gf_dirent_t *entries, const char *buf, size_t buf_size) -{ -	struct gf_dirent_nb *entry_nb = NULL; -	int                  remaining_size = 0; -	int                  least_dirent_size = 0; -	int                  count = 0; -	gf_dirent_t         *entry = NULL; -	int                  entry_strlen = 0; -	int                  entry_len = 0; - - -	remaining_size = buf_size; -	least_dirent_size = (sizeof (struct gf_dirent_nb) + 2); - -	while (remaining_size >= least_dirent_size) { -		entry_nb = (void *)(buf + (buf_size - remaining_size)); - -		entry_strlen = strnlen (entry_nb->d_name, remaining_size); -		if (entry_strlen == remaining_size) { -			break; -		} - -		entry_len = sizeof (gf_dirent_t) + entry_strlen + 1; -		entry = GF_CALLOC (1, entry_len, gf_common_mt_gf_dirent_t); -		if (!entry) { -			break; -		} - -		entry->d_ino  = ntoh64 (entry_nb->d_ino); -		entry->d_off  = ntoh64 (entry_nb->d_off); -		entry->d_len  = ntoh32 (entry_nb->d_len); -		entry->d_type = ntoh32 (entry_nb->d_type); - -                gf_stat_to_iatt (&entry_nb->d_stat, &entry->d_stat); - -		strcpy (entry->d_name, entry_nb->d_name); - -		list_add_tail (&entry->list, &entries->list); - -		remaining_size -= (sizeof (*entry_nb) + entry_strlen + 1); -		count++; -	} - -	return count; -} - -int -protocol_common_init (void) -{ -        gf_mop_list[GF_MOP_SETVOLUME]   = "SETVOLUME"; -        gf_mop_list[GF_MOP_GETVOLUME]   = "GETVOLUME"; -        gf_mop_list[GF_MOP_SETSPEC]     = "SETSPEC"; -        gf_mop_list[GF_MOP_GETSPEC]     = "GETSPEC"; -        gf_mop_list[GF_MOP_LOG]         = "LOG"; -        gf_mop_list[GF_MOP_PING]        = "PING"; - -        gf_cbk_list[GF_CBK_FORGET]      = "FORGET"; -        gf_cbk_list[GF_CBK_RELEASE]     = "RELEASE"; -        gf_cbk_list[GF_CBK_RELEASEDIR]  = "RELEASEDIR"; - -        return 0; -}  | 
