/**
* Copyright (C) 2008 Happy Fish / YuQing
*
* FastDFS may be copied only under the terms of the GNU General
* Public License V3, which may be found in the FastDFS source kit.
* Please visit the FastDFS Home Page http://www.fastken.com/ for more detail.
**/

//storage_global.h

#ifndef _STORAGE_GLOBAL_H
#define _STORAGE_GLOBAL_H

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include "fastcommon/common_define.h"
#include "fastcommon/local_ip_func.h"
#include "fdfs_define.h"
#include "tracker_types.h"
#include "client_global.h"
#include "fdht_types.h"
#include "storage_types.h"

#ifdef WITH_HTTPD
#include "fdfs_http_shared.h"
#endif

#define STORAGE_BEAT_DEF_INTERVAL    30
#define STORAGE_REPORT_DEF_INTERVAL  300
#define STORAGE_DEF_SYNC_WAIT_MSEC   100
#define DEFAULT_DISK_READER_THREADS  1
#define DEFAULT_DISK_WRITER_THREADS  1
#define DEFAULT_SYNC_STAT_FILE_INTERVAL  300
#define DEFAULT_DATA_DIR_COUNT_PER_PATH	 256
#define DEFAULT_UPLOAD_PRIORITY           10
#define FDFS_DEFAULT_SYNC_MARK_FILE_FREQ  500
#define STORAGE_DEFAULT_BUFF_SIZE    (64 * 1024)

#define STORAGE_FILE_SIGNATURE_METHOD_HASH  1
#define STORAGE_FILE_SIGNATURE_METHOD_MD5   2

#ifdef __cplusplus
extern "C" {
#endif

/* subdirs under store path, g_subdir_count * g_subdir_count 2 level subdirs */
extern int g_subdir_count_per_path;

extern int g_http_port;  //http server port
extern int g_last_server_port;
extern int g_last_http_port;  //last http server port
extern char g_http_domain[FDFS_DOMAIN_NAME_MAX_SIZE];  //http server domain name
 
extern bool g_disk_rw_direct;     //if file read / write directly
extern bool g_disk_rw_separated;  //if disk read / write separated
extern int g_disk_reader_threads; //disk reader thread count per store base path
extern int g_disk_writer_threads; //disk writer thread count per store base path
extern int g_disk_recovery_threads; //disk recovery thread count
extern int g_extra_open_file_flags; //extra open file flags

extern int g_file_distribute_path_mode;
extern int g_file_distribute_rotate_count;
extern int g_fsync_after_written_bytes;

extern int g_dist_path_index_high; //current write to high path
extern int g_dist_path_index_low;  //current write to low path
extern int g_dist_write_file_count; //current write file count

extern int g_storage_count;  //stoage server count in my group
extern FDFSStorageServer g_storage_servers[FDFS_MAX_SERVERS_EACH_GROUP];
extern FDFSStorageServer *g_sorted_storages[FDFS_MAX_SERVERS_EACH_GROUP];

extern int g_tracker_reporter_count;
extern int g_heart_beat_interval;
extern int g_stat_report_interval;
extern int g_sync_wait_usec;
extern int g_sync_interval; //unit: milliseconds
extern TimeInfo g_sync_start_time;
extern TimeInfo g_sync_end_time;
extern bool g_sync_part_time; //true for part time, false for all time of a day
extern int g_sync_binlog_buff_interval;
extern int g_write_mark_file_freq;      //write to mark file after sync N files
extern int g_sync_stat_file_interval;   //sync storage stat info to disk interval

extern FDFSStorageStat g_storage_stat;
extern int g_stat_change_count;
extern int g_sync_change_count; //sync src timestamp change counter

extern int g_storage_join_time;  //my join timestamp
extern int g_sync_until_timestamp;
extern bool g_sync_old_done;     //if old files synced to me done
extern char g_sync_src_id[FDFS_STORAGE_ID_MAX_SIZE]; //the source storage server id

extern char g_group_name[FDFS_GROUP_NAME_MAX_LEN + 1];
extern char g_my_server_id_str[FDFS_STORAGE_ID_MAX_SIZE]; //my server id string
extern FDFSMultiIP g_tracker_client_ip; //storage ip as tracker client
extern FDFSMultiIP g_last_storage_ip;	//the last storage ip address

extern LogContext g_access_log_context;

extern in_addr_t g_server_id_in_filename;
extern bool g_store_slave_file_use_link; //if store slave file use symbol link
extern bool g_use_storage_id;  //identify storage by ID instead of IP address
extern byte g_id_type_in_filename; //id type of the storage server in the filename
extern bool g_use_access_log;  //if log to access log
extern bool g_rotate_access_log;  //if rotate the access log every day
extern bool g_compress_old_access_log; //if compress the old access log

extern TimeInfo g_access_log_rotate_time; //rotate access log time base

extern bool g_check_file_duplicate;  //if check file content duplicate
extern byte g_file_signature_method; //file signature method
extern char g_key_namespace[FDHT_MAX_NAMESPACE_LEN+1];
extern int g_namespace_len;

extern int g_allow_ip_count;  /* -1 means match any ip address */
extern in_addr_t *g_allow_ip_addrs;  /* sorted array, asc order */

extern StorageStatusPerTracker *g_my_report_status;  //returned by tracker server

extern bool g_client_bind_addr;
extern bool g_storage_ip_changed_auto_adjust;
extern bool g_thread_kill_done;

extern bool g_file_sync_skip_invalid_record;

extern bool g_check_store_path_mark;
extern bool g_compress_binlog;
extern TimeInfo g_compress_binlog_time;  //compress binlog time base

extern int g_upload_priority;

#ifdef WITH_HTTPD
extern FDFSHTTPParams g_http_params;
extern int g_http_trunk_size;
#endif

#if defined(DEBUG_FLAG) && defined(OS_LINUX)
extern char g_exe_name[256];
#endif

extern int g_compress_access_log_days_before;

extern struct storage_dio_thread_data *g_dio_thread_data;  //disk io thread data

int storage_cmp_by_server_id(const void *p1, const void *p2);

int storage_insert_ip_addr_to_multi_ips(FDFSMultiIP *multi_ip,
        const char *ip_addr, const int ips_limit);

#ifdef __cplusplus
}
#endif

#endif