Changes in uspace/srv/net/tcp/ncsim.c [257feec:69a93df7] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/tcp/ncsim.c
r257feec r69a93df7 44 44 #include <io/log.h> 45 45 #include <stdlib.h> 46 #include < fibril.h>46 #include <thread.h> 47 47 #include "conn.h" 48 48 #include "ncsim.h" … … 74 74 link_t *link; 75 75 76 log_msg(L OG_DEFAULT, LVL_DEBUG, "tcp_ncsim_bounce_seg()");76 log_msg(LVL_DEBUG, "tcp_ncsim_bounce_seg()"); 77 77 tcp_rqueue_bounce_seg(sp, seg); 78 78 return; … … 80 80 if (0 /*random() % 4 == 3*/) { 81 81 /* Drop segment */ 82 log_msg(L OG_DEFAULT, LVL_ERROR, "NCSim dropping segment");82 log_msg(LVL_ERROR, "NCSim dropping segment"); 83 83 tcp_segment_delete(seg); 84 84 return; … … 87 87 sqe = calloc(1, sizeof(tcp_squeue_entry_t)); 88 88 if (sqe == NULL) { 89 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed allocating SQE.");89 log_msg(LVL_ERROR, "Failed allocating SQE."); 90 90 return; 91 91 } … … 119 119 } 120 120 121 /** Network condition simulator handler fibril. */122 static int tcp_ncsim_fibril(void *arg)121 /** Network condition simulator handler thread. */ 122 static void tcp_ncsim_thread(void *arg) 123 123 { 124 124 link_t *link; … … 126 126 int rc; 127 127 128 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_ncsim_fibril()"); 128 log_msg(LVL_DEBUG, "tcp_ncsim_thread()"); 129 129 130 130 131 while (true) { … … 138 139 sqe = list_get_instance(link, tcp_squeue_entry_t, link); 139 140 140 log_msg(L OG_DEFAULT, LVL_DEBUG, "NCSim - Sleep");141 log_msg(LVL_DEBUG, "NCSim - Sleep"); 141 142 rc = fibril_condvar_wait_timeout(&sim_queue_cv, 142 143 &sim_queue_lock, sqe->delay); … … 146 147 fibril_mutex_unlock(&sim_queue_lock); 147 148 148 log_msg(L OG_DEFAULT, LVL_DEBUG, "NCSim - End Sleep");149 log_msg(LVL_DEBUG, "NCSim - End Sleep"); 149 150 tcp_rqueue_bounce_seg(&sqe->sp, sqe->seg); 150 151 free(sqe); 151 152 } 152 153 /* Not reached */154 return 0;155 153 } 156 154 157 /** Start simulator handler fibril. */158 void tcp_ncsim_ fibril_start(void)155 /** Start simulator handler thread. */ 156 void tcp_ncsim_thread_start(void) 159 157 { 160 fid_t fid; 158 thread_id_t tid; 159 int rc; 161 160 162 log_msg(L OG_DEFAULT, LVL_DEBUG, "tcp_ncsim_fibril_start()");161 log_msg(LVL_DEBUG, "tcp_ncsim_thread_start()"); 163 162 164 fid = fibril_create(tcp_ncsim_fibril, NULL);165 if ( fid == 0) {166 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed creating ncsim fibril.");163 rc = thread_create(tcp_ncsim_thread, NULL, "ncsim", &tid); 164 if (rc != EOK) { 165 log_msg(LVL_ERROR, "Failed creating ncsim thread."); 167 166 return; 168 167 } 169 170 fibril_add_ready(fid);171 168 } 172 169
Note:
See TracChangeset
for help on using the changeset viewer.