Lines Matching refs:stream_fd
169 poll_fd_t stream_fd; /* replication channel */ member
734 tapdisk_server_unregister_event(s->stream_fd.id); in close_stream_fd()
735 close(s->stream_fd.fd); in close_stream_fd()
736 s->stream_fd.fd = -2; in close_stream_fd()
773 state->stream_fd.fd = fd; in primary_do_connect()
774 state->stream_fd.id = id; in primary_do_connect()
825 state->stream_fd.fd = fd; in primary_blocking_connect()
826 state->stream_fd.id = id; in primary_blocking_connect()
855 if(s->stream_fd.fd == -1) { in primary_queue_write()
863 if (mwrite(s->stream_fd.fd, TDREMUS_WRITE, strlen(TDREMUS_WRITE)) < 0) in primary_queue_write()
865 if (mwrite(s->stream_fd.fd, header, sizeof(header)) < 0) in primary_queue_write()
868 if (mwrite(s->stream_fd.fd, treq.buf, treq.secs * driver->info.sector_size) < 0) in primary_queue_write()
889 if (s->stream_fd.fd == -1) in client_flush()
893 if (mwrite(s->stream_fd.fd, TDREMUS_COMMIT, strlen(TDREMUS_COMMIT)) < 0) { in client_flush()
924 s->stream_fd.fd = -1; in primary_start()
925 s->stream_fd.id = -1; in primary_start()
936 if (connect(s->stream_fd.fd, (struct sockaddr *)&s->sa, sizeof(s->sa)) in remus_retry_connect_event()
942 tapdisk_server_unregister_event(s->stream_fd.id); in remus_retry_connect_event()
943 …if((id = tapdisk_server_register_event(SCHEDULER_POLL_TIMEOUT, s->stream_fd.fd, REMUS_CONNRETRY_TI… in remus_retry_connect_event()
947 s->stream_fd.id = id; in remus_retry_connect_event()
960 tapdisk_server_unregister_event(s->stream_fd.id); in remus_retry_connect_event()
961 …if((id = tapdisk_server_register_event(SCHEDULER_POLL_WRITE_FD, s->stream_fd.fd, 0, remus_connect_… in remus_retry_connect_event()
965 s->stream_fd.id = id; in remus_retry_connect_event()
979 if (getsockopt(s->stream_fd.fd, SOL_SOCKET, SO_ERROR, &socket_errno, &socket_errno_size)) { in remus_connect_event()
994 tapdisk_server_unregister_event(s->stream_fd.id); in remus_connect_event()
995 …if((id = tapdisk_server_register_event(SCHEDULER_POLL_TIMEOUT, s->stream_fd.fd, REMUS_CONNRETRY_TI… in remus_connect_event()
999 s->stream_fd.id = id; in remus_connect_event()
1011 tapdisk_server_unregister_event(s->stream_fd.id); in remus_connect_event()
1012 …if((id = tapdisk_server_register_event(SCHEDULER_POLL_READ_FD, s->stream_fd.fd, 0, remus_client_ev… in remus_connect_event()
1016 s->stream_fd.id = id; in remus_connect_event()
1032 if (mread(s->stream_fd.fd, req, sizeof(req) - 1) < 0) { in remus_client_event()
1060 int stream_fd; in remus_server_accept() local
1064 if ((stream_fd = accept(s->server_fd.fd, NULL, NULL)) < 0) { in remus_server_accept()
1074 cid = tapdisk_server_register_event(SCHEDULER_POLL_READ_FD, stream_fd, 0, in remus_server_accept()
1079 close(stream_fd); in remus_server_accept()
1084 s->stream_fd.fd = stream_fd; in remus_server_accept()
1085 s->stream_fd.id = cid; in remus_server_accept()
1210 if (mread(s->stream_fd.fd, header, sizeof(header)) < 0) in server_do_wreq()
1224 if (mread(s->stream_fd.fd, buf, len) < 0) in server_do_wreq()
1260 if (write(s->stream_fd.fd, TDREMUS_DONE, strlen(TDREMUS_DONE)) != 4) in server_do_creq()
1279 if (mread(s->stream_fd.fd, req, sizeof(req) - 1) < 0) { in remus_server_event()
1650 s->stream_fd.fd = -1; in tdremus_open()
1702 if (s->stream_fd.fd >= 0) in tdremus_close()