diff options
| author | Volker Lendecke <vlendec@samba.org> | 2007-01-05 11:18:59 +0000 |
|---|---|---|
| committer | Gerald (Jerry) Carter <jerry@samba.org> | 2007-10-10 12:16:55 -0500 |
| commit | 36f60407ae9b430dc5d7f67dd3e7ed8b1dbc93a8 (patch) | |
| tree | 7518be0a47c8d088765a8542effd841fb84a0c01 /source/smbd/aio.c | |
| parent | 11c6f573af5c1d3387e60f3fc44b00e28cd87813 (diff) | |
| download | samba-36f60407ae9b430dc5d7f67dd3e7ed8b1dbc93a8.tar.gz samba-36f60407ae9b430dc5d7f67dd3e7ed8b1dbc93a8.tar.xz samba-36f60407ae9b430dc5d7f67dd3e7ed8b1dbc93a8.zip | |
r20541: Fix some obvious glitches in wait_for_aio_completion. Hmmm. It seems
reply_close() at its heart is going to be an async call :-)
Volker
Diffstat (limited to 'source/smbd/aio.c')
| -rw-r--r-- | source/smbd/aio.c | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/source/smbd/aio.c b/source/smbd/aio.c index ad25242060e..0abc20ab7d9 100644 --- a/source/smbd/aio.c +++ b/source/smbd/aio.c @@ -580,14 +580,13 @@ int process_aio_queue(void) #define SMB_TIME_FOR_AIO_COMPLETE_WAIT 29 -BOOL wait_for_aio_completion(files_struct *fsp) +int wait_for_aio_completion(files_struct *fsp) { struct aio_extra *aio_ex; const SMB_STRUCT_AIOCB **aiocb_list; int aio_completion_count = 0; time_t start_time = time(NULL); int seconds_left; - int ret = 0; for (seconds_left = SMB_TIME_FOR_AIO_COMPLETE_WAIT; seconds_left >= 0;) { int err = 0; @@ -602,7 +601,7 @@ BOOL wait_for_aio_completion(files_struct *fsp) } if (!aio_completion_count) { - return ret; + return 0; } DEBUG(3,("wait_for_aio_completion: waiting for %d aio events to complete.\n", @@ -610,7 +609,7 @@ BOOL wait_for_aio_completion(files_struct *fsp) aiocb_list = SMB_MALLOC_ARRAY(const SMB_STRUCT_AIOCB *, aio_completion_count); if (!aiocb_list) { - return False; + return ENOMEM; } for( i = 0, aio_ex = aio_list_head; aio_ex; aio_ex = aio_ex->next) { @@ -637,7 +636,7 @@ BOOL wait_for_aio_completion(files_struct *fsp) /* Timeout. */ cancel_aio_by_fsp(fsp); SAFE_FREE(aiocb_list); - return ret ? ret : EIO; + return EIO; } /* One or more events might have completed - process them if so. */ @@ -666,7 +665,7 @@ BOOL wait_for_aio_completion(files_struct *fsp) DEBUG(10,("wait_for_aio_completion: aio_suspend timed out waiting for %d events\n", aio_completion_count)); - return ret ? ret : EIO; + return EIO; } /**************************************************************************** |