fanasina/y_project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

y_socket: record file in an other dir

Browse Source
This commit is contained in:
fanasina
2025-10-18 13:44:11 +02:00
parent 760a3bb7c7
commit 807269035d
2 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
y_socket_t/src/y_socket_t/y_file_handler.c
+13 -8
View File
@@ -2,7 +2,10 @@
#include "y_socket_t/y_file_handler.h" #include "y_socket_t/y_file_handler.h"
#define TTL_SOCKDRAM 10 #define TTL_SOCKDRAM 10
#define REPO_LOCAL ".dest"
#define LEN_REPO_LOCAL 6
//#include "y_socket_t/y_node_t.h" //#include "y_socket_t/y_node_t.h"
@@ -787,11 +790,11 @@ void receve_from_node(struct pollfd *fds, struct main_list_y_ptr_HEADER_T *m_hea
//struct js_value *js_cmd_v = get_js_value_of_key("cmd", js_header_v ); //struct js_value *js_cmd_v = get_js_value_of_key("cmd", js_header_v );
//printf("debug: index=[%ld] \n BEGIN file ***\n%s\n END\n",local_current->index,buf_loc); //printf("debug: index=[%ld] \n BEGIN file ***\n%s\n END\n",local_current->index,buf_loc);
if(js_header_v){ if(js_header_v){
/*
struct js_value *js_cmd = get_js_value_of_key("cmd", js_header_v ); struct js_value *js_cmd = get_js_value_of_key("cmd", js_header_v );
if(js_cmd && js_cmd->type.object.value->code_type == jstype_string){ if(js_cmd && js_cmd->type.object.value->code_type == jstype_string){
char * buf_cmd_v = js_cmd->type.object.value->type.string; char * buf_cmd_v = js_cmd->type.object.value->type.string;
*/
struct js_value *js_seq_v = get_js_value_of_key("seq", js_header_v ); struct js_value *js_seq_v = get_js_value_of_key("seq", js_header_v );
char eof=0; char eof=0;
if(js_seq_v){ if(js_seq_v){
@@ -831,9 +834,11 @@ void receve_from_node(struct pollfd *fds, struct main_list_y_ptr_HEADER_T *m_hea
if(local_header){ if(local_header){
struct main_list_y_ptr_MSG_CONTENT_T *m_content_l = local_header->value->m_content_l; struct main_list_y_ptr_MSG_CONTENT_T *m_content_l = local_header->value->m_content_l;
struct list_y_ptr_MSG_CONTENT_T * tmpCnt_l = m_content_l->begin_list; struct list_y_ptr_MSG_CONTENT_T * tmpCnt_l = m_content_l->begin_list;
if(strncmp(buf_cmd_v+5,"file",4)==0){ //if(strncmp(buf_cmd_v+5,"file",4)==0){
int fd_file ; int fd_file ;
if((fd_file = open(tmpCnt_l->value->nameid, O_WRONLY | O_CREAT , char fileNameLocal[tmpCnt_l->value->size_nameid + LEN_REPO_LOCAL + 1];
sprintf(fileNameLocal, "%s/%s",REPO_LOCAL,tmpCnt_l->value->nameid);
if((fd_file = open(fileNameLocal, O_WRONLY | O_CREAT ,
S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)) == -1){ S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)) == -1){
fprintf(stderr,"erreur write %s\n",tmpCnt_l->value->nameid); fprintf(stderr,"erreur write %s\n",tmpCnt_l->value->nameid);
break;//return NULL; break;//return NULL;
@@ -846,7 +851,7 @@ void receve_from_node(struct pollfd *fds, struct main_list_y_ptr_HEADER_T *m_hea
tmpCnt_l=tmpCnt_l->next; tmpCnt_l=tmpCnt_l->next;
} }
close(fd_file); close(fd_file);
} //}
struct list_y_ptr_HEADER_T * l_head_to_remove = pull_index_from_list_y_ptr_HEADER_T(m_head_l_t, local_header->index); struct list_y_ptr_HEADER_T * l_head_to_remove = pull_index_from_list_y_ptr_HEADER_T(m_head_l_t, local_header->index);
free_y_ptr_HEADER_T(l_head_to_remove->value); free_y_ptr_HEADER_T(l_head_to_remove->value);
free(l_head_to_remove); free(l_head_to_remove);
@@ -886,10 +891,10 @@ void receve_from_node(struct pollfd *fds, struct main_list_y_ptr_HEADER_T *m_hea
printf("debug: \n NNNNNNNNNNNNNNNNOOOOOOOOOOOOOSSSSSSSSSSSSSSSEEEEEEEEEEEEEEQQQQQQQQQQQQQ :type header : %d \n",js_header_v->code_type); printf("debug: \n NNNNNNNNNNNNNNNNOOOOOOOOOOOOOSSSSSSSSSSSSSSSEEEEEEEEEEEEEEQQQQQQQQQQQQQ :type header : %d \n",js_header_v->code_type);
}*/ }*/
}else{ /*}else{
printf("debug: \n NO CMD :type header : %d \n",js_header_v->code_type); printf("debug: \n NO CMD :type header : %d \n",js_header_v->code_type);
} }*/
free_js_value(js_header_v); free_js_value(js_header_v);
}else{ }else{
printf("\ndebug NULLL JS___HHHEADER_V \n"); printf("\ndebug NULLL JS___HHHEADER_V \n");
y_socket_t/test/is_good.c
+2 -2
View File
@@ -165,12 +165,12 @@ TEST(searchNode){
TEST(import_nodes){ TEST(import_nodes){
struct main_list_y_NODE_T * listNodes = create_var_list_y_NODE_T(); struct main_list_y_NODE_T * listNodes = create_var_list_y_NODE_T();
char *file_nodes_name = "FILE_NODES"; char *file_nodes_name = ".dest/.FILE_NODES";
if(import_nodes_from_file(file_nodes_name, 1600, listNodes)==-1){ if(import_nodes_from_file(file_nodes_name, 1600, listNodes)==-1){
LOG("something wrong check file %s\n",file_nodes_name); LOG("something wrong check file %s\n",file_nodes_name);
} }
export_nodes_to_file("CPY_file_nodes_name", listNodes); export_nodes_to_file(".dest/.CPY_file_nodes_name", listNodes);
free_all_var_list_y_NODE_T(listNodes); free_all_var_list_y_NODE_T(listNodes);